From 5b353f2877895d659b693bde94a9b1e428d60b97 Mon Sep 17 00:00:00 2001
From: chenshijun <csj_sky@126.com>
Date: 星期五, 06 九月 2019 16:42:33 +0800
Subject: [PATCH] 修改json传递解析的bug
---
agent.go | 15 ++++++++-------
1 files changed, 8 insertions(+), 7 deletions(-)
diff --git a/agent.go b/agent.go
index f6657d6..a243e1d 100644
--- a/agent.go
+++ b/agent.go
@@ -169,10 +169,14 @@
}
} else if ev.Name == QueryEventUpdateDBData {
fmt.Println(string(ev.Payload))
- var tmpstringslice []string
- tmpstringslice = append(tmpstringslice, string(ev.Payload))
- fmt.Println(tmpstringslice)
- rows, err := ExecuteQuerySql(tmpstringslice)
+ var tableNames []string
+ err := json.Unmarshal(ev.Payload, &tableNames)
+ if err !=nil {
+ fmt.Println("Query tableNames unmarshal err")
+ return
+ }
+
+ rows, err := ExecuteQuerySql(tableNames)
if err != nil {
fmt.Println("err: ", err)
return
@@ -190,9 +194,6 @@
return
}
}
-
- //var res []*Rows
- //json.Unmarshal(bytesReturn, &res)
}
case serf.MemberEvent:
if event.EventType() == serf.EventMemberLeave {
--
Gitblit v1.8.0