|
alue();
214 _Value.Value = _QueryTable;
215 return _Value;
216 }
217
218 public async Task SaveAsync(string argument_SqlText, DbParameter[] argument_Parameters)
219 {
220 this.Connection.Open();
221 int _CommandResult = 0;
222 DbCommand _Command = this.Connection.DatabaseProvide.Factory.CreateCommand();
223 _Command.Connection = this.Connection.Connection;
224 _Command.CommandText = argument_SqlText;
225 _Command.CommandType = CommandType.Text;
226 if (null != argument_Parameters)
227 {
228 _Command.Parameters.AddRange(argument_Parameters);
229 }
230
231 try
232 {
233 _CommandResult = await _Command.ExecuteNonQueryAsync();
234 }
235 catch (Exception)
236 {
237 }
238
239 OperationValue _Value = new OperationValue();
240 _Value.Value = _CommandResult;
241 return _Value;
242 }
243
244 public async Task SaveAsync(string argument_SqlText, DbTransaction argument_Transaction, DbParameter[] argument_Parameters)
245 {
246 this.Connection.Open();
247 int _CommandResult = 0;
248 DbCommand _Command = this.Connection.DatabaseProvide.Factory.CreateCommand();
249 _Command.Connection = this.Connection.Connection;
250 DbTransaction _Transaction = argument_Transaction;
251 _Command.Transaction = _Transaction;
252 _Command.CommandText = argument_SqlText;
253 _Command.CommandType = CommandType.Text;
254 if (null != argument_Parameters)
255 {
256 _Command.Parameters.AddRange(argument_Parameters);
257 }
258
259 try
260 {
261 _CommandResult = await _Command.ExecuteNonQueryAsync();
262 //_Transaction.Commit();
263 }
264 catch (Exception)
265 {
266 _Transaction.Rollback();
267 }
268
269 OperationValue _Value = new OperationValue();
270 _Value.Value = _CommandResult;
271 return _Value;
272 }
273
274 public async Task TransactionDeleteAsync(string argument_SqlText, DbParameter[] argument_Parameters)
275 {
276 int _CommandResult = 0;
277 DbCommand _Command = this.Connection.DatabaseProvide.Factory.CreateCommand();
278 DbTransaction _Transaction = this.Connection.Connection.BeginTransaction();
279 _Command.Connection = this.Connection.Connection;
280 _Command.Transaction = _Transaction;
281 _Command.CommandText = argument_SqlText;
282 _Command.CommandType = CommandType.Text;
283 if (null != argument_Parameters)
284 {
285 _Command.Parameters.AddRange(argument_Parameters);
286 }
287
288 try
289 {
290 this.Connection.Open();
291 _CommandResult = await _Command.ExecuteNonQueryAsync();
292 _Transaction.Commit();
293 }
294 catch (Exception)
295 {
296 _Transaction.Rollback();
297 }
298
299 OperationValue _Value = new OperationValue();
300 _Value.Value = _CommandResult;
301
302 return _Value;
303 }
304
305 public async Task TransactionModifyAsync(string argument_SqlText, DbParameter[] argument_Parameters)
306 {
307 this.Connection.Open();
308 int _CommandResult = 0;
309 DbCommand _Command = this.Connection.DatabaseProvide.Factory.CreateCommand();
310 DbTransaction _Transaction = this.Connection.Connection.BeginTransaction();
311 _Command.Transaction = _Transaction;
312 _Command.Connection = this.Connection.Connection;
313 _Command.CommandText = argument_SqlText;
314 _Command.CommandType = CommandType.Te |