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 ClassesModifier and TypeClassDescriptionprotected static class
protected static class
protected static enum
protected static class
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 -
Method Summary
Modifier and TypeMethodDescriptionprotected 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 theBaseJdbcStore
will be initialized except forBaseJdbcStore.tableOperations
when this is invoked.- Specified by:
createTableOperations
in classBaseJdbcStore<K,
V, C extends AbstractSchemaJdbcConfiguration> - Parameters:
ctx
- store contextconfig
- 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 extendAbstractSchemaJdbcStore.SchemaTableOperations
providing ways to retrieve the statements needed.- Parameters:
schemaOptions
- the operations for the schema for this store- Returns:
- the operations object to use
-