New unified driver interfaces

Author: simolus3

build.gradle.kts

@@ -13,8 +13,6 @@ plugins {
     alias(libs.plugins.skie) apply false
     alias(libs.plugins.kotlin.jvm) apply false
     alias(libs.plugins.kotlin.android) apply false
-    alias(libs.plugins.sqldelight) apply false
-    alias(libs.plugins.grammarKitComposer) apply false
     alias(libs.plugins.mavenPublishPlugin) apply false
     alias(libs.plugins.downloadPlugin) apply false
     alias(libs.plugins.kotlinter) apply false

compose/build.gradle.kts

@@ -19,7 +19,6 @@ kotlin {
     sourceSets {
         commonMain.dependencies {
             api(project(":core"))
-            implementation(project(":persistence"))
             implementation(compose.runtime)
         }
         androidMain.dependencies {

core/build.gradle.kts

@@ -201,6 +201,8 @@ kotlin {
             }
 
             dependencies {
+                api(libs.kermit)
+
                 implementation(libs.uuid)
                 implementation(libs.kotlin.stdlib)
                 implementation(libs.ktor.client.core)
@@ -213,8 +215,7 @@ kotlin {
                 implementation(libs.kotlinx.datetime)
                 implementation(libs.stately.concurrency)
                 implementation(libs.configuration.annotations)
-                api(projects.persistence)
-                api(libs.kermit)
+                implementation(projects.drivers.common)
             }
         }
 

core/src/androidMain/kotlin/com/powersync/DatabaseDriverFactory.android.kt

@@ -1,79 +1,37 @@
 package com.powersync
 
 import android.content.Context
-import com.powersync.db.JdbcSqliteDriver
-import com.powersync.db.buildDefaultWalProperties
-import com.powersync.db.internal.InternalSchema
-import com.powersync.db.migrateDriver
-import kotlinx.coroutines.CoroutineScope
-import org.sqlite.SQLiteCommitListener
-import java.util.concurrent.atomic.AtomicBoolean
+import androidx.sqlite.SQLiteConnection
+import com.powersync.db.loadExtensions
+import com.powersync.db.setSchemaVersion
+import com.powersync.internal.driver.AndroidDriver
+import com.powersync.internal.driver.ConnectionListener
+import com.powersync.internal.driver.JdbcConnection
 
 @Suppress("EXPECT_ACTUAL_CLASSIFIERS_ARE_IN_BETA_WARNING")
 public actual class DatabaseDriverFactory(
     private val context: Context,
 ) {
-    internal actual fun createDriver(
-        scope: CoroutineScope,
+    internal actual fun openDatabase(
         dbFilename: String,
         dbDirectory: String?,
         readOnly: Boolean,
-    ): PsSqlDriver {
-        val schema = InternalSchema
-
+        listener: ConnectionListener?
+    ): SQLiteConnection {
         val dbPath =
             if (dbDirectory != null) {
                 "$dbDirectory/$dbFilename"
             } else {
-                context.getDatabasePath(dbFilename)
+                "${context.getDatabasePath(dbFilename)}"
             }
 
-        val properties = buildDefaultWalProperties(readOnly = readOnly)
-        val isFirst = IS_FIRST_CONNECTION.getAndSet(false)
-        if (isFirst) {
-            // Make sure the temp_store_directory points towards a temporary directory we actually
-            // have access to. Due to sandboxing, the default /tmp/ is inaccessible.
-            // The temp_store_directory pragma is deprecated and not thread-safe, so we only set it
-            // on the first connection (it sets a global field and will affect every connection
-            // opened).
-            val escapedPath = context.cacheDir.absolutePath.replace("\"", "\"\"")
-            properties.setProperty("temp_store_directory", "\"$escapedPath\"")
-        }
-
-        val driver =
-            JdbcSqliteDriver(
-                url = "jdbc:sqlite:$dbPath",
-                properties = properties,
-            )
-
-        migrateDriver(driver, schema)
-
-        driver.loadExtensions(
+        val driver = AndroidDriver(context)
+        val connection = driver.openDatabase(dbPath, readOnly, listener) as JdbcConnection
+        connection.setSchemaVersion()
+        connection.loadExtensions(
             "libpowersync.so" to "sqlite3_powersync_init",
         )
 
-        val mappedDriver = PsSqlDriver(driver = driver)
-
-        driver.connection.database.addUpdateListener { _, _, table, _ ->
-            mappedDriver.updateTable(table)
-        }
-
-        driver.connection.database.addCommitListener(
-            object : SQLiteCommitListener {
-                override fun onCommit() {
-                    // We track transactions manually
-                }
-
-                override fun onRollback() {
-                    mappedDriver.clearTableUpdates()
-                }
-            },
-        )
-
-        return mappedDriver
-    }
-
-    private companion object {
-        val IS_FIRST_CONNECTION = AtomicBoolean(true)
+        return connection
     }
 }