|
8 | 8 | //------------------------------------------------------------------------------
|
9 | 9 |
|
10 | 10 |
|
11 |
| -using System; |
12 | 11 | using System.Collections.Generic;
|
13 | 12 | using System.Data;
|
14 | 13 | using System.Data.Common;
|
@@ -90,23 +89,24 @@ public async Task<int> ExecuteNonQueryAsync(CancellationToken cancellationToken)
|
90 | 89 | return 0;
|
91 | 90 | }
|
92 | 91 |
|
93 |
| - var batcherCommand = _batcher.Driver.GenerateCommand( |
| 92 | + using (var batcherCommand = _batcher.Driver.GenerateCommand( |
94 | 93 | _commandType,
|
95 | 94 | _sql.ToSqlString(),
|
96 |
| - _sqlTypes.ToArray() |
97 |
| - ); |
98 |
| - for (var i = 0; i < _parameters.Count; i++) |
| 95 | + _sqlTypes.ToArray())) |
99 | 96 | {
|
100 |
| - var parameter = _parameters[i]; |
101 |
| - var cmdParam = batcherCommand.Parameters[i]; |
102 |
| - cmdParam.Value = parameter.Value; |
103 |
| - cmdParam.Direction = parameter.Direction; |
104 |
| - cmdParam.Precision = parameter.Precision; |
105 |
| - cmdParam.Scale = parameter.Scale; |
106 |
| - cmdParam.Size = parameter.Size; |
| 97 | + for (var i = 0; i < _parameters.Count; i++) |
| 98 | + { |
| 99 | + var parameter = _parameters[i]; |
| 100 | + var cmdParam = batcherCommand.Parameters[i]; |
| 101 | + cmdParam.Value = parameter.Value; |
| 102 | + cmdParam.Direction = parameter.Direction; |
| 103 | + cmdParam.Precision = parameter.Precision; |
| 104 | + cmdParam.Scale = parameter.Scale; |
| 105 | + cmdParam.Size = parameter.Size; |
| 106 | + } |
| 107 | + await (_batcher.PrepareAsync(batcherCommand, cancellationToken)).ConfigureAwait(false); |
| 108 | + return await (batcherCommand.ExecuteNonQueryAsync(cancellationToken)).ConfigureAwait(false); |
107 | 109 | }
|
108 |
| - await (_batcher.PrepareAsync(batcherCommand, cancellationToken)).ConfigureAwait(false); |
109 |
| - return await (batcherCommand.ExecuteNonQueryAsync(cancellationToken)).ConfigureAwait(false); |
110 | 110 | }
|
111 | 111 | }
|
112 | 112 | }
|
|
0 commit comments