Merge pull request #897 from utopia-php/fix/remove-postgres-transaction-override

refactor(transaction): inherit postgres startTransaction

Author: abnegate

src/Database/Adapter/Postgres.php

@@ -31,44 +31,6 @@
 class Postgres extends SQL
 {
     public const MAX_IDENTIFIER_NAME = 63;
-    /**
-     * @inheritDoc
-     */
-    public function startTransaction(): bool
-    {
-        try {
-            if ($this->inTransaction === 0) {
-                try {
-                    if ($this->getPDO()->inTransaction()) {
-                        $this->getPDO()->rollBack();
-                    } else {
-                        // If no active transaction, this has no effect.
-                        $this->getPDO()->prepare('ROLLBACK')->execute();
-                    }
-                } catch (PDOException) {
-                    // A pooled connection can report a transaction it no longer
-                    // holds after a reconnect (e.g. Swoole PDOProxy keeps its own
-                    // counter), making this cleanup rollback throw. It is best
-                    // effort; swallow it and begin a fresh transaction below.
-                }
-
-                $result = $this->getPDO()->beginTransaction();
-            } else {
-                $this->getPDO()->exec('SAVEPOINT transaction' . $this->inTransaction);
-                $result = true;
-            }
-        } catch (PDOException $e) {
-            throw new TransactionException('Failed to start transaction: ' . $e->getMessage(), $e->getCode(), $e);
-        }
-
-        if (!$result) {
-            throw new TransactionException('Failed to start transaction');
-        }
-
-        $this->inTransaction++;
-
-        return $result;
-    }
 
     /**
      * @inheritDoc

tests/unit/SQLTransactionTest.php

@@ -4,11 +4,13 @@
 
 use PDOException;
 use PHPUnit\Framework\TestCase;
+use ReflectionMethod;
 use Utopia\Database\Adapter\MySQL;
 use Utopia\Database\Adapter\Postgres;
+use Utopia\Database\Adapter\SQL;
 use Utopia\Database\Exception\Transaction as TransactionException;
 
-class SQLTransactionTest extends TestCase
+final class SQLTransactionTest extends TestCase
 {
     /**
      * A pooled connection (e.g. Swoole PDOProxy) can keep its own transaction
@@ -61,6 +63,9 @@ public function testStartTransactionDoesNotMaskBeginFailureAfterDesyncedRollback
 
     public function testPostgresStartTransactionRecoversFromDesyncedRollback(): void
     {
+        $method = new ReflectionMethod(Postgres::class, 'startTransaction');
+        $this->assertSame(SQL::class, $method->getDeclaringClass()->getName());
+
         $pdo = $this->getMockBuilder(\PDO::class)
             ->disableOriginalConstructor()
             ->getMock();