org.infinispan.persistence.jdbc.table.management

Class AbstractTableManager

java.lang.Object

org.infinispan.persistence.jdbc.table.management.AbstractTableManager

All Implemented Interfaces:

TableManager

public abstract class AbstractTableManager
extends Object
implements TableManager

Author:

Ryan Emerson

Field Summary

Fields

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

Fields inherited from interface org.infinispan.persistence.jdbc.table.management.TableManager

DEFAULT_BATCH_SIZE, DEFAULT_FETCH_SIZE

Method Summary

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

connectionFactory

protected final ConnectionFactory connectionFactory

config

protected final TableManipulationConfiguration config

identifierQuoteString

protected String identifierQuoteString

cacheName

protected String cacheName

metaData

protected org.infinispan.persistence.jdbc.table.management.DbMetaData metaData

tableName

protected TableName tableName

insertRowSql

protected String insertRowSql

updateRowSql

protected String updateRowSql

selectRowSql

protected String selectRowSql

selectIdRowSql

protected String selectIdRowSql

deleteRowSql

protected String deleteRowSql

loadAllRowsSql

protected String loadAllRowsSql

countRowsSql

protected String countRowsSql

loadAllNonExpiredRowsSql

protected String loadAllNonExpiredRowsSql

deleteAllRows

protected String deleteAllRows

selectExpiredRowsSql

protected String selectExpiredRowsSql

deleteExpiredRowsSql

protected String deleteExpiredRowsSql

Method Detail

start

public void start()
           throws PersistenceException

Specified by:

start in interface TableManager

Throws:

PersistenceException

stop

public void stop()
          throws PersistenceException

Specified by:

stop in interface TableManager

Throws:

PersistenceException

setCacheName

public void setCacheName(String cacheName)

Specified by:

setCacheName in interface TableManager

tableExists

public boolean tableExists(Connection connection)
                    throws PersistenceException

Specified by:

tableExists in interface TableManager

Throws:

PersistenceException

tableExists

public boolean tableExists(Connection connection,
                           TableName tableName)
                    throws PersistenceException

Specified by:

tableExists in interface TableManager

Throws:

PersistenceException

createTable

public void createTable(Connection conn)
                 throws PersistenceException

Specified by:

createTable in interface TableManager

Throws:

PersistenceException

executeUpdateSql

public void executeUpdateSql(Connection conn,
                             String sql)
                      throws PersistenceException

Throws:

PersistenceException

dropTable

public void dropTable(Connection conn)
               throws PersistenceException

Specified by:

dropTable in interface TableManager

Throws:

PersistenceException

getFetchSize

public int getFetchSize()

Specified by:

getFetchSize in interface TableManager

getBatchSize

public int getBatchSize()

Specified by:

getBatchSize in interface TableManager

getIdentifierQuoteString

public String getIdentifierQuoteString()

Specified by:

getIdentifierQuoteString in interface TableManager

getTableName

public TableName getTableName()

Specified by:

getTableName in interface TableManager

getInsertRowSql

public String getInsertRowSql()

Specified by:

getInsertRowSql in interface TableManager

getUpdateRowSql

public String getUpdateRowSql()

Specified by:

getUpdateRowSql in interface TableManager

getSelectRowSql

public String getSelectRowSql()

Specified by:

getSelectRowSql in interface TableManager

getSelectIdRowSql

public String getSelectIdRowSql()

Specified by:

getSelectIdRowSql in interface TableManager

getCountRowsSql

public String getCountRowsSql()

Specified by:

getCountRowsSql in interface TableManager

getDeleteRowSql

public String getDeleteRowSql()

Specified by:

getDeleteRowSql in interface TableManager

getLoadNonExpiredAllRowsSql

public String getLoadNonExpiredAllRowsSql()

Specified by:

getLoadNonExpiredAllRowsSql in interface TableManager

getLoadAllRowsSql

public String getLoadAllRowsSql()

Specified by:

getLoadAllRowsSql in interface TableManager

getDeleteAllRowsSql

public String getDeleteAllRowsSql()

Specified by:

getDeleteAllRowsSql in interface TableManager

getSelectExpiredRowsSql

public String getSelectExpiredRowsSql()

Specified by:

getSelectExpiredRowsSql in interface TableManager

getDeleteExpiredRowsSql

public String getDeleteExpiredRowsSql()

Specified by:

getDeleteExpiredRowsSql in interface TableManager

isStringEncodingRequired

public boolean isStringEncodingRequired()

Specified by:

isStringEncodingRequired in interface TableManager

encodeString

public String encodeString(String string)

Specified by:

encodeString in interface TableManager