基于serf的数据库同步模块库
liuxiaolong
2020-09-19 8819911f0b5289294fc764aba18544f96358a47c
fix logSql has '
1个文件已修改
8 ■■■■ 已修改文件
agent.go 8 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
agent.go
@@ -142,7 +142,7 @@
                    logger.Info("ev.LTime:",ev.LTime,"userEvent exec ",sqlUe.Sql,",Result:",flag,", err:",e)
                    logLT := strconv.Itoa(int(ev.LTime))
                    logT := time.Now().Format("2006-01-02 15:04:05")
                    logSql := strings.Join(sqlUe.Sql, ";")
                    logSql := strings.ReplaceAll(strings.Join(sqlUe.Sql, ";"), "'", "''")
                    logResult := "0"
                    if flag {
                        logResult = "1"
@@ -251,7 +251,7 @@
                    logLT := strconv.Itoa(int(ev.LTime))
                    logT := time.Now().Format("2006-01-02 15:04:05")
                    logSql := "QueryEventUpdateDBData from "+targetNode.Name
                    logSql := strings.ReplaceAll("QueryEventUpdateDBData from "+targetNode.Name,"'","''")
                    logResult := "0"
                    logErr := ""
                    if sendErr ==nil {
@@ -286,7 +286,7 @@
                logger.Info("EventMemberLeave,current Members:",ev.Members)
                logLT := ""
                logT := time.Now().Format("2006-01-02 15:04:05")
                logSql := leaveSql
                logSql := strings.ReplaceAll(leaveSql, "'","''")
                logResult := "0"
                if flag {
                    logResult = "1"
@@ -307,7 +307,7 @@
                logger.Info("EventMemberJoin,current Members:",ev.Members)
                logLT := ""
                logT := time.Now().Format("2006-01-02 15:04:05")
                logSql := joinSql
                logSql := strings.ReplaceAll(joinSql, "'", "''")
                logResult := "0"
                if flag {
                    logResult = "1"