Class JdbcMetadataStore
java.lang.Object
org.springframework.integration.jdbc.metadata.JdbcMetadataStore
- All Implemented Interfaces:
org.springframework.beans.factory.InitializingBean,org.springframework.integration.metadata.ConcurrentMetadataStore,org.springframework.integration.metadata.MetadataStore
public class JdbcMetadataStore
extends Object
implements org.springframework.integration.metadata.ConcurrentMetadataStore, org.springframework.beans.factory.InitializingBean
Implementation of
ConcurrentMetadataStore using a relational database via JDBC.
SQL scripts to create the necessary tables are packaged as
org/springframework/integration/jdbc/schema-*.sql,
where * is the target database type.
The transaction management is required to use this ConcurrentMetadataStore.
- Since:
- 5.0
-
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final StringDefault value for the table prefix property. -
Constructor Summary
ConstructorsConstructorDescriptionJdbcMetadataStore(DataSource dataSource) Instantiate aJdbcMetadataStoreusing provided dataSourceDataSource.JdbcMetadataStore(org.springframework.jdbc.core.JdbcOperations jdbcOperations) Instantiate aJdbcMetadataStoreusing provided jdbcOperationsJdbcOperations. -
Method Summary
Modifier and TypeMethodDescriptionvoidvoidputIfAbsent(String key, String value) booleanvoidsetLockHint(String lockHint) Specify a row lock hint for the query in the lock-based operations.voidA unique grouping identifier for all messages persisted with this store.voidsetTablePrefix(String tablePrefix) Public setter for the table prefix property.
-
Field Details
-
DEFAULT_TABLE_PREFIX
Default value for the table prefix property.- See Also:
-
-
Constructor Details
-
JdbcMetadataStore
Instantiate aJdbcMetadataStoreusing provided dataSourceDataSource.- Parameters:
dataSource- aDataSource
-
JdbcMetadataStore
public JdbcMetadataStore(org.springframework.jdbc.core.JdbcOperations jdbcOperations) Instantiate aJdbcMetadataStoreusing provided jdbcOperationsJdbcOperations.- Parameters:
jdbcOperations- aJdbcOperations
-
-
Method Details
-
setTablePrefix
Public setter for the table prefix property. This will be prefixed to all the table names before queries are executed. Defaults toDEFAULT_TABLE_PREFIX.- Parameters:
tablePrefix- the tablePrefix to set
-
setRegion
A unique grouping identifier for all messages persisted with this store. Using multiple regions allows the store to be partitioned (if necessary) for different purposes. Defaults toDEFAULT.- Parameters:
region- the region name to set
-
setLockHint
Specify a row lock hint for the query in the lock-based operations. Defaults toFOR UPDATE. Can be specified as an empty string, if the target RDBMS doesn't support locking on tables from queries. The value depends from RDBMS vendor, e.g. SQL Server requiresWITH (ROWLOCK).- Parameters:
lockHint- the RDBMS vendor-specific lock hint.- Since:
- 5.0.7
-
afterPropertiesSet
public void afterPropertiesSet()- Specified by:
afterPropertiesSetin interfaceorg.springframework.beans.factory.InitializingBean
-
putIfAbsent
- Specified by:
putIfAbsentin interfaceorg.springframework.integration.metadata.ConcurrentMetadataStore
-
replace
- Specified by:
replacein interfaceorg.springframework.integration.metadata.ConcurrentMetadataStore
-
put
- Specified by:
putin interfaceorg.springframework.integration.metadata.MetadataStore
-
get
- Specified by:
getin interfaceorg.springframework.integration.metadata.MetadataStore
-
remove
- Specified by:
removein interfaceorg.springframework.integration.metadata.MetadataStore
-