From 2573bc9ab765e2b720dbe92f5bd3d7af71a36a87 Mon Sep 17 00:00:00 2001
From: huanghai <10402852@qq.com>
Date: Mon, 7 Sep 2020 09:07:29 +0800
Subject: [PATCH] 'commit'

---
 .../ElasticsearchToGreenPlum/ElasticsearchToGreenPlum.go     | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/dsSupport/Test/ElasticsearchToGreenPlum/ElasticsearchToGreenPlum.go b/dsSupport/Test/ElasticsearchToGreenPlum/ElasticsearchToGreenPlum.go
index a349a34f..1da42dfb 100644
--- a/dsSupport/Test/ElasticsearchToGreenPlum/ElasticsearchToGreenPlum.go
+++ b/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)) + "条.")
 }