package io.ebean.config; import com.fasterxml.jackson.core.JsonFactory; import io.avaje.config.Config; import io.ebean.*; import io.ebean.annotation.*; import io.ebean.cache.ServerCachePlugin; import io.ebean.config.dbplatform.DatabasePlatform; import io.ebean.config.dbplatform.DbEncrypt; import io.ebean.config.dbplatform.DbType; import io.ebean.config.dbplatform.IdType; import io.ebean.datasource.DataSourceConfig; import io.ebean.event.*; import io.ebean.event.changelog.ChangeLogListener; import io.ebean.event.changelog.ChangeLogPrepare; import io.ebean.event.changelog.ChangeLogRegister; import io.ebean.event.readaudit.ReadAuditLogger; import io.ebean.event.readaudit.ReadAuditPrepare; import io.ebean.meta.MetricNamingMatch; import io.ebean.util.StringHelper; import javax.persistence.EnumType; import javax.sql.DataSource; import java.time.Clock; import java.time.ZonedDateTime; import java.time.format.DateTimeFormatter; import java.util.*; import java.util.function.Function; /** * The configuration used for creating a Database. *

* Used to programmatically construct an Database and optionally register it * with the DB singleton. *

* If you just use DB thout this programmatic configuration Ebean will read * the application.properties file and take the configuration from there. This usually * includes searching the class path and automatically registering any entity * classes and listeners etc. *

{@code
 *
 * DatabaseConfig config = new DatabaseConfig();
 *
 * // read the ebean.properties and load
 * // those settings into this DatabaseConfig object
 * config.loadFromProperties();
 *
 * // explicitly register the entity beans to avoid classpath scanning
 * config.addClass(Customer.class);
 * config.addClass(User.class);
 *
 * Database db = DatabaseFactory.create(config);
 *
 * }
* *

* Note that DatabaseConfigProvider provides a standard Java ServiceLoader mechanism that can * be used to apply configuration to the DatabaseConfig. * * @author emcgreal * @author rbygrave * @see DatabaseFactory */ public class DatabaseConfig { /** * The Database name. */ private String name = "db"; /** * Typically configuration type objects that are passed by this DatabaseConfig * to plugins. For example - IgniteConfiguration passed to Ignite plugin. */ private final Map serviceObject = new HashMap<>(); private ContainerConfig containerConfig; /** * The underlying properties that were used during configuration. */ private Properties properties; /** * The resource directory. */ private String resourceDirectory; /** * Set to true to register this Database with the DB singleton. */ private boolean register = true; /** * Set to true if this is the default/primary database. */ private boolean defaultServer = true; /** * Set this to true to disable class path search. */ private boolean disableClasspathSearch; private TenantMode tenantMode = TenantMode.NONE; private String tenantPartitionColumn = "tenant_id"; private CurrentTenantProvider currentTenantProvider; private TenantDataSourceProvider tenantDataSourceProvider; private TenantSchemaProvider tenantSchemaProvider; private TenantCatalogProvider tenantCatalogProvider; /** * When true will load entity classes via EntityClassRegister. *

* NB: EntityClassRegister implementations are generated by querybean generator. * Having this on and registering entity classes means we don't need to manually * write that code or use classpath scanning to find entity classes. */ private boolean loadModuleInfo = true; /** * Interesting classes such as entities, embedded, ScalarTypes, * Listeners, Finders, Controllers, AttributeConverters etc. */ private Set> classes = new HashSet<>(); /** * The packages that are searched for interesting classes. Only used when * classes is empty/not explicitly specified. */ private List packages = new ArrayList<>(); /** * Configuration for the ElasticSearch integration. */ private DocStoreConfig docStoreConfig = new DocStoreConfig(); /** * Set to true when the Database only uses Document store. */ private boolean docStoreOnly; /** * This is used to populate @WhoCreated, @WhoModified and * support other audit features (who executed a query etc). */ private CurrentUserProvider currentUserProvider; /** * Config controlling the AutoTune behaviour. */ private AutoTuneConfig autoTuneConfig = new AutoTuneConfig(); /** * The JSON format used for DateTime types. Default to millis. */ private JsonConfig.DateTime jsonDateTime = JsonConfig.DateTime.ISO8601; /** * The JSON format used for Date types. Default to millis. */ private JsonConfig.Date jsonDate = JsonConfig.Date.ISO8601; /** * For writing JSON specify if null values or empty collections should be excluded. * By default all values are included. */ private JsonConfig.Include jsonInclude = JsonConfig.Include.ALL; /** * The default mode used for {@code @DbJson} with Jackson ObjectMapper. */ private MutationDetection jsonMutationDetection = MutationDetection.HASH; /** * The database platform name. Used to imply a DatabasePlatform to use. */ private String databasePlatformName; /** * The database platform. */ private DatabasePlatform databasePlatform; /** * JDBC fetchSize hint when using findList. Defaults to 0 leaving it up to the JDBC driver. */ private int jdbcFetchSizeFindList; /** * JDBC fetchSize hint when using findEach/findEachWhile. Defaults to 100. Note that this does * not apply to MySql as that gets special treatment (forward only etc). */ private int jdbcFetchSizeFindEach = 100; /** * Suffix appended to the base table to derive the view that contains the union * of the base table and the history table in order to support asOf queries. */ private String asOfViewSuffix = "_with_history"; /** * Column used to support history and 'As of' queries. This column is a timestamp range * or equivalent. */ private String asOfSysPeriod = "sys_period"; /** * Suffix appended to the base table to derive the view that contains the union * of the base table and the history table in order to support asOf queries. */ private String historyTableSuffix = "_history"; /** * When true explicit transactions beans that have been made dirty will be * automatically persisted via update on flush. */ private boolean autoPersistUpdates; /** * Use for transaction scoped batch mode. */ private PersistBatch persistBatch = PersistBatch.NONE; /** * Use for cascade persist JDBC batch mode. INHERIT means use the platform default * which is ALL except for SQL Server where it is NONE (as getGeneratedKeys isn't * supported on SQL Server with JDBC batch). */ private PersistBatch persistBatchOnCascade = PersistBatch.INHERIT; private int persistBatchSize = 20; private EnumType defaultEnumType = EnumType.ORDINAL; private boolean disableLazyLoading; /** * The default batch size for lazy loading */ private int lazyLoadBatchSize = 10; /** * The default batch size for 'query joins'. */ private int queryBatchSize = 100; private boolean eagerFetchLobs; /** * Timezone used to get/set Timestamp values via JDBC. */ private String dataTimeZone; private boolean ddlGenerate; private boolean ddlRun; private boolean ddlExtra = true; private boolean ddlCreateOnly; private String ddlInitSql; private String ddlSeedSql; private String ddlHeader; /** * Mode used to check non-null columns added via migration have a default value specified etc. */ private boolean ddlStrictMode = true; /** * Comma and equals delimited key/value placeholders to replace in DDL scripts. */ private String ddlPlaceholders; /** * Map of key/value placeholders to replace in DDL scripts. */ private Map ddlPlaceholderMap; private boolean runMigration; /** * When true L2 bean cache use is skipped after a write has occurred on a transaction. */ private boolean skipCacheAfterWrite = true; private boolean useJtaTransactionManager; /** * The external transaction manager (like Spring). */ private ExternalTransactionManager externalTransactionManager; private boolean skipDataSourceCheck; /** * The data source (if programmatically provided). */ private DataSource dataSource; /** * The read only data source (can be null). */ private DataSource readOnlyDataSource; /** * The data source config. */ private DataSourceConfig dataSourceConfig = new DataSourceConfig(); /** * When true create a read only DataSource using readOnlyDataSourceConfig defaulting values from dataSourceConfig. * I believe this will default to true in some future release (as it has a nice performance benefit). *

* autoReadOnlyDataSource is an unfortunate name for this config option but I haven't come up with a better one. */ private boolean autoReadOnlyDataSource; /** * Optional configuration for a read only data source. */ private DataSourceConfig readOnlyDataSourceConfig = new DataSourceConfig(); /** * Optional - the database schema that should be used to own the tables etc. */ private String dbSchema; /** * The ClassLoadConfig used to detect Joda, Java8, Jackson etc and create plugin instances given a className. */ private ClassLoadConfig classLoadConfig = new ClassLoadConfig(); /** * The naming convention. */ private NamingConvention namingConvention = new UnderscoreNamingConvention(); /** * Behaviour of updates in JDBC batch to by default include all properties. */ private boolean updateAllPropertiesInBatch; /** * Database platform configuration. */ private PlatformConfig platformConfig = new PlatformConfig(); /** * The UUID version to use. */ private UuidVersion uuidVersion = UuidVersion.VERSION4; /** * The UUID state file (for Version 1 UUIDs). By default, the file is created in * ${HOME}/.ebean/${servername}-uuid.state */ private String uuidStateFile; /** * The node id (=mac address) for Version 1 UUIDs. There are several options: *

* Note: It is possible that multiple servers are sharing the same state file as * long as they are in the same JVM/ClassLoader scope. In this case it is * recommended to use the same uuidNodeId configuration. * * If you have multiple servers in different JVMs, do not share the state * files! */ private String uuidNodeId; /** * The clock used for setting the timestamps (e.g. @UpdatedTimestamp) on objects. */ private Clock clock = Clock.systemUTC(); private List idGenerators = new ArrayList<>(); private List findControllers = new ArrayList<>(); private List persistControllers = new ArrayList<>(); private List postLoaders = new ArrayList<>(); private List postConstructListeners = new ArrayList<>(); private List persistListeners = new ArrayList<>(); private List queryAdapters = new ArrayList<>(); private final List bulkTableEventListeners = new ArrayList<>(); private final List configStartupListeners = new ArrayList<>(); /** * By default inserts are included in the change log. */ private boolean changeLogIncludeInserts = true; private ChangeLogPrepare changeLogPrepare; private ChangeLogListener changeLogListener; private ChangeLogRegister changeLogRegister; private boolean changeLogAsync = true; private ReadAuditLogger readAuditLogger; private ReadAuditPrepare readAuditPrepare; private EncryptKeyManager encryptKeyManager; private EncryptDeployManager encryptDeployManager; private Encryptor encryptor; private DbEncrypt dbEncrypt; private boolean dbOffline; private ServerCachePlugin serverCachePlugin; /** * The default PersistenceContextScope used if one is not explicitly set on a query. */ private PersistenceContextScope persistenceContextScope = PersistenceContextScope.TRANSACTION; private JsonFactory jsonFactory; private boolean localTimeWithNanos; private boolean durationWithNanos; private int maxCallStack = 5; private boolean transactionRollbackOnChecked = true; // configuration for the background executor service (thread pool) private int backgroundExecutorSchedulePoolSize = 1; private int backgroundExecutorShutdownSecs = 30; private BackgroundExecutorWrapper backgroundExecutorWrapper = new MdcBackgroundExecutorWrapper(); // defaults for the L2 bean caching private int cacheMaxSize = 10000; private int cacheMaxIdleTime = 600; private int cacheMaxTimeToLive = 60 * 60 * 6; // defaults for the L2 query caching private int queryCacheMaxSize = 1000; private int queryCacheMaxIdleTime = 600; private int queryCacheMaxTimeToLive = 60 * 60 * 6; private Object objectMapper; /** * Set to true if you want eq("someProperty", null) to generate 1=1 rather than "is null" sql expression. */ private boolean expressionEqualsWithNullAsNoop; /** * Set to true to use native ILIKE expression (if support by database platform / like Postgres). */ private boolean expressionNativeIlike; private String jodaLocalTimeMode; /** * Time to live for query plans - defaults to 5 minutes. */ private int queryPlanTTLSeconds = 60 * 5; /** * Set to true to globally disable L2 caching (typically for performance testing). */ private boolean disableL2Cache; private String enabledL2Regions; /** * Set to true to effectively disable L2 cache plugins. */ private boolean localOnlyL2Cache; /** * Should the javax.validation.constraints.NotNull enforce a notNull column in DB. * If set to false, use io.ebean.annotation.NotNull or Column(nullable=true). */ private boolean useValidationNotNull = true; /** * Generally we want to perform L2 cache notification in the background and not impact * the performance of executing transactions. */ private boolean notifyL2CacheInForeground; /** * Set to true to enable bind capture required for query plan capture. */ private boolean queryPlanEnable; /** * The default threshold in micros for collecting query plans. */ private long queryPlanThresholdMicros = Long.MAX_VALUE; /** * Set to true to enable automatic periodic query plan capture. */ private boolean queryPlanCapture; private long queryPlanCapturePeriodSecs = 60 * 10; // 10 minutes private long queryPlanCaptureMaxTimeMillis = 10_000; // 10 seconds private int queryPlanCaptureMaxCount = 10; private QueryPlanListener queryPlanListener; /** * The time in millis used to determine when a query is alerted for being slow. */ private long slowQueryMillis; /** * The listener for processing slow query events. */ private SlowQueryListener slowQueryListener; private ProfilingConfig profilingConfig = new ProfilingConfig(); /** * The mappingLocations for searching xml mapping. */ private List mappingLocations = new ArrayList<>(); /** * When true we do not need explicit GeneratedValue mapping. */ private boolean idGeneratorAutomatic = true; private boolean dumpMetricsOnShutdown; private String dumpMetricsOptions; private Function metricNaming = MetricNamingMatch.INSTANCE; /** * Construct a Database Configuration for programmatically creating an Database. */ public DatabaseConfig() { } /** * Get the clock used for setting the timestamps (e.g. @UpdatedTimestamp) on objects. */ public Clock getClock() { return clock; } /** * Set the clock used for setting the timestamps (e.g. @UpdatedTimestamp) on objects. */ public void setClock(final Clock clock) { this.clock = clock; } /** * Return the slow query time in millis. */ public long getSlowQueryMillis() { return slowQueryMillis; } /** * Set the slow query time in millis. */ public void setSlowQueryMillis(long slowQueryMillis) { this.slowQueryMillis = slowQueryMillis; } /** * Return the slow query event listener. */ public SlowQueryListener getSlowQueryListener() { return slowQueryListener; } /** * Set the slow query event listener. */ public void setSlowQueryListener(SlowQueryListener slowQueryListener) { this.slowQueryListener = slowQueryListener; } /** * Put a service object into configuration such that it can be used by ebean or a plugin. *

* For example, put IgniteConfiguration in to be passed to the Ignite plugin. */ public void putServiceObject(String key, Object configObject) { serviceObject.put(key, configObject); } /** * Put a service object into configuration such that it can be used by ebean or a plugin. *

* For example, put IgniteConfiguration in to be passed to the Ignite plugin. * You can also override some SPI objects that should be used for that Database. Currently, the following * objects are possible. *

    *
  • DataSourceAlertFactory (e.g. add different alert factories for different ebean instances)
  • *
  • DocStoreFactory
  • *
  • SlowQueryListener (e.g. add custom query listener for a certain ebean instance)
  • *
  • ServerCacheNotifyPlugin
  • *
*/ public void putServiceObject(Class iface, T configObject) { serviceObject.put(serviceObjectKey(iface), configObject); } /** * Return the service object given the key. */ public Object getServiceObject(String key) { return serviceObject.get(key); } /** * Put a service object into configuration such that it can be used by ebean or a plugin. * *
{@code
   *
   *   JedisPool jedisPool = ..
   *
   *   config.putServiceObject(jedisPool);
   *
   * }
*/ public void putServiceObject(Object configObject) { String key = serviceObjectKey(configObject); serviceObject.put(key, configObject); } private String serviceObjectKey(Object configObject) { return serviceObjectKey(configObject.getClass()); } private String serviceObjectKey(Class cls) { String simpleName = cls.getSimpleName(); return Character.toLowerCase(simpleName.charAt(0)) + simpleName.substring(1); } /** * Used by ebean or plugins to obtain service objects. * *
{@code
   *
   *   JedisPool jedisPool = config.getServiceObject(JedisPool.class);
   *
   * }
* * @param cls The type of the service object to obtain * @return The service object given the class type */ @SuppressWarnings("unchecked") public

P getServiceObject(Class

cls) { return (P) serviceObject.get(serviceObjectKey(cls)); } /** * Return the Jackson JsonFactory to use. *

* If not set a default implementation will be used. */ public JsonFactory getJsonFactory() { return jsonFactory; } /** * Set the Jackson JsonFactory to use. *

* If not set a default implementation will be used. */ public void setJsonFactory(JsonFactory jsonFactory) { this.jsonFactory = jsonFactory; } /** * Return the JSON format used for DateTime types. */ public JsonConfig.DateTime getJsonDateTime() { return jsonDateTime; } /** * Set the JSON format to use for DateTime types. */ public void setJsonDateTime(JsonConfig.DateTime jsonDateTime) { this.jsonDateTime = jsonDateTime; } /** * Return the JSON format used for Date types. */ public JsonConfig.Date getJsonDate() { return jsonDate; } /** * Set the JSON format to use for Date types. */ public void setJsonDate(JsonConfig.Date jsonDate) { this.jsonDate = jsonDate; } /** * Return the JSON include mode used when writing JSON. */ public JsonConfig.Include getJsonInclude() { return jsonInclude; } /** * Set the JSON include mode used when writing JSON. *

* Set to NON_NULL or NON_EMPTY to suppress nulls or null and empty collections respectively. */ public void setJsonInclude(JsonConfig.Include jsonInclude) { this.jsonInclude = jsonInclude; } /** * Return the default MutableDetection to use with {@code @DbJson} using Jackson. * * @see DbJson#mutationDetection() */ public MutationDetection getJsonMutationDetection() { return jsonMutationDetection; } /** * Set the default MutableDetection to use with {@code @DbJson} using Jackson. * * @see DbJson#mutationDetection() */ public void setJsonMutationDetection(MutationDetection jsonMutationDetection) { this.jsonMutationDetection = jsonMutationDetection; } /** * Return the name of the Database. */ public String getName() { return name; } /** * Set the name of the Database. */ public void setName(String name) { this.name = name; } /** * Return the container / clustering configuration. *

* The container holds all the Database instances and provides clustering communication * services to all the Database instances. */ public ContainerConfig getContainerConfig() { return containerConfig; } /** * Set the container / clustering configuration. *

* The container holds all the Database instances and provides clustering communication * services to all the Database instances. */ public void setContainerConfig(ContainerConfig containerConfig) { this.containerConfig = containerConfig; } /** * Return true if this server should be registered with the Ebean singleton * when it is created. *

* By default this is set to true. */ public boolean isRegister() { return register; } /** * Set to false if you do not want this server to be registered with the Ebean * singleton when it is created. *

* By default this is set to true. */ public void setRegister(boolean register) { this.register = register; } /** * Return true if this server should be registered as the "default" server * with the Ebean singleton. *

* This is only used when {@link #setRegister(boolean)} is also true. */ public boolean isDefaultServer() { return defaultServer; } /** * Set false if you do not want this Database to be registered as the "default" database * with the DB singleton. *

* This is only used when {@link #setRegister(boolean)} is also true. */ public void setDefaultServer(boolean defaultServer) { this.defaultServer = defaultServer; } /** * Return the CurrentUserProvider. This is used to populate @WhoCreated, @WhoModified and * support other audit features (who executed a query etc). */ public CurrentUserProvider getCurrentUserProvider() { return currentUserProvider; } /** * Set the CurrentUserProvider. This is used to populate @WhoCreated, @WhoModified and * support other audit features (who executed a query etc). */ public void setCurrentUserProvider(CurrentUserProvider currentUserProvider) { this.currentUserProvider = currentUserProvider; } /** * Return the tenancy mode used. */ public TenantMode getTenantMode() { return tenantMode; } /** * Set the tenancy mode to use. */ public void setTenantMode(TenantMode tenantMode) { this.tenantMode = tenantMode; } /** * Return the column name used for TenantMode.PARTITION. */ public String getTenantPartitionColumn() { return tenantPartitionColumn; } /** * Set the column name used for TenantMode.PARTITION. */ public void setTenantPartitionColumn(String tenantPartitionColumn) { this.tenantPartitionColumn = tenantPartitionColumn; } /** * Return the current tenant provider. */ public CurrentTenantProvider getCurrentTenantProvider() { return currentTenantProvider; } /** * Set the current tenant provider. */ public void setCurrentTenantProvider(CurrentTenantProvider currentTenantProvider) { this.currentTenantProvider = currentTenantProvider; } /** * Return the tenancy datasource provider. */ public TenantDataSourceProvider getTenantDataSourceProvider() { return tenantDataSourceProvider; } /** * Set the tenancy datasource provider. */ public void setTenantDataSourceProvider(TenantDataSourceProvider tenantDataSourceProvider) { this.tenantDataSourceProvider = tenantDataSourceProvider; } /** * Return the tenancy schema provider. */ public TenantSchemaProvider getTenantSchemaProvider() { return tenantSchemaProvider; } /** * Set the tenancy schema provider. */ public void setTenantSchemaProvider(TenantSchemaProvider tenantSchemaProvider) { this.tenantSchemaProvider = tenantSchemaProvider; } /** * Return the tenancy catalog provider. */ public TenantCatalogProvider getTenantCatalogProvider() { return tenantCatalogProvider; } /** * Set the tenancy catalog provider. */ public void setTenantCatalogProvider(TenantCatalogProvider tenantCatalogProvider) { this.tenantCatalogProvider = tenantCatalogProvider; } /** * Return true if dirty beans are automatically persisted. */ public boolean isAutoPersistUpdates() { return autoPersistUpdates; } /** * Set to true if dirty beans are automatically persisted. */ public void setAutoPersistUpdates(boolean autoPersistUpdates) { this.autoPersistUpdates = autoPersistUpdates; } /** * Return the PersistBatch mode to use by default at the transaction level. *

* When INSERT or ALL is used then save(), delete() etc do not execute immediately but instead go into * a JDBC batch execute buffer that is flushed. The buffer is flushed if a query is executed, transaction ends * or the batch size is meet. */ public PersistBatch getPersistBatch() { return persistBatch; } /** * Set the JDBC batch mode to use at the transaction level. *

* When INSERT or ALL is used then save(), delete() etc do not execute immediately but instead go into * a JDBC batch execute buffer that is flushed. The buffer is flushed if a query is executed, transaction ends * or the batch size is meet. */ public void setPersistBatch(PersistBatch persistBatch) { this.persistBatch = persistBatch; } /** * Return the JDBC batch mode to use per save(), delete(), insert() or update() request. *

* This makes sense when a save() or delete() cascades and executes multiple child statements. The best case * for this is when saving a master/parent bean this cascade inserts many detail/child beans. *

* This only takes effect when the persistBatch mode at the transaction level does not take effect. */ public PersistBatch getPersistBatchOnCascade() { return persistBatchOnCascade; } /** * Set the JDBC batch mode to use per save(), delete(), insert() or update() request. *

* This makes sense when a save() or delete() etc cascades and executes multiple child statements. The best caase * for this is when saving a master/parent bean this cascade inserts many detail/child beans. *

* This only takes effect when the persistBatch mode at the transaction level does not take effect. */ public void setPersistBatchOnCascade(PersistBatch persistBatchOnCascade) { this.persistBatchOnCascade = persistBatchOnCascade; } /** * Deprecated, please migrate to using setPersistBatch(). *

* Set to true if you what to use JDBC batching for persisting and deleting beans. *

* With this Ebean will batch up persist requests and use the JDBC batch api. * This is a performance optimisation designed to reduce the network chatter. *

* When true this is equivalent to {@code setPersistBatch(PersistBatch.ALL)} or * when false to {@code setPersistBatch(PersistBatch.NONE)} */ public void setPersistBatching(boolean persistBatching) { this.persistBatch = (persistBatching) ? PersistBatch.ALL : PersistBatch.NONE; } /** * Return the batch size used for JDBC batching. This defaults to 20. */ public int getPersistBatchSize() { return persistBatchSize; } /** * Set the batch size used for JDBC batching. If unset this defaults to 20. *

* You can also set the batch size on the transaction. * * @see Transaction#setBatchSize(int) */ public void setPersistBatchSize(int persistBatchSize) { this.persistBatchSize = persistBatchSize; } /** * Gets the query batch size. This defaults to 100. * * @return the query batch size */ public int getQueryBatchSize() { return queryBatchSize; } /** * Sets the query batch size. This defaults to 100. * * @param queryBatchSize the new query batch size */ public void setQueryBatchSize(int queryBatchSize) { this.queryBatchSize = queryBatchSize; } public EnumType getDefaultEnumType() { return defaultEnumType; } public void setDefaultEnumType(EnumType defaultEnumType) { this.defaultEnumType = defaultEnumType; } /** * Return true if lazy loading is disabled on queries by default. */ public boolean isDisableLazyLoading() { return disableLazyLoading; } /** * Set to true to disable lazy loading by default. *

* It can be turned on per query via {@link Query#setDisableLazyLoading(boolean)}. */ public void setDisableLazyLoading(boolean disableLazyLoading) { this.disableLazyLoading = disableLazyLoading; } /** * Return the default batch size for lazy loading of beans and collections. */ public int getLazyLoadBatchSize() { return lazyLoadBatchSize; } /** * Set the default batch size for lazy loading. *

* This is the number of beans or collections loaded when lazy loading is * invoked by default. *

* The default value is for this is 10 (load 10 beans or collections). *

* You can explicitly control the lazy loading batch size for a given join on * a query using +lazy(batchSize) or JoinConfig. */ public void setLazyLoadBatchSize(int lazyLoadBatchSize) { this.lazyLoadBatchSize = lazyLoadBatchSize; } /** * Set the number of sequences to fetch/preallocate when using DB sequences. *

* This is a performance optimisation to reduce the number times Ebean * requests a sequence to be used as an Id for a bean (aka reduce network * chatter). */ public void setDatabaseSequenceBatchSize(int databaseSequenceBatchSize) { platformConfig.setDatabaseSequenceBatchSize(databaseSequenceBatchSize); } /** * Return the default JDBC fetchSize hint for findList queries. */ public int getJdbcFetchSizeFindList() { return jdbcFetchSizeFindList; } /** * Set the default JDBC fetchSize hint for findList queries. */ public void setJdbcFetchSizeFindList(int jdbcFetchSizeFindList) { this.jdbcFetchSizeFindList = jdbcFetchSizeFindList; } /** * Return the default JDBC fetchSize hint for findEach/findEachWhile queries. */ public int getJdbcFetchSizeFindEach() { return jdbcFetchSizeFindEach; } /** * Set the default JDBC fetchSize hint for findEach/findEachWhile queries. */ public void setJdbcFetchSizeFindEach(int jdbcFetchSizeFindEach) { this.jdbcFetchSizeFindEach = jdbcFetchSizeFindEach; } /** * Return the ChangeLogPrepare. *

* This is used to set user context information to the ChangeSet in the * foreground thread prior to the logging occurring in a background thread. */ public ChangeLogPrepare getChangeLogPrepare() { return changeLogPrepare; } /** * Set the ChangeLogPrepare. *

* This is used to set user context information to the ChangeSet in the * foreground thread prior to the logging occurring in a background thread. */ public void setChangeLogPrepare(ChangeLogPrepare changeLogPrepare) { this.changeLogPrepare = changeLogPrepare; } /** * Return the ChangeLogListener which actually performs the logging of change sets * in the background. */ public ChangeLogListener getChangeLogListener() { return changeLogListener; } /** * Set the ChangeLogListener which actually performs the logging of change sets * in the background. */ public void setChangeLogListener(ChangeLogListener changeLogListener) { this.changeLogListener = changeLogListener; } /** * Return the ChangeLogRegister which controls which ChangeLogFilter is used for each * bean type and in this way provide fine grained control over which persist requests * are included in the change log. */ public ChangeLogRegister getChangeLogRegister() { return changeLogRegister; } /** * Set the ChangeLogRegister which controls which ChangeLogFilter is used for each * bean type and in this way provide fine grained control over which persist requests * are included in the change log. */ public void setChangeLogRegister(ChangeLogRegister changeLogRegister) { this.changeLogRegister = changeLogRegister; } /** * Return true if inserts should be included in the change log by default. */ public boolean isChangeLogIncludeInserts() { return changeLogIncludeInserts; } /** * Set if inserts should be included in the change log by default. */ public void setChangeLogIncludeInserts(boolean changeLogIncludeInserts) { this.changeLogIncludeInserts = changeLogIncludeInserts; } /** * Return true (default) if the changelog should be written async. */ public boolean isChangeLogAsync() { return changeLogAsync; } /** * Sets if the changelog should be written async (default = true). */ public void setChangeLogAsync(boolean changeLogAsync) { this.changeLogAsync = changeLogAsync; } /** * Return the ReadAuditLogger to use. */ public ReadAuditLogger getReadAuditLogger() { return readAuditLogger; } /** * Set the ReadAuditLogger to use. If not set the default implementation is used * which logs the read events in JSON format to a standard named SLF4J logger * (which can be configured in say logback to log to a separate log file). */ public void setReadAuditLogger(ReadAuditLogger readAuditLogger) { this.readAuditLogger = readAuditLogger; } /** * Return the ReadAuditPrepare to use. */ public ReadAuditPrepare getReadAuditPrepare() { return readAuditPrepare; } /** * Set the ReadAuditPrepare to use. *

* It is expected that an implementation is used that read user context information * (user id, user ip address etc) and sets it on the ReadEvent bean before it is sent * to the ReadAuditLogger. */ public void setReadAuditPrepare(ReadAuditPrepare readAuditPrepare) { this.readAuditPrepare = readAuditPrepare; } /** * Return the configuration for profiling. */ public ProfilingConfig getProfilingConfig() { return profilingConfig; } /** * Set the configuration for profiling. */ public void setProfilingConfig(ProfilingConfig profilingConfig) { this.profilingConfig = profilingConfig; } /** * Return the DB schema to use. */ public String getDbSchema() { return dbSchema; } /** * Set the DB schema to use. This specifies to use this schema for: *

    *
  • Running Database migrations - Create and use the DB schema
  • *
  • Testing DDL - Create-all.sql DDL execution creates and uses schema
  • *
  • Testing Docker - Set default schema on connection URL
  • *
*/ public void setDbSchema(String dbSchema) { this.dbSchema = dbSchema; } /** * Return the Geometry SRID. */ public int getGeometrySRID() { return platformConfig.getGeometrySRID(); } /** * Set the Geometry SRID. */ public void setGeometrySRID(int geometrySRID) { platformConfig.setGeometrySRID(geometrySRID); } /** * Return the time zone to use when reading/writing Timestamps via JDBC. *

* When set a Calendar object is used in JDBC calls when reading/writing Timestamp objects. */ public String getDataTimeZone() { return System.getProperty("ebean.dataTimeZone", dataTimeZone); } /** * Set the time zone to use when reading/writing Timestamps via JDBC. */ public void setDataTimeZone(String dataTimeZone) { this.dataTimeZone = dataTimeZone; } /** * Return the suffix appended to the base table to derive the view that contains the union * of the base table and the history table in order to support asOf queries. */ public String getAsOfViewSuffix() { return asOfViewSuffix; } /** * Set the suffix appended to the base table to derive the view that contains the union * of the base table and the history table in order to support asOf queries. */ public void setAsOfViewSuffix(String asOfViewSuffix) { this.asOfViewSuffix = asOfViewSuffix; } /** * Return the database column used to support history and 'As of' queries. This column is a timestamp range * or equivalent. */ public String getAsOfSysPeriod() { return asOfSysPeriod; } /** * Set the database column used to support history and 'As of' queries. This column is a timestamp range * or equivalent. */ public void setAsOfSysPeriod(String asOfSysPeriod) { this.asOfSysPeriod = asOfSysPeriod; } /** * Return the history table suffix (defaults to _history). */ public String getHistoryTableSuffix() { return historyTableSuffix; } /** * Set the history table suffix. */ public void setHistoryTableSuffix(String historyTableSuffix) { this.historyTableSuffix = historyTableSuffix; } /** * Return true if we are running in a JTA Transaction manager. */ public boolean isUseJtaTransactionManager() { return useJtaTransactionManager; } /** * Set to true if we are running in a JTA Transaction manager. */ public void setUseJtaTransactionManager(boolean useJtaTransactionManager) { this.useJtaTransactionManager = useJtaTransactionManager; } /** * Return the external transaction manager. */ public ExternalTransactionManager getExternalTransactionManager() { return externalTransactionManager; } /** * Set the external transaction manager. */ public void setExternalTransactionManager(ExternalTransactionManager externalTransactionManager) { this.externalTransactionManager = externalTransactionManager; } /** * Return the ServerCachePlugin. */ public ServerCachePlugin getServerCachePlugin() { return serverCachePlugin; } /** * Set the ServerCachePlugin to use. */ public void setServerCachePlugin(ServerCachePlugin serverCachePlugin) { this.serverCachePlugin = serverCachePlugin; } /** * Return true if LOB's should default to fetch eager. * By default this is set to false and LOB's must be explicitly fetched. */ public boolean isEagerFetchLobs() { return eagerFetchLobs; } /** * Set to true if you want LOB's to be fetch eager by default. * By default this is set to false and LOB's must be explicitly fetched. */ public void setEagerFetchLobs(boolean eagerFetchLobs) { this.eagerFetchLobs = eagerFetchLobs; } /** * Return the max call stack to use for origin location. */ public int getMaxCallStack() { return maxCallStack; } /** * Set the max call stack to use for origin location. */ public void setMaxCallStack(int maxCallStack) { this.maxCallStack = maxCallStack; } /** * Return true if transactions should rollback on checked exceptions. */ public boolean isTransactionRollbackOnChecked() { return transactionRollbackOnChecked; } /** * Set to true if transactions should by default rollback on checked exceptions. */ public void setTransactionRollbackOnChecked(boolean transactionRollbackOnChecked) { this.transactionRollbackOnChecked = transactionRollbackOnChecked; } /** * Return the Background executor schedule pool size. Defaults to 1. */ public int getBackgroundExecutorSchedulePoolSize() { return backgroundExecutorSchedulePoolSize; } /** * Set the Background executor schedule pool size. */ public void setBackgroundExecutorSchedulePoolSize(int backgroundExecutorSchedulePoolSize) { this.backgroundExecutorSchedulePoolSize = backgroundExecutorSchedulePoolSize; } /** * Return the Background executor shutdown seconds. This is the time allowed for the pool to shutdown nicely * before it is forced shutdown. */ public int getBackgroundExecutorShutdownSecs() { return backgroundExecutorShutdownSecs; } /** * Set the Background executor shutdown seconds. This is the time allowed for the pool to shutdown nicely * before it is forced shutdown. */ public void setBackgroundExecutorShutdownSecs(int backgroundExecutorShutdownSecs) { this.backgroundExecutorShutdownSecs = backgroundExecutorShutdownSecs; } /** * Return the background executor wrapper. */ public BackgroundExecutorWrapper getBackgroundExecutorWrapper() { return backgroundExecutorWrapper; } /** * Sets the background executor wrapper. The wrapper is used when a task is sent to background and should copy the thread-locals. */ public void setBackgroundExecutorWrapper(BackgroundExecutorWrapper backgroundExecutorWrapper) { this.backgroundExecutorWrapper = backgroundExecutorWrapper; } /** * Return the L2 cache default max size. */ public int getCacheMaxSize() { return cacheMaxSize; } /** * Set the L2 cache default max size. */ public void setCacheMaxSize(int cacheMaxSize) { this.cacheMaxSize = cacheMaxSize; } /** * Return the L2 cache default max idle time in seconds. */ public int getCacheMaxIdleTime() { return cacheMaxIdleTime; } /** * Set the L2 cache default max idle time in seconds. */ public void setCacheMaxIdleTime(int cacheMaxIdleTime) { this.cacheMaxIdleTime = cacheMaxIdleTime; } /** * Return the L2 cache default max time to live in seconds. */ public int getCacheMaxTimeToLive() { return cacheMaxTimeToLive; } /** * Set the L2 cache default max time to live in seconds. */ public void setCacheMaxTimeToLive(int cacheMaxTimeToLive) { this.cacheMaxTimeToLive = cacheMaxTimeToLive; } /** * Return the L2 query cache default max size. */ public int getQueryCacheMaxSize() { return queryCacheMaxSize; } /** * Set the L2 query cache default max size. */ public void setQueryCacheMaxSize(int queryCacheMaxSize) { this.queryCacheMaxSize = queryCacheMaxSize; } /** * Return the L2 query cache default max idle time in seconds. */ public int getQueryCacheMaxIdleTime() { return queryCacheMaxIdleTime; } /** * Set the L2 query cache default max idle time in seconds. */ public void setQueryCacheMaxIdleTime(int queryCacheMaxIdleTime) { this.queryCacheMaxIdleTime = queryCacheMaxIdleTime; } /** * Return the L2 query cache default max time to live in seconds. */ public int getQueryCacheMaxTimeToLive() { return queryCacheMaxTimeToLive; } /** * Set the L2 query cache default max time to live in seconds. */ public void setQueryCacheMaxTimeToLive(int queryCacheMaxTimeToLive) { this.queryCacheMaxTimeToLive = queryCacheMaxTimeToLive; } /** * Return the NamingConvention. *

* If none has been set the default UnderscoreNamingConvention is used. */ public NamingConvention getNamingConvention() { return namingConvention; } /** * Set the NamingConvention. *

* If none is set the default UnderscoreNamingConvention is used. */ public void setNamingConvention(NamingConvention namingConvention) { this.namingConvention = namingConvention; } /** * Return true if all DB column and table names should use quoted identifiers. */ public boolean isAllQuotedIdentifiers() { return platformConfig.isAllQuotedIdentifiers(); } /** * Set to true if all DB column and table names should use quoted identifiers. *

* For Postgres pgjdbc version 42.3.0 should be used with datasource property * quoteReturningIdentifiers set to false (refer #2303). */ public void setAllQuotedIdentifiers(boolean allQuotedIdentifiers) { platformConfig.setAllQuotedIdentifiers(allQuotedIdentifiers); if (allQuotedIdentifiers) { adjustNamingConventionForAllQuoted(); } } private void adjustNamingConventionForAllQuoted() { if (namingConvention instanceof UnderscoreNamingConvention) { // we need to use matching naming convention this.namingConvention = new MatchingNamingConvention(); } } /** * Return true if this Database is a Document store only instance (has no JDBC DB). */ public boolean isDocStoreOnly() { return docStoreOnly; } /** * Set to true if this Database is Document store only instance (has no JDBC DB). */ public void setDocStoreOnly(boolean docStoreOnly) { this.docStoreOnly = docStoreOnly; } /** * Return the configuration for the ElasticSearch integration. */ public DocStoreConfig getDocStoreConfig() { return docStoreConfig; } /** * Set the configuration for the ElasticSearch integration. */ public void setDocStoreConfig(DocStoreConfig docStoreConfig) { this.docStoreConfig = docStoreConfig; } /** * Return the constraint naming convention used in DDL generation. */ public DbConstraintNaming getConstraintNaming() { return platformConfig.getConstraintNaming(); } /** * Set the constraint naming convention used in DDL generation. */ public void setConstraintNaming(DbConstraintNaming constraintNaming) { platformConfig.setConstraintNaming(constraintNaming); } /** * Return the configuration for AutoTune. */ public AutoTuneConfig getAutoTuneConfig() { return autoTuneConfig; } /** * Set the configuration for AutoTune. */ public void setAutoTuneConfig(AutoTuneConfig autoTuneConfig) { this.autoTuneConfig = autoTuneConfig; } /** * Return true if the startup DataSource check should be skipped. */ public boolean skipDataSourceCheck() { return skipDataSourceCheck; } /** * Set to true to skip the startup DataSource check. */ public void setSkipDataSourceCheck(boolean skipDataSourceCheck) { this.skipDataSourceCheck = skipDataSourceCheck; } /** * Return the DataSource. */ public DataSource getDataSource() { return dataSource; } /** * Set a DataSource. */ public void setDataSource(DataSource dataSource) { this.dataSource = dataSource; } /** * Return the read only DataSource. */ public DataSource getReadOnlyDataSource() { return readOnlyDataSource; } /** * Set the read only DataSource. *

* Note that the DataSource is expected to use AutoCommit true mode avoiding the need * for explicit commit (or rollback). *

* This read only DataSource will be used for implicit query only transactions. It is not * used if the transaction is created explicitly or if the query is an update or delete query. */ public void setReadOnlyDataSource(DataSource readOnlyDataSource) { this.readOnlyDataSource = readOnlyDataSource; } /** * Return the configuration to build a DataSource using Ebean's own DataSource * implementation. */ public DataSourceConfig getDataSourceConfig() { return dataSourceConfig; } /** * Set the configuration required to build a DataSource using Ebean's own * DataSource implementation. */ public void setDataSourceConfig(DataSourceConfig dataSourceConfig) { this.dataSourceConfig = dataSourceConfig; } /** * Return true if Ebean should create a DataSource for use with implicit read only transactions. */ public boolean isAutoReadOnlyDataSource() { return autoReadOnlyDataSource; } /** * Set to true if Ebean should create a DataSource for use with implicit read only transactions. */ public void setAutoReadOnlyDataSource(boolean autoReadOnlyDataSource) { this.autoReadOnlyDataSource = autoReadOnlyDataSource; } /** * Return the configuration for the read only DataSource. *

* This is only used if autoReadOnlyDataSource is true. *

* The driver, url, username and password default to the configuration for the main DataSource if they are not * set on this configuration. This means there is actually no need to set any configuration here and we only * set configuration for url, username and password etc if it is different from the main DataSource. */ public DataSourceConfig getReadOnlyDataSourceConfig() { return readOnlyDataSourceConfig; } /** * Set the configuration for the read only DataSource. */ public void setReadOnlyDataSourceConfig(DataSourceConfig readOnlyDataSourceConfig) { this.readOnlyDataSourceConfig = readOnlyDataSourceConfig; } /** * Return a value used to represent TRUE in the database. *

* This is used for databases that do not support boolean natively. *

* The value returned is either a Integer or a String (e.g. "1", or "T"). */ public String getDatabaseBooleanTrue() { return platformConfig.getDatabaseBooleanTrue(); } /** * Set the value to represent TRUE in the database. *

* This is used for databases that do not support boolean natively. *

* The value set is either a Integer or a String (e.g. "1", or "T"). */ public void setDatabaseBooleanTrue(String databaseTrue) { platformConfig.setDatabaseBooleanTrue(databaseTrue); } /** * Return a value used to represent FALSE in the database. *

* This is used for databases that do not support boolean natively. *

* The value returned is either a Integer or a String (e.g. "0", or "F"). */ public String getDatabaseBooleanFalse() { return platformConfig.getDatabaseBooleanFalse(); } /** * Set the value to represent FALSE in the database. *

* This is used for databases that do not support boolean natively. *

* The value set is either a Integer or a String (e.g. "0", or "F"). */ public void setDatabaseBooleanFalse(String databaseFalse) { this.platformConfig.setDatabaseBooleanFalse(databaseFalse); } /** * Return the number of DB sequence values that should be preallocated. */ public int getDatabaseSequenceBatchSize() { return platformConfig.getDatabaseSequenceBatchSize(); } /** * Set the number of DB sequence values that should be preallocated and cached * by Ebean. *

* This is only used for DB's that use sequences and is a performance * optimisation. This reduces the number of times Ebean needs to get a * sequence value from the Database reducing network chatter. *

* By default this value is 10 so when we need another Id (and don't have one * in our cache) Ebean will fetch 10 id's from the database. Note that when * the cache drops to have full (which is 5 by default) Ebean will fetch * another batch of Id's in a background thread. */ public void setDatabaseSequenceBatch(int databaseSequenceBatchSize) { this.platformConfig.setDatabaseSequenceBatchSize(databaseSequenceBatchSize); } /** * Return the database platform name (can be null). *

* If null then the platform is determined automatically via the JDBC driver * information. */ public String getDatabasePlatformName() { return databasePlatformName; } /** * Explicitly set the database platform name *

* If none is set then the platform is determined automatically via the JDBC * driver information. *

* This can be used when the Database Platform can not be automatically * detected from the JDBC driver (possibly 3rd party JDBC driver). It is also * useful when you want to do offline DDL generation for a database platform * that you don't have access to. *

* Values are oracle, h2, postgres, mysql, sqlserver16, sqlserver17. */ public void setDatabasePlatformName(String databasePlatformName) { this.databasePlatformName = databasePlatformName; } /** * Return the database platform to use for this database. */ public DatabasePlatform getDatabasePlatform() { return databasePlatform; } /** * Explicitly set the database platform to use. *

* If none is set then the platform is determined via the databasePlatformName * or automatically via the JDBC driver information. */ public void setDatabasePlatform(DatabasePlatform databasePlatform) { this.databasePlatform = databasePlatform; } /** * Return the preferred DB platform IdType. */ public IdType getIdType() { return platformConfig.getIdType(); } /** * Set the preferred DB platform IdType. */ public void setIdType(IdType idType) { this.platformConfig.setIdType(idType); } /** * Return the EncryptKeyManager. */ public EncryptKeyManager getEncryptKeyManager() { return encryptKeyManager; } /** * Set the EncryptKeyManager. *

* This is required when you want to use encrypted properties. *

* You can also set this in ebean.proprerties: *

*

{@code
   * # set via ebean.properties
   * ebean.encryptKeyManager=org.avaje.tests.basic.encrypt.BasicEncyptKeyManager
   * }
*/ public void setEncryptKeyManager(EncryptKeyManager encryptKeyManager) { this.encryptKeyManager = encryptKeyManager; } /** * Return the EncryptDeployManager. *

* This is optionally used to programmatically define which columns are * encrypted instead of using the {@link Encrypted} Annotation. */ public EncryptDeployManager getEncryptDeployManager() { return encryptDeployManager; } /** * Set the EncryptDeployManager. *

* This is optionally used to programmatically define which columns are * encrypted instead of using the {@link Encrypted} Annotation. */ public void setEncryptDeployManager(EncryptDeployManager encryptDeployManager) { this.encryptDeployManager = encryptDeployManager; } /** * Return the Encryptor used to encrypt data on the java client side (as * opposed to DB encryption functions). */ public Encryptor getEncryptor() { return encryptor; } /** * Set the Encryptor used to encrypt data on the java client side (as opposed * to DB encryption functions). *

* Ebean has a default implementation that it will use if you do not set your * own Encryptor implementation. */ public void setEncryptor(Encryptor encryptor) { this.encryptor = encryptor; } /** * Return true if the Database instance should be created in offline mode. */ public boolean isDbOffline() { return dbOffline; } /** * Set to true if the Database instance should be created in offline mode. *

* Typically used to create an Database instance for DDL Migration generation * without requiring a real DataSource / Database to connect to. */ public void setDbOffline(boolean dbOffline) { this.dbOffline = dbOffline; } /** * Return the DbEncrypt used to encrypt and decrypt properties. *

* Note that if this is not set then the DbPlatform may already have a * DbEncrypt set and that will be used. */ public DbEncrypt getDbEncrypt() { return dbEncrypt; } /** * Set the DbEncrypt used to encrypt and decrypt properties. *

* Note that if this is not set then the DbPlatform may already have a * DbEncrypt set (H2, MySql, Postgres and Oracle platforms have a DbEncrypt) */ public void setDbEncrypt(DbEncrypt dbEncrypt) { this.dbEncrypt = dbEncrypt; } /** * Return the configuration for DB types (such as UUID and custom mappings). */ public PlatformConfig getPlatformConfig() { return platformConfig; } /** * Set the configuration for DB platform (such as UUID and custom mappings). */ public void setPlatformConfig(PlatformConfig platformConfig) { this.platformConfig = platformConfig; } /** * Set the DB type used to store UUID. */ public void setDbUuid(PlatformConfig.DbUuid dbUuid) { this.platformConfig.setDbUuid(dbUuid); } /** * Returns the UUID version mode. */ public UuidVersion getUuidVersion() { return uuidVersion; } /** * Sets the UUID version mode. */ public void setUuidVersion(UuidVersion uuidVersion) { this.uuidVersion = uuidVersion; } /** * Return the UUID state file. */ public String getUuidStateFile() { if (uuidStateFile == null || uuidStateFile.isEmpty()) { // by default, add servername... uuidStateFile = name + "-uuid.state"; // and store it in the user's home directory String homeDir = System.getProperty("user.home"); if (homeDir != null && homeDir.isEmpty()) { uuidStateFile = homeDir + "/.ebean/" + uuidStateFile; } } return uuidStateFile; } /** * Set the UUID state file. */ public void setUuidStateFile(String uuidStateFile) { this.uuidStateFile = uuidStateFile; } /** * Returns the V1-UUID-NodeId */ public String getUuidNodeId() { return uuidNodeId; } /** * Sets the V1-UUID-NodeId. */ public void setUuidNodeId(String uuidNodeId) { this.uuidNodeId = uuidNodeId; } /** * Return true if LocalTime should be persisted with nanos precision. */ public boolean isLocalTimeWithNanos() { return localTimeWithNanos; } /** * Set to true if LocalTime should be persisted with nanos precision. *

* Otherwise it is persisted using java.sql.Time which is seconds precision. */ public void setLocalTimeWithNanos(boolean localTimeWithNanos) { this.localTimeWithNanos = localTimeWithNanos; } /** * Return true if Duration should be persisted with nanos precision (SQL DECIMAL). *

* Otherwise it is persisted with second precision (SQL INTEGER). */ public boolean isDurationWithNanos() { return durationWithNanos; } /** * Set to true if Duration should be persisted with nanos precision (SQL DECIMAL). *

* Otherwise it is persisted with second precision (SQL INTEGER). */ public void setDurationWithNanos(boolean durationWithNanos) { this.durationWithNanos = durationWithNanos; } /** * Set to true to run DB migrations on server start. *

* This is the same as config.getMigrationConfig().setRunMigration(). We have added this method here * as it is often the only thing we need to configure for migrations. */ public void setRunMigration(boolean runMigration) { this.runMigration = runMigration; } /** * Return true if the DB migration should run on server start. */ public boolean isRunMigration() { final String run = System.getProperty("ebean.migration.run"); return (run != null) ? Boolean.parseBoolean(run) : runMigration; } /** * Set to true to generate the "create all" DDL on startup. *

* Typically we want this on when we are running tests locally (and often using H2) * and we want to create the full DB schema from scratch to run tests. */ public void setDdlGenerate(boolean ddlGenerate) { this.ddlGenerate = ddlGenerate; } /** * Set to true to run the generated "create all DDL" on startup. *

* Typically we want this on when we are running tests locally (and often using H2) * and we want to create the full DB schema from scratch to run tests. */ public void setDdlRun(boolean ddlRun) { this.ddlRun = ddlRun; } /** * Set to false if you not want to run the extra-ddl.xml scripts. (default = true) *

* Typically we want this on when we are running tests. */ public void setDdlExtra(boolean ddlExtra) { this.ddlExtra = ddlExtra; } /** * Return true if the "drop all ddl" should be skipped. *

* Typically we want to do this when using H2 (in memory) as our test database and the drop statements * are not required so skipping the drop table statements etc makes it faster with less noise in the logs. */ public boolean isDdlCreateOnly() { return ddlCreateOnly; } /** * Set to true if the "drop all ddl" should be skipped. *

* Typically we want to do this when using H2 (in memory) as our test database and the drop statements * are not required so skipping the drop table statements etc makes it faster with less noise in the logs. */ public void setDdlCreateOnly(boolean ddlCreateOnly) { this.ddlCreateOnly = ddlCreateOnly; } /** * Return SQL script to execute after the "create all" DDL has been run. *

* Typically this is a sql script that inserts test seed data when running tests. * Place a sql script in src/test/resources that inserts test seed data. */ public String getDdlSeedSql() { return ddlSeedSql; } /** * Set a SQL script to execute after the "create all" DDL has been run. *

* Typically this is a sql script that inserts test seed data when running tests. * Place a sql script in src/test/resources that inserts test seed data. */ public void setDdlSeedSql(String ddlSeedSql) { this.ddlSeedSql = ddlSeedSql; } /** * Return a SQL script to execute before the "create all" DDL has been run. */ public String getDdlInitSql() { return ddlInitSql; } /** * Set a SQL script to execute before the "create all" DDL has been run. */ public void setDdlInitSql(String ddlInitSql) { this.ddlInitSql = ddlInitSql; } /** * Return true if the DDL should be generated. */ public boolean isDdlGenerate() { return ddlGenerate; } /** * Return true if the DDL should be run. */ public boolean isDdlRun() { return ddlRun; } /** * Return true, if extra-ddl.xml should be executed. */ public boolean isDdlExtra() { return ddlExtra; } /** * Set the header to use with DDL generation. */ public void setDdlHeader(String ddlHeader) { this.ddlHeader = ddlHeader; } /** * Return the header to use with DDL generation. */ public String getDdlHeader() { if (ddlHeader != null && !ddlHeader.isEmpty()) { String header = ddlHeader.replace("${version}", EbeanVersion.getVersion()); header = header.replace("${timestamp}", ZonedDateTime.now().format(DateTimeFormatter.ISO_INSTANT)); return header; } return ddlHeader; } /** * Return true if strict mode is used which includes a check that non-null columns have a default value. */ public boolean isDdlStrictMode() { return ddlStrictMode; } /** * Set to false to turn off strict mode allowing non-null columns to not have a default value. */ public void setDdlStrictMode(boolean ddlStrictMode) { this.ddlStrictMode = ddlStrictMode; } /** * Return a comma and equals delimited placeholders that are substituted in DDL scripts. */ public String getDdlPlaceholders() { return ddlPlaceholders; } /** * Set a comma and equals delimited placeholders that are substituted in DDL scripts. */ public void setDdlPlaceholders(String ddlPlaceholders) { this.ddlPlaceholders = ddlPlaceholders; } /** * Return a map of placeholder values that are substituted in DDL scripts. */ public Map getDdlPlaceholderMap() { return ddlPlaceholderMap; } /** * Set a map of placeholder values that are substituted in DDL scripts. */ public void setDdlPlaceholderMap(Map ddlPlaceholderMap) { this.ddlPlaceholderMap = ddlPlaceholderMap; } /** * Return true if the class path search should be disabled. */ public boolean isDisableClasspathSearch() { return disableClasspathSearch; } /** * Set to true to disable the class path search even for the case where no entity bean classes * have been registered. This can be used to start an Database instance just to use the * SQL functions such as SqlQuery, SqlUpdate etc. */ public void setDisableClasspathSearch(boolean disableClasspathSearch) { this.disableClasspathSearch = disableClasspathSearch; } /** * Return the mode to use for Joda LocalTime support 'normal' or 'utc'. */ public String getJodaLocalTimeMode() { return jodaLocalTimeMode; } /** * Set the mode to use for Joda LocalTime support 'normal' or 'utc'. */ public void setJodaLocalTimeMode(String jodaLocalTimeMode) { this.jodaLocalTimeMode = jodaLocalTimeMode; } /** * Programmatically add classes (typically entities) that this server should use. *

* The class can be an Entity, Embedded type, ScalarType, BeanPersistListener, * BeanFinder or BeanPersistController. *

* If no classes are specified then the classes are found automatically via * searching the class path. * * @param cls the entity type (or other type) that should be registered by this database. */ public void addClass(Class cls) { classes.add(cls); } /** * Register all the classes (typically entity classes). */ public void addAll(Collection> classList) { if (classList != null && !classList.isEmpty()) { classes.addAll(classList); } } /** * Add a package to search for entities via class path search. *

* This is only used if classes have not been explicitly specified. */ public void addPackage(String packageName) { packages.add(packageName); } /** * Return packages to search for entities via class path search. *

* This is only used if classes have not been explicitly specified. */ public List getPackages() { return packages; } /** * Set packages to search for entities via class path search. *

* This is only used if classes have not been explicitly specified. */ public void setPackages(List packages) { this.packages = packages; } /** * Set the list of classes (entities, listeners, scalarTypes etc) that should * be used for this database. *

* If no classes are specified then the classes are found automatically via * searching the class path. *

* Alternatively the classes can contain added via {@link #addClass(Class)}. */ public void setClasses(Collection> classes) { this.classes = new HashSet<>(classes); } /** * Return the classes registered for this database. Typically, this includes * entities and perhaps listeners. */ public Set> classes() { return classes; } /** * Deprecated - migrate to classes(). *

* Sorry if returning Set rather than List breaks code but it feels safer to * do that than a subtle change to return a shallow copy which you will not detect. */ @Deprecated public Set> getClasses() { return classes; } /** * Return true if L2 bean cache should be skipped once writes have occurred on a transaction. *

* This defaults to true and means that for "find by id" and "find by natural key" * queries that normally hit L2 bean cache automatically will not do so after a write/persist * on the transaction. *

*

{@code
   *
   *   // assume Customer has L2 bean caching enabled ...
   *
   *   try (Transaction transaction = DB.beginTransaction()) {
   *
   *     // this uses L2 bean cache as the transaction
   *     // ... is considered "query only" at this point
   *     Customer.find.byId(42);
   *
   *     // transaction no longer "query only" once
   *     // ... a bean has been saved etc
   *     DB.save(someBean);
   *
   *     // will NOT use L2 bean cache as the transaction
   *     // ... is no longer considered "query only"
   *     Customer.find.byId(55);
   *
   *
   *
   *     // explicit control - please use L2 bean cache
   *
   *     transaction.setSkipCache(false);
   *     Customer.find.byId(77); // hit the l2 bean cache
   *
   *
   *     // explicit control - please don't use L2 bean cache
   *
   *     transaction.setSkipCache(true);
   *     Customer.find.byId(99); // skips l2 bean cache
   *
   *   }
   *
   * }
* * @see Transaction#setSkipCache(boolean) */ public boolean isSkipCacheAfterWrite() { return skipCacheAfterWrite; } /** * Set to false when we still want to hit the cache after a write has occurred on a transaction. */ public void setSkipCacheAfterWrite(boolean skipCacheAfterWrite) { this.skipCacheAfterWrite = skipCacheAfterWrite; } /** * Returns true if updates in JDBC batch default to include all properties by default. */ public boolean isUpdateAllPropertiesInBatch() { return updateAllPropertiesInBatch; } /** * Set to false if by default updates in JDBC batch should not include all properties. *

* This mode can be explicitly set per transaction. * * @see Transaction#setUpdateAllLoadedProperties(boolean) */ public void setUpdateAllPropertiesInBatch(boolean updateAllPropertiesInBatch) { this.updateAllPropertiesInBatch = updateAllPropertiesInBatch; } /** * Returns the resource directory. */ public String getResourceDirectory() { return resourceDirectory; } /** * Sets the resource directory. */ public void setResourceDirectory(String resourceDirectory) { this.resourceDirectory = resourceDirectory; } /** * Add a custom type mapping. *

*

{@code
   *
   *   // set the default mapping for BigDecimal.class/decimal
   *   config.addCustomMapping(DbType.DECIMAL, "decimal(18,6)");
   *
   *   // set the default mapping for String.class/varchar but only for Postgres
   *   config.addCustomMapping(DbType.VARCHAR, "text", Platform.POSTGRES);
   *
   * }
* * @param type The DB type this mapping should apply to * @param columnDefinition The column definition that should be used * @param platform Optionally specify the platform this mapping should apply to. */ public void addCustomMapping(DbType type, String columnDefinition, Platform platform) { platformConfig.addCustomMapping(type, columnDefinition, platform); } /** * Add a custom type mapping that applies to all platforms. *

*

{@code
   *
   *   // set the default mapping for BigDecimal/decimal
   *   config.addCustomMapping(DbType.DECIMAL, "decimal(18,6)");
   *
   *   // set the default mapping for String/varchar
   *   config.addCustomMapping(DbType.VARCHAR, "text");
   *
   * }
* * @param type The DB type this mapping should apply to * @param columnDefinition The column definition that should be used */ public void addCustomMapping(DbType type, String columnDefinition) { platformConfig.addCustomMapping(type, columnDefinition); } /** * Register a BeanQueryAdapter instance. *

* Note alternatively you can use {@link #setQueryAdapters(List)} to set all * the BeanQueryAdapter instances. */ public void add(BeanQueryAdapter beanQueryAdapter) { queryAdapters.add(beanQueryAdapter); } /** * Return the BeanQueryAdapter instances. */ public List getQueryAdapters() { return queryAdapters; } /** * Register all the BeanQueryAdapter instances. *

* Note alternatively you can use {@link #add(BeanQueryAdapter)} to add * BeanQueryAdapter instances one at a time. */ public void setQueryAdapters(List queryAdapters) { this.queryAdapters = queryAdapters; } /** * Return the custom IdGenerator instances. */ public List getIdGenerators() { return idGenerators; } /** * Set the custom IdGenerator instances. */ public void setIdGenerators(List idGenerators) { this.idGenerators = idGenerators; } /** * Register a customer IdGenerator instance. */ public void add(IdGenerator idGenerator) { idGenerators.add(idGenerator); } /** * Register a BeanPersistController instance. *

* Note alternatively you can use {@link #setPersistControllers(List)} to set * all the BeanPersistController instances. */ public void add(BeanPersistController beanPersistController) { persistControllers.add(beanPersistController); } /** * Register a BeanPostLoad instance. *

* Note alternatively you can use {@link #setPostLoaders(List)} to set * all the BeanPostLoad instances. */ public void add(BeanPostLoad postLoad) { postLoaders.add(postLoad); } /** * Register a BeanPostConstructListener instance. *

* Note alternatively you can use {@link #setPostConstructListeners(List)} to set * all the BeanPostConstructListener instances. */ public void add(BeanPostConstructListener listener) { postConstructListeners.add(listener); } /** * Return the list of BeanFindController instances. */ public List getFindControllers() { return findControllers; } /** * Set the list of BeanFindController instances. */ public void setFindControllers(List findControllers) { this.findControllers = findControllers; } /** * Return the list of BeanPostLoader instances. */ public List getPostLoaders() { return postLoaders; } /** * Set the list of BeanPostLoader instances. */ public void setPostLoaders(List postLoaders) { this.postLoaders = postLoaders; } /** * Return the list of BeanPostLoader instances. */ public List getPostConstructListeners() { return postConstructListeners; } /** * Set the list of BeanPostLoader instances. */ public void setPostConstructListeners(List listeners) { this.postConstructListeners = listeners; } /** * Return the BeanPersistController instances. */ public List getPersistControllers() { return persistControllers; } /** * Register all the BeanPersistController instances. *

* Note alternatively you can use {@link #add(BeanPersistController)} to add * BeanPersistController instances one at a time. */ public void setPersistControllers(List persistControllers) { this.persistControllers = persistControllers; } /** * Register a BeanPersistListener instance. *

* Note alternatively you can use {@link #setPersistListeners(List)} to set * all the BeanPersistListener instances. */ public void add(BeanPersistListener beanPersistListener) { persistListeners.add(beanPersistListener); } /** * Return the BeanPersistListener instances. */ public List getPersistListeners() { return persistListeners; } /** * Add a BulkTableEventListener */ public void add(BulkTableEventListener bulkTableEventListener) { bulkTableEventListeners.add(bulkTableEventListener); } /** * Return the list of BulkTableEventListener instances. */ public List getBulkTableEventListeners() { return bulkTableEventListeners; } /** * Add a ServerConfigStartup. */ public void addServerConfigStartup(ServerConfigStartup configStartupListener) { configStartupListeners.add(configStartupListener); } /** * Return the list of ServerConfigStartup instances. */ public List getServerConfigStartupListeners() { return configStartupListeners; } /** * Register all the BeanPersistListener instances. *

* Note alternatively you can use {@link #add(BeanPersistListener)} to add * BeanPersistListener instances one at a time. */ public void setPersistListeners(List persistListeners) { this.persistListeners = persistListeners; } /** * Return the default PersistenceContextScope to be used if one is not explicitly set on a query. *

* The PersistenceContextScope can specified on each query via {@link io.ebean * .Query#setPersistenceContextScope(io.ebean.PersistenceContextScope)}. If it * is not set on the query this default scope is used. * * @see Query#setPersistenceContextScope(PersistenceContextScope) */ public PersistenceContextScope getPersistenceContextScope() { // if somehow null return TRANSACTION scope return persistenceContextScope == null ? PersistenceContextScope.TRANSACTION : persistenceContextScope; } /** * Set the PersistenceContext scope to be used if one is not explicitly set on a query. *

* This defaults to {@link PersistenceContextScope#TRANSACTION}. *

* The PersistenceContextScope can specified on each query via {@link io.ebean * .Query#setPersistenceContextScope(io.ebean.PersistenceContextScope)}. If it * is not set on the query this scope is used. * * @see Query#setPersistenceContextScope(PersistenceContextScope) */ public void setPersistenceContextScope(PersistenceContextScope persistenceContextScope) { this.persistenceContextScope = persistenceContextScope; } /** * Return the ClassLoadConfig which is used to detect Joda, Java8 types etc and also * create new instances of plugins given a className. */ public ClassLoadConfig getClassLoadConfig() { return classLoadConfig; } /** * Set the ClassLoadConfig which is used to detect Joda, Java8 types etc and also * create new instances of plugins given a className. */ public void setClassLoadConfig(ClassLoadConfig classLoadConfig) { this.classLoadConfig = classLoadConfig; } /** * Load settings from application.properties, application.yaml and other sources. *

* Uses avaje-config to load configuration properties. Goto https://avaje.io/config * for detail on how and where properties are loaded from. */ public void loadFromProperties() { this.properties = Config.asProperties(); configureFromProperties(); } /** * Load the settings from the given properties */ public void loadFromProperties(Properties properties) { // keep the properties used for configuration so that these are available for plugins this.properties = Config.asConfiguration().eval(properties); configureFromProperties(); } /** * Load the settings from the given properties */ private void configureFromProperties() { List autoConfigures = autoConfiguration(); loadSettings(new PropertiesWrapper("ebean", name, properties, classLoadConfig)); for (AutoConfigure autoConfigure : autoConfigures) { autoConfigure.postConfigure(this); } } /** * Use a 'plugin' to provide automatic configuration. Intended for automatic testing * configuration with Docker containers via ebean-test-config. */ private List autoConfiguration() { List list = new ArrayList<>(); for (AutoConfigure autoConfigure : ServiceLoader.load(AutoConfigure.class)) { autoConfigure.preConfigure(this); list.add(autoConfigure); } return list; } /** * Return the properties that we used for configuration and were set via a call to loadFromProperties(). */ public Properties getProperties() { return properties; } /** * loads the data source settings to preserve existing behaviour. IMHO, if someone has set the datasource config already, * they don't want the settings to be reloaded and reset. This allows a descending class to override this behaviour and prevent it * from happening. * * @param p - The defined property source passed to load settings */ protected void loadDataSourceSettings(PropertiesWrapper p) { dataSourceConfig.loadSettings(p.properties, name); readOnlyDataSourceConfig.loadSettings(p.properties, name + "-ro"); } /** * This is broken out to allow overridden behaviour. */ protected void loadDocStoreSettings(PropertiesWrapper p) { docStoreConfig.loadSettings(p); } /** * This is broken out to allow overridden behaviour. */ protected void loadAutoTuneSettings(PropertiesWrapper p) { autoTuneConfig.loadSettings(p); } /** * Load the configuration settings from the properties file. */ protected void loadSettings(PropertiesWrapper p) { dbSchema = p.get("dbSchema", dbSchema); profilingConfig.loadSettings(p, name); platformConfig.loadSettings(p); if (platformConfig.isAllQuotedIdentifiers()) { adjustNamingConventionForAllQuoted(); } namingConvention = createNamingConvention(p, namingConvention); if (namingConvention != null) { namingConvention.loadFromProperties(p); } if (autoTuneConfig == null) { autoTuneConfig = new AutoTuneConfig(); } loadAutoTuneSettings(p); if (dataSourceConfig == null) { dataSourceConfig = new DataSourceConfig(); } loadDataSourceSettings(p); if (docStoreConfig == null) { docStoreConfig = new DocStoreConfig(); } loadDocStoreSettings(p); defaultServer = p.getBoolean("defaultServer", defaultServer); autoPersistUpdates = p.getBoolean("autoPersistUpdates", autoPersistUpdates); loadModuleInfo = p.getBoolean("loadModuleInfo", loadModuleInfo); maxCallStack = p.getInt("maxCallStack", maxCallStack); dumpMetricsOnShutdown = p.getBoolean("dumpMetricsOnShutdown", dumpMetricsOnShutdown); dumpMetricsOptions = p.get("dumpMetricsOptions", dumpMetricsOptions); queryPlanTTLSeconds = p.getInt("queryPlanTTLSeconds", queryPlanTTLSeconds); slowQueryMillis = p.getLong("slowQueryMillis", slowQueryMillis); queryPlanEnable = p.getBoolean("queryPlan.enable", queryPlanEnable); queryPlanThresholdMicros = p.getLong("queryPlan.thresholdMicros", queryPlanThresholdMicros); queryPlanCapture = p.getBoolean("queryPlan.capture", queryPlanCapture); queryPlanCapturePeriodSecs = p.getLong("queryPlan.capturePeriodSecs", queryPlanCapturePeriodSecs); queryPlanCaptureMaxTimeMillis = p.getLong("queryPlan.captureMaxTimeMillis", queryPlanCaptureMaxTimeMillis); queryPlanCaptureMaxCount = p.getInt("queryPlan.captureMaxCount", queryPlanCaptureMaxCount); docStoreOnly = p.getBoolean("docStoreOnly", docStoreOnly); disableL2Cache = p.getBoolean("disableL2Cache", disableL2Cache); localOnlyL2Cache = p.getBoolean("localOnlyL2Cache", localOnlyL2Cache); enabledL2Regions = p.get("enabledL2Regions", enabledL2Regions); notifyL2CacheInForeground = p.getBoolean("notifyL2CacheInForeground", notifyL2CacheInForeground); useJtaTransactionManager = p.getBoolean("useJtaTransactionManager", useJtaTransactionManager); useValidationNotNull = p.getBoolean("useValidationNotNull", useValidationNotNull); autoReadOnlyDataSource = p.getBoolean("autoReadOnlyDataSource", autoReadOnlyDataSource); idGeneratorAutomatic = p.getBoolean("idGeneratorAutomatic", idGeneratorAutomatic); backgroundExecutorSchedulePoolSize = p.getInt("backgroundExecutorSchedulePoolSize", backgroundExecutorSchedulePoolSize); backgroundExecutorShutdownSecs = p.getInt("backgroundExecutorShutdownSecs", backgroundExecutorShutdownSecs); backgroundExecutorWrapper = p.createInstance(BackgroundExecutorWrapper.class, "backgroundExecutorWrapper", backgroundExecutorWrapper); disableClasspathSearch = p.getBoolean("disableClasspathSearch", disableClasspathSearch); currentUserProvider = p.createInstance(CurrentUserProvider.class, "currentUserProvider", currentUserProvider); databasePlatform = p.createInstance(DatabasePlatform.class, "databasePlatform", databasePlatform); encryptKeyManager = p.createInstance(EncryptKeyManager.class, "encryptKeyManager", encryptKeyManager); encryptDeployManager = p.createInstance(EncryptDeployManager.class, "encryptDeployManager", encryptDeployManager); encryptor = p.createInstance(Encryptor.class, "encryptor", encryptor); dbEncrypt = p.createInstance(DbEncrypt.class, "dbEncrypt", dbEncrypt); dbOffline = p.getBoolean("dbOffline", dbOffline); serverCachePlugin = p.createInstance(ServerCachePlugin.class, "serverCachePlugin", serverCachePlugin); String packagesProp = p.get("search.packages", p.get("packages", null)); packages = searchList(packagesProp, packages); skipCacheAfterWrite = p.getBoolean("skipCacheAfterWrite", skipCacheAfterWrite); updateAllPropertiesInBatch = p.getBoolean("updateAllPropertiesInBatch", updateAllPropertiesInBatch); if (p.get("batch.mode") != null || p.get("persistBatching") != null) { throw new IllegalArgumentException("Property 'batch.mode' or 'persistBatching' is being set but no longer used. Please change to use 'persistBatchMode'"); } persistBatch = p.getEnum(PersistBatch.class, "persistBatch", persistBatch); persistBatchOnCascade = p.getEnum(PersistBatch.class, "persistBatchOnCascade", persistBatchOnCascade); int batchSize = p.getInt("batch.size", persistBatchSize); persistBatchSize = p.getInt("persistBatchSize", batchSize); persistenceContextScope = PersistenceContextScope.valueOf(p.get("persistenceContextScope", "TRANSACTION")); changeLogAsync = p.getBoolean("changeLogAsync", changeLogAsync); changeLogIncludeInserts = p.getBoolean("changeLogIncludeInserts", changeLogIncludeInserts); expressionEqualsWithNullAsNoop = p.getBoolean("expressionEqualsWithNullAsNoop", expressionEqualsWithNullAsNoop); expressionNativeIlike = p.getBoolean("expressionNativeIlike", expressionNativeIlike); dataTimeZone = p.get("dataTimeZone", dataTimeZone); asOfViewSuffix = p.get("asOfViewSuffix", asOfViewSuffix); asOfSysPeriod = p.get("asOfSysPeriod", asOfSysPeriod); historyTableSuffix = p.get("historyTableSuffix", historyTableSuffix); jdbcFetchSizeFindEach = p.getInt("jdbcFetchSizeFindEach", jdbcFetchSizeFindEach); jdbcFetchSizeFindList = p.getInt("jdbcFetchSizeFindList", jdbcFetchSizeFindList); databasePlatformName = p.get("databasePlatformName", databasePlatformName); uuidVersion = p.getEnum(UuidVersion.class, "uuidVersion", uuidVersion); uuidStateFile = p.get("uuidStateFile", uuidStateFile); uuidNodeId = p.get("uuidNodeId", uuidNodeId); localTimeWithNanos = p.getBoolean("localTimeWithNanos", localTimeWithNanos); jodaLocalTimeMode = p.get("jodaLocalTimeMode", jodaLocalTimeMode); defaultEnumType = p.getEnum(EnumType.class, "defaultEnumType", defaultEnumType); disableLazyLoading = p.getBoolean("disableLazyLoading", disableLazyLoading); lazyLoadBatchSize = p.getInt("lazyLoadBatchSize", lazyLoadBatchSize); queryBatchSize = p.getInt("queryBatchSize", queryBatchSize); jsonInclude = p.getEnum(JsonConfig.Include.class, "jsonInclude", jsonInclude); jsonDateTime = p.getEnum(JsonConfig.DateTime.class, "jsonDateTime", jsonDateTime); jsonDate = p.getEnum(JsonConfig.Date.class, "jsonDate", jsonDate); jsonMutationDetection = p.getEnum(MutationDetection.class, "jsonMutationDetection", jsonMutationDetection); skipDataSourceCheck = p.getBoolean("skipDataSourceCheck", skipDataSourceCheck); runMigration = p.getBoolean("migration.run", runMigration); ddlGenerate = p.getBoolean("ddl.generate", ddlGenerate); ddlRun = p.getBoolean("ddl.run", ddlRun); ddlExtra = p.getBoolean("ddl.extra", ddlExtra); ddlCreateOnly = p.getBoolean("ddl.createOnly", ddlCreateOnly); ddlInitSql = p.get("ddl.initSql", ddlInitSql); ddlSeedSql = p.get("ddl.seedSql", ddlSeedSql); ddlStrictMode = p.getBoolean("ddl.strictMode", ddlStrictMode); ddlPlaceholders = p.get("ddl.placeholders", ddlPlaceholders); ddlHeader = p.get("ddl.header", ddlHeader); // read tenant-configuration from config: // tenant.mode = NONE | DB | SCHEMA | CATALOG | PARTITION String mode = p.get("tenant.mode"); if (mode != null) { for (TenantMode value : TenantMode.values()) { if (value.name().equalsIgnoreCase(mode)) { tenantMode = value; break; } } } currentTenantProvider = p.createInstance(CurrentTenantProvider.class, "tenant.currentTenantProvider", currentTenantProvider); tenantCatalogProvider = p.createInstance(TenantCatalogProvider.class, "tenant.catalogProvider", tenantCatalogProvider); tenantSchemaProvider = p.createInstance(TenantSchemaProvider.class, "tenant.schemaProvider", tenantSchemaProvider); tenantPartitionColumn = p.get("tenant.partitionColumn", tenantPartitionColumn); classes = readClasses(p); String mappingsProp = p.get("mappingLocations", null); mappingLocations = searchList(mappingsProp, mappingLocations); } private NamingConvention createNamingConvention(PropertiesWrapper properties, NamingConvention namingConvention) { NamingConvention nc = properties.createInstance(NamingConvention.class, "namingConvention", null); return (nc != null) ? nc : namingConvention; } /** * Build the list of classes from the comma delimited string. * * @param properties the properties * @return the classes */ private Set> readClasses(PropertiesWrapper properties) { String classNames = properties.get("classes", null); if (classNames == null) { return classes; } Set> classList = new HashSet<>(); String[] split = StringHelper.splitNames(classNames); for (String cn : split) { if (!"class".equalsIgnoreCase(cn)) { try { classList.add(Class.forName(cn)); } catch (ClassNotFoundException e) { String msg = "Error registering class [" + cn + "] from [" + classNames + "]"; throw new RuntimeException(msg, e); } } } return classList; } private List searchList(String searchNames, List defaultValue) { if (searchNames != null) { String[] entries = StringHelper.splitNames(searchNames); List hitList = new ArrayList<>(entries.length); Collections.addAll(hitList, entries); return hitList; } else { return defaultValue; } } /** * Return the PersistBatch mode to use for 'batchOnCascade' taking into account if the database * platform supports getGeneratedKeys in batch mode. */ public PersistBatch appliedPersistBatchOnCascade() { if (persistBatchOnCascade == PersistBatch.INHERIT) { // use the platform default (ALL except SQL Server which has NONE) return databasePlatform.persistBatchOnCascade(); } return persistBatchOnCascade; } /** * Return the Jackson ObjectMapper. *

* Note that this is not strongly typed as Jackson ObjectMapper is an optional dependency. */ public Object getObjectMapper() { return objectMapper; } /** * Set the Jackson ObjectMapper. *

* Note that this is not strongly typed as Jackson ObjectMapper is an optional dependency. */ public void setObjectMapper(Object objectMapper) { this.objectMapper = objectMapper; } /** * Return true if eq("someProperty", null) should to generate "1=1" rather than "is null" sql expression. */ public boolean isExpressionEqualsWithNullAsNoop() { return expressionEqualsWithNullAsNoop; } /** * Set to true if you want eq("someProperty", null) to generate "1=1" rather than "is null" sql expression. *

* Setting this to true has the effect that eq(propertyName, value), ieq(propertyName, value) and * ne(propertyName, value) have no effect when the value is null. The expression factory adds a NoopExpression * which will add "1=1" into the SQL rather than "is null". */ public void setExpressionEqualsWithNullAsNoop(boolean expressionEqualsWithNullAsNoop) { this.expressionEqualsWithNullAsNoop = expressionEqualsWithNullAsNoop; } /** * Return true if native ILIKE expression should be used if supported by the database platform (e.g. Postgres). */ public boolean isExpressionNativeIlike() { return expressionNativeIlike; } /** * Set to true to use native ILIKE expression if supported by the database platform (e.g. Postgres). */ public void setExpressionNativeIlike(boolean expressionNativeIlike) { this.expressionNativeIlike = expressionNativeIlike; } /** * Return the enabled L2 cache regions. */ public String getEnabledL2Regions() { return enabledL2Regions; } /** * Set the enabled L2 cache regions (comma delimited). */ public void setEnabledL2Regions(String enabledL2Regions) { this.enabledL2Regions = enabledL2Regions; } /** * Return true if L2 cache is disabled. */ public boolean isDisableL2Cache() { return disableL2Cache; } /** * Set to true to disable L2 caching. Typically useful in performance testing. */ public void setDisableL2Cache(boolean disableL2Cache) { this.disableL2Cache = disableL2Cache; } /** * Return true to use local only L2 cache. Effectively ignore l2 cache plugin like ebean-redis etc. */ public boolean isLocalOnlyL2Cache() { return localOnlyL2Cache; } /** * Force the use of local only L2 cache. Effectively ignore l2 cache plugin like ebean-redis etc. */ public void setLocalOnlyL2Cache(boolean localOnlyL2Cache) { this.localOnlyL2Cache = localOnlyL2Cache; } /** * Returns if we use javax.validation.constraints.NotNull */ public boolean isUseValidationNotNull() { return useValidationNotNull; } /** * Controls if Ebean should ignore &x64;javax.validation.contstraints.NotNull or * &x64;jakarta.validation.contstraints.NotNull * with respect to generating a NOT NULL column. *

* Normally when Ebean sees javax NotNull annotation it means that column is defined as NOT NULL. * Set this to false and the javax NotNull annotation is effectively ignored (and * we instead use Ebean's own NotNull annotation or JPA Column(nullable=false) annotation. */ public void setUseValidationNotNull(boolean useValidationNotNull) { this.useValidationNotNull = useValidationNotNull; } /** * Return true if L2 cache notification should run in the foreground. */ public boolean isNotifyL2CacheInForeground() { return notifyL2CacheInForeground; } /** * Set this to true to run L2 cache notification in the foreground. *

* In general we don't want to do that as when we use a distributed cache (like Ignite, Hazelcast etc) * we are making network calls and we prefer to do this in background and not impact the response time * of the executing transaction. */ public void setNotifyL2CacheInForeground(boolean notifyL2CacheInForeground) { this.notifyL2CacheInForeground = notifyL2CacheInForeground; } /** * Return the time to live for ebean's internal query plan. */ public int getQueryPlanTTLSeconds() { return queryPlanTTLSeconds; } /** * Set the time to live for ebean's internal query plan. *

* This is the plan that knows how to execute the query, read the result * and collects execution metrics. By default this is set to 5 mins. */ public void setQueryPlanTTLSeconds(int queryPlanTTLSeconds) { this.queryPlanTTLSeconds = queryPlanTTLSeconds; } /** * Create a new PlatformConfig based of the one held but with overridden properties by reading * properties with the given path and prefix. *

* Typically used in Db Migration generation for many platform targets that might have different * configuration for IdType, UUID, quoted identifiers etc. * * @param propertiesPath The properties path used for loading and setting properties * @param platformPrefix The prefix used for loading and setting properties * @return A copy of the PlatformConfig with overridden properties */ public PlatformConfig newPlatformConfig(String propertiesPath, String platformPrefix) { if (properties == null) { properties = new Properties(); } PropertiesWrapper p = new PropertiesWrapper(propertiesPath, platformPrefix, properties, classLoadConfig); PlatformConfig config = new PlatformConfig(platformConfig); config.loadSettings(p); return config; } /** * Add a mapping location to search for xml mapping via class path search. */ public void addMappingLocation(String mappingLocation) { if (mappingLocations == null) { mappingLocations = new ArrayList<>(); } mappingLocations.add(mappingLocation); } /** * Return mapping locations to search for xml mapping via class path search. */ public List getMappingLocations() { return mappingLocations; } /** * Set mapping locations to search for xml mapping via class path search. *

* This is only used if classes have not been explicitly specified. */ public void setMappingLocations(List mappingLocations) { this.mappingLocations = mappingLocations; } /** * When false we need explicit @GeneratedValue mapping to assign * Identity or Sequence generated values. When true Id properties are automatically * assigned Identity or Sequence without the GeneratedValue mapping. */ public boolean isIdGeneratorAutomatic() { return idGeneratorAutomatic; } /** * Set to false such that Id properties require explicit @GeneratedValue * mapping before they are assigned Identity or Sequence generation based on platform. */ public void setIdGeneratorAutomatic(boolean idGeneratorAutomatic) { this.idGeneratorAutomatic = idGeneratorAutomatic; } /** * Return true if query plan capture is enabled. */ public boolean isQueryPlanEnable() { return queryPlanEnable; } /** * Set to true to enable query plan capture. */ public void setQueryPlanEnable(boolean queryPlanEnable) { this.queryPlanEnable = queryPlanEnable; } /** * Return the query plan collection threshold in microseconds. */ public long getQueryPlanThresholdMicros() { return queryPlanThresholdMicros; } /** * Set the query plan collection threshold in microseconds. *

* Queries executing slower than this will have bind values captured such that later * the query plan can be captured and reported. */ public void setQueryPlanThresholdMicros(long queryPlanThresholdMicros) { this.queryPlanThresholdMicros = queryPlanThresholdMicros; } /** * Return true if periodic capture of query plans is enabled. */ public boolean isQueryPlanCapture() { return queryPlanCapture; } /** * Set to true to turn on periodic capture of query plans. */ public void setQueryPlanCapture(boolean queryPlanCapture) { this.queryPlanCapture = queryPlanCapture; } /** * Return the frequency to capture query plans. */ public long getQueryPlanCapturePeriodSecs() { return queryPlanCapturePeriodSecs; } /** * Set the frequency in seconds to capture query plans. */ public void setQueryPlanCapturePeriodSecs(long queryPlanCapturePeriodSecs) { this.queryPlanCapturePeriodSecs = queryPlanCapturePeriodSecs; } /** * Return the time after which a capture query plans request will * stop capturing more query plans. *

* Effectively this controls the amount of load/time we want to * allow for query plan capture. */ public long getQueryPlanCaptureMaxTimeMillis() { return queryPlanCaptureMaxTimeMillis; } /** * Set the time after which a capture query plans request will * stop capturing more query plans. *

* Effectively this controls the amount of load/time we want to * allow for query plan capture. */ public void setQueryPlanCaptureMaxTimeMillis(long queryPlanCaptureMaxTimeMillis) { this.queryPlanCaptureMaxTimeMillis = queryPlanCaptureMaxTimeMillis; } /** * Return the max number of query plans captured per request. */ public int getQueryPlanCaptureMaxCount() { return queryPlanCaptureMaxCount; } /** * Set the max number of query plans captured per request. */ public void setQueryPlanCaptureMaxCount(int queryPlanCaptureMaxCount) { this.queryPlanCaptureMaxCount = queryPlanCaptureMaxCount; } /** * Return the listener used to process captured query plans. */ public QueryPlanListener getQueryPlanListener() { return queryPlanListener; } /** * Set the listener used to process captured query plans. */ public void setQueryPlanListener(QueryPlanListener queryPlanListener) { this.queryPlanListener = queryPlanListener; } /** * Return true if metrics should be dumped when the server is shutdown. */ public boolean isDumpMetricsOnShutdown() { return dumpMetricsOnShutdown; } /** * Set to true if metrics should be dumped when the server is shutdown. */ public void setDumpMetricsOnShutdown(boolean dumpMetricsOnShutdown) { this.dumpMetricsOnShutdown = dumpMetricsOnShutdown; } /** * Return the options for dumping metrics. */ public String getDumpMetricsOptions() { return dumpMetricsOptions; } /** * Include 'sql' or 'hash' in options such that they are included in the output. * * @param dumpMetricsOptions Example "sql,hash", "sql" */ public void setDumpMetricsOptions(String dumpMetricsOptions) { this.dumpMetricsOptions = dumpMetricsOptions; } /** * Return true if entity classes should be loaded and registered via EntityClassRegister. *

* When false we either register entity classes via application code or use classpath * scanning to find and register entity classes. */ public boolean isLoadModuleInfo() { return loadModuleInfo; } /** * Deprecated - migrate to isLoadModuleInfo(). */ @Deprecated public boolean isAutoLoadModuleInfo() { return loadModuleInfo; } /** * Set false to turn off automatic registration of entity beans. *

* When using query beans that also generates a module info class that * can register the entity bean classes (to avoid classpath scanning). * This is on by default and setting this to false turns it off. */ public void setLoadModuleInfo(boolean loadModuleInfo) { this.loadModuleInfo = loadModuleInfo; } /** * Return the naming convention to apply to metrics names. */ public Function getMetricNaming() { return metricNaming; } /** * Set the naming convention to apply to metrics names. */ public void setMetricNaming(Function metricNaming) { this.metricNaming = metricNaming; } public enum UuidVersion { VERSION4, VERSION1, VERSION1RND } }