From 4878ca47b5979d74cf70a8fd0ad06c101fd39bba Mon Sep 17 00:00:00 2001 From: Rob Bygrave Date: Thu, 1 Jun 2023 19:45:17 +1200 Subject: [PATCH] Remove deprecated ExtendedServer query methods - use query.usingTransaction() instead Removing all the deprecated query methods from ExtendedServer. Migrate to passing the explicit transaction to the query using query.usingTransaction() instead. --- .../main/java/io/ebean/ExtendedServer.java | 167 ------------------ .../io/ebeaninternal/api/SpiEbeanServer.java | 136 ++++++++++++++ .../ebean/xtest/base/ExtendedServerTest.java | 2 +- 3 files changed, 137 insertions(+), 168 deletions(-) diff --git a/ebean-api/src/main/java/io/ebean/ExtendedServer.java b/ebean-api/src/main/java/io/ebean/ExtendedServer.java index db8c6d9f5..1c1a68289 100644 --- a/ebean-api/src/main/java/io/ebean/ExtendedServer.java +++ b/ebean-api/src/main/java/io/ebean/ExtendedServer.java @@ -1,15 +1,6 @@ package io.ebean; -import io.avaje.lang.Nullable; - import java.time.Clock; -import java.util.List; -import java.util.Map; -import java.util.Optional; -import java.util.Set; -import java.util.function.Consumer; -import java.util.function.Predicate; -import java.util.stream.Stream; /** * The extended API for Database. @@ -35,162 +26,4 @@ public interface ExtendedServer { @Deprecated void setClock(Clock clock); - /** - * Deprecated migrate to using {@link Query#usingTransaction(Transaction)}. - */ - @Deprecated - boolean exists(Query ormQuery, Transaction transaction); - - /** - * Deprecated migrate to using {@link Query#usingTransaction(Transaction)}. - */ - @Deprecated - int findCount(Query query, Transaction transaction); - - /** - * Deprecated migrate to using {@link Query#usingTransaction(Transaction)}. - */ - @Deprecated - List findIds(Query query, Transaction transaction); - - /** - * Deprecated migrate to using {@link Query#usingTransaction(Transaction)}. - */ - @Deprecated - QueryIterator findIterate(Query query, Transaction transaction); - - /** - * Deprecated migrate to using {@link Query#usingTransaction(Transaction)}. - */ - @Deprecated - Stream findStream(Query query, Transaction transaction); - - /** - * Deprecated migrate to using {@link Query#usingTransaction(Transaction)}. - */ - @Deprecated - void findEach(Query query, Consumer consumer, Transaction transaction); - - /** - * Deprecated migrate to using {@link Query#usingTransaction(Transaction)}. - */ - @Deprecated - void findEach(Query query, int batch, Consumer> consumer, Transaction t); - - /** - * Deprecated migrate to using {@link Query#usingTransaction(Transaction)}. - */ - @Deprecated - void findEachWhile(Query query, Predicate consumer, Transaction transaction); - - /** - * Deprecated migrate to using {@link Query#usingTransaction(Transaction)}. - */ - @Deprecated - List> findVersions(Query query, Transaction transaction); - - /** - * Deprecated migrate to using {@link Query#usingTransaction(Transaction)}. - */ - @Deprecated - List findList(Query query, Transaction transaction); - - /** - * Deprecated migrate to using {@link Query#usingTransaction(Transaction)}. - */ - @Deprecated - FutureRowCount findFutureCount(Query query, Transaction transaction); - - /** - * Deprecated migrate to using {@link Query#usingTransaction(Transaction)}. - */ - @Deprecated - FutureIds findFutureIds(Query query, Transaction transaction); - - /** - * Deprecated migrate to using {@link Query#usingTransaction(Transaction)}. - */ - @Deprecated - FutureList findFutureList(Query query, Transaction transaction); - - /** - * Deprecated migrate to using {@link Query#usingTransaction(Transaction)}. - */ - @Deprecated - PagedList findPagedList(Query query, Transaction transaction); - - /** - * Deprecated migrate to using {@link Query#usingTransaction(Transaction)}. - */ - @Deprecated - Set findSet(Query query, Transaction transaction); - - /** - * Deprecated migrate to using {@link Query#usingTransaction(Transaction)}. - */ - @Deprecated - Map findMap(Query query, Transaction transaction); - - /** - * Deprecated migrate to using {@link Query#usingTransaction(Transaction)}. - */ - @Deprecated - List findSingleAttributeList(Query query, Transaction transaction); - - /** - * Deprecated migrate to using {@link Query#usingTransaction(Transaction)}. - */ - @Deprecated - Set findSingleAttributeSet(Query query, Transaction transaction); - - /** - * Deprecated migrate to using {@link Query#usingTransaction(Transaction)}. - */ - @Deprecated - @Nullable - T findOne(Query query, Transaction transaction); - - /** - * Deprecated migrate to using {@link Query#usingTransaction(Transaction)}. - */ - @Deprecated - Optional findOneOrEmpty(Query query, Transaction transaction); - - /** - * Deprecated migrate to using {@link Query#usingTransaction(Transaction)}. - */ - @Deprecated - int delete(Query query, Transaction transaction); - - /** - * Deprecated migrate to using {@link Query#usingTransaction(Transaction)}. - */ - @Deprecated - int update(Query query, Transaction transaction); - - /** - * Deprecated migrate to using {@link Query#usingTransaction(Transaction)}. - */ - @Deprecated - List findList(SqlQuery query, Transaction transaction); - - /** - * Deprecated migrate to using {@link Query#usingTransaction(Transaction)}. - */ - @Deprecated - void findEach(SqlQuery query, Consumer consumer, Transaction transaction); - - /** - * Deprecated migrate to using {@link Query#usingTransaction(Transaction)}. - */ - @Deprecated - void findEachWhile(SqlQuery query, Predicate consumer, Transaction transaction); - - /** - * Deprecated migrate to using {@link SqlQuery#usingTransaction(Transaction)}. - */ - @Deprecated - @Nullable - SqlRow findOne(SqlQuery query, Transaction transaction); - } diff --git a/ebean-core/src/main/java/io/ebeaninternal/api/SpiEbeanServer.java b/ebean-core/src/main/java/io/ebeaninternal/api/SpiEbeanServer.java index 2111be2be..cac3c874f 100644 --- a/ebean-core/src/main/java/io/ebeaninternal/api/SpiEbeanServer.java +++ b/ebean-core/src/main/java/io/ebeaninternal/api/SpiEbeanServer.java @@ -16,6 +16,9 @@ import io.ebeaninternal.server.query.CQuery; import io.ebeaninternal.server.transaction.RemoteTransactionEvent; import java.util.List; +import java.util.Map; +import java.util.Optional; +import java.util.Set; import java.util.function.Consumer; import java.util.function.Predicate; import java.util.stream.Stream; @@ -317,4 +320,137 @@ public interface SpiEbeanServer extends SpiServer, ExtendedServer, BeanCollectio * Create a query bind capture for the given query plan. */ SpiQueryBindCapture createQueryBindCapture(SpiQueryPlan queryPlan); + + + /** + * Deprecated migrate to using {@link Query#usingTransaction(Transaction)}. + */ + boolean exists(Query ormQuery, Transaction transaction); + + /** + * Deprecated migrate to using {@link Query#usingTransaction(Transaction)}. + */ + int findCount(Query query, Transaction transaction); + + /** + * Deprecated migrate to using {@link Query#usingTransaction(Transaction)}. + */ + List findIds(Query query, Transaction transaction); + + /** + * Deprecated migrate to using {@link Query#usingTransaction(Transaction)}. + */ + QueryIterator findIterate(Query query, Transaction transaction); + + /** + * Deprecated migrate to using {@link Query#usingTransaction(Transaction)}. + */ + Stream findStream(Query query, Transaction transaction); + + /** + * Deprecated migrate to using {@link Query#usingTransaction(Transaction)}. + */ + void findEach(Query query, Consumer consumer, Transaction transaction); + + /** + * Deprecated migrate to using {@link Query#usingTransaction(Transaction)}. + */ + void findEach(Query query, int batch, Consumer> consumer, Transaction t); + + /** + * Deprecated migrate to using {@link Query#usingTransaction(Transaction)}. + */ + void findEachWhile(Query query, Predicate consumer, Transaction transaction); + + /** + * Deprecated migrate to using {@link Query#usingTransaction(Transaction)}. + */ + List> findVersions(Query query, Transaction transaction); + + /** + * Deprecated migrate to using {@link Query#usingTransaction(Transaction)}. + */ + List findList(Query query, Transaction transaction); + + /** + * Deprecated migrate to using {@link Query#usingTransaction(Transaction)}. + */ + FutureRowCount findFutureCount(Query query, Transaction transaction); + + /** + * Deprecated migrate to using {@link Query#usingTransaction(Transaction)}. + */ + FutureIds findFutureIds(Query query, Transaction transaction); + + /** + * Deprecated migrate to using {@link Query#usingTransaction(Transaction)}. + */ + FutureList findFutureList(Query query, Transaction transaction); + + /** + * Deprecated migrate to using {@link Query#usingTransaction(Transaction)}. + */ + PagedList findPagedList(Query query, Transaction transaction); + + /** + * Deprecated migrate to using {@link Query#usingTransaction(Transaction)}. + */ + Set findSet(Query query, Transaction transaction); + + /** + * Deprecated migrate to using {@link Query#usingTransaction(Transaction)}. + */ + Map findMap(Query query, Transaction transaction); + + /** + * Deprecated migrate to using {@link Query#usingTransaction(Transaction)}. + */ + List findSingleAttributeList(Query query, Transaction transaction); + + /** + * Deprecated migrate to using {@link Query#usingTransaction(Transaction)}. + */ + Set findSingleAttributeSet(Query query, Transaction transaction); + + /** + * Deprecated migrate to using {@link Query#usingTransaction(Transaction)}. + */ + @Nullable + T findOne(Query query, Transaction transaction); + + /** + * Deprecated migrate to using {@link Query#usingTransaction(Transaction)}. + */ + Optional findOneOrEmpty(Query query, Transaction transaction); + + /** + * Deprecated migrate to using {@link Query#usingTransaction(Transaction)}. + */ + int delete(Query query, Transaction transaction); + + /** + * Deprecated migrate to using {@link Query#usingTransaction(Transaction)}. + */ + int update(Query query, Transaction transaction); + + /** + * Deprecated migrate to using {@link Query#usingTransaction(Transaction)}. + */ + List findList(SqlQuery query, Transaction transaction); + + /** + * Deprecated migrate to using {@link Query#usingTransaction(Transaction)}. + */ + void findEach(SqlQuery query, Consumer consumer, Transaction transaction); + + /** + * Deprecated migrate to using {@link Query#usingTransaction(Transaction)}. + */ + void findEachWhile(SqlQuery query, Predicate consumer, Transaction transaction); + + /** + * Deprecated migrate to using {@link SqlQuery#usingTransaction(Transaction)}. + */ + @Nullable + SqlRow findOne(SqlQuery query, Transaction transaction); } diff --git a/ebean-test/src/test/java/io/ebean/xtest/base/ExtendedServerTest.java b/ebean-test/src/test/java/io/ebean/xtest/base/ExtendedServerTest.java index c0ccdfb9b..d29b52401 100644 --- a/ebean-test/src/test/java/io/ebean/xtest/base/ExtendedServerTest.java +++ b/ebean-test/src/test/java/io/ebean/xtest/base/ExtendedServerTest.java @@ -44,7 +44,7 @@ public class ExtendedServerTest extends BaseTestCase { // obtain extended API ... such that we can execute the // query using an explicit transaction - List customers = server.extended().findList(query, transaction); + List customers = query.usingTransaction(transaction).findList(); assertThat(customers).isNotEmpty(); transaction.commit();