基于serf的数据库同步模块库
liuxiaolong
2020-09-14 ea032b4e1973ab1afd4c8d1994bc6a78d99ca7eb
add log
1个文件已修改
4 ■■■ 已修改文件
dbself.go 4 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
dbself.go
@@ -154,10 +154,12 @@
        var arr []string
        var dumpSql []DumpSql
        for _,table :=range tableNames {
            logger.Info("dump current tableName:", table)
            dumpSql = make([]DumpSql, 0)
            var tDescArr []TableDesc
            tSql := fmt.Sprintf(`PRAGMA table_info("%s")`, table)
            err := localDb.Raw(tSql).Scan(&tDescArr).Error
            logger.Debug("tDescArr err:", err, "len(tDescArr)=", len(tDescArr))
            if err !=nil {
                return nil,errors.New("tableDesc err")
            }
@@ -189,9 +191,9 @@
            logger.Info("tSql:",tSql)
            err = localDb.Raw(tSql).Scan(&dumpSql).Error
            logger.Debug("dump err:", err)
            if err !=nil {
                return nil,errors.New("dump err")
                continue
            }
            if len(dumpSql)>0 {
                for _,d :=range dumpSql {