| | |
| | | fmt.Println("Query tableNames unmarshal err") |
| | | return |
| | | } |
| | | fmt.Println("Query tableNames:",tableNames) |
| | | datas, err := ExecuteQueryByGorm(tableNames) |
| | | if err !=nil { |
| | | fmt.Println("queryByGorm err") |
| | |
| | | mbs := a.GroupMembers(a.conf.ClusterID) |
| | | var specmembername string |
| | | for _, m := range mbs { |
| | | if m.Addr.String() != a.conf.BindAddr { |
| | | fmt.Println("m",m) |
| | | if m.Name != a.conf.NodeName { |
| | | specmembername = m.Name |
| | | break |
| | | } |
| | | } |
| | | fmt.Println(specmembername) |
| | | fmt.Println("mbs:",mbs,"a.conf.BindAddr:",a.conf.BindAddr,"specmembername:",specmembername) |
| | | |
| | | //query: get db file. |
| | | params := serf.QueryParam{ |
| | | FilterNodes: strings.Fields(specmembername), |
| | | //FilterNodes: strings.Fields(specmembername), |
| | | FilterNodes: strings.Fields(a.conf.NodeName), |
| | | } |
| | | |
| | | //SQL |