public class JdbcMetadataStore extends ObjectSE implements ConcurrentMetadataStore, InitializingBean
ConcurrentMetadataStore
の実装。必要なテーブルを作成するための SQL スクリプトは、org/springframework/integration/jdbc/schema-*.sql
としてパッケージ化されています。ここで、*
はターゲットデータベース型です。 この ConcurrentMetadataStore
を使用するには、トランザクション管理が必要です。
修飾子と型 | フィールドと説明 |
---|---|
static StringSE | DEFAULT_TABLE_PREFIX テーブルプレフィックスプロパティのデフォルト値。 |
コンストラクターと説明 |
---|
JdbcMetadataStore(DataSourceSE dataSource) 提供された dataSource DataSource SE を使用して JdbcMetadataStore をインスタンス化します。 |
JdbcMetadataStore(JdbcOperations jdbcOperations) 提供された jdbcOperations JdbcOperations を使用して JdbcMetadataStore をインスタンス化します。 |
修飾子と型 | メソッドと説明 |
---|---|
void | afterPropertiesSet() |
StringSE | get(StringSE key) この MetadataStore から指定されたキーの値を読み取ります。 |
void | put(StringSE key, StringSE value) キーと値のペアをこの MetadataStore に書き込みます。 |
StringSE | putIfAbsent(StringSE key, StringSE value) キーをストアに原子的に挿入します。 |
StringSE | remove(StringSE key) この MetadataStore から指定されたキーの値を削除します。 |
boolean | replace(StringSE key, StringSE oldValue, StringSE newValue) 古い値が oldValue 引数と一致する場合、ストア内のキーの値をアトミックに置き換えます。 |
void | setLockHint(StringSE lockHint) ロックベースの操作でクエリの行ロックヒントを指定します。 |
void | setRegion(StringSE region) このストアで保持されるすべてのメッセージの一意のグループ化識別子。 |
void | setTablePrefix(StringSE tablePrefix) テーブルプレフィックスプロパティのパブリック setter。 |
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSE
public JdbcMetadataStore(DataSourceSE dataSource)
DataSource
SE を使用して JdbcMetadataStore
をインスタンス化します。dataSource
- DataSource
SEpublic JdbcMetadataStore(JdbcOperations jdbcOperations)
JdbcOperations
を使用して JdbcMetadataStore
をインスタンス化します。jdbcOperations
- JdbcOperations
public void setTablePrefix(StringSE tablePrefix)
DEFAULT_TABLE_PREFIX
です。tablePrefix
- 設定する tablePrefixpublic void setRegion(StringSE region)
DEFAULT
です。region
- 設定する領域名 public void setLockHint(StringSE lockHint)
FOR UPDATE
です。ターゲット RDBMS がクエリからのテーブルのロックをサポートしていない場合は、空の文字列として指定できます。値は RDBMS ベンダーによって異なります。SQL Server には WITH (ROWLOCK)
が必要です。lockHint
- RDBMS ベンダー固有のロックヒント。public void afterPropertiesSet()
InitializingBean
の afterPropertiesSet
@Transactional public StringSE putIfAbsent(StringSE key, StringSE value)
ConcurrentMetadataStore
ConcurrentMetadataStore
の putIfAbsent
key
- キー。value
- 値。@Transactional public boolean replace(StringSE key, StringSE oldValue, StringSE newValue)
ConcurrentMetadataStore
ConcurrentMetadataStore
の replace
key
- キー。oldValue
- 古い値。newValue
- 新しい値。@Transactional public void put(StringSE key, StringSE value)
MetadataStore
MetadataStore
の put
key
- キー。value
- 値。@Transactional public StringSE get(StringSE key)
MetadataStore
MetadataStore
の get
key
- キー。@Transactional public StringSE remove(StringSE key)
MetadataStore
MetadataStore
の remove
key
- キー。