IQueryServiceConnectionOverloads extension

Ergonomic overloads that take a Connection directly instead of a raw connectionId string. Each method delegates to its String connectionId counterpart, keeping the original API stable while removing the manual conn.id plumbing at call sites.

The methods live in an extension so adding new ones is purely additive — implementers of IQueryService do not need to override anything.

Example:

final connResult = await service.connect('DSN=mydsn');
final conn = connResult.getOrThrow();

// Before (still supported):
final a = await service.executeQuery(
  'SELECT 1',
  connectionId: conn.id,
);

// After (no manual conn.id plumbing):
final b = await service.executeQueryFor(conn, 'SELECT 1');
on

Methods

executeQueryColumnarFor(Connection conn, String sql, {List? params}) → Future<Result<TypedColumnarResult>>

Available on IQueryService, provided by the IQueryServiceConnectionOverloads extension

executeQueryColumnar overload that accepts a Connection.
executeQueryFor(Connection conn, String sql, {List? params}) → Future<Result<QueryResult>>

Available on IQueryService, provided by the IQueryServiceConnectionOverloads extension

executeQuery overload that accepts a Connection.
executeQueryNamedFor(Connection conn, String sql, Map<String, Object?> namedParams) → Future<Result<QueryResult>>

Available on IQueryService, provided by the IQueryServiceConnectionOverloads extension

executeQueryNamed overload that accepts a Connection.
executeQueryParamsFor(Connection conn, String sql, List params, {ResultEncoding resultEncoding = ResultEncoding.rowMajor}) → Future<Result<QueryResult>>

Available on IQueryService, provided by the IQueryServiceConnectionOverloads extension

executeQueryParams overload that accepts a Connection.
streamQueryColumnarFor(Connection conn, String sql) → Stream<Result<TypedColumnarResult>>

Available on IQueryService, provided by the IQueryServiceConnectionOverloads extension

streamQueryColumnar overload that accepts a Connection.
streamQueryFor(Connection conn, String sql) → Stream<Result<QueryResult>>

Available on IQueryService, provided by the IQueryServiceConnectionOverloads extension

streamQuery overload that accepts a Connection.
streamQueryNamedFor(Connection conn, String sql, Map<String, Object?> namedParams) → Stream<Result<QueryResult>>

Available on IQueryService, provided by the IQueryServiceConnectionOverloads extension

streamQueryNamed overload that accepts a Connection.