From 45d8874b3a968c508b6894a414b47b2af67f3422 Mon Sep 17 00:00:00 2001
From: huanghai <10402852@qq.com>
Date: Fri, 4 Sep 2020 17:00:08 +0800
Subject: [PATCH] 'commit'

---
 .../ElasticsearchToGreenPlum.go               | 21 ++++++-------------
 1 file changed, 6 insertions(+), 15 deletions(-)

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
-	}
 }