public class TableManipulation extends Object implements Cloneable
Modifier and Type | Field and Description |
---|---|
DatabaseType |
databaseType |
static int |
DEFAULT_BATCH_SIZE |
static int |
DEFAULT_FETCH_SIZE |
Constructor and Description |
---|
TableManipulation() |
TableManipulation(TableManipulationConfiguration config) |
Modifier and Type | Method and Description |
---|---|
TableManipulation |
clone() |
void |
createTable(Connection conn) |
void |
dropTable(Connection conn) |
int |
getBatchSize()
When doing repetitive DB inserts (e.g.
|
String |
getCountRowsSql() |
String |
getDeleteAllRowsSql() |
String |
getDeleteExpiredRowsSql() |
String |
getDeleteRowSql() |
int |
getFetchSize()
For DB queries (e.g.
|
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) |
public static final int DEFAULT_FETCH_SIZE
public static final int DEFAULT_BATCH_SIZE
public DatabaseType databaseType
public TableManipulation(TableManipulationConfiguration config)
public TableManipulation()
public boolean tableExists(Connection connection, TableName tableName) throws CacheLoaderException
CacheLoaderException
public void createTable(Connection conn) throws CacheLoaderException
CacheLoaderException
public void dropTable(Connection conn) throws CacheLoaderException
CacheLoaderException
public void start(ConnectionFactory connectionFactory) throws CacheLoaderException
CacheLoaderException
public void stop() throws CacheLoaderException
CacheLoaderException
public String getInsertRowSql()
public String getUpdateRowSql()
public String getSelectRowSql()
public String getSelectIdRowSql()
public String getCountRowsSql()
public String getDeleteRowSql()
public String getLoadNonExpiredAllRowsSql()
public String getLoadAllRowsSql()
public String getDeleteAllRowsSql()
public String getSelectExpiredRowsSql()
public String getDeleteExpiredRowsSql()
public TableManipulation clone()
public TableName getTableName()
public boolean tableExists(Connection connection) throws CacheLoaderException
CacheLoaderException
public void setCacheName(String cacheName)
public boolean isVariableLimitSupported()
public String getLoadSomeRowsSql()
public String getLoadAllKeysBinarySql()
public String getLoadAllKeysStringSql()
public int getFetchSize()
org.infinispan.loaders.spi.CacheStore#toStream(java.io.ObjectOutput)
) the fetch size
will be set on ResultSet.setFetchSize(int)
. This is optional parameter, if not specified will be
defaulted to DEFAULT_FETCH_SIZE
.public int getBatchSize()
org.infinispan.loaders.spi.CacheStore#fromStream(java.io.ObjectInput)
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.public String getIdentifierQuoteString()
Copyright © 2013 JBoss, a division of Red Hat. All Rights Reserved.