Cleanup, and then while debugging a test, noticed that sqlite3_busy_timeout doesn't retry a sqlite3_step for you automatically. So that's a problem that I'll need to fix.

3 files changed, 23 insertions, 5 deletions

diff --git a/Tests/FMDatabaseAdditionsTests.m b/Tests/FMDatabaseAdditionsTests.m
index 6164847..b861ef1 100644
--- a/Tests/FMDatabaseAdditionsTests.m
+++ b/Tests/FMDatabaseAdditionsTests.m
@@ -94,4 +94,11 @@
     XCTAssertFalse([self.db columnExists:@"c" inTableWithName:@"nulltest"]);
 }
 
+- (void)testUserVersion {
+    
+    [[self db] setUserVersion:12];
+    
+    XCTAssertTrue([[self db] userVersion] == 12);
+}
+
 @end
diff --git a/Tests/FMDatabasePoolTests.m b/Tests/FMDatabasePoolTests.m
index 36183c5..55ce5ea 100644
--- a/Tests/FMDatabasePoolTests.m
+++ b/Tests/FMDatabasePoolTests.m
@@ -36,7 +36,10 @@
     [super setUp];
     // Put setup code here. This method is called before the invocation of each test method in the class.
     
-    self.pool = [FMDatabasePool databasePoolWithPath:self.databasePath];
+    [self setPool:[FMDatabasePool databasePoolWithPath:self.databasePath]];
+    
+    [[self pool] setDelegate:self];
+    
 }
 
 - (void)tearDown
@@ -249,6 +252,14 @@
     XCTAssert([self.pool countOfOpenDatabases] < 64, @"There should be significantly less than 64 databases after that stress test");
 }
 
+
+- (BOOL)databasePool:(FMDatabasePool*)pool shouldAddDatabaseToPool:(FMDatabase*)database {
+    [database setRetryTimeout:.1];
+    [database setCrashOnErrors:YES];
+    #pragma message "FIXME: Gus - we need to check for a SQLITE_BUSY when we call sqlite3_step.  sqlite will sleep for the retry amount - BUT, it won't just try the step again.  We'll have to put the old loops back in.  testReadWriteStressTest shows this mistake."
+    return YES;
+}
+
 - (void)testReadWriteStressTest
 {
     int ops = 16;
diff --git a/Tests/FMDatabaseTests.m b/Tests/FMDatabaseTests.m
index 9918309..279f09f 100644
--- a/Tests/FMDatabaseTests.m
+++ b/Tests/FMDatabaseTests.m
@@ -91,8 +91,8 @@
 
 - (void)testPragmaJournalMode
 {
-    FMResultSet *ps = [self.db executeQuery:@"PRAGMA journal_mode=delete"];
-    XCTAssertFalse([self.db hadError], @"PRAGMA should have succeeded");
+    FMResultSet *ps = [self.db executeQuery:@"pragma journal_mode=delete"];
+    XCTAssertFalse([self.db hadError], @"pragma should have succeeded");
     XCTAssertNotNil(ps, @"Result set should be non-nil");
     XCTAssertTrue([ps next], @"Result set should have a next result");
     [ps close];
@@ -101,7 +101,7 @@
 - (void)testPragmaPageSize
 {
     [self.db executeUpdate:@"PRAGMA page_size=2048"];
-    XCTAssertFalse([self.db hadError], @"PRAGMA should have succeeded");
+    XCTAssertFalse([self.db hadError], @"pragma should have succeeded");
 }
 
 - (void)testVacuum
@@ -670,7 +670,7 @@
 
 - (void)testPragmaDatabaseList
 {
-    FMResultSet *rs = [self.db executeQuery:@"PRAGMA database_list"];
+    FMResultSet *rs = [self.db executeQuery:@"pragma database_list"];
     int counter = 0;
     while ([rs next]) {
         counter++;