'commit'

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