org.apache.activemq.artemis.jdbc.store.sql

Class PropertySQLProvider

java.lang.Object

org.apache.activemq.artemis.jdbc.store.sql.PropertySQLProvider

All Implemented Interfaces:

SQLProvider

public class PropertySQLProvider
extends Object
implements SQLProvider

Property-based implementation of a SQLProvider's factory. Properties are stored in a journal-sql.properties. Dialects specific to a database can be customized by suffixing the property keys with the name of the dialect.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	PropertySQLProvider.Factory

Nested classes/interfaces inherited from interface org.apache.activemq.artemis.jdbc.store.sql.SQLProvider

SQLProvider.DatabaseStoreType

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	PropertySQLProvider(PropertySQLProvider.Factory.SQLDialect dialect, String tableName, Properties sqlProperties)

Method Summary

Modifier and Type	Method and Description
boolean	closeConnectionOnShutdown()
String	createBackupLockSQL()
String	createLiveLockSQL()
String	createNodeIdSQL()
String	createNodeManagerStoreTableSQL()
String	createStateSQL()
String	currentTimestampSQL()
String	getAppendToLargeObjectSQL()
String	getCloneFileRecordByIdSQL()
String	getCopyFileRecordByIdSQL()
String	getCountJournalRecordsSQL()
String	getCreateFileTableSQL()
String[]	getCreateJournalTableSQL()
String	getDeleteFileSQL()
String	getDeleteJournalRecordsSQL()
String	getDeleteJournalTxRecordsSQL()
String	getDropFileTableSQL()
String	getInsertFileSQL()
String	getInsertJournalRecordsSQL()
long	getMaxBlobSize()
String	getReadLargeObjectSQL()
String	getSelectFileByFileName()
String	getSelectFileNamesByExtensionSQL()
String	getSelectJournalRecordsSQL()
String	getTableName()
String	getUpdateFileNameByIdSQL()
String	initializeNodeIdSQL()
String	isBackupLockedSQL()
String	isLiveLockedSQL()
String	readNodeIdSQL()
String	readStateSQL()
String	renewBackupLockSQL()
String	renewLiveLockSQL()
String	tryAcquireBackupLockSQL()
String	tryAcquireLiveLockSQL()
String	tryReleaseBackupLockSQL()
String	tryReleaseLiveLockSQL()
String	writeNodeIdSQL()
String	writeStateSQL()

Methods inherited from class java.lang.Object

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

Constructor Detail

PropertySQLProvider

protected PropertySQLProvider(PropertySQLProvider.Factory.SQLDialect dialect,
                              String tableName,
                              Properties sqlProperties)

Method Detail

getMaxBlobSize

public long getMaxBlobSize()

Specified by:

getMaxBlobSize in interface SQLProvider

getCreateJournalTableSQL

public String[] getCreateJournalTableSQL()

Specified by:

getCreateJournalTableSQL in interface SQLProvider

getInsertJournalRecordsSQL

public String getInsertJournalRecordsSQL()

Specified by:

getInsertJournalRecordsSQL in interface SQLProvider

getSelectJournalRecordsSQL

public String getSelectJournalRecordsSQL()

Specified by:

getSelectJournalRecordsSQL in interface SQLProvider

getDeleteJournalRecordsSQL

public String getDeleteJournalRecordsSQL()

Specified by:

getDeleteJournalRecordsSQL in interface SQLProvider

getDeleteJournalTxRecordsSQL

public String getDeleteJournalTxRecordsSQL()

Specified by:

getDeleteJournalTxRecordsSQL in interface SQLProvider

getTableName

public String getTableName()

Specified by:

getTableName in interface SQLProvider

getCreateFileTableSQL

public String getCreateFileTableSQL()

Specified by:

getCreateFileTableSQL in interface SQLProvider

getInsertFileSQL

public String getInsertFileSQL()

Specified by:

getInsertFileSQL in interface SQLProvider

getSelectFileNamesByExtensionSQL

public String getSelectFileNamesByExtensionSQL()

Specified by:

