增加执行原始方法

chain.go

@@ -352,6 +352,7 @@ func (this *Query) BuildSelectSql() (map[string]interface{}, error) {
 	if len(this.join) > 0 {
 		var builder strings.Builder
 		builder.WriteString(sql)
+		boo := false
 		for _, joinitem := range this.join {
 			if len(joinitem) < 2 {
 				continue
@@ -370,8 +371,9 @@ func (this *Query) BuildSelectSql() (map[string]interface{}, error) {
 			}
 			builder.WriteString(" on ")
 			builder.WriteString(joinitem[1])
+			boo = true
 		}
-		if builder.Len() > 0 {
+		if boo {
 			sql = builder.String()
 		}
 	}

db.go

@@ -354,6 +354,7 @@ func GetRow(dbName, table_name, alias string, titles string, with, join [][]stri
 	if len(join) > 0 {
 		var builder strings.Builder
 		builder.WriteString(sql_str)
+		boo := false
 		for _, joinitem := range join {
 			if len(joinitem) < 2 {
 				continue
@@ -372,8 +373,9 @@ func GetRow(dbName, table_name, alias string, titles string, with, join [][]stri
 			}
 			builder.WriteString(" on ")
 			builder.WriteString(joinitem[1])
+			boo = true
 		}
-		if builder.Len() > 0 {
+		if boo {
 			sql_str = builder.String()
 		}
 	}
@@ -544,11 +546,11 @@ func FetchRows(dbName, table_name, alias string, titles string, with, join [][]s
 	if len(join) > 0 {
 		var builder strings.Builder
 		builder.WriteString(sql_str)
+		boo := false
 		for _, joinitem := range join {
 			if len(joinitem) < 2 {
 				continue
 			}
-
 			builder.WriteString(" ")
 			if len(joinitem) >= 3 {
 				builder.WriteString(joinitem[2])
@@ -563,8 +565,9 @@ func FetchRows(dbName, table_name, alias string, titles string, with, join [][]s
 			}
 			builder.WriteString(" on ")
 			builder.WriteString(joinitem[1])
+			boo = true
 		}
-		if builder.Len() > 0 {
+		if boo {
 			sql_str = builder.String()
 		}
 	}

transaction_chain.go

@@ -270,6 +270,7 @@ func (this *TxQuery) BuildSelectSql() (map[string]interface{}, error) {
 	if len(this.join) > 0 {
 		var builder strings.Builder
 		builder.WriteString(sql)
+		boo := false
 		for _, joinitem := range this.join {
 			if len(joinitem) < 2 {
 				continue
@@ -288,8 +289,9 @@ func (this *TxQuery) BuildSelectSql() (map[string]interface{}, error) {
 			}
 			builder.WriteString(" on ")
 			builder.WriteString(joinitem[1])
+			boo = true
 		}
-		if builder.Len() > 0 {
+		if boo {
 			sql = builder.String()
 		}
 	}
@@ -875,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()
+}
+
 /**
  * 提交
  */