Merge pull request #1843 from tursodatabase/fix-wal-count

libsql-sqlite3: Fix libsql_wal_frame_count() for empty databases

Author: penberg

libsql-ffi/bundled/SQLite3MultipleCiphers/src/sqlite3.c

@@ -65291,7 +65291,8 @@ SQLITE_PRIVATE int sqlite3PagerWalFrameCount(Pager *pPager, unsigned int *pnFram
   if( pagerUseWal(pPager) ){
     return pPager->wal->methods.xFrameCount(pPager->wal->pData, 0, pnFrames);
   }else{
-    return SQLITE_ERROR;
+    *pnFrames = 0;
+    return SQLITE_OK;
   }
 }
 

libsql-ffi/bundled/src/sqlite3.c

@@ -65291,7 +65291,8 @@ SQLITE_PRIVATE int sqlite3PagerWalFrameCount(Pager *pPager, unsigned int *pnFram
   if( pagerUseWal(pPager) ){
     return pPager->wal->methods.xFrameCount(pPager->wal->pData, 0, pnFrames);
   }else{
-    return SQLITE_ERROR;
+    *pnFrames = 0;
+    return SQLITE_OK;
   }
 }
 

libsql-sqlite3/src/pager.c

@@ -7780,7 +7780,8 @@ int sqlite3PagerWalFrameCount(Pager *pPager, unsigned int *pnFrames){
   if( pagerUseWal(pPager) ){
     return pPager->wal->methods.xFrameCount(pPager->wal->pData, 0, pnFrames);
   }else{
-    return SQLITE_ERROR;
+    *pnFrames = 0;
+    return SQLITE_OK;
   }
 }
 

libsql-sqlite3/src/test_walapi.c

@@ -1,6 +1,7 @@
 #include <sqlite3.h>
 #include <stdio.h>
 #include <string.h>
+#include <assert.h>
 
 #if 0
 static void dump_frame(unsigned char *frame, size_t size){
@@ -127,6 +128,7 @@ int open_db(const char *path, sqlite3 **db) {
 int main(int argc, char *argv[])
 {
     sqlite3 *db_primary, *db_backup;
+    unsigned int max_frame;
     int rc;
 
     rc = open_db("primary.db", &db_primary);
@@ -136,6 +138,16 @@ int main(int argc, char *argv[])
     gen_data(db_primary);
 
     rc = open_db("backup.db", &db_backup);
+    if (rc != SQLITE_OK) {
+        return 1;
+    }
+    rc = libsql_wal_frame_count(db_backup, &max_frame);
+    if (rc != SQLITE_OK) {
+        fprintf(stderr, "Can't get frame count for backup: %s\n", sqlite3_errmsg(db_backup));
+        return 1;
+    }
+    assert(max_frame == 0);
+    
     sync_db(db_primary, db_backup);
 
     if (cmp_data(db_primary, db_backup)) {