getSelectFileNamesByExtensionSQL in interface SQLProvider

getSelectFileByFileName

public String getSelectFileByFileName()

Specified by:

getSelectFileByFileName in interface SQLProvider

getAppendToLargeObjectSQL

public String getAppendToLargeObjectSQL()

Specified by:

getAppendToLargeObjectSQL in interface SQLProvider

getReadLargeObjectSQL

public String getReadLargeObjectSQL()

Specified by:

getReadLargeObjectSQL in interface SQLProvider

getDeleteFileSQL

public String getDeleteFileSQL()

Specified by:

getDeleteFileSQL in interface SQLProvider

getUpdateFileNameByIdSQL

public String getUpdateFileNameByIdSQL()

Specified by:

getUpdateFileNameByIdSQL in interface SQLProvider

getCopyFileRecordByIdSQL

public String getCopyFileRecordByIdSQL()

Specified by:

getCopyFileRecordByIdSQL in interface SQLProvider

getDropFileTableSQL

public String getDropFileTableSQL()

Specified by:

getDropFileTableSQL in interface SQLProvider

getCloneFileRecordByIdSQL

public String getCloneFileRecordByIdSQL()

Specified by:

getCloneFileRecordByIdSQL in interface SQLProvider

getCountJournalRecordsSQL

public String getCountJournalRecordsSQL()

Specified by:

getCountJournalRecordsSQL in interface SQLProvider

closeConnectionOnShutdown

public boolean closeConnectionOnShutdown()

Specified by:

closeConnectionOnShutdown in interface SQLProvider

createNodeManagerStoreTableSQL

public String createNodeManagerStoreTableSQL()

Specified by:

createNodeManagerStoreTableSQL in interface SQLProvider

createStateSQL

public String createStateSQL()

Specified by:

createStateSQL in interface SQLProvider

createNodeIdSQL

public String createNodeIdSQL()

Specified by:

createNodeIdSQL in interface SQLProvider

createLiveLockSQL

public String createLiveLockSQL()

Specified by:

createLiveLockSQL in interface SQLProvider

createBackupLockSQL

public String createBackupLockSQL()

Specified by:

createBackupLockSQL in interface SQLProvider

tryAcquireLiveLockSQL

public String tryAcquireLiveLockSQL()

Specified by:

tryAcquireLiveLockSQL in interface SQLProvider

tryAcquireBackupLockSQL

public String tryAcquireBackupLockSQL()

Specified by:

tryAcquireBackupLockSQL in interface SQLProvider

tryReleaseLiveLockSQL

public String tryReleaseLiveLockSQL()

Specified by:

tryReleaseLiveLockSQL in interface SQLProvider

tryReleaseBackupLockSQL

public String tryReleaseBackupLockSQL()

Specified by:

tryReleaseBackupLockSQL in interface SQLProvider

isLiveLockedSQL

public String isLiveLockedSQL()

Specified by:

isLiveLockedSQL in interface SQLProvider

isBackupLockedSQL

public String isBackupLockedSQL()

Specified by:

isBackupLockedSQL in interface SQLProvider

renewLiveLockSQL

public String renewLiveLockSQL()

Specified by:

renewLiveLockSQL in interface SQLProvider

renewBackupLockSQL

public String renewBackupLockSQL()

Specified by:

renewBackupLockSQL in interface SQLProvider

currentTimestampSQL

public String currentTimestampSQL()

Specified by:

currentTimestampSQL in interface SQLProvider

writeStateSQL

public String writeStateSQL()

Specified by:

writeStateSQL in interface SQLProvider

readStateSQL

public String readStateSQL()

Specified by:

readStateSQL in interface SQLProvider

writeNodeIdSQL

public String writeNodeIdSQL()

Specified by:

writeNodeIdSQL in interface SQLProvider

readNodeIdSQL

public String readNodeIdSQL()

Specified by:

readNodeIdSQL in interface SQLProvider

initializeNodeIdSQL

public String initializeNodeIdSQL()

Specified by:

initializeNodeIdSQL in interface SQLProvider