Package org.infinispan.persistence.sql

Class AbstractSchemaJdbcStore<K,V,C extends AbstractSchemaJdbcConfiguration>

java.lang.Object

org.infinispan.persistence.jdbc.common.impl.BaseJdbcStore<K,V,C>

org.infinispan.persistence.sql.AbstractSchemaJdbcStore<K,V,C>

All Implemented Interfaces:

NonBlockingStore<K,V>

Direct Known Subclasses:

QueriesJdbcStore, TableJdbcStore

public abstract class AbstractSchemaJdbcStore<K,V,C extends AbstractSchemaJdbcConfiguration>
extends BaseJdbcStore<K,V,C>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	AbstractSchemaJdbcStore.Parameter
protected static class	AbstractSchemaJdbcStore.ProtoSchemaOptions<K,V,C extends AbstractSchemaJdbcConfiguration>
protected static enum	AbstractSchemaJdbcStore.ProtostreamFieldType
protected static class	AbstractSchemaJdbcStore.SchemaTableOperations<K,V,C extends AbstractSchemaJdbcConfiguration>

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

NonBlockingStore.Characteristic, NonBlockingStore.SegmentedPublisher<Type>

Field Summary

Fields inherited from class org.infinispan.persistence.jdbc.common.impl.BaseJdbcStore

blockingManager, config, connectionFactory, log, tableOperations, transactionConnectionMap

Fields inherited from interface org.infinispan.persistence.spi.NonBlockingStore

SIZE_UNAVAILABLE_FUTURE

Constructor Summary

Constructors

Constructor	Description
AbstractSchemaJdbcStore()

Method Summary

Modifier and Type	Method	Description
protected abstract TableOperations<K,V>	actualCreateTableOperations(AbstractSchemaJdbcStore.ProtoSchemaOptions<K,V,C> schemaOptions)	Implementation specific method to return a table operations which will then be used appropriately for store operations.
protected TableOperations<K,V>	createTableOperations(InitializationContext ctx, C config)	Extension point to allow for initializing and creating a table operations object.
protected AbstractSchemaJdbcStore.Parameter[]	determinePrimaryParameters(C config, AbstractSchemaJdbcStore.Parameter[] allParameters)

Methods inherited from class org.infinispan.persistence.jdbc.common.impl.BaseJdbcStore

approximateSize, batch, characteristics, clear, commit, delete, destroyTxConnection, extraStopSteps, getTxConnection, isAvailable, load, prepareWithModifications, publishEntries, publishKeys, rollback, size, start, stop, write

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.NonBlockingStore

addSegments, containsKey, destroy, ignoreCommandWithFlags, purgeExpired, removeSegments

Constructor Details

AbstractSchemaJdbcStore

public AbstractSchemaJdbcStore()

Method Details

createTableOperations

protected TableOperations<K,V> createTableOperations(InitializationContext ctx,
 C config)
                                              throws SQLException

Description copied from class: BaseJdbcStore

Extension point to allow for initializing and creating a table operations object. All variables in the BaseJdbcStore will be initialized except for BaseJdbcStore.tableOperations when this is invoked.

Specified by:

createTableOperations in class BaseJdbcStore<K,V,C extends AbstractSchemaJdbcConfiguration>

Parameters:

ctx - store context

config - configuration of the store

Returns:

the table operations to use for future calls

Throws:

SQLException - if any database exception occurs during creation

determinePrimaryParameters

protected AbstractSchemaJdbcStore.Parameter[] determinePrimaryParameters(C config,
 AbstractSchemaJdbcStore.Parameter[] allParameters)

actualCreateTableOperations

protected abstract TableOperations<K,V> actualCreateTableOperations(AbstractSchemaJdbcStore.ProtoSchemaOptions<K,V,C> schemaOptions)

Implementation specific method to return a table operations which will then be used appropriately for store operations. It is recommended to extend AbstractSchemaJdbcStore.SchemaTableOperations providing ways to retrieve the statements needed.

Parameters:

schemaOptions - the operations for the schema for this store

Returns:

the operations object to use