fix escaping of encryptionKey (#1016)

Author: delagen

demos/example-node/src/main.ts

@@ -45,12 +45,12 @@ const main = async () => {
       openWorker: customWorker,
       initializeConnection: async (db) => {
         if (encryptionKey.length) {
-          const escapedKey = encryptionKey.replace("'", "''");
-          await db.execute(`pragma key = '${escapedKey}'`);
+          const escapedKey = encryptionKey.replaceAll("'", "''");
+          await db.execute(`PRAGMA key = '${escapedKey}'`);
         }
 
         // Make sure the database is readable, this fails early if the key is wrong.
-        await db.execute('pragma user_version');
+        await db.execute('PRAGMA user_version');
       }
     },
     logger

packages/node/README.md

@@ -141,12 +141,12 @@ const db = new PowerSyncDatabase({
     },
     initializeConnection: async (db) => {
       if (encryptionKey.length) {
-        const escapedKey = encryptionKey.replace("'", "''");
-        await db.execute(`pragma key = '${escapedKey}'`);
+        const escapedKey = encryptionKey.replaceAll("'", "''");
+        await db.execute(`PRAGMA key = '${escapedKey}'`);
       }
 
       // Make sure the database is readable, this fails early if the key is wrong.
-      await db.execute('pragma user_version');
+      await db.execute('PRAGMA user_version');
     }
   },
   logger

packages/web/src/db/adapters/wa-sqlite/RawSqliteConnection.ts

@@ -55,8 +55,8 @@ export class RawSqliteConnection {
     );
     await this.executeRaw(`PRAGMA temp_store = ${this.options.temporaryStorage};`);
     if (this.options.encryptionKey) {
-      const escapedKey = this.options.encryptionKey.replace("'", "''");
-      await this.executeRaw(`PRAGMA key = '${escapedKey}'`);
+      const escapedKey = this.options.encryptionKey.replaceAll("'", "''");
+      await this.executeRaw(`PRAGMA key = '${escapedKey}';`);
     }
     await this.executeRaw(`PRAGMA cache_size = -${this.options.cacheSizeKb};`);