Added refreshSchema to DBAdapter.

Author: Chriztiaan

packages/common/src/client/AbstractPowerSyncDatabase.ts

@@ -362,6 +362,7 @@ export abstract class AbstractPowerSyncDatabase extends BaseObserver<PowerSyncDB
     this._schema = schema;
 
     await this.database.execute('SELECT powersync_replace_schema(?)', [JSON.stringify(this.schema.toJSON())]);
+    await this.database.refreshSchema();
     this.iterateListeners(async (cb) => cb.schemaChanged?.(schema));
   }
 

packages/common/src/db/DBAdapter.ts

@@ -101,6 +101,7 @@ export interface DBAdapter extends BaseObserverInterface<DBAdapterListener>, DBG
   readTransaction: <T>(fn: (tx: Transaction) => Promise<T>, options?: DBLockOptions) => Promise<T>;
   writeLock: <T>(fn: (tx: LockContext) => Promise<T>, options?: DBLockOptions) => Promise<T>;
   writeTransaction: <T>(fn: (tx: Transaction) => Promise<T>, options?: DBLockOptions) => Promise<T>;
+  refreshSchema: () => Promise<void>;
 }
 
 export function isBatchedUpdateNotification(

packages/powersync-op-sqlite/src/db/OPSQLiteConnection.ts

@@ -79,4 +79,8 @@ export class OPSQLiteConnection extends BaseObserver<DBAdapterListener> {
     }
     return result as T;
   }
+
+  async refreshSchema() {
+    await this.get("PRAGMA table_info('sqlite_master')");
+  }
 }

packages/powersync-op-sqlite/src/db/OPSqliteAdapter.ts

@@ -259,4 +259,12 @@ export class OPSQLiteDBAdapter extends BaseObserver<DBAdapterListener> implement
       throw ex;
     }
   }
+
+  async refreshSchema(): Promise<void> {
+    await this.writeConnection?.refreshSchema();
+
+    for (let connection of this.readConnections) {
+      await connection.refreshSchema();
+    }
+  }
 }

packages/react-native/src/db/adapters/react-native-quick-sqlite/RNQSDBAdapter.ts

@@ -124,4 +124,8 @@ export class RNQSDBAdapter extends BaseObserver<DBAdapterListener> implements DB
       }
     };
   }
+
+  async refreshSchema() {
+    await this.baseDB.refreshSchema();
+  }
 }

packages/web/src/db/adapters/SSRDBAdapter.ts

@@ -85,4 +85,6 @@ export class SSRDBAdapter extends BaseObserver<DBAdapterListener> implements DBA
       }
     };
   }
+
+  async refreshSchema(): Promise<void> {}
 }

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

@@ -275,4 +275,6 @@ export class WASQLiteDBAdapter extends BaseObserver<DBAdapterListener> implement
       }
     };
   }
+
+  async refreshSchema(): Promise<void> {}
 }