diff --git a/packages/drift_sqlite_async/lib/src/connection.dart b/packages/drift_sqlite_async/lib/src/connection.dart
index e375795..a1af55a 100644
--- a/packages/drift_sqlite_async/lib/src/connection.dart
+++ b/packages/drift_sqlite_async/lib/src/connection.dart
@@ -15,8 +15,8 @@ import 'package:sqlite_async/sqlite_async.dart';
 class SqliteAsyncDriftConnection extends DatabaseConnection {
   late StreamSubscription _updateSubscription;
 
-  SqliteAsyncDriftConnection(SqliteConnection db)
-      : super(SqliteAsyncQueryExecutor(db)) {
+  SqliteAsyncDriftConnection(SqliteConnection db, {bool logStatements = false})
+      : super(SqliteAsyncQueryExecutor(db, logStatements: logStatements)) {
     _updateSubscription = (db as SqliteQueries).updates!.listen((event) {
       var setUpdates = <TableUpdate>{};
       for (var tableName in event.tables) {
diff --git a/packages/drift_sqlite_async/lib/src/executor.dart b/packages/drift_sqlite_async/lib/src/executor.dart
index 91c6f7f..b68e2e6 100644
--- a/packages/drift_sqlite_async/lib/src/executor.dart
+++ b/packages/drift_sqlite_async/lib/src/executor.dart
@@ -127,10 +127,8 @@ class _SqliteAsyncVersionDelegate extends DynamicVersionDelegate {
 /// Extnral update notifications from the [SqliteConnection] are _not_ forwarded
 /// automatically - use [SqliteAsyncDriftConnection] for that.
 class SqliteAsyncQueryExecutor extends DelegatedDatabase {
-  SqliteAsyncQueryExecutor(SqliteConnection db)
-      : super(
-          _SqliteAsyncDelegate(db),
-        );
+  SqliteAsyncQueryExecutor(SqliteConnection db, {bool logStatements = false})
+      : super(_SqliteAsyncDelegate(db), logStatements: logStatements);
 
   /// The underlying SqliteConnection used by drift to send queries.
   SqliteConnection get db {