chore: Update opsqlite 11.2.13 (#463)

powersync-ja · Jan 10, 2025 · b38bcdb · b38bcdb
1 parent e52af89
commit b38bcdb
Show file tree

Hide file tree

Showing 6 changed files with 90 additions and 115 deletions.
diff --git a/.changeset/hip-pianos-relax.md b/.changeset/hip-pianos-relax.md
@@ -0,0 +1,5 @@
+---
+'@powersync/op-sqlite': patch
+---
+
+Update op-sqlite to v11.2.13.
diff --git a/.changeset/rotten-rats-raise.md b/.changeset/rotten-rats-raise.md
@@ -0,0 +1,5 @@
+---
+'@powersync/react-native': patch
+---
+
+Fixed an issue where the read and write locks were executing mutually exclusively. A read conccurent with a write or another read should correctly proceed instead of being blocked until the other lock has released.
diff --git a/packages/powersync-op-sqlite/package.json b/packages/powersync-op-sqlite/package.json
@@ -65,7 +65,7 @@
     "access": "public"
   },
   "peerDependencies": {
-    "@op-engineering/op-sqlite": "^10.1.0",
+    "@op-engineering/op-sqlite": "^11.2.13",
     "@powersync/common": "workspace:^1.22.1",
     "react": "*",
     "react-native": "*"
@@ -75,7 +75,7 @@
     "async-lock": "^1.4.0"
   },
   "devDependencies": {
-    "@op-engineering/op-sqlite": "^10.1.0",
+    "@op-engineering/op-sqlite": "^11.2.13",
     "@react-native/eslint-config": "^0.73.1",
     "@types/async-lock": "^1.4.0",
     "@types/react": "^18.2.44",

diff --git a/packages/powersync-op-sqlite/src/db/OPSqliteAdapter.ts b/packages/powersync-op-sqlite/src/db/OPSqliteAdapter.ts
@@ -78,9 +78,7 @@ export class OPSQLiteDBAdapter extends BaseObserver<DBAdapterListener> implement
 
     this.readConnections = [];
     for (let i = 0; i < READ_CONNECTIONS; i++) {
-      // Workaround to create read-only connections
-      let dbName = './'.repeat(i + 1) + dbFilename;
-      const conn = await this.openConnection(dbName);
+      const conn = await this.openConnection(dbFilename);
       await conn.execute('PRAGMA query_only = true');
       this.readConnections.push({ busy: false, connection: conn });
     }

diff --git a/packages/react-native/src/db/PowerSyncDatabase.ts b/packages/react-native/src/db/PowerSyncDatabase.ts
@@ -58,4 +58,14 @@ export class PowerSyncDatabase extends AbstractPowerSyncDatabase {
       identifier: this.database.name
     });
   }
+
+  async readLock<T>(callback: (db: DBAdapter) => Promise<T>): Promise<T> {
+    await this.waitForReady();
+    return this.database.readLock(callback);
+  }
+
+  async writeLock<T>(callback: (db: DBAdapter) => Promise<T>): Promise<T> {
+    await this.waitForReady();
+    return this.database.writeLock(callback);
+  }
 }