基于serf的数据库同步模块库
liuxiaolong
2019-08-09 1d801237e476f40af8a6974b871afe85cdca5441
agent.go
@@ -178,6 +178,7 @@
            fmt.Println("Query tableNames unmarshal err")
            return
         }
         fmt.Println("Query tableNames:",tableNames)
         datas, err := ExecuteQueryByGorm(tableNames)
         if err !=nil {
            fmt.Println("queryByGorm err")
@@ -432,8 +433,7 @@
   //query: get db file.
   params := serf.QueryParam{
      //FilterNodes: strings.Fields(specmembername),
      FilterNodes: strings.Fields(a.conf.NodeName),
      FilterNodes: strings.Fields(specmembername),
   }
   //SQL