From b6e0dfa8c993cb838a94e2cb6de59448db1c6b1b Mon Sep 17 00:00:00 2001
From: Tobe O <thosakwe@gmail.com>
Date: Wed, 9 Oct 2019 12:13:25 -0400
Subject: [PATCH] Use transaction executor in delete

---
 angel_orm/lib/src/query.dart                | 2 +-
 angel_orm_test/lib/src/belongs_to_test.dart | 3 ++-
 2 files changed, 3 insertions(+), 2 deletions(-)

diff --git a/angel_orm/lib/src/query.dart b/angel_orm/lib/src/query.dart
index f20b21ca..7addbbe7 100644
--- a/angel_orm/lib/src/query.dart
+++ b/angel_orm/lib/src/query.dart
@@ -279,7 +279,7 @@ abstract class Query<T, Where extends QueryWhere> extends QueryBase<T> {
         // TODO: Can this be done with just *one* query?
         var existing = await get(tx);
         //var sql = compile(preamble: 'SELECT $tableName.id', withFields: false);
-        return executor
+        return tx
             .query(tableName, sql, substitutionValues)
             .then((_) => existing);
       });
diff --git a/angel_orm_test/lib/src/belongs_to_test.dart b/angel_orm_test/lib/src/belongs_to_test.dart
index 09342317..c58dc7f8 100644
--- a/angel_orm_test/lib/src/belongs_to_test.dart
+++ b/angel_orm_test/lib/src/belongs_to_test.dart
@@ -125,8 +125,9 @@ belongsToTests(FutureOr<QueryExecutor> Function() createExecutor,
   });
 
   test('delete stream', () async {
+    printSeparator('Delete stream test');
     var query = new BookQuery()..where.name.equals(deathlyHallows.name);
-    print(query.compile(Set()));
+    print(query.compile(Set(), preamble: 'DELETE', withFields: false));
     var books = await query.delete(executor);
     expect(books, hasLength(1));