| | |
|---|
| | | |
|---|
| | | dumpData := dbDumpH.Dump(strings.Join(tableNames, ",")) |
|---|
| | | |
|---|
| | | bytesReturn, _ := json.Marshal(dumpData) |
|---|
| | | bytesReturn := []byte(dumpData) |
|---|
| | | fmt.Println("androidSync len(bytesReturn): ", len(bytesReturn)) |
|---|
| | | if query, ok := event.(*serf.Query); ok { |
|---|
| | | if err := query.Respond(bytesReturn); err != nil { |
|---|
| | |
|---|
| | | select { |
|---|
| | | case r := <-respCh: |
|---|
| | | fmt.Println("Query response's len:", len(r.Payload)) |
|---|
| | | err := json.Unmarshal(r.Payload, &dumpSqls) |
|---|
| | | if err == nil { |
|---|
| | | fmt.Println("dumpSql:", dumpSqls) |
|---|
| | | dumpSqls = string(r.Payload) |
|---|
| | | if len(dumpSqls) >0 { |
|---|
| | | fmt.Println("data dump success") |
|---|
| | | } else { |
|---|
| | | fmt.Println("Query response.err:", err) |
|---|
| | | fmt.Println("Query response.len = 0") |
|---|
| | | } |
|---|
| | | return |
|---|
| | | } |
|---|
