fix init params test

Author: insani7y

python/tests/test_transaction.py

@@ -5,11 +5,14 @@
 import pytest
 
 from psqlpy import Cursor, IsolationLevel, PSQLPool, ReadVariant
-from psqlpy.exceptions import DBTransactionError
+from psqlpy.exceptions import DBTransactionError, RustPSQLDriverPyBaseError
 
 
 @pytest.mark.anyio()
-async def test_transaction_init_parameters(psql_pool: PSQLPool) -> None:
+async def test_transaction_init_parameters(
+    psql_pool: PSQLPool,
+    table_name: str,
+) -> None:
     connection = await psql_pool.connection()
 
     test_init_parameters: typing.Final[list[dict[str, typing.Any]]] = [
@@ -35,13 +38,26 @@ async def test_transaction_init_parameters(psql_pool: PSQLPool) -> None:
             "read_variant": ReadVariant.ReadWrite,
         },
     ]
-
     for init_parameters in test_init_parameters:
-        connection.transaction(
+        insert_exception = None
+        async with connection.transaction(
             isolation_level=init_parameters.get("isolation_level"),
             deferrable=init_parameters.get("deferrable"),
             read_variant=init_parameters.get("read_variant"),
-        )
+        ) as transaction:
+            await transaction.execute("SELECT 1")
+            try:
+                await transaction.execute(
+                    f"INSERT INTO {table_name} VALUES ($1, $2)",
+                    parameters=[100, "test_name"],
+                )
+            except RustPSQLDriverPyBaseError as exception:
+                insert_exception = exception
+
+            assert (
+                insert_exception is None
+                or init_parameters.get("read_variant") is ReadVariant.ReadOnly
+            )
 
 
 @pytest.mark.anyio()

src/driver/transaction.rs

@@ -27,7 +27,7 @@ pub struct RustTransaction {
 
     isolation_level: Option<IsolationLevel>,
     read_variant: Option<ReadVariant>,
-    deferrable: Option<bool>,
+    deferable: Option<bool>,
     cursor_num: usize,
 }
 
@@ -40,7 +40,7 @@ impl RustTransaction {
         rollback_savepoint: Arc<tokio::sync::RwLock<HashSet<String>>>,
         isolation_level: Option<IsolationLevel>,
         read_variant: Option<ReadVariant>,
-        deferrable: Option<bool>,
+        deferable: Option<bool>,
         cursor_num: usize,
     ) -> Self {
         Self {
@@ -50,7 +50,7 @@ impl RustTransaction {
             rollback_savepoint,
             isolation_level,
             read_variant,
-            deferrable,
+            deferable,
             cursor_num,
         }
     }
@@ -108,7 +108,7 @@ impl RustTransaction {
 
     /// Start transaction
     /// Set up isolation level if specified
-    /// Set up deferrable if specified
+    /// Set up deferable if specified
     ///
     /// # Errors
     /// May return Err Result if cannot execute querystring.
@@ -124,7 +124,7 @@ impl RustTransaction {
             querystring.push_str(format!(" {}", &read_var.to_str_option()).as_str());
         }
 
-        if self.deferrable.is_some() {
+        if self.deferable.is_some() {
             querystring.push_str(" DEFERRABLE");
         } else {
             querystring.push_str(" NOT DEFERRABLE");