| | |
| | | "net" |
| | | "os" |
| | | "strconv" |
| | | "sync" |
| | | |
| | | //"os" |
| | | "strings" |
| | | "time" |
| | |
| | | } |
| | | if sqlUe.Owner != a.conf.NodeName { |
| | | |
| | | evTime := uint64(ev.LTime) |
| | | logger.Info("ev.LTime:",evTime,",SqlUserEvent.sql:",sqlUe.Sql) |
| | | flag, e := ExecuteSqlByGorm(sqlUe.Sql) |
| | | |
| | | flag, _ := ExecuteSqlByGorm(sqlUe.Sql) |
| | | logger.Info("userEvent exec ",sqlUe.Sql,",Result:",flag) |
| | | evTime := uint64(ev.LTime) |
| | | logger.Info("ev.LTime:",evTime,"userEvent exec ",sqlUe.Sql,",Result:",flag,", err:",e) |
| | | } |
| | | } else if ev.Name == UserEventSyncDbTablePersonCache { |
| | | logger.Info("LTime:",ev.LTime,",ev.Payload.len:",len(ev.Payload)) |
| | |
| | | From string `json:"from"` |
| | | } |
| | | |
| | | var QueryTcpResponseChan = make(chan []byte) |
| | | //GetDbFromCluster get the newest database after join cluster |
| | | //dbPathWrite the path where to write after got a database, |
| | | func (a *Agent) GetTableDataFromCluster(tableNames []string) (*[]string,error) { |
| | |
| | | |
| | | var dumpSqls []string |
| | | |
| | | //var wg sync.WaitGroup |
| | | //wg.Add(1) |
| | | //go func() { |
| | | // defer wg.Done() |
| | | // respCh := resp.ResponseCh() |
| | | // for { |
| | | // select { |
| | | // case r := <-respCh: |
| | | // logger.Info("Query response's len:", len(r.Payload)) |
| | | // err := json.Unmarshal(r.Payload, &dumpSqls) |
| | | // if err ==nil { |
| | | // logger.Error("dumpSql:",dumpSqls) |
| | | // logger.Error("data dump success") |
| | | // } |
| | | // return |
| | | // } |
| | | // } |
| | | //}() |
| | | //wg.Wait() |
| | | var wg sync.WaitGroup |
| | | wg.Add(1) |
| | | go func() { |
| | | defer wg.Done() |
| | | //respCh := resp.ResponseCh() |
| | | for { |
| | | select { |
| | | //case r := <-respCh: |
| | | // logger.Info("Query response's len:", len(r.Payload)) |
| | | // err := json.Unmarshal(r.Payload, &dumpSqls) |
| | | // if err ==nil { |
| | | // logger.Error("dumpSql:",dumpSqls) |
| | | // logger.Error("data dump success") |
| | | // } |
| | | // return |
| | | case msg := <-QueryTcpResponseChan: |
| | | logger.Debug("QueryTcpResponseChan receive msg len:",len(msg)) |
| | | err := json.Unmarshal(msg, &dumpSqls) |
| | | if err ==nil { |
| | | logger.Error("dumpSql success:",dumpSqls) |
| | | } else { |
| | | logger.Error("data dump err:",err) |
| | | } |
| | | return |
| | | } |
| | | |
| | | } |
| | | }() |
| | | wg.Wait() |
| | | return &dumpSqls,nil |
| | | |
| | | //r, err = c.Query([]string{query}, false, false) |