feature: add executeWrite method to PowerSyncDB that wraps the execut…

…ing in a writeTransaction

Package.swift

@@ -21,4 +21,4 @@ let package = Package(
         )
         ,
     ]
-)
+)

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

@@ -153,6 +153,7 @@ internal class PowerSyncDatabaseImpl(
             return@readTransaction CrudTransaction(
                 crud = entries, transactionId = txId,
                 complete = { writeCheckpoint ->
+                    println("[CrudTransaction::complete] Completing transaction with checkpoint $writeCheckpoint")
                     handleWriteCheckpoint(entries.last().clientId, writeCheckpoint)
                 }
             )
@@ -208,6 +209,10 @@ internal class PowerSyncDatabaseImpl(
         return internalDb.execute(sql, parameters)
     }
 
+    override suspend fun executeWrite(sql: String, parameters: List<Any>?): Long {
+        return internalDb.executeWrite(sql, parameters)
+    }
+
     private suspend fun handleWriteCheckpoint(lastTransactionId: Int, writeCheckpoint: String?) {
         writeTransaction {
             internalDb.queries.deleteEntriesWithIdLessThan(lastTransactionId.toLong())

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

@@ -9,6 +9,8 @@ interface WriteQueries {
      */
     suspend fun execute(sql: String, parameters: List<Any>? = listOf()): Long
 
+    suspend fun executeWrite(sql: String, parameters: List<Any>?): Long
+
     suspend fun <R> writeTransaction(body: suspend SuspendingTransactionWithReturn<R>.() -> R): R
 
 }

core/src/commonMain/kotlin/com/powersync/db/internal/PsInternalDatabase.kt

@@ -167,6 +167,12 @@ class PsInternalDatabase(val driver: PsSqlDriver, private val scope: CoroutineSc
         return transactor.transactionWithResult(noEnclosing = true, body)
     }
 
+    override suspend fun executeWrite(sql: String, parameters: List<Any>?): Long {
+        return writeTransaction {
+            execute(sql, parameters)
+        }
+    }
+
     // Register callback for table updates
     private fun tableUpdates(): Flow<List<String>> {
         return driver.tableUpdates()