Initial setup needed for transactional support

Todo: integrate into shortcut methods, need to handle methods routines to close/free/end connection.

In reference to #154

Author: TheTechsTech

lib/Database/ez_mysqli.php

@@ -13,6 +13,7 @@ class ez_mysqli extends ezsqlModel implements DatabaseInterface
     private $return_val = 0;
     private $is_insert = false;
     private $shortcutUsed = false;
+    private $isTransactional = false;
 
     /**
     * Database connection handle 
@@ -501,4 +502,29 @@ public function getInsertId()
     {
         return \mysqli_insert_id($this->dbh);
     } // getInsertId
+        
+    /**
+     * Begin Mysql Transaction
+     */
+    public function beginTransaction()
+    {
+        /* turn autocommit off */
+        $this->dbh->autocommit(false);
+        $this->dbh->begin_transaction(MYSQLI_TRANS_START_READ_WRITE);
+        $this->isTransactional = true;
+    }
+
+    public function commit()
+    {
+        $this->dbh->commit();
+        $this->dbh->autocommit(true);
+        $this->isTransactional = false;
+    }
+    
+    public function rollback()
+    {
+        $this->dbh->rollBack();
+        $this->dbh->autocommit(true);
+        $this->isTransactional = false;
+    }
 } // ez_mysqli

lib/Database/ez_pdo.php

@@ -14,6 +14,7 @@ class ez_pdo extends ezsqlModel implements DatabaseInterface
     private $return_val = 0;
     private $is_insert = false;
     private $shortcutUsed = false;
+    private $isTransactional = false;
 
     /**
      * Database connection handle 
@@ -469,4 +470,25 @@ public function handle()
     {
         return $this->dbh;
     }
+        
+    /**
+     * Begin PDO Transaction
+     */
+    public function beginTransaction()
+    {
+        $this->dbh->beginTransaction();
+        $this->isTransactional = true;
+    }
+
+    public function commit()
+    {
+        $this->dbh->commit();
+        $this->isTransactional = false;
+    }
+    
+    public function rollback()
+    {
+        $this->dbh->rollback();
+        $this->isTransactional = false;
+    }
 } // ez_pdo

lib/Database/ez_pgsql.php

@@ -13,6 +13,7 @@ class ez_pgsql extends ezsqlModel implements DatabaseInterface
     private $return_val = 0;
     private $is_insert = false;
     private $shortcutUsed = false;
+    private $isTransactional = false;
 
     /**
     * Database connection handle 
@@ -354,4 +355,25 @@ public function getPort()
     {
         return $this->database->getPort();
     } // getPort
+    
+    /**
+     * Begin Postgresql Transaction
+     */
+    public function beginTransaction()
+    {
+        @\pg_query($this->dbh, "BEGIN");
+        $this->isTransactional = true;
+    }
+
+    public function commit()
+    {
+        @\pg_query($this->dbh, "COMMIT");
+        $this->isTransactional = false;
+    }
+
+    public function rollback()
+    {
+        @\pg_query($this->dbh, "ROLLBACK");
+        $this->isTransactional = false;
+    }
 } // ez_pgsql

lib/Database/ez_sqlite3.php

@@ -13,6 +13,7 @@ class ez_sqlite3 extends ezsqlModel implements DatabaseInterface
     private $return_val = 0;
     private $is_insert = false;
     private $shortcutUsed = false;
+    private $isTransactional = false;
 
     /**
     * Database connection handle 
@@ -309,4 +310,25 @@ public function handle()
     {
         return $this->dbh;
     }
+       
+    /**
+     * Begin sqlite3 Transaction
+     */
+    public function beginTransaction()
+    {
+        $this->dbh->exec('BEGIN');
+        $this->isTransactional = true;
+    }
+
+    public function commit()
+    {
+        $this->dbh->exec('COMMIT');
+        $this->isTransactional = false;
+    }
+
+    public function rollback()
+    {
+        $this->dbh->exec('ROLLBACK');
+        $this->isTransactional = false;
+    }
 }

lib/Database/ez_sqlsrv.php

@@ -13,6 +13,7 @@ class ez_sqlsrv extends ezsqlModel implements DatabaseInterface
     private $return_val = 0;
     private $is_insert = false;
     private $shortcutUsed = false;
+    private $isTransactional = false;
 
     /**
      * ezSQL non duplicating data type id's; converting type ids to str
@@ -428,4 +429,25 @@ public function handle()
     {
         return $this->dbh;
     }
+        
+    /**
+     * Begin sqlsrv Transaction
+     */
+    public function beginTransaction()
+    {
+        @\sqlsrv_begin_transaction($this->dbh);
+        $this->isTransactional = true;
+    }
+
+    public function commit()
+    {
+        @\sqlsrv_commit($this->dbh);
+        $this->isTransactional = false;
+    }
+
+    public function rollback()
+    {
+        @\sqlsrv_rollback($this->dbh);
+        $this->isTransactional = false;
+    }
 } // end class

lib/DatabaseInterface.php

@@ -102,4 +102,19 @@ public function handle();
      * Reset connection handle
      */
     public function reset();
+    
+    /**
+     * Begin Transaction
+     */
+    public function beginTransaction();
+
+    /**
+     * Commit Transaction
+     */
+    public function commit();
+
+    /**
+     * Rollback Transaction
+     */
+    public function rollback();
 }