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 class
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
All Methods Instance Methods Abstract Methods Concrete Methods 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
-
-
-
-
Method Detail
-
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
-
-