diff --git a/src/database/executors/pgrx.rs b/src/database/executors/pgrx.rs
index 1552003..9041de7 100644
--- a/src/database/executors/pgrx.rs
+++ b/src/database/executors/pgrx.rs
@@ -77,8 +77,8 @@ impl DatabaseExecutor for SpiExecutor {
 
     pgrx::debug1!("JSPG_SQL: {}", sql);
     self.transact(|| {
-      Spi::connect(|client| {
-        match client.select(sql, Some(args_with_oid.len() as i64), &args_with_oid) {
+      Spi::connect_mut(|client| {
+        match client.update(sql, Some(args_with_oid.len() as i64), &args_with_oid) {
           Ok(tup_table) => {
             let mut results = Vec::new();
             for row in tup_table {