--

liuxiaolong

2020-05-13 a7bdf872b7477a858ea312ceeab3c25caa585111

 sync.go

@@ -5,6 +5,7 @@
   sdb "basic.com/Android/syncdb.git"
   "basic.com/valib/logger.git"
   "encoding/json"
   "fmt"
   "strings"
)
type ReceiveSqlInterface2 interface {
@@ -15,7 +16,7 @@
   sdb.RegisterReceiveSqlInterface(c)
}

func InitAgent(devID string) bool {
/*func InitAgent(devID string) bool {
   var nodeIps []string
   sqlFindAllCluster := string("select * from " + dBNameCluster)
   clusters, err := sdb.ExecuteQuerySql([]string{sqlFindAllCluster})
@@ -42,7 +43,7 @@
   }

   return true
}
}*/

func SyncInit(clusterID string, password string, nodeID string, strAddrs string, snapshotPath string) bool {
   var ips []string
@@ -63,11 +64,19 @@
   return true
}

func RegisterDbHandler(h sdb.DbHandler) {
type DbHandlerInterface interface {
   sdb.DbHandler
}

type DbDumpHandlerInterface interface {
   sdb.DbDumpHandler
}

func RegisterDbHandler(h DbHandlerInterface) {
   sdb.RegisterDbHandler(h)
}

func RegisterDbDumpHandler(h sdb.DbDumpHandler) {
func RegisterDbDumpHandler(h DbDumpHandlerInterface) {
   sdb.RegisterDbDumpHandler(h)
}

@@ -144,14 +153,17 @@
   }

   var dumpSqls *[]string
   dumpSqls, err = agent.GetTableDataFromCluster(syncTables)
   dumpSqls, err := agent.GetTableDataFromCluster(syncTables)
   fmt.Println("dumpSqls:", dumpSqls, "err:",err)
   if dumpSqls != nil {
      for _, dumpSql := range *dumpSqls {
         sqls = append(sqls, dumpSql)
      }
   } else {
      return false
   }

   logger.Debug("成功获取集群中数据")
   logger.Debug("成功获取集群中数据,err:",err)

   //timeUnix := time.Now().Unix()
   //fmtTimeStr := time.Unix(timeUnix, 0).Format("2006-01-02 15:04:05")