From 424bb857ca89a6e8ad1ea0c0dae48b4f5e98e16f Mon Sep 17 00:00:00 2001 From: huanghai <10402852@qq.com> Date: Mon, 7 Sep 2020 08:58:20 +0800 Subject: [PATCH] 'commit' --- .../ElasticsearchToGreenPlum.go | 2 +- .../Test/ReadEsExistMapping/ReadEsExistMapping.go | 10 +++++----- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/dsSupport/Test/ElasticsearchToGreenPlum/ElasticsearchToGreenPlum.go b/dsSupport/Test/ElasticsearchToGreenPlum/ElasticsearchToGreenPlum.go index e4713f72..a349a34f 100644 --- a/dsSupport/Test/ElasticsearchToGreenPlum/ElasticsearchToGreenPlum.go +++ b/dsSupport/Test/ElasticsearchToGreenPlum/ElasticsearchToGreenPlum.go @@ -204,5 +204,5 @@ func batchSave(tableName string, pkName string) { fmt.Println(sql) panic(err) } - fmt.Println("批量执行" + CommonUtil.ConvertIntToString(len(insertStrArray)) + "条.") + fmt.Println(tableName+"批量执行" + CommonUtil.ConvertIntToString(len(insertStrArray)) + "条.") } diff --git a/dsSupport/Test/ReadEsExistMapping/ReadEsExistMapping.go b/dsSupport/Test/ReadEsExistMapping/ReadEsExistMapping.go index f28fb737..32884300 100644 --- a/dsSupport/Test/ReadEsExistMapping/ReadEsExistMapping.go +++ b/dsSupport/Test/ReadEsExistMapping/ReadEsExistMapping.go @@ -35,10 +35,10 @@ func main() { } //要同步的索引名称，也就是表名称 - indexName := "user_teacher_org" + indexName := "user_student" //取所有 CTX := context.Background() - result, err := esClient.Scroll().Index(indexName).Size(10).Do(CTX) + result, err := esClient.Scroll().Index(indexName).Size(100).Do(CTX) if err != nil { panic(err) } @@ -50,7 +50,7 @@ func main() { //如果是第一次的话而且表不存在的情况下，重新创建表结构 m := make(map[string]interface{}) json.Unmarshal([]byte(value.String()), &m) - if len(m) > 0 && i == 0 { + if len(m) > 0 && i == len(result.Hits.Hits)-1 { addFieldData(indexName, m) break } @@ -83,8 +83,8 @@ func addFieldData(tableName string, m map[string]interface{}) { model.FieldLength = 128 model.DecimalPointLength = 0 } - _,err:=db.Insert(model) - if err!=nil{ + _, err := db.Insert(model) + if err != nil { panic(err) } }