- Began WIP on SQL specific PdoObject

src/Common/PdoObject/SqlPdoObject.php

@@ -0,0 +1,35 @@
+<?php
+
+namespace Ulmus\Common\PdoObject;
+
+class SqlPdoObject extends \Ulmus\Common\PdoObject
+{
+    protected int $openedTransaction = 0;
+
+    public function beginTransaction(): bool
+    {
+        if ( 0 === ++$this->openedTransaction ) {
+            return parent::beginTransaction();
+        }
+
+        return $this->exec('SAVEPOINT transaction_'.$this->openedTransaction) !== false;
+    }
+
+    public function commit() : bool
+    {
+        if ( 0 === --$this->openedTransaction) {
+            return parent::commit();
+        }
+
+        return false;
+    }
+
+    public function rollback() : bool
+    {
+        if (0 !== $this->openedTransaction) {
+            return $this->exec('ROLLBACK TO transaction_' . $this->openedTransaction--) !== false;
+        }
+
+        return parent::rollback();
+    }
+}

src/Common/PdoObject/SqlitePdoObject.php

@@ -0,0 +1,20 @@
+<?php
+
+namespace Ulmus\Common\PdoObject;
+
+class SqlitePdoObject extends SqlPdoObject
+{
+    public function beginTransaction(): bool
+    {
+        if ( 0 === ++$this->openedTransaction ) {
+            return $this->beginImmediateTransaction();
+        }
+
+        return $this->exec('SAVEPOINT transaction_'.$this->openedTransaction) !== false;
+    }
+
+    protected function beginImmediateTransaction(): bool
+    {
+        return $this->exec("BEGIN IMMEDIATE TRANSACTION") !== false;
+    }
+}