| | |
| | | sdb "basic.com/Android/syncdb.git" |
| | | "basic.com/valib/logger.git" |
| | | "encoding/json" |
| | | "github.com/micro/go-micro/logger" |
| | | "strings" |
| | | ) |
| | | type ReceiveSqlInterface2 interface { |
| | |
| | | } |
| | | |
| | | var dumpSqls *[]string |
| | | dumpSqls, err = agent.GetTableDataFromCluster(syncTables) |
| | | dumpSqls, err := agent.GetTableDataFromCluster(syncTables) |
| | | if dumpSqls != nil { |
| | | for _, dumpSql := range *dumpSqls { |
| | | sqls = append(sqls, dumpSql) |
| | | } |
| | | } |
| | | |
| | | logger.Debug("成功获取集群中数据") |
| | | logger.Debug("成功获取集群中数据,err:",err) |
| | | |
| | | //timeUnix := time.Now().Unix() |
| | | //fmtTimeStr := time.Unix(timeUnix, 0).Format("2006-01-02 15:04:05") |