From c02c0ac5e06ee1a556107baa071ef0c80a387a13 Mon Sep 17 00:00:00 2001
From: liuxiaolong <736321739@qq.com>
Date: 星期六, 28 九月 2019 10:34:43 +0800
Subject: [PATCH] rm ltime save and get from sqlite
---
dbself.go | 34 ++++++++++++++++++++++++++++++++++
1 files changed, 34 insertions(+), 0 deletions(-)
diff --git a/dbself.go b/dbself.go
index 884b867..49c4d34 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,39 @@
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 {
+ if 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 {
+ 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)
+ }
+ }
+ return 0
+}
+
type TableDesc struct {
Cid int `json:"cid"`
Name string `json:"name"`
--
Gitblit v1.8.0