add log

liuxiaolong

2020-05-13 d67b30fa3005f543554ad181b6bc6561eefa6f6f

add log

 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
@@ -153,10 +154,13 @@

    var dumpSqls *[]string
    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("成功获取集群中数据,err:",err)
@@ -170,7 +174,7 @@
    //sqls = append(sqls, sqlSync)
    sqls = append(sqls, "PRAGMA foreign_keys=ON")
    sqlDump := strings.Join(sqls, ";")
    if !sdb.DbHandle.Forward(sqlDump) {
    if !sdb.DbHandle.Execute(sqlDump) {
        logger.Debug("sdb.DbHandle.Execute ret: false")
        return false
    } else {