From cac6e9c7b13021b8b2bafa882772370ba847d226 Mon Sep 17 00:00:00 2001
From: liuxiaolong <736321739@qq.com>
Date: 星期五, 27 九月 2019 17:44:05 +0800
Subject: [PATCH] add lamport_time to db
---
dbself.go | 27 +++++++++++++++++++++++++++
1 files changed, 27 insertions(+), 0 deletions(-)
diff --git a/dbself.go b/dbself.go
index 884b867..a3a9140 100644
--- a/dbself.go
+++ b/dbself.go
@@ -6,6 +6,7 @@
"os"
"os/exec"
"path/filepath"
+ "strconv"
"strings"
"sync"
"github.com/jinzhu/gorm"
@@ -132,6 +133,32 @@
return false,errors.New("localDb is nil")
}
+type SyncSerf struct {
+ LamportTime string `json:"lamport_time"`
+}
+
+func QueryLTimeFromDbByGorm() uint64 {
+ if localDb != nil {
+ var syncSerf []SyncSerf
+ err := localDb.Raw("select * from sync_serf").Scan(&syncSerf).Error
+ if err == nil && len(syncSerf) > 0 {
+ ltStr := syncSerf[0].LamportTime
+ logger.Info("db.LamportTime str:", ltStr)
+ t, e := strconv.ParseUint(ltStr, 10, 64)
+ if e != nil {
+ logger.Error("db.LamportTime parseUint err:", e)
+ } else {
+ curLTime = t
+ }
+ logger.Info("db.LamportTime:", ltStr)
+
+ } else {
+ logger.Error("get db.LamportTime err:", err)
+ }
+ }
+ return 0
+}
+
type TableDesc struct {
Cid int `json:"cid"`
Name string `json:"name"`
--
Gitblit v1.8.0