From aed591b550b73250a06c07889705ef7b697ae443 Mon Sep 17 00:00:00 2001
From: sunty <1172534965@qq.com>
Date: 星期三, 27 三月 2024 19:19:03 +0800
Subject: [PATCH] add DeleteByDocumentNumber
---
EsApi.go | 32 ++++++++++++++++++++++++++++++++
1 files changed, 32 insertions(+), 0 deletions(-)
diff --git a/EsApi.go b/EsApi.go
index ea3fc93..7b2bb1a 100644
--- a/EsApi.go
+++ b/EsApi.go
@@ -2400,6 +2400,38 @@
}
// 鎸夋棩鏈熻寖鍥达紝鏈嶅姟鍣↖d鍒犻櫎鏁版嵁
+func DeleteByDocumentNumber(docNumber []string, serverIp string, serverPort string, indexName string) (total int, err error) {
+
+ url := "http://" + serverIp + ":" + serverPort + "/" + indexName + "/_delete_by_query"
+ docNumbers := strings.Replace(strings.Trim(fmt.Sprint(docNumber), "[]"), " ", "\",\"", -1)
+ deleteJson := `{
+ "query":{
+ "bool":{
+ "filter":[
+ {
+ "terms":{
+ "documentNumber":["` + docNumbers + `"]
+ }
+ }
+ ]
+ }
+ }
+} `
+ fmt.Println(url)
+ fmt.Println(deleteJson)
+ return
+ buf, err := EsReq("POST", url, []byte(deleteJson))
+ if err != nil {
+ return -1, errors.New("璇锋眰澶辫触")
+ }
+ deleteRes, err := SourceDeleted(buf)
+ if err != nil {
+ return -1, errors.New("瑙ｇ爜澶辫触")
+ }
+ return deleteRes, nil
+}
+
+// 鎸夋棩鏈熻寖鍥达紝鏈嶅姟鍣↖d鍒犻櫎鏁版嵁
func DeleteAnalyServerData(serverIp string, serverPort string, indexName string, startTime string, endTime string, analyServerId string) (total int, err error) {
url := "http://" + serverIp + ":" + serverPort + "/" + indexName + "/_delete_by_query"
deleteJson := `{
--
Gitblit v1.8.0