@@ -18,12 +18,14 @@ public sealed class MicrosoftSqlClientAsyncTests : AsyncTests<MicrosoftSqlClient
18
18
#endif
19
19
20
20
[ Collection ( NonParallelDefinition . Name ) ]
21
- public sealed class SystemSqlClientAsyncQueryCacheTests : AsyncQueryCacheTests < SystemSqlClientProvider > {
21
+ public sealed class SystemSqlClientAsyncQueryCacheTests : AsyncQueryCacheTests < SystemSqlClientProvider >
22
+ {
22
23
public SystemSqlClientAsyncQueryCacheTests ( ITestOutputHelper log ) : base ( log ) { }
23
24
}
24
25
#if MSSQLCLIENT
25
26
[ Collection ( NonParallelDefinition . Name ) ]
26
- public sealed class MicrosoftSqlClientAsyncQueryCacheTests : AsyncQueryCacheTests < MicrosoftSqlClientProvider > {
27
+ public sealed class MicrosoftSqlClientAsyncQueryCacheTests : AsyncQueryCacheTests < MicrosoftSqlClientProvider >
28
+ {
27
29
public MicrosoftSqlClientAsyncQueryCacheTests ( ITestOutputHelper log ) : base ( log ) { }
28
30
}
29
31
#endif
@@ -32,7 +34,7 @@ public MicrosoftSqlClientAsyncQueryCacheTests(ITestOutputHelper log) : base(log)
32
34
public abstract class AsyncTests < TProvider > : TestBase < TProvider > where TProvider : SqlServerDatabaseProvider
33
35
{
34
36
private DbConnection _marsConnection ;
35
-
37
+
36
38
private DbConnection MarsConnection => _marsConnection ?? ( _marsConnection = Provider . GetOpenConnection ( true ) ) ;
37
39
38
40
[ Fact ]
@@ -128,9 +130,12 @@ public void TestLongOperationWithCancellation()
128
130
[ Fact ]
129
131
public async Task TestBasicStringUsageClosedAsync ( )
130
132
{
131
- var query = await connection . QueryAsync < string > ( "select 'abc' as [Value] union all select @txt" , new { txt = "def" } ) . ConfigureAwait ( false ) ;
132
- var arr = query . ToArray ( ) ;
133
- Assert . Equal ( new [ ] { "abc" , "def" } , arr ) ;
133
+ using ( var conn = GetClosedConnection ( ) )
134
+ {
135
+ var query = await conn . QueryAsync < string > ( "select 'abc' as [Value] union all select @txt" , new { txt = "def" } ) . ConfigureAwait ( false ) ;
136
+ var arr = query . ToArray ( ) ;
137
+ Assert . Equal ( new [ ] { "abc" , "def" } , arr ) ;
138
+ }
134
139
}
135
140
136
141
[ Fact ]
@@ -159,9 +164,12 @@ public async Task TestExecuteAsync()
159
164
[ Fact ]
160
165
public void TestExecuteClosedConnAsyncInner ( )
161
166
{
162
- var query = connection . ExecuteAsync ( "declare @foo table(id int not null); insert @foo values(@id);" , new { id = 1 } ) ;
163
- var val = query . Result ;
164
- Assert . Equal ( 1 , val ) ;
167
+ using ( var conn = GetClosedConnection ( ) )
168
+ {
169
+ var query = conn . ExecuteAsync ( "declare @foo table(id int not null); insert @foo values(@id);" , new { id = 1 } ) ;
170
+ var val = query . Result ;
171
+ Assert . Equal ( 1 , val ) ;
172
+ }
165
173
}
166
174
167
175
[ Fact ]
@@ -248,23 +256,29 @@ public async Task TestMultiAsyncViaFirstOrDefault()
248
256
[ Fact ]
249
257
public async Task TestMultiClosedConnAsync ( )
250
258
{
251
- using ( SqlMapper . GridReader multi = await connection . QueryMultipleAsync ( "select 1; select 2" ) . ConfigureAwait ( false ) )
259
+ using ( var conn = GetClosedConnection ( ) )
252
260
{
253
- Assert . Equal ( 1 , multi . ReadAsync < int > ( ) . Result . Single ( ) ) ;
254
- Assert . Equal ( 2 , multi . ReadAsync < int > ( ) . Result . Single ( ) ) ;
261
+ using ( SqlMapper . GridReader multi = await conn . QueryMultipleAsync ( "select 1; select 2" ) . ConfigureAwait ( false ) )
262
+ {
263
+ Assert . Equal ( 1 , multi . ReadAsync < int > ( ) . Result . Single ( ) ) ;
264
+ Assert . Equal ( 2 , multi . ReadAsync < int > ( ) . Result . Single ( ) ) ;
265
+ }
255
266
}
256
267
}
257
268
258
269
[ Fact ]
259
270
public async Task TestMultiClosedConnAsyncViaFirstOrDefault ( )
260
271
{
261
- using ( SqlMapper . GridReader multi = await connection . QueryMultipleAsync ( "select 1; select 2; select 3; select 4; select 5;" ) . ConfigureAwait ( false ) )
272
+ using ( var conn = GetClosedConnection ( ) )
262
273
{
263
- Assert . Equal ( 1 , multi . ReadFirstOrDefaultAsync < int > ( ) . Result ) ;
264
- Assert . Equal ( 2 , multi . ReadAsync < int > ( ) . Result . Single ( ) ) ;
265
- Assert . Equal ( 3 , multi . ReadFirstOrDefaultAsync < int > ( ) . Result ) ;
266
- Assert . Equal ( 4 , multi . ReadAsync < int > ( ) . Result . Single ( ) ) ;
267
- Assert . Equal ( 5 , multi . ReadFirstOrDefaultAsync < int > ( ) . Result ) ;
274
+ using ( SqlMapper . GridReader multi = await conn . QueryMultipleAsync ( "select 1; select 2; select 3; select 4; select 5" ) . ConfigureAwait ( false ) )
275
+ {
276
+ Assert . Equal ( 1 , multi . ReadFirstOrDefaultAsync < int > ( ) . Result ) ;
277
+ Assert . Equal ( 2 , multi . ReadAsync < int > ( ) . Result . Single ( ) ) ;
278
+ Assert . Equal ( 3 , multi . ReadFirstOrDefaultAsync < int > ( ) . Result ) ;
279
+ Assert . Equal ( 4 , multi . ReadAsync < int > ( ) . Result . Single ( ) ) ;
280
+ Assert . Equal ( 5 , multi . ReadFirstOrDefaultAsync < int > ( ) . Result ) ;
281
+ }
268
282
}
269
283
}
270
284
0 commit comments