Package org.infinispan.persistence.sql

Class AbstractSchemaJdbcStore<K,V,C extends org.infinispan.persistence.sql.configuration.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 org.infinispan.persistence.sql.configuration.AbstractSchemaJdbcConfiguration>
extends org.infinispan.persistence.jdbc.common.impl.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 org.infinispan.persistence.sql.configuration.AbstractSchemaJdbcConfiguration>
protected static enum	AbstractSchemaJdbcStore.ProtostreamFieldType
protected static class	AbstractSchemaJdbcStore.SchemaTableOperations<K,V,C extends org.infinispan.persistence.sql.configuration.AbstractSchemaJdbcConfiguration>

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

NonBlockingStore.Characteristic, NonBlockingStore.SegmentedPublisher<Type>

Field Summary

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)
protected AbstractSchemaJdbcStore.Parameter[]	determinePrimaryParameters(C config, AbstractSchemaJdbcStore.Parameter[] allParameters)

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

Throws:

SQLException

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