#69 - ENH: Query bean constructor taking Transaction

Author: rbygrave

h2-create.sql

@@ -30,7 +30,7 @@
     <dependency>
       <groupId>io.ebean</groupId>
       <artifactId>querybean-generator</artifactId>
-      <version>12.1.11</version>
+      <version>12.1.12-SNAPSHOT</version>
       <scope>provided</scope>
     </dependency>
 

h2-drop.sql

@@ -137,6 +137,22 @@ public TQRootBean(Class<T> beanType, Database database) {
     this(database.find(beanType));
   }
 
+  /**
+   * Construct with a transaction.
+   */
+  protected TQRootBean(Class<T> beanType, Transaction transaction) {
+    this(beanType);
+    query.usingTransaction(transaction);
+  }
+
+  /**
+   * Construct with a database and transaction.
+   */
+  protected TQRootBean(Class<T> beanType, Database database, Transaction transaction) {
+    this(beanType, database);
+    query.usingTransaction(transaction);
+  }
+
   /**
    * Construct using a query.
    */

pom.xml

@@ -1,6 +1,7 @@
 package org.querytest;
 
 import io.ebean.DB;
+import io.ebean.Database;
 import io.ebean.PagedList;
 import io.ebean.Query;
 import io.ebean.QueryIterator;
@@ -43,6 +44,33 @@
 
 public class QCustomerTest {
 
+  @Test
+  public void findWithTransaction() {
+
+    final Database database = DB.getDefault();
+
+    try (Transaction txn = database.createTransaction()) {
+      Customer customer = new Customer();
+      customer.setName("explicitTransaction");
+
+      database.save(customer, txn);
+
+      final Customer found = new QCustomer(txn)
+        .name.eq("explicitTransaction")
+        .findOne();
+      assertThat(found).isNotNull();
+
+      // not found using other transaction
+      final Customer foundNot = new QCustomer()
+        .name.eq("explicitTransaction")
+        .findOne();
+      assertThat(foundNot).isNull();
+
+      txn.commit();
+    }
+
+  }
+
   @Test
   public void findSingleAttribute() {
 
@@ -83,7 +111,7 @@ public void findIterate() {
     try {
       while (iterate.hasNext()) {
         Customer customer = iterate.next();
-        customer.getName();
+        assertThat(customer.getName()).isNotNull();
       }
     } finally {
       iterate.close();
@@ -325,7 +353,7 @@ public void testFindLargeStream() {
     try (Stream<Customer> stream = new QCustomer()
       .name.startsWith("largeStream")
       .id.asc()
-      .findSteam()) {
+      .findLargeStream()) {
 
       stream.forEach(it -> sb.add(it.getName()));
     }