'commit'

dsSupport/Test/ElasticsearchToGreenPlum/ElasticsearchToGreenPlum.go

@@ -177,6 +177,9 @@ func addRecord(pk string, jsonStr string) {
 func batchSave(tableName string, pkName string) {
 	var pkStr = ""
 	//数组去重
+	if len(pkStrArray) == 0 { //应该是有错误的数据，导致拿不到结果
+		return
+	}
 	pkStrArray = CommonUtil.RemoveRepeatedElement(pkStrArray)
 	for i := range pkStrArray {
 		pkStr += "'" + pkStrArray[i] + "',"
@@ -204,5 +207,5 @@ func batchSave(tableName string, pkName string) {
 		fmt.Println(sql)
 		panic(err)
 	}
-	fmt.Println(tableName+"批量执行" + CommonUtil.ConvertIntToString(len(insertStrArray)) + "条.")
+	fmt.Println(tableName + "批量执行" + CommonUtil.ConvertIntToString(len(insertStrArray)) + "条.")
 }