chore: add changes to disconnectAndClear (#58)

* chore: add changes to disconnectAndClear

* chore: add dialect and custom function to sq file

---------

Co-authored-by: DominicGBauer <[email protected]>

core/src/commonMain/kotlin/com/powersync/db/PowerSyncDatabaseImpl.kt

@@ -284,19 +284,10 @@ internal class PowerSyncDatabaseImpl(
     override suspend fun disconnectAndClear(clearLocal: Boolean) {
         disconnect()
 
-        this.writeTransaction { tx ->
-            tx.execute("DELETE FROM ${InternalTable.OPLOG}")
-            tx.execute("DELETE FROM ${InternalTable.CRUD}")
-            tx.execute("DELETE FROM ${InternalTable.BUCKETS}")
-            tx.execute("DELETE FROM ${InternalTable.UNTYPED}")
-
-            val tableGlob = if (clearLocal) "ps_data_*" else "ps_data__*"
-            val existingTableRows = internalDb.getExistingTableNames(tableGlob)
-
-            for (row in existingTableRows) {
-                tx.execute("DELETE FROM ${quoteIdentifier(row)}")
-            }
+        this.writeTransaction {
+            internalDb.queries.powersyncClear(if(clearLocal) "1" else "0").awaitAsOne()
         }
+        currentStatus.update(lastSyncedAt = null, hasSynced = false)
     }
 
     private suspend fun updateHasSynced() {

dialect/README.md

@@ -0,0 +1,27 @@
+# SQLDelight Custom PowerSync Dialect
+
+This defines the custom PowerSync SQLite functions to be used in the `PowerSync.sq` file found in the `persistence` module.
+
+## Example
+```kotlin
+public class PowerSyncTypeResolver(private val parentResolver: TypeResolver) :
+    TypeResolver by SqliteTypeResolver(parentResolver) {
+    override fun functionType(functionExpr: SqlFunctionExpr): IntermediateType? {
+        when (functionExpr.functionName.text) {
+            "powersync_replace_schema" -> return IntermediateType(
+                PrimitiveType.TEXT
+            )
+        }
+        return parentResolver.functionType(functionExpr)
+    }
+}
+```
+
+allows
+
+```sql
+replaceSchema:
+SELECT powersync_replace_schema(?);
+```
+
+To be used in the `PowerSync.sq` file in the `persistence` module.

dialect/src/main/kotlin/com/powersync/sqlite/PowerSyncDialect.kt

@@ -16,7 +16,7 @@ public class PowerSyncTypeResolver(private val parentResolver: TypeResolver) :
     TypeResolver by SqliteTypeResolver(parentResolver) {
     override fun functionType(functionExpr: SqlFunctionExpr): IntermediateType? {
         when (functionExpr.functionName.text) {
-            "sqlite_version", "powersync_rs_version", "powersync_replace_schema" -> return IntermediateType(
+            "sqlite_version", "powersync_rs_version", "powersync_replace_schema", "powersync_clear" -> return IntermediateType(
                 PrimitiveType.TEXT
             )
         }

persistence/src/commonMain/sqldelight/com/persistence/Powersync.sq

@@ -8,6 +8,9 @@ SELECT powersync_rs_version();
 replaceSchema:
 SELECT powersync_replace_schema(?);
 
+powersyncClear:
+SELECT powersync_clear(?);
+
 -- CRUD operations
 hasCrud:
 SELECT 1 FROM ps_crud LIMIT 1;