org.infinispan.persistence.jdbc

Class TableManipulation

java.lang.Object

org.infinispan.persistence.jdbc.TableManipulation

All Implemented Interfaces:

Cloneable

public class TableManipulation
extends Object
implements Cloneable

Contains all the logic of manipulating the table, including creating it if needed and access operations like inserting, selecting etc. Used by JDBC based cache persistence.

Author:

Mircea.Markus@jboss.com

Field Summary

Fields

Modifier and Type	Field and Description
DatabaseType	databaseType
static int	DEFAULT_BATCH_SIZE
static int	DEFAULT_FETCH_SIZE

Constructor Summary

Constructors

Constructor and Description
TableManipulation()
TableManipulation(TableManipulationConfiguration config)

Method Summary

Methods

Modifier and Type	Method and Description
TableManipulation	clone()
void	createTable(Connection conn)
void	dropTable(Connection conn)
int	getBatchSize() When doing repetitive DB inserts this will be batched according to this parameter.
String	getCountRowsSql()
String	getDeleteAllRowsSql()
String	getDeleteExpiredRowsSql()
String	getDeleteRowSql()
int	getFetchSize() For DB queries the fetch size will be set on ResultSet.setFetchSize(int).
String	getIdentifierQuoteString()
String	getInsertRowSql()
String	getLoadAllKeysBinarySql()
String	getLoadAllKeysStringSql()
String	getLoadAllRowsSql()
String	getLoadNonExpiredAllRowsSql()
String	getLoadSomeRowsSql()
String	getSelectExpiredRowsSql()
String	getSelectIdRowSql()
String	getSelectRowSql()
TableName	getTableName()
String	getUpdateRowSql()
boolean	isVariableLimitSupported()
void	setCacheName(String cacheName)
void	start(ConnectionFactory connectionFactory)
void	stop()
boolean	tableExists(Connection connection)
boolean	tableExists(Connection connection, TableName tableName)

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_FETCH_SIZE

public static final int DEFAULT_FETCH_SIZE

See Also:

Constant Field Values

DEFAULT_BATCH_SIZE

public static final int DEFAULT_BATCH_SIZE

See Also:

Constant Field Values

databaseType

public DatabaseType databaseType

Constructor Detail

TableManipulation

public TableManipulation(TableManipulationConfiguration config)

TableManipulation

public TableManipulation()

Method Detail

tableExists

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

Throws:

PersistenceException

createTable

public void createTable(Connection conn)
                 throws PersistenceException

Throws:

PersistenceException

dropTable

public void dropTable(Connection conn)
               throws PersistenceException

Throws:

PersistenceException

start

public void start(ConnectionFactory connectionFactory)
           throws PersistenceException

Throws:

PersistenceException

stop

public void stop()
          throws PersistenceException

Throws:

PersistenceException

getInsertRowSql

public String getInsertRowSql()

getUpdateRowSql

public String getUpdateRowSql()

getSelectRowSql

public String getSelectRowSql()

getSelectIdRowSql

public String getSelectIdRowSql()

getCountRowsSql

public String getCountRowsSql()

getDeleteRowSql

public String getDeleteRowSql()

getLoadNonExpiredAllRowsSql

public String getLoadNonExpiredAllRowsSql()

getLoadAllRowsSql

public String getLoadAllRowsSql()

getDeleteAllRowsSql

public String getDeleteAllRowsSql()

getSelectExpiredRowsSql

public String getSelectExpiredRowsSql()

getDeleteExpiredRowsSql

public String getDeleteExpiredRowsSql()

clone

public TableManipulation clone()

Overrides:

clone in class Object

getTableName

public TableName getTableName()

tableExists

public boolean tableExists(Connection connection)
                    throws PersistenceException

Throws:

PersistenceException

setCacheName

public void setCacheName(String cacheName)

isVariableLimitSupported

public boolean isVariableLimitSupported()

getLoadSomeRowsSql

public String getLoadSomeRowsSql()

getLoadAllKeysBinarySql

public String getLoadAllKeysBinarySql()

getLoadAllKeysStringSql

public String getLoadAllKeysStringSql()

getFetchSize

public int getFetchSize()

For DB queries the fetch size will be set on ResultSet.setFetchSize(int). This is optional parameter, if not specified will be defaulted to DEFAULT_FETCH_SIZE.

getBatchSize

public int getBatchSize()

When doing repetitive DB inserts this will be batched according to this parameter. This is an optional parameter, and if it is not specified it will be defaulted to DEFAULT_BATCH_SIZE. Guaranteed to be a power of two.

getIdentifierQuoteString

public String getIdentifierQuoteString()