| | |
|---|
| | | if err == nil || !strings.Contains(err.Error(), "cannot contain") { |
|---|
| | | fmt.Println("err: ", err) |
|---|
| | | } |
|---|
| | | fmt.Println("Query.resp.err:",err,"resp:",resp) |
|---|
| | | |
|---|
| | | |
|---|
| | | go func() { |
|---|
| | | respCh := resp.ResponseCh() |
|---|
| | | for { |
|---|
| | | select { |
|---|
| | | case r := <-respCh: |
|---|
| | | fmt.Println("x length is: ", len(r.Payload)) |
|---|
| | | // // byte to file. |
|---|
| | | var dumpSqls []string |
|---|
| | | err := json.Unmarshal(r.Payload, &dumpSqls) |
|---|
| | | if err ==nil { |
|---|
| | | if flag,_ := ExecuteSqlByGorm(dumpSqls);flag{ |
|---|
| | | fmt.Println("data dump success") |
|---|
| | | } |
|---|
| | | } |
|---|
| | | return |
|---|
| | | } |
|---|
| | | } |
|---|
| | | }() |
|---|
| | | return nil |
|---|
| | | //go func() { |
|---|
| | | // respCh := resp.ResponseCh() |
|---|
| | | // for { |
|---|
| | | // select { |
|---|
| | | // case r := <-respCh: |
|---|
| | | // fmt.Println("x length is: ", len(r.Payload)) |
|---|
| | | // // // byte to file. |
|---|
| | | // var dumpSqls []string |
|---|
| | | // err := json.Unmarshal(r.Payload, &dumpSqls) |
|---|
| | | // if err ==nil { |
|---|
| | | // if flag,_ := ExecuteSqlByGorm(dumpSqls);flag{ |
|---|
| | | // fmt.Println("data dump success") |
|---|
| | | // } |
|---|
| | | // } |
|---|
| | | // return |
|---|
| | | // } |
|---|
| | | // } |
|---|
| | | //}() |
|---|
| | | return err |
|---|
| | | |
|---|
| | | //r, err = c.Query([]string{query}, false, false) |
|---|
| | | //if err != nil { |
|---|
