lists as raw table

Author: davidmartos96

demos/supabase-todolist/lib/migrations/fts_setup.dart

@@ -62,11 +62,12 @@ SqliteMigration createFtsMigration(
 /// with the data you would like to search on
 Future<void> configureFts(PowerSyncDatabase db) async {
   migrations
-    ..add(createFtsMigration(
-        migrationVersion: 1,
-        tableName: 'lists',
-        columns: ['name'],
-        tokenizationMethod: 'porter unicode61'))
+    // ..add(createFtsMigration(
+    //     migrationVersion: 1,
+    //     tableName: 'lists',
+    //     isRawTable: true,
+    //     columns: ['name'],
+    //     tokenizationMethod: 'porter unicode61'))
     ..add(createFtsMigration(
       migrationVersion: 2,
       tableName: 'todos',

demos/supabase-todolist/lib/models/schema.dart

@@ -2,8 +2,10 @@ import 'package:powersync/powersync.dart';
 import 'package:powersync_attachments_helper/powersync_attachments_helper.dart';
 
 const todosTable = 'todos';
+const listsRawTable = 'lists';
 
-Schema schema = Schema(([
+
+Schema schema = Schema([
   const Table(todosTable, [
     Column.text('list_id'),
     Column.text('photo_id'),
@@ -17,11 +19,30 @@ Schema schema = Schema(([
     // Index to allow efficient lookup within a list
     Index('list', [IndexedColumn('list_id')])
   ]),
-  const Table('lists', [
-    Column.text('created_at'),
-    Column.text('name'),
-    Column.text('owner_id')
-  ]),
+  // const Table('lists', [
+  //   Column.text('created_at'),
+  //   Column.text('name'),
+  //   Column.text('owner_id')
+  // ]),
   AttachmentsQueueTable(
-      attachmentsQueueTableName: defaultAttachmentsQueueTableName)
-]));
+    attachmentsQueueTableName: defaultAttachmentsQueueTableName,
+  ),
+], rawTables: [
+  RawTable(
+    name: 'lists',
+    put: PendingStatement(
+      sql:
+          "INSERT OR REPLACE INTO $listsRawTable (id, created_at, name, owner_id) VALUES (?, ?, ?, ?);",
+      params: [
+        PendingStmtValueId(),
+        PendingStmtValueColumn('created_at'),
+        PendingStmtValueColumn('name'),
+        PendingStmtValueColumn('owner_id'),
+      ],
+    ),
+    delete: PendingStatement(
+      sql: "DELETE FROM $listsRawTable WHERE id = ?",
+      params: [PendingStmtValueId()],
+    ),
+  )
+]);

demos/supabase-todolist/lib/powersync.dart

@@ -5,6 +5,7 @@ import 'package:path/path.dart';
 import 'package:path_provider/path_provider.dart';
 import 'package:powersync/powersync.dart';
 import 'package:powersync_flutter_demo/migrations/fts_setup.dart';
+import 'package:powersync_flutter_demo/raw_tables_helper.dart';
 import 'package:supabase_flutter/supabase_flutter.dart';
 
 import './app_config.dart';
@@ -157,9 +158,18 @@ Future<void> openDatabase() async {
   final dbPath = await getDatabasePath();
   print("Opening database at $dbPath");
   // Open the local database
-  db = PowerSyncDatabase(schema: schema, path: dbPath, logger: attachedLogger);
+  db = PowerSyncDatabase(
+    schema: schema,
+    path: dbPath,
+    logger: attachedLogger,
+    manualSchemaManagement: true,
+  );
   await db.initialize();
 
+  await initializeRawTablesSchema(db);
+  await db.updateSchema(schema);
+  await db.markSchemaAsReady();
+
   await loadSupabase();
 
   SupabaseConnector? currentConnector;
@@ -168,7 +178,10 @@ Future<void> openDatabase() async {
     // If the user is already logged in, connect immediately.
     // Otherwise, connect once logged in.
     currentConnector = SupabaseConnector();
-    db.connect(connector: currentConnector);
+    db.connect(
+      connector: currentConnector,
+      options: SyncOptions(syncImplementation: SyncClientImplementation.rust),
+    );
   }
 
   Supabase.instance.client.auth.onAuthStateChange.listen((data) async {

demos/supabase-todolist/lib/raw_tables_helper.dart

@@ -0,0 +1,20 @@
+import 'package:powersync/powersync.dart';
+import 'package:powersync_flutter_demo/models/schema.dart';
+import 'package:sqlite_async/sqlite_async.dart';
+
+Future<void> initializeRawTablesSchema(PowerSyncDatabase db) async {
+  await db.writeTransaction((ctx) async {
+    await _createListsRawTable(ctx);
+  });
+}
+
+Future<void> _createListsRawTable(SqliteWriteContext ctx) async {
+  await ctx.execute('''
+CREATE TABLE IF NOT EXISTS $listsRawTable(
+  id TEXT NOT NULL PRIMARY KEY,
+  created_at TEXT NOT NULL,
+  name TEXT NOT NULL,
+  owner_id TEXT NOT NULL
+) STRICT;
+''');
+}

packages/powersync_core/lib/src/schema.dart

@@ -322,11 +322,11 @@ class RawTable {
   final PendingStatement put;
   final PendingStatement delete;
 
-  const RawTable(
-    this.name,
-    this.put,
-    this.delete,
-  );
+  const RawTable({
+    required this.name,
+    required this.put,
+    required this.delete,
+  });
 
   Map<String, dynamic> toJson() => {
         'name': name,