|
ument_Parameters);
67 }
68
69 try
70 {
71 this.Connection.Open();
72 _CommandResult = _Command.ExecuteNonQuery();
73 }
74 catch (Exception)
75 {
76 }
77
78 OperationValue _Value = new OperationValue();
79 _Value.Value = _CommandResult;
80
81 return _Value;
82 }
83
84 public OperationValue Delete(string argument_SqlText, DbTransaction argument_Transaction, DbParameter[] argument_Parameters)
85 {
86 this.Connection.Open();
87 int _CommandResult = 0;
88 DbCommand _Command = this.Connection.DatabaseProvide.Factory.CreateCommand();
89 DbTransaction _Transaction = argument_Transaction;
90 _Command.Connection = this.Connection.Connection;
91 _Command.Transaction = _Transaction;
92 _Command.CommandText = argument_SqlText;
93 _Command.CommandType = CommandType.Text;
94 if (null != argument_Parameters)
95 {
96 _Command.Parameters.AddRange(argument_Parameters);
97 }
98
99 try
100 {
101 _CommandResult = _Command.ExecuteNonQuery();
102 //_Transaction.Commit();
103 }
104 catch (Exception)
105 {
106 _Transaction.Rollback();
107 }
108
109 OperationValue _Value = new OperationValue();
110 _Value.Value = _CommandResult;
111
112 return _Value;
113 }
114
115 public DataTableReader Reader(string argument_SqlText, DbParameter[] argument_Parameters)
116 {
117 this.Connection.Open();
118 DataTable _QueryTable = new DataTable();
119 DbCommand _Command = this.Connection.DatabaseProvide.Factory.CreateCommand();
120 _Command.Connection = this.Connection.Connection;
121 _Command.CommandText = argument_SqlText;
122 _Command.CommandType = CommandType.Text;
123 if (null != argument_Parameters)
124 {
125 _Command.Parameters.AddRange(argument_Parameters);
126 }
127
128 DbDataReader _Reader = _Command.ExecuteReader();
129 _QueryTable.Load(_Reader);
130 return _QueryTable.CreateDataReader();
131 }
132
133 public OperationValue Query(string argument_SqlText, DbParameter[] argument_Parameters)
134 {
135 this.Connection.Open();
136 DataTable _QueryTable = new DataTable();
137 DbCommand _Command = this.Connection.DatabaseProvide.Factory.CreateCommand();
138 _Command.Connection = this.Connection.Connection;
139 _Command.CommandText = argument_SqlText;
140 _Command.CommandType = CommandType.Text;
141 if (null != argument_Parameters)
142 {
143 _Command.Parameters.AddRange(argument_Parameters);
144 }
145
146 DbDataReader _Reader = _Command.ExecuteReader();
147 _QueryTable.Load(_Reader);
148 _Reader.Close();
149 OperationValue _Value = new OperationValue();
150 _Value.Value = _QueryTable;
151 return _Value;
152 }
153
154 public OperationValue Query(string argument_SqlText, DbTransaction argument_Transaction, DbParameter[] argument_Parameters)
155 {
156 this.Connection.Open();
157 DataTable _QueryTable = new DataTable();
158 DbCommand _Command = this.Connection.DatabaseProvide.Factory.CreateCommand();
159 _Command.Connection = this.Connection.Connection;
160 _Command.Transaction = argument_Transaction;
161 _Command.CommandText = argument_SqlText;
162 _Command.CommandType = CommandType.Text;
163 if (null != argument_Parameters)
164 {
165 _Command.Parameters.AddRange(argument_Parameters);
166 }
167
168 DbD |