Merge branch 'master' of http://192.168.5.5:10010/r/aps/apsClient

zhangqian

2023-10-21 f91232c13c2682a6cf9ef4b46ecadee8deb372fd

Merge branch 'master' of http://192.168.5.5:10010/r/aps/apsClient

 serf/sqlite.go

@@ -41,15 +41,12 @@

            tSql := fmt.Sprintf(`PRAGMA table_info("%s")`, table)
            err := db.Raw(tSql).Scan(&tDescArr).Error

            fmt.Println("tDescArr err:", err, "len(tDescArr)=", len(tDescArr))
            if err != nil {
                return nil, errors.New("tableDesc err")
            }

            fmt.Println(table, "'Columns is:", tDescArr)
            if tDescArr == nil || len(tDescArr) == 0 {
                return nil, errors.New(table + " has no column")
                continue
            }

            var columnNames []string

 serf/sync.go

@@ -410,10 +410,11 @@
    //fmt.Println("同步全量数据给节点:", targetId)
    sqls, err := DumpTables(ss.sqlDB, ss.syncTables)
    if err != nil {
        fmt.Println("DumpTables error, ", err.Error())
        logx.Errorf("DumpTables error: %s", err.Error())
        return err
    }

    logx.Infof("DumpTables sql:%v", sqls)
    syncSql := strings.Join(sqls, ";")
    if len(syncSql) < sizeLimit {
        err = ss.pubSyncSqlMessage([]byte(syncSql), targetId)
@@ -427,6 +428,10 @@

            shard = fmt.Sprintf("%s%s;", shard, sql)
        }

        if len(shard) >0 {
            err = ss.pubSyncSqlMessage([]byte(shard), targetId)
        }
    }

    return err