1 public partial classModifyRecordManager : BaseManager, IBaseManager2 {3 ///

4 ///构造函数5 ///

6 publicModifyRecordManager()7 {8 if (base.dbHelper == null)9 {10 base.dbHelper =DbHelperFactory.GetHelper(BaseSystemInfo.BusinessDbType, BaseSystemInfo.BusinessDbConnection);11 }12 if (string.IsNullOrEmpty(base.CurrentTableName))13 {14 base.CurrentTableName =ZTO_QUOTE_MODIFYRECORDEntity.TableName;15 }16 base.PrimaryKey = "Id";17 }18

19 ///

20 ///构造函数21 /// 指定表名

22 ///

23 public ModifyRecordManager(stringtableName)24 {25 base.CurrentTableName =tableName;26 }27

28 ///

29 ///构造函数30 ///

31 /// 数据库连接

32 publicModifyRecordManager(IDbHelper dbHelper)33 : this()34 {35 DbHelper =dbHelper;36 }37

38 ///

39 ///构造函数40 ///

41 /// 用户信息

42 publicModifyRecordManager(BaseUserInfo userInfo)43 : this()44 {45 UserInfo =userInfo;46 }47

48 ///

49 ///构造函数50 ///

51 /// 用户信息

52 /// 指定表名

53 public ModifyRecordManager(BaseUserInfo userInfo, stringtableName)54 : this(userInfo)55 {56 base.CurrentTableName =tableName;57 }58

59 ///

60 ///构造函数61 ///

62 /// 数据库连接

63 /// 用户信息

64 publicModifyRecordManager(IDbHelper dbHelper, BaseUserInfo userInfo)65 : this(dbHelper)66 {67 UserInfo =userInfo;68 }69

70 ///

71 ///构造函数72 ///

73 /// 数据库连接

74 /// 用户信息

75 /// 指定表名

76 public ModifyRecordManager(IDbHelper dbHelper, BaseUserInfo userInfo, stringtableName)77 : this(dbHelper, userInfo)78 {79 base.CurrentTableName =tableName;80 }81

82 ///

83 ///添加, 这里可以人工干预，提高程序的性能84 ///

85 /// 实体

86 /// 自增量方式，表主键是否采用自增的策略

87 /// 返回主键，不返回程序允许速度会快，主要是为了主细表批量插入数据优化用的

88 /// 主键

89 public string Add(ZTO_QUOTE_MODIFYRECORDEntity entity, bool identity = true, bool returnId = true)90 {91 this.Identity =identity;92 this.ReturnId =returnId;93 entity.Id = int.Parse(this.AddObject(entity));94 returnentity.Id.ToString();95 }96

97 ///

98 ///更新99 ///

100 /// 实体

101 public intUpdate(ZTO_QUOTE_MODIFYRECORDEntity entity)102 {103 return this.UpdateObject(entity);104 }105

106 ///

107 ///获取实体108 ///

109 /// 主键

110 public ZTO_QUOTE_MODIFYRECORDEntity GetObject(stringid)111 {112 return GetObject(int.Parse(id));113 }114

115 public ZTO_QUOTE_MODIFYRECORDEntity GetObject(intid)116 {117 return BaseEntity.Create(this.GetDataTable(new KeyValuePair(this.PrimaryKey, id)));118 }119

120 ///

121 ///添加实体122 ///

123 /// 实体

124 public stringAddObject(ZTO_QUOTE_MODIFYRECORDEntity entity)125 {126 string key = string.Empty;127 SQLBuilder sqlBuilder = new SQLBuilder(DbHelper, this.Identity, this.ReturnId);128 sqlBuilder.BeginInsert(this.CurrentTableName, this.PrimaryKey);129 if (!this.Identity)130 {131 //这里已经是指定了主键了，所以不需要返回主键了

132 sqlBuilder.ReturnId = false;133 sqlBuilder.SetValue(this.PrimaryKey, entity.Id);134 }135 else

136 {137 if (!this.ReturnId && (DbHelper.CurrentDbType == CurrentDbType.Oracle || DbHelper.CurrentDbType ==CurrentDbType.DB2))138 {139 if (DbHelper.CurrentDbType ==CurrentDbType.Oracle)140 {141 sqlBuilder.SetFormula(this.PrimaryKey, "SEQ_" + this.CurrentTableName.ToUpper() + ".NEXTVAL");142 }143 if (DbHelper.CurrentDbType ==CurrentDbType.DB2)144 {145 sqlBuilder.SetFormula(this.PrimaryKey, "NEXT VALUE FOR SEQ_" + this.CurrentTableName.ToUpper());146 }147 }148 else

149 {150 if (this.Identity && (DbHelper.CurrentDbType == CurrentDbType.Oracle || DbHelper.CurrentDbType ==CurrentDbType.DB2))151 {152 BaseSequenceManager sequenceManager = newBaseSequenceManager(DbHelper);153 entity.Id = int.Parse(sequenceManager.Increment(this.CurrentTableName));154 sqlBuilder.SetValue(this.PrimaryKey, entity.Id);155 }156 }157 }158 this.SetObject(sqlBuilder, entity);159 if (UserInfo != null)160 {161 sqlBuilder.SetValue(ZTO_QUOTE_MODIFYRECORDEntity.FieldCreateUserId, UserInfo.Id);162 sqlBuilder.SetValue(ZTO_QUOTE_MODIFYRECORDEntity.FieldCreateBy, UserInfo.RealName);163 }164 sqlBuilder.SetDBNow(ZTO_QUOTE_MODIFYRECORDEntity.FieldCreateOn);165 if (this.Identity && (DbHelper.CurrentDbType == CurrentDbType.SqlServer || DbHelper.CurrentDbType ==CurrentDbType.Access))166 {167 key =sqlBuilder.EndInsert().ToString();168 }169 else

170 {171 sqlBuilder.EndInsert();172 }173 if (this.Identity && (DbHelper.CurrentDbType == CurrentDbType.Oracle || DbHelper.CurrentDbType ==CurrentDbType.DB2))174 {175 returnentity.Id.ToString();176 }177 returnkey;178 }179

180 ///

181 ///更新实体182 ///

183 /// 实体

184 public intUpdateObject(ZTO_QUOTE_MODIFYRECORDEntity entity)185 {186 SQLBuilder sqlBuilder = newSQLBuilder(DbHelper);187 sqlBuilder.BeginUpdate(this.CurrentTableName);188 this.SetObject(sqlBuilder, entity);189 sqlBuilder.SetWhere(this.PrimaryKey, entity.Id);190 returnsqlBuilder.EndUpdate();191 }192

193 //这个是声明扩展方法

194 partial voidSetObjectExpand(SQLBuilder sqlBuilder, ZTO_QUOTE_MODIFYRECORDEntity entity);195

196 ///

197 ///设置实体198 ///

199 /// 实体

200 private voidSetObject(SQLBuilder sqlBuilder, ZTO_QUOTE_MODIFYRECORDEntity entity)201 {202 SetObjectExpand(sqlBuilder, entity);203 sqlBuilder.SetValue(ZTO_QUOTE_MODIFYRECORDEntity.FieldNEWKEY, entity.NEWKEY);204 sqlBuilder.SetValue(ZTO_QUOTE_MODIFYRECORDEntity.FieldNEWVALUE, entity.NEWVALUE);205 sqlBuilder.SetValue(ZTO_QUOTE_MODIFYRECORDEntity.FieldCOLUMNDESCRIPTION, entity.COLUMNDESCRIPTION);206 sqlBuilder.SetValue(ZTO_QUOTE_MODIFYRECORDEntity.FieldOLDKEY, entity.OLDKEY);207 sqlBuilder.SetValue(ZTO_QUOTE_MODIFYRECORDEntity.FieldOLDVALUE, entity.OLDVALUE);208 sqlBuilder.SetValue(ZTO_QUOTE_MODIFYRECORDEntity.FieldRECORDKEY, entity.RECORDKEY);209 sqlBuilder.SetValue(ZTO_QUOTE_MODIFYRECORDEntity.FieldCOLUMNCODE, entity.COLUMNCODE);210 sqlBuilder.SetValue(ZTO_QUOTE_MODIFYRECORDEntity.FieldTABLEDESCRIPTION, entity.TABLEDESCRIPTION);211 sqlBuilder.SetValue(ZTO_QUOTE_MODIFYRECORDEntity.FieldTABLECODE, entity.TABLECODE);212 }213

214 ///

215 ///删除实体216 ///

217 /// 主键

218 /// 影响行数

219 public int Delete(intid)220 {221 return this.Delete(new KeyValuePair(this.PrimaryKey, id));222 }223 }