liuxiaolong
2020-05-14 91bd26e795e78ebfe8570f31cb80915b81d93586
GetTableDataFromCluster ret *string
1个文件已修改
7 ■■■■ 已修改文件
sync.go 7 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
sync.go
@@ -152,13 +152,10 @@
        sqls = append(sqls, delSql)
    }
    var dumpSqls *[]string
    dumpSqls, err := agent.GetTableDataFromCluster(syncTables)
    fmt.Println("dumpSqls:", dumpSqls, "err:",err)
    fmt.Println("len(dumpSqls):", len(*dumpSqls), "err:",err)
    if dumpSqls != nil && len(*dumpSqls) > 0 {
        for _, dumpSql := range *dumpSqls {
            sqls = append(sqls, dumpSql)
        }
        sqls = append(sqls, *dumpSqls)
    } else {
        return false
    }