|
|
@@ -29,7 +29,7 @@ func (sqlTemplatesExecutor *SqlTemplatesExecutor) Execute() ([][]map[string]inte
|
|
|
|
|
|
sqlModel := 1
|
|
|
|
|
|
- if sqlTemplatesExecutor.session.IsSqlFuc == true {
|
|
|
+ if sqlTemplatesExecutor.session.IsSqlFunc == true {
|
|
|
err := sqlTemplatesExecutor.session.begin()
|
|
|
if err != nil {
|
|
|
return nil, nil, err
|
|
|
@@ -42,7 +42,7 @@ func (sqlTemplatesExecutor *SqlTemplatesExecutor) Execute() ([][]map[string]inte
|
|
|
if sqlTemplatesExecutor.parmas == nil {
|
|
|
sqlStr, err = sqlTemplatesExecutor.session.Engine.GetSqlTemplate(sqlkey).Execute(nil)
|
|
|
if err != nil {
|
|
|
- if sqlTemplatesExecutor.session.IsSqlFuc == true {
|
|
|
+ if sqlTemplatesExecutor.session.IsSqlFunc == true {
|
|
|
err1 := sqlTemplatesExecutor.session.rollback()
|
|
|
if err1 != nil {
|
|
|
return nil, nil, err1
|
|
|
@@ -70,7 +70,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 {
|
|
|
+ if sqlTemplatesExecutor.session.IsSqlFunc == true {
|
|
|
err1 := sqlTemplatesExecutor.session.rollback()
|
|
|
if err1 != nil {
|
|
|
return nil, nil, err1
|
|
|
@@ -97,7 +97,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 {
|
|
|
+ if sqlTemplatesExecutor.session.IsSqlFunc == true {
|
|
|
err1 := sqlTemplatesExecutor.session.rollback()
|
|
|
if err1 != nil {
|
|
|
return nil, nil, err1
|
|
|
@@ -165,7 +165,7 @@ func (sqlTemplatesExecutor *SqlTemplatesExecutor) Execute() ([][]map[string]inte
|
|
|
for i, _ := range sqlkeysSlice {
|
|
|
sqlStr, err := sqlTemplatesExecutor.session.Engine.GetSqlTemplate(sqlkeysSlice[i]).Execute(nil)
|
|
|
if err != nil {
|
|
|
- if sqlTemplatesExecutor.session.IsSqlFuc == true {
|
|
|
+ if sqlTemplatesExecutor.session.IsSqlFunc == true {
|
|
|
err1 := sqlTemplatesExecutor.session.rollback()
|
|
|
if err1 != nil {
|
|
|
return nil, nil, err1
|
|
|
@@ -189,7 +189,7 @@ func (sqlTemplatesExecutor *SqlTemplatesExecutor) Execute() ([][]map[string]inte
|
|
|
|
|
|
if sqlModel == 1 {
|
|
|
if model_1_results.Error != nil {
|
|
|
- if sqlTemplatesExecutor.session.IsSqlFuc == true {
|
|
|
+ if sqlTemplatesExecutor.session.IsSqlFunc == true {
|
|
|
err1 := sqlTemplatesExecutor.session.rollback()
|
|
|
if err1 != nil {
|
|
|
return nil, nil, err1
|
|
|
@@ -202,7 +202,7 @@ func (sqlTemplatesExecutor *SqlTemplatesExecutor) Execute() ([][]map[string]inte
|
|
|
|
|
|
} else if sqlModel == 2 {
|
|
|
if err != nil {
|
|
|
- if sqlTemplatesExecutor.session.IsSqlFuc == true {
|
|
|
+ if sqlTemplatesExecutor.session.IsSqlFunc == true {
|
|
|
err1 := sqlTemplatesExecutor.session.rollback()
|
|
|
if err1 != nil {
|
|
|
return nil, nil, err1
|
|
|
@@ -220,7 +220,7 @@ func (sqlTemplatesExecutor *SqlTemplatesExecutor) Execute() ([][]map[string]inte
|
|
|
resultMap[0]["LastInsertId"] = LastInsertId
|
|
|
RowsAffected, err := model_2_results.RowsAffected()
|
|
|
if err != nil {
|
|
|
- if sqlTemplatesExecutor.session.IsSqlFuc == true {
|
|
|
+ if sqlTemplatesExecutor.session.IsSqlFunc == true {
|
|
|
err1 := sqlTemplatesExecutor.session.rollback()
|
|
|
if err1 != nil {
|
|
|
return nil, nil, err1
|
|
|
@@ -245,7 +245,7 @@ func (sqlTemplatesExecutor *SqlTemplatesExecutor) Execute() ([][]map[string]inte
|
|
|
parmaSlice = sqlTemplatesExecutor.parmas.([]map[string]interface{})
|
|
|
|
|
|
default:
|
|
|
- if sqlTemplatesExecutor.session.IsSqlFuc == true {
|
|
|
+ if sqlTemplatesExecutor.session.IsSqlFunc == true {
|
|
|
err1 := sqlTemplatesExecutor.session.rollback()
|
|
|
if err1 != nil {
|
|
|
return nil, nil, err1
|
|
|
@@ -257,7 +257,7 @@ func (sqlTemplatesExecutor *SqlTemplatesExecutor) Execute() ([][]map[string]inte
|
|
|
for i, _ := range sqlkeysSlice {
|
|
|
sqlStr, err := sqlTemplatesExecutor.session.Engine.GetSqlTemplate(sqlkeysSlice[i]).Execute(parmaSlice[i])
|
|
|
if err != nil {
|
|
|
- if sqlTemplatesExecutor.session.IsSqlFuc == true {
|
|
|
+ if sqlTemplatesExecutor.session.IsSqlFunc == true {
|
|
|
err1 := sqlTemplatesExecutor.session.rollback()
|
|
|
if err1 != nil {
|
|
|
return nil, nil, err1
|
|
|
@@ -294,7 +294,7 @@ func (sqlTemplatesExecutor *SqlTemplatesExecutor) Execute() ([][]map[string]inte
|
|
|
|
|
|
if sqlModel == 1 {
|
|
|
if model_1_results.Error != nil {
|
|
|
- if sqlTemplatesExecutor.session.IsSqlFuc == true {
|
|
|
+ if sqlTemplatesExecutor.session.IsSqlFunc == true {
|
|
|
err1 := sqlTemplatesExecutor.session.rollback()
|
|
|
if err1 != nil {
|
|
|
return nil, nil, err1
|
|
|
@@ -307,7 +307,7 @@ func (sqlTemplatesExecutor *SqlTemplatesExecutor) Execute() ([][]map[string]inte
|
|
|
|
|
|
} else if sqlModel == 2 {
|
|
|
if err != nil {
|
|
|
- if sqlTemplatesExecutor.session.IsSqlFuc == true {
|
|
|
+ if sqlTemplatesExecutor.session.IsSqlFunc == true {
|
|
|
err1 := sqlTemplatesExecutor.session.rollback()
|
|
|
if err1 != nil {
|
|
|
return nil, nil, err1
|
|
|
@@ -325,7 +325,7 @@ func (sqlTemplatesExecutor *SqlTemplatesExecutor) Execute() ([][]map[string]inte
|
|
|
resultMap[0]["LastInsertId"] = LastInsertId
|
|
|
RowsAffected, err := model_2_results.RowsAffected()
|
|
|
if err != nil {
|
|
|
- if sqlTemplatesExecutor.session.IsSqlFuc == true {
|
|
|
+ if sqlTemplatesExecutor.session.IsSqlFunc == true {
|
|
|
err1 := sqlTemplatesExecutor.session.rollback()
|
|
|
if err1 != nil {
|
|
|
return nil, nil, err1
|
|
|
@@ -344,7 +344,7 @@ func (sqlTemplatesExecutor *SqlTemplatesExecutor) Execute() ([][]map[string]inte
|
|
|
|
|
|
}
|
|
|
|
|
|
- if sqlTemplatesExecutor.session.IsSqlFuc == true {
|
|
|
+ if sqlTemplatesExecutor.session.IsSqlFunc == true {
|
|
|
err1 := sqlTemplatesExecutor.session.commit()
|
|
|
if err1 != nil {
|
|
|
return nil, nil, err1
|
|
|
@@ -364,7 +364,7 @@ func (sqlTemplatesExecutor *SqlTemplatesExecutor) Execute() ([][]map[string]inte
|
|
|
for k, _ := range sqlkeysMap {
|
|
|
sqlStr, err := sqlTemplatesExecutor.session.Engine.GetSqlTemplate(sqlkeysMap[k]).Execute(nil)
|
|
|
if err != nil {
|
|
|
- if sqlTemplatesExecutor.session.IsSqlFuc == true {
|
|
|
+ if sqlTemplatesExecutor.session.IsSqlFunc == true {
|
|
|
err1 := sqlTemplatesExecutor.session.rollback()
|
|
|
if err1 != nil {
|
|
|
return nil, nil, err1
|
|
|
@@ -388,7 +388,7 @@ func (sqlTemplatesExecutor *SqlTemplatesExecutor) Execute() ([][]map[string]inte
|
|
|
|
|
|
if sqlModel == 1 {
|
|
|
if model_1_results.Error != nil {
|
|
|
- if sqlTemplatesExecutor.session.IsSqlFuc == true {
|
|
|
+ if sqlTemplatesExecutor.session.IsSqlFunc == true {
|
|
|
err1 := sqlTemplatesExecutor.session.rollback()
|
|
|
if err1 != nil {
|
|
|
return nil, nil, err1
|
|
|
@@ -401,7 +401,7 @@ func (sqlTemplatesExecutor *SqlTemplatesExecutor) Execute() ([][]map[string]inte
|
|
|
|
|
|
} else if sqlModel == 2 {
|
|
|
if err != nil {
|
|
|
- if sqlTemplatesExecutor.session.IsSqlFuc == true {
|
|
|
+ if sqlTemplatesExecutor.session.IsSqlFunc == true {
|
|
|
err1 := sqlTemplatesExecutor.session.rollback()
|
|
|
if err1 != nil {
|
|
|
return nil, nil, err1
|
|
|
@@ -419,7 +419,7 @@ func (sqlTemplatesExecutor *SqlTemplatesExecutor) Execute() ([][]map[string]inte
|
|
|
resultMap[0]["LastInsertId"] = LastInsertId
|
|
|
RowsAffected, err := model_2_results.RowsAffected()
|
|
|
if err != nil {
|
|
|
- if sqlTemplatesExecutor.session.IsSqlFuc == true {
|
|
|
+ if sqlTemplatesExecutor.session.IsSqlFunc == true {
|
|
|
err1 := sqlTemplatesExecutor.session.rollback()
|
|
|
if err1 != nil {
|
|
|
return nil, nil, err1
|
|
|
@@ -444,7 +444,7 @@ func (sqlTemplatesExecutor *SqlTemplatesExecutor) Execute() ([][]map[string]inte
|
|
|
parmasMap = sqlTemplatesExecutor.parmas.(map[string]map[string]interface{})
|
|
|
|
|
|
default:
|
|
|
- if sqlTemplatesExecutor.session.IsSqlFuc == true {
|
|
|
+ if sqlTemplatesExecutor.session.IsSqlFunc == true {
|
|
|
err1 := sqlTemplatesExecutor.session.rollback()
|
|
|
if err1 != nil {
|
|
|
return nil, nil, err1
|
|
|
@@ -456,7 +456,7 @@ func (sqlTemplatesExecutor *SqlTemplatesExecutor) Execute() ([][]map[string]inte
|
|
|
for k, _ := range sqlkeysMap {
|
|
|
sqlStr, err := sqlTemplatesExecutor.session.Engine.GetSqlTemplate(sqlkeysMap[k]).Execute(parmasMap[k])
|
|
|
if err != nil {
|
|
|
- if sqlTemplatesExecutor.session.IsSqlFuc == true {
|
|
|
+ if sqlTemplatesExecutor.session.IsSqlFunc == true {
|
|
|
err1 := sqlTemplatesExecutor.session.rollback()
|
|
|
if err1 != nil {
|
|
|
return nil, nil, err1
|
|
|
@@ -493,7 +493,7 @@ func (sqlTemplatesExecutor *SqlTemplatesExecutor) Execute() ([][]map[string]inte
|
|
|
|
|
|
if sqlModel == 1 {
|
|
|
if model_1_results.Error != nil {
|
|
|
- if sqlTemplatesExecutor.session.IsSqlFuc == true {
|
|
|
+ if sqlTemplatesExecutor.session.IsSqlFunc == true {
|
|
|
err1 := sqlTemplatesExecutor.session.rollback()
|
|
|
if err1 != nil {
|
|
|
return nil, nil, err1
|
|
|
@@ -506,7 +506,7 @@ func (sqlTemplatesExecutor *SqlTemplatesExecutor) Execute() ([][]map[string]inte
|
|
|
|
|
|
} else if sqlModel == 2 {
|
|
|
if err != nil {
|
|
|
- if sqlTemplatesExecutor.session.IsSqlFuc == true {
|
|
|
+ if sqlTemplatesExecutor.session.IsSqlFunc == true {
|
|
|
err1 := sqlTemplatesExecutor.session.rollback()
|
|
|
if err1 != nil {
|
|
|
return nil, nil, err1
|
|
|
@@ -524,7 +524,7 @@ func (sqlTemplatesExecutor *SqlTemplatesExecutor) Execute() ([][]map[string]inte
|
|
|
resultMap[0]["LastInsertId"] = LastInsertId
|
|
|
RowsAffected, err := model_2_results.RowsAffected()
|
|
|
if err != nil {
|
|
|
- if sqlTemplatesExecutor.session.IsSqlFuc == true {
|
|
|
+ if sqlTemplatesExecutor.session.IsSqlFunc == true {
|
|
|
err1 := sqlTemplatesExecutor.session.rollback()
|
|
|
if err1 != nil {
|
|
|
return nil, nil, err1
|
|
|
@@ -543,7 +543,7 @@ func (sqlTemplatesExecutor *SqlTemplatesExecutor) Execute() ([][]map[string]inte
|
|
|
|
|
|
}
|
|
|
|
|
|
- if sqlTemplatesExecutor.session.IsSqlFuc == true {
|
|
|
+ if sqlTemplatesExecutor.session.IsSqlFunc == true {
|
|
|
err1 := sqlTemplatesExecutor.session.commit()
|
|
|
if err1 != nil {
|
|
|
return nil, nil, err1
|