新增新事务机制

engine.go

@@ -1425,16 +1425,16 @@ func (engine *Engine) dropAll() error {
 	session := engine.NewSession()
 	defer session.Close()
 
-	err := session.Begin()
+	tx, err := session.Begin()
 	if err != nil {
 		return err
 	}
 	err = session.dropAll()
 	if err != nil {
-		session.Rollback()
+		tx.Rollback()
 		return err
 	}
-	return session.Commit()
+	return tx.Commit()
 }
 
 // CreateTables create tabls according bean
@@ -1442,7 +1442,7 @@ func (engine *Engine) CreateTables(beans ...interface{}) error {
 	session := engine.NewSession()
 	defer session.Close()
 
-	err := session.Begin()
+	tx, err := session.Begin()
 	if err != nil {
 		return err
 	}
@@ -1450,11 +1450,11 @@ func (engine *Engine) CreateTables(beans ...interface{}) error {
 	for _, bean := range beans {
 		err = session.CreateTable(bean)
 		if err != nil {
-			session.Rollback()
+			tx.Rollback()
 			return err
 		}
 	}
-	return session.Commit()
+	return tx.Commit()
 }
 
 // DropTables drop specify tables
@@ -1462,7 +1462,7 @@ func (engine *Engine) DropTables(beans ...interface{}) error {
 	session := engine.NewSession()
 	defer session.Close()
 
-	err := session.Begin()
+	tx, err := session.Begin()
 	if err != nil {
 		return err
 	}
@@ -1470,11 +1470,11 @@ func (engine *Engine) DropTables(beans ...interface{}) error {
 	for _, bean := range beans {
 		err = session.DropTable(bean)
 		if err != nil {
-			session.Rollback()
+			tx.Rollback()
 			return err
 		}
 	}
-	return session.Commit()
+	return tx.Commit()
 }
 
 func (engine *Engine) createAll() error {

session.go

@@ -95,7 +95,7 @@ func (session *Session) Close() {
 		// When Close be called, if session is a transaction and do not call
 		// Commit or Rollback, then call Rollback.
 		if session.Tx != nil && !session.IsCommitedOrRollbacked {
-			session.Rollback()
+			session.rollback()
 		}
 		session.Tx = nil
 		session.stmtCache = nil
@@ -380,7 +380,7 @@ func (session *Session) Conds() builder.Cond {
 }
 
 // Begin a transaction
-func (session *Session) Begin() error {
+func (session *Session) begin() error {
 	if session.IsAutoCommit {
 		tx, err := session.DB().Begin()
 		if err != nil {
@@ -395,7 +395,7 @@ func (session *Session) Begin() error {
 }
 
 // Rollback When using transaction, you can rollback if any error
-func (session *Session) Rollback() error {
+func (session *Session) rollback() error {
 	if !session.IsAutoCommit && !session.IsCommitedOrRollbacked {
 		session.saveLastSQL(session.Engine.dialect.RollBackStr())
 		session.IsCommitedOrRollbacked = true
@@ -405,7 +405,7 @@ func (session *Session) Rollback() error {
 }
 
 // Commit When using transaction, Commit will commit all operations.
-func (session *Session) Commit() error {
+func (session *Session) commit() error {
 	if !session.IsAutoCommit && !session.IsCommitedOrRollbacked {
 		session.saveLastSQL("COMMIT")
 		session.IsCommitedOrRollbacked = true
@@ -541,7 +541,7 @@ func (session *Session) exec(sqlStr string, args ...interface{}) (sql.Result, er
 			if session.Engine.dialect.DBType() == core.ORACLE {
 				session.Begin()
 				r, err := session.Tx.Exec(sqlStr, args...)
-				session.Commit()
+				session.commit()
 				return r, err
 			}
 			return session.innerExec(sqlStr, args...)

sql_executor.go

@@ -29,7 +29,7 @@ func (sqlsExecutor *SqlsExecutor) Execute() ([][]map[string]interface{}, map[str
 	sqlModel := 1
 
 	if sqlsExecutor.session.IsSqlFuc == true {
-		err := sqlsExecutor.session.Begin()
+		err := sqlsExecutor.session.begin()
 		if err != nil {
 			return nil, nil, err
 		}
@@ -88,7 +88,7 @@ func (sqlsExecutor *SqlsExecutor) Execute() ([][]map[string]interface{}, map[str
 				sqlsExecutor.session.Engine.RemoveSql(key)
 			default:
 				if sqlsExecutor.session.IsSqlFuc == true {
-					err1 := sqlsExecutor.session.Rollback()
+					err1 := sqlsExecutor.session.rollback()
 					if err1 != nil {
 						return nil, nil, err1
 					}
@@ -102,7 +102,7 @@ func (sqlsExecutor *SqlsExecutor) Execute() ([][]map[string]interface{}, map[str
 		if sqlModel == 1 {
 			if model_1_results.Error != nil {
 				if sqlsExecutor.session.IsSqlFuc == true {
-					err1 := sqlsExecutor.session.Rollback()
+					err1 := sqlsExecutor.session.rollback()
 					if err1 != nil {
 						return nil, nil, err1
 					}
@@ -116,7 +116,7 @@ func (sqlsExecutor *SqlsExecutor) Execute() ([][]map[string]interface{}, map[str
 		} else if sqlModel == 2 {
 			if err != nil {
 				if sqlsExecutor.session.IsSqlFuc == true {
-					err1 := sqlsExecutor.session.Rollback()
+					err1 := sqlsExecutor.session.rollback()
 					if err1 != nil {
 						return nil, nil, err1
 					}
@@ -166,7 +166,7 @@ func (sqlsExecutor *SqlsExecutor) Execute() ([][]map[string]interface{}, map[str
 				if sqlModel == 1 {
 					if model_1_results.Error != nil {
 						if sqlsExecutor.session.IsSqlFuc == true {
-							err1 := sqlsExecutor.session.Rollback()
+							err1 := sqlsExecutor.session.rollback()
 							if err1 != nil {
 								return nil, nil, err1
 							}
@@ -179,7 +179,7 @@ func (sqlsExecutor *SqlsExecutor) Execute() ([][]map[string]interface{}, map[str
 				} else if sqlModel == 2 {
 					if err != nil {
 						if sqlsExecutor.session.IsSqlFuc == true {
-							err1 := sqlsExecutor.session.Rollback()
+							err1 := sqlsExecutor.session.rollback()
 							if err1 != nil {
 								return nil, nil, err1
 							}
@@ -197,7 +197,7 @@ func (sqlsExecutor *SqlsExecutor) Execute() ([][]map[string]interface{}, map[str
 					RowsAffected, err := model_2_results.RowsAffected()
 					if err != nil {
 						if sqlsExecutor.session.IsSqlFuc == true {
-							err1 := sqlsExecutor.session.Rollback()
+							err1 := sqlsExecutor.session.rollback()
 							if err1 != nil {
 								return nil, nil, err1
 							}
@@ -221,7 +221,7 @@ func (sqlsExecutor *SqlsExecutor) Execute() ([][]map[string]interface{}, map[str
 
 			default:
 				if sqlsExecutor.session.IsSqlFuc == true {
-					err1 := sqlsExecutor.session.Rollback()
+					err1 := sqlsExecutor.session.rollback()
 					if err1 != nil {
 						return nil, nil, err1
 					}
@@ -262,7 +262,7 @@ func (sqlsExecutor *SqlsExecutor) Execute() ([][]map[string]interface{}, map[str
 				if sqlModel == 1 {
 					if model_1_results.Error != nil {
 						if sqlsExecutor.session.IsSqlFuc == true {
-							err1 := sqlsExecutor.session.Rollback()
+							err1 := sqlsExecutor.session.rollback()
 							if err1 != nil {
 								return nil, nil, err1
 							}
@@ -275,7 +275,7 @@ func (sqlsExecutor *SqlsExecutor) Execute() ([][]map[string]interface{}, map[str
 				} else if sqlModel == 2 {
 					if err != nil {
 						if sqlsExecutor.session.IsSqlFuc == true {
-							err1 := sqlsExecutor.session.Rollback()
+							err1 := sqlsExecutor.session.rollback()
 							if err1 != nil {
 								return nil, nil, err1
 							}
@@ -293,7 +293,7 @@ func (sqlsExecutor *SqlsExecutor) Execute() ([][]map[string]interface{}, map[str
 					RowsAffected, err := model_2_results.RowsAffected()
 					if err != nil {
 						if sqlsExecutor.session.IsSqlFuc == true {
-							err1 := sqlsExecutor.session.Rollback()
+							err1 := sqlsExecutor.session.rollback()
 							if err1 != nil {
 								return nil, nil, err1
 							}
@@ -312,7 +312,7 @@ func (sqlsExecutor *SqlsExecutor) Execute() ([][]map[string]interface{}, map[str
 		}
 
 		if sqlsExecutor.session.IsSqlFuc == true {
-			err1 := sqlsExecutor.session.Commit()
+			err1 := sqlsExecutor.session.commit()
 			if err1 != nil {
 				return nil, nil, err1
 			}
@@ -347,7 +347,7 @@ func (sqlsExecutor *SqlsExecutor) Execute() ([][]map[string]interface{}, map[str
 				if sqlModel == 1 {
 					if model_1_results.Error != nil {
 						if sqlsExecutor.session.IsSqlFuc == true {
-							err1 := sqlsExecutor.session.Rollback()
+							err1 := sqlsExecutor.session.rollback()
 							if err1 != nil {
 								return nil, nil, err1
 							}
@@ -360,7 +360,7 @@ func (sqlsExecutor *SqlsExecutor) Execute() ([][]map[string]interface{}, map[str
 				} else if sqlModel == 2 {
 					if err != nil {
 						if sqlsExecutor.session.IsSqlFuc == true {
-							err1 := sqlsExecutor.session.Rollback()
+							err1 := sqlsExecutor.session.rollback()
 							if err1 != nil {
 								return nil, nil, err1
 							}
@@ -379,7 +379,7 @@ func (sqlsExecutor *SqlsExecutor) Execute() ([][]map[string]interface{}, map[str
 					if err != nil {
 
 						if sqlsExecutor.session.IsSqlFuc == true {
-							err1 := sqlsExecutor.session.Rollback()
+							err1 := sqlsExecutor.session.rollback()
 							if err1 != nil {
 								return nil, nil, err1
 							}
@@ -402,7 +402,7 @@ func (sqlsExecutor *SqlsExecutor) Execute() ([][]map[string]interface{}, map[str
 
 			default:
 				if sqlsExecutor.session.IsSqlFuc == true {
-					err1 := sqlsExecutor.session.Rollback()
+					err1 := sqlsExecutor.session.rollback()
 					if err1 != nil {
 						return nil, nil, err1
 					}
@@ -448,7 +448,7 @@ func (sqlsExecutor *SqlsExecutor) Execute() ([][]map[string]interface{}, map[str
 				if sqlModel == 1 {
 					if model_1_results.Error != nil {
 						if sqlsExecutor.session.IsSqlFuc == true {
-							err1 := sqlsExecutor.session.Rollback()
+							err1 := sqlsExecutor.session.rollback()
 							if err1 != nil {
 								return nil, nil, err1
 							}
@@ -461,7 +461,7 @@ func (sqlsExecutor *SqlsExecutor) Execute() ([][]map[string]interface{}, map[str
 				} else if sqlModel == 2 {
 					if err != nil {
 						if sqlsExecutor.session.IsSqlFuc == true {
-							err1 := sqlsExecutor.session.Rollback()
+							err1 := sqlsExecutor.session.rollback()
 							if err1 != nil {
 								return nil, nil, err1
 							}
@@ -479,7 +479,7 @@ func (sqlsExecutor *SqlsExecutor) Execute() ([][]map[string]interface{}, map[str
 					RowsAffected, err := model_2_results.RowsAffected()
 					if err != nil {
 						if sqlsExecutor.session.IsSqlFuc == true {
-							err1 := sqlsExecutor.session.Rollback()
+							err1 := sqlsExecutor.session.rollback()
 							if err1 != nil {
 								return nil, nil, err1
 							}
@@ -498,7 +498,7 @@ func (sqlsExecutor *SqlsExecutor) Execute() ([][]map[string]interface{}, map[str
 		}
 
 		if sqlsExecutor.session.IsSqlFuc == true {
-			err1 := sqlsExecutor.session.Commit()
+			err1 := sqlsExecutor.session.commit()
 			if err1 != nil {
 				return nil, nil, err1
 			}

sqlmaps_executor.go

@@ -29,7 +29,7 @@ func (sqlMapsExecutor *SqlMapsExecutor) Execute() ([][]map[string]interface{}, m
 	sqlModel := 1
 
 	if sqlMapsExecutor.session.IsSqlFuc == true {
-		err := sqlMapsExecutor.session.Begin()
+		err := sqlMapsExecutor.session.begin()
 		if err != nil {
 			return nil, nil, err
 		}
@@ -85,7 +85,7 @@ func (sqlMapsExecutor *SqlMapsExecutor) Execute() ([][]map[string]interface{}, m
 
 			default:
 				if sqlMapsExecutor.session.IsSqlFuc == true {
-					err1 := sqlMapsExecutor.session.Rollback()
+					err1 := sqlMapsExecutor.session.rollback()
 					if err1 != nil {
 						return nil, nil, err1
 					}
@@ -99,7 +99,7 @@ func (sqlMapsExecutor *SqlMapsExecutor) Execute() ([][]map[string]interface{}, m
 		if sqlModel == 1 {
 			if model_1_results.Error != nil {
 				if sqlMapsExecutor.session.IsSqlFuc == true {
-					err1 := sqlMapsExecutor.session.Rollback()
+					err1 := sqlMapsExecutor.session.rollback()
 					if err1 != nil {
 						return nil, nil, err1
 					}
@@ -112,7 +112,7 @@ func (sqlMapsExecutor *SqlMapsExecutor) Execute() ([][]map[string]interface{}, m
 		} else if sqlModel == 2 {
 			if err != nil {
 				if sqlMapsExecutor.session.IsSqlFuc == true {
-					err1 := sqlMapsExecutor.session.Rollback()
+					err1 := sqlMapsExecutor.session.rollback()
 					if err1 != nil {
 						return nil, nil, err1
 					}
@@ -163,7 +163,7 @@ func (sqlMapsExecutor *SqlMapsExecutor) Execute() ([][]map[string]interface{}, m
 				if sqlModel == 1 {
 					if model_1_results.Error != nil {
 						if sqlMapsExecutor.session.IsSqlFuc == true {
-							err1 := sqlMapsExecutor.session.Rollback()
+							err1 := sqlMapsExecutor.session.rollback()
 							if err1 != nil {
 								return nil, nil, err1
 							}
@@ -176,7 +176,7 @@ func (sqlMapsExecutor *SqlMapsExecutor) Execute() ([][]map[string]interface{}, m
 				} else if sqlModel == 2 {
 					if err != nil {
 						if sqlMapsExecutor.session.IsSqlFuc == true {
-							err1 := sqlMapsExecutor.session.Rollback()
+							err1 := sqlMapsExecutor.session.rollback()
 							if err1 != nil {
 								return nil, nil, err1
 							}
@@ -194,7 +194,7 @@ func (sqlMapsExecutor *SqlMapsExecutor) Execute() ([][]map[string]interface{}, m
 					RowsAffected, err := model_2_results.RowsAffected()
 					if err != nil {
 						if sqlMapsExecutor.session.IsSqlFuc == true {
-							err1 := sqlMapsExecutor.session.Rollback()
+							err1 := sqlMapsExecutor.session.rollback()
 							if err1 != nil {
 								return nil, nil, err1
 							}
@@ -218,7 +218,7 @@ func (sqlMapsExecutor *SqlMapsExecutor) Execute() ([][]map[string]interface{}, m
 
 			default:
 				if sqlMapsExecutor.session.IsSqlFuc == true {
-					err1 := sqlMapsExecutor.session.Rollback()
+					err1 := sqlMapsExecutor.session.rollback()
 					if err1 != nil {
 						return nil, nil, err1
 					}
@@ -258,7 +258,7 @@ func (sqlMapsExecutor *SqlMapsExecutor) Execute() ([][]map[string]interface{}, m
 				if sqlModel == 1 {
 					if model_1_results.Error != nil {
 						if sqlMapsExecutor.session.IsSqlFuc == true {
-							err1 := sqlMapsExecutor.session.Rollback()
+							err1 := sqlMapsExecutor.session.rollback()
 							if err1 != nil {
 								return nil, nil, err1
 							}
@@ -271,7 +271,7 @@ func (sqlMapsExecutor *SqlMapsExecutor) Execute() ([][]map[string]interface{}, m
 				} else if sqlModel == 2 {
 					if err != nil {
 						if sqlMapsExecutor.session.IsSqlFuc == true {
-							err1 := sqlMapsExecutor.session.Rollback()
+							err1 := sqlMapsExecutor.session.rollback()
 							if err1 != nil {
 								return nil, nil, err1
 							}
@@ -289,7 +289,7 @@ func (sqlMapsExecutor *SqlMapsExecutor) Execute() ([][]map[string]interface{}, m
 					RowsAffected, err := model_2_results.RowsAffected()
 					if err != nil {
 						if sqlMapsExecutor.session.IsSqlFuc == true {
-							err1 := sqlMapsExecutor.session.Rollback()
+							err1 := sqlMapsExecutor.session.rollback()
 							if err1 != nil {
 								return nil, nil, err1
 							}
@@ -308,7 +308,7 @@ func (sqlMapsExecutor *SqlMapsExecutor) Execute() ([][]map[string]interface{}, m
 		}
 
 		if sqlMapsExecutor.session.IsSqlFuc == true {
-			err1 := sqlMapsExecutor.session.Commit()
+			err1 := sqlMapsExecutor.session.commit()
 			if err1 != nil {
 				return nil, nil, err1
 			}
@@ -342,7 +342,7 @@ func (sqlMapsExecutor *SqlMapsExecutor) Execute() ([][]map[string]interface{}, m
 				if sqlModel == 1 {
 					if model_1_results.Error != nil {
 						if sqlMapsExecutor.session.IsSqlFuc == true {
-							err1 := sqlMapsExecutor.session.Rollback()
+							err1 := sqlMapsExecutor.session.rollback()
 							if err1 != nil {
 								return nil, nil, err1
 							}
@@ -355,7 +355,7 @@ func (sqlMapsExecutor *SqlMapsExecutor) Execute() ([][]map[string]interface{}, m
 				} else if sqlModel == 2 {
 					if err != nil {
 						if sqlMapsExecutor.session.IsSqlFuc == true {
-							err1 := sqlMapsExecutor.session.Rollback()
+							err1 := sqlMapsExecutor.session.rollback()
 							if err1 != nil {
 								return nil, nil, err1
 							}
@@ -373,7 +373,7 @@ func (sqlMapsExecutor *SqlMapsExecutor) Execute() ([][]map[string]interface{}, m
 					RowsAffected, err := model_2_results.RowsAffected()
 					if err != nil {
 						if sqlMapsExecutor.session.IsSqlFuc == true {
-							err1 := sqlMapsExecutor.session.Rollback()
+							err1 := sqlMapsExecutor.session.rollback()
 							if err1 != nil {
 								return nil, nil, err1
 							}
@@ -397,7 +397,7 @@ func (sqlMapsExecutor *SqlMapsExecutor) Execute() ([][]map[string]interface{}, m
 
 			default:
 				if sqlMapsExecutor.session.IsSqlFuc == true {
-					err1 := sqlMapsExecutor.session.Rollback()
+					err1 := sqlMapsExecutor.session.rollback()
 					if err1 != nil {
 						return nil, nil, err1
 					}
@@ -437,7 +437,7 @@ func (sqlMapsExecutor *SqlMapsExecutor) Execute() ([][]map[string]interface{}, m
 				if sqlModel == 1 {
 					if model_1_results.Error != nil {
 						if sqlMapsExecutor.session.IsSqlFuc == true {
-							err1 := sqlMapsExecutor.session.Rollback()
+							err1 := sqlMapsExecutor.session.rollback()
 							if err1 != nil {
 								return nil, nil, err1
 							}
@@ -450,7 +450,7 @@ func (sqlMapsExecutor *SqlMapsExecutor) Execute() ([][]map[string]interface{}, m
 				} else if sqlModel == 2 {
 					if err != nil {
 						if sqlMapsExecutor.session.IsSqlFuc == true {
-							err1 := sqlMapsExecutor.session.Rollback()
+							err1 := sqlMapsExecutor.session.rollback()
 							if err1 != nil {
 								return nil, nil, err1
 							}
@@ -468,7 +468,7 @@ func (sqlMapsExecutor *SqlMapsExecutor) Execute() ([][]map[string]interface{}, m
 					RowsAffected, err := model_2_results.RowsAffected()
 					if err != nil {
 						if sqlMapsExecutor.session.IsSqlFuc == true {
-							err1 := sqlMapsExecutor.session.Rollback()
+							err1 := sqlMapsExecutor.session.rollback()
 							if err1 != nil {
 								return nil, nil, err1
 							}
@@ -486,7 +486,7 @@ func (sqlMapsExecutor *SqlMapsExecutor) Execute() ([][]map[string]interface{}, m
 		}
 
 		if sqlMapsExecutor.session.IsSqlFuc == true {
-			err1 := sqlMapsExecutor.session.Commit()
+			err1 := sqlMapsExecutor.session.commit()
 			if err1 != nil {
 				return nil, nil, err1
 			}

sqltemplates_executor.go

@@ -30,7 +30,7 @@ func (sqlTemplatesExecutor *SqlTemplatesExecutor) Execute() ([][]map[string]inte
 	sqlModel := 1
 
 	if sqlTemplatesExecutor.session.IsSqlFuc == true {
-		err := sqlTemplatesExecutor.session.Begin()
+		err := sqlTemplatesExecutor.session.begin()
 		if err != nil {
 			return nil, nil, err
 		}
@@ -43,7 +43,7 @@ func (sqlTemplatesExecutor *SqlTemplatesExecutor) Execute() ([][]map[string]inte
 			sqlStr, err = sqlTemplatesExecutor.session.Engine.GetSqlTemplate(sqlkey).Execute(nil)
 			if err != nil {
 				if sqlTemplatesExecutor.session.IsSqlFuc == true {
-					err1 := sqlTemplatesExecutor.session.Rollback()
+					err1 := sqlTemplatesExecutor.session.rollback()
 					if err1 != nil {
 						return nil, nil, err1
 					}
@@ -71,7 +71,7 @@ func (sqlTemplatesExecutor *SqlTemplatesExecutor) Execute() ([][]map[string]inte
 				sqlStr, err = sqlTemplatesExecutor.session.Engine.GetSqlTemplate(sqlkey).Execute(parmaMap[0])
 				if err != nil {
 					if sqlTemplatesExecutor.session.IsSqlFuc == true {
-						err1 := sqlTemplatesExecutor.session.Rollback()
+						err1 := sqlTemplatesExecutor.session.rollback()
 						if err1 != nil {
 							return nil, nil, err1
 						}
@@ -98,7 +98,7 @@ func (sqlTemplatesExecutor *SqlTemplatesExecutor) Execute() ([][]map[string]inte
 				sqlStr, err = sqlTemplatesExecutor.session.Engine.GetSqlTemplate(sqlkey).Execute(parmaMap)
 				if err != nil {
 					if sqlTemplatesExecutor.session.IsSqlFuc == true {
-						err1 := sqlTemplatesExecutor.session.Rollback()
+						err1 := sqlTemplatesExecutor.session.rollback()
 						if err1 != nil {
 							return nil, nil, err1
 						}
@@ -166,7 +166,7 @@ func (sqlTemplatesExecutor *SqlTemplatesExecutor) Execute() ([][]map[string]inte
 				sqlStr, err := sqlTemplatesExecutor.session.Engine.GetSqlTemplate(sqlkeysSlice[i]).Execute(nil)
 				if err != nil {
 					if sqlTemplatesExecutor.session.IsSqlFuc == true {
-						err1 := sqlTemplatesExecutor.session.Rollback()
+						err1 := sqlTemplatesExecutor.session.rollback()
 						if err1 != nil {
 							return nil, nil, err1
 						}
@@ -190,7 +190,7 @@ func (sqlTemplatesExecutor *SqlTemplatesExecutor) Execute() ([][]map[string]inte
 				if sqlModel == 1 {
 					if model_1_results.Error != nil {
 						if sqlTemplatesExecutor.session.IsSqlFuc == true {
-							err1 := sqlTemplatesExecutor.session.Rollback()
+							err1 := sqlTemplatesExecutor.session.rollback()
 							if err1 != nil {
 								return nil, nil, err1
 							}
@@ -203,7 +203,7 @@ func (sqlTemplatesExecutor *SqlTemplatesExecutor) Execute() ([][]map[string]inte
 				} else if sqlModel == 2 {
 					if err != nil {
 						if sqlTemplatesExecutor.session.IsSqlFuc == true {
-							err1 := sqlTemplatesExecutor.session.Rollback()
+							err1 := sqlTemplatesExecutor.session.rollback()
 							if err1 != nil {
 								return nil, nil, err1
 							}
@@ -221,7 +221,7 @@ func (sqlTemplatesExecutor *SqlTemplatesExecutor) Execute() ([][]map[string]inte
 					RowsAffected, err := model_2_results.RowsAffected()
 					if err != nil {
 						if sqlTemplatesExecutor.session.IsSqlFuc == true {
-							err1 := sqlTemplatesExecutor.session.Rollback()
+							err1 := sqlTemplatesExecutor.session.rollback()
 							if err1 != nil {
 								return nil, nil, err1
 							}
@@ -246,7 +246,7 @@ func (sqlTemplatesExecutor *SqlTemplatesExecutor) Execute() ([][]map[string]inte
 
 			default:
 				if sqlTemplatesExecutor.session.IsSqlFuc == true {
-					err1 := sqlTemplatesExecutor.session.Rollback()
+					err1 := sqlTemplatesExecutor.session.rollback()
 					if err1 != nil {
 						return nil, nil, err1
 					}
@@ -258,7 +258,7 @@ func (sqlTemplatesExecutor *SqlTemplatesExecutor) Execute() ([][]map[string]inte
 				sqlStr, err := sqlTemplatesExecutor.session.Engine.GetSqlTemplate(sqlkeysSlice[i]).Execute(parmaSlice[i])
 				if err != nil {
 					if sqlTemplatesExecutor.session.IsSqlFuc == true {
-						err1 := sqlTemplatesExecutor.session.Rollback()
+						err1 := sqlTemplatesExecutor.session.rollback()
 						if err1 != nil {
 							return nil, nil, err1
 						}
@@ -295,7 +295,7 @@ func (sqlTemplatesExecutor *SqlTemplatesExecutor) Execute() ([][]map[string]inte
 				if sqlModel == 1 {
 					if model_1_results.Error != nil {
 						if sqlTemplatesExecutor.session.IsSqlFuc == true {
-							err1 := sqlTemplatesExecutor.session.Rollback()
+							err1 := sqlTemplatesExecutor.session.rollback()
 							if err1 != nil {
 								return nil, nil, err1
 							}
@@ -308,7 +308,7 @@ func (sqlTemplatesExecutor *SqlTemplatesExecutor) Execute() ([][]map[string]inte
 				} else if sqlModel == 2 {
 					if err != nil {
 						if sqlTemplatesExecutor.session.IsSqlFuc == true {
-							err1 := sqlTemplatesExecutor.session.Rollback()
+							err1 := sqlTemplatesExecutor.session.rollback()
 							if err1 != nil {
 								return nil, nil, err1
 							}
@@ -326,7 +326,7 @@ func (sqlTemplatesExecutor *SqlTemplatesExecutor) Execute() ([][]map[string]inte
 					RowsAffected, err := model_2_results.RowsAffected()
 					if err != nil {
 						if sqlTemplatesExecutor.session.IsSqlFuc == true {
-							err1 := sqlTemplatesExecutor.session.Rollback()
+							err1 := sqlTemplatesExecutor.session.rollback()
 							if err1 != nil {
 								return nil, nil, err1
 							}
@@ -345,7 +345,7 @@ func (sqlTemplatesExecutor *SqlTemplatesExecutor) Execute() ([][]map[string]inte
 		}
 
 		if sqlTemplatesExecutor.session.IsSqlFuc == true {
-			err1 := sqlTemplatesExecutor.session.Commit()
+			err1 := sqlTemplatesExecutor.session.commit()
 			if err1 != nil {
 				return nil, nil, err1
 			}
@@ -365,7 +365,7 @@ func (sqlTemplatesExecutor *SqlTemplatesExecutor) Execute() ([][]map[string]inte
 				sqlStr, err := sqlTemplatesExecutor.session.Engine.GetSqlTemplate(sqlkeysMap[k]).Execute(nil)
 				if err != nil {
 					if sqlTemplatesExecutor.session.IsSqlFuc == true {
-						err1 := sqlTemplatesExecutor.session.Rollback()
+						err1 := sqlTemplatesExecutor.session.rollback()
 						if err1 != nil {
 							return nil, nil, err1
 						}
@@ -389,7 +389,7 @@ func (sqlTemplatesExecutor *SqlTemplatesExecutor) Execute() ([][]map[string]inte
 				if sqlModel == 1 {
 					if model_1_results.Error != nil {
 						if sqlTemplatesExecutor.session.IsSqlFuc == true {
-							err1 := sqlTemplatesExecutor.session.Rollback()
+							err1 := sqlTemplatesExecutor.session.rollback()
 							if err1 != nil {
 								return nil, nil, err1
 							}
@@ -402,7 +402,7 @@ func (sqlTemplatesExecutor *SqlTemplatesExecutor) Execute() ([][]map[string]inte
 				} else if sqlModel == 2 {
 					if err != nil {
 						if sqlTemplatesExecutor.session.IsSqlFuc == true {
-							err1 := sqlTemplatesExecutor.session.Rollback()
+							err1 := sqlTemplatesExecutor.session.rollback()
 							if err1 != nil {
 								return nil, nil, err1
 							}
@@ -420,7 +420,7 @@ func (sqlTemplatesExecutor *SqlTemplatesExecutor) Execute() ([][]map[string]inte
 					RowsAffected, err := model_2_results.RowsAffected()
 					if err != nil {
 						if sqlTemplatesExecutor.session.IsSqlFuc == true {
-							err1 := sqlTemplatesExecutor.session.Rollback()
+							err1 := sqlTemplatesExecutor.session.rollback()
 							if err1 != nil {
 								return nil, nil, err1
 							}
@@ -445,7 +445,7 @@ func (sqlTemplatesExecutor *SqlTemplatesExecutor) Execute() ([][]map[string]inte
 
 			default:
 				if sqlTemplatesExecutor.session.IsSqlFuc == true {
-					err1 := sqlTemplatesExecutor.session.Rollback()
+					err1 := sqlTemplatesExecutor.session.rollback()
 					if err1 != nil {
 						return nil, nil, err1
 					}
@@ -457,7 +457,7 @@ func (sqlTemplatesExecutor *SqlTemplatesExecutor) Execute() ([][]map[string]inte
 				sqlStr, err := sqlTemplatesExecutor.session.Engine.GetSqlTemplate(sqlkeysMap[k]).Execute(parmasMap[k])
 				if err != nil {
 					if sqlTemplatesExecutor.session.IsSqlFuc == true {
-						err1 := sqlTemplatesExecutor.session.Rollback()
+						err1 := sqlTemplatesExecutor.session.rollback()
 						if err1 != nil {
 							return nil, nil, err1
 						}
@@ -494,7 +494,7 @@ func (sqlTemplatesExecutor *SqlTemplatesExecutor) Execute() ([][]map[string]inte
 				if sqlModel == 1 {
 					if model_1_results.Error != nil {
 						if sqlTemplatesExecutor.session.IsSqlFuc == true {
-							err1 := sqlTemplatesExecutor.session.Rollback()
+							err1 := sqlTemplatesExecutor.session.rollback()
 							if err1 != nil {
 								return nil, nil, err1
 							}
@@ -507,7 +507,7 @@ func (sqlTemplatesExecutor *SqlTemplatesExecutor) Execute() ([][]map[string]inte
 				} else if sqlModel == 2 {
 					if err != nil {
 						if sqlTemplatesExecutor.session.IsSqlFuc == true {
-							err1 := sqlTemplatesExecutor.session.Rollback()
+							err1 := sqlTemplatesExecutor.session.rollback()
 							if err1 != nil {
 								return nil, nil, err1
 							}
@@ -525,7 +525,7 @@ func (sqlTemplatesExecutor *SqlTemplatesExecutor) Execute() ([][]map[string]inte
 					RowsAffected, err := model_2_results.RowsAffected()
 					if err != nil {
 						if sqlTemplatesExecutor.session.IsSqlFuc == true {
-							err1 := sqlTemplatesExecutor.session.Rollback()
+							err1 := sqlTemplatesExecutor.session.rollback()
 							if err1 != nil {
 								return nil, nil, err1
 							}
@@ -544,7 +544,7 @@ func (sqlTemplatesExecutor *SqlTemplatesExecutor) Execute() ([][]map[string]inte
 		}
 
 		if sqlTemplatesExecutor.session.IsSqlFuc == true {
-			err1 := sqlTemplatesExecutor.session.Commit()
+			err1 := sqlTemplatesExecutor.session.commit()
 			if err1 != nil {
 				return nil, nil, err1
 			}