Fix missing query method in transactions

CHANGELOG.md

@@ -1,12 +1,16 @@
+## 3.0.0+1
+
+- Fix missing `query` method in transactions
+
 ## 3.0.0
 
-Major performance refactor with a few breaking changes.
+Major performance refactor with a few breaking changes
 
-- Change how tables and primary keys are fetched to minimize reads.
-- Allow for more efficient bulk writing in underlying implementation.
-- Rework abstractions to allow exposing Sqlite batches.
-- Rename classes to better reflect their goals.
-- Correctly identify and forbid semicolon separated statements.
+- Change how tables and primary keys are fetched to minimize reads
+- Allow for more efficient bulk writing in underlying implementation
+- Rework abstractions to allow exposing Sqlite batches
+- Rename classes to better reflect their goals
+- Correctly identify and forbid semicolon separated statements
 
 ## 2.1.7
 

lib/src/crdt_executor.dart

@@ -7,11 +7,18 @@ import 'database_api.dart';
 final _sqlEngine = SqlEngine();
 
 /// Intercepts CREATE TABLE queries to assist with table creation and updates.
-/// Does not affect any other query types.
-class CrdtTableExecutor {
+/// Does not impact any other query types.
+class CrdtTableExecutor extends _CrdtTableExecutor {
+  CrdtTableExecutor(ReadWriteApi super._db);
+
+  Future<List<Map<String, Object?>>> query(String sql, [List<Object?>? args]) =>
+      (_db as ReadWriteApi).query(sql, args);
+}
+
+class _CrdtTableExecutor {
   final WriteApi _db;
 
-  CrdtTableExecutor(this._db);
+  _CrdtTableExecutor(this._db);
 
   /// Executes a SQL query with an optional [args] list.
   /// Use "?" placeholders for parameters to avoid injection vulnerabilities:
@@ -93,13 +100,20 @@ class CrdtTableExecutor {
   }
 }
 
-class CrdtExecutor extends CrdtTableExecutor {
+class CrdtExecutor extends CrdtWriteExecutor {
+  CrdtExecutor(ReadWriteApi super._db, super.hlc);
+
+  Future<List<Map<String, Object?>>> query(String sql, [List<Object?>? args]) =>
+      (_db as ReadWriteApi).query(sql, args);
+}
+
+class CrdtWriteExecutor extends _CrdtTableExecutor {
   final Hlc hlc;
   late final _hlcString = hlc.toString();
 
   final affectedTables = <String>{};
 
-  CrdtExecutor(super._db, this.hlc);
+  CrdtWriteExecutor(super._db, this.hlc);
 
   @override
   Future<void> _executeStatement(

pubspec.yaml

@@ -1,6 +1,6 @@
 name: sql_crdt
 description: Base package for Conflict-free Replicated Data Types (CRDTs) using SQL databases
-version: 3.0.0
+version: 3.0.0+1
 homepage: https://github.com/cachapa/sql_crdt
 repository: https://github.com/cachapa/sql_crdt
 issue_tracker: https://github.com/cachapa/sql_crdt/issues