liuxiaolong
2020-05-13 8f1e42921da26573b5d08ec2e6909f3081d85109
agent.go
@@ -131,11 +131,11 @@
}
type DbHandler interface {
   Forward(sql string) bool
   Execute(sql string) bool
}
type DbDumpHandler interface {
   Forward(tables string) string
   Dump(tables string) string
}
//数据库execute句柄
@@ -211,12 +211,13 @@
      } else if ev.Name == QueryEventUpdateDBData {
         //fmt.Println(string(ev.Payload))
         var tableNames []string
         json.Unmarshal(ev.Payload, &tableNames)
         err := json.Unmarshal(ev.Payload, &tableNames)
         fmt.Println("androidSync tableNames:", tableNames, "err:", err)
         dumpData := dbDumpH.Forward(strings.Join(tableNames, ","))
         dumpData := dbDumpH.Dump(strings.Join(tableNames, ","))
         bytesReturn, _ := json.Marshal(dumpData)
         //fmt.Println("results: ", bytesReturn)
         fmt.Println("androidSync len(bytesReturn): ", len(bytesReturn))
         if query, ok := event.(*serf.Query); ok {
            if err := query.Respond(bytesReturn); err != nil {
               //fmt.Printf("err: %s\n", err)
@@ -462,9 +463,9 @@
         }
      }
   }
   if specmembername == "" {
      return nil, errors.New("other pad node not found in memberlist")
   }
   //if specmembername == "" {
   //   return nil, errors.New("other pad node not found in memberlist")
   //}
   //fmt.Println("mbs:", mbs, "a.conf.BindAddr:", a.conf.BindAddr, "specmembername:", specmembername)
   //query: get db file.