sql method

Future<List<ArrowRecordBatch>> sql({
  1. required String database,
  2. required String query,
  3. Object? params,
  4. List<String>? namespace,
})

Implementation

Future<List<ArrowRecordBatch>> sql({required String database, required String query, Object? params, List<String>? namespace}) async {
  final rows = <ArrowRecordBatch>[];
  await for (final chunk in sqlStream(database: database, query: query, params: params, namespace: namespace)) {
    rows.add(chunk);
  }
  return rows;
}