新增 事务回滚

Author: zzfly256

App/Controller/apiController.php

@@ -8,8 +8,18 @@
 class apiController extends Controller {
 
     public function testGet($id){
-        $data = Demo::find($id);
-        return $this->response($data);
+        $table = "demo";
+        $database = new Database($table);
+
+        $database->beginTransaction();
+        $database->where([ "id" => 1])->update([ "author" => $id ]);
+        if($id ==1 ){
+            sleep(10);
+        }
+
+        dump($database->commit());
+
+        dd(Demo::find(1));
     }
 
     // ORM 查询类方法演示
@@ -142,4 +152,22 @@ public function responseDemoGet($id){
         //    }
 
     }
+
+    public function transactionGet($id){
+        // 事物演示，以第一行的数据作为例子（并没使用异常捕获并回滚）
+        $table = "demo";
+        $database = new Database($table);
+        //开始事物
+        $database->beginTransaction();
+        $database->where([ "id" => 1])->update([ "author" => $id ]);
+
+        // 如果请求的 id 是 1，则等待 10 秒
+        // 在这 10 秒内，可以试着用不同的 id 进行访问，结果： id 为 1 的请求在 10 秒后完成，其余请求亦是在 id 为 1 的请求完成后全部完成，可见事物起作用了（因为其他请求被阻塞了呀！事物操作具有原子性和隔离性，并常用于保持数据的一致）
+        if($id ==1 ){
+            sleep(10);
+        }
+        
+        dump($database->commit());
+        dd(Demo::find(1));
+    }
 }

System/Database.php

@@ -128,21 +128,28 @@ public function fetchAll() {
 
     /**
      * 开始一个新的事务
-     * @uses 用于 Model->update(), Model->delete(), Model->save() 等操作的准备工作
+     * @return boolean
      */
     public function beginTransaction() {
-        $this->PDOConnect->beginTransaction();
+        return $this->PDOConnect->beginTransaction();
     }
 
     /**
      * 提交事务
      * @return boolean
-     * @uses 用于 Model->update(), Model->delete(), Model->save() 等操作使 SQL 生效
      */
     public function commit() {
         return $this->PDOConnect->commit();
     }
 
+    /**
+     * 回滚事务
+     * @return boolean
+     */
+    public function rollBack() {
+        return $this->PDOConnect->rollBack();
+    }
+
 
     // ORM 数据库查询方法