|
ataReader _Reader = _Command.ExecuteReader();
169 _QueryTable.Load(_Reader);
170 _Reader.Close();
171 OperationValue _Value = new OperationValue();
172 _Value.Value = _QueryTable;
173 return _Value;
174 }
175
176 public OperationValue TransactionSave(string argument_SqlText, DbParameter[] argument_Parameters)
177 {
178 this.Connection.Open();
179 int _CommandResult = 0;
180 DbCommand _Command = this.Connection.DatabaseProvide.Factory.CreateCommand();
181 _Command.Connection = this.Connection.Connection;
182 DbTransaction _Transaction = this.Connection.Connection.BeginTransaction();
183 _Command.Transaction = _Transaction;
184 _Command.CommandText = argument_SqlText;
185 _Command.CommandType = CommandType.Text;
186 if (null != argument_Parameters)
187 {
188 _Command.Parameters.AddRange(argument_Parameters);
189 }
190
191 try
192 {
193 _CommandResult = _Command.ExecuteNonQuery();
194 _Transaction.Commit();
195 }
196 catch (Exception)
197 {
198 _Transaction.Rollback();
199 }
200
201 OperationValue _Value = new OperationValue();
202 _Value.Value = _CommandResult;
203 return _Value;
204 }
205
206 public OperationValue Save(string argument_SqlText, DbParameter[] argument_Parameters)
207 {
208 this.Connection.Open();
209 int _CommandResult = 0;
210 DbCommand _Command = this.Connection.DatabaseProvide.Factory.CreateCommand();
211 _Command.Connection = this.Connection.Connection;
212 _Command.CommandText = argument_SqlText;
213 _Command.CommandType = CommandType.Text;
214 if (null != argument_Parameters)
215 {
216 _Command.Parameters.AddRange(argument_Parameters);
217 }
218
219 try
220 {
221 _CommandResult = _Command.ExecuteNonQuery();
222 }
223 catch (Exception)
224 {
225 }
226
227 OperationValue _Value = new OperationValue();
228 _Value.Value = _CommandResult;
229 return _Value;
230 }
231
232 public OperationValue Save(string argument_SqlText, DbTransaction argument_Transaction, DbParameter[] argument_Parameters)
233 {
234 this.Connection.Open();
235 int _CommandResult = 0;
236 DbCommand _Command = this.Connection.DatabaseProvide.Factory.CreateCommand();
237 _Command.Connection = this.Connection.Connection;
238 DbTransaction _Transaction = argument_Transaction;
239 _Command.Transaction = _Transaction;
240 _Command.CommandText = argument_SqlText;
241 _Command.CommandType = CommandType.Text;
242 if (null != argument_Parameters)
243 {
244 _Command.Parameters.AddRange(argument_Parameters);
245 }
246
247 try
248 {
249 _CommandResult = _Command.ExecuteNonQuery();
250 //_Transaction.Commit();
251 }
252 catch (Exception)
253 {
254 _Transaction.Rollback();
255 }
256
257 OperationValue _Value = new OperationValue();
258 _Value.Value = _CommandResult;
259 return _Value;
260 }
261
262 public OperationValue TransactionModify(string argument_SqlText, DbParameter[] argument_Parameters)
263 {
264 this.Connection.Open();
265 int _CommandResult = 0;
266 DbCommand _Command = this.Connection.DatabaseProvide.Factory.CreateCommand();
267 DbTransaction _Transaction = this.Connection.Connection.BeginTransaction();
268 _Command.Transaction = _Transaction;
269 _Command.Connection = this.Connectio |