增加执行原始方法

transaction_chain.go

@@ -877,6 +877,26 @@ func (this *TxQuery) CreateAll() (int64, error) {
 	return StmtForInsertExec(this.stmt, this.value)
 }
 
+/**
+ * 执行原生sql
+ * return error
+ */
+func (this *TxQuery) ExecSql(sql string) (int64, error) {
+	if this.debug {
+		log.Println("ExecSql sql:", sql)
+	}
+	stmt, err = this.tx.Prepare(sql)
+
+	if err != nil {
+		return 0, err
+	}
+	res, err := stmt.Exec()
+	if err != nil {
+		return 0, errors.New("执行失败：" + err.Error())
+	}
+	return res.RowsAffected()
+}
+
 /**
  * 提交
  */