基于serf的数据库同步模块库
liuxiaolong
2019-09-27 a2d9de39e35663578861385fca686944857d473b
dbself.go
@@ -141,7 +141,8 @@
   if localDb != nil {
      var syncSerf []SyncSerf
      err := localDb.Raw("select * from sync_serf").Scan(&syncSerf).Error
      if err == nil && len(syncSerf) > 0 {
      if err == nil {
         if len(syncSerf) > 0{
         ltStr := syncSerf[0].LamportTime
         logger.Info("db.LamportTime str:", ltStr)
         t, e := strconv.ParseUint(ltStr, 10, 64)
@@ -151,6 +152,12 @@
            curLTime = t
         }
         logger.Info("db.LamportTime:", ltStr)
         }else {
            err = localDb.Exec("insert into sync_serf values('0')").Error
            if err !=nil {
               logger.Error("sync_serf lamport_time init err:",err)
            }
         }
      } else {
         logger.Error("get db.LamportTime err:", err)