Support for transactions

bpolaszek · Jan 23, 2018 · 2a366fa · 2a366fa
1 parent 0c31627
commit 2a366fa
Show file tree

Hide file tree

Showing 3 changed files with 21 additions and 6 deletions.
diff --git a/src/Contract/AdapterInterface.php b/src/Contract/AdapterInterface.php
@@ -20,4 +20,19 @@ public function getWrappedConnection();
      * @return CredentialsInterface
      */
     public function getCredentials(): CredentialsInterface;
+
+    /**
+     * Init a transaction.
+     */
+    public function beginTransaction(): void;
+
+    /**
+     * Commit current transaction
+     */
+    public function commit(): void;
+
+    /**
+     * Rollback current transaction
+     */
+    public function rollback(): void;
 }
diff --git a/src/Model/Adapter/Mysqli/MysqliAdapter.php b/src/Model/Adapter/Mysqli/MysqliAdapter.php
@@ -280,15 +280,15 @@ private function runStmt(Statement $stmt)
     /**
      * @inheritDoc
      */
-    public function beginTransaction()
+    public function beginTransaction(): void
     {
         $this->getWrappedConnection()->autocommit(false);
     }
 
     /**
      * @inheritDoc
      */
-    public function commit()
+    public function commit(): void
     {
         $this->getWrappedConnection()->commit();
         $this->getWrappedConnection()->autocommit(true);
@@ -297,7 +297,7 @@ public function commit()
     /**
      * @inheritDoc
      */
-    public function rollback()
+    public function rollback(): void
     {
         $this->getWrappedConnection()->rollback();
         $this->getWrappedConnection()->autocommit(true);

diff --git a/src/Model/Adapter/PDO/PDOAdapter.php b/src/Model/Adapter/PDO/PDOAdapter.php
@@ -204,23 +204,23 @@ private function runStmt(Statement $stmt)
     /**
      * @inheritDoc
      */
-    public function beginTransaction()
+    public function beginTransaction(): void
     {
         $this->getWrappedConnection()->beginTransaction();
     }
 
     /**
      * @inheritDoc
      */
-    public function commit()
+    public function commit(): void
     {
         $this->getWrappedConnection()->commit();
     }
 
     /**
      * @inheritDoc
      */
-    public function rollback()
+    public function rollback(): void
     {
         $this->getWrappedConnection()->rollBack();
     }