| | |
| | | } |
| | | |
| | | type DbHandler interface { |
| | | Forward(sql string) bool |
| | | Execute(sql string) bool |
| | | } |
| | | |
| | | type DbDumpHandler interface { |
| | | Forward(tables string) string |
| | | Dump(tables string) string |
| | | } |
| | | |
| | | //数据库execute句柄 |
| | |
| | | } else if ev.Name == QueryEventUpdateDBData { |
| | | //fmt.Println(string(ev.Payload)) |
| | | var tableNames []string |
| | | json.Unmarshal(ev.Payload, &tableNames) |
| | | err := json.Unmarshal(ev.Payload, &tableNames) |
| | | fmt.Println("androidSync tableNames:", tableNames, "err:", err) |
| | | |
| | | dumpData := dbDumpH.Forward(strings.Join(tableNames, ",")) |
| | | dumpData := dbDumpH.Dump(strings.Join(tableNames, ",")) |
| | | |
| | | bytesReturn, _ := json.Marshal(dumpData) |
| | | //fmt.Println("results: ", bytesReturn) |
| | | fmt.Println("androidSync len(bytesReturn): ", len(bytesReturn)) |
| | | if query, ok := event.(*serf.Query); ok { |
| | | if err := query.Respond(bytesReturn); err != nil { |
| | | //fmt.Printf("err: %s\n", err) |
| | |
| | | } |
| | | } |
| | | } |
| | | if specmembername == "" { |
| | | return nil, errors.New("other pad node not found in memberlist") |
| | | } |
| | | //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) |
| | | |
| | | //query: get db file. |