libsql: Make Statement::run() immutable

Author: penberg

libsql/src/hrana/hyper.rs

@@ -245,7 +245,7 @@ impl crate::statement::Stmt for crate::hrana::Statement<HttpSender> {
         self.query(params).await
     }
 
-    async fn run(&mut self, params: &Params) -> crate::Result<()> {
+    async fn run(&self, params: &Params) -> crate::Result<()> {
         self.run(params).await
     }
 

libsql/src/hrana/mod.rs

@@ -170,7 +170,7 @@ where
         Ok(result.affected_row_count as usize)
     }
 
-    pub async fn run(&mut self, params: &Params) -> crate::Result<()> {
+    pub async fn run(&self, params: &Params) -> crate::Result<()> {
         let mut stmt = self.inner.clone();
         bind_params(params.clone(), &mut stmt);
 

libsql/src/local/impls.rs

@@ -122,7 +122,7 @@ impl Stmt for LibsqlStmt {
         stmt.query(&params).map(LibsqlRows).map(Rows::new)
     }
 
-    async fn run(&mut self, params: &Params) -> Result<()> {
+    async fn run(&self, params: &Params) -> Result<()> {
         let params = params.clone();
         let stmt = self.0.clone();
 

libsql/src/replication/connection.rs

@@ -722,8 +722,8 @@ impl Stmt for RemoteStatement {
         Ok(Rows::new(RemoteRows(rows, 0)))
     }
 
-    async fn run(&mut self, params: &Params) -> Result<()> {
-        if let Some(stmt) = &mut self.local_statement {
+    async fn run(&self, params: &Params) -> Result<()> {
+        if let Some(stmt) = &self.local_statement {
             return stmt.run(params.clone()).await;
         }
 

libsql/src/statement.rs

@@ -12,7 +12,7 @@ pub(crate) trait Stmt {
 
     async fn query(&self, params: &Params) -> Result<Rows>;
 
-    async fn run(&mut self, params: &Params) -> Result<()>;
+    async fn run(&self, params: &Params) -> Result<()>;
 
     fn interrupt(&self) -> Result<()>;
 
@@ -58,7 +58,7 @@ impl Statement {
     /// provided to execute any type of SQL statement.
     ///
     /// Note: This is an extension to the Rusqlite API.
-    pub async fn run(&mut self, params: impl IntoParams) -> Result<()> {
+    pub async fn run(&self, params: impl IntoParams) -> Result<()> {
         tracing::trace!("run for prepared statement");
         self.inner.run(&params.into_params()?).await?;
         Ok(())

libsql/src/sync/statement.rs

@@ -38,7 +38,7 @@ impl Stmt for SyncedStatement {
         self.inner.query(params).await
     }
 
-    async fn run(&mut self, params: &Params) -> Result<()> {
+    async fn run(&self, params: &Params) -> Result<()> {
         if self.needs_pull.load(Ordering::Relaxed) {
             let mut context = self.context.lock().await;
             crate::sync::try_pull(&mut context, &self.conn).await?;