Add transaction isolation param

amphp · Oct 11, 2024 · 94a2465 · 94a2465
1 parent 04c8bbd
commit 94a2465
Showing 1 changed file with 10 additions and 1 deletion.
diff --git a/src/PostgresConnectionPool.php b/src/PostgresConnectionPool.php
@@ -8,6 +8,8 @@
 use Amp\Sql\SqlResult;
 use Amp\Sql\SqlStatement;
 use Amp\Sql\SqlTransaction;
+use Amp\Sql\SqlTransactionIsolation;
+use Amp\Sql\SqlTransactionIsolationLevel;
 use function Amp\async;
 
 /**
@@ -33,8 +35,15 @@ public function __construct(
         int $idleTimeout = self::DEFAULT_IDLE_TIMEOUT,
         private readonly bool $resetConnections = true,
         ?SqlConnector $connector = null,
+        SqlTransactionIsolation $transactionIsolation = SqlTransactionIsolationLevel::Committed,
     ) {
-        parent::__construct($config, $connector ?? postgresConnector(), $maxConnections, $idleTimeout);
+        parent::__construct(
+            config: $config,
+            connector: $connector ?? postgresConnector(),
+            maxConnections: $maxConnections,
+            idleTimeout: $idleTimeout,
+            transactionIsolation: $transactionIsolation,
+        );
     }
 
     /**