基于serf的数据库同步模块库
liuxiaolong
2019-08-09 fcb5c85db200303715b120261f310f3622b262c8
agent.go
@@ -456,9 +456,9 @@
            err := json.Unmarshal(r.Payload, &dumpSqls)
            if err ==nil {
               fmt.Println("dumpSql:",dumpSqls)
               //if flag,_ := ExecuteSqlByGorm(dumpSqls);flag{
               //   fmt.Println("data dump success")
               //}
               if flag,_ := ExecuteSqlByGorm(dumpSqls);flag{
                  fmt.Println("data dump success")
               }
            }
            return
         }