code · pull · May 20, 2025 · May 16, 2025 · May 20, 2025 · May 20, 2025
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -25,18 +25,18 @@ exclude = [
 ]
 
 [workspace.package]
-version = "0.9.7"
+version = "0.9.8"
 authors = ["the libSQL authors"]
 edition = "2021"
 license = "MIT"
 repository = "https://github.com/tursodatabase/libsql"
 
 [workspace.dependencies]
-libsql-ffi = { path = "libsql-ffi", version = "0.9.7" }
-libsql-sys = { path = "libsql-sys", version = "0.9.7", default-features = false }
-libsql-hrana = { path = "libsql-hrana", version = "0.9.7" }
-libsql_replication = { path = "libsql-replication", version = "0.9.7" }
-rusqlite = { package = "libsql-rusqlite", path = "vendored/rusqlite", version = "0.9.7", default-features = false, features = [
+libsql-ffi = { path = "libsql-ffi", version = "0.9.8" }
+libsql-sys = { path = "libsql-sys", version = "0.9.8", default-features = false }
+libsql-hrana = { path = "libsql-hrana", version = "0.9.8" }
+libsql_replication = { path = "libsql-replication", version = "0.9.8" }
+rusqlite = { package = "libsql-rusqlite", path = "vendored/rusqlite", version = "0.9.8", default-features = false, features = [
     "libsql-experimental",
     "column_decltype",
     "load_extension",

diff --git a/libsql/src/database/builder.rs b/libsql/src/database/builder.rs
@@ -2,9 +2,8 @@ cfg_core! {
     use crate::EncryptionConfig;
 }
 
-use crate::{Database, Result};
-
 use super::DbType;
+use crate::{Database, Result};
 
 /// A builder for [`Database`]. This struct can be used to build
 /// all variants of [`Database`]. These variants include:
@@ -644,11 +643,18 @@ cfg_sync! {
             }
 
             let mut bg_abort: Option<std::sync::Arc<crate::sync::DropAbort>> = None;
-            let conn = db.connect()?;
-
-            let sync_ctx = db.sync_ctx.as_ref().unwrap().clone();
 
             if let Some(sync_interval) = sync_interval {
+                let sync_ctx = db.sync_ctx.as_ref().unwrap().clone();
+                {
+                    let mut ctx = sync_ctx.lock().await;
+                    crate::sync::bootstrap_db(&mut ctx).await?;
+                }
+
+                // db.connect creates a local db file, so it is important that we always call
+                // `bootstrap_db` (for synced dbs) before calling connect. Otherwise, the sync
+                // protocol skips calling `export` endpoint causing slowdown in initial bootstrap.
+                let conn = db.connect()?;
                 let jh = tokio::spawn(
                     async move {
                         loop {

diff --git a/libsql/src/hrana/hyper.rs b/libsql/src/hrana/hyper.rs
@@ -234,6 +234,10 @@ impl crate::statement::Stmt for crate::hrana::Statement<HttpSender> {
         Some(&named_param.name)
     }
 
+    fn column_count(&self) -> usize {
+        self.cols.len()
+    }
+
     fn columns(&self) -> Vec<crate::Column> {
         //FIXME: there are several blockers here:
         // 1. We cannot know the column types before sending a query, so this method will never return results right

diff --git a/libsql/src/local/impls.rs b/libsql/src/local/impls.rs
@@ -145,6 +145,10 @@ impl Stmt for LibsqlStmt {
         self.0.parameter_name(idx)
     }
 
+    fn column_count(&self) -> usize {
+        self.0.column_count()
+    }
+
     fn columns(&self) -> Vec<Column> {
         self.0.columns()
     }

diff --git a/libsql/src/replication/connection.rs b/libsql/src/replication/connection.rs
@@ -779,6 +779,16 @@ impl Stmt for RemoteStatement {
         }
     }
 
+    fn column_count(&self) -> usize {
+        if let Some(stmt) = self.local_statement.as_ref() {
+            return stmt.column_count();
+        }
+        match self.metas.first() {
+            Some(meta) => meta.columns.len(),
+            None => 0,
+        }
+    }
+
     fn columns(&self) -> Vec<Column> {
         if let Some(stmt) = self.local_statement.as_ref() {
             return stmt.columns();

diff --git a/libsql/src/statement.rs b/libsql/src/statement.rs
@@ -22,6 +22,8 @@ pub(crate) trait Stmt {
 
     fn parameter_name(&self, idx: i32) -> Option<&str>;
 
+    fn column_count(&self) -> usize;
+
     fn columns(&self) -> Vec<Column>;
 }
 
@@ -95,6 +97,11 @@ impl Statement {
         self.inner.parameter_name(idx)
     }
 
+    /// Fetch the number of columns for the prepared statement.
+    pub fn column_count(&self) -> usize {
+        self.inner.column_count()
+    }
+
     /// Fetch the list of columns for the prepared statement.
     pub fn columns(&self) -> Vec<Column> {
         self.inner.columns()

diff --git a/libsql/src/sync/statement.rs b/libsql/src/sync/statement.rs
@@ -56,6 +56,10 @@ impl Stmt for SyncedStatement {
         self.inner.parameter_name(idx)
     }
 
+    fn column_count(&self) -> usize {
+        self.inner.column_count()
+    }
+
     fn columns(&self) -> Vec<Column> {
         self.inner.columns()
     }

diff --git a/vendored/rusqlite/Cargo.toml b/vendored/rusqlite/Cargo.toml
@@ -1,7 +1,7 @@
 [package]
 name = "libsql-rusqlite"
 # Note: Update version in README.md when you change this.
-version = "0.9.7"
+version = "0.9.8"
 authors = ["The rusqlite developers"]
 edition = "2018"
 description = "Ergonomic wrapper for SQLite (libsql fork)"