Fix compatibility with Drift 2.19.0 (#2162)

* Add support for drift 2.19.0

* Update

* fix test

* Update CHANGELOG

* Add ignores

Author: buenaflor

CHANGELOG.md

@@ -10,6 +10,7 @@
 
 ### Fixes
 
+- Fix sentry_drift compatibility with Drift 2.19.0 ([#2162](https://github.com/getsentry/sentry-dart/pull/2162))
 - App starts hanging for 30s ([#2140](https://github.com/getsentry/sentry-dart/pull/2140))
   - Time out for app start info retrieval has been reduced to 10s
   - If `autoAppStarts` is `false` and `setAppStartEnd` has not been called, the app start event processor will now return early instead of waiting for `getAppStartInfo` to finish

drift/lib/src/sentry_query_executor.dart

@@ -3,9 +3,10 @@ import 'dart:async';
 import 'package:drift/drift.dart';
 import 'package:meta/meta.dart';
 import 'package:sentry/sentry.dart';
-import 'version.dart';
+
 import 'sentry_span_helper.dart';
 import 'sentry_transaction_executor.dart';
+import 'version.dart';
 
 /// Signature of a function that opens a database connection when instructed to.
 typedef DatabaseOpener = FutureOr<QueryExecutor> Function();
@@ -167,6 +168,17 @@ class SentryQueryExecutor extends QueryExecutor {
     );
   }
 
+  @override
+  // ignore: override_on_non_overriding_member, public_member_api_docs
+  QueryExecutor beginExclusive() {
+    final dynamic uncheckedExecutor = _executor;
+    try {
+      return uncheckedExecutor.beginExclusive() as QueryExecutor;
+    } on NoSuchMethodError catch (_) {
+      throw Exception('This method is not supported in Drift versions <2.19.0');
+    }
+  }
+
   @override
   Future<void> close() {
     return _spanHelper.asyncWrapInSpan(

drift/lib/src/sentry_transaction_executor.dart

@@ -1,6 +1,7 @@
 import 'package:drift/backends.dart';
 import 'package:meta/meta.dart';
 import 'package:sentry/sentry.dart';
+
 import 'sentry_span_helper.dart';
 
 /// @nodoc
@@ -134,6 +135,17 @@ class SentryTransactionExecutor extends TransactionExecutor {
     );
   }
 
+  @override
+  // ignore: override_on_non_overriding_member, public_member_api_docs
+  QueryExecutor beginExclusive() {
+    final dynamic uncheckedExecutor = _executor;
+    try {
+      return uncheckedExecutor.beginExclusive() as QueryExecutor;
+    } on NoSuchMethodError catch (_) {
+      throw Exception('This method is not supported in Drift versions <2.19.0');
+    }
+  }
+
   @override
   Future<int> runUpdate(String statement, List<Object?> args) {
     return _spanHelper.asyncWrapInSpan(

drift/test/sentry_database_test.dart

@@ -324,9 +324,14 @@ void main() {
         });
       } catch (_) {}
 
+      final spans = fixture.tracer.children
+          .where((child) => child.status == SpanStatus.aborted());
+      expect(spans.length, 1);
+      final abortedSpan = spans.first;
+
       verifySpan(
         expectedTransactionStatement,
-        fixture.getCreatedSpan(),
+        abortedSpan,
         origin: SentryTraceOrigins.autoDbDriftTransactionExecutor,
         status: SpanStatus.aborted(),
       );