From 974a818237c989fa7e4a5accaf848c49f97a5ca0 Mon Sep 17 00:00:00 2001
From: liuxiaolong <736321739@qq.com>
Date: 星期四, 10 十月 2019 14:31:39 +0800
Subject: [PATCH] add log
---
agent.go | 31 ++++++++++++++++++-------------
1 files changed, 18 insertions(+), 13 deletions(-)
diff --git a/agent.go b/agent.go
index fe65539..974a29f 100644
--- a/agent.go
+++ b/agent.go
@@ -135,11 +135,10 @@
}
if sqlUe.Owner != a.conf.NodeName {
- evTime := uint64(ev.LTime)
- logger.Info("ev.LTime:",evTime,",SqlUserEvent.sql:",sqlUe.Sql)
+ flag, e := ExecuteSqlByGorm(sqlUe.Sql)
- flag, _ := ExecuteSqlByGorm(sqlUe.Sql)
- logger.Info("userEvent exec ",sqlUe.Sql,",Result:",flag)
+ evTime := uint64(ev.LTime)
+ logger.Info("ev.LTime:",evTime,"userEvent exec ",sqlUe.Sql,",Result:",flag,", err:",e)
}
} else if ev.Name == UserEventSyncDbTablePersonCache {
logger.Info("LTime:",ev.LTime,",ev.Payload.len:",len(ev.Payload))
@@ -517,19 +516,25 @@
wg.Add(1)
go func() {
defer wg.Done()
- respCh := resp.ResponseCh()
+ //respCh := resp.ResponseCh()
for {
select {
- case r := <-respCh:
- logger.Info("Query response's len:", len(r.Payload))
- err := json.Unmarshal(r.Payload, &dumpSqls)
- if err ==nil {
- logger.Error("dumpSql:",dumpSqls)
- logger.Error("data dump success")
- }
- return
+ //case r := <-respCh:
+ // logger.Info("Query response's len:", len(r.Payload))
+ // err := json.Unmarshal(r.Payload, &dumpSqls)
+ // if err ==nil {
+ // logger.Error("dumpSql:",dumpSqls)
+ // logger.Error("data dump success")
+ // }
+ // return
case msg := <-QueryTcpResponseChan:
logger.Debug("QueryTcpResponseChan receive msg len:",len(msg))
+ err := json.Unmarshal(msg, &dumpSqls)
+ if err ==nil {
+ logger.Error("dumpSql success:",dumpSqls)
+ } else {
+ logger.Error("data dump err:",err)
+ }
return
}
--
Gitblit v1.8.0