Transactions

Author: riverside

src/DB.php

@@ -44,6 +44,32 @@ public function __construct()
         $this->mount();
     }
 
+    public function autoCommit(int $value): DB
+    {
+        $statement = sprintf("SET AUTOCOMMIT = %u;", $value);
+        if (!$this->fire($statement))
+        {
+            return false;
+        }
+
+        $this->dump();
+
+        return $this;
+    }
+
+    public function begin(): DB
+    {
+        $statement = "BEGIN;";
+        if (!$this->fire($statement))
+        {
+            return false;
+        }
+
+        $this->dump();
+
+        return $this;
+    }
+
     protected function buildInsert(array $data, $modifiers=null, $upsert=false): string
     {
         if ($modifiers)
@@ -167,7 +193,20 @@ protected function buildWhere(): string
 
         return join(' AND ', $tmp);
     }
-    
+
+    public function commit(): DB
+    {
+        $statement = "COMMIT;";
+        if (!$this->fire($statement))
+        {
+            return false;
+        }
+
+        $this->dump();
+
+        return $this;
+    }
+
     public static function config(string $filename)
         {
         self::$config = $filename;
@@ -470,6 +509,19 @@ public function rightJoin(string $table, string $conditions): DB
         return $this;
     }
 
+    public function rollback(): DB
+    {
+        $statement = "ROLLBACK;";
+        if (!$this->fire($statement))
+        {
+            return false;
+        }
+
+        $this->dump();
+
+        return $this;
+    }
+
     public function select(string $value=null): DB
     {
         $this->select = $value;