org.infinispan.persistence.jdbc.common

Class AbstractJdbcStore<K,V>

java.lang.Object

org.infinispan.persistence.jdbc.common.AbstractJdbcStore<K,V>

All Implemented Interfaces:

Lifecycle, AdvancedCacheLoader<K,V>, AdvancedCacheWriter<K,V>, AdvancedLoadWriteStore<K,V>, CacheLoader<K,V>, CacheWriter<K,V>, ExternalStore<K,V>, TransactionalCacheWriter<K,V>

Direct Known Subclasses:

JdbcBinaryStore, JdbcStringBasedStore

public abstract class AbstractJdbcStore<K,V>
extends Object
implements AdvancedLoadWriteStore<K,V>, TransactionalCacheWriter<K,V>

Author:

Ryan Emerson

Nested Class Summary

Nested classes/interfaces inherited from interface org.infinispan.persistence.spi.AdvancedCacheLoader

AdvancedCacheLoader.CacheLoaderTask<K,V>, AdvancedCacheLoader.TaskContext

Nested classes/interfaces inherited from interface org.infinispan.persistence.spi.AdvancedCacheWriter

AdvancedCacheWriter.PurgeListener<K>

Field Summary

Fields

Modifier and Type	Field and Description
protected String	cacheName
protected ConnectionFactory	connectionFactory
protected InitializationContext	ctx
protected TableManager	tableManager

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractJdbcStore(Log log)

Method Summary

Modifier and Type	Method and Description
void	clear() Removes all the data from the storage.
void	commit(Transaction tx) Commit the provided transaction's changes to the underlying store.
protected void	destroyTxConnection(Transaction tx)
ConnectionFactory	getConnectionFactory()
protected abstract TableManager	getTableManager()
protected Connection	getTxConnection(Transaction tx)
void	init(InitializationContext ctx) Used to initialize a cache loader.
void	initializeConnectionFactory(ConnectionFactory connectionFactory) Keeps a reference to the connection factory for further use.
protected ByteBuffer	marshall(Object obj)
void	rollback(Transaction tx) Rollback the provided transaction's changes to the underlying store.
void	start() Invoked on component start
void	stop() Invoked on component stop
protected <T> T	unmarshall(InputStream inputStream)
protected void	waitForFutureToComplete(Future<Void> future)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.infinispan.persistence.spi.AdvancedCacheLoader

process, size

Methods inherited from interface org.infinispan.persistence.spi.CacheLoader

contains, load

Methods inherited from interface org.infinispan.persistence.spi.TransactionalCacheWriter

prepareWithModifications

Methods inherited from interface org.infinispan.persistence.spi.AdvancedCacheWriter

purge

Methods inherited from interface org.infinispan.persistence.spi.CacheWriter

delete, deleteBatch, write, writeBatch

Field Detail

connectionFactory

protected ConnectionFactory connectionFactory

tableManager

protected TableManager tableManager

ctx

protected InitializationContext ctx

cacheName

protected String cacheName

Constructor Detail

AbstractJdbcStore

protected AbstractJdbcStore(Log log)

Method Detail

getTableManager

protected abstract TableManager getTableManager()

init

public void init(InitializationContext ctx)

Description copied from interface: CacheLoader

Used to initialize a cache loader. Typically invoked by the PersistenceManager when setting up cache loaders.

Specified by:

init in interface CacheLoader<K,V>

Specified by:

init in interface CacheWriter<K,V>

start

public void start()

Description copied from interface: Lifecycle

Invoked on component start

Specified by:

start in interface Lifecycle

stop

public void stop()

Description copied from interface: Lifecycle

Invoked on component stop

Specified by:

stop in interface Lifecycle

clear

public void clear()

Description copied from interface: AdvancedCacheWriter

Removes all the data from the storage.

Specified by:

clear in interface AdvancedCacheWriter<K,V>

commit

public void commit(Transaction tx)

Description copied from interface: TransactionalCacheWriter

Commit the provided transaction's changes to the underlying store.

Specified by:

commit in interface TransactionalCacheWriter<K,V>

Parameters:

tx - the current transactional context.

rollback

public void rollback(Transaction tx)

Description copied from interface: TransactionalCacheWriter

Rollback the provided transaction's changes to the underlying store.

Specified by:

rollback in interface TransactionalCacheWriter<K,V>

Parameters:

tx - the current transactional context.

getTxConnection

protected Connection getTxConnection(Transaction tx)

destroyTxConnection

protected void destroyTxConnection(Transaction tx)

initializeConnectionFactory

public void initializeConnectionFactory(ConnectionFactory connectionFactory)
                                 throws PersistenceException

Keeps a reference to the connection factory for further use. Also initializes the TableManager that needs connections. This method should be called when you don't want the store to manage the connection factory, perhaps because it is using an shared connection factory: see org.infinispan.persistence.jdbc.stores.mixed.JdbcMixedStore for such an example of this.

Throws:

PersistenceException

getConnectionFactory

public ConnectionFactory getConnectionFactory()

waitForFutureToComplete

protected void waitForFutureToComplete(Future<Void> future)

marshall

protected ByteBuffer marshall(Object obj)
                       throws PersistenceException,
                              InterruptedException

Throws:

PersistenceException

InterruptedException

unmarshall

protected <T> T unmarshall(InputStream inputStream)
                    throws PersistenceException

Throws:

PersistenceException