GetPdAddrs gets PD address from TiDB
(tctx *tcontext.Context, db *sql.DB)
| 857 | |
| 858 | // GetPdAddrs gets PD address from TiDB |
| 859 | func GetPdAddrs(tctx *tcontext.Context, db *sql.DB) ([]string, error) { |
| 860 | const query = "SELECT * FROM information_schema.cluster_info where type = 'pd';" |
| 861 | rows, err := db.QueryContext(tctx, query) |
| 862 | if err != nil { |
| 863 | return []string{}, errors.Annotatef(err, "sql: %s", query) |
| 864 | } |
| 865 | pdAddrs, err := GetSpecifiedColumnValueAndClose(rows, "STATUS_ADDRESS") |
| 866 | return pdAddrs, errors.Annotatef(err, "sql: %s", query) |
| 867 | } |
| 868 | |
| 869 | // GetTiDBDDLIDs gets DDL IDs from TiDB |
| 870 | func GetTiDBDDLIDs(tctx *tcontext.Context, db *sql.DB) ([]string, error) { |
no test coverage detected