Package com.evolveum.midpoint.repo.sqale

Class SqaleRepositoryConfiguration

java.lang.Object

com.evolveum.midpoint.repo.sqale.SqaleRepositoryConfiguration

All Implemented Interfaces:

JdbcRepositoryConfiguration

public class SqaleRepositoryConfiguration
extends Object
implements JdbcRepositoryConfiguration

Common part of the SQL-based repository configuration. Contains JDBC/datasource setup, connection pool configuration, but no framework/ORM stuff.

Field Summary

Fields

Modifier and Type	Field	Description
static String	APPLICATION_NAME_JDBC_PARAM

Fields inherited from interface com.evolveum.midpoint.repo.sqlbase.JdbcRepositoryConfiguration

PROPERTY_CREATE_MISSING_CUSTOM_COLUMNS, PROPERTY_DATABASE, PROPERTY_DATASOURCE, PROPERTY_DRIVER_CLASS_NAME, PROPERTY_FULL_OBJECT_FORMAT, PROPERTY_IDLE_TIMEOUT, PROPERTY_INITIALIZATION_FAIL_TIMEOUT, PROPERTY_ITERATIVE_SEARCH_BY_PAGING_BATCH_SIZE, PROPERTY_JDBC_PASSWORD, PROPERTY_JDBC_PASSWORD_FILE, PROPERTY_JDBC_URL, PROPERTY_JDBC_USERNAME, PROPERTY_KEEPALIVE_TIME, PROPERTY_LEAK_DETECTION_THRESHOLD, PROPERTY_MAX_LIFETIME, PROPERTY_MAX_POOL_SIZE, PROPERTY_MIN_POOL_SIZE, PROPERTY_PERFORMANCE_STATISTICS_FILE, PROPERTY_PERFORMANCE_STATISTICS_LEVEL, PROPERTY_USE_ZIP, PROPERTY_USE_ZIP_AUDIT

Constructor Summary

Constructors

Constructor	Description
SqaleRepositoryConfiguration(@NotNull org.apache.commons.configuration2.Configuration configuration)

Method Summary

Modifier and Type	Method	Description
@NotNull SupportedDatabase	getDatabaseType()
String	getDataSource()
String	getDefaultEmbeddedJdbcUrlPrefix()
String	getDriverClassName()
String	getFullObjectFormat()	Returns serialization format (language) for writing fullObject.
Long	getIdleTimeout()
long	getInitializationFailTimeout()
int	getIterativeSearchByPagingBatchSize()
String	getJdbcPassword()
String	getJdbcUrl()
String	getJdbcUrl(@NotNull String applicationName)	Allows distinguishing connections for various usages like repository, audit, scheduler.
String	getJdbcUsername()
Long	getKeepaliveTime()
Long	getLeakDetectionThreshold()
Long	getMaxLifetime()
int	getMaxPoolSize()
int	getMinPoolSize()
String	getPerformanceStatisticsFile()
int	getPerformanceStatisticsLevel()
long	getSqlDurationWarningMs()	Returns threshold duration for SQL, after which it should be logged on warning level.
TransactionIsolation	getTransactionIsolation()
void	init()
static SqaleRepositoryConfiguration	initForAudit(@NotNull SqaleRepositoryConfiguration mainRepoConfig, org.apache.commons.configuration2.Configuration auditConfig)	Creates a copy of provided configuration for audit and applies override from config.xml.
boolean	isCreateMissingCustomColumns()
boolean	isEmbedded()
boolean	isUseZip()	We leave potential compression to PG, for us the values are plain.
boolean	isUseZipAudit()	We leave potential compression to PG, for us the values are plain.
boolean	isUsing(SupportedDatabase db)
protected void	notEmpty(String value, String message)
void	setIterativeSearchByPagingBatchSize(int iterativeSearchByPagingBatchSize)
boolean	useSetReadOnlyOnConnection()	If true, then Connection.setReadOnly(boolean) is used for read only transactions and JdbcRepositoryConfiguration.getReadOnlyTransactionStatement() is ignored.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.evolveum.midpoint.repo.sqlbase.JdbcRepositoryConfiguration

getReadOnlyTransactionStatement, isUsingH2, isUsingOracle, isUsingPostgreSQL, isUsingSQLServer

Field Detail

APPLICATION_NAME_JDBC_PARAM

public static final String APPLICATION_NAME_JDBC_PARAM

See Also:

Constant Field Values

Constructor Detail

SqaleRepositoryConfiguration

public SqaleRepositoryConfiguration(@NotNull
                                    @NotNull org.apache.commons.configuration2.Configuration configuration)

Method Detail

init

@PostConstruct
public void init()
          throws RepositoryServiceFactoryException

Throws:

RepositoryServiceFactoryException

getDatabaseType

@NotNull
public @NotNull SupportedDatabase getDatabaseType()

Specified by:

getDatabaseType in interface JdbcRepositoryConfiguration

getDataSource

public String getDataSource()

Specified by:

getDataSource in interface JdbcRepositoryConfiguration

notEmpty

protected void notEmpty(String value,
                        String message)
                 throws RepositoryServiceFactoryException

Throws:

RepositoryServiceFactoryException

getDriverClassName

public String getDriverClassName()

Specified by:

getDriverClassName in interface JdbcRepositoryConfiguration

getJdbcUrl

public String getJdbcUrl()

Specified by:

getJdbcUrl in interface JdbcRepositoryConfiguration

getJdbcUrl

public String getJdbcUrl(@NotNull
                         @NotNull String applicationName)

Description copied from interface: JdbcRepositoryConfiguration

Allows distinguishing connections for various usages like repository, audit, scheduler. By default, this doesn't do anything, but works for new repository.

Specified by:

getJdbcUrl in interface JdbcRepositoryConfiguration

getJdbcUsername

public String getJdbcUsername()

Specified by:

getJdbcUsername in interface JdbcRepositoryConfiguration

getJdbcPassword

public String getJdbcPassword()

Specified by:

getJdbcPassword in interface JdbcRepositoryConfiguration

isUseZip

public boolean isUseZip()

We leave potential compression to PG, for us the values are plain.

Specified by:

isUseZip in interface JdbcRepositoryConfiguration

isUseZipAudit

public boolean isUseZipAudit()

We leave potential compression to PG, for us the values are plain.

Specified by:

isUseZipAudit in interface JdbcRepositoryConfiguration

getFullObjectFormat

public String getFullObjectFormat()

Returns serialization format (language) for writing fullObject. Also see JdbcRepositoryConfiguration.PROPERTY_FULL_OBJECT_FORMAT.

Specified by:

getFullObjectFormat in interface JdbcRepositoryConfiguration

isEmbedded

public boolean isEmbedded()

Specified by:

isEmbedded in interface JdbcRepositoryConfiguration

getDefaultEmbeddedJdbcUrlPrefix

public String getDefaultEmbeddedJdbcUrlPrefix()

Specified by:

getDefaultEmbeddedJdbcUrlPrefix in interface JdbcRepositoryConfiguration

isUsing

public boolean isUsing(SupportedDatabase db)

Specified by:

isUsing in interface JdbcRepositoryConfiguration

getTransactionIsolation

public TransactionIsolation getTransactionIsolation()

Specified by:

getTransactionIsolation in interface JdbcRepositoryConfiguration

useSetReadOnlyOnConnection

public boolean useSetReadOnlyOnConnection()

Description copied from interface: JdbcRepositoryConfiguration

If true, then Connection.setReadOnly(boolean) is used for read only transactions and JdbcRepositoryConfiguration.getReadOnlyTransactionStatement() is ignored.

Specified by:

useSetReadOnlyOnConnection in interface JdbcRepositoryConfiguration

getMinPoolSize

public int getMinPoolSize()

Specified by:

getMinPoolSize in interface JdbcRepositoryConfiguration

getMaxPoolSize

public int getMaxPoolSize()

Specified by:

getMaxPoolSize in interface JdbcRepositoryConfiguration

getMaxLifetime

public Long getMaxLifetime()

Specified by:

getMaxLifetime in interface JdbcRepositoryConfiguration

getIdleTimeout

public Long getIdleTimeout()

Specified by:

getIdleTimeout in interface JdbcRepositoryConfiguration

getInitializationFailTimeout

public long getInitializationFailTimeout()

Specified by:

getInitializationFailTimeout in interface JdbcRepositoryConfiguration

getKeepaliveTime

public Long getKeepaliveTime()

Specified by:

getKeepaliveTime in interface JdbcRepositoryConfiguration

getLeakDetectionThreshold

public Long getLeakDetectionThreshold()

Specified by:

getLeakDetectionThreshold in interface JdbcRepositoryConfiguration

getPerformanceStatisticsFile

public String getPerformanceStatisticsFile()

Specified by:

getPerformanceStatisticsFile in interface JdbcRepositoryConfiguration

getPerformanceStatisticsLevel

public int getPerformanceStatisticsLevel()

Specified by:

getPerformanceStatisticsLevel in interface JdbcRepositoryConfiguration

getIterativeSearchByPagingBatchSize

public int getIterativeSearchByPagingBatchSize()

Specified by:

getIterativeSearchByPagingBatchSize in interface JdbcRepositoryConfiguration

setIterativeSearchByPagingBatchSize

public void setIterativeSearchByPagingBatchSize(int iterativeSearchByPagingBatchSize)

isCreateMissingCustomColumns

public boolean isCreateMissingCustomColumns()

Specified by:

isCreateMissingCustomColumns in interface JdbcRepositoryConfiguration

getSqlDurationWarningMs

public long getSqlDurationWarningMs()

Returns threshold duration for SQL, after which it should be logged on warning level. Value of 0 or less means that this warning is disabled.

initForAudit

public static SqaleRepositoryConfiguration initForAudit(@NotNull
                                                        @NotNull SqaleRepositoryConfiguration mainRepoConfig,
                                                        org.apache.commons.configuration2.Configuration auditConfig)

Creates a copy of provided configuration for audit and applies override from config.xml. This is used when the same data source is used by audit and repository.