| | |
|---|
| | | } |
|---|
| | | } else if ev.Name == QueryEventUpdateDBData { |
|---|
| | | fmt.Println(string(ev.Payload)) |
|---|
| | | var tmpstringslice []string |
|---|
| | | tmpstringslice = append(tmpstringslice, string(ev.Payload)) |
|---|
| | | fmt.Println(tmpstringslice) |
|---|
| | | rows, err := ExecuteQuerySql(tmpstringslice) |
|---|
| | | var tableNames []string |
|---|
| | | err := json.Unmarshal(ev.Payload, &tableNames) |
|---|
| | | if err !=nil { |
|---|
| | | fmt.Println("Query tableNames unmarshal err") |
|---|
| | | return |
|---|
| | | } |
|---|
| | | |
|---|
| | | rows, err := ExecuteQuerySql(tableNames) |
|---|
| | | if err != nil { |
|---|
| | | fmt.Println("err: ", err) |
|---|
| | | return |
|---|
| | |
|---|
| | | return |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | //var res []*Rows |
|---|
| | | //json.Unmarshal(bytesReturn, &res) |
|---|
| | | } |
|---|
| | | case serf.MemberEvent: |
|---|
| | | if event.EventType() == serf.EventMemberLeave { |
|---|
