|
ory.CreateCommand();
98 _Command.Connection = this.Connection.Connection;
99 _Command.CommandText = argument_SqlText;
100 _Command.CommandType = CommandType.Text;
101 if (null != argument_Parameters)
102 {
103 _Command.Parameters.AddRange(argument_Parameters);
104 }
105
106 try
107 {
108 _CommandResult = await _Command.ExecuteNonQueryAsync();
109 }
110 catch (Exception)
111 {
112 }
113
114 OperationValue _Value = new OperationValue();
115 _Value.Value = _CommandResult;
116
117 return _Value;
118 }
119
120 public async Task ModifyAsync(string argument_SqlText, DbTransaction argument_Transaction, DbParameter[] argument_Parameters)
121 {
122 this.Connection.Open();
123 int _CommandResult = 0;
124 DbCommand _Command = this.Connection.DatabaseProvide.Factory.CreateCommand();
125 DbTransaction _Transaction = argument_Transaction;
126 _Command.Transaction = _Transaction;
127 _Command.Connection = this.Connection.Connection;
128 _Command.CommandText = argument_SqlText;
129 _Command.CommandType = CommandType.Text;
130 if (null != argument_Parameters)
131 {
132 _Command.Parameters.AddRange(argument_Parameters);
133 }
134
135 try
136 {
137 _CommandResult = await _Command.ExecuteNonQueryAsync();
138 //_Transaction.Commit();
139 }
140 catch (Exception)
141 {
142 _Transaction.Rollback();
143 }
144
145 OperationValue _Value = new OperationValue();
146 _Value.Value = _CommandResult;
147
148 return _Value;
149 }
150
151 public async Task QueryAsync(string argument_SqlText, DbParameter[] argument_Parameters)
152 {
153 this.Connection.Open();
154 DataTable _QueryTable = new DataTable();
155 DbCommand _Command = this.Connection.DatabaseProvide.Factory.CreateCommand();
156 _Command.Connection = this.Connection.Connection;
157 _Command.CommandText = argument_SqlText;
158 _Command.CommandType = CommandType.Text;
159 DbDataReader _Reader = null;
160 if (null != argument_Parameters)
161 {
162 _Command.Parameters.AddRange(argument_Parameters);
163 }
164
165 try
166 {
167 _Reader = await _Command.ExecuteReaderAsync();
168 _QueryTable.Load(_Reader);
169 }
170 catch (Exception)
171 {
172
173 }
174 finally
175 {
176 _Reader.Close();
177 }
178
179 OperationValue _Value = new OperationValue();
180 _Value.Value = _QueryTable;
181 return _Value;
182 }
183
184 public async Task QueryAsync(string argument_SqlText, DbTransaction argument_Transaction, DbParameter[] argument_Parameters)
185 {
186 this.Connection.Open();
187 DataTable _QueryTable = new DataTable();
188 DbCommand _Command = this.Connection.DatabaseProvide.Factory.CreateCommand();
189 _Command.Connection = this.Connection.Connection;
190 _Command.Transaction = argument_Transaction;
191 _Command.CommandText = argument_SqlText;
192 _Command.CommandType = CommandType.Text;
193 DbDataReader _Reader = null;
194 if (null != argument_Parameters)
195 {
196 _Command.Parameters.AddRange(argument_Parameters);
197 }
198
199 try
200 {
201 _Reader = await _Command.ExecuteReaderAsync();
202 _QueryTable.Load(_Reader);
203 }
204 catch (Exception)
205 {
206
207 }
208 finally
209 {
210 _Reader.Close();
211 }
212
213 OperationValue _Value = new OperationV |