public abstract class AbstractTableManager extends Object implements TableManager
Modifier and Type | Field and Description |
---|---|
protected String |
cacheName |
protected TableManipulationConfiguration |
config |
protected ConnectionFactory |
connectionFactory |
protected String |
countRowsSql |
protected String |
deleteAllRows |
protected String |
deleteExpiredRowsSql |
protected String |
deleteRowSql |
protected String |
identifierQuoteString |
protected String |
insertRowSql |
protected String |
loadAllNonExpiredRowsSql |
protected String |
loadAllRowsSql |
protected org.infinispan.persistence.jdbc.table.management.DbMetaData |
metaData |
protected String |
selectExpiredRowsSql |
protected String |
selectIdRowSql |
protected String |
selectRowSql |
protected TableName |
tableName |
protected String |
updateRowSql |
DEFAULT_BATCH_SIZE, DEFAULT_FETCH_SIZE
Modifier and Type | Method and Description |
---|---|
void |
createTable(Connection conn) |
void |
dropTable(Connection conn) |
String |
encodeString(String string) |
void |
executeUpdateSql(Connection conn,
String sql) |
int |
getBatchSize() |
String |
getCountRowsSql() |
String |
getDeleteAllRowsSql() |
String |
getDeleteExpiredRowsSql() |
String |
getDeleteRowSql() |
int |
getFetchSize() |
String |
getIdentifierQuoteString() |
String |
getInsertRowSql() |
String |
getLoadAllRowsSql() |
String |
getLoadNonExpiredAllRowsSql() |
String |
getSelectExpiredRowsSql() |
String |
getSelectIdRowSql() |
String |
getSelectRowSql() |
TableName |
getTableName() |
String |
getUpdateRowSql() |
boolean |
isStringEncodingRequired() |
void |
setCacheName(String cacheName) |
void |
start() |
void |
stop() |
boolean |
tableExists(Connection connection) |
boolean |
tableExists(Connection connection,
TableName tableName) |
protected final ConnectionFactory connectionFactory
protected final TableManipulationConfiguration config
protected String identifierQuoteString
protected String cacheName
protected org.infinispan.persistence.jdbc.table.management.DbMetaData metaData
protected TableName tableName
protected String insertRowSql
protected String updateRowSql
protected String selectRowSql
protected String selectIdRowSql
protected String deleteRowSql
protected String loadAllRowsSql
protected String countRowsSql
protected String loadAllNonExpiredRowsSql
protected String deleteAllRows
protected String selectExpiredRowsSql
protected String deleteExpiredRowsSql
public void start() throws org.infinispan.persistence.spi.PersistenceException
start
in interface TableManager
org.infinispan.persistence.spi.PersistenceException
public void stop() throws org.infinispan.persistence.spi.PersistenceException
stop
in interface TableManager
org.infinispan.persistence.spi.PersistenceException
public void setCacheName(String cacheName)
setCacheName
in interface TableManager
public boolean tableExists(Connection connection) throws org.infinispan.persistence.spi.PersistenceException
tableExists
in interface TableManager
org.infinispan.persistence.spi.PersistenceException
public boolean tableExists(Connection connection, TableName tableName) throws org.infinispan.persistence.spi.PersistenceException
tableExists
in interface TableManager
org.infinispan.persistence.spi.PersistenceException
public void createTable(Connection conn) throws org.infinispan.persistence.spi.PersistenceException
createTable
in interface TableManager
org.infinispan.persistence.spi.PersistenceException
public void executeUpdateSql(Connection conn, String sql) throws org.infinispan.persistence.spi.PersistenceException
org.infinispan.persistence.spi.PersistenceException
public void dropTable(Connection conn) throws org.infinispan.persistence.spi.PersistenceException
dropTable
in interface TableManager
org.infinispan.persistence.spi.PersistenceException
public int getFetchSize()
getFetchSize
in interface TableManager
public int getBatchSize()
getBatchSize
in interface TableManager
public String getIdentifierQuoteString()
getIdentifierQuoteString
in interface TableManager
public TableName getTableName()
getTableName
in interface TableManager
public String getInsertRowSql()
getInsertRowSql
in interface TableManager
public String getUpdateRowSql()
getUpdateRowSql
in interface TableManager
public String getSelectRowSql()
getSelectRowSql
in interface TableManager
public String getSelectIdRowSql()
getSelectIdRowSql
in interface TableManager
public String getCountRowsSql()
getCountRowsSql
in interface TableManager
public String getDeleteRowSql()
getDeleteRowSql
in interface TableManager
public String getLoadNonExpiredAllRowsSql()
getLoadNonExpiredAllRowsSql
in interface TableManager
public String getLoadAllRowsSql()
getLoadAllRowsSql
in interface TableManager
public String getDeleteAllRowsSql()
getDeleteAllRowsSql
in interface TableManager
public String getSelectExpiredRowsSql()
getSelectExpiredRowsSql
in interface TableManager
public String getDeleteExpiredRowsSql()
getDeleteExpiredRowsSql
in interface TableManager
public boolean isStringEncodingRequired()
isStringEncodingRequired
in interface TableManager
public String encodeString(String string)
encodeString
in interface TableManager
Copyright © 2017 JBoss, a division of Red Hat. All rights reserved.