Don't run SET TRANSACTION ISOLATION LEVEL with sqlite

prisma · Sep 11, 2023 · cc3295d · cc3295d
1 parent 5b1a9cb
commit cc3295d
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 6 deletions.
diff --git a/query-engine/driver-adapters/src/proxy.rs b/query-engine/driver-adapters/src/proxy.rs
@@ -44,7 +44,7 @@ pub(crate) struct TransactionProxy {
     /// commit transaction
     commit: AsyncJsFunction<(), ()>,
 
-    /// rollback transcation
+    /// rollback transaction
     rollback: AsyncJsFunction<(), ()>,
 }
 
@@ -353,7 +353,7 @@ impl TransactionProxy {
     pub fn new(js_transaction: &JsObject) -> napi::Result<Self> {
         let commit = js_transaction.get_named_property("commit")?;
         let rollback = js_transaction.get_named_property("rollback")?;
-        let options: TransactionOptions = js_transaction.get_named_property("options")?;
+        let options = js_transaction.get_named_property("options")?;
 
         Ok(Self {
             commit,

diff --git a/query-engine/driver-adapters/src/queryable.rs b/query-engine/driver-adapters/src/queryable.rs
@@ -6,10 +6,7 @@ use async_trait::async_trait;
 use napi::JsObject;
 use psl::datamodel_connector::Flavour;
 use quaint::{
-    connector::{
-        metrics::{self},
-        IsolationLevel, Transaction,
-    },
+    connector::{metrics, IsolationLevel, Transaction},
     error::{Error, ErrorKind},
     prelude::{Query as QuaintQuery, Queryable as QuaintQueryable, ResultSet, TransactionCapable},
     visitor::{self, Visitor},
@@ -112,6 +109,13 @@ impl QuaintQueryable for JsBaseQueryable {
             return Err(Error::builder(ErrorKind::invalid_isolation_level(&isolation_level)).build());
         }
 
+        if self.flavour == Flavour::Sqlite {
+            return match isolation_level {
+                IsolationLevel::Serializable => Ok(()),
+                _ => Err(Error::builder(ErrorKind::invalid_isolation_level(&isolation_level)).build()),
+            };
+        }
+
         self.raw_cmd(&format!("SET TRANSACTION ISOLATION LEVEL {isolation_level}"))
             .await
     }