Rewrote internal connection implementation.

Rewrote internal connection implementation, continue supporting DBAPI pep.

Author: chandr-andr

python/psqlpy/__init__.py

@@ -13,7 +13,6 @@
     ReadVariant,
     SingleQueryResult,
     SslMode,
-    SynchronousCommit,
     TargetSessionAttrs,
     Transaction,
     connect,
@@ -35,7 +34,6 @@
     "ReadVariant",
     "SingleQueryResult",
     "SslMode",
-    "SynchronousCommit",
     "TargetSessionAttrs",
     "Transaction",
     "connect",

python/psqlpy/_internal/__init__.pyi

@@ -150,38 +150,6 @@ class SingleQueryResult:
         Type that return passed function.
         """
 
-class SynchronousCommit(Enum):
-    """
-    Synchronous_commit option for transactions.
-
-    ### Variants:
-    - `On`: The meaning may change based on whether you have
-        a synchronous standby or not.
-        If there is a synchronous standby,
-        setting the value to on will result in waiting till “remote flush”.
-    - `Off`: As the name indicates, the commit acknowledgment can come before
-        flushing the records to disk.
-        This is generally called as an asynchronous commit.
-        If the PostgreSQL instance crashes,
-        the last few asynchronous commits might be lost.
-    - `Local`: WAL records are written and flushed to local disks.
-        In this case, the commit will be acknowledged after the
-        local WAL Write and WAL flush completes.
-    - `RemoteWrite`: WAL records are successfully handed over to
-        remote instances which acknowledged back
-        about the write (not flush).
-    - `RemoteApply`: This will result in commits waiting until replies from the
-        current synchronous standby(s) indicate they have received
-        the commit record of the transaction and applied it so
-        that it has become visible to queries on the standby(s).
-    """
-
-    On = 1
-    Off = 2
-    Local = 3
-    RemoteWrite = 4
-    RemoteApply = 5
-
 class IsolationLevel(Enum):
     """Isolation Level for transactions."""
 
@@ -1117,15 +1085,13 @@ class Connection:
         isolation_level: IsolationLevel | None = None,
         read_variant: ReadVariant | None = None,
         deferrable: bool | None = None,
-        synchronous_commit: SynchronousCommit | None = None,
     ) -> Transaction:
         """Create new transaction.
 
         ### Parameters:
         - `isolation_level`: configure isolation level of the transaction.
         - `read_variant`: configure read variant of the transaction.
         - `deferrable`: configure deferrable of the transaction.
-        - `synchronous_commit`: configure synchronous_commit option for transaction.
         """
     def cursor(
         self: Self,

python/tests/test_transaction.py

@@ -8,7 +8,6 @@
     Cursor,
     IsolationLevel,
     ReadVariant,
-    SynchronousCommit,
 )
 from psqlpy.exceptions import (
     InterfaceError,
@@ -362,29 +361,3 @@ async def test_execute_batch_method(psql_pool: ConnectionPool) -> None:
         await transaction.execute(querystring="SELECT * FROM execute_batch2")
 
     connection.back_to_pool()
-
-
-@pytest.mark.parametrize(
-    "synchronous_commit",
-    [
-        SynchronousCommit.On,
-        SynchronousCommit.Off,
-        SynchronousCommit.Local,
-        SynchronousCommit.RemoteWrite,
-        SynchronousCommit.RemoteApply,
-    ],
-)
-async def test_synchronous_commit(
-    synchronous_commit: SynchronousCommit,
-    psql_pool: ConnectionPool,
-    table_name: str,
-    number_database_records: int,
-) -> None:
-    async with psql_pool.acquire() as conn, conn.transaction(
-        synchronous_commit=synchronous_commit,
-    ) as trans:
-        res = await trans.execute(
-            f"SELECT * FROM {table_name}",
-        )
-
-        assert len(res.result()) == number_database_records