(ctx context.Context, conn *sql.Conn, handleOneRow func(*sql.Rows) error, query string, args ...any)
| 1264 | } |
| 1265 | |
| 1266 | func simpleQueryWithArgs(ctx context.Context, conn *sql.Conn, handleOneRow func(*sql.Rows) error, query string, args ...any) error { |
| 1267 | var ( |
| 1268 | rows *sql.Rows |
| 1269 | err error |
| 1270 | ) |
| 1271 | if len(args) > 0 { |
| 1272 | rows, err = conn.QueryContext(ctx, query, args...) |
| 1273 | } else { |
| 1274 | rows, err = conn.QueryContext(ctx, query) |
| 1275 | } |
| 1276 | if err != nil { |
| 1277 | return errors.Annotatef(err, "sql: %s, args: %s", query, args) |
| 1278 | } |
| 1279 | defer rows.Close() |
| 1280 | |
| 1281 | for rows.Next() { |
| 1282 | if err := handleOneRow(rows); err != nil { |
| 1283 | rows.Close() |
| 1284 | return errors.Annotatef(err, "sql: %s, args: %s", query, args) |
| 1285 | } |
| 1286 | } |
| 1287 | return errors.Annotatef(rows.Err(), "sql: %s, args: %s", query, args) |
| 1288 | } |
| 1289 | |
| 1290 | func pickupPossibleField(tctx *tcontext.Context, meta TableMeta, db *BaseConn) (string, error) { |
| 1291 | // try using _tidb_rowid first |
no test coverage detected