org.infinispan.loaders.jdbc
Class AbstractNonDelegatingJdbcCacheStoreConfig

java.lang.Object
  org.infinispan.config.AbstractConfigurationBean
      org.infinispan.config.AbstractNamedCacheConfigurationBean
          org.infinispan.loaders.AbstractCacheLoaderConfig
              org.infinispan.loaders.AbstractCacheStoreConfig
                  org.infinispan.loaders.LockSupportCacheStoreConfig
                      org.infinispan.loaders.jdbc.AbstractJdbcCacheStoreConfig
                          org.infinispan.loaders.jdbc.AbstractNonDelegatingJdbcCacheStoreConfig

All Implemented Interfaces:

Serializable, Cloneable, CloneableConfigurationComponent, JAXBUnmarshallable, CacheLoaderConfig, CacheStoreConfig

Direct Known Subclasses:

JdbcBinaryCacheStoreConfig, JdbcStringBasedCacheStoreConfig

public abstract class AbstractNonDelegatingJdbcCacheStoreConfig
extends AbstractJdbcCacheStoreConfig

An abstract configuration for JDBC cache stores which have support for locking.

Version:

4.1

Author:

Manik Surtani

See Also:

Serialized Form

Field Summary

static int	DEFAULT_CONCURRENCY_LEVEL
static int	DEFAULT_LOCK_ACQUISITION_TIMEOUT
protected boolean	manageConnectionFactory
protected TableManipulation	tableManipulation

Fields inherited from class org.infinispan.loaders.jdbc.AbstractJdbcCacheStoreConfig

connectionFactoryConfig

Fields inherited from class org.infinispan.loaders.AbstractCacheStoreConfig

async, fetchPersistentState, ignoreModifications, purgeOnStartup, purgerThreads, purgeSynchronously, singletonStore

Fields inherited from class org.infinispan.loaders.AbstractCacheLoaderConfig

cacheLoaderClassName, properties

Fields inherited from class org.infinispan.config.AbstractNamedCacheConfigurationBean

cr

Fields inherited from class org.infinispan.config.AbstractConfigurationBean

overriddenConfigurationElements

Constructor Summary

AbstractNonDelegatingJdbcCacheStoreConfig()

Method Summary

AbstractNonDelegatingJdbcCacheStoreConfig	clone()
int	getBatchSize()
String	getDatabaseType()
int	getFetchSize()
TableManipulation	getTableManipulation()
boolean	isManageConnectionFactory() If this method returns false, then the connection factory should not be created by the JdbcStringBasedCacheStore, but will be injected through JdbcStringBasedCacheStore.doConnectionFactoryInitialization(org.infinispan.loaders.jdbc.connectionfactory.ConnectionFactory)
void	setBatchSize(int batchSize)
void	setCacheName(String cacheName) Sets the name of the table where data will be stored.
void	setCreateTableOnStart(boolean createTableOnStart)
void	setDatabaseType(String dbType) Sets the database dialect.
void	setDataColumnName(String dataColumnName) Sets the name of the column where the StoredEntry will be binary stored.
void	setDataColumnType(String dataColumnType) Sets the type of the column where data will be binary stored.
void	setDropTableOnExit(boolean dropTableOnExit)
void	setFetchSize(int fetchSize)
void	setIdColumnName(String idColumnName) Sets the name of the column where the id will be stored.
void	setIdColumnType(String idColumnType) sql equivalent for java's String.
void	setTableManipulation(TableManipulation tableManipulation)
void	setTimestampColumnName(String timestampColumnName) Sets the name of the column where the timestamp (Long in java) will be stored.
void	setTimestampColumnType(String timestampColumnType) Sets the prefix for the name of the table where the data will be stored.
String	toString()

Methods inherited from class org.infinispan.loaders.jdbc.AbstractJdbcCacheStoreConfig

getConnectionFactoryConfig, setConnectionFactoryClass, setConnectionUrl, setDatasourceJndiLocation, setDriverClass, setPassword, setUserName

Methods inherited from class org.infinispan.loaders.LockSupportCacheStoreConfig

getLockAcquistionTimeout, getLockConcurrencyLevel, setLockAcquistionTimeout, setLockConcurrencyLevel

Methods inherited from class org.infinispan.loaders.AbstractCacheStoreConfig

accept, asyncStore, equals, equalsExcludingProperties, fetchPersistentState, getAsyncStoreConfig, getPurgerThreads, getSingletonStoreConfig, getTypedProperties, hashCode, hashCodeExcludingProperties, ignoreModifications, isFetchPersistentState, isIgnoreModifications, isPurgeOnStartup, isPurgeSynchronously, purgeOnStartup, purgerThreads, purgeSynchronously, setAsyncStoreConfig, setFetchPersistentState, setIgnoreModifications, setPurgeOnStartup, setPurgerThreads, setPurgeSynchronously, setSingletonStoreConfig, setTypedProperties, singletonStore

Methods inherited from class org.infinispan.loaders.AbstractCacheLoaderConfig

getCacheLoaderClassName, getClassLoader, getProperties, setCacheLoaderClassName, setProperties, setProperties

Methods inherited from class org.infinispan.config.AbstractNamedCacheConfigurationBean

hasComponentStarted, inject

Methods inherited from class org.infinispan.config.AbstractConfigurationBean

testImmutability, toTypedProperties, toTypedProperties, uc, willUnmarshall

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.infinispan.loaders.CacheLoaderConfig

getCacheLoaderClassName, getClassLoader, setCacheLoaderClassName

Field Detail

DEFAULT_CONCURRENCY_LEVEL

public static final int DEFAULT_CONCURRENCY_LEVEL

See Also:

Constant Field Values

DEFAULT_LOCK_ACQUISITION_TIMEOUT

public static final int DEFAULT_LOCK_ACQUISITION_TIMEOUT

See Also:

Constant Field Values

tableManipulation

protected TableManipulation tableManipulation

manageConnectionFactory

protected boolean manageConnectionFactory

Constructor Detail

AbstractNonDelegatingJdbcCacheStoreConfig

public AbstractNonDelegatingJdbcCacheStoreConfig()

Method Detail

setCacheName

public void setCacheName(String cacheName)

Sets the name of the table where data will be stored.

setIdColumnName

public void setIdColumnName(String idColumnName)

Sets the name of the column where the id will be stored. The id is obtained through:

   key2StringMapper.getStringMapping(storedEntry.getKey());
 

Mandatory.

setDataColumnName

public void setDataColumnName(String dataColumnName)

Sets the name of the column where the StoredEntry will be binary stored. Mandatory.

setTimestampColumnName

public void setTimestampColumnName(String timestampColumnName)

Sets the name of the column where the timestamp (Long in java) will be stored. Mandatory.

setTimestampColumnType

public void setTimestampColumnType(String timestampColumnType)

Sets the prefix for the name of the table where the data will be stored. "_" will be appended to this prefix in order to enforce unique table names for each cache.

getTableManipulation

public TableManipulation getTableManipulation()

setIdColumnType

public void setIdColumnType(String idColumnType)

sql equivalent for java's String. Mandatory.

setDataColumnType

public void setDataColumnType(String dataColumnType)

Sets the type of the column where data will be binary stored. It should be a binary type like BLOB. Mandatory.
Character types like CLOB/LONGVARCHAR/VARCHAR are not supported.
Note that on MySQL you need to use strict mode or the database will truncate long values without raising any errors, leading to unmarshalling errors on load.

setDropTableOnExit

public void setDropTableOnExit(boolean dropTableOnExit)

setCreateTableOnStart

public void setCreateTableOnStart(boolean createTableOnStart)

isManageConnectionFactory

public boolean isManageConnectionFactory()

If this method returns false, then the connection factory should not be created by the JdbcStringBasedCacheStore, but will be injected through JdbcStringBasedCacheStore.doConnectionFactoryInitialization(org.infinispan.loaders.jdbc.connectionfactory.ConnectionFactory)

setTableManipulation

public void setTableManipulation(TableManipulation tableManipulation)

setFetchSize

public void setFetchSize(int fetchSize)

See Also:

TableManipulation.getFetchSize()

setBatchSize

public void setBatchSize(int batchSize)

See Also:

TableManipulation.getBatchSize()

getFetchSize

public int getFetchSize()

See Also:

TableManipulation.getFetchSize()

getBatchSize

public int getBatchSize()

See Also:

TableManipulation.getBatchSize()

getDatabaseType

public String getDatabaseType()

setDatabaseType

public void setDatabaseType(String dbType)

Sets the database dialect. Valid types are reflected in the DatabaseType enum. If unspecified, will attempt to "guess" appropriate dialect from the JDBC driver specified.

Parameters:

dbType -

clone

public AbstractNonDelegatingJdbcCacheStoreConfig clone()

Specified by:

clone in interface CloneableConfigurationComponent

Specified by:

clone in interface CacheLoaderConfig

Overrides:

clone in class AbstractJdbcCacheStoreConfig

toString

public String toString()

Overrides:

toString in class AbstractJdbcCacheStoreConfig