Package org.cyclos.impl.sql
Class CachingPreparedStatement
- java.lang.Object
-
- org.cyclos.impl.sql.CachingPreparedStatement
-
- All Implemented Interfaces:
AutoCloseable,PreparedStatement,Statement,Wrapper
public class CachingPreparedStatement extends Object implements PreparedStatement
APreparedStatementwhich enables transparent query cache
-
-
Field Summary
-
Fields inherited from interface java.sql.Statement
CLOSE_ALL_RESULTS, CLOSE_CURRENT_RESULT, EXECUTE_FAILED, KEEP_CURRENT_RESULT, NO_GENERATED_KEYS, RETURN_GENERATED_KEYS, SUCCESS_NO_INFO
-
-
Constructor Summary
Constructors Constructor Description CachingPreparedStatement(CachingConnection connection, CacheType<TableCacheKey,TableCacheValue> cacheType, String sql, JsonConverter jsonConverter)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidaddBatch()voidaddBatch(String sql)voidcancel()voidclearBatch()voidclearParameters()voidclearWarnings()voidclose()voidcloseOnCompletion()booleanexecute()booleanexecute(String sql)booleanexecute(String sql, int autoGeneratedKeys)booleanexecute(String sql, int[] columnIndexes)booleanexecute(String sql, String[] columnNames)int[]executeBatch()ResultSetexecuteQuery()ResultSetexecuteQuery(String sql)intexecuteUpdate()intexecuteUpdate(String sql)intexecuteUpdate(String sql, int autoGeneratedKeys)intexecuteUpdate(String sql, int[] columnIndexes)intexecuteUpdate(String sql, String[] columnNames)ConnectiongetConnection()intgetFetchDirection()intgetFetchSize()ResultSetgetGeneratedKeys()intgetMaxFieldSize()intgetMaxRows()ResultSetMetaDatagetMetaData()booleangetMoreResults()booleangetMoreResults(int current)ParameterMetaDatagetParameterMetaData()intgetQueryTimeout()ResultSetgetResultSet()intgetResultSetConcurrency()intgetResultSetHoldability()intgetResultSetType()intgetUpdateCount()SQLWarninggetWarnings()booleanisClosed()booleanisCloseOnCompletion()booleanisPoolable()booleanisWrapperFor(Class<?> iface)voidsetArray(int index, Array x)voidsetAsciiStream(int index, InputStream x)voidsetAsciiStream(int index, InputStream x, int length)voidsetAsciiStream(int index, InputStream x, long length)voidsetBigDecimal(int index, BigDecimal x)voidsetBinaryStream(int index, InputStream x)voidsetBinaryStream(int index, InputStream x, int length)voidsetBinaryStream(int index, InputStream x, long length)voidsetBlob(int index, InputStream inputStream)voidsetBlob(int index, InputStream inputStream, long length)voidsetBlob(int index, Blob x)voidsetBoolean(int index, boolean x)voidsetByte(int index, byte x)voidsetBytes(int index, byte[] x)voidsetCharacterStream(int index, Reader reader)voidsetCharacterStream(int index, Reader reader, int length)voidsetCharacterStream(int index, Reader reader, long length)voidsetClob(int index, Reader reader)voidsetClob(int index, Reader reader, long length)voidsetClob(int index, Clob x)voidsetCursorName(String name)voidsetDate(int index, Date x)voidsetDate(int index, Date x, Calendar cal)voidsetDouble(int index, double x)voidsetEscapeProcessing(boolean enable)voidsetFetchDirection(int direction)voidsetFetchSize(int rows)voidsetFloat(int index, float x)voidsetInt(int index, int x)voidsetLong(int index, long x)voidsetMaxFieldSize(int max)voidsetMaxRows(int max)voidsetNCharacterStream(int index, Reader x)voidsetNCharacterStream(int index, Reader x, long length)voidsetNClob(int index, Reader reader)voidsetNClob(int index, Reader reader, long length)voidsetNClob(int index, NClob x)voidsetNString(int index, String x)voidsetNull(int index, int type)voidsetNull(int index, int sqlType, String typeName)voidsetObject(int index, Object x)voidsetObject(int index, Object x, int targetSqlType)voidsetObject(int index, Object x, int targetSqlType, int scaleOrLength)voidsetPoolable(boolean poolable)voidsetQueryTimeout(int seconds)voidsetRef(int index, Ref x)voidsetRowId(int index, RowId x)voidsetShort(int index, short x)voidsetSQLXML(int index, SQLXML x)voidsetString(int index, String x)voidsetTime(int index, Time x)voidsetTime(int index, Time x, Calendar cal)voidsetTimestamp(int index, Timestamp x)voidsetTimestamp(int index, Timestamp x, Calendar cal)voidsetUnicodeStream(int index, InputStream x, int length)voidsetURL(int index, URL x)<T> Tunwrap(Class<T> iface)-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface java.sql.PreparedStatement
executeLargeUpdate, setObject, setObject
-
Methods inherited from interface java.sql.Statement
enquoteIdentifier, enquoteLiteral, enquoteNCharLiteral, executeLargeBatch, executeLargeUpdate, executeLargeUpdate, executeLargeUpdate, executeLargeUpdate, getLargeMaxRows, getLargeUpdateCount, isSimpleIdentifier, setLargeMaxRows
-
-
-
-
Constructor Detail
-
CachingPreparedStatement
public CachingPreparedStatement(CachingConnection connection, CacheType<TableCacheKey,TableCacheValue> cacheType, String sql, JsonConverter jsonConverter)
-
-
Method Detail
-
addBatch
public void addBatch() throws SQLException- Specified by:
addBatchin interfacePreparedStatement- Throws:
SQLException
-
addBatch
public void addBatch(String sql) throws SQLException
- Specified by:
addBatchin interfaceStatement- Throws:
SQLException
-
cancel
public void cancel() throws SQLException- Specified by:
cancelin interfaceStatement- Throws:
SQLException
-
clearBatch
public void clearBatch() throws SQLException- Specified by:
clearBatchin interfaceStatement- Throws:
SQLException
-
clearParameters
public void clearParameters() throws SQLException- Specified by:
clearParametersin interfacePreparedStatement- Throws:
SQLException
-
clearWarnings
public void clearWarnings() throws SQLException- Specified by:
clearWarningsin interfaceStatement- Throws:
SQLException
-
close
public void close() throws SQLException- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceStatement- Throws:
SQLException
-
closeOnCompletion
public void closeOnCompletion() throws SQLException- Specified by:
closeOnCompletionin interfaceStatement- Throws:
SQLException
-
execute
public boolean execute() throws SQLException- Specified by:
executein interfacePreparedStatement- Throws:
SQLException
-
execute
public boolean execute(String sql) throws SQLException
- Specified by:
executein interfaceStatement- Throws:
SQLException
-
execute
public boolean execute(String sql, int autoGeneratedKeys) throws SQLException
- Specified by:
executein interfaceStatement- Throws:
SQLException
-
execute
public boolean execute(String sql, int[] columnIndexes) throws SQLException
- Specified by:
executein interfaceStatement- Throws:
SQLException
-
execute
public boolean execute(String sql, String[] columnNames) throws SQLException
- Specified by:
executein interfaceStatement- Throws:
SQLException
-
executeBatch
public int[] executeBatch() throws SQLException- Specified by:
executeBatchin interfaceStatement- Throws:
SQLException
-
executeQuery
public ResultSet executeQuery() throws SQLException
- Specified by:
executeQueryin interfacePreparedStatement- Throws:
SQLException
-
executeQuery
public ResultSet executeQuery(String sql) throws SQLException
- Specified by:
executeQueryin interfaceStatement- Throws:
SQLException
-
executeUpdate
public int executeUpdate() throws SQLException- Specified by:
executeUpdatein interfacePreparedStatement- Throws:
SQLException
-
executeUpdate
public int executeUpdate(String sql) throws SQLException
- Specified by:
executeUpdatein interfaceStatement- Throws:
SQLException
-
executeUpdate
public int executeUpdate(String sql, int autoGeneratedKeys) throws SQLException
- Specified by:
executeUpdatein interfaceStatement- Throws:
SQLException
-
executeUpdate
public int executeUpdate(String sql, int[] columnIndexes) throws SQLException
- Specified by:
executeUpdatein interfaceStatement- Throws:
SQLException
-
executeUpdate
public int executeUpdate(String sql, String[] columnNames) throws SQLException
- Specified by:
executeUpdatein interfaceStatement- Throws:
SQLException
-
getConnection
public Connection getConnection() throws SQLException
- Specified by:
getConnectionin interfaceStatement- Throws:
SQLException
-
getFetchDirection
public int getFetchDirection() throws SQLException- Specified by:
getFetchDirectionin interfaceStatement- Throws:
SQLException
-
getFetchSize
public int getFetchSize() throws SQLException- Specified by:
getFetchSizein interfaceStatement- Throws:
SQLException
-
getGeneratedKeys
public ResultSet getGeneratedKeys() throws SQLException
- Specified by:
getGeneratedKeysin interfaceStatement- Throws:
SQLException
-
getMaxFieldSize
public int getMaxFieldSize() throws SQLException- Specified by:
getMaxFieldSizein interfaceStatement- Throws:
SQLException
-
getMaxRows
public int getMaxRows() throws SQLException- Specified by:
getMaxRowsin interfaceStatement- Throws:
SQLException
-
getMetaData
public ResultSetMetaData getMetaData() throws SQLException
- Specified by:
getMetaDatain interfacePreparedStatement- Throws:
SQLException
-
getMoreResults
public boolean getMoreResults() throws SQLException- Specified by:
getMoreResultsin interfaceStatement- Throws:
SQLException
-
getMoreResults
public boolean getMoreResults(int current) throws SQLException- Specified by:
getMoreResultsin interfaceStatement- Throws:
SQLException
-
getParameterMetaData
public ParameterMetaData getParameterMetaData() throws SQLException
- Specified by:
getParameterMetaDatain interfacePreparedStatement- Throws:
SQLException
-
getQueryTimeout
public int getQueryTimeout() throws SQLException- Specified by:
getQueryTimeoutin interfaceStatement- Throws:
SQLException
-
getResultSet
public ResultSet getResultSet() throws SQLException
- Specified by:
getResultSetin interfaceStatement- Throws:
SQLException
-
getResultSetConcurrency
public int getResultSetConcurrency() throws SQLException- Specified by:
getResultSetConcurrencyin interfaceStatement- Throws:
SQLException
-
getResultSetHoldability
public int getResultSetHoldability() throws SQLException- Specified by:
getResultSetHoldabilityin interfaceStatement- Throws:
SQLException
-
getResultSetType
public int getResultSetType() throws SQLException- Specified by:
getResultSetTypein interfaceStatement- Throws:
SQLException
-
getUpdateCount
public int getUpdateCount() throws SQLException- Specified by:
getUpdateCountin interfaceStatement- Throws:
SQLException
-
getWarnings
public SQLWarning getWarnings() throws SQLException
- Specified by:
getWarningsin interfaceStatement- Throws:
SQLException
-
isClosed
public boolean isClosed() throws SQLException- Specified by:
isClosedin interfaceStatement- Throws:
SQLException
-
isCloseOnCompletion
public boolean isCloseOnCompletion() throws SQLException- Specified by:
isCloseOnCompletionin interfaceStatement- Throws:
SQLException
-
isPoolable
public boolean isPoolable() throws SQLException- Specified by:
isPoolablein interfaceStatement- Throws:
SQLException
-
isWrapperFor
public boolean isWrapperFor(Class<?> iface) throws SQLException
- Specified by:
isWrapperForin interfaceWrapper- Throws:
SQLException
-
setArray
public void setArray(int index, Array x) throws SQLException- Specified by:
setArrayin interfacePreparedStatement- Throws:
SQLException
-
setAsciiStream
public void setAsciiStream(int index, InputStream x) throws SQLException- Specified by:
setAsciiStreamin interfacePreparedStatement- Throws:
SQLException
-
setAsciiStream
public void setAsciiStream(int index, InputStream x, int length) throws SQLException- Specified by:
setAsciiStreamin interfacePreparedStatement- Throws:
SQLException
-
setAsciiStream
public void setAsciiStream(int index, InputStream x, long length) throws SQLException- Specified by:
setAsciiStreamin interfacePreparedStatement- Throws:
SQLException
-
setBigDecimal
public void setBigDecimal(int index, BigDecimal x) throws SQLException- Specified by:
setBigDecimalin interfacePreparedStatement- Throws:
SQLException
-
setBinaryStream
public void setBinaryStream(int index, InputStream x) throws SQLException- Specified by:
setBinaryStreamin interfacePreparedStatement- Throws:
SQLException
-
setBinaryStream
public void setBinaryStream(int index, InputStream x, int length) throws SQLException- Specified by:
setBinaryStreamin interfacePreparedStatement- Throws:
SQLException
-
setBinaryStream
public void setBinaryStream(int index, InputStream x, long length) throws SQLException- Specified by:
setBinaryStreamin interfacePreparedStatement- Throws:
SQLException
-
setBlob
public void setBlob(int index, Blob x) throws SQLException- Specified by:
setBlobin interfacePreparedStatement- Throws:
SQLException
-
setBlob
public void setBlob(int index, InputStream inputStream) throws SQLException- Specified by:
setBlobin interfacePreparedStatement- Throws:
SQLException
-
setBlob
public void setBlob(int index, InputStream inputStream, long length) throws SQLException- Specified by:
setBlobin interfacePreparedStatement- Throws:
SQLException
-
setBoolean
public void setBoolean(int index, boolean x) throws SQLException- Specified by:
setBooleanin interfacePreparedStatement- Throws:
SQLException
-
setByte
public void setByte(int index, byte x) throws SQLException- Specified by:
setBytein interfacePreparedStatement- Throws:
SQLException
-
setBytes
public void setBytes(int index, byte[] x) throws SQLException- Specified by:
setBytesin interfacePreparedStatement- Throws:
SQLException
-
setCharacterStream
public void setCharacterStream(int index, Reader reader) throws SQLException- Specified by:
setCharacterStreamin interfacePreparedStatement- Throws:
SQLException
-
setCharacterStream
public void setCharacterStream(int index, Reader reader, int length) throws SQLException- Specified by:
setCharacterStreamin interfacePreparedStatement- Throws:
SQLException
-
setCharacterStream
public void setCharacterStream(int index, Reader reader, long length) throws SQLException- Specified by:
setCharacterStreamin interfacePreparedStatement- Throws:
SQLException
-
setClob
public void setClob(int index, Clob x) throws SQLException- Specified by:
setClobin interfacePreparedStatement- Throws:
SQLException
-
setClob
public void setClob(int index, Reader reader) throws SQLException- Specified by:
setClobin interfacePreparedStatement- Throws:
SQLException
-
setClob
public void setClob(int index, Reader reader, long length) throws SQLException- Specified by:
setClobin interfacePreparedStatement- Throws:
SQLException
-
setCursorName
public void setCursorName(String name) throws SQLException
- Specified by:
setCursorNamein interfaceStatement- Throws:
SQLException
-
setDate
public void setDate(int index, Date x) throws SQLException- Specified by:
setDatein interfacePreparedStatement- Throws:
SQLException
-
setDate
public void setDate(int index, Date x, Calendar cal) throws SQLException- Specified by:
setDatein interfacePreparedStatement- Throws:
SQLException
-
setDouble
public void setDouble(int index, double x) throws SQLException- Specified by:
setDoublein interfacePreparedStatement- Throws:
SQLException
-
setEscapeProcessing
public void setEscapeProcessing(boolean enable) throws SQLException- Specified by:
setEscapeProcessingin interfaceStatement- Throws:
SQLException
-
setFetchDirection
public void setFetchDirection(int direction) throws SQLException- Specified by:
setFetchDirectionin interfaceStatement- Throws:
SQLException
-
setFetchSize
public void setFetchSize(int rows) throws SQLException- Specified by:
setFetchSizein interfaceStatement- Throws:
SQLException
-
setFloat
public void setFloat(int index, float x) throws SQLException- Specified by:
setFloatin interfacePreparedStatement- Throws:
SQLException
-
setInt
public void setInt(int index, int x) throws SQLException- Specified by:
setIntin interfacePreparedStatement- Throws:
SQLException
-
setLong
public void setLong(int index, long x) throws SQLException- Specified by:
setLongin interfacePreparedStatement- Throws:
SQLException
-
setMaxFieldSize
public void setMaxFieldSize(int max) throws SQLException- Specified by:
setMaxFieldSizein interfaceStatement- Throws:
SQLException
-
setMaxRows
public void setMaxRows(int max) throws SQLException- Specified by:
setMaxRowsin interfaceStatement- Throws:
SQLException
-
setNCharacterStream
public void setNCharacterStream(int index, Reader x) throws SQLException- Specified by:
setNCharacterStreamin interfacePreparedStatement- Throws:
SQLException
-
setNCharacterStream
public void setNCharacterStream(int index, Reader x, long length) throws SQLException- Specified by:
setNCharacterStreamin interfacePreparedStatement- Throws:
SQLException
-
setNClob
public void setNClob(int index, NClob x) throws SQLException- Specified by:
setNClobin interfacePreparedStatement- Throws:
SQLException
-
setNClob
public void setNClob(int index, Reader reader) throws SQLException- Specified by:
setNClobin interfacePreparedStatement- Throws:
SQLException
-
setNClob
public void setNClob(int index, Reader reader, long length) throws SQLException- Specified by:
setNClobin interfacePreparedStatement- Throws:
SQLException
-
setNString
public void setNString(int index, String x) throws SQLException- Specified by:
setNStringin interfacePreparedStatement- Throws:
SQLException
-
setNull
public void setNull(int index, int type) throws SQLException- Specified by:
setNullin interfacePreparedStatement- Throws:
SQLException
-
setNull
public void setNull(int index, int sqlType, String typeName) throws SQLException- Specified by:
setNullin interfacePreparedStatement- Throws:
SQLException
-
setObject
public void setObject(int index, Object x) throws SQLException- Specified by:
setObjectin interfacePreparedStatement- Throws:
SQLException
-
setObject
public void setObject(int index, Object x, int targetSqlType) throws SQLException- Specified by:
setObjectin interfacePreparedStatement- Throws:
SQLException
-
setObject
public void setObject(int index, Object x, int targetSqlType, int scaleOrLength) throws SQLException- Specified by:
setObjectin interfacePreparedStatement- Throws:
SQLException
-
setPoolable
public void setPoolable(boolean poolable) throws SQLException- Specified by:
setPoolablein interfaceStatement- Throws:
SQLException
-
setQueryTimeout
public void setQueryTimeout(int seconds) throws SQLException- Specified by:
setQueryTimeoutin interfaceStatement- Throws:
SQLException
-
setRef
public void setRef(int index, Ref x) throws SQLException- Specified by:
setRefin interfacePreparedStatement- Throws:
SQLException
-
setRowId
public void setRowId(int index, RowId x) throws SQLException- Specified by:
setRowIdin interfacePreparedStatement- Throws:
SQLException
-
setShort
public void setShort(int index, short x) throws SQLException- Specified by:
setShortin interfacePreparedStatement- Throws:
SQLException
-
setSQLXML
public void setSQLXML(int index, SQLXML x) throws SQLException- Specified by:
setSQLXMLin interfacePreparedStatement- Throws:
SQLException
-
setString
public void setString(int index, String x) throws SQLException- Specified by:
setStringin interfacePreparedStatement- Throws:
SQLException
-
setTime
public void setTime(int index, Time x) throws SQLException- Specified by:
setTimein interfacePreparedStatement- Throws:
SQLException
-
setTime
public void setTime(int index, Time x, Calendar cal) throws SQLException- Specified by:
setTimein interfacePreparedStatement- Throws:
SQLException
-
setTimestamp
public void setTimestamp(int index, Timestamp x) throws SQLException- Specified by:
setTimestampin interfacePreparedStatement- Throws:
SQLException
-
setTimestamp
public void setTimestamp(int index, Timestamp x, Calendar cal) throws SQLException- Specified by:
setTimestampin interfacePreparedStatement- Throws:
SQLException
-
setUnicodeStream
public void setUnicodeStream(int index, InputStream x, int length) throws SQLException- Specified by:
setUnicodeStreamin interfacePreparedStatement- Throws:
SQLException
-
setURL
public void setURL(int index, URL x) throws SQLException- Specified by:
setURLin interfacePreparedStatement- Throws:
SQLException
-
unwrap
public <T> T unwrap(Class<T> iface) throws SQLException
- Specified by:
unwrapin interfaceWrapper- Throws:
SQLException
-
-