'commit'

dsSupport/Test/ElasticsearchToGreenPlum/ElasticsearchToGreenPlum.go

@@ -108,6 +108,9 @@ func main() {
 				break
 			}
 			//批量执行
+			if len(pkStrArray) == 0 { //应该是有错误的数据，导致拿不到结果
+				continue
+			}
 			batchSave(indexName, pk)
 		}
 		fmt.Println("索引" + indexName + "同步完成！")
@@ -177,9 +180,6 @@ 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] + "',"