reWrite another error at query time

8 months ago · a1e40345f1
parent 59a4723fce
commit a1e40345f1
1 changed files with 1 additions and 0 deletions
--- a/db/db.go
+++ b/db/db.go
@ -846,6 +846,7 @@ func (db *DB) queryStmtWithConn(ctx context.Context, stmt *command.Statement, xT
 			ptrs[i] = &dest[i]
 		}
 		if err := rs.Scan(ptrs...); err != nil {
+			err = rewriteContextTimeout(err, ErrQueryTimeout)
 			return nil, err
 		}
 		params, err := normalizeRowValues(dest, xTypes)