chore(powersync): align rusqlite with sqlx-sqlite

examples/egui_todolist/Cargo.toml

@@ -11,7 +11,7 @@ futures-lite = "2.6.1"
 log = "0.4.28"
 powersync = { path = "../../powersync", features = ["tokio", "reqwest"] }
 reqwest = { version = "0.13.2", features = ["json"] }
-rusqlite = { version = "0.39.0", features = ["load_extension", "bundled"] }
+rusqlite = { version = "0.32.0", features = ["load_extension", "bundled"] }
 serde = "1.0.228"
 serde_json = "1.0.145"
 tokio = { version = "1.47.1", features = ["rt-multi-thread", "net"] }

powersync/Cargo.toml

@@ -33,7 +33,7 @@ reqwest = { version = "0.13.2", default-features = false, optional = true, featu
 bytes = "1"
 log = "0.4.28"
 pin-project-lite = "0.2.16"
-rusqlite = { version = "0.39.0", features = ["load_extension"] }
+rusqlite = { version = "0.32.0", features = ["load_extension"] }
 scopeguard = "1.2.0"
 serde = { version = "1.0.219", features = ["derive", "rc"] }
 serde_json = { version = "1.0.143", features = ["raw_value"] }

powersync/src/db/internal.rs

@@ -83,7 +83,7 @@ impl InnerPowerSyncState {
 
         let serialized_schema = serde_json::to_string(&self.schema)?;
         conn.prepare("SELECT powersync_replace_schema(?)")?
-            .query_one(params![serialized_schema], |_| Ok(()))?;
+            .query_row(params![serialized_schema], |_| Ok(()))?;
         // TODO: Update readers? Should be fine at the moment because we're only doing this during
         // initialization.
         Ok(())

powersync/src/db/pool.rs

@@ -25,7 +25,7 @@ impl ConnectionPool {
         connection
             .prepare("SELECT powersync_update_hooks('install');")
             .expect("should prepare statement for update hooks")
-            .query_one(params![], |_| Ok(()))
+            .query_row(params![], |_| Ok(()))
             .expect("could not install update hook");
 
         Arc::new(Mutex::new(connection))
@@ -119,7 +119,7 @@ impl ConnectionPool {
         writer: &Connection,
     ) -> Result<SqliteUpdateNotification, Error> {
         let mut stmt = writer.prepare_cached("SELECT powersync_update_hooks('get');")?;
-        let rows: String = stmt.query_one(params![], |row| row.get(0))?;
+        let rows: String = stmt.query_row(params![], |row| row.get(0))?;
 
         let updates = serde_json::from_str::<SqliteUpdateNotification>(&rows)
             .map_err(|_| Error::InvalidQuery)?;

powersync/src/sync/upload.rs

@@ -298,7 +298,7 @@ impl<'a> CrudUpload<'a> {
         let client_id = {
             let reader = self.db.reader().await?;
             let mut stmt = reader.prepare("SELECT powersync_client_id()")?;
-            let id: String = stmt.query_one(params![], |row| row.get(0))?;
+            let id: String = stmt.query_row(params![], |row| row.get(0))?;
             id
         };
 

powersync/tests/crud_test.rs

@@ -305,7 +305,7 @@ fn raw_table_clear() {
         {
             let writer = db.writer().await.unwrap();
             let mut stmt = writer.prepare("SELECT powersync_clear(0)").unwrap();
-            stmt.query_one(params![], |_| Ok(())).unwrap();
+            stmt.query_row(params![], |_| Ok(())).unwrap();
         }
 
         assert_eq!(
@@ -347,7 +347,7 @@ fn raw_table_crud_trigger() {
 
             for write in &["INSERT", "UPDATE", "DELETE"] {
                 trigger_stmt
-                    .query_one(
+                    .query_row(
                         params![serialized_table, format!("users_{write}"), write],
                         |_| Ok(()),
                     )

powersync/tests/database_test.rs

@@ -18,7 +18,7 @@ fn link_core_extension() {
 
         let reader = db.reader().await.unwrap();
         let mut stmt = reader.prepare("SELECT powersync_rs_version();").unwrap();
-        let _: String = stmt.query_one(params![], |row| row.get(0)).unwrap();
+        let _: String = stmt.query_row(params![], |row| row.get(0)).unwrap();
     });
 }
 

powersync_test_utils/Cargo.toml

@@ -16,7 +16,7 @@ log = "0.4.28"
 bytes = "1"
 pin-project-lite = "0.2.16"
 powersync = { path = "../powersync" }
-rusqlite = { version = "0.39.0", features = ["load_extension", "bundled"] }
+rusqlite = { version = "0.32.0", features = ["load_extension", "bundled"] }
 serde = "1.0.228"
 serde_json = "1.0.145"
 serde_with = "3.15.0"