我与ADO.NET二三事(七)
29 DataTable _QueryTable = new DataTable();
30 DbCommand _Command = this.Connection.DatabaseProvide.Factory.CreateCommand();
31 _Command.Connection = this.Connection.Connection;
32 _Command.CommandText = argument_ProcedureName;
33 _Command.CommandType = CommandType.StoredProcedure;
34 if (null != argument_Parameters)
35 {
36 _Command.Parameters.AddRange(argument_Parameters);
37 }
38
39 DbDataReader _Reader = _Command.ExecuteReader();
40 _QueryTable.Load(_Reader);
41 _Reader.Close();
42 OperationValue _Value = new OperationValue();
43 _Value.Value = _QueryTable;
44 return _Value;
45 }
46
47 public OperationValue ExecuteNonQuery(string argument_ProcedureName, DbParameter[] argument_Parameters)
48 {
49 this.Connection.Open();
50 int _CommandResult = 0;
51 DbCommand _Command = this.Connection.DatabaseProvide.Factory.CreateCommand();
52 _Command.Connection = this.Connection.Connection;
53 _Command.CommandText = argument_ProcedureName;
54 _Command.CommandType = CommandType.StoredProcedure;
55 if (null != argument_Parameters)
56 {
57 _Command.Parameters.AddRange(argument_Parameters);
58 }
59
60 _CommandResult = _Command.ExecuteNonQuery();
61 OperationValue _Value = new OperationValue();
62 _Value.Value = _CommandResult;
63 return _Value;
64 }
65 }
以上提供的接口操作：
1 public interface IDatabaseCommandTextProvide
2 {
3 string CommandName { get; set; }
4 DatabaseConnection Connection { get; }
5 DbParameter
NewParameter();
6 DbParameter NewParameter(string argument_ParameterName, object argument_Value, DbType argument_DbType, ParameterDirection Direction);
7 OperationValue Query(string argument_SqlText, DbParameter[] argument_Parameters);
8 OperationValue Query(string argument_SqlText, DbTransaction argument_Transaction, DbParameter[] argument_Parameters);
9 DataTableReader Reader(string argument_SqlText, DbParameter[] argument_Parameters);
10 OperationValue TransactionSave(string argument_SqlText, DbParameter[] argument_Parameters);
11 OperationValue Save(string argument_SqlText, DbParameter[] argument_Parameters);
12 OperationValue Save(string argument_SqlText, DbTransaction argument_Transaction, DbParameter[] argument_Parameters);
13 OperationValue TransactionModify(string argument_SqlText , DbParameter[] argument_Parameters);
14 OperationValue Modify(string argument_SqlText, DbParameter[] argument_Parameters);
15 OperationValue Modify(string argument_SqlText, DbTransaction argument_Transaction, DbParameter[] argument_Parameters);
16 OperationValue TransactionDelete(string argument_SqlText, DbParameter[] argument_Parameters);
17 OperationValue Delete(string argument_SqlText, DbParameter[] argument_Parameters);
18 OperationValue Delete(string argument_SqlText, DbTransaction argument_Transaction, DbParameter[] argument_Parameters);
19 }
1 public interface IDatabaseCommandProcedure
2 {
3 string CommandName { get; set; }
4 DatabaseConnection Connection { get; }
5 OperationValue Query(string argument_ProcedureName, DbParameter[] argument_Parameters);
6 OperationValue ExecuteNonQuery(string argument_ProcedureName, DbParameter[] argument_Parameters);
7 DbParameter NewParameter();
8 DbParameter Ne