#2359 - Rename internal methods - SpiEbeanServer

This commit is contained in:
rbygrave committed 2021-09-08 15:25:18 +12:00
1 parent d389ac680f
commit 93ff2ef2e4
50 files changed
+128 -129

No files matched your search

@@ -63,7 +63,7 @@ public interface SpiEbeanServer extends SpiServer, ExtendedServer, EbeanServer,
/**
* Return the PersistenceContextScope to use defined at query or server level.
*/
PersistenceContextScope getPersistenceContextScope(SpiQuery<?> query);
PersistenceContextScope persistenceContextScope(SpiQuery<?> query);
/**
* Clear the query execution statistics.
@@ -73,32 +73,32 @@ public interface SpiEbeanServer extends SpiServer, ExtendedServer, EbeanServer,
/**
* Return the transaction manager.
*/
SpiTransactionManager getTransactionManager();
SpiTransactionManager transactionManager();
/**
* Return all the descriptors.
*/
List<BeanDescriptor<?>> getBeanDescriptors();
List<BeanDescriptor<?>> descriptors();
/**
* Return the BeanDescriptor for a given type of bean.
*/
<T> BeanDescriptor<T> getBeanDescriptor(Class<T> type);
<T> BeanDescriptor<T> descriptor(Class<T> type);
/**
* Return BeanDescriptor using it's unique id.
*/
BeanDescriptor<?> getBeanDescriptorById(String className);
BeanDescriptor<?> descriptorById(String className);
/**
* Return BeanDescriptor using it's unique doc store queueId.
*/
BeanDescriptor<?> getBeanDescriptorByQueueId(String queueId);
BeanDescriptor<?> descriptorByQueueId(String queueId);
/**
* Return BeanDescriptors mapped to this table.
*/
List<BeanDescriptor<?>> getBeanDescriptors(String tableName);
List<BeanDescriptor<?>> descriptors(String tableName);
/**
* Process committed changes from another framework.
@@ -170,7 +170,7 @@ public interface SpiEbeanServer extends SpiServer, ExtendedServer, EbeanServer,
/**
* Return the default batch size for lazy loading.
*/
int getLazyLoadBatchSize();
int lazyLoadBatchSize();
/**
* Return true if the type is known as an Entity or Xml type or a List Set or
@@ -181,18 +181,18 @@ public interface SpiEbeanServer extends SpiServer, ExtendedServer, EbeanServer,
/**
* Return the ReadAuditLogger to use for logging all read audit events.
*/
ReadAuditLogger getReadAuditLogger();
ReadAuditLogger readAuditLogger();
/**
* Return the ReadAuditPrepare used to populate the read audit events with
* user context information (user id, user ip address etc).
*/
ReadAuditPrepare getReadAuditPrepare();
ReadAuditPrepare readAuditPrepare();
/**
* Return the DataTimeZone to use when reading/writing timestamps via JDBC.
*/
DataTimeZone getDataTimeZone();
DataTimeZone dataTimeZone();
/**
* Check for slow query event.
@@ -122,6 +122,6 @@ public abstract class BeanRequest {
* Return the DataTimeZone to use.
*/
public DataTimeZone dataTimeZone() {
return server.getDataTimeZone();
return server.dataTimeZone();
}
}
@@ -54,7 +54,7 @@ final class DefaultBeanLoader {
private void loadManyInternal(EntityBean parentBean, String propertyName, Transaction t, boolean refresh, boolean onlyIds) {
EntityBeanIntercept ebi = parentBean._ebean_getIntercept();
PersistenceContext pc = ebi.getPersistenceContext();
BeanDescriptor<?> parentDesc = server.getBeanDescriptor(parentBean.getClass());
BeanDescriptor<?> parentDesc = server.descriptor(parentBean.getClass());
BeanPropertyAssocMany<?> many = (BeanPropertyAssocMany<?>) parentDesc.beanProperty(propertyName);
BeanCollection<?> beanCollection = null;
ExpressionList<?> filterMany = null;
@@ -176,7 +176,7 @@ final class DefaultBeanLoader {
pc = null;
}
BeanDescriptor<?> desc = server.getBeanDescriptor(bean.getClass());
BeanDescriptor<?> desc = server.descriptor(bean.getClass());
if (EntityType.EMBEDDED == desc.entityType()) {
// lazy loading on an embedded bean property
EntityBean embeddedOwner = (EntityBean) ebi.getEmbeddedOwner();
@@ -295,7 +295,7 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
}
@Override
public int getLazyLoadBatchSize() {
public int lazyLoadBatchSize() {
return lazyLoadBatchSize;
}
@@ -320,7 +320,7 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
}
@Override
public DataTimeZone getDataTimeZone() {
public DataTimeZone dataTimeZone() {
return dataTimeZone;
}
@@ -365,12 +365,12 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
}
@Override
public ReadAuditPrepare getReadAuditPrepare() {
public ReadAuditPrepare readAuditPrepare() {
return readAuditPrepare;
}
@Override
public ReadAuditLogger getReadAuditLogger() {
public ReadAuditLogger readAuditLogger() {
return readAuditLogger;
}
@@ -595,7 +595,7 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
if (a == null) {
return null;
}
BeanDescriptor<?> desc = getBeanDescriptor(a.getClass());
BeanDescriptor<?> desc = descriptor(a.getClass());
return DiffHelp.diff(a, b, desc);
}
@@ -628,7 +628,7 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
public void truncate(Class<?>... types) {
List<String> tableNames = new ArrayList<>();
for (Class<?> type : types) {
tableNames.add(getBeanDescriptor(type).baseTable());
tableNames.add(descriptor(type).baseTable());
}
truncate(tableNames.toArray(new String[0]));
}
@@ -659,7 +659,7 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
*/
@Override
public void clearQueryStatistics() {
for (BeanDescriptor<?> desc : getBeanDescriptors()) {
for (BeanDescriptor<?> desc : descriptors()) {
desc.clearQueryStatistics();
}
}
@@ -674,7 +674,7 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
*/
@Override
public <T> T createEntityBean(Class<T> type) {
return getBeanDescriptor(type).createBean();
return descriptor(type).createBean();
}
/**
@@ -691,7 +691,7 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
if (id == null) {
throw new NullPointerException("The id is null");
}
BeanDescriptor desc = getBeanDescriptor(type);
BeanDescriptor desc = descriptor(type);
id = desc.convertId(id);
PersistenceContext pc = null;
SpiTransaction t = transactionManager.getActive();
@@ -852,7 +852,7 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
@Override
public Object nextId(Class<?> beanType) {
BeanDescriptor<?> desc = getBeanDescriptor(beanType);
BeanDescriptor<?> desc = descriptor(beanType);
return desc.nextId(null);
}
@@ -871,7 +871,7 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
}
// use first bean in the list as the correct type
Class<T> beanType = (Class<T>) list.get(0).getClass();
BeanDescriptor<T> beanDescriptor = getBeanDescriptor(beanType);
BeanDescriptor<T> beanDescriptor = descriptor(beanType);
if (beanDescriptor == null) {
throw new PersistenceException("BeanDescriptor not found, is [" + beanType + "] an entity bean?");
}
@@ -880,7 +880,7 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
@Override
public <T> Set<String> validateQuery(Query<T> query) {
BeanDescriptor<T> beanDescriptor = getBeanDescriptor(query.getBeanType());
BeanDescriptor<T> beanDescriptor = descriptor(query.getBeanType());
if (beanDescriptor == null) {
throw new PersistenceException("BeanDescriptor not found, is [" + query.getBeanType() + "] an entity bean?");
}
@@ -889,7 +889,7 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
@Override
public <T> Filter<T> filter(Class<T> beanType) {
BeanDescriptor<T> desc = getBeanDescriptor(beanType);
BeanDescriptor<T> desc = descriptor(beanType);
if (desc == null) {
String m = beanType.getName() + " is NOT an Entity Bean registered with this server?";
throw new PersistenceException(m);
@@ -899,7 +899,7 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
@Override
public <T> CsvReader<T> createCsvReader(Class<T> beanType) {
BeanDescriptor<T> descriptor = getBeanDescriptor(beanType);
BeanDescriptor<T> descriptor = descriptor(beanType);
if (descriptor == null) {
throw new NullPointerException("BeanDescriptor for " + beanType.getName() + " not found");
}
@@ -923,7 +923,7 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
@Override
public void merge(Object bean, MergeOptions options, Transaction transaction) {
BeanDescriptor<?> desc = getBeanDescriptor(bean.getClass());
BeanDescriptor<?> desc = descriptor(bean.getClass());
if (desc == null) {
throw new PersistenceException(bean.getClass().getName() + " is NOT an Entity Bean registered with this server?");
}
@@ -937,7 +937,7 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
@Override
public <T> Query<T> findNative(Class<T> beanType, String nativeSql) {
BeanDescriptor<T> desc = getBeanDescriptor(beanType);
BeanDescriptor<T> desc = descriptor(beanType);
if (desc == null) {
throw new PersistenceException(beanType.getName() + " is NOT an Entity Bean registered with this server?");
}
@@ -948,7 +948,7 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
@Override
public <T> Query<T> createNamedQuery(Class<T> beanType, String namedQuery) {
BeanDescriptor<T> desc = getBeanDescriptor(beanType);
BeanDescriptor<T> desc = descriptor(beanType);
if (desc == null) {
throw new PersistenceException(beanType.getName() + " is NOT an Entity Bean registered with this server?");
}
@@ -974,7 +974,7 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
@Override
public <T> DefaultOrmQuery<T> createQuery(Class<T> beanType) {
BeanDescriptor<T> desc = getBeanDescriptor(beanType);
BeanDescriptor<T> desc = descriptor(beanType);
if (desc == null) {
throw new PersistenceException(beanType.getName() + " is NOT an Entity Bean registered with this server?");
}
@@ -983,7 +983,7 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
@Override
public <T> Update<T> createUpdate(Class<T> beanType, String ormUpdate) {
BeanDescriptor<?> desc = getBeanDescriptor(beanType);
BeanDescriptor<?> desc = descriptor(beanType);
if (desc == null) {
String m = beanType.getName() + " is NOT an Entity Bean registered with this server?";
throw new PersistenceException(m);
@@ -1134,14 +1134,14 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
* Return true if transactions PersistenceContext should be used.
*/
private <T> boolean useTransactionPersistenceContext(SpiQuery<T> query) {
return PersistenceContextScope.TRANSACTION == getPersistenceContextScope(query);
return PersistenceContextScope.TRANSACTION == persistenceContextScope(query);
}
/**
* Return the PersistenceContextScope to use defined at query or server level.
*/
@Override
public PersistenceContextScope getPersistenceContextScope(SpiQuery<?> query) {
public PersistenceContextScope persistenceContextScope(SpiQuery<?> query) {
PersistenceContextScope scope = query.getPersistenceContextScope();
return (scope != null) ? scope : defaultPersistenceContextScope;
}
@@ -2048,7 +2048,7 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
* Return all the BeanDescriptors.
*/
@Override
public List<BeanDescriptor<?>> getBeanDescriptors() {
public List<BeanDescriptor<?>> descriptors() {
return beanDescriptorManager.getBeanDescriptorList();
}
@@ -2056,7 +2056,7 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
* Return the transaction manager.
*/
@Override
public SpiTransactionManager getTransactionManager() {
public SpiTransactionManager transactionManager() {
return transactionManager;
}
@@ -2075,13 +2075,13 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
@Override
public boolean isSupportedType(java.lang.reflect.Type genericType) {
TypeInfo typeInfo = ParamTypeHelper.getTypeInfo(genericType);
return typeInfo != null && getBeanDescriptor(typeInfo.getBeanType()) != null;
return typeInfo != null && descriptor(typeInfo.getBeanType()) != null;
}
@Override
public Object beanId(Object bean, Object id) {
EntityBean eb = checkEntityBean(bean);
BeanDescriptor<?> desc = getBeanDescriptor(bean.getClass());
BeanDescriptor<?> desc = descriptor(bean.getClass());
if (desc == null) {
throw new PersistenceException(bean.getClass().getName() + " is NOT an Entity Bean registered with this server?");
}
@@ -2091,7 +2091,7 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
@Override
public Object beanId(Object bean) {
EntityBean eb = checkEntityBean(bean);
BeanDescriptor<?> desc = getBeanDescriptor(bean.getClass());
BeanDescriptor<?> desc = descriptor(bean.getClass());
if (desc == null) {
throw new PersistenceException(bean.getClass().getName() + " is NOT an Entity Bean registered with this server?");
}
@@ -2102,7 +2102,7 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
* Return the BeanDescriptor for a given type of bean.
*/
@Override
public <T> BeanDescriptor<T> getBeanDescriptor(Class<T> beanClass) {
public <T> BeanDescriptor<T> descriptor(Class<T> beanClass) {
return beanDescriptorManager.getBeanDescriptor(beanClass);
}
@@ -2110,7 +2110,7 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
* Return the BeanDescriptor's for a given table name.
*/
@Override
public List<BeanDescriptor<?>> getBeanDescriptors(String tableName) {
public List<BeanDescriptor<?>> descriptors(String tableName) {
return beanDescriptorManager.getBeanDescriptors(tableName);
}
@@ -2119,7 +2119,7 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
*/
@Override
public List<? extends BeanType<?>> beanTypes() {
return getBeanDescriptors();
return descriptors();
}
/**
@@ -2132,11 +2132,11 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
@Override
public BeanType<?> beanTypeForQueueId(String queueId) {
return getBeanDescriptorByQueueId(queueId);
return descriptorByQueueId(queueId);
}
@Override
public BeanDescriptor<?> getBeanDescriptorByQueueId(String queueId) {
public BeanDescriptor<?> descriptorByQueueId(String queueId) {
return beanDescriptorManager.getBeanDescriptorByQueueId(queueId);
}
@@ -2145,14 +2145,14 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
*/
@Override
public <T> BeanType<T> beanType(Class<T> beanType) {
return getBeanDescriptor(beanType);
return descriptor(beanType);
}
/**
* Return the BeanDescriptor using its class name.
*/
@Override
public BeanDescriptor<?> getBeanDescriptorById(String beanClassName) {
public BeanDescriptor<?> descriptorById(String beanClassName) {
return beanDescriptorManager.getBeanDescriptorByClassName(beanClassName);
}
@@ -2278,7 +2278,7 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
@Override
public Set<Property> checkUniqueness(Object bean, Transaction transaction) {
EntityBean entityBean = checkEntityBean(bean);
BeanDescriptor<?> beanDesc = getBeanDescriptor(entityBean.getClass());
BeanDescriptor<?> beanDesc = descriptor(entityBean.getClass());
BeanProperty idProperty = beanDesc.idProperty();
// if the ID of the Property is null we are unable to check uniqueness
if (idProperty == null) {
@@ -66,7 +66,7 @@ public final class DtoQueryRequest<T> extends AbstractSqlQueryRequest {
@Override
protected void setResultSet(ResultSet resultSet, Object queryPlanKey) throws SQLException {
this.resultSet = resultSet;
this.dataReader = new RsetDataReader(server.getDataTimeZone(), resultSet);
this.dataReader = new RsetDataReader(server.dataTimeZone(), resultSet);
obtainPlan(queryPlanKey);
}
@@ -325,7 +325,7 @@ public final class OrmQueryRequest<T> extends BeanRequest implements SpiOrmQuery
if (ctx != null) return ctx;
// determine the scope (from the query and then server)
PersistenceContextScope scope = server.getPersistenceContextScope(query);
PersistenceContextScope scope = server.persistenceContextScope(query);
if (scope == PersistenceContextScope.QUERY || t == null) {
return new DefaultPersistenceContext();
}
@@ -745,7 +745,7 @@ public final class OrmQueryRequest<T> extends BeanRequest implements SpiOrmQuery
*/
public int lazyLoadBatchSize() {
int batchSize = query.getLazyLoadBatchSize();
return (batchSize > 0) ? batchSize : server.getLazyLoadBatchSize();
return (batchSize > 0) ? batchSize : server.lazyLoadBatchSize();
}
/**
@@ -759,14 +759,14 @@ public class BeanDescriptor<T> implements BeanType<T>, STreeType, SpiBeanType {
* Return the ReadAuditLogger for logging read audit events.
*/
public ReadAuditLogger readAuditLogger() {
return ebeanServer.getReadAuditLogger();
return ebeanServer.readAuditLogger();
}
/**
* Return the ReadAuditPrepare for preparing read audit events prior to logging.
*/
private ReadAuditPrepare readAuditPrepare() {
return ebeanServer.getReadAuditPrepare();
return ebeanServer.readAuditPrepare();
}
public boolean isChangeLog() {
@@ -175,7 +175,7 @@ public final class DefaultPersister implements Persister {
public <T> List<T> draftRestore(Query<T> query, Transaction transaction) {
Class<T> beanType = query.getBeanType();
BeanDescriptor<T> desc = server.getBeanDescriptor(beanType);
BeanDescriptor<T> desc = server.descriptor(beanType);
DraftHandler<T> draftHandler = new DraftHandler<>(desc, transaction);
@@ -220,7 +220,7 @@ public final class DefaultPersister implements Persister {
public <T> List<T> publish(Query<T> query, Transaction transaction) {
Class<T> beanType = query.getBeanType();
BeanDescriptor<T> desc = server.getBeanDescriptor(beanType);
BeanDescriptor<T> desc = server.descriptor(beanType);
DraftHandler<T> draftHandler = new DraftHandler<>(desc, transaction);
@@ -86,7 +86,7 @@ public class CQueryPlan implements SpiQueryPlan {
*/
CQueryPlan(OrmQueryRequest<?> request, SqlLimitResponse sqlRes, SqlTree sqlTree, boolean rawSql, String logWhereSql) {
this.server = request.server();
this.dataTimeZone = server.getDataTimeZone();
this.dataTimeZone = server.dataTimeZone();
this.beanType = request.descriptor().type();
this.planKey = request.queryPlanKey();
SpiQuery<?> query = request.query();
@@ -111,7 +111,7 @@ public class CQueryPlan implements SpiQueryPlan {
*/
CQueryPlan(OrmQueryRequest<?> request, String sql, SqlTree sqlTree, String logWhereSql) {
this.server = request.server();
this.dataTimeZone = server.getDataTimeZone();
this.dataTimeZone = server.dataTimeZone();
this.beanType = request.descriptor().type();
SpiQuery<?> query = request.query();
this.profileLocation = query.getProfileLocation();
@@ -425,7 +425,7 @@ public final class DJsonContext implements SpiJsonContext {
* Return the BeanDescriptor for the given bean type.
*/
private <T> BeanDescriptor<T> getDescriptor(Class<T> beanType) {
BeanDescriptor<T> d = server.getBeanDescriptor(beanType);
BeanDescriptor<T> d = server.descriptor(beanType);
if (d == null) {
throw new RuntimeException("No BeanDescriptor found for " + beanType);
}
@@ -600,7 +600,7 @@ public final class WriteJson implements SpiJsonWriter {
}
private <T> BeanDescriptor<T> getDescriptor(Class<T> cls) {
BeanDescriptor<T> d = server.getBeanDescriptor(cls);
BeanDescriptor<T> d = server.descriptor(cls);
if (d == null) {
throw new RuntimeException("No BeanDescriptor found for " + cls);
}
@@ -47,7 +47,7 @@ public final class BeanPersistIds implements BinaryWritable {
public static BeanPersistIds readBinaryMessage(SpiEbeanServer server, BinaryReadContext input) throws IOException {
BeanDescriptor<?> desc = server.getBeanDescriptorById(input.readUTF());
BeanDescriptor<?> desc = server.descriptorById(input.readUTF());
BeanPersistIds bp = new BeanPersistIds(desc);
bp.read(input);
return bp;