基于serf的数据库同步模块库
liuxiaolong
2019-08-14 df17d827d53a89a19c43816d3a633ba49f9105ae
agent.go
@@ -119,14 +119,11 @@
   switch ev := event.(type) {
   case serf.UserEvent:
      fmt.Println(string(ev.Payload))
      var tmpstringslice []string
      tmpstringslice = append(tmpstringslice, string(ev.Payload))
      fmt.Println(tmpstringslice)
      results, err := ExecuteWriteSql(tmpstringslice)
      for _, result := range results {
         fmt.Println(result, "results err: ", err)
      }
      var sqlArr []string
      sqlArr = append(sqlArr, string(ev.Payload))
      //results, err := ExecuteWriteSql(sqlArr)
      flag, _ := ExecuteSqlByGorm(sqlArr)
      fmt.Println("userEvent exec ",sqlArr,",Result:",flag)
   case *serf.Query: