You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
/// <#= String.Format("Data access base class for {0}Entity", table.DisplayName) #>
@@ -111,60 +111,64 @@ WHERE <#= table.PrimaryKeyColumns.Select(m => String.Format("{0}=@{0}", m.Name))
111
111
112
112
public virtual Boolean Exists(<#= table.PrimaryKeyColumns.Select(m => String.Format("{0} {1}", m.TypeName, m.Name)).Aggregate((a, b) => a + ", " + b) #>)
113
113
{
114
-
var cmd = DatabaseObject.GetSqlStringCommand(Exists_<#= table.DisplayName #>_Sql);
public virtual Int32 Add(<#= entClassName #> entity)
@@ -174,20 +178,21 @@ WHERE <#= table.PrimaryKeyColumns.Select(m => String.Format("{0}=@{0}", m.Name))
174
178
{
175
179
#>
176
180
var isAutoGetNewId = entity.<#= pkCol.PascalCase #> == default(<#= pkTypeName #>);
177
-
var cmd = DatabaseObject.GetSqlStringCommand(Insert_<#= table.DisplayName #>_Sql) as MySqlCommand;
178
-
179
-
var pkParam = new MySqlParameter("<#= pkCol.Name #>", MySqlDbType.<#= MySqlTypeConverter.AsMySqlDbType(pkCol.RawType).ToString() #>) { Value = entity.<#= pkCol.PascalCase #>, Direction = ParameterDirection.Input };
180
-
cmd.Parameters.Add(pkParam);
181
-
var nonKeyParams = BuildParametersForNonKey(entity);
182
-
cmd.Parameters.AddRange(nonKeyParams);
183
-
184
-
var execResult = DataContextObject.ExecuteNonQuery(cmd);
185
-
if(isAutoGetNewId && cmd.LastInsertedId > 0)
181
+
using(var cmd = DatabaseObject.GetSqlStringCommand(Insert_<#= table.DisplayName #>_Sql) as MySqlCommand)
var pkParam = new MySqlParameter("<#= pkCol.Name #>", MySqlDbType.<#= MySqlTypeConverter.AsMySqlDbType(pkCol.RawType).ToString() #>) { Value = entity.<#= pkCol.PascalCase #>, Direction = ParameterDirection.Input };
184
+
cmd.Parameters.Add(pkParam);
185
+
var nonKeyParams = BuildParametersForNonKey(entity);
186
+
cmd.Parameters.AddRange(nonKeyParams);
187
+
188
+
var execResult = DataContextObject.ExecuteNonQuery(cmd);
@@ -203,10 +208,12 @@ WHERE <#= table.PrimaryKeyColumns.Select(m => String.Format("{0}=@{0}", m.Name))
203
208
204
209
public virtual Int32 Add(DbParameter[] @parameters)
205
210
{
206
-
var cmd = DatabaseObject.GetSqlStringCommand(Insert_<#= table.DisplayName #>_Sql) as MySqlCommand;
207
-
cmd.Parameters.AddRange(@parameters);
211
+
using(var cmd = DatabaseObject.GetSqlStringCommand(Insert_<#= table.DisplayName #>_Sql) as MySqlCommand)
212
+
{
213
+
cmd.Parameters.AddRange(@parameters);
208
214
209
-
return DataContextObject.ExecuteNonQuery(cmd);
215
+
return DataContextObject.ExecuteNonQuery(cmd);
216
+
}
210
217
}
211
218
212
219
public virtual Int32 Add(IEnumerable<<#= entClassName #>> list)
@@ -226,11 +233,13 @@ WHERE <#= table.PrimaryKeyColumns.Select(m => String.Format("{0}=@{0}", m.Name))
226
233
index++;
227
234
}
228
235
var sql = InsertIntoClause + string.Join(",", valueClauses) + ";";
229
-
var cmd = DatabaseObject.GetSqlStringCommand(sql) as MySqlCommand;
230
-
var @parameters = BuildParameters(list);
231
-
cmd.Parameters.AddRange(@parameters);
236
+
using(var cmd = DatabaseObject.GetSqlStringCommand(sql) as MySqlCommand)
237
+
{
238
+
var @parameters = BuildParameters(list);
239
+
cmd.Parameters.AddRange(@parameters);
232
240
233
-
return DataContextObject.ExecuteNonQuery(cmd);
241
+
return DataContextObject.ExecuteNonQuery(cmd);
242
+
}
234
243
}
235
244
236
245
public virtual Int32 Update(<#= entClassName #> entity)
@@ -242,10 +251,12 @@ WHERE <#= table.PrimaryKeyColumns.Select(m => String.Format("{0}=@{0}", m.Name))
242
251
243
252
public virtual Int32 Update(DbParameter[] @parameters)
244
253
{
245
-
var cmd = DatabaseObject.GetSqlStringCommand(Update_<#= table.DisplayName #>_Sql) as MySqlCommand;
246
-
cmd.Parameters.AddRange(@parameters);
254
+
using(var cmd = DatabaseObject.GetSqlStringCommand(Update_<#= table.DisplayName #>_Sql) as MySqlCommand)
255
+
{
256
+
cmd.Parameters.AddRange(@parameters);
247
257
248
-
return DataContextObject.ExecuteNonQuery(cmd);
258
+
return DataContextObject.ExecuteNonQuery(cmd);
259
+
}
249
260
}
250
261
251
262
public virtual Int32 Save(<#= entClassName #> entity)
@@ -268,10 +279,12 @@ WHERE <#= table.PrimaryKeyColumns.Select(m => String.Format("{0}=@{0}", m.Name))
268
279
269
280
public virtual Int32 Save(DbParameter[] @parameters)
270
281
{
271
-
var cmd = DatabaseObject.GetSqlStringCommand(Save_<#= table.DisplayName #>_Sql) as MySqlCommand;
272
-
cmd.Parameters.AddRange(@parameters);
282
+
using(var cmd = DatabaseObject.GetSqlStringCommand(Save_<#= table.DisplayName #>_Sql) as MySqlCommand)
283
+
{
284
+
cmd.Parameters.AddRange(@parameters);
273
285
274
-
return DataContextObject.ExecuteNonQuery(cmd);
286
+
return DataContextObject.ExecuteNonQuery(cmd);
287
+
}
275
288
}
276
289
277
290
public virtual Int32 Delete(<#= entClassName #> entity)
@@ -283,26 +296,29 @@ WHERE <#= table.PrimaryKeyColumns.Select(m => String.Format("{0}=@{0}", m.Name))
283
296
284
297
public virtual Int32 Delete(<#= table.PrimaryKeyColumns.Select(m => String.Format("{0} {1}", m.TypeName, m.Name)).Aggregate((a, b) => a + ", " + b) #>)
285
298
{
286
-
var cmd = DatabaseObject.GetSqlStringCommand(Delete_<#= table.DisplayName #>_Sql);
0 commit comments