diff --git a/dsSupport/Test/ElasticsearchToGreenPlum/ElasticsearchToGreenPlum.go b/dsSupport/Test/ElasticsearchToGreenPlum/ElasticsearchToGreenPlum.go index d24999f5..73ec1f35 100644 --- a/dsSupport/Test/ElasticsearchToGreenPlum/ElasticsearchToGreenPlum.go +++ b/dsSupport/Test/ElasticsearchToGreenPlum/ElasticsearchToGreenPlum.go @@ -72,7 +72,7 @@ func main() { addRecord(indexName, pk, value.String()) } //批量执行 - commitTran(sqls) + batchSave(sqls) //继续用的 scoll_id scrollId := result.ScrollId @@ -104,7 +104,7 @@ func main() { break } //批量执行 - commitTran(sqls) + batchSave(sqls) } } @@ -153,21 +153,12 @@ func addRecord(tableName string, pk string, jsonStr string) { sqls = append(sqls, sql) } -//提交事务 -func commitTran(sqls []string) { - session := db.NewSession() - defer session.Close() - err := session.Begin() +//提交 +func batchSave(sqls []string) { for i := range sqls { - _, err = session.Insert(sqls[i]) + _, err := db.SQL(sqls[i]).Execute() if err != nil { - fmt.Println(err.Error()) - session.Rollback() - return + panic(err) } } - err = session.Commit() - if err != nil { - return - } }