| | |
|---|
| | | "os" |
|---|
| | | "os/exec" |
|---|
| | | "path/filepath" |
|---|
| | | "strconv" |
|---|
| | | "strings" |
|---|
| | | "sync" |
|---|
| | | "github.com/jinzhu/gorm" |
|---|
| | |
|---|
| | | return true,nil |
|---|
| | | } |
|---|
| | | 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 { |
|---|
