Interface TableManager
-
- All Known Implementing Classes:
AbstractTableManager
public interface TableManager
- Author:
- Ryan Emerson
-
-
Field Summary
Fields Modifier and Type Field Description static int
DEFAULT_BATCH_SIZE
static int
DEFAULT_FETCH_SIZE
-
Method Summary
-
-
-
Field Detail
-
DEFAULT_FETCH_SIZE
static final int DEFAULT_FETCH_SIZE
- See Also:
- Constant Field Values
-
DEFAULT_BATCH_SIZE
static final int DEFAULT_BATCH_SIZE
- See Also:
- Constant Field Values
-
-
Method Detail
-
start
void start() throws org.infinispan.persistence.spi.PersistenceException
- Throws:
org.infinispan.persistence.spi.PersistenceException
-
stop
void stop() throws org.infinispan.persistence.spi.PersistenceException
- Throws:
org.infinispan.persistence.spi.PersistenceException
-
tableExists
boolean tableExists(Connection connection) throws org.infinispan.persistence.spi.PersistenceException
- Throws:
org.infinispan.persistence.spi.PersistenceException
-
tableExists
boolean tableExists(Connection connection, TableName tableName) throws org.infinispan.persistence.spi.PersistenceException
- Throws:
org.infinispan.persistence.spi.PersistenceException
-
createTable
void createTable(Connection conn) throws org.infinispan.persistence.spi.PersistenceException
- Throws:
org.infinispan.persistence.spi.PersistenceException
-
dropTable
void dropTable(Connection conn) throws org.infinispan.persistence.spi.PersistenceException
- Throws:
org.infinispan.persistence.spi.PersistenceException
-
setCacheName
void setCacheName(String cacheName)
-
getFetchSize
int getFetchSize()
-
getBatchSize
@Deprecated int getBatchSize()
Deprecated.Please useAbstractStoreConfiguration.maxBatchSize()
instead.
-
isUpsertSupported
boolean isUpsertSupported()
-
getTableName
TableName getTableName()
-
getIdentifierQuoteString
String getIdentifierQuoteString()
-
getInsertRowSql
String getInsertRowSql()
-
getUpdateRowSql
String getUpdateRowSql()
-
getUpsertRowSql
String getUpsertRowSql()
-
getSelectRowSql
String getSelectRowSql()
-
getSelectMultipleRowSql
String getSelectMultipleRowSql(int numberOfParams)
-
getSelectIdRowSql
String getSelectIdRowSql()
-
getCountRowsSql
String getCountRowsSql()
-
getDeleteRowSql
String getDeleteRowSql()
-
getLoadNonExpiredAllRowsSql
String getLoadNonExpiredAllRowsSql()
-
getLoadAllRowsSql
String getLoadAllRowsSql()
-
getDeleteAllRowsSql
String getDeleteAllRowsSql()
-
getSelectExpiredBucketsSql
String getSelectExpiredBucketsSql()
-
getSelectOnlyExpiredRowsSql
String getSelectOnlyExpiredRowsSql()
-
isStringEncodingRequired
boolean isStringEncodingRequired()
-
prepareUpsertStatement
void prepareUpsertStatement(PreparedStatement ps, String key, long timestamp, org.infinispan.commons.io.ByteBuffer byteBuffer) throws SQLException
- Throws:
SQLException
-
prepareUpdateStatement
default void prepareUpdateStatement(PreparedStatement ps, String key, long timestamp, org.infinispan.commons.io.ByteBuffer byteBuffer) throws SQLException
- Throws:
SQLException
-
-