org.springframework.integration.jdbc.metadata

Class JdbcMetadataStore

java.lang.Object

org.springframework.integration.jdbc.metadata.JdbcMetadataStore

All Implemented Interfaces:

InitializingBean, ConcurrentMetadataStore, MetadataStore

public class JdbcMetadataStore
extends Object
implements ConcurrentMetadataStore, InitializingBean

Implementation of MetadataStore 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 MetadataStore.

Since:

5.0

Author:

Bojan Vukasovic, Artem Bilan

Field Summary

Fields

Modifier and Type	Field and Description
static String	DEFAULT_TABLE_PREFIX Default value for the table prefix property.

Constructor Summary

Constructors

Constructor and Description
JdbcMetadataStore(DataSource dataSource) Instantiate a JdbcMetadataStore using provided dataSource DataSource.
JdbcMetadataStore(JdbcOperations jdbcOperations) Instantiate a JdbcMetadataStore using provided jdbcOperations JdbcOperations.

Method Summary

Modifier and Type	Method and Description
void	afterPropertiesSet()
String	get(String key) Reads a value for the given key from this MetadataStore.
void	put(String key, String value) Writes a key value pair to this MetadataStore.
String	putIfAbsent(String key, String value) Atomically insert the key into the store.
String	remove(String key) Remove a value for the given key from this MetadataStore.
boolean	replace(String key, String oldValue, String newValue) Atomically replace the value for the key in the store if the old value matches the oldValue argument.
void	setRegion(String region) A unique grouping identifier for all messages persisted with this store.
void	setTablePrefix(String tablePrefix) Public setter for the table prefix property.

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_TABLE_PREFIX

public static final String DEFAULT_TABLE_PREFIX

Default value for the table prefix property.

See Also:

Constant Field Values

Constructor Detail

JdbcMetadataStore

public JdbcMetadataStore(DataSource dataSource)

Instantiate a JdbcMetadataStore using provided dataSource DataSource.

Parameters:

dataSource - a DataSource

JdbcMetadataStore

public JdbcMetadataStore(JdbcOperations jdbcOperations)

Instantiate a JdbcMetadataStore using provided jdbcOperations JdbcOperations.

Parameters:

jdbcOperations - a JdbcOperations

Method Detail

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception

Specified by:

afterPropertiesSet in interface InitializingBean

Throws:

Exception

setTablePrefix

public void setTablePrefix(String tablePrefix)

Public setter for the table prefix property. This will be prefixed to all the table names before queries are executed. Defaults to DEFAULT_TABLE_PREFIX.

Parameters:

tablePrefix - the tablePrefix to set

setRegion

public void setRegion(String region)

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 to DEFAULT.

Parameters:

region - the region name to set

putIfAbsent

@Transactional
public String putIfAbsent(String key,
                                         String value)

Description copied from interface: ConcurrentMetadataStore

Atomically insert the key into the store.

Specified by:

putIfAbsent in interface ConcurrentMetadataStore

Parameters:

key - The key.

value - The value.

Returns:

null if successful, the old value otherwise.

replace

@Transactional
public boolean replace(String key,
                                      String oldValue,
                                      String newValue)

Description copied from interface: ConcurrentMetadataStore

Atomically replace the value for the key in the store if the old value matches the oldValue argument.

Specified by:

replace in interface ConcurrentMetadataStore

Parameters:

key - The key.

oldValue - The old value.

newValue - The new value.

Returns:

true if successful.

put

@Transactional
public void put(String key,
                               String value)

Description copied from interface: MetadataStore

Writes a key value pair to this MetadataStore.

Specified by:

put in interface MetadataStore

Parameters:

key - The key.

value - The value.

get

@Transactional
public String get(String key)

Description copied from interface: MetadataStore

Reads a value for the given key from this MetadataStore.

Specified by:

get in interface MetadataStore

Parameters:

key - The key.

Returns:

The value.

remove

@Transactional
public String remove(String key)

Description copied from interface: MetadataStore

Remove a value for the given key from this MetadataStore.

Specified by:

remove in interface MetadataStore

Parameters:

key - The key.

Returns:

The previous value associated with key, or null if there was no mapping for key.