lazyJoins();
}
diff --git a/ebean-core/src/main/java/io/ebeaninternal/api/SpiSqlUpdate.java b/ebean-core/src/main/java/io/ebeaninternal/api/SpiSqlUpdate.java
index 1a19bb4e3..f19c45b2f 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/api/SpiSqlUpdate.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/api/SpiSqlUpdate.java
@@ -7,12 +7,12 @@ public interface SpiSqlUpdate extends SqlUpdate {
/**
* Return the sql taking into account bind parameter expansion.
*/
- String getBaseSql();
+ String baseSql();
/**
* Return the Bind parameters.
*/
- BindParams getBindParams();
+ BindParams bindParams();
/**
* Set the final sql being executed with named parameters replaced etc.
diff --git a/ebean-core/src/main/java/io/ebeaninternal/api/SpiTransaction.java b/ebean-core/src/main/java/io/ebeaninternal/api/SpiTransaction.java
index a8acdb45a..e15b51298 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/api/SpiTransaction.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/api/SpiTransaction.java
@@ -25,8 +25,7 @@ public interface SpiTransaction extends Transaction {
/**
* Return the user defined label for the transaction.
*/
- String getLabel();
-
+ String label();
/**
* Return true if generated SQL and Bind values should be logged to the
@@ -91,12 +90,12 @@ public interface SpiTransaction extends Transaction {
* Returns a String used to identify the transaction. This id is used for
* Transaction logging.
*/
- String getId();
+ String id();
/**
* Return the start timestamp for the transaction (JVM side).
*/
- long getStartNanoTime();
+ long startNanoTime();
/**
* Return true if this transaction has updateAllLoadedProperties set.
@@ -109,7 +108,7 @@ public interface SpiTransaction extends Transaction {
*
* Returning 0 implies to use the system wide default batch size.
*/
- DocStoreMode getDocStoreMode();
+ DocStoreMode docStoreMode();
/**
* Return the batch size to us for ElasticSearch Bulk API calls
@@ -184,7 +183,7 @@ public interface SpiTransaction extends Transaction {
* indexes. On commit the Table modifications this generates is broadcast
* around the cluster (if you have a cluster).
*/
- TransactionEvent getEvent();
+ TransactionEvent event();
/**
* Whether persistCascade is on for save and delete.
@@ -200,7 +199,7 @@ public interface SpiTransaction extends Transaction {
/**
* Return the BatchControl used to batch up persist requests.
*/
- BatchControl getBatchControl();
+ BatchControl batchControl();
/**
* Set the BatchControl used to batch up persist requests. There should only be one
@@ -215,7 +214,7 @@ public interface SpiTransaction extends Transaction {
* later. This is along the lines of 'extended persistence context'
* behaviour.
*/
- SpiPersistenceContext getPersistenceContext();
+ SpiPersistenceContext persistenceContext();
/**
* Set the persistence context to this transaction.
@@ -236,7 +235,7 @@ public interface SpiTransaction extends Transaction {
* that method we can no longer trust the query only status of a
* Transaction.
*/
- Connection getInternalConnection();
+ Connection internalConnection();
/**
* Return true if the manyToMany intersection should be persisted for this particular relationship direction.
@@ -291,7 +290,7 @@ public interface SpiTransaction extends Transaction {
/**
* Return a document store transaction.
*/
- DocStoreTransaction getDocStoreTransaction();
+ DocStoreTransaction docStoreTransaction();
/**
* Set the current Tenant Id.
@@ -301,7 +300,7 @@ public interface SpiTransaction extends Transaction {
/**
* Return the current Tenant Id.
*/
- Object getTenantId();
+ Object tenantId();
/**
* Return the offset time from the start of the transaction.
@@ -331,7 +330,7 @@ public interface SpiTransaction extends Transaction {
/**
* Return the profile location for this transaction.
*/
- ProfileLocation getProfileLocation();
+ ProfileLocation profileLocation();
/**
* Return true when nested transactions should create Savepoints.
diff --git a/ebean-core/src/main/java/io/ebeaninternal/api/SpiTransactionProxy.java b/ebean-core/src/main/java/io/ebeaninternal/api/SpiTransactionProxy.java
index 87c2f606a..bb738cb5a 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/api/SpiTransactionProxy.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/api/SpiTransactionProxy.java
@@ -28,8 +28,8 @@ public abstract class SpiTransactionProxy implements SpiTransaction {
}
@Override
- public long getStartNanoTime() {
- return transaction.getStartNanoTime();
+ public long startNanoTime() {
+ return transaction.startNanoTime();
}
@Override
@@ -38,8 +38,8 @@ public abstract class SpiTransactionProxy implements SpiTransaction {
}
@Override
- public String getLabel() {
- return transaction.getLabel();
+ public String label() {
+ return transaction.label();
}
@Override
@@ -98,8 +98,8 @@ public abstract class SpiTransactionProxy implements SpiTransaction {
}
@Override
- public ProfileLocation getProfileLocation() {
- return transaction.getProfileLocation();
+ public ProfileLocation profileLocation() {
+ return transaction.profileLocation();
}
@Override
@@ -108,18 +108,18 @@ public abstract class SpiTransactionProxy implements SpiTransaction {
}
@Override
- public Object getTenantId() {
- return transaction.getTenantId();
+ public Object tenantId() {
+ return transaction.tenantId();
}
@Override
- public DocStoreTransaction getDocStoreTransaction() {
- return transaction.getDocStoreTransaction();
+ public DocStoreTransaction docStoreTransaction() {
+ return transaction.docStoreTransaction();
}
@Override
- public DocStoreMode getDocStoreMode() {
- return transaction.getDocStoreMode();
+ public DocStoreMode docStoreMode() {
+ return transaction.docStoreMode();
}
@Override
@@ -214,8 +214,8 @@ public abstract class SpiTransactionProxy implements SpiTransaction {
}
@Override
- public String getId() {
- return transaction.getId();
+ public String id() {
+ return transaction.id();
}
@Override
@@ -359,8 +359,8 @@ public abstract class SpiTransactionProxy implements SpiTransaction {
}
@Override
- public TransactionEvent getEvent() {
- return transaction.getEvent();
+ public TransactionEvent event() {
+ return transaction.event();
}
@Override
@@ -374,8 +374,8 @@ public abstract class SpiTransactionProxy implements SpiTransaction {
}
@Override
- public BatchControl getBatchControl() {
- return transaction.getBatchControl();
+ public BatchControl batchControl() {
+ return transaction.batchControl();
}
@Override
@@ -384,8 +384,8 @@ public abstract class SpiTransactionProxy implements SpiTransaction {
}
@Override
- public SpiPersistenceContext getPersistenceContext() {
- return transaction.getPersistenceContext();
+ public SpiPersistenceContext persistenceContext() {
+ return transaction.persistenceContext();
}
@Override
@@ -394,8 +394,8 @@ public abstract class SpiTransactionProxy implements SpiTransaction {
}
@Override
- public Connection getInternalConnection() {
- return transaction.getInternalConnection();
+ public Connection internalConnection() {
+ return transaction.internalConnection();
}
@Override
diff --git a/ebean-core/src/main/java/io/ebeaninternal/api/SpiUpdate.java b/ebean-core/src/main/java/io/ebeaninternal/api/SpiUpdate.java
index 2e2ed8531..4553363db 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/api/SpiUpdate.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/api/SpiUpdate.java
@@ -41,32 +41,32 @@ public interface SpiUpdate extends Update {
/**
* Return the type of bean being updated.
*/
- Class> getBeanType();
+ Class> beanType();
/**
* Return the label (for metrics collection).
*/
- String getLabel();
+ String label();
/**
* Return the type of this - insert, update or delete.
*/
- OrmUpdateType getOrmUpdateType();
+ OrmUpdateType ormUpdateType();
/**
* Return the name of the table being modified.
*/
- String getBaseTable();
+ String baseTable();
/**
* Return the update statement. This could be either sql or an orm update with bean types and property names.
*/
- String getUpdateStatement();
+ String updateStatement();
/**
* Return the timeout in seconds.
*/
- int getTimeout();
+ int timeout();
/**
* Return true if the cache should be notified to invalidate objects.
@@ -76,7 +76,7 @@ public interface SpiUpdate extends Update {
/**
* Return the bind parameters.
*/
- BindParams getBindParams();
+ BindParams bindParams();
/**
* Set the generated sql used.
diff --git a/ebean-core/src/main/java/io/ebeaninternal/api/SpiUpdatePlan.java b/ebean-core/src/main/java/io/ebeaninternal/api/SpiUpdatePlan.java
index ab094616d..5cb956b85 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/api/SpiUpdatePlan.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/api/SpiUpdatePlan.java
@@ -36,27 +36,27 @@ public interface SpiUpdatePlan {
/**
* Return the time this plan was created.
*/
- long getTimeCreated();
+ long timeCreated();
/**
* Return the time this plan was last used.
*/
- long getTimeLastUsed();
+ long timeLastUsed();
/**
* Return the hash key for this plan.
*/
- String getKey();
+ String key();
/**
* Return the concurrency mode for this plan.
*/
- ConcurrencyMode getMode();
+ ConcurrencyMode mode();
/**
* Return the update SQL statement.
*/
- String getSql();
+ String sql();
/**
* Return the set of bindable update properties.
diff --git a/ebean-core/src/main/java/io/ebeaninternal/api/TransactionEvent.java b/ebean-core/src/main/java/io/ebeaninternal/api/TransactionEvent.java
index 2c06dbb81..c1fc45f30 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/api/TransactionEvent.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/api/TransactionEvent.java
@@ -55,7 +55,7 @@ public final class TransactionEvent implements Serializable {
deleteByIdMap.addList(desc, idList);
}
- public DeleteByIdMap getDeleteByIdMap() {
+ public DeleteByIdMap deleteByIdMap() {
return deleteByIdMap;
}
@@ -70,11 +70,11 @@ public final class TransactionEvent implements Serializable {
/**
* Return the list of PersistRequestBean's for this transaction.
*/
- public List> getListenerNotify() {
+ public List> listenerNotify() {
return listenerNotify;
}
- public TransactionEventTable getEventTables() {
+ public TransactionEventTable eventTables() {
return eventTables;
}
@@ -129,7 +129,7 @@ public final class TransactionEvent implements Serializable {
* Add any relevant PersistRequestBean's to DocStoreUpdates for later processing.
*/
public void addDocStoreUpdates(DocStoreUpdates docStoreUpdates) {
- List> requests = getListenerNotify();
+ List> requests = listenerNotify();
if (requests != null) {
for (PersistRequestBean> persistRequestBean : requests) {
persistRequestBean.addDocStoreUpdates(docStoreUpdates);
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/core/AbstractSqlQueryRequest.java b/ebean-core/src/main/java/io/ebeaninternal/server/core/AbstractSqlQueryRequest.java
index b4a0c5b20..685232dec 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/core/AbstractSqlQueryRequest.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/core/AbstractSqlQueryRequest.java
@@ -136,7 +136,7 @@ public abstract class AbstractSqlQueryRequest implements CancelableQuery {
try {
query.checkCancelled();
prepareSql();
- Connection conn = transaction.getInternalConnection();
+ Connection conn = transaction.internalConnection();
pstmt = conn.prepareStatement(sql);
if (query.getTimeout() > 0) {
pstmt.setQueryTimeout(query.getTimeout());
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/core/DefaultBeanLoader.java b/ebean-core/src/main/java/io/ebeaninternal/server/core/DefaultBeanLoader.java
index 871a5b982..a421044b0 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/core/DefaultBeanLoader.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/core/DefaultBeanLoader.java
@@ -137,7 +137,7 @@ final class DefaultBeanLoader {
private List> executeQuery(LoadRequest loadRequest, SpiQuery> query) {
if (onIterateUseExtraTxn && loadRequest.isParentFindIterate()) {
// MySql - we need a different transaction to execute the secondary query
- SpiTransaction extraTxn = server.createReadOnlyTransaction(query.getTenantId());
+ SpiTransaction extraTxn = server.createReadOnlyTransaction(query.tenantId());
try {
return server.findList(query, extraTxn);
} finally {
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/core/DefaultCallableSql.java b/ebean-core/src/main/java/io/ebeaninternal/server/core/DefaultCallableSql.java
index 50807aa64..27314c977 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/core/DefaultCallableSql.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/core/DefaultCallableSql.java
@@ -87,8 +87,8 @@ final class DefaultCallableSql implements Serializable, SpiCallableSql {
@Override
public Object getObject(int position) {
- Param p = bindParameters.getParameter(position);
- return p.getOutValue();
+ Param p = bindParameters.parameter(position);
+ return p.outValue();
}
@Override
@@ -108,12 +108,12 @@ final class DefaultCallableSql implements Serializable, SpiCallableSql {
* transaction after the transaction is committed.
*/
@Override
- public TransactionEventTable getTransactionEventTable() {
+ public TransactionEventTable transactionEventTable() {
return transactionEvent;
}
@Override
- public BindParams getBindParams() {
+ public BindParams bindParams() {
return bindParameters;
}
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/core/DefaultServer.java b/ebean-core/src/main/java/io/ebeaninternal/server/core/DefaultServer.java
index 7357721d8..8841349f4 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/core/DefaultServer.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/core/DefaultServer.java
@@ -611,7 +611,7 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
PersistenceContext pc = null;
SpiTransaction t = transactionManager.active();
if (t != null) {
- pc = t.getPersistenceContext();
+ pc = t.persistenceContext();
Object existing = desc.contextGet(pc, id);
if (existing != null) {
return (T) existing;
@@ -904,7 +904,7 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
@Override
public SpiResultSet findResultSet(SpiQuery> ormQuery, SpiTransaction transaction) {
- SpiOrmQueryRequest> request = createQueryRequest(ormQuery.getType(), ormQuery, transaction);
+ SpiOrmQueryRequest> request = createQueryRequest(ormQuery.type(), ormQuery, transaction);
request.initTransIfRequired();
return request.findResultSet();
}
@@ -965,12 +965,12 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
}
query.selectAllForLazyLoadProperty();
}
- ProfileLocation profileLocation = query.getProfileLocation();
+ ProfileLocation profileLocation = query.profileLocation();
if (profileLocation != null) {
profileLocation.obtain();
}
// if determine cost and no origin for AutoTune
- if (query.getParentNode() == null) {
+ if (query.parentNode() == null) {
query.setOrigin(createCallOrigin());
}
return new OrmQueryRequest<>(this, queryEngine, query, (SpiTransaction) transaction);
@@ -986,12 +986,12 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
if (t == null) {
t = currentServerTransaction();
}
- BeanDescriptor desc = query.getBeanDescriptor();
+ BeanDescriptor desc = query.descriptor();
id = desc.convertId(id);
PersistenceContext pc = null;
if (t != null && useTransactionPersistenceContext(query)) {
// first look in the transaction scoped persistence context
- pc = t.getPersistenceContext();
+ pc = t.persistenceContext();
if (pc != null) {
WithOption o = desc.contextGetWithOption(pc, id);
if (o != null) {
@@ -1022,7 +1022,7 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
*/
@Override
public PersistenceContextScope persistenceContextScope(SpiQuery> query) {
- PersistenceContextScope scope = query.getPersistenceContextScope();
+ PersistenceContextScope scope = query.persistenceContextScope();
return (scope != null) ? scope : defaultPersistenceContextScope;
}
@@ -1031,7 +1031,7 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
private T findId(Query query, @Nullable Transaction transaction) {
SpiQuery spiQuery = (SpiQuery) query;
spiQuery.setType(Type.BEAN);
- if (SpiQuery.Mode.NORMAL == spiQuery.getMode() && !spiQuery.isForceHitDatabase()) {
+ if (SpiQuery.Mode.NORMAL == spiQuery.mode() && !spiQuery.isForceHitDatabase()) {
// See if we can skip doing the fetch completely by getting the bean from the
// persistence context or the bean cache
T bean = findIdCheckPersistenceContextAndCache(transaction, spiQuery, spiQuery.getId());
@@ -2158,7 +2158,7 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
@Override
public void slowQueryCheck(long timeMicros, int rowCount, SpiQuery> query) {
if (timeMicros > slowQueryMicros && slowQueryListener != null) {
- slowQueryListener.process(new SlowQueryEvent(query.getGeneratedSql(), timeMicros / 1000L, rowCount, query.getParentNode()));
+ slowQueryListener.process(new SlowQueryEvent(query.getGeneratedSql(), timeMicros / 1000L, rowCount, query.parentNode()));
}
}
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/core/DefaultSqlUpdate.java b/ebean-core/src/main/java/io/ebeaninternal/server/core/DefaultSqlUpdate.java
index d9023b356..98f7cba58 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/core/DefaultSqlUpdate.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/core/DefaultSqlUpdate.java
@@ -246,7 +246,7 @@ public final class DefaultSqlUpdate implements Serializable, SpiSqlUpdate {
}
@Override
- public String getBaseSql() {
+ public String baseSql() {
return baseSql;
}
@@ -342,7 +342,7 @@ public final class DefaultSqlUpdate implements Serializable, SpiSqlUpdate {
* Return the bind parameters.
*/
@Override
- public BindParams getBindParams() {
+ public BindParams bindParams() {
return bindParams;
}
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/core/DtoQueryRequest.java b/ebean-core/src/main/java/io/ebeaninternal/server/core/DtoQueryRequest.java
index 58c5dae77..5ca74e9f9 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/core/DtoQueryRequest.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/core/DtoQueryRequest.java
@@ -33,7 +33,7 @@ public final class DtoQueryRequest extends AbstractSqlQueryRequest {
private DataReader dataReader;
DtoQueryRequest(SpiEbeanServer server, DtoQueryEngine engine, SpiDtoQuery query) {
- super(server, query, query.getTransaction());
+ super(server, query, query.transaction());
this.queryEngine = engine;
this.query = query;
query.obtainLocation();
@@ -45,7 +45,7 @@ public final class DtoQueryRequest extends AbstractSqlQueryRequest {
@Override
public void executeSql(Binder binder, SpiQuery.Type type) throws SQLException {
startNano = System.nanoTime();
- SpiQuery> ormQuery = query.getOrmQuery();
+ SpiQuery> ormQuery = query.ormQuery();
if (ormQuery != null) {
ormQuery.setType(type);
ormQuery.setManualId();
@@ -55,7 +55,7 @@ public final class DtoQueryRequest extends AbstractSqlQueryRequest {
SpiResultSet result = server.findResultSet(ormQuery, transaction);
this.pstmt = result.getStatement();
this.sql = ormQuery.getGeneratedSql();
- setResultSet(result.getResultSet(), ormQuery.getQueryPlanKey());
+ setResultSet(result.getResultSet(), ormQuery.queryPlanKey());
} else {
// native SQL query execution
@@ -74,7 +74,7 @@ public final class DtoQueryRequest extends AbstractSqlQueryRequest {
if (planKey == null) {
planKey = query.planKey();
}
- plan = query.getQueryPlan(planKey);
+ plan = query.queryPlan(planKey);
if (plan == null) {
plan = query.buildPlan(mappingRequest());
query.putQueryPlan(planKey, plan);
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/core/OrmQueryRequest.java b/ebean-core/src/main/java/io/ebeaninternal/server/core/OrmQueryRequest.java
index 6f0930523..3f0d2ea37 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/core/OrmQueryRequest.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/core/OrmQueryRequest.java
@@ -48,12 +48,12 @@ public final class OrmQueryRequest extends BeanRequest implements SpiOrmQuery
public OrmQueryRequest(SpiEbeanServer server, OrmQueryEngine queryEngine, SpiQuery query, SpiTransaction t) {
super(server, t);
- this.beanDescriptor = query.getBeanDescriptor();
+ this.beanDescriptor = query.descriptor();
this.finder = beanDescriptor.beanFinder();
this.queryEngine = queryEngine;
this.query = query;
this.readOnly = query.isReadOnly();
- this.persistenceContext = query.getPersistenceContext();
+ this.persistenceContext = query.persistenceContext();
}
public PersistenceException translate(String bindLog, String sql, SQLException e) {
@@ -188,7 +188,7 @@ public final class OrmQueryRequest extends BeanRequest implements SpiOrmQuery
public DeployParser createDeployParser() {
if (query.isRawSql()) {
- return new DeployPropertyParserMap(query.getRawSql().getColumnMapping().getMapping());
+ return new DeployPropertyParserMap(query.rawSql().getColumnMapping().getMapping());
} else {
return beanDescriptor.parser();
}
@@ -214,22 +214,22 @@ public final class OrmQueryRequest extends BeanRequest implements SpiOrmQuery
public void initTransIfRequired() {
// first check if the query requires its own transaction
if (transaction == null) {
- if (query.getType().isUpdate()) {
+ if (query.type().isUpdate()) {
// bulk update or delete query
transaction = server.beginServerTransaction();
} else {
// create an implicit transaction to execute this query
// potentially using read-only DataSource with autoCommit
- transaction = server.createReadOnlyTransaction(query.getTenantId());
+ transaction = server.createReadOnlyTransaction(query.tenantId());
}
createdTransaction = true;
}
persistenceContext = persistenceContext(query, transaction);
- if (Type.ITERATE == query.getType()) {
+ if (Type.ITERATE == query.type()) {
persistenceContext.beginIterate();
}
loadContext = new DLoadContext(this, secondaryQueries);
- loadContext.useReferences(Type.ITERATE == query.getType());
+ loadContext.useReferences(Type.ITERATE == query.type());
}
/**
@@ -237,7 +237,7 @@ public final class OrmQueryRequest extends BeanRequest implements SpiOrmQuery
*/
@Override
public void rollbackTransIfRequired() {
- if (Type.ITERATE == query.getType()) {
+ if (Type.ITERATE == query.type()) {
persistenceContext.endIterate();
}
if (createdTransaction) {
@@ -258,7 +258,7 @@ public final class OrmQueryRequest extends BeanRequest implements SpiOrmQuery
@Override
public JsonReadOptions createJsonReadOptions() {
persistenceContext = persistenceContext(query, transaction);
- if (query.getPersistenceContext() == null) {
+ if (query.persistenceContext() == null) {
query.setPersistenceContext(persistenceContext);
}
JsonReadOptions jsonRead = new JsonReadOptions();
@@ -277,7 +277,7 @@ public final class OrmQueryRequest extends BeanRequest implements SpiOrmQuery
private PersistenceContext persistenceContext(SpiQuery> query, SpiTransaction t) {
// check if there is already a persistence context set which is the case
// when lazy loading or query joins are executed
- PersistenceContext ctx = query.getPersistenceContext();
+ PersistenceContext ctx = query.persistenceContext();
if (ctx != null) return ctx;
// determine the scope (from the query and then server)
@@ -285,7 +285,7 @@ public final class OrmQueryRequest extends BeanRequest implements SpiOrmQuery
if (scope == PersistenceContextScope.QUERY || t == null) {
return new DefaultPersistenceContext();
}
- return t.getPersistenceContext();
+ return t.persistenceContext();
}
/**
@@ -295,12 +295,12 @@ public final class OrmQueryRequest extends BeanRequest implements SpiOrmQuery
*/
@Override
public void endTransIfRequired() {
- if (Type.ITERATE == query.getType()) {
+ if (Type.ITERATE == query.type()) {
persistenceContext.endIterate();
}
if (createdTransaction && transaction.isActive()) {
transaction.commit();
- if (query.getType().isUpdate()) {
+ if (query.type().isUpdate()) {
// for implicit update/delete queries clear the thread local
server.clearServerTransaction();
}
@@ -311,14 +311,14 @@ public final class OrmQueryRequest extends BeanRequest implements SpiOrmQuery
* Return true if this is a find by id (rather than List Set or Map).
*/
public boolean isFindById() {
- return query.getType() == Type.BEAN;
+ return query.type() == Type.BEAN;
}
/**
* Return true if this is a findEach, findIterate type query where we expect many results.
*/
public boolean isFindIterate() {
- return query.getType() == Type.ITERATE;
+ return query.type() == Type.ITERATE;
}
@Override
@@ -421,7 +421,7 @@ public final class OrmQueryRequest extends BeanRequest implements SpiOrmQuery
@Override
@SuppressWarnings("unchecked")
public Map findMap() {
- String mapKey = query.getMapKey();
+ String mapKey = query.mapKey();
if (mapKey == null) {
BeanProperty idProp = beanDescriptor.idProperty();
if (idProp != null) {
@@ -497,7 +497,7 @@ public final class OrmQueryRequest extends BeanRequest implements SpiOrmQuery
}
public boolean isQueryCachePut() {
- return cacheKey != null && query.getUseQueryCache().isPut();
+ return cacheKey != null && query.queryCacheMode().isPut();
}
public boolean isBeanCachePutMany() {
@@ -513,7 +513,7 @@ public final class OrmQueryRequest extends BeanRequest implements SpiOrmQuery
*/
public void mergeCacheHits(BeanCollection result) {
if (cacheBeans != null && !cacheBeans.isEmpty()) {
- if (query.getType() == Type.MAP) {
+ if (query.type() == Type.MAP) {
mergeCacheHitsToMap(result);
} else {
mergeCacheHitsToCollection(result);
@@ -572,7 +572,7 @@ public final class OrmQueryRequest extends BeanRequest implements SpiOrmQuery
}
private ElPropertyValue mapProperty() {
- final String key = query.getMapKey();
+ final String key = query.mapKey();
final ElPropertyValue property = key == null ? beanDescriptor.idProperty() : beanDescriptor.elGetValue(key);
if (property == null) {
throw new IllegalStateException("Unknown map key property " + key);
@@ -631,14 +631,14 @@ public final class OrmQueryRequest extends BeanRequest implements SpiOrmQuery
@Override
@SuppressWarnings("unchecked")
public Object getFromQueryCache() {
- if (query.getUseQueryCache() == CacheMode.OFF
+ if (query.queryCacheMode() == CacheMode.OFF
|| (transaction != null && transaction.isSkipCache())
|| server.isDisableL2Cache()) {
return null;
} else {
cacheKey = query.queryHash();
}
- if (!query.getUseQueryCache().isGet()) {
+ if (!query.queryCacheMode().isGet()) {
return null;
}
@@ -674,7 +674,7 @@ public final class OrmQueryRequest extends BeanRequest implements SpiOrmQuery
* it in read auditing. Return false for row count and find ids queries.
*/
private boolean readAuditQueryType() {
- Type type = query.getType();
+ Type type = query.type();
switch (type) {
case BEAN:
case ITERATE:
@@ -688,7 +688,7 @@ public final class OrmQueryRequest extends BeanRequest implements SpiOrmQuery
}
public void putToQueryCache(Object result) {
- beanDescriptor.queryCachePut(cacheKey, new QueryCacheEntry(result, dependentTables, transaction.getStartNanoTime()));
+ beanDescriptor.queryCachePut(cacheKey, new QueryCacheEntry(result, dependentTables, transaction.startNanoTime()));
}
/**
@@ -709,7 +709,7 @@ public final class OrmQueryRequest extends BeanRequest implements SpiOrmQuery
* Return the batch size for lazy loading on this bean query request.
*/
public int lazyLoadBatchSize() {
- int batchSize = query.getLazyLoadBatchSize();
+ int batchSize = query.lazyLoadBatchSize();
return (batchSize > 0) ? batchSize : server.lazyLoadBatchSize();
}
@@ -740,7 +740,7 @@ public final class OrmQueryRequest extends BeanRequest implements SpiOrmQuery
* Return the tenantId associated with this request.
*/
public Object tenantId() {
- return (transaction == null) ? null : transaction.getTenantId();
+ return (transaction == null) ? null : transaction.tenantId();
}
/**
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/core/PersistRequest.java b/ebean-core/src/main/java/io/ebeaninternal/server/core/PersistRequest.java
index 3d30f70b3..315fb5484 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/core/PersistRequest.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/core/PersistRequest.java
@@ -126,7 +126,7 @@ public abstract class PersistRequest extends BeanRequest implements BatchPostExe
boolean batch = isBatchThisRequest();
try {
int rows;
- BatchControl control = transaction.getBatchControl();
+ BatchControl control = transaction.batchControl();
if (control != null) {
rows = control.executeStatementOrBatch(this, batch, addBatch);
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/core/PersistRequestBean.java b/ebean-core/src/main/java/io/ebeaninternal/server/core/PersistRequestBean.java
index f9b08aa5f..f4a41c25d 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/core/PersistRequestBean.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/core/PersistRequestBean.java
@@ -192,7 +192,7 @@ public final class PersistRequestBean extends PersistRequest implements BeanP
* don't want to send to the doc store.
*/
private DocStoreMode calcDocStoreMode(SpiTransaction txn, Type type) {
- DocStoreMode txnMode = (txn == null) ? null : txn.getDocStoreMode();
+ DocStoreMode txnMode = (txn == null) ? null : txn.docStoreMode();
return beanDescriptor.docStoreMode(type, txnMode);
}
@@ -750,7 +750,7 @@ public final class PersistRequestBean extends PersistRequest implements BeanP
public int executeOrQueue() {
boolean batch = isBatchThisRequest();
try {
- BatchControl control = transaction.getBatchControl();
+ BatchControl control = transaction.batchControl();
if (control != null) {
return control.executeOrQueue(this, batch);
}
@@ -821,7 +821,7 @@ public final class PersistRequestBean extends PersistRequest implements BeanP
*/
private void postUpdate() {
if (statelessUpdate) {
- beanDescriptor.contextClear(transaction.getPersistenceContext(), idValue);
+ beanDescriptor.contextClear(transaction.persistenceContext(), idValue);
}
}
@@ -836,14 +836,14 @@ public final class PersistRequestBean extends PersistRequest implements BeanP
*/
public void removeFromPersistenceContext() {
idValue = beanDescriptor.getId(entityBean);
- beanDescriptor.contextDeleted(transaction.getPersistenceContext(), idValue);
+ beanDescriptor.contextDeleted(transaction.persistenceContext(), idValue);
}
/**
* Aggressive L1 and L2 cache cleanup for deletes.
*/
private void postDelete() {
- beanDescriptor.contextClear(transaction.getPersistenceContext(), idValue);
+ beanDescriptor.contextClear(transaction.persistenceContext(), idValue);
}
private void changeLog() {
@@ -952,7 +952,7 @@ public final class PersistRequestBean extends PersistRequest implements BeanP
* Add the request to TransactionEvent if there are post commit listeners.
*/
private void addPostCommitListeners() {
- TransactionEvent event = transaction.getEvent();
+ TransactionEvent event = transaction.event();
if (event != null && isNotifyListeners()) {
event.addListenerNotify(this);
}
@@ -984,7 +984,7 @@ public final class PersistRequestBean extends PersistRequest implements BeanP
}
if (transaction.isAutoPersistUpdates() && idValue != null) {
// with getGeneratedKeys off we will not have a idValue
- beanDescriptor.contextPut(transaction.getPersistenceContext(), idValue, entityBean);
+ beanDescriptor.contextPut(transaction.persistenceContext(), idValue, entityBean);
}
}
@@ -1057,7 +1057,7 @@ public final class PersistRequestBean extends PersistRequest implements BeanP
postExecute = true;
if (notifyCache && complete) {
// add cache notification (on batch persist)
- TransactionEvent event = transaction.getEvent();
+ TransactionEvent event = transaction.event();
if (event != null) {
notifyCache(event.obtainCacheChangeSet());
}
@@ -1071,7 +1071,7 @@ public final class PersistRequestBean extends PersistRequest implements BeanP
complete = true;
if (notifyCache && postExecute) {
// add cache notification (on non-batch persist)
- TransactionEvent event = transaction.getEvent();
+ TransactionEvent event = transaction.event();
if (event != null) {
notifyCache(event.obtainCacheChangeSet());
}
@@ -1187,7 +1187,7 @@ public final class PersistRequestBean extends PersistRequest implements BeanP
}
private void setTenantId() {
- Object tenantId = transaction.getTenantId();
+ Object tenantId = transaction.tenantId();
if (tenantId != null) {
beanDescriptor.setTenantId(entityBean, tenantId);
}
@@ -1242,13 +1242,13 @@ public final class PersistRequestBean extends PersistRequest implements BeanP
// processing now so set IGNORE (unlike DB + DocStore processing with post-commit)
docStoreMode = DocStoreMode.IGNORE;
try {
- docStoreUpdate(transaction.getDocStoreTransaction().obtain());
+ docStoreUpdate(transaction.docStoreTransaction().obtain());
postExecute();
if (type == Type.UPDATE
&& beanDescriptor.isDocStoreEmbeddedInvalidation()
&& transaction.isPersistCascade()) {
// queue embedded/nested updates for later processing
- beanDescriptor.docStoreUpdateEmbedded(this, transaction.getDocStoreTransaction().queue());
+ beanDescriptor.docStoreUpdateEmbedded(this, transaction.docStoreTransaction().queue());
}
} catch (IOException e) {
throw new PersistenceException("Error persisting doc store bean", e);
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/core/PersistRequestCallableSql.java b/ebean-core/src/main/java/io/ebeaninternal/server/core/PersistRequestCallableSql.java
index 217bb0e5c..52ae6c933 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/core/PersistRequestCallableSql.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/core/PersistRequestCallableSql.java
@@ -86,9 +86,9 @@ public final class PersistRequestCallableSql extends PersistRequest {
}
// register table modifications with the transaction event
- TransactionEventTable tableEvents = callableSql.getTransactionEventTable();
+ TransactionEventTable tableEvents = callableSql.transactionEventTable();
if (tableEvents != null && !tableEvents.isEmpty()) {
- transaction.getEvent().add(tableEvents);
+ transaction.event().add(tableEvents);
} else {
transaction.markNotQueryOnly();
}
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/core/PersistRequestOrmUpdate.java b/ebean-core/src/main/java/io/ebeaninternal/server/core/PersistRequestOrmUpdate.java
index 7707be1db..03aa874f8 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/core/PersistRequestOrmUpdate.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/core/PersistRequestOrmUpdate.java
@@ -19,7 +19,7 @@ public final class PersistRequestOrmUpdate extends PersistRequest {
private String bindLog;
public PersistRequestOrmUpdate(SpiEbeanServer server, BeanManager> mgr, SpiUpdate> ormUpdate, SpiTransaction t, PersistExecute persistExecute) {
- super(server, t, persistExecute, ormUpdate.getLabel());
+ super(server, t, persistExecute, ormUpdate.label());
this.beanDescriptor = mgr.getBeanDescriptor();
this.ormUpdate = ormUpdate;
}
@@ -80,8 +80,8 @@ public final class PersistRequestOrmUpdate extends PersistRequest {
if (startNanos > 0) {
persistExecute.collectOrmUpdate(label, startNanos);
}
- OrmUpdateType ormUpdateType = ormUpdate.getOrmUpdateType();
- String tableName = ormUpdate.getBaseTable();
+ OrmUpdateType ormUpdateType = ormUpdate.ormUpdateType();
+ String tableName = ormUpdate.baseTable();
if (transaction.isLogSummary()) {
transaction.logSummary("{0} table[{1}] rows[{2}] bind[{3}]", ormUpdateType, tableName, rowCount, bindLog);
}
@@ -90,13 +90,13 @@ public final class PersistRequestOrmUpdate extends PersistRequest {
// this is used to invalidate cached objects etc
switch (ormUpdateType) {
case INSERT:
- transaction.getEvent().add(tableName, true, false, false);
+ transaction.event().add(tableName, true, false, false);
break;
case UPDATE:
- transaction.getEvent().add(tableName, false, true, false);
+ transaction.event().add(tableName, false, true, false);
break;
case DELETE:
- transaction.getEvent().add(tableName, false, false, true);
+ transaction.event().add(tableName, false, false, true);
break;
default:
break;
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/core/PersistRequestUpdateSql.java b/ebean-core/src/main/java/io/ebeaninternal/server/core/PersistRequestUpdateSql.java
index f0b5f31fa..e4f0c023f 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/core/PersistRequestUpdateSql.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/core/PersistRequestUpdateSql.java
@@ -65,7 +65,7 @@ public final class PersistRequestUpdateSql extends PersistRequest {
* Add this request to BatchControl to flush later.
*/
public void addToFlushQueue(int pos) {
- BatchControl control = transaction.getBatchControl();
+ BatchControl control = transaction.batchControl();
if (control == null) {
control = persistExecute.createBatchControl(transaction);
}
@@ -167,13 +167,13 @@ public final class PersistRequestUpdateSql extends PersistRequest {
// this is used to invalidate cached objects etc
switch (sqlType) {
case SQL_INSERT:
- transaction.getEvent().add(tableName, true, false, false);
+ transaction.event().add(tableName, true, false, false);
break;
case SQL_UPDATE:
- transaction.getEvent().add(tableName, false, true, false);
+ transaction.event().add(tableName, false, true, false);
break;
case SQL_DELETE:
- transaction.getEvent().add(tableName, false, false, true);
+ transaction.event().add(tableName, false, false, true);
break;
case SQL_UNKNOWN:
transaction.markNotQueryOnly();
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/deploy/BeanCollectionHelpFactory.java b/ebean-core/src/main/java/io/ebeaninternal/server/deploy/BeanCollectionHelpFactory.java
index d1aae9fb2..a2b0480db 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/deploy/BeanCollectionHelpFactory.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/deploy/BeanCollectionHelpFactory.java
@@ -48,7 +48,7 @@ public final class BeanCollectionHelpFactory {
} else if (manyType == SpiQuery.Type.MAP) {
BeanDescriptor target = request.descriptor();
- ElPropertyValue elProperty = target.elGetValue(request.query().getMapKey());
+ ElPropertyValue elProperty = target.elGetValue(request.query().mapKey());
return new BeanMapQueryHelp<>(elProperty);
} else {
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/deploy/BeanDescriptor.java b/ebean-core/src/main/java/io/ebeaninternal/server/deploy/BeanDescriptor.java
index 15d05881d..c34a79a70 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/deploy/BeanDescriptor.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/deploy/BeanDescriptor.java
@@ -1618,7 +1618,7 @@ public class BeanDescriptor implements BeanType, STreeType, SpiBeanType {
* Return the many property included in the query or null if one is not.
*/
public BeanPropertyAssocMany> manyProperty(SpiQuery> query) {
- OrmQueryDetail detail = query.getDetail();
+ OrmQueryDetail detail = query.detail();
for (BeanPropertyAssocMany> many : propertiesMany) {
if (detail.includesPath(many.name())) {
return many;
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/deploy/BeanDescriptorCacheHelp.java b/ebean-core/src/main/java/io/ebeaninternal/server/deploy/BeanDescriptorCacheHelp.java
index 7d3e64eb3..79a20ce12 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/deploy/BeanDescriptorCacheHelp.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/deploy/BeanDescriptorCacheHelp.java
@@ -755,7 +755,7 @@ final class BeanDescriptorCacheHelp {
void cacheUpdateQuery(boolean update, SpiTransaction transaction) {
if (invalidateQueryCache || cacheNotifyOnAll || (!update && cacheNotifyOnDelete)) {
- transaction.getEvent().add(desc.baseTable(), false, update, !update);
+ transaction.event().add(desc.baseTable(), false, update, !update);
}
}
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/deploy/BeanPropertyAssocMany.java b/ebean-core/src/main/java/io/ebeaninternal/server/deploy/BeanPropertyAssocMany.java
index a6c861e40..1ce1e7f2d 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/deploy/BeanPropertyAssocMany.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/deploy/BeanPropertyAssocMany.java
@@ -421,11 +421,11 @@ public class BeanPropertyAssocMany extends BeanPropertyAssoc implements ST
if (hasJoinTable()) {
sb.append(query.isAsDraft() ? intersectionDraftTable : intersectionPublishTable);
} else {
- sb.append(targetDescriptor.baseTable(query.getTemporalMode()));
+ sb.append(targetDescriptor.baseTable(query.temporalMode()));
}
if (needsX2Table && hasJoinTable()) {
sb.append(" x join ");
- sb.append(targetDescriptor.baseTable(query.getTemporalMode()));
+ sb.append(targetDescriptor.baseTable(query.temporalMode()));
sb.append(" x2 on ");
inverseJoin.addJoin("x2", "x", sb);
} else {
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/dto/DtoMappingRequest.java b/ebean-core/src/main/java/io/ebeaninternal/server/dto/DtoMappingRequest.java
index 7f5e6126b..60e3fdf1c 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/dto/DtoMappingRequest.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/dto/DtoMappingRequest.java
@@ -18,9 +18,9 @@ public final class DtoMappingRequest {
private final DtoColumn[] columnMeta;
public DtoMappingRequest(SpiDtoQuery query, String sql, DtoColumn[] columnMeta) {
- this.type = query.getType();
- this.label = query.getPlanLabel();
- this.profileLocation = query.getProfileLocation();
+ this.type = query.type();
+ this.label = query.planLabel();
+ this.profileLocation = query.profileLocation();
this.sql = sql;
this.relaxedMode = query.isRelaxedMode();
this.columnMeta = columnMeta;
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/expression/DefaultExpressionList.java b/ebean-core/src/main/java/io/ebeaninternal/server/expression/DefaultExpressionList.java
index 2898b50eb..83419a22f 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/expression/DefaultExpressionList.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/expression/DefaultExpressionList.java
@@ -558,12 +558,12 @@ public class DefaultExpressionList implements SpiExpressionList {
@Override
public ExpressionList addAll(ExpressionList exprList) {
SpiExpressionList spiList = (SpiExpressionList) exprList;
- list.addAll(spiList.getUnderlyingList());
+ list.addAll(spiList.underlyingList());
return this;
}
@Override
- public List getUnderlyingList() {
+ public List underlyingList() {
return list;
}
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/expression/FilterExpressionList.java b/ebean-core/src/main/java/io/ebeaninternal/server/expression/FilterExpressionList.java
index d58a6fdfe..f9956f106 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/expression/FilterExpressionList.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/expression/FilterExpressionList.java
@@ -21,7 +21,7 @@ public final class FilterExpressionList extends DefaultExpressionList {
private String orderByClause;
public FilterExpressionList(FilterExprPath pathPrefix, FilterExpressionList original) {
- super(null, original.expr, null, original.getUnderlyingList());
+ super(null, original.expr, null, original.underlyingList());
this.pathPrefix = pathPrefix;
this.rootQuery = original.rootQuery;
}
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/expression/PrepareDocNested.java b/ebean-core/src/main/java/io/ebeaninternal/server/expression/PrepareDocNested.java
index 8f1f48d38..2a73d64b3 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/expression/PrepareDocNested.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/expression/PrepareDocNested.java
@@ -50,7 +50,7 @@ final class PrepareDocNested {
this.type = type;
this.beanDescriptor = beanDescriptor;
this.original = original;
- this.origUnderlying = original.getUnderlyingList();
+ this.origUnderlying = original.underlyingList();
this.origSize = origUnderlying.size();
}
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/loadcontext/DLoadBaseContext.java b/ebean-core/src/main/java/io/ebeaninternal/server/loadcontext/DLoadBaseContext.java
index 0b767b71f..ca49bdcb3 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/loadcontext/DLoadBaseContext.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/loadcontext/DLoadBaseContext.java
@@ -52,7 +52,7 @@ abstract class DLoadBaseContext {
void setLabel(SpiQuery> query) {
String label = parent.planLabel();
if (label != null) {
- query.setProfilePath(label, fullPath + "(" + query.getLoadMode() + ")", parent.profileLocation());
+ query.setProfilePath(label, fullPath + "(" + query.loadMode() + ")", parent.profileLocation());
}
}
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/loadcontext/DLoadContext.java b/ebean-core/src/main/java/io/ebeaninternal/server/loadcontext/DLoadContext.java
index b8ac78b84..14d486325 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/loadcontext/DLoadContext.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/loadcontext/DLoadContext.java
@@ -89,16 +89,16 @@ public final class DLoadContext implements LoadContext {
this.useDocStore = query.isUseDocStore();
this.asOf = query.getAsOf();
this.asDraft = query.isAsDraft();
- this.includeSoftDeletes = query.isIncludeSoftDeletes() && query.getMode() == SpiQuery.Mode.NORMAL;
+ this.includeSoftDeletes = query.isIncludeSoftDeletes() && query.mode() == SpiQuery.Mode.NORMAL;
this.readOnly = query.isReadOnly();
this.disableReadAudit = query.isDisableReadAudit();
this.disableLazyLoading = query.isDisableLazyLoading();
- this.useBeanCache = query.getUseBeanCache();
- this.profilingListener = query.getProfilingListener();
- this.planLabel = query.getPlanLabel();
- this.profileLocation = query.getProfileLocation();
+ this.useBeanCache = query.beanCacheMode();
+ this.profilingListener = query.profilingListener();
+ this.planLabel = query.planLabel();
+ this.profileLocation = query.profileLocation();
- ObjectGraphNode parentNode = query.getParentNode();
+ ObjectGraphNode parentNode = query.parentNode();
if (parentNode != null) {
this.origin = parentNode.origin();
this.relativePath = parentNode.path();
@@ -129,13 +129,13 @@ public final class DLoadContext implements LoadContext {
* Register the +query and +lazy secondary queries with their appropriate LoadBeanContext or LoadManyContext.
*/
private void registerSecondaryQueries(SpiQuerySecondary secondaryQueries) {
- this.secQuery = secondaryQueries.getQueryJoins();
+ this.secQuery = secondaryQueries.queryJoins();
if (secQuery != null) {
for (OrmQueryProperties pathProperties : secQuery) {
registerSecondaryQuery(pathProperties);
}
}
- List lazyJoins = secondaryQueries.getLazyJoins();
+ List lazyJoins = secondaryQueries.lazyJoins();
if (lazyJoins != null) {
for (OrmQueryProperties lazyJoin : lazyJoins) {
registerSecondaryQuery(lazyJoin);
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/persist/Binder.java b/ebean-core/src/main/java/io/ebeaninternal/server/persist/Binder.java
index c63f32674..7edcc3f22 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/persist/Binder.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/persist/Binder.java
@@ -105,13 +105,13 @@ public final class Binder {
for (BindParams.Param param : list) {
if (param.isOutParam() && cstmt != null) {
- cstmt.registerOutParameter(dataBind.nextPos(), param.getType());
+ cstmt.registerOutParameter(dataBind.nextPos(), param.type());
if (param.isInParam()) {
dataBind.decrementPos();
}
}
if (param.isInParam()) {
- value = param.getInValue();
+ value = param.inValue();
if (bindLog != null) {
if (bindLog.length() > 0) {
bindLog.append(", ");
@@ -128,7 +128,7 @@ public final class Binder {
}
} else if (value == null) {
// this doesn't work for query predicates
- bindObject(dataBind, null, param.getType());
+ bindObject(dataBind, null, param.type());
} else {
bindObject(dataBind, value);
}
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/persist/DefaultPersister.java b/ebean-core/src/main/java/io/ebeaninternal/server/persist/DefaultPersister.java
index 24a5e4f1c..3d54c0167 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/persist/DefaultPersister.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/persist/DefaultPersister.java
@@ -72,7 +72,7 @@ public final class DefaultPersister implements Persister {
@Override
public int executeOrmUpdate(Update> update, Transaction t) {
SpiUpdate> ormUpdate = (SpiUpdate>) update;
- BeanManager> mgr = beanManager(ormUpdate.getBeanType());
+ BeanManager> mgr = beanManager(ormUpdate.beanType());
return executeOrQueue(new PersistRequestOrmUpdate(server, mgr, ormUpdate, (SpiTransaction) t, persistExecute));
}
@@ -97,7 +97,7 @@ public final class DefaultPersister implements Persister {
@Override
public int[] executeBatch(SpiSqlUpdate sqlUpdate, SpiTransaction transaction) {
- BatchControl batchControl = transaction.getBatchControl();
+ BatchControl batchControl = transaction.batchControl();
try {
return batchControl.execute(sqlUpdate.getGeneratedSql(), sqlUpdate.isGetGeneratedKeys());
} catch (SQLException e) {
@@ -761,14 +761,14 @@ public final class DefaultPersister implements Persister {
notifyDeleteById(descriptor, id, idList, transaction);
deleteById.setAutoTableMod(false);
if (idList != null) {
- t.getEvent().addDeleteByIdList(descriptor, idList);
+ t.event().addDeleteByIdList(descriptor, idList);
} else {
- t.getEvent().addDeleteById(descriptor, id);
+ t.event().addDeleteById(descriptor, id);
}
int rows = executeSqlUpdate(deleteById, t);
// Delete from the persistence context so that it can't be fetched again later
- PersistenceContext persistenceContext = t.getPersistenceContext();
+ PersistenceContext persistenceContext = t.persistenceContext();
if (idList != null) {
for (Object idValue : idList) {
descriptor.contextDeleted(persistenceContext, idValue);
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/persist/ExeCallableSql.java b/ebean-core/src/main/java/io/ebeaninternal/server/persist/ExeCallableSql.java
index 1849cb811..a39c4b3c0 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/persist/ExeCallableSql.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/persist/ExeCallableSql.java
@@ -60,7 +60,7 @@ final class ExeCallableSql {
SpiTransaction t = request.transaction();
String sql = callableSql.getSql();
- BindParams bindParams = callableSql.getBindParams();
+ BindParams bindParams = callableSql.bindParams();
// process named parameters if required
sql = BindParamsParser.parse(bindParams, sql);
@@ -80,7 +80,7 @@ final class ExeCallableSql {
}
String bindLog = null;
if (!bindParams.isEmpty()) {
- bindLog = binder.bind(bindParams, cstmt, t.getInternalConnection());
+ bindLog = binder.bind(bindParams, cstmt, t.internalConnection());
}
request.setBindLog(bindLog);
// required to read OUT params later
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/persist/ExeOrmUpdate.java b/ebean-core/src/main/java/io/ebeaninternal/server/persist/ExeOrmUpdate.java
index 1725c5242..fb166d49d 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/persist/ExeOrmUpdate.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/persist/ExeOrmUpdate.java
@@ -39,8 +39,8 @@ final class ExeOrmUpdate {
return -1;
} else {
SpiUpdate> ormUpdate = request.ormUpdate();
- if (ormUpdate.getTimeout() > 0) {
- pstmt.setQueryTimeout(ormUpdate.getTimeout());
+ if (ormUpdate.timeout() > 0) {
+ pstmt.setQueryTimeout(ormUpdate.timeout());
}
int rowCount = pstmt.executeUpdate();
request.checkRowCount(rowCount);
@@ -71,11 +71,11 @@ final class ExeOrmUpdate {
SpiUpdate> ormUpdate = request.ormUpdate();
SpiTransaction t = request.transaction();
- String sql = ormUpdate.getUpdateStatement();
+ String sql = ormUpdate.updateStatement();
// convert bean and property names to table and
// column names if required
sql = translate(request, sql);
- BindParams bindParams = ormUpdate.getBindParams();
+ BindParams bindParams = ormUpdate.bindParams();
// process named parameters if required
sql = BindParamsParser.parse(bindParams, sql);
ormUpdate.setGeneratedSql(sql);
@@ -91,7 +91,7 @@ final class ExeOrmUpdate {
}
String bindLog = null;
if (!bindParams.isEmpty()) {
- bindLog = binder.bind(bindParams, pstmt, t.getInternalConnection());
+ bindLog = binder.bind(bindParams, pstmt, t.internalConnection());
}
request.setBindLog(bindLog);
return pstmt;
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/persist/ExeUpdateSql.java b/ebean-core/src/main/java/io/ebeaninternal/server/persist/ExeUpdateSql.java
index 20b20ef71..cd1aad8a2 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/persist/ExeUpdateSql.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/persist/ExeUpdateSql.java
@@ -77,10 +77,10 @@ final class ExeUpdateSql {
SpiSqlUpdate updateSql = request.updateSql();
SpiTransaction t = request.transaction();
- BindParams bindParams = updateSql.getBindParams();
+ BindParams bindParams = updateSql.bindParams();
// process named parameters if required
- String sql = updateSql.getBaseSql();
+ String sql = updateSql.baseSql();
sql = BindParamsParser.parse(bindParams, sql);
parseUpdate(sql, request);
@@ -95,7 +95,7 @@ final class ExeUpdateSql {
}
String bindLog = null;
if (!bindParams.isEmpty()) {
- bindLog = binder.bind(bindParams, pstmt, t.getInternalConnection());
+ bindLog = binder.bind(bindParams, pstmt, t.internalConnection());
}
request.setBindLog(bindLog);
updateSql.setGeneratedSql(sql);
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/persist/PstmtFactory.java b/ebean-core/src/main/java/io/ebeaninternal/server/persist/PstmtFactory.java
index 39f0ead4d..3c8eca4e2 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/persist/PstmtFactory.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/persist/PstmtFactory.java
@@ -21,7 +21,7 @@ final class PstmtFactory {
* Get a callable statement without any batching.
*/
CallableStatement cstmt(SpiTransaction t, String sql) throws SQLException {
- Connection conn = t.getInternalConnection();
+ Connection conn = t.internalConnection();
return conn.prepareCall(sql);
}
@@ -29,7 +29,7 @@ final class PstmtFactory {
* Get a prepared statement without any batching.
*/
PreparedStatement pstmt(SpiTransaction t, String sql, boolean getGeneratedKeys) throws SQLException {
- Connection conn = t.getInternalConnection();
+ Connection conn = t.internalConnection();
if (getGeneratedKeys) {
return conn.prepareStatement(sql, Statement.RETURN_GENERATED_KEYS);
} else {
@@ -41,7 +41,7 @@ final class PstmtFactory {
* Return a prepared statement taking into account batch requirements.
*/
PreparedStatement pstmtBatch(SpiTransaction t, String sql, BatchPostExecute batchExe) throws SQLException {
- BatchedPstmtHolder batch = t.getBatchControl().pstmtHolder();
+ BatchedPstmtHolder batch = t.batchControl().pstmtHolder();
BatchedPstmt existingStmt = batch.batchedPstmt(sql);
if (existingStmt != null) {
if (existingStmt.isEmpty() && t.isLogSql()) {
@@ -52,7 +52,7 @@ final class PstmtFactory {
if (t.isLogSql()) {
t.logSql(TrimLogSql.trim(sql));
}
- Connection conn = t.getInternalConnection();
+ Connection conn = t.internalConnection();
PreparedStatement stmt = conn.prepareStatement(sql);
BatchedPstmt bs = new BatchedPstmt(stmt, false, sql, t);
batch.addStmt(bs, batchExe);
@@ -63,7 +63,7 @@ final class PstmtFactory {
* Return a callable statement taking into account batch requirements.
*/
CallableStatement cstmtBatch(SpiTransaction t, boolean logSql, String sql, BatchPostExecute batchExe) throws SQLException {
- BatchedPstmtHolder batch = t.getBatchControl().pstmtHolder();
+ BatchedPstmtHolder batch = t.batchControl().pstmtHolder();
CallableStatement stmt = (CallableStatement) batch.stmt(sql, batchExe);
if (stmt != null) {
return stmt;
@@ -71,7 +71,7 @@ final class PstmtFactory {
if (logSql) {
t.logSql(sql);
}
- Connection conn = t.getInternalConnection();
+ Connection conn = t.internalConnection();
stmt = conn.prepareCall(sql);
BatchedPstmt bs = new BatchedPstmt(stmt, false, sql, t);
batch.addStmt(bs, batchExe);
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/persist/SaveManyBeans.java b/ebean-core/src/main/java/io/ebeaninternal/server/persist/SaveManyBeans.java
index ec2ab6a32..338099eed 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/persist/SaveManyBeans.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/persist/SaveManyBeans.java
@@ -179,7 +179,7 @@ final class SaveManyBeans extends SaveManyBase {
if (hasOrderColumn && !clearedParent) {
// Clear the parent bean from the PersistenceContext (L1 cache), because the order of referenced beans might have changed
final BeanDescriptor> beanDescriptor = many.descriptor();
- beanDescriptor.contextClear(transaction.getPersistenceContext(), beanDescriptor.getId(parentBean));
+ beanDescriptor.contextClear(transaction.persistenceContext(), beanDescriptor.getId(parentBean));
clearedParent = true;
}
}
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/persist/dml/DmlHandler.java b/ebean-core/src/main/java/io/ebeaninternal/server/persist/dml/DmlHandler.java
index 54d318a0a..478e86ed7 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/persist/dml/DmlHandler.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/persist/dml/DmlHandler.java
@@ -66,7 +66,7 @@ public abstract class DmlHandler implements PersistHandler, BindableRequest {
* Bind to the statement returning the DataBind.
*/
DataBind bind(PreparedStatement stmt) {
- return new DataBind(persistRequest.dataTimeZone(), stmt, transaction.getInternalConnection());
+ return new DataBind(persistRequest.dataTimeZone(), stmt, transaction.internalConnection());
}
/**
@@ -234,7 +234,7 @@ public abstract class DmlHandler implements PersistHandler, BindableRequest {
* Check with useGeneratedKeys to get appropriate PreparedStatement.
*/
PreparedStatement getPstmt(SpiTransaction t, String sql, boolean genKeys) throws SQLException {
- Connection conn = t.getInternalConnection();
+ Connection conn = t.internalConnection();
if (genKeys) {
// the Id generated is always the first column
// Required to stop Oracle10 giving us Oracle rowId??
@@ -249,7 +249,7 @@ public abstract class DmlHandler implements PersistHandler, BindableRequest {
* Return a prepared statement taking into account batch requirements.
*/
PreparedStatement getPstmtBatch(SpiTransaction t, String sql, PersistRequestBean> request, boolean genKeys) throws SQLException {
- BatchedPstmtHolder batch = t.getBatchControl().pstmtHolder();
+ BatchedPstmtHolder batch = t.batchControl().pstmtHolder();
batchedPstmt = batch.batchedPstmt(sql);
if (batchedPstmt != null) {
batchedStatus = batchedPstmt.isEmpty() ? BATCHED_FIRST : BATCHED;
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/persist/dml/InsertHandler.java b/ebean-core/src/main/java/io/ebeaninternal/server/persist/dml/InsertHandler.java
index 3e7ec1cd7..399cae8d1 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/persist/dml/InsertHandler.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/persist/dml/InsertHandler.java
@@ -89,7 +89,7 @@ public final class InsertHandler extends DmlHandler {
*/
@Override
PreparedStatement getPstmt(SpiTransaction t, String sql, boolean useGeneratedKeys) throws SQLException {
- Connection conn = t.getInternalConnection();
+ Connection conn = t.internalConnection();
if (useGeneratedKeys) {
return conn.prepareStatement(sql, meta.getIdentityDbColumns());
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/persist/dml/UpdateHandler.java b/ebean-core/src/main/java/io/ebeaninternal/server/persist/dml/UpdateHandler.java
index 01c6e3ce9..51dfa8a87 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/persist/dml/UpdateHandler.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/persist/dml/UpdateHandler.java
@@ -37,7 +37,7 @@ public final class UpdateHandler extends DmlHandler {
return;
}
- sql = updatePlan.getSql();
+ sql = updatePlan.sql();
SpiTransaction t = persistRequest.transaction();
PreparedStatement pstmt;
if (persistRequest.isBatched()) {
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/persist/dml/UpdatePlan.java b/ebean-core/src/main/java/io/ebeaninternal/server/persist/dml/UpdatePlan.java
index 69527de9b..cba841191 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/persist/dml/UpdatePlan.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/persist/dml/UpdatePlan.java
@@ -45,27 +45,27 @@ final class UpdatePlan implements SpiUpdatePlan {
}
@Override
- public long getTimeCreated() {
+ public long timeCreated() {
return timeCreated;
}
@Override
- public long getTimeLastUsed() {
+ public long timeLastUsed() {
return timeLastUsed;
}
@Override
- public String getKey() {
+ public String key() {
return key;
}
@Override
- public ConcurrencyMode getMode() {
+ public ConcurrencyMode mode() {
return mode;
}
@Override
- public String getSql() {
+ public String sql() {
return sql;
}
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/query/CQuery.java b/ebean-core/src/main/java/io/ebeaninternal/server/query/CQuery.java
index 283bc032d..4f63522b5 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/query/CQuery.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/query/CQuery.java
@@ -183,13 +183,13 @@ public final class CQuery implements DbReadContext, CancelableQuery, SpiProfi
this.audit = request.isAuditReads();
this.queryPlan = queryPlan;
this.query = request.query();
- this.queryMode = query.getMode();
+ this.queryMode = query.mode();
this.loadContextBean = queryMode.isLoadContextBean() || query.getForUpdateLockType() != null;
- this.lazyLoadManyProperty = query.getLazyLoadMany();
+ this.lazyLoadManyProperty = query.lazyLoadMany();
this.readOnly = request.isReadOnly();
this.disableLazyLoading = query.isDisableLazyLoading();
- this.objectGraphNode = query.getParentNode();
- this.profilingListener = query.getProfilingListener();
+ this.objectGraphNode = query.parentNode();
+ this.profilingListener = query.profilingListener();
this.autoTuneProfiling = profilingListener != null;
// set the generated sql back to the query
// so its available to the user...
@@ -214,7 +214,7 @@ public final class CQuery implements DbReadContext, CancelableQuery, SpiProfi
if (request.isFindById()) {
return null;
} else {
- SpiQuery.Type manyType = request.query().getType();
+ SpiQuery.Type manyType = request.query().type();
if (manyType == null) {
// subQuery compiled for InQueryExpression
return null;
@@ -312,7 +312,7 @@ public final class CQuery implements DbReadContext, CancelableQuery, SpiProfi
SpiTransaction t = request.transaction();
profileOffset = t.profileOffset();
if (query.isRawSql()) {
- ResultSet suppliedResultSet = query.getRawSql().getResultSet();
+ ResultSet suppliedResultSet = query.rawSql().getResultSet();
if (suppliedResultSet != null) {
// this is a user supplied ResultSet so use that
bindLog = "";
@@ -320,7 +320,7 @@ public final class CQuery implements DbReadContext, CancelableQuery, SpiProfi
}
}
- Connection conn = t.getInternalConnection();
+ Connection conn = t.internalConnection();
if (forwardOnlyHint) {
// Use forward only hints for large resultSet processing (Issue 56, MySql specific)
pstmt = conn.prepareStatement(sql, ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY);
@@ -328,11 +328,11 @@ public final class CQuery implements DbReadContext, CancelableQuery, SpiProfi
} else {
pstmt = conn.prepareStatement(sql);
}
- if (query.getTimeout() > 0) {
- pstmt.setQueryTimeout(query.getTimeout());
+ if (query.timeout() > 0) {
+ pstmt.setQueryTimeout(query.timeout());
}
- if (query.getBufferFetchSizeHint() > 0) {
- pstmt.setFetchSize(query.getBufferFetchSizeHint());
+ if (query.bufferFetchSizeHint() > 0) {
+ pstmt.setFetchSize(query.bufferFetchSizeHint());
}
bindLog = predicates.bind(queryPlan.bindEncryptedProperties(pstmt, conn));
} finally {
@@ -566,7 +566,7 @@ public final class CQuery implements DbReadContext, CancelableQuery, SpiProfi
public void profile() {
transaction()
.profileStream()
- .addQueryEvent(query.profileEventId(), profileOffset, desc.name(), loadedBeanCount, query.getProfileId());
+ .addQueryEvent(query.profileEventId(), profileOffset, desc.name(), loadedBeanCount, query.profileId());
}
QueryIterator readIterate(int bufferSize, OrmQueryRequest request) {
@@ -695,7 +695,7 @@ public final class CQuery implements DbReadContext, CancelableQuery, SpiProfi
void auditFindMany() {
if (auditIds != null && !auditIds.isEmpty()) {
// get the id values of the underlying collection
- ReadEvent futureReadEvent = query.getFutureFetchAudit();
+ ReadEvent futureReadEvent = query.futureFetchAudit();
if (futureReadEvent == null) {
// normal query execution
desc.readAuditMany(queryPlan.auditQueryKey(), bindLog, auditIds);
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/query/CQueryBuilder.java b/ebean-core/src/main/java/io/ebeaninternal/server/query/CQueryBuilder.java
index bf5ecc1d6..e9e58f78a 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/query/CQueryBuilder.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/query/CQueryBuilder.java
@@ -1,7 +1,6 @@
package io.ebeaninternal.server.query;
import io.ebean.CountDistinctOrder;
-import io.ebean.OrderBy;
import io.ebean.Query;
import io.ebean.RawSql;
import io.ebean.RawSqlBuilder;
@@ -91,7 +90,7 @@ final class CQueryBuilder {
*/
CQueryUpdate buildUpdateQuery(boolean deleteRequest, OrmQueryRequest request) {
SpiQuery query = request.query();
- String rootTableAlias = query.getAlias();
+ String rootTableAlias = query.alias();
query.setupForDeleteOrUpdate();
CQueryPredicates predicates = new CQueryPredicates(binder, request);
@@ -183,7 +182,7 @@ final class CQueryBuilder {
if (!query.isIncludeSoftDeletes()) {
BeanDescriptor> desc = request.descriptor();
if (desc.isSoftDelete()) {
- query.addSoftDeletePredicate(desc.softDeletePredicate(alias(query.getAlias())));
+ query.addSoftDeletePredicate(desc.softDeletePredicate(alias(query.alias())));
}
}
CQueryPredicates predicates = new CQueryPredicates(binder, request);
@@ -211,7 +210,7 @@ final class CQueryBuilder {
query.setSelectId();
BeanDescriptor desc = request.descriptor();
if (!query.isIncludeSoftDeletes() && desc.isSoftDelete()) {
- query.addSoftDeletePredicate(desc.softDeletePredicate(alias(query.getAlias())));
+ query.addSoftDeletePredicate(desc.softDeletePredicate(alias(query.alias())));
}
return buildFetchAttributeQuery(request);
}
@@ -220,14 +219,14 @@ final class CQueryBuilder {
* Return the history support if this query needs it (is a 'as of' type query).
*/
CQueryHistorySupport historySupport(SpiQuery query) {
- return query.getTemporalMode().isHistory() ? historySupport : null;
+ return query.temporalMode().isHistory() ? historySupport : null;
}
/**
* Return the draft support (or null) for a 'asDraft' query.
*/
CQueryDraftSupport draftSupport(SpiQuery query) {
- return query.getTemporalMode() == SpiQuery.TemporalMode.DRAFT ? draftSupport : null;
+ return query.temporalMode() == SpiQuery.TemporalMode.DRAFT ? draftSupport : null;
}
/**
@@ -260,7 +259,7 @@ final class CQueryBuilder {
predicates.prepare(true);
SqlTree sqlTree = createSqlTree(request, predicates, selectCountWithColumnAlias && withAgg);
- if (SpiQuery.TemporalMode.CURRENT == query.getTemporalMode()) {
+ if (SpiQuery.TemporalMode.CURRENT == query.temporalMode()) {
sqlTree.addSoftDeletePredicate(query);
}
@@ -298,7 +297,7 @@ final class CQueryBuilder {
* Return true if the query includes an aggregation property.
*/
private boolean includesAggregation(OrmQueryRequest request, SpiQuery query) {
- return request.descriptor().includesAggregation(query.getDetail());
+ return request.descriptor().includesAggregation(query.detail());
}
private String wrapSelectCount(String sql) {
@@ -335,7 +334,7 @@ final class CQueryBuilder {
SqlTree sqlTree = createSqlTree(request, predicates);
if (query.isAsOfQuery()) {
sqlTree.addAsOfTableAlias(query);
- } else if (SpiQuery.TemporalMode.CURRENT == query.getTemporalMode()) {
+ } else if (SpiQuery.TemporalMode.CURRENT == query.temporalMode()) {
sqlTree.addSoftDeletePredicate(query);
}
@@ -391,12 +390,12 @@ final class CQueryBuilder {
private SqlTree createNativeSqlTree(OrmQueryRequest> request, CQueryPredicates predicates) {
SpiQuery> query = request.query();
// parse named parameters returning the final sql to execute
- String sql = predicates.parseBindParams(query.getNativeSql());
+ String sql = predicates.parseBindParams(query.nativeSql());
if (query.hasMaxRowsOrFirstRow()) {
sql = nativeQueryPaging(query, sql);
}
query.setGeneratedSql(sql);
- Connection connection = request.transaction().getInternalConnection();
+ Connection connection = request.transaction().internalConnection();
BeanDescriptor> desc = request.descriptor();
try {
// For SqlServer we need either "selectMethod=cursor" in the connection string or fetch explicitly a cursorable
@@ -429,7 +428,7 @@ final class CQueryBuilder {
private SqlTree createRawSqlSqlTree(OrmQueryRequest> request, CQueryPredicates predicates) {
BeanDescriptor> descriptor = request.descriptor();
- ColumnMapping columnMapping = request.query().getRawSql().getColumnMapping();
+ ColumnMapping columnMapping = request.query().rawSql().getColumnMapping();
PathProperties pathProps = new PathProperties();
// convert list of columns into (tree like) PathProperties
@@ -511,7 +510,7 @@ final class CQueryBuilder {
return new SqlLimitResponse(query.getGeneratedSql());
}
if (query.isRawSql()) {
- return rawSqlHandler.buildSql(request, predicates, query.getRawSql().getSql());
+ return rawSqlHandler.buildSql(request, predicates, query.rawSql().getSql());
}
return new BuildReq(selectClause, request, predicates, select).buildSql();
}
@@ -649,7 +648,7 @@ final class CQueryBuilder {
if (request.isFindById() || query.getId() != null) {
appendAndOrWhere();
BeanDescriptor> desc = request.descriptor();
- String idSql = desc.idBinderIdSql(query.getAlias());
+ String idSql = desc.idBinderIdSql(query.alias());
if (idSql.isEmpty()) {
throw new IllegalStateException("Executing FindById query on entity bean " + desc.name()
+ " that doesn't have an @Id property??");
@@ -671,7 +670,7 @@ final class CQueryBuilder {
}
private void appendSoftDelete() {
- List softDeletePredicates = query.getSoftDeletePredicates();
+ List softDeletePredicates = query.softDeletePredicates();
if (softDeletePredicates != null) {
appendAndOrWhere();
for (int i = 0; i < softDeletePredicates.size(); i++) {
@@ -707,7 +706,7 @@ final class CQueryBuilder {
}
if (countSingleAttribute) {
sb.append(") r1 group by r1.attribute_");
- sb.append(toSql(query.getCountDistinctOrder()));
+ sb.append(toSql(query.countDistinctOrder()));
}
if (useSqlLimiter) {
// use LIMIT/OFFSET, ROW_NUMBER() or rownum type SQL query limitation
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/query/CQueryBuilderRawSql.java b/ebean-core/src/main/java/io/ebeaninternal/server/query/CQueryBuilderRawSql.java
index 2963d979d..eac5fea14 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/query/CQueryBuilderRawSql.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/query/CQueryBuilderRawSql.java
@@ -32,7 +32,7 @@ final class CQueryBuilderRawSql {
}
if (!rsql.isParsed()) {
String sql = rsql.getUnparsedSql();
- BindParams bindParams = request.query().getBindParams();
+ BindParams bindParams = request.query().bindParams();
if (bindParams != null && bindParams.requiresNamedParamsPrepare()) {
// convert named parameters into positioned parameters
sql = BindParamsParser.parse(bindParams, sql);
@@ -57,7 +57,7 @@ final class CQueryBuilderRawSql {
private String buildMainQuery(String orderBy, OrmQueryRequest> request, CQueryPredicates predicates, SpiRawSql.Sql sql) {
StringBuilder sb = new StringBuilder();
- OrmQueryProperties ormQueryProperties = request.query().getDetail().getChunk(null, false);
+ OrmQueryProperties ormQueryProperties = request.query().detail().getChunk(null, false);
if (ormQueryProperties.hasSelectClause()) {
boolean first = true;
for (String selectProperty : ormQueryProperties.getIncluded()) {
@@ -73,7 +73,7 @@ final class CQueryBuilderRawSql {
sb.append(" ");
String s = sql.getPreWhere();
- BindParams bindParams = request.query().getBindParams();
+ BindParams bindParams = request.query().bindParams();
if (bindParams != null && bindParams.requiresNamedParamsPrepare()) {
// convert named parameters into positioned parameters
// Named Parameters only allowed prior to dynamic where
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/query/CQueryEngine.java b/ebean-core/src/main/java/io/ebeaninternal/server/query/CQueryEngine.java
index 4078d511b..2d89e0968 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/query/CQueryEngine.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/query/CQueryEngine.java
@@ -198,7 +198,7 @@ public final class CQueryEngine {
int iterateBufferSize = request.secondaryQueriesMinBatchSize();
if (iterateBufferSize < 1) {
// not set on query joins so check if batch size set on query itself
- int queryBatch = request.query().getLazyLoadBatchSize();
+ int queryBatch = request.query().lazyLoadBatchSize();
if (queryBatch > 0) {
iterateBufferSize = queryBatch;
} else {
@@ -235,8 +235,8 @@ public final class CQueryEngine {
SpiQuery query = request.query();
String sysPeriodLower = getSysPeriodLower(query);
if (query.isVersionsBetween() && !historySupport.isStandardsBased()) {
- query.where().lt(sysPeriodLower, query.getVersionEnd());
- query.where().geOrNull(getSysPeriodUpper(query), query.getVersionStart());
+ query.where().lt(sysPeriodLower, query.versionEnd());
+ query.where().geOrNull(getSysPeriodUpper(query), query.versionStart());
}
// order by lower sys period desc
@@ -410,10 +410,10 @@ public final class CQueryEngine {
*/
private void logFindBeanSummary(CQuery> q) {
SpiQuery> query = q.request().query();
- String loadMode = query.getLoadMode();
- String loadDesc = query.getLoadDescription();
- String lazyLoadProp = query.getLazyLoadProperty();
- ObjectGraphNode node = query.getParentNode();
+ String loadMode = query.loadMode();
+ String loadDesc = query.loadDescription();
+ String lazyLoadProp = query.lazyLoadProperty();
+ ObjectGraphNode node = query.parentNode();
String originKey;
if (node == null || node.origin() == null) {
originKey = null;
@@ -453,10 +453,10 @@ public final class CQueryEngine {
*/
private void logFindManySummary(CQuery> q) {
SpiQuery> query = q.request().query();
- String loadMode = query.getLoadMode();
- String loadDesc = query.getLoadDescription();
- String lazyLoadProp = query.getLazyLoadProperty();
- ObjectGraphNode node = query.getParentNode();
+ String loadMode = query.loadMode();
+ String loadDesc = query.loadDescription();
+ String lazyLoadProp = query.lazyLoadProperty();
+ ObjectGraphNode node = query.parentNode();
String originKey;
if (node == null || node.origin() == null) {
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/query/CQueryFetchSingleAttribute.java b/ebean-core/src/main/java/io/ebeaninternal/server/query/CQueryFetchSingleAttribute.java
index 78b20dc1c..a687beae5 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/query/CQueryFetchSingleAttribute.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/query/CQueryFetchSingleAttribute.java
@@ -125,13 +125,13 @@ final class CQueryFetchSingleAttribute implements SpiProfileTransactionEvent, Ca
query.checkCancelled();
SpiTransaction t = transaction();
profileOffset = t.profileOffset();
- Connection conn = t.getInternalConnection();
+ Connection conn = t.internalConnection();
pstmt = conn.prepareStatement(sql);
- if (query.getBufferFetchSizeHint() > 0) {
- pstmt.setFetchSize(query.getBufferFetchSizeHint());
+ if (query.bufferFetchSizeHint() > 0) {
+ pstmt.setFetchSize(query.bufferFetchSizeHint());
}
- if (query.getTimeout() > 0) {
- pstmt.setQueryTimeout(query.getTimeout());
+ if (query.timeout() > 0) {
+ pstmt.setQueryTimeout(query.timeout());
}
bindLog = predicates.bind(pstmt, conn);
} finally {
@@ -165,7 +165,7 @@ final class CQueryFetchSingleAttribute implements SpiProfileTransactionEvent, Ca
public void profile() {
transaction()
.profileStream()
- .addQueryEvent(query.profileEventId(), profileOffset, desc.name(), rowCount, query.getProfileId());
+ .addQueryEvent(query.profileEventId(), profileOffset, desc.name(), rowCount, query.profileId());
}
Set dependentTables() {
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/query/CQueryPlan.java b/ebean-core/src/main/java/io/ebeaninternal/server/query/CQueryPlan.java
index ad52e4eca..fc982503d 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/query/CQueryPlan.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/query/CQueryPlan.java
@@ -85,10 +85,10 @@ public class CQueryPlan implements SpiQueryPlan {
this.beanType = request.descriptor().type();
this.planKey = request.queryPlanKey();
SpiQuery> query = request.query();
- this.profileLocation = query.getProfileLocation();
+ this.profileLocation = query.profileLocation();
this.location = (profileLocation == null) ? null : profileLocation.location();
- this.label = query.getPlanLabel();
- this.name = deriveName(label, query.getType(), request.descriptor().simpleName());
+ this.label = query.planLabel();
+ this.name = deriveName(label, query.type(), request.descriptor().simpleName());
this.asOfTableCount = query.getAsOfTableCount();
this.sql = sqlRes.getSql();
this.sqlTree = sqlTree;
@@ -109,10 +109,10 @@ public class CQueryPlan implements SpiQueryPlan {
this.dataTimeZone = server.dataTimeZone();
this.beanType = request.descriptor().type();
SpiQuery> query = request.query();
- this.profileLocation = query.getProfileLocation();
+ this.profileLocation = query.profileLocation();
this.location = (profileLocation == null) ? null : profileLocation.location();
- this.label = query.getPlanLabel();
- this.name = deriveName(label, query.getType(), request.descriptor().simpleName());
+ this.label = query.planLabel();
+ this.name = deriveName(label, query.type(), request.descriptor().simpleName());
this.planKey = buildPlanKey(sql, logWhereSql);
this.asOfTableCount = 0;
this.sql = sql;
@@ -142,11 +142,11 @@ public class CQueryPlan implements SpiQueryPlan {
}
private SpiQueryBindCapture initBindCapture(SpiQuery> query) {
- return query.getType().isUpdate() ? SpiQueryBindCapture.NOOP : server.createQueryBindCapture(this);
+ return query.type().isUpdate() ? SpiQueryBindCapture.NOOP : server.createQueryBindCapture(this);
}
private SpiQueryBindCapture initBindCaptureRaw(String sql, SpiQuery> query) {
- return sql.equals(RESULT_SET_BASED_RAW_SQL) || query.getType().isUpdate() ? SpiQueryBindCapture.NOOP : server.createQueryBindCapture(this);
+ return sql.equals(RESULT_SET_BASED_RAW_SQL) || query.type().isUpdate() ? SpiQueryBindCapture.NOOP : server.createQueryBindCapture(this);
}
private CQueryPlanKey buildPlanKey(String sql, String logWhereSql) {
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/query/CQueryPlanManager.java b/ebean-core/src/main/java/io/ebeaninternal/server/query/CQueryPlanManager.java
index ac39f6beb..b3a4091d4 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/query/CQueryPlanManager.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/query/CQueryPlanManager.java
@@ -30,8 +30,8 @@ public final class CQueryPlanManager implements QueryPlanManager {
this.transactionManager = transactionManager;
this.defaultThreshold = defaultThreshold;
this.planLogger = planLogger;
- this.timeCollection = extraMetrics.getPlanCollect();
- this.timeBindCapture = extraMetrics.getBindCapture();
+ this.timeCollection = extraMetrics.planCollect();
+ this.timeBindCapture = extraMetrics.bindCapture();
}
@Override
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/query/CQueryPlanRawSql.java b/ebean-core/src/main/java/io/ebeaninternal/server/query/CQueryPlanRawSql.java
index 935f730ec..f19e3fd37 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/query/CQueryPlanRawSql.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/query/CQueryPlanRawSql.java
@@ -28,7 +28,7 @@ final class CQueryPlanRawSql extends CQueryPlan {
private int[] createIndexPositions(OrmQueryRequest> request, SqlTree sqlTree) {
List chain = sqlTree.buildRawSqlSelectChain();
- ColumnMapping columnMapping = request.query().getRawSql().getColumnMapping();
+ ColumnMapping columnMapping = request.query().rawSql().getColumnMapping();
int[] indexPositions = new int[chain.size()];
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/query/CQueryPredicates.java b/ebean-core/src/main/java/io/ebeaninternal/server/query/CQueryPredicates.java
index 4058e00fc..78b54d56d 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/query/CQueryPredicates.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/query/CQueryPredicates.java
@@ -76,7 +76,7 @@ public final class CQueryPredicates {
this.binder = binder;
this.request = request;
this.query = request.query();
- this.bindParams = query.getBindParams();
+ this.bindParams = query.bindParams();
this.idValue = query.getId();
}
@@ -85,15 +85,15 @@ public final class CQueryPredicates {
}
public String bind(DataBind dataBind) throws SQLException {
- OrmUpdateProperties updateProperties = query.getUpdateProperties();
+ OrmUpdateProperties updateProperties = query.updateProperties();
if (updateProperties != null) {
// bind the update set clause
updateProperties.bind(binder, dataBind);
}
if (query.isVersionsBetween() && binder.isAsOfStandardsBased()) {
// sql2011 based versions between timestamp syntax
- Timestamp start = query.getVersionStart();
- Timestamp end = query.getVersionEnd();
+ Timestamp start = query.versionStart();
+ Timestamp end = query.versionEnd();
dataBind.append("between ").append(start).append(" and ").append(end);
binder.bindObject(dataBind, start);
binder.bindObject(dataBind, end);
@@ -137,7 +137,7 @@ public final class CQueryPredicates {
private void buildUpdateClause(boolean buildSql, DeployParser deployParser) {
if (buildSql) {
- OrmUpdateProperties updateProperties = query.getUpdateProperties();
+ OrmUpdateProperties updateProperties = query.updateProperties();
if (updateProperties != null) {
dbUpdateClause = updateProperties.buildSetClause(deployParser);
}
@@ -159,14 +159,14 @@ public final class CQueryPredicates {
if (!buildSql && bindParams != null && bindParams.requiresNamedParamsPrepare()) {
if (query.isNativeSql()) {
// convert named params into positioned params
- String sql = query.getNativeSql();
+ String sql = query.nativeSql();
BindParamsParser.parse(bindParams, sql);
} else if (query.isRawSql()) {
// RawSql query hit cached query plan. Need to convert
// named parameters into positioned parameters so that
// the named parameters are bound
- SpiRawSql.Sql sql = query.getRawSql().getSql();
+ SpiRawSql.Sql sql = query.rawSql().getSql();
String s = sql.isParsed() ? sql.getPreWhere() : sql.getUnparsedSql();
BindParamsParser.parse(bindParams, s);
}
@@ -187,7 +187,7 @@ public final class CQueryPredicates {
// create a copy of the includes required to support the orderBy
orderByIncludes = new HashSet<>(deployParser.includes());
}
- SpiExpressionList> whereExp = query.getWhereExpressions();
+ SpiExpressionList> whereExp = query.whereExpressions();
if (whereExp != null) {
this.where = new DefaultExpressionRequest(request, deployParser, binder, whereExp);
if (buildSql) {
@@ -195,7 +195,7 @@ public final class CQueryPredicates {
}
}
if (manyProperty != null) {
- OrmQueryProperties chunk = query.getDetail().getChunk(manyProperty.name(), false);
+ OrmQueryProperties chunk = query.detail().getChunk(manyProperty.name(), false);
SpiExpressionList> filterManyExpr = chunk.getFilterMany();
if (filterManyExpr != null) {
this.filterMany = new DefaultExpressionRequest(request, deployParser, binder, filterManyExpr);
@@ -204,7 +204,7 @@ public final class CQueryPredicates {
}
}
}
- SpiExpressionList> havingExpr = query.getHavingExpressions();
+ SpiExpressionList> havingExpr = query.havingExpressions();
if (havingExpr != null) {
this.having = new DefaultExpressionRequest(request, deployParser, binder, havingExpr);
if (buildSql) {
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/query/CQueryRowCount.java b/ebean-core/src/main/java/io/ebeaninternal/server/query/CQueryRowCount.java
index 3b1865825..4d43da157 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/query/CQueryRowCount.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/query/CQueryRowCount.java
@@ -89,13 +89,13 @@ final class CQueryRowCount implements SpiProfileTransactionEvent, CancelableQuer
try {
SpiTransaction t = transaction();
profileOffset = t.profileOffset();
- Connection conn = t.getInternalConnection();
+ Connection conn = t.internalConnection();
lock.lock();
try {
query.checkCancelled();
pstmt = conn.prepareStatement(sql);
- if (query.getTimeout() > 0) {
- pstmt.setQueryTimeout(query.getTimeout());
+ if (query.timeout() > 0) {
+ pstmt.setQueryTimeout(query.timeout());
}
bindLog = predicates.bind(pstmt, conn);
} finally {
@@ -137,7 +137,7 @@ final class CQueryRowCount implements SpiProfileTransactionEvent, CancelableQuer
public void profile() {
transaction()
.profileStream()
- .addQueryEvent(query.profileEventId(), profileOffset, desc.name(), rowCount, query.getProfileId());
+ .addQueryEvent(query.profileEventId(), profileOffset, desc.name(), rowCount, query.profileId());
}
Set dependentTables() {
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/query/CQueryUpdate.java b/ebean-core/src/main/java/io/ebeaninternal/server/query/CQueryUpdate.java
index edd8b348f..85081238b 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/query/CQueryUpdate.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/query/CQueryUpdate.java
@@ -66,13 +66,13 @@ final class CQueryUpdate implements SpiProfileTransactionEvent, CancelableQuery
try {
SpiTransaction t = transaction();
profileOffset = t.profileOffset();
- Connection conn = t.getInternalConnection();
+ Connection conn = t.internalConnection();
lock.lock();
try {
query.checkCancelled();
pstmt = conn.prepareStatement(sql);
- if (query.getTimeout() > 0) {
- pstmt.setQueryTimeout(query.getTimeout());
+ if (query.timeout() > 0) {
+ pstmt.setQueryTimeout(query.timeout());
}
bindLog = predicates.bind(pstmt, conn);
} finally {
@@ -113,7 +113,7 @@ final class CQueryUpdate implements SpiProfileTransactionEvent, CancelableQuery
public void profile() {
transaction()
.profileStream()
- .addQueryEvent(query.profileEventId(), profileOffset, desc.name(), rowCount, query.getProfileId());
+ .addQueryEvent(query.profileEventId(), profileOffset, desc.name(), rowCount, query.profileId());
}
@Override
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/query/SqlTreeBuilder.java b/ebean-core/src/main/java/io/ebeaninternal/server/query/SqlTreeBuilder.java
index 3c0a09dcb..8a2465293 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/query/SqlTreeBuilder.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/query/SqlTreeBuilder.java
@@ -87,14 +87,14 @@ public final class SqlTreeBuilder {
this.temporalMode = SpiQuery.TemporalMode.of(query);
this.disableLazyLoad = query.isDisableLazyLoading();
this.readOnly = Boolean.TRUE.equals(query.isReadOnly());
- this.subQuery = Type.SQ_EXISTS == query.getType()
- || Type.SQ_EX == query.getType()
- || Type.ID_LIST == query.getType()
- || Type.DELETE == query.getType()
+ this.subQuery = Type.SQ_EXISTS == query.type()
+ || Type.SQ_EX == query.type()
+ || Type.ID_LIST == query.type()
+ || Type.DELETE == query.type()
|| query.isCountDistinct();
- this.includeJoin = query.getM2mIncludeJoin();
- this.manyWhereJoins = query.getManyWhereJoins();
- this.queryDetail = query.getDetail();
+ this.includeJoin = query.m2mIncludeJoin();
+ this.manyWhereJoins = query.manyWhereJoins();
+ this.queryDetail = query.detail();
this.predicates = predicates;
this.alias = new SqlTreeAlias(request.baseTableAlias(), temporalMode);
this.distinctOnPlatform = builder.isPlatformDistinctOn();
@@ -138,7 +138,7 @@ public final class SqlTreeBuilder {
if (rawSql) {
return "Not Used";
}
- if (query.getType() == Type.SQ_EXISTS) {
+ if (query.type() == Type.SQ_EXISTS) {
// effective query is "where exists (select 1 from ...)"
return "1";
}
@@ -147,7 +147,7 @@ public final class SqlTreeBuilder {
}
private String buildGroupByClause() {
- if (rawSql || (!rootNode.isAggregation() && query.getHavingExpressions() == null)) {
+ if (rawSql || (!rootNode.isAggregation() && query.havingExpressions() == null)) {
return null;
}
ctx.startGroupBy();
@@ -156,7 +156,7 @@ public final class SqlTreeBuilder {
}
private String buildDistinctOn() {
- if (rawSql || !distinctOnPlatform || !sqlDistinct || Type.COUNT == query.getType()) {
+ if (rawSql || !distinctOnPlatform || !sqlDistinct || Type.COUNT == query.type()) {
return null;
}
ctx.startGroupBy();
@@ -214,7 +214,7 @@ public final class SqlTreeBuilder {
if (!rawSql) {
alias.addJoin(queryDetail.getFetchPaths(), desc);
alias.addJoin(predicates.predicateIncludes(), desc);
- alias.addManyWhereJoins(manyWhereJoins.getPropertyNames());
+ alias.addManyWhereJoins(manyWhereJoins.propertyNames());
// build set of table alias
alias.buildAlias();
predicates.parseTableAlias(alias);
@@ -259,7 +259,7 @@ public final class SqlTreeBuilder {
extraProps.forEach(props::addExtra);
if (!rawSql && manyWhereJoins.isFormulaWithJoin(prefix)) {
- for (String property : manyWhereJoins.getFormulaJoinProperties(prefix)) {
+ for (String property : manyWhereJoins.formulaJoinProperties(prefix)) {
final STreeProperty beanProperty = desc.findPropertyFromPath(property);
myJoinList.add(new SqlTreeNodeFormulaWhereJoin(beanProperty, SqlJoinType.OUTER, null));
}
@@ -283,15 +283,15 @@ public final class SqlTreeBuilder {
*
*/
private void addManyWhereJoins(List myJoinList) {
- Collection includes = manyWhereJoins.getPropertyJoins();
+ Collection includes = manyWhereJoins.propertyJoins();
for (PropertyJoin joinProp : includes) {
- STreePropertyAssoc beanProperty = (STreePropertyAssoc) desc.findPropertyFromPath(joinProp.getProperty());
- SqlTreeNodeManyWhereJoin nodeJoin = new SqlTreeNodeManyWhereJoin(joinProp.getProperty(), beanProperty, joinProp.getSqlJoinType(), temporalMode);
+ STreePropertyAssoc beanProperty = (STreePropertyAssoc) desc.findPropertyFromPath(joinProp.property());
+ SqlTreeNodeManyWhereJoin nodeJoin = new SqlTreeNodeManyWhereJoin(joinProp.property(), beanProperty, joinProp.sqlJoinType(), temporalMode);
myJoinList.add(nodeJoin);
- if (manyWhereJoins.isFormulaWithJoin(joinProp.getProperty())) {
- for (String property : manyWhereJoins.getFormulaJoinProperties(joinProp.getProperty())) {
- STreeProperty beanProperty2 = desc.findPropertyFromPath(SplitName.add(joinProp.getProperty(), property));
- myJoinList.add(new SqlTreeNodeFormulaWhereJoin(beanProperty2, SqlJoinType.OUTER, joinProp.getProperty()));
+ if (manyWhereJoins.isFormulaWithJoin(joinProp.property())) {
+ for (String property : manyWhereJoins.formulaJoinProperties(joinProp.property())) {
+ STreeProperty beanProperty2 = desc.findPropertyFromPath(SplitName.add(joinProp.property(), property));
+ myJoinList.add(new SqlTreeNodeFormulaWhereJoin(beanProperty2, SqlJoinType.OUTER, joinProp.property()));
}
}
}
@@ -302,10 +302,10 @@ public final class SqlTreeBuilder {
buildExtraJoins(desc, myList);
// Optional many property for lazy loading query
- STreePropertyAssocMany lazyLoadMany = (query == null) ? null : query.getLazyLoadMany();
+ STreePropertyAssocMany lazyLoadMany = (query == null) ? null : query.lazyLoadMany();
boolean withId = !rawNoId && !subQuery && (query == null || query.isWithId());
- String baseTable = (query == null) ? null : query.getBaseTable();
+ String baseTable = (query == null) ? null : query.baseTable();
if (baseTable == null) {
baseTable = desc.baseTable(temporalMode);
}
@@ -356,7 +356,7 @@ public final class SqlTreeBuilder {
// support the predicates or order by clauses.
// remove ManyWhereJoins from the predicateIncludes
- predicateIncludes.removeAll(manyWhereJoins.getPropertyNames());
+ predicateIncludes.removeAll(manyWhereJoins.propertyNames());
predicateIncludes.addAll(predicates.orderByIncludes());
// look for predicateIncludes that are not in selectIncludes and add
@@ -626,7 +626,7 @@ public final class SqlTreeBuilder {
// add many where joins
if (manyWhereJoins.isFormulaWithJoin(includeProp)) {
- for (String property : manyWhereJoins.getFormulaJoinProperties(includeProp)) {
+ for (String property : manyWhereJoins.formulaJoinProperties(includeProp)) {
STreeProperty beanProperty = desc.findPropertyFromPath(SplitName.add(includeProp, property));
extraJoin.addChild(new SqlTreeNodeFormulaWhereJoin(beanProperty, SqlJoinType.OUTER, null));
}
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/querydefn/DefaultDtoQuery.java b/ebean-core/src/main/java/io/ebeaninternal/server/querydefn/DefaultDtoQuery.java
index a3cd1a9b7..e9aa83bab 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/querydefn/DefaultDtoQuery.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/querydefn/DefaultDtoQuery.java
@@ -48,8 +48,8 @@ public final class DefaultDtoQuery extends AbstractQuery implements SpiDtoQue
this.server = server;
this.descriptor = descriptor;
this.ormQuery = ormQuery;
- this.label = ormQuery.getLabel();
- this.profileLocation = ormQuery.getProfileLocation();
+ this.label = ormQuery.label();
+ this.profileLocation = ormQuery.profileLocation();
}
/**
@@ -68,7 +68,7 @@ public final class DefaultDtoQuery extends AbstractQuery implements SpiDtoQue
}
@Override
- public DtoQueryPlan getQueryPlan(Object planKey) {
+ public DtoQueryPlan queryPlan(Object planKey) {
return descriptor.queryPlan(planKey);
}
@@ -205,17 +205,17 @@ public final class DefaultDtoQuery extends AbstractQuery implements SpiDtoQue
}
@Override
- public Class getType() {
+ public Class type() {
return descriptor.type();
}
@Override
- public SpiQuery> getOrmQuery() {
+ public SpiQuery> ormQuery() {
return ormQuery;
}
@Override
- public Transaction getTransaction() {
+ public Transaction transaction() {
return transaction;
}
@@ -243,7 +243,7 @@ public final class DefaultDtoQuery extends AbstractQuery implements SpiDtoQue
@Nullable
@Override
- public String getPlanLabel() {
+ public String planLabel() {
if (label != null) {
return label;
}
@@ -267,7 +267,7 @@ public final class DefaultDtoQuery extends AbstractQuery implements SpiDtoQue
}
@Override
- public ProfileLocation getProfileLocation() {
+ public ProfileLocation profileLocation() {
return profileLocation;
}
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/querydefn/DefaultOrmQuery.java b/ebean-core/src/main/java/io/ebeaninternal/server/querydefn/DefaultOrmQuery.java
index 1b5dbff22..dce828bcf 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/querydefn/DefaultOrmQuery.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/querydefn/DefaultOrmQuery.java
@@ -189,7 +189,7 @@ public class DefaultOrmQuery extends AbstractQuery implements SpiQuery {
}
@Override
- public final BeanDescriptor getBeanDescriptor() {
+ public final BeanDescriptor descriptor() {
return beanDescriptor;
}
@@ -222,8 +222,8 @@ public class DefaultOrmQuery extends AbstractQuery implements SpiQuery {
}
@Override
- public final String getProfileId() {
- return getPlanLabel();
+ public final String profileId() {
+ return planLabel();
}
@Override
@@ -233,12 +233,12 @@ public class DefaultOrmQuery extends AbstractQuery implements SpiQuery {
}
@Override
- public final String getLabel() {
+ public final String label() {
return label;
}
@Override
- public final String getPlanLabel() {
+ public final String planLabel() {
if (label != null) {
return label;
}
@@ -291,7 +291,7 @@ public class DefaultOrmQuery extends AbstractQuery implements SpiQuery {
}
@Override
- public final List getSoftDeletePredicates() {
+ public final List softDeletePredicates() {
return softDeletePredicates;
}
@@ -364,7 +364,7 @@ public class DefaultOrmQuery extends AbstractQuery implements SpiQuery {
}
@Override
- public final SpiRawSql getRawSql() {
+ public final SpiRawSql rawSql() {
return rawSql;
}
@@ -384,7 +384,7 @@ public class DefaultOrmQuery extends AbstractQuery implements SpiQuery {
}
@Override
- public final int getLazyLoadBatchSize() {
+ public final int lazyLoadBatchSize() {
return lazyLoadBatchSize;
}
@@ -395,7 +395,7 @@ public class DefaultOrmQuery extends AbstractQuery implements SpiQuery {
}
@Override
- public final String getLazyLoadProperty() {
+ public final String lazyLoadProperty() {
return lazyLoadProperty;
}
@@ -432,7 +432,7 @@ public class DefaultOrmQuery extends AbstractQuery implements SpiQuery {
* Return the extra joins required to support the where clause for 'Many' properties.
*/
@Override
- public final ManyWhereJoins getManyWhereJoins() {
+ public final ManyWhereJoins manyWhereJoins() {
return manyWhereJoins;
}
@@ -524,7 +524,7 @@ public class DefaultOrmQuery extends AbstractQuery implements SpiQuery {
}
@Override
- public final Object getTenantId() {
+ public final Object tenantId() {
return tenantId;
}
@@ -539,7 +539,7 @@ public class DefaultOrmQuery extends AbstractQuery implements SpiQuery {
}
@Override
- public final OrmQueryDetail getDetail() {
+ public final OrmQueryDetail detail() {
return detail;
}
@@ -617,7 +617,7 @@ public class DefaultOrmQuery extends AbstractQuery implements SpiQuery {
}
@Override
- public final CountDistinctOrder getCountDistinctOrder() {
+ public final CountDistinctOrder countDistinctOrder() {
return countDistinctOrder;
}
@@ -634,7 +634,7 @@ public class DefaultOrmQuery extends AbstractQuery implements SpiQuery {
if (whereExpressions == null) {
return null;
}
- List underlyingList = whereExpressions.getUnderlyingList();
+ List underlyingList = whereExpressions.underlyingList();
if (underlyingList.isEmpty()) {
if (id != null) {
return new CacheIdLookupSingle<>(id);
@@ -664,7 +664,7 @@ public class DefaultOrmQuery extends AbstractQuery implements SpiQuery {
}
NaturalKeyQueryData data = new NaturalKeyQueryData<>(naturalKey);
- for (SpiExpression expression : whereExpressions.getUnderlyingList()) {
+ for (SpiExpression expression : whereExpressions.underlyingList()) {
// must be eq or in
if (!expression.naturalKey(data)) {
return null;
@@ -674,10 +674,10 @@ public class DefaultOrmQuery extends AbstractQuery implements SpiQuery {
}
@Override
- public final NaturalKeyBindParam getNaturalKeyBindParam() {
+ public final NaturalKeyBindParam naturalKeyBindParam() {
NaturalKeyBindParam namedBind = null;
if (bindParams != null) {
- namedBind = bindParams.getNaturalKeyBindParam();
+ namedBind = bindParams.naturalKeyBindParam();
if (namedBind == null) {
return null;
}
@@ -765,12 +765,12 @@ public class DefaultOrmQuery extends AbstractQuery implements SpiQuery {
}
@Override
- public final PersistenceContextScope getPersistenceContextScope() {
+ public final PersistenceContextScope persistenceContextScope() {
return persistenceContextScope;
}
@Override
- public final Type getType() {
+ public final Type type() {
return type;
}
@@ -780,12 +780,12 @@ public class DefaultOrmQuery extends AbstractQuery implements SpiQuery {
}
@Override
- public final String getLoadDescription() {
+ public final String loadDescription() {
return loadDescription;
}
@Override
- public final String getLoadMode() {
+ public final String loadMode() {
return loadMode;
}
@@ -803,7 +803,7 @@ public class DefaultOrmQuery extends AbstractQuery implements SpiQuery {
*
*/
@Override
- public final PersistenceContext getPersistenceContext() {
+ public final PersistenceContext persistenceContext() {
return persistenceContext;
}
@@ -825,7 +825,7 @@ public class DefaultOrmQuery extends AbstractQuery implements SpiQuery {
}
@Override
- public final BeanPropertyAssocMany> getLazyLoadMany() {
+ public final BeanPropertyAssocMany> lazyLoadMany() {
return lazyLoadForParentsProperty;
}
@@ -913,7 +913,7 @@ public class DefaultOrmQuery extends AbstractQuery implements SpiQuery {
}
@Override
- public final ProfilingListener getProfilingListener() {
+ public final ProfilingListener profilingListener() {
return profilingListener;
}
@@ -936,12 +936,12 @@ public class DefaultOrmQuery extends AbstractQuery implements SpiQuery {
}
@Override
- public final Mode getMode() {
+ public final Mode mode() {
return mode;
}
@Override
- public final TemporalMode getTemporalMode() {
+ public final TemporalMode temporalMode() {
return temporalMode;
}
@@ -981,7 +981,7 @@ public class DefaultOrmQuery extends AbstractQuery implements SpiQuery {
}
@Override
- public final ObjectGraphNode getParentNode() {
+ public final ObjectGraphNode parentNode() {
return parentNode;
}
@@ -1113,12 +1113,12 @@ public class DefaultOrmQuery extends AbstractQuery implements SpiQuery {
}
@Override
- public final String getNativeSql() {
+ public final String nativeSql() {
return nativeSql;
}
@Override
- public final Object getQueryPlanKey() {
+ public final Object queryPlanKey() {
return queryPlanKey;
}
@@ -1197,7 +1197,7 @@ public class DefaultOrmQuery extends AbstractQuery implements SpiQuery {
* Return the timeout.
*/
@Override
- public final int getTimeout() {
+ public final int timeout() {
return timeout;
}
@@ -1212,12 +1212,12 @@ public class DefaultOrmQuery extends AbstractQuery implements SpiQuery {
}
@Override
- public final Timestamp getVersionStart() {
+ public final Timestamp versionStart() {
return versionsStart;
}
@Override
- public final Timestamp getVersionEnd() {
+ public final Timestamp versionEnd() {
return versionsEnd;
}
@@ -1255,12 +1255,12 @@ public class DefaultOrmQuery extends AbstractQuery implements SpiQuery {
}
@Override
- public final CacheMode getUseBeanCache() {
+ public final CacheMode beanCacheMode() {
return useBeanCache;
}
@Override
- public final CacheMode getUseQueryCache() {
+ public final CacheMode queryCacheMode() {
return useQueryCache;
}
@@ -1701,7 +1701,7 @@ public class DefaultOrmQuery extends AbstractQuery implements SpiQuery {
}
@Override
- public final TableJoin getM2mIncludeJoin() {
+ public final TableJoin m2mIncludeJoin() {
return m2mIncludeJoin;
}
@@ -1744,7 +1744,7 @@ public class DefaultOrmQuery extends AbstractQuery implements SpiQuery {
}
@Override
- public final String getMapKey() {
+ public final String mapKey() {
return mapKey;
}
@@ -1769,7 +1769,7 @@ public class DefaultOrmQuery extends AbstractQuery implements SpiQuery {
}
@Override
- public final BindParams getBindParams() {
+ public final BindParams bindParams() {
return bindParams;
}
@@ -1826,17 +1826,17 @@ public class DefaultOrmQuery extends AbstractQuery implements SpiQuery {
}
@Override
- public final SpiExpressionList getHavingExpressions() {
+ public final SpiExpressionList havingExpressions() {
return havingExpressions;
}
@Override
- public final SpiExpressionList getWhereExpressions() {
+ public final SpiExpressionList whereExpressions() {
return whereExpressions;
}
@Override
- public final SpiExpressionList getTextExpression() {
+ public final SpiExpressionList textExpression() {
return textExpressions;
}
@@ -1881,7 +1881,7 @@ public class DefaultOrmQuery extends AbstractQuery implements SpiQuery {
}
@Override
- public final int getBufferFetchSizeHint() {
+ public final int bufferFetchSizeHint() {
return bufferFetchSizeHint;
}
@@ -1912,7 +1912,7 @@ public class DefaultOrmQuery extends AbstractQuery implements SpiQuery {
}
@Override
- public final ReadEvent getFutureFetchAudit() {
+ public final ReadEvent futureFetchAudit() {
return futureFetchAudit;
}
@@ -1923,7 +1923,7 @@ public class DefaultOrmQuery extends AbstractQuery implements SpiQuery {
}
@Override
- public final String getBaseTable() {
+ public final String baseTable() {
return baseTable;
}
@@ -1934,7 +1934,7 @@ public class DefaultOrmQuery extends AbstractQuery implements SpiQuery {
}
@Override
- public final String getAlias() {
+ public final String alias() {
return rootTableAlias;
}
@@ -1966,7 +1966,7 @@ public class DefaultOrmQuery extends AbstractQuery implements SpiQuery {
validation.validate(property.getProperty());
}
}
- return validation.getUnknownProperties();
+ return validation.unknownProperties();
}
final void setUpdateProperties(OrmUpdateProperties updateProperties) {
@@ -1974,12 +1974,12 @@ public class DefaultOrmQuery extends AbstractQuery implements SpiQuery {
}
@Override
- public final OrmUpdateProperties getUpdateProperties() {
+ public final OrmUpdateProperties updateProperties() {
return updateProperties;
}
@Override
- public final ProfileLocation getProfileLocation() {
+ public final ProfileLocation profileLocation() {
return profileLocation;
}
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/querydefn/DefaultOrmUpdate.java b/ebean-core/src/main/java/io/ebeaninternal/server/querydefn/DefaultOrmUpdate.java
index 3f0d306e8..c35e3adef 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/querydefn/DefaultOrmUpdate.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/querydefn/DefaultOrmUpdate.java
@@ -51,7 +51,7 @@ public final class DefaultOrmUpdate implements SpiUpdate, Serializable {
}
@Override
- public Class> getBeanType() {
+ public Class> beanType() {
return beanType;
}
@@ -59,7 +59,7 @@ public final class DefaultOrmUpdate implements SpiUpdate, Serializable {
* Return the timeout in seconds.
*/
@Override
- public int getTimeout() {
+ public int timeout() {
return timeout;
}
@@ -127,12 +127,12 @@ public final class DefaultOrmUpdate implements SpiUpdate, Serializable {
}
@Override
- public String getLabel() {
+ public String label() {
return label;
}
@Override
- public String getUpdateStatement() {
+ public String updateStatement() {
return updateStatement;
}
@@ -188,7 +188,7 @@ public final class DefaultOrmUpdate implements SpiUpdate, Serializable {
* Return the bind parameters.
*/
@Override
- public BindParams getBindParams() {
+ public BindParams bindParams() {
return bindParams;
}
@@ -203,12 +203,12 @@ public final class DefaultOrmUpdate implements SpiUpdate, Serializable {
}
@Override
- public String getBaseTable() {
+ public String baseTable() {
return baseTable;
}
@Override
- public OrmUpdateType getOrmUpdateType() {
+ public OrmUpdateType ormUpdateType() {
return type;
}
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/querydefn/DefaultUpdateQuery.java b/ebean-core/src/main/java/io/ebeaninternal/server/querydefn/DefaultUpdateQuery.java
index 2f062632d..62e385cec 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/querydefn/DefaultUpdateQuery.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/querydefn/DefaultUpdateQuery.java
@@ -19,7 +19,7 @@ public final class DefaultUpdateQuery implements UpdateQuery {
public DefaultUpdateQuery(DefaultOrmQuery query) {
this.query = query;
- this.descriptor = query.getBeanDescriptor();
+ this.descriptor = query.descriptor();
query.setUpdateProperties(values);
}
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/querydefn/OrmQueryProperties.java b/ebean-core/src/main/java/io/ebeaninternal/server/querydefn/OrmQueryProperties.java
index 98864e744..8b41ae8b0 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/querydefn/OrmQueryProperties.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/querydefn/OrmQueryProperties.java
@@ -231,7 +231,7 @@ public final class OrmQueryProperties implements Serializable {
if (filterMany != null) {
filterMany.applyRowLimits(query);
SpiExpressionList> trimPath = filterMany.trimPath(path.length() + 1);
- for (SpiExpression spiExpression : trimPath.getUnderlyingList()) {
+ for (SpiExpression spiExpression : trimPath.underlyingList()) {
query.where().add(spiExpression);
}
}
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/querydefn/OrmQuerySecondary.java b/ebean-core/src/main/java/io/ebeaninternal/server/querydefn/OrmQuerySecondary.java
index 4d2a94b1c..75372c7bc 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/querydefn/OrmQuerySecondary.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/querydefn/OrmQuerySecondary.java
@@ -24,7 +24,7 @@ final class OrmQuerySecondary implements SpiQuerySecondary {
* Return a list of path/properties that are query join loaded.
*/
@Override
- public List getQueryJoins() {
+ public List queryJoins() {
return queryJoins;
}
@@ -32,7 +32,7 @@ final class OrmQuerySecondary implements SpiQuerySecondary {
* Return the list of path/properties that are lazy loaded.
*/
@Override
- public List getLazyJoins() {
+ public List lazyJoins() {
return lazyJoins;
}
}
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/transaction/DocStoreOnlyTransaction.java b/ebean-core/src/main/java/io/ebeaninternal/server/transaction/DocStoreOnlyTransaction.java
index 55e4eb0f5..03756be48 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/transaction/DocStoreOnlyTransaction.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/transaction/DocStoreOnlyTransaction.java
@@ -30,7 +30,7 @@ public final class DocStoreOnlyTransaction extends JdbcTransaction {
}
@Override
- public Connection getInternalConnection() {
+ public Connection internalConnection() {
throw new RuntimeException("not supported on DocStoreTransaction");
}
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/transaction/ImplicitReadOnlyTransaction.java b/ebean-core/src/main/java/io/ebeaninternal/server/transaction/ImplicitReadOnlyTransaction.java
index f665662f6..d2121b316 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/transaction/ImplicitReadOnlyTransaction.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/transaction/ImplicitReadOnlyTransaction.java
@@ -80,7 +80,7 @@ final class ImplicitReadOnlyTransaction implements SpiTransaction, TxnProfileEve
}
@Override
- public long getStartNanoTime() {
+ public long startNanoTime() {
// not used on read only transaction
return startNanos;
}
@@ -101,7 +101,7 @@ final class ImplicitReadOnlyTransaction implements SpiTransaction, TxnProfileEve
}
@Override
- public String getLabel() {
+ public String label() {
return null;
}
@@ -131,7 +131,7 @@ final class ImplicitReadOnlyTransaction implements SpiTransaction, TxnProfileEve
}
@Override
- public ProfileLocation getProfileLocation() {
+ public ProfileLocation profileLocation() {
return profileLocation;
}
@@ -175,7 +175,7 @@ final class ImplicitReadOnlyTransaction implements SpiTransaction, TxnProfileEve
}
@Override
- public DocStoreMode getDocStoreMode() {
+ public DocStoreMode docStoreMode() {
return null;
}
@@ -362,7 +362,7 @@ final class ImplicitReadOnlyTransaction implements SpiTransaction, TxnProfileEve
}
@Override
- public BatchControl getBatchControl() {
+ public BatchControl batchControl() {
return null;
}
@@ -387,7 +387,7 @@ final class ImplicitReadOnlyTransaction implements SpiTransaction, TxnProfileEve
* Return the persistence context associated with this transaction.
*/
@Override
- public SpiPersistenceContext getPersistenceContext() {
+ public SpiPersistenceContext persistenceContext() {
return persistenceContext;
}
@@ -407,7 +407,7 @@ final class ImplicitReadOnlyTransaction implements SpiTransaction, TxnProfileEve
}
@Override
- public TransactionEvent getEvent() {
+ public TransactionEvent event() {
throw new IllegalStateException(notExpectedMessage);
}
@@ -448,7 +448,7 @@ final class ImplicitReadOnlyTransaction implements SpiTransaction, TxnProfileEve
* Return the transaction id.
*/
@Override
- public String getId() {
+ public String id() {
return null;
}
@@ -458,7 +458,7 @@ final class ImplicitReadOnlyTransaction implements SpiTransaction, TxnProfileEve
}
@Override
- public Object getTenantId() {
+ public Object tenantId() {
return tenantId;
}
@@ -466,7 +466,7 @@ final class ImplicitReadOnlyTransaction implements SpiTransaction, TxnProfileEve
* Return the underlying connection for internal use.
*/
@Override
- public Connection getInternalConnection() {
+ public Connection internalConnection() {
if (!active) {
throw new IllegalStateException(illegalStateMessage);
}
@@ -478,7 +478,7 @@ final class ImplicitReadOnlyTransaction implements SpiTransaction, TxnProfileEve
*/
@Override
public Connection connection() {
- return getInternalConnection();
+ return internalConnection();
}
private void deactivate() {
@@ -608,7 +608,7 @@ final class ImplicitReadOnlyTransaction implements SpiTransaction, TxnProfileEve
}
@Override
- public DocStoreTransaction getDocStoreTransaction() {
+ public DocStoreTransaction docStoreTransaction() {
throw new IllegalStateException(notExpectedMessage);
}
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/transaction/JdbcTransaction.java b/ebean-core/src/main/java/io/ebeaninternal/server/transaction/JdbcTransaction.java
index a432a54d4..92c2efb4a 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/transaction/JdbcTransaction.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/transaction/JdbcTransaction.java
@@ -136,12 +136,12 @@ class JdbcTransaction implements SpiTransaction, TxnProfileEventCodes {
}
@Override
- public final String getLabel() {
+ public final String label() {
return label;
}
@Override
- public final long getStartNanoTime() {
+ public final long startNanoTime() {
return startNanos;
}
@@ -173,7 +173,7 @@ class JdbcTransaction implements SpiTransaction, TxnProfileEventCodes {
}
@Override
- public final ProfileLocation getProfileLocation() {
+ public final ProfileLocation profileLocation() {
return profileLocation;
}
@@ -300,7 +300,7 @@ class JdbcTransaction implements SpiTransaction, TxnProfileEventCodes {
}
@Override
- public final DocStoreMode getDocStoreMode() {
+ public final DocStoreMode docStoreMode() {
return docStoreMode;
}
@@ -609,7 +609,7 @@ class JdbcTransaction implements SpiTransaction, TxnProfileEventCodes {
}
@Override
- public final BatchControl getBatchControl() {
+ public final BatchControl batchControl() {
return batchControl;
}
@@ -667,7 +667,7 @@ class JdbcTransaction implements SpiTransaction, TxnProfileEventCodes {
* Return the persistence context associated with this transaction.
*/
@Override
- public final SpiPersistenceContext getPersistenceContext() {
+ public final SpiPersistenceContext persistenceContext() {
return persistenceContext;
}
@@ -687,7 +687,7 @@ class JdbcTransaction implements SpiTransaction, TxnProfileEventCodes {
* Return the underlying TransactionEvent.
*/
@Override
- public final TransactionEvent getEvent() {
+ public final TransactionEvent event() {
queryOnly = false;
if (event == null) {
event = new TransactionEvent();
@@ -732,7 +732,7 @@ class JdbcTransaction implements SpiTransaction, TxnProfileEventCodes {
* Return the transaction id.
*/
@Override
- public final String getId() {
+ public final String id() {
return id;
}
@@ -742,7 +742,7 @@ class JdbcTransaction implements SpiTransaction, TxnProfileEventCodes {
}
@Override
- public final Object getTenantId() {
+ public final Object tenantId() {
return tenantId;
}
@@ -750,7 +750,7 @@ class JdbcTransaction implements SpiTransaction, TxnProfileEventCodes {
* Return the underlying connection for internal use.
*/
@Override
- public Connection getInternalConnection() {
+ public Connection internalConnection() {
return connection;
}
@@ -760,7 +760,7 @@ class JdbcTransaction implements SpiTransaction, TxnProfileEventCodes {
@Override
public Connection connection() {
queryOnly = false;
- return getInternalConnection();
+ return internalConnection();
}
void deactivate() {
@@ -1085,11 +1085,11 @@ class JdbcTransaction implements SpiTransaction, TxnProfileEventCodes {
@Override
public final void addModification(String tableName, boolean inserts, boolean updates, boolean deletes) {
- getEvent().add(tableName, inserts, updates, deletes);
+ event().add(tableName, inserts, updates, deletes);
}
@Override
- public final DocStoreTransaction getDocStoreTransaction() {
+ public final DocStoreTransaction docStoreTransaction() {
if (docStoreTxn == null) {
queryOnly = false;
docStoreTxn = manager.createDocStoreTransaction(docStoreBatchSize);
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/transaction/JtaTransactionManager.java b/ebean-core/src/main/java/io/ebeaninternal/server/transaction/JtaTransactionManager.java
index c4027ff04..f4b15b77e 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/transaction/JtaTransactionManager.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/transaction/JtaTransactionManager.java
@@ -89,7 +89,7 @@ public final class JtaTransactionManager implements ExternalTransactionManager {
SpiTransaction currentEbeanTransaction = scope.inScope();
if (currentEbeanTransaction != null) {
// NOT expecting this so log WARNING
- log.log(WARNING, "JTA Transaction - no current txn BUT using current Ebean one {0}", currentEbeanTransaction.getId());
+ log.log(WARNING, "JTA Transaction - no current txn BUT using current Ebean one {0}", currentEbeanTransaction.id());
return currentEbeanTransaction;
}
@@ -182,25 +182,25 @@ public final class JtaTransactionManager implements ExternalTransactionManager {
public void afterCompletion(int status) {
switch (status) {
case Status.STATUS_COMMITTED:
- log.log(DEBUG, "Jta Txn [{0}] committed", transaction.getId());
+ log.log(DEBUG, "Jta Txn [{0}] committed", transaction.id());
transaction.postCommit();
// Remove this transaction object as it is completed
transactionManager.scope().clearExternal();
break;
case Status.STATUS_ROLLEDBACK:
- log.log(DEBUG, "Jta Txn [{0}] rollback", transaction.getId());
+ log.log(DEBUG, "Jta Txn [{0}] rollback", transaction.id());
transaction.postRollback(null);
// Remove this transaction object as it is completed
transactionManager.scope().clearExternal();
break;
default:
- log.log(DEBUG, "Jta Txn [{0}] status:{1}", transaction.getId(), status);
+ log.log(DEBUG, "Jta Txn [{0}] status:{1}", transaction.id(), status);
}
// No matter the completion status of the transaction, we release the connection we got from the pool.
- JdbcClose.close(transaction.getInternalConnection());
+ JdbcClose.close(transaction.internalConnection());
}
}
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/transaction/NoTransaction.java b/ebean-core/src/main/java/io/ebeaninternal/server/transaction/NoTransaction.java
index b0ee596df..76228f1f1 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/transaction/NoTransaction.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/transaction/NoTransaction.java
@@ -41,7 +41,7 @@ final class NoTransaction implements SpiTransaction {
}
@Override
- public String getLabel() {
+ public String label() {
return null;
}
@@ -56,7 +56,7 @@ final class NoTransaction implements SpiTransaction {
}
@Override
- public long getStartNanoTime() {
+ public long startNanoTime() {
// not used
return System.nanoTime();
}
@@ -168,7 +168,7 @@ final class NoTransaction implements SpiTransaction {
}
@Override
- public String getId() {
+ public String id() {
return null;
}
@@ -178,7 +178,7 @@ final class NoTransaction implements SpiTransaction {
}
@Override
- public DocStoreMode getDocStoreMode() {
+ public DocStoreMode docStoreMode() {
return null;
}
@@ -317,7 +317,7 @@ final class NoTransaction implements SpiTransaction {
}
@Override
- public TransactionEvent getEvent() {
+ public TransactionEvent event() {
return null;
}
@@ -332,7 +332,7 @@ final class NoTransaction implements SpiTransaction {
}
@Override
- public BatchControl getBatchControl() {
+ public BatchControl batchControl() {
return null;
}
@@ -341,7 +341,7 @@ final class NoTransaction implements SpiTransaction {
}
@Override
- public SpiPersistenceContext getPersistenceContext() {
+ public SpiPersistenceContext persistenceContext() {
return null;
}
@@ -350,7 +350,7 @@ final class NoTransaction implements SpiTransaction {
}
@Override
- public Connection getInternalConnection() {
+ public Connection internalConnection() {
return null;
}
@@ -398,7 +398,7 @@ final class NoTransaction implements SpiTransaction {
}
@Override
- public DocStoreTransaction getDocStoreTransaction() {
+ public DocStoreTransaction docStoreTransaction() {
return null;
}
@@ -407,7 +407,7 @@ final class NoTransaction implements SpiTransaction {
}
@Override
- public Object getTenantId() {
+ public Object tenantId() {
return null;
}
@@ -434,7 +434,7 @@ final class NoTransaction implements SpiTransaction {
}
@Override
- public ProfileLocation getProfileLocation() {
+ public ProfileLocation profileLocation() {
return null;
}
}
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/transaction/PostCommitProcessing.java b/ebean-core/src/main/java/io/ebeaninternal/server/transaction/PostCommitProcessing.java
index f36dd7ede..ae9cd2ba2 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/transaction/PostCommitProcessing.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/transaction/PostCommitProcessing.java
@@ -46,8 +46,8 @@ final class PostCommitProcessing {
this.txnDocStoreMode = DocStoreMode.IGNORE;
this.txnDocStoreBatchSize = 0;
this.event = event;
- this.deleteByIdMap = event.getDeleteByIdMap();
- this.listenerNotify = event.getListenerNotify();
+ this.deleteByIdMap = event.deleteByIdMap();
+ this.listenerNotify = event.listenerNotify();
this.remoteTransactionEvent = createRemoteTransactionEvent();
}
@@ -58,11 +58,11 @@ final class PostCommitProcessing {
this.clusterManager = clusterManager;
this.manager = manager;
this.serverName = manager.name();
- this.txnDocStoreMode = transaction.getDocStoreMode();
+ this.txnDocStoreMode = transaction.docStoreMode();
this.txnDocStoreBatchSize = transaction.getDocStoreBatchSize();
- this.event = transaction.getEvent();
- this.deleteByIdMap = event.getDeleteByIdMap();
- this.listenerNotify = event.getListenerNotify();
+ this.event = transaction.event();
+ this.deleteByIdMap = event.deleteByIdMap();
+ this.listenerNotify = event.listenerNotify();
this.remoteTransactionEvent = createRemoteTransactionEvent();
}
@@ -149,7 +149,7 @@ final class PostCommitProcessing {
request.notifyLocalPersistListener();
}
}
- TransactionEventTable eventTables = event.getEventTables();
+ TransactionEventTable eventTables = event.eventTables();
if (eventTables != null && !eventTables.isEmpty()) {
BulkEventListenerMap map = manager.bulkEventListenerMap();
for (TableIUD tableIUD : eventTables.values()) {
@@ -183,7 +183,7 @@ final class PostCommitProcessing {
if (deleteByIdMap != null) {
remoteTransactionEvent.setDeleteByIdMap(deleteByIdMap);
}
- TransactionEventTable eventTables = event.getEventTables();
+ TransactionEventTable eventTables = event.eventTables();
if (eventTables != null && !eventTables.isEmpty()) {
for (TableIUD tableIUD : eventTables.values()) {
remoteTransactionEvent.addTableIUD(tableIUD);
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/transaction/SavepointTransaction.java b/ebean-core/src/main/java/io/ebeaninternal/server/transaction/SavepointTransaction.java
index b9e3f8b8a..85ef1e8a9 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/transaction/SavepointTransaction.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/transaction/SavepointTransaction.java
@@ -30,7 +30,7 @@ final class SavepointTransaction extends SpiTransactionProxy {
SavepointTransaction(SpiTransaction transaction, TransactionManager manager) throws SQLException {
this.manager = manager;
this.transaction = transaction;
- this.connection = transaction.getInternalConnection();
+ this.connection = transaction.internalConnection();
this.savepoint = connection.setSavepoint();
if (transaction.isLogSql()) {
int savepointId = manager.isSupportsSavepointId() ? savepoint.getSavepointId() : 0;
@@ -41,7 +41,7 @@ final class SavepointTransaction extends SpiTransactionProxy {
}
@Override
- public TransactionEvent getEvent() {
+ public TransactionEvent event() {
if (event == null) {
event = new TransactionEvent();
}
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/transaction/TransactionFactory.java b/ebean-core/src/main/java/io/ebeaninternal/server/transaction/TransactionFactory.java
index dcd6e73ea..f8eeba38a 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/transaction/TransactionFactory.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/transaction/TransactionFactory.java
@@ -35,7 +35,7 @@ abstract class TransactionFactory {
*/
final SpiTransaction setIsolationLevel(SpiTransaction t, boolean explicit, int isolationLevel) {
if (isolationLevel > -1) {
- Connection connection = t.getInternalConnection();
+ Connection connection = t.internalConnection();
try {
connection.setTransactionIsolation(isolationLevel);
} catch (SQLException e) {
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/transaction/TransactionManager.java b/ebean-core/src/main/java/io/ebeaninternal/server/transaction/TransactionManager.java
index 442a25ff8..bfaf8cfb5 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/transaction/TransactionManager.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/transaction/TransactionManager.java
@@ -334,7 +334,7 @@ public class TransactionManager implements SpiTransactionManager {
public final void externalModification(TransactionEventTable tableEvent) {
SpiTransaction t = active();
if (t != null) {
- t.getEvent().add(tableEvent);
+ t.event().add(tableEvent);
} else {
externalModificationEvent(tableEvent);
}
diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/util/BindParamsParser.java b/ebean-core/src/main/java/io/ebeaninternal/server/util/BindParamsParser.java
index d08d2a136..bda557746 100644
--- a/ebean-core/src/main/java/io/ebeaninternal/server/util/BindParamsParser.java
+++ b/ebean-core/src/main/java/io/ebeaninternal/server/util/BindParamsParser.java
@@ -61,7 +61,7 @@ public final class BindParamsParser {
*/
private String parseSql() {
if (params.isSameBindHash()) {
- String preparedSql = params.getPreparedSql();
+ String preparedSql = params.preparedSql();
if (preparedSql != null && !preparedSql.isEmpty()) {
// the sql has already been parsed and positionedParameters are set in order
return preparedSql;
@@ -117,7 +117,7 @@ public final class BindParamsParser {
Param param = extractNamedParam(paramName);
orderedList.appendSql(sql.substring(startPos, nameParamStart));
- Object inValue = param.getInValue();
+ Object inValue = param.inValue();
if (inValue instanceof Collection>) {
addCollectionParams(orderedList, param, (Collection>) inValue);
} else {
@@ -139,7 +139,7 @@ public final class BindParamsParser {
if (paramName.startsWith(ENCRYPTKEY_PREFIX)) {
param = addEncryptKeyParam(paramName);
} else {
- param = params.getParameter(paramName);
+ param = params.parameter(paramName);
}
if (param == null) {
throw new PersistenceException("Bind value is not set or null for " + paramName + " in " + sql);
diff --git a/ebean-core/src/test/java/io/ebeaninternal/server/core/DefaultServer_createOrmQueryRequestTest.java b/ebean-core/src/test/java/io/ebeaninternal/server/core/DefaultServer_createOrmQueryRequestTest.java
index aedbb29a9..460a532de 100644
--- a/ebean-core/src/test/java/io/ebeaninternal/server/core/DefaultServer_createOrmQueryRequestTest.java
+++ b/ebean-core/src/test/java/io/ebeaninternal/server/core/DefaultServer_createOrmQueryRequestTest.java
@@ -27,7 +27,7 @@ public class DefaultServer_createOrmQueryRequestTest {
}
OrmQueryDetail detail(Query query) {
- return queryRequest(query).query().getDetail();
+ return queryRequest(query).query().detail();
}
@Test
@@ -124,7 +124,7 @@ public class DefaultServer_createOrmQueryRequestTest {
.fetch("details");
OrmQueryRequest queryRequest = queryRequest(query);
- OrmQueryDetail detail = queryRequest.query().getDetail();
+ OrmQueryDetail detail = queryRequest.query().detail();
assertThat(detail.getFetchPaths()).containsExactly("customer", "details");
}
@@ -138,7 +138,7 @@ public class DefaultServer_createOrmQueryRequestTest {
.where().eq("customer.name", "rob").query();
OrmQueryRequest queryRequest = queryRequest(query);
- OrmQueryDetail detail = queryRequest.query().getDetail();
+ OrmQueryDetail detail = queryRequest.query().detail();
assertThat(detail.getFetchPaths()).containsExactly("details");
}
@@ -152,7 +152,7 @@ public class DefaultServer_createOrmQueryRequestTest {
.fetchQuery("details");
OrmQueryRequest queryRequest = queryRequest(query);
- OrmQueryDetail detail = queryRequest.query().getDetail();
+ OrmQueryDetail detail = queryRequest.query().detail();
assertThat(detail.getFetchPaths()).containsExactly("customer");
}
@@ -166,7 +166,7 @@ public class DefaultServer_createOrmQueryRequestTest {
.fetchQuery("details");
OrmQueryRequest queryRequest = queryRequest(query);
- OrmQueryDetail detail = queryRequest.query().getDetail();
+ OrmQueryDetail detail = queryRequest.query().detail();
assertThat(detail.getFetchPaths()).containsExactly("customer");
}
@@ -180,7 +180,7 @@ public class DefaultServer_createOrmQueryRequestTest {
.fetch("details", FetchConfig.ofLazy());
OrmQueryRequest queryRequest = queryRequest(query);
- OrmQueryDetail detail = queryRequest.query().getDetail();
+ OrmQueryDetail detail = queryRequest.query().detail();
assertThat(detail.getFetchPaths()).containsExactly("customer");
}
@@ -194,7 +194,7 @@ public class DefaultServer_createOrmQueryRequestTest {
.fetchLazy("details");
OrmQueryRequest queryRequest = queryRequest(query);
- OrmQueryDetail detail = queryRequest.query().getDetail();
+ OrmQueryDetail detail = queryRequest.query().detail();
assertThat(detail.getFetchPaths()).containsExactly("customer");
}
@@ -209,7 +209,7 @@ public class DefaultServer_createOrmQueryRequestTest {
.fetch("details.product");
OrmQueryRequest queryRequest = queryRequest(query);
- OrmQueryDetail detail = queryRequest.query().getDetail();
+ OrmQueryDetail detail = queryRequest.query().detail();
assertThat(detail.getFetchPaths()).containsExactly("customer");
}
@@ -224,7 +224,7 @@ public class DefaultServer_createOrmQueryRequestTest {
.fetch("customer", "name");
OrmQueryRequest queryRequest = queryRequest(query);
- OrmQueryDetail detail = queryRequest.query().getDetail();
+ OrmQueryDetail detail = queryRequest.query().detail();
assertThat(detail.getFetchPaths()).containsExactly("details", "details.product", "customer");
}
@@ -239,7 +239,7 @@ public class DefaultServer_createOrmQueryRequestTest {
.fetch("customer", "name");
OrmQueryRequest queryRequest = queryRequest(query);
- OrmQueryDetail detail = queryRequest.query().getDetail();
+ OrmQueryDetail detail = queryRequest.query().detail();
assertThat(detail.getFetchPaths()).containsExactly("customer");
}
@@ -254,7 +254,7 @@ public class DefaultServer_createOrmQueryRequestTest {
.fetch("customer.contacts"); // second many path
OrmQueryRequest queryRequest = queryRequest(query);
- OrmQueryDetail detail = queryRequest.query().getDetail();
+ OrmQueryDetail detail = queryRequest.query().detail();
assertThat(detail.getFetchPaths()).containsExactly("details", "details.product", "customer");
}
@@ -270,7 +270,7 @@ public class DefaultServer_createOrmQueryRequestTest {
.fetch("customer.contacts"); // many path
OrmQueryRequest queryRequest = queryRequest(query);
- OrmQueryDetail detail = queryRequest.query().getDetail();
+ OrmQueryDetail detail = queryRequest.query().detail();
assertThat(detail.getFetchPaths()).containsExactly("customer");
}
@@ -286,7 +286,7 @@ public class DefaultServer_createOrmQueryRequestTest {
.fetch("customer.contacts"); // many path
OrmQueryRequest queryRequest = queryRequest(query);
- OrmQueryDetail detail = queryRequest.query().getDetail();
+ OrmQueryDetail detail = queryRequest.query().detail();
assertThat(detail.getFetchPaths()).containsExactly("customer");
}
@@ -303,7 +303,7 @@ public class DefaultServer_createOrmQueryRequestTest {
.query();
OrmQueryRequest queryRequest = queryRequest(query);
- OrmQueryDetail detail = queryRequest.query().getDetail();
+ OrmQueryDetail detail = queryRequest.query().detail();
assertThat(detail.getFetchPaths()).containsExactly("details", "details.product", "customer");
}
@@ -320,7 +320,7 @@ public class DefaultServer_createOrmQueryRequestTest {
.query();
OrmQueryRequest queryRequest = queryRequest(query);
- OrmQueryDetail detail = queryRequest.query().getDetail();
+ OrmQueryDetail detail = queryRequest.query().detail();
assertThat(detail.getFetchPaths()).containsExactly("customer", "customer.contacts");
}
@@ -337,7 +337,7 @@ public class DefaultServer_createOrmQueryRequestTest {
.query();
OrmQueryRequest queryRequest = queryRequest(query);
- OrmQueryDetail detail = queryRequest.query().getDetail();
+ OrmQueryDetail detail = queryRequest.query().detail();
assertThat(detail.getFetchPaths()).containsExactly("customer", "customer.contacts");
}
diff --git a/ebean-core/src/test/java/io/ebeaninternal/server/expression/PrepareDocNestedTest.java b/ebean-core/src/test/java/io/ebeaninternal/server/expression/PrepareDocNestedTest.java
index c9be84436..fbe4866e3 100644
--- a/ebean-core/src/test/java/io/ebeaninternal/server/expression/PrepareDocNestedTest.java
+++ b/ebean-core/src/test/java/io/ebeaninternal/server/expression/PrepareDocNestedTest.java
@@ -25,7 +25,7 @@ public class PrepareDocNestedTest extends BaseTest {
DefaultExpressionList> exp = (DefaultExpressionList>) where;
PrepareDocNested.prepare(exp, getBeanDescriptor(Order.class));
- List underlyingList = exp.getUnderlyingList();
+ List underlyingList = exp.underlyingList();
assertEquals(underlyingList.size(), 1);
assertEquals(exp.allDocNestedPath, "details");
}
@@ -43,7 +43,7 @@ public class PrepareDocNestedTest extends BaseTest {
DefaultExpressionList> exp = (DefaultExpressionList>) where;
PrepareDocNested.prepare(exp, getBeanDescriptor(Order.class));
- List underlyingList = exp.getUnderlyingList();
+ List underlyingList = exp.underlyingList();
assertEquals(underlyingList.size(), 2);
assertEquals(exp.allDocNestedPath, "details");
}
@@ -62,7 +62,7 @@ public class PrepareDocNestedTest extends BaseTest {
DefaultExpressionList> exp = (DefaultExpressionList>) where;
PrepareDocNested.prepare(exp, getBeanDescriptor(Order.class));
- List underlyingList = exp.getUnderlyingList();
+ List underlyingList = exp.underlyingList();
assertEquals(underlyingList.size(), 2);
assertNull(exp.allDocNestedPath);
@@ -84,12 +84,12 @@ public class PrepareDocNestedTest extends BaseTest {
DefaultExpressionList> exp = (DefaultExpressionList>) where;
PrepareDocNested.prepare(exp, getBeanDescriptor(Order.class));
- List underlyingList = exp.getUnderlyingList();
+ List underlyingList = exp.underlyingList();
assertEquals(underlyingList.size(), 1);
assertNull(exp.allDocNestedPath);
JunctionExpression> junction = (JunctionExpression>) underlyingList.get(0);
- List junctionUnderlying = junction.exprList.getUnderlyingList();
+ List junctionUnderlying = junction.exprList.underlyingList();
JunctionExpression> nestedNestedPath = (JunctionExpression>) junctionUnderlying.get(1);
assertEquals(nestedNestedPath.exprList.allDocNestedPath, "details");
}
@@ -107,7 +107,7 @@ public class PrepareDocNestedTest extends BaseTest {
DefaultExpressionList> exp = (DefaultExpressionList>) where;
PrepareDocNested.prepare(exp, getBeanDescriptor(Order.class));
- List underlyingList = exp.getUnderlyingList();
+ List underlyingList = exp.underlyingList();
assertEquals(underlyingList.size(), 2);
assertNull(exp.allDocNestedPath);
@@ -135,7 +135,7 @@ public class PrepareDocNestedTest extends BaseTest {
DefaultExpressionList> exp = (DefaultExpressionList>) where;
PrepareDocNested.prepare(exp, getBeanDescriptor(Order.class));
- List underlyingList = exp.getUnderlyingList();
+ List underlyingList = exp.underlyingList();
assertEquals(underlyingList.size(), 5);
assertNull(exp.allDocNestedPath);
diff --git a/ebean-core/src/test/java/io/ebeaninternal/server/querydefn/DefaultOrmQueryTest.java b/ebean-core/src/test/java/io/ebeaninternal/server/querydefn/DefaultOrmQueryTest.java
index 6563886dc..cd61df7db 100644
--- a/ebean-core/src/test/java/io/ebeaninternal/server/querydefn/DefaultOrmQueryTest.java
+++ b/ebean-core/src/test/java/io/ebeaninternal/server/querydefn/DefaultOrmQueryTest.java
@@ -20,20 +20,20 @@ public class DefaultOrmQueryTest extends BaseExpressionTest {
DefaultOrmQuery q1 = (DefaultOrmQuery) DB.find(Customer.class)
.forUpdate().where().eq("id", 42).query();
- assertThat(q1.getUseBeanCache()).isSameAs(CacheMode.OFF);
+ assertThat(q1.beanCacheMode()).isSameAs(CacheMode.OFF);
}
@Test
public void checkForId_when_eqId_then_translatedTo_setId() {
DefaultOrmQuery q1 = (DefaultOrmQuery) DB.find(Order.class).where().eq("id", 42).query();
- assertThat(q1.getWhereExpressions()).isNotNull();
+ assertThat(q1.whereExpressions()).isNotNull();
assertThat(q1.getId()).isNull();
assertThat(q1.isFindById()).isTrue();
assertThat(q1.getId()).isEqualTo(42);
- assertThat(q1.getWhereExpressions()).isNull();
+ assertThat(q1.whereExpressions()).isNull();
}
@Test
diff --git a/ebean-querybean/src/test/java/io/ebean/typequery/PBooleanTest.java b/ebean-querybean/src/test/java/io/ebean/typequery/PBooleanTest.java
index 365e5dc86..40b754357 100644
--- a/ebean-querybean/src/test/java/io/ebean/typequery/PBooleanTest.java
+++ b/ebean-querybean/src/test/java/io/ebean/typequery/PBooleanTest.java
@@ -85,7 +85,7 @@ public class PBooleanTest {
private SimpleExpression getExpression(QCustomer customer) {
DefaultExpressionList where = (DefaultExpressionList)customer.query().where();
- return (SimpleExpression)where.getUnderlyingList().get(0);
+ return (SimpleExpression)where.underlyingList().get(0);
}
diff --git a/ebean-spring-txn/src/main/java/io/ebean/spring/txn/SpringJdbcTransactionManager.java b/ebean-spring-txn/src/main/java/io/ebean/spring/txn/SpringJdbcTransactionManager.java
index 8375acf7c..482222ab5 100644
--- a/ebean-spring-txn/src/main/java/io/ebean/spring/txn/SpringJdbcTransactionManager.java
+++ b/ebean-spring-txn/src/main/java/io/ebean/spring/txn/SpringJdbcTransactionManager.java
@@ -145,12 +145,12 @@ public final class SpringJdbcTransactionManager implements ExternalTransactionMa
public void afterCompletion(int status) {
switch (status) {
case STATUS_COMMITTED:
- log.log(DEBUG, "Spring Txn [{0}] committed", transaction.getId());
+ log.log(DEBUG, "Spring Txn [{0}] committed", transaction.id());
transaction.postCommit();
break;
case STATUS_ROLLED_BACK:
- log.log(DEBUG, "Spring Txn [{0}] rollback", transaction.getId());
+ log.log(DEBUG, "Spring Txn [{0}] rollback", transaction.id());
transaction.postRollback(null);
break;
diff --git a/ebean-test/src/test/java/io/ebean/xtest/internal/api/BindParamsTest.java b/ebean-test/src/test/java/io/ebean/xtest/internal/api/BindParamsTest.java
index beea174a2..dba70b434 100644
--- a/ebean-test/src/test/java/io/ebean/xtest/internal/api/BindParamsTest.java
+++ b/ebean-test/src/test/java/io/ebean/xtest/internal/api/BindParamsTest.java
@@ -17,7 +17,7 @@ public class BindParamsTest {
List ids = Arrays.asList("1", "2", "3");
bindParams.setParameter("ids", ids);
- BindParams.Param param = bindParams.getParameter("ids");
+ BindParams.Param param = bindParams.parameter("ids");
assertEquals(3, param.queryBindCount());
assertFalse(bindParams.isSameBindHash());
bindParams.updateHash();
diff --git a/ebean-test/src/test/java/io/ebean/xtest/plugin/BeanTypeTest.java b/ebean-test/src/test/java/io/ebean/xtest/plugin/BeanTypeTest.java
index b5a136a2a..d08874051 100644
--- a/ebean-test/src/test/java/io/ebean/xtest/plugin/BeanTypeTest.java
+++ b/ebean-test/src/test/java/io/ebean/xtest/plugin/BeanTypeTest.java
@@ -166,7 +166,7 @@ public class BeanTypeTest {
SpiQuery orderQuery = (SpiQuery) db.find(Order.class);
beanType(Order.class).docStore().applyPath(orderQuery);
- OrmQueryDetail detail = orderQuery.getDetail();
+ OrmQueryDetail detail = orderQuery.detail();
assertThat(detail.getChunk("customer", false).getIncluded()).containsExactly("id", "name");
}
diff --git a/ebean-test/src/test/java/org/tests/basic/TestPersistenceContext.java b/ebean-test/src/test/java/org/tests/basic/TestPersistenceContext.java
index 98b746240..2f338368b 100644
--- a/ebean-test/src/test/java/org/tests/basic/TestPersistenceContext.java
+++ b/ebean-test/src/test/java/org/tests/basic/TestPersistenceContext.java
@@ -165,7 +165,7 @@ public class TestPersistenceContext extends BaseTestCase {
lastBean[0] = customer;
});
- SpiPersistenceContext pc = ((SpiTransaction) txn).getPersistenceContext();
+ SpiPersistenceContext pc = ((SpiTransaction) txn).persistenceContext();
// the first 100 customers using strong references
assertThat(pc.toString()).contains("Customer=size:5000 (4900 weak)");
assertThat(pc.toString()).contains("Order=size:100 (100 weak)");
diff --git a/ebean-test/src/test/java/org/tests/batchinsert/TestBatchInsertFlush.java b/ebean-test/src/test/java/org/tests/batchinsert/TestBatchInsertFlush.java
index 0ba734092..f0506ed58 100644
--- a/ebean-test/src/test/java/org/tests/batchinsert/TestBatchInsertFlush.java
+++ b/ebean-test/src/test/java/org/tests/batchinsert/TestBatchInsertFlush.java
@@ -70,7 +70,7 @@ public class TestBatchInsertFlush extends BaseTestCase {
// detail
assertThat(sql.get(3)).contains("insert into t_detail_with_other_namexxxyy");
- assertThat(((SpiTransaction)transaction).getLabel()).isEqualTo("TestBatchInsertFlush.no_cascade");
+ assertThat(((SpiTransaction)transaction).label()).isEqualTo("TestBatchInsertFlush.no_cascade");
} finally {
transaction.end();
diff --git a/ebean-test/src/test/java/org/tests/batchinsert/TestBatchOnCascadeExceptionHandling.java b/ebean-test/src/test/java/org/tests/batchinsert/TestBatchOnCascadeExceptionHandling.java
index d9501c731..5750e30a1 100644
--- a/ebean-test/src/test/java/org/tests/batchinsert/TestBatchOnCascadeExceptionHandling.java
+++ b/ebean-test/src/test/java/org/tests/batchinsert/TestBatchOnCascadeExceptionHandling.java
@@ -96,7 +96,7 @@ public class TestBatchOnCascadeExceptionHandling extends BaseTestCase {
Assertions.fail("PersistenceException expected");
} catch (PersistenceException e) {
assertThat(txn.isBatchMode()).as("batch mode").isFalse(); // should not have changed
- BatchControl bc = ((SpiTransaction) txn).getBatchControl();
+ BatchControl bc = ((SpiTransaction) txn).batchControl();
assertThat(bc == null || bc.isEmpty()).as("batch emtpy").isTrue();
} finally {
txn.end();
diff --git a/ebean-test/src/test/java/org/tests/query/TestAutofetchTuneWithJoin.java b/ebean-test/src/test/java/org/tests/query/TestAutofetchTuneWithJoin.java
index 3b9874f4b..9364d2217 100644
--- a/ebean-test/src/test/java/org/tests/query/TestAutofetchTuneWithJoin.java
+++ b/ebean-test/src/test/java/org/tests/query/TestAutofetchTuneWithJoin.java
@@ -51,7 +51,7 @@ public class TestAutofetchTuneWithJoin extends BaseTestCase {
}
SpiQuery> sq = (SpiQuery>) q;
- ObjectGraphNode parentNode = sq.getParentNode();
+ ObjectGraphNode parentNode = sq.parentNode();
ObjectGraphOrigin origin = parentNode.origin();
assertThat(origin).isNotNull();
// MetaAutoFetchStatistic metaAutoFetchStatistic =
diff --git a/ebean-test/src/test/java/org/tests/query/TestQueryFindEach.java b/ebean-test/src/test/java/org/tests/query/TestQueryFindEach.java
index 95bebbe25..ee63a1818 100644
--- a/ebean-test/src/test/java/org/tests/query/TestQueryFindEach.java
+++ b/ebean-test/src/test/java/org/tests/query/TestQueryFindEach.java
@@ -123,7 +123,7 @@ public class TestQueryFindEach extends BaseTestCase {
.findList();
SpiTransaction spiTxn = (SpiTransaction) transaction;
- PersistenceContext pc = spiTxn.getPersistenceContext();
+ PersistenceContext pc = spiTxn.persistenceContext();
assertThat(pc.size(Customer.class)).isEqualTo(customerList.size());
LoggedSql.start();
diff --git a/ebean-test/src/test/java/org/tests/rawsql/TestInsertSqlLogging.java b/ebean-test/src/test/java/org/tests/rawsql/TestInsertSqlLogging.java
index cdfc0af5b..512458441 100644
--- a/ebean-test/src/test/java/org/tests/rawsql/TestInsertSqlLogging.java
+++ b/ebean-test/src/test/java/org/tests/rawsql/TestInsertSqlLogging.java
@@ -119,7 +119,7 @@ public class TestInsertSqlLogging extends BaseTestCase {
update.execute();
transaction.commit();
- assertFalse(((SpiTransaction) transaction).getEvent().getEventTables().isEmpty());
+ assertFalse(((SpiTransaction) transaction).event().eventTables().isEmpty());
} finally {
transaction.end();
diff --git a/ebean-test/src/test/java/org/tests/transaction/TestDeleteFromPersistenceContext.java b/ebean-test/src/test/java/org/tests/transaction/TestDeleteFromPersistenceContext.java
index 936babbd2..0d10b7e23 100644
--- a/ebean-test/src/test/java/org/tests/transaction/TestDeleteFromPersistenceContext.java
+++ b/ebean-test/src/test/java/org/tests/transaction/TestDeleteFromPersistenceContext.java
@@ -29,12 +29,12 @@ public class TestDeleteFromPersistenceContext extends BaseTestCase {
// same instance from PersistenceContext
assertSame(bean2, bean3);
- Object bean4 = transaction.getPersistenceContext().get(EBasicVer.class, bean.getId());
+ Object bean4 = transaction.persistenceContext().get(EBasicVer.class, bean.getId());
assertSame(bean2, bean4);
DB.delete(bean2);
- Object bean5 = transaction.getPersistenceContext().get(EBasicVer.class, bean.getId());
+ Object bean5 = transaction.persistenceContext().get(EBasicVer.class, bean.getId());
assertNull(bean5);
DB.commitTransaction();
diff --git a/ebean-test/src/test/java/org/tests/transaction/TestNestedSubTransaction.java b/ebean-test/src/test/java/org/tests/transaction/TestNestedSubTransaction.java
index f1b1cb16e..1952a0715 100644
--- a/ebean-test/src/test/java/org/tests/transaction/TestNestedSubTransaction.java
+++ b/ebean-test/src/test/java/org/tests/transaction/TestNestedSubTransaction.java
@@ -108,13 +108,13 @@ public class TestNestedSubTransaction extends BaseTestCase {
server.save(bean);
- TransactionEvent event0 = ((SpiTransaction) txn0).getEvent();
+ TransactionEvent event0 = ((SpiTransaction) txn0).event();
try (Transaction txn1 = server.beginTransaction()) {
bean.setName("updateNested");
server.save(bean);
- TransactionEvent event1 = ((SpiTransaction) txn1).getEvent();
+ TransactionEvent event1 = ((SpiTransaction) txn1).event();
assertThat(event1).isNotSameAs(event0);
try (Transaction txn2 = server.beginTransaction()) {
diff --git a/ebean-test/src/test/java/org/tests/transaction/TestPersistContextClear.java b/ebean-test/src/test/java/org/tests/transaction/TestPersistContextClear.java
index 06e2cb826..ff656fc2e 100644
--- a/ebean-test/src/test/java/org/tests/transaction/TestPersistContextClear.java
+++ b/ebean-test/src/test/java/org/tests/transaction/TestPersistContextClear.java
@@ -28,7 +28,7 @@ public class TestPersistContextClear extends BaseTestCase {
try {
ResetBasicData.createOrderCustAndOrder("testPc");
SpiTransaction spiTxn = (SpiTransaction) t;
- PersistenceContext pc = spiTxn.getPersistenceContext();
+ PersistenceContext pc = spiTxn.persistenceContext();
// no orders or customers in the PC
assertEquals(0, pc.size(Order.class));
diff --git a/ebean-test/src/test/java/org/tests/transparentpersist/TestTransparentPersist.java b/ebean-test/src/test/java/org/tests/transparentpersist/TestTransparentPersist.java
index 52c323884..8d5e87505 100644
--- a/ebean-test/src/test/java/org/tests/transparentpersist/TestTransparentPersist.java
+++ b/ebean-test/src/test/java/org/tests/transparentpersist/TestTransparentPersist.java
@@ -341,7 +341,7 @@ public class TestTransparentPersist extends BaseTestCase {
private List getDirtyBeansFromPersistenceContext(Transaction transaction) {
final SpiBeanTypeManager mgr = Mockito.mock(SpiBeanTypeManager.class);
- return ((SpiTransaction)transaction).getPersistenceContext().dirtyBeans(mgr);
+ return ((SpiTransaction)transaction).persistenceContext().dirtyBeans(mgr);
}
}