基于serf的数据库同步模块库
liuxiaolong
2019-09-28 c02c0ac5e06ee1a556107baa071ef0c80a387a13
agent.go
@@ -131,11 +131,15 @@
            return
         }
         if sqlUe.Owner != a.conf.NodeName {
            //results, err := ExecuteWriteSql(sqlArr)
            evTime := uint64(ev.LTime)
            logger.Info("ev.LTime:",evTime,",SqlUserEvent.sql:",sqlUe.Sql)
            flag, _ := ExecuteSqlByGorm(sqlUe.Sql)
            logger.Info("userEvent exec ",sqlUe.Sql,",Result:",flag)
         }
      } else if ev.Name == UserEventSyncDbTablePersonCache {
         logger.Info("LTime:",ev.LTime,",ev.Payload.len:",len(ev.Payload))
         SyncDbTablePersonCacheChan <- ev.Payload
      }