| | |
| | | } |
| | | |
| | | type DbHandler interface { |
| | | Execute(sql string) bool |
| | | Forward(sql string) bool |
| | | } |
| | | |
| | | type DbDumpHandler interface { |
| | | Dump(tables string) string |
| | | Forward(tables string) string |
| | | } |
| | | |
| | | //数据库execute句柄 |
| | |
| | | var tableNames []string |
| | | json.Unmarshal(ev.Payload, &tableNames) |
| | | |
| | | dumpData := dbDumpH.Dump(strings.Join(tableNames, ",")) |
| | | dumpData := dbDumpH.Forward(strings.Join(tableNames, ",")) |
| | | |
| | | bytesReturn, _ := json.Marshal(dumpData) |
| | | //fmt.Println("results: ", bytesReturn) |
| | |
| | | func (a *Agent) GetTableDataFromCluster(tableNames []string) (*[]string, error) { |
| | | //members: get name of first member |
| | | mbs := a.GroupMembers(a.conf.ClusterID) |
| | | var specmembername string |
| | | specmembername := "" |
| | | for _, m := range mbs { |
| | | //fmt.Println("m", m) |
| | | if m.Name != a.conf.NodeName { //前缀:DSVAD:分析服务器 DSPAD:进出入pad |
| | |
| | | specmembername = m.Name |
| | | break |
| | | } |
| | | }else{ |
| | | specmembername = m.Name |
| | | break |
| | | } |
| | | } |
| | | } |
| | | if specmembername == "" { |
| | | return nil, errors.New("other pad node not found in memberlist") |
| | | } |
| | | //fmt.Println("mbs:", mbs, "a.conf.BindAddr:", a.conf.BindAddr, "specmembername:", specmembername) |
| | | |
| | |
| | | |
| | | resp, err := a.Query(QueryEventUpdateDBData, tBytes, ¶ms) |
| | | if err == nil || !strings.Contains(err.Error(), "cannot contain") { |
| | | //fmt.Println("err: ", err) |
| | | //fmt.Println("QueryEventUpdateDBData err: ") |
| | | } |
| | | //fmt.Println("Query.resp.err:", err, "resp:", resp) |
| | | fmt.Println("Query.resp.err:", err, "resp:", resp) |
| | | |
| | | var wg sync.WaitGroup |
| | | wg.Add(1) |