|
n.Connection;
270 _Command.CommandText = argument_SqlText;
271 _Command.CommandType = CommandType.Text;
272 if (null != argument_Parameters)
273 {
274 _Command.Parameters.AddRange(argument_Parameters);
275 }
276
277 try
278 {
279 _CommandResult = _Command.ExecuteNonQuery();
280 _Transaction.Commit();
281 }
282 catch (Exception)
283 {
284 _Transaction.Rollback();
285 }
286
287 OperationValue _Value = new OperationValue();
288 _Value.Value = _CommandResult;
289
290 return _Value;
291 }
292
293 public OperationValue Modify(string argument_SqlText, DbParameter[] argument_Parameters)
294 {
295 this.Connection.Open();
296 int _CommandResult = 0;
297 DbCommand _Command = this.Connection.DatabaseProvide.Factory.CreateCommand();
298 _Command.Connection = this.Connection.Connection;
299 _Command.CommandText = argument_SqlText;
300 _Command.CommandType = CommandType.Text;
301 if (null != argument_Parameters)
302 {
303 _Command.Parameters.AddRange(argument_Parameters);
304 }
305
306 try
307 {
308 _CommandResult = _Command.ExecuteNonQuery();
309 }
310 catch (Exception)
311 {
312 }
313
314 OperationValue _Value = new OperationValue();
315 _Value.Value = _CommandResult;
316
317 return _Value;
318 }
319
320 public OperationValue Modify(string argument_SqlText, DbTransaction argument_Transaction, DbParameter[] argument_Parameters)
321 {
322 this.Connection.Open();
323 int _CommandResult = 0;
324 DbCommand _Command = this.Connection.DatabaseProvide.Factory.CreateCommand();
325 DbTransaction _Transaction = argument_Transaction;
326 _Command.Transaction = _Transaction;
327 _Command.Connection = this.Connection.Connection;
328 _Command.CommandText = argument_SqlText;
329 _Command.CommandType = CommandType.Text;
330 if (null != argument_Parameters)
331 {
332 _Command.Parameters.AddRange(argument_Parameters);
333 }
334
335 try
336 {
337 _CommandResult = _Command.ExecuteNonQuery();
338 //_Transaction.Commit();
339 }
340 catch (Exception)
341 {
342 _Transaction.Rollback();
343 }
344
345 OperationValue _Value = new OperationValue();
346 _Value.Value = _CommandResult;
347
348 return _Value;
349 }
350 }
?
?
?
1 public sealed class DatabaseCommandProcedure : IDatabaseCommandProcedure
2 {
3 public DatabaseCommandProcedure(DatabaseConnection argument_Connection)
4 {
5 this.Connection = argument_Connection;
6 }
7
8 public DatabaseConnection Connection { get; private set; }
9 public string CommandName { get; set; }
10
11 public DbParameter NewParameter()
12 {
13 return this.Connection.DatabaseProvide.Factory.CreateParameter();
14 }
15
16 public DbParameter NewParameter(string argument_ParameterName, object argument_Value, DbType argument_DbType, ParameterDirection Direction)
17 {
18 DbParameter _Parameter = this.Connection.DatabaseProvide.Factory.CreateParameter();
19 _Parameter.ParameterName = argument_ParameterName;
20 _Parameter.Value = argument_Value;
21 _Parameter.DbType = argument_DbType;
22 _Parameter.Direction = Direction;
23 return _Parameter;
24 }
25
26 public OperationValue Query(string argument_ProcedureName, DbParameter[] argument_Parameters)
27 {
28 this.Connection.Open();
|