@@ -14,7 +14,7 @@ You may obtain a copy of the License at
1414 limitations under the License.
1515*/
1616
17- using NUnit . Framework ;
17+ using Xunit ;
1818using System ;
1919using System . Collections . Generic ;
2020using System . Linq ;
@@ -26,34 +26,33 @@ limitations under the License.
2626
2727namespace SQLitePCL . pretty . tests
2828{
29- [ TestFixture ]
3029 public class AsyncDatabaseConnectionTests
3130 {
32- [ Test ]
31+ [ Fact ]
3332 public async Task TestProfileEvent ( )
3433 {
3534 using ( var db = SQLite3 . OpenInMemory ( ) . AsAsyncDatabaseConnection ( ) )
3635 {
3736 var statement = "CREATE TABLE foo (x int);" ;
3837 db . Profile . Subscribe ( e =>
3938 {
40- Assert . AreEqual ( statement , e . Statement ) ;
41- Assert . Less ( TimeSpan . MinValue , e . ExecutionTime ) ;
39+ Assert . Equal ( statement , e . Statement ) ;
40+ Assert . True ( TimeSpan . MinValue < e . ExecutionTime ) ;
4241 } ) ;
4342
4443 await db . ExecuteAsync ( statement ) ;
4544 }
4645 }
4746
48- [ Test ]
47+ [ Fact ]
4948 public async Task TestTraceEvent ( )
5049 {
5150 using ( var db = SQLite3 . OpenInMemory ( ) . AsAsyncDatabaseConnection ( ) )
5251 {
5352 var statement = "CREATE TABLE foo (x int);" ;
5453 db . Trace . Subscribe ( e =>
5554 {
56- Assert . AreEqual ( statement , e . Statement ) ;
55+ Assert . Equal ( statement , e . Statement ) ;
5756 } ) ;
5857
5958 await db . ExecuteAsync ( statement ) ;
@@ -63,7 +62,7 @@ public async Task TestTraceEvent()
6362 }
6463 }
6564
66- [ Test ]
65+ [ Fact ]
6766 public async Task TestUpdateEvent ( )
6867 {
6968 using ( var db = SQLite3 . OpenInMemory ( ) . AsAsyncDatabaseConnection ( ) )
@@ -73,10 +72,10 @@ public async Task TestUpdateEvent()
7372
7473 db . Update . Subscribe ( e =>
7574 {
76- Assert . AreEqual ( currentAction , e . Action ) ;
77- Assert . AreEqual ( "main" , e . Database ) ;
78- Assert . AreEqual ( "foo" , e . Table ) ;
79- Assert . AreEqual ( rowid , e . RowId ) ;
75+ Assert . Equal ( currentAction , e . Action ) ;
76+ Assert . Equal ( "main" , e . Database ) ;
77+ Assert . Equal ( "foo" , e . Table ) ;
78+ Assert . Equal ( rowid , e . RowId ) ;
8079 } ) ;
8180
8281 currentAction = ActionCode . CreateTable ;
@@ -97,7 +96,7 @@ public async Task TestUpdateEvent()
9796 }
9897 }
9998
100- [ Test ]
99+ [ Fact ]
101100 public async Task TestUse ( )
102101 {
103102 using ( var adb = SQLite3 . OpenInMemory ( ) . AsAsyncDatabaseConnection ( ) )
@@ -106,15 +105,15 @@ await adb.Use(db => Enumerable.Range(0, 1000))
106105 . Scan ( Tuple . Create ( - 1 , - 1 ) , ( x , y ) => Tuple . Create ( x . Item1 + 1 , y ) )
107106 . Do ( result =>
108107 {
109- Assert . AreEqual ( result . Item2 , result . Item1 ) ;
108+ Assert . Equal ( result . Item2 , result . Item1 ) ;
110109 } ) ;
111110
112111 int expected = 10 ;
113112 var t = await adb . Use ( db =>
114113 {
115114 return db . Query ( "Select ?" , expected ) . SelectScalarInt ( ) . First ( ) ;
116115 } ) ;
117- Assert . AreEqual ( t , expected ) ;
116+ Assert . Equal ( t , expected ) ;
118117
119118 var anotherUse = adb . Use ( db => Enumerable . Range ( 0 , 1000 ) ) ;
120119
@@ -125,11 +124,11 @@ await adb.Use(db => Enumerable.Range(0, 1000))
125124
126125 Assert . Throws < ObjectDisposedException > ( ( ) => adb . Use ( db => Enumerable . Range ( 0 , 1000 ) ) ) ;
127126 Assert . Throws < ObjectDisposedException > ( ( ) => anotherUse . Subscribe ( ) ) ;
128- Assert . Throws < ObjectDisposedException > ( ( ) => adb . Use ( db => { } ) ) ;
127+ Assert . ThrowsAsync < ObjectDisposedException > ( async ( ) => await adb . Use ( db => { } ) ) ;
129128 }
130129 }
131130
132- [ Test ]
131+ [ Fact ]
133132 public async Task TestIDatabaseConnectionStatements ( )
134133 {
135134 using ( var adb = SQLite3 . OpenInMemory ( ) . AsAsyncDatabaseConnection ( ) )
@@ -159,12 +158,12 @@ await adb.Use(db =>
159158 Assert . True ( stmts . Contains ( stmt ) ) ;
160159 }
161160
162- Assert . AreEqual ( count , stmts . Count ) ;
161+ Assert . Equal ( count , stmts . Count ) ;
163162 } ) ;
164163 }
165164 }
166165
167- [ Test ]
166+ [ Fact ]
168167 public async Task TestIDatabaseConnectionEvents ( )
169168 {
170169 using ( var adb = SQLite3 . OpenInMemory ( ) . AsAsyncDatabaseConnection ( ) )
@@ -234,7 +233,7 @@ await adb.Use(db =>
234233 }
235234 }
236235
237- [ Test ]
236+ [ Fact ]
238237 public async Task TestIDatabaseConnectionDispose ( )
239238 {
240239 using ( var adb = SQLite3 . OpenInMemory ( ) . AsAsyncDatabaseConnection ( ) )
@@ -243,19 +242,20 @@ public async Task TestIDatabaseConnectionDispose()
243242
244243 await adb . Use ( db =>
245244 {
246- Assert . DoesNotThrow ( ( ) => { var x = db . IsAutoCommit ; } ) ;
247- Assert . DoesNotThrow ( ( ) => { var x = db . IsReadOnly ; } ) ;
248- Assert . DoesNotThrow ( ( ) => { var x = db . Changes ; } ) ;
249- Assert . DoesNotThrow ( ( ) => { var x = db . TotalChanges ; } ) ;
250- Assert . DoesNotThrow ( ( ) => { var x = db . LastInsertedRowId ; } ) ;
251- Assert . DoesNotThrow ( ( ) => { var x = db . Statements ; } ) ;
252- Assert . DoesNotThrow ( ( ) => { var x = db . IsDatabaseReadOnly ( "main" ) ; } ) ;
253- Assert . DoesNotThrow ( ( ) => { using ( var stmt = db . PrepareStatement ( "SELECT x FROM foo;" ) ) { } } ) ;
245+ // Assert these don't throw
246+ { var x = db . IsAutoCommit ; }
247+ { var x = db . IsReadOnly ; }
248+ { var x = db . Changes ; }
249+ { var x = db . TotalChanges ; }
250+ { var x = db . LastInsertedRowId ; } ;
251+ { var x = db . Statements ; } ;
252+ { var x = db . IsDatabaseReadOnly ( "main" ) ; } ;
253+ { using ( var stmt = db . PrepareStatement ( "SELECT x FROM foo;" ) ) { } } ;
254254
255255 int current ;
256256 int highwater ;
257- Assert . DoesNotThrow ( ( ) => { db . Status ( DatabaseConnectionStatusCode . CacheMiss , out current , out highwater , false ) ; } ) ;
258- Assert . DoesNotThrow ( ( ) => { db . WalCheckPoint ( "main" ) ; } ) ;
257+ { db . Status ( DatabaseConnectionStatusCode . CacheMiss , out current , out highwater , false ) ; } ;
258+ { db . WalCheckPoint ( "main" ) ; } ;
259259
260260 db . Dispose ( ) ;
261261
@@ -276,7 +276,7 @@ await adb.Use(db =>
276276 await adb . Use ( db =>
277277 {
278278 // Assert that the database is not disposed, despite the previous user disposing it's instance.
279- Assert . DoesNotThrow ( ( ) => { var x = db . IsAutoCommit ; } ) ;
279+ { var x = db . IsAutoCommit ; } ;
280280 } ) ;
281281
282282 // Test that subscribe doesn't throw after Dispose() is called.
@@ -285,27 +285,27 @@ await adb.Use(db =>
285285 await disposedObservable . Materialize ( )
286286 . Do ( x =>
287287 {
288- Assert . AreEqual ( x . Kind , NotificationKind . OnError ) ;
289- Assert . IsInstanceOf < ObjectDisposedException > ( x . Exception ) ;
288+ Assert . Equal ( x . Kind , NotificationKind . OnError ) ;
289+ Assert . IsAssignableFrom < ObjectDisposedException > ( x . Exception ) ;
290290 } ) ;
291291 }
292292 }
293293
294- [ Test ]
294+ [ Fact ]
295295 public void TestUseCancelled ( )
296296 {
297297 using ( var adb = SQLite3 . OpenInMemory ( ) . AsAsyncDatabaseConnection ( ) )
298298 {
299299 var cts = new CancellationTokenSource ( ) ;
300300 cts . Cancel ( ) ;
301- Assert . That ( async ( ) => await adb . Use ( ( db , ct ) => { } , cts . Token ) , Throws . TypeOf < TaskCanceledException > ( ) ) ;
301+ Assert . ThrowsAsync < TaskCanceledException > ( async ( ) => await adb . Use ( ( db , ct ) => { } , cts . Token ) ) ;
302302
303303 cts = new CancellationTokenSource ( ) ;
304- Assert . That ( async ( ) => await adb . Use ( ( db , ct ) => { cts . Cancel ( ) ; } , cts . Token ) , Throws . TypeOf < TaskCanceledException > ( ) ) ;
304+ Assert . ThrowsAsync < TaskCanceledException > ( async ( ) => await adb . Use ( ( db , ct ) => { cts . Cancel ( ) ; } , cts . Token ) ) ;
305305 }
306306 }
307307
308- [ Test ]
308+ [ Fact ]
309309 public async Task TestPrepareAllAsync ( )
310310 {
311311 using ( var adb = SQLite3 . OpenInMemory ( ) . AsAsyncDatabaseConnection ( ) )
@@ -316,19 +316,19 @@ await adb.PrepareAllAsync(
316316 "SELECT * FROM foo;" +
317317 "SELECT x FROM foo;" +
318318 "SELECT rowid, x FROM foo;" ) ;
319- Assert . AreEqual ( stmts . Count , 3 ) ;
319+ Assert . Equal ( stmts . Count , 3 ) ;
320320
321321 var stmt0 = await stmts [ 0 ] . Use < string > ( stmt => stmt . SQL ) ;
322322 var stmt1 = await stmts [ 1 ] . Use < string > ( stmt => stmt . SQL ) ;
323323 var stmt2 = await stmts [ 2 ] . Use < string > ( stmt => stmt . SQL ) ;
324324
325- Assert . AreEqual ( stmt0 , "SELECT * FROM foo;" ) ;
326- Assert . AreEqual ( stmt1 , "SELECT x FROM foo;" ) ;
327- Assert . AreEqual ( stmt2 , "SELECT rowid, x FROM foo;" ) ;
325+ Assert . Equal ( stmt0 , "SELECT * FROM foo;" ) ;
326+ Assert . Equal ( stmt1 , "SELECT x FROM foo;" ) ;
327+ Assert . Equal ( stmt2 , "SELECT rowid, x FROM foo;" ) ;
328328 }
329329 }
330330
331- [ Test ]
331+ [ Fact ]
332332 public async Task TestQuery ( )
333333 {
334334 using ( var adb = SQLite3 . OpenInMemory ( ) . AsAsyncDatabaseConnection ( ) )
@@ -342,25 +342,25 @@ await adb.Query("Select ?, ?, ?", _0, _1, _2)
342342 . Select ( row => Tuple . Create ( row [ 0 ] . ToString ( ) , row [ 1 ] . ToInt ( ) , row [ 2 ] . ToInt ( ) ) )
343343 . FirstAsync ( ) ;
344344
345- Assert . AreEqual ( result . Item1 , _0 ) ;
346- Assert . AreEqual ( result . Item2 , _1 ) ;
347- Assert . AreEqual ( result . Item3 != 0 , _2 ) ;
345+ Assert . Equal ( result . Item1 , _0 ) ;
346+ Assert . Equal ( result . Item2 , _1 ) ;
347+ Assert . Equal ( result . Item3 != 0 , _2 ) ;
348348 }
349349 }
350350
351- [ Test ]
351+ [ Fact ]
352352 public void TestStatementCancellation ( )
353353 {
354354 using ( var adb = SQLite3 . OpenInMemory ( ) . AsAsyncDatabaseConnection ( TaskPoolScheduler . Default , 1 ) )
355355 {
356356 var cts = new CancellationTokenSource ( ) ;
357- Assert . That ( async ( ) =>
357+ Assert . ThrowsAsync < TaskCanceledException > ( async ( ) =>
358358 await adb . Use ( ( db , ct ) =>
359359 {
360360 cts . Cancel ( ) ;
361361 db . Execute ( "Select 1;" ) ;
362- Assert . Fail ( ) ;
363- } , cts . Token ) , Throws . TypeOf < TaskCanceledException > ( ) ) ;
362+ Assert . True ( false , "Expected exception to be thrown." ) ;
363+ } , cts . Token ) ) ;
364364 }
365365 }
366366 }
0 commit comments