增加事务相关操作

wonder-game · Apr 11, 2022 · ad5c583 · ad5c583
1 parent a8072b7
commit ad5c583
Showing 1 changed file with 18 additions and 0 deletions.
diff --git a/src/Model/BaseModelTrait.php b/src/Model/BaseModelTrait.php
@@ -2,6 +2,7 @@
 
 namespace WonderGame\EsUtility\Model;
 
+use EasySwoole\ORM\DbManager;
 use EasySwoole\RedisPool\RedisPool;
 use EasySwoole\ORM\AbstractModel;
 
@@ -416,6 +417,23 @@ protected function _after_delete($res)
         $where = [];
     }
 
+    // 开启事务
+    public function startTrans()
+    {
+        DbManager::getInstance()->startTransaction($this->getQueryConnection());
+    }
+
+    public function commit()
+    {
+        DbManager::getInstance()->commit($this->getQueryConnection());
+
+    }
+
+    public function rollback()
+    {
+        DbManager::getInstance()->rollback($this->getQueryConnection());
+    }
+
     /******************** 兼容部分项目 _error ，最好能改为异常处理 ************************/
     public function getError()
     {