增加3种事务方法begin/commit/rollback

plugins/db/Db.php

@@ -405,8 +405,17 @@ private function __query($sql, $retry=false, $params=[]){
 	 * @param string $sql
 	 * @return boolean|int|array
 	 */
-	public function execute($sql){
-		return $this->__query($sql);
+	public function execute($sql,$params=[]){
+		return $this->__query($sql, false, $params);
+	}
+	public function begin(){
+		return $this->engine->begin();
+	}
+	public function commit(){
+		return $this->engine->commit();
+	}
+	public function rollback(){
+		return $this->engine->rollback();
 	}
 
 	private function __quote($condition,$split="AND",&$params=[]){

plugins/db/DbMysqli.php

@@ -120,6 +120,24 @@ public function error(){
 		if(!$this->_stmt)return false;
 		return $this->_stmt->error;
 	}
+	public function begin(){
+		if($this->_mysqli->connect_errno){
+			return false;
+		}
+		return $this->_mysqli->begin_transaction();
+	}
+	public function commit(){
+		if($this->_mysqli->connect_errno){
+			return false;
+		}
+		return $this->_mysqli->commit();
+	}
+	public function rollback(){
+		if($this->_mysqli->connect_errno){
+			return false;
+		}
+		return $this->_mysqli->rollback();
+	}
 	public function errno(){
 		$error=0;
 		if($this->_mysqli->connect_errno){

plugins/db/DbPDO.php

@@ -90,6 +90,8 @@ public function query($sql,$params=[]){
 		$this->_stmt = $this->_pdo->prepare($sql);
 		if($this->_stmt){
 			return $this->_stmt->execute($params);
+		}else{
+			trigger_error("CONNECT DATABASE ERROR ( ".implode("\n",$this->_pdo->errorInfo())." ) ",E_USER_WARNING);
 		}
 		return false;
 	}
@@ -101,6 +103,18 @@ public function count(){
 		if(!$this->_stmt)return false;
 		return $this->_stmt->rowCount();
 	}
+	public function begin(){
+		if(!$this->_pdo)return false;
+		return $this->_pdo->beginTransaction();
+	}
+	public function commit(){
+		if(!$this->_pdo)return false;
+		return $this->_pdo->commit();
+	}
+	public function rollback(){
+		if(!$this->_pdo)return false;
+		return $this->_pdo->rollBack();
+	}
 	public function escape($str){
 		if(!$this->_pdo)return false;
 		return trim($this->_pdo->quote($str),"'");