Module com.aoapps.sql.failfast

Package com.aoapps.sql.failfast

Class FailFastConnectionImpl

java.lang.Object

com.aoapps.sql.wrapper.ConnectionWrapperImpl

com.aoapps.sql.failfast.FailFastConnectionImpl

All Implemented Interfaces:

FailFastConnection, ConnectionWrapper, Wrapper, AutoCloseable, Connection, Wrapper

public class FailFastConnectionImpl
extends ConnectionWrapperImpl
implements FailFastConnection

Makes a Connection perform in a fail-fast manner. All access to the connection will fail once a Throwable has been thrown by the underlying driver, with this state only being cleared by rollback.

Author:

AO Industries, Inc.

Nested Class Summary

Nested classes/interfaces inherited from interface com.aoapps.sql.failfast.FailFastConnection

FailFastConnection.State

Field Summary

Fields inherited from interface java.sql.Connection

TRANSACTION_NONE, TRANSACTION_READ_COMMITTED, TRANSACTION_READ_UNCOMMITTED, TRANSACTION_REPEATABLE_READ, TRANSACTION_SERIALIZABLE

Constructor Summary

Constructors

Constructor	Description
FailFastConnectionImpl(FailFastDriver driver, Connection wrapped)
FailFastConnectionImpl(Connection wrapped)

Method Summary

Modifier and Type	Method	Description
void	abort(Executor executor)	Puts the connection into a terminal AbortedSQLException fail-fast state then calls doAbort(java.lang.Throwable, java.util.concurrent.Executor).
void	addFailFastCause(Throwable cause)	Registers a cause for the current failure.
Throwable	clearFailFast()	Clears the cause of the current fail-fast state.
void	clearWarnings()
void	close()	Puts the connection into a terminal ClosedSQLException fail-fast state then calls doClose(java.lang.Throwable).
void	commit()
FailFastArrayImpl	createArrayOf(String typeName, Object[] elements)
FailFastBlobImpl	createBlob()
FailFastClobImpl	createClob()
FailFastNClobImpl	createNClob()
FailFastSQLXMLImpl	createSQLXML()
FailFastStatementImpl	createStatement()
FailFastStatementImpl	createStatement(int resultSetType, int resultSetConcurrency)
FailFastStatementImpl	createStatement(int resultSetType, int resultSetConcurrency, int resultSetHoldability)
FailFastStructImpl	createStruct(String typeName, Object[] attributes)
protected void	doAbort(Throwable failFastCause, Executor executor)
protected void	doClose(Throwable failFastCause)
protected void	failFastIOException()	Performs fail-fast check.
protected void	failFastSQLClientInfoException(Supplier<? extends Map<String,ClientInfoStatus>> failedPropertiesSupplier)	Performs fail-fast check.
protected void	failFastSQLException()	Performs fail-fast check.
boolean	getAutoCommit()
String	getCatalog()
Properties	getClientInfo()
String	getClientInfo(String name)
Throwable	getFailFastCause()	Gets the cause of the current fail-fast state.
FailFastConnection.State	getFailFastState()	Gets the current fail-fail state.
int	getHoldability()
FailFastDatabaseMetaDataImpl	getMetaData()
int	getNetworkTimeout()
String	getSchema()
int	getTransactionIsolation()
Map<String,Class<?>>	getTypeMap()
SQLWarning	getWarnings()
boolean	isClosed()
boolean	isReadOnly()
boolean	isValid(int timeout)
String	nativeSQL(String sql)
protected FailFastArrayImpl	newArrayWrapper(StatementWrapperImpl stmtWrapper, Array array)
protected FailFastBlobImpl	newBlobWrapper(Blob blob)
protected FailFastCallableStatementImpl	newCallableStatementWrapper(CallableStatement cstmt)
protected FailFastClobImpl	newClobWrapper(Clob clob)
protected FailFastDatabaseMetaDataImpl	newDatabaseMetaDataWrapper(DatabaseMetaData metaData)
protected FailFastInputStream	newInputStreamWrapper(InputStream in)
protected FailFastNClobImpl	newNClobWrapper(NClob nclob)
protected FailFastOutputStream	newOutputStreamWrapper(OutputStream out)
protected FailFastParameterMetaDataImpl	newParameterMetaDataWrapper(ParameterMetaData metaData)
protected FailFastPreparedStatementImpl	newPreparedStatementWrapper(PreparedStatement pstmt)
protected FailFastReader	newReaderWrapper(Reader in)
protected FailFastRefImpl	newRefWrapper(Ref ref)
protected FailFastResultSetMetaDataImpl	newResultSetMetaDataWrapper(ResultSetMetaData metaData)
protected FailFastResultSetImpl	newResultSetWrapper(StatementWrapperImpl stmtWrapper, ResultSet results)
protected FailFastRowIdImpl	newRowIdWrapper(RowId rowId)
protected FailFastSavepointImpl	newSavepointWrapper(Savepoint savepoint)
protected SQLDataWrapperImpl	newSQLDataWrapper(SQLData sqlData)
protected FailFastSQLInputImpl	newSQLInputWrapper(SQLInput sqlInput)
protected FailFastSQLOutputImpl	newSQLOutputWrapper(SQLOutput sqlOutput)
protected FailFastSQLXMLImpl	newSQLXMLWrapper(SQLXML sqlXml)
protected FailFastStatementImpl	newStatementWrapper(Statement stmt)
protected FailFastStructImpl	newStructWrapper(Struct struct)
protected FailFastWriter	newWriterWrapper(Writer out)
FailFastCallableStatementImpl	prepareCall(String sql)
FailFastCallableStatementImpl	prepareCall(String sql, int resultSetType, int resultSetConcurrency)
FailFastCallableStatementImpl	prepareCall(String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability)
FailFastPreparedStatementImpl	prepareStatement(String sql)
FailFastPreparedStatementImpl	prepareStatement(String sql, int autoGeneratedKeys)
FailFastPreparedStatementImpl	prepareStatement(String sql, int[] columnIndexes)
FailFastPreparedStatementImpl	prepareStatement(String sql, int resultSetType, int resultSetConcurrency)
FailFastPreparedStatementImpl	prepareStatement(String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability)
FailFastPreparedStatementImpl	prepareStatement(String sql, String[] columnNames)
void	releaseSavepoint(Savepoint savepoint)
void	rollback()	When not in a terminal fail-fast state, will clear the fail-fast state upon a successful call to super.rollback().
void	rollback(Savepoint savepoint)	When not in a terminal fail-fast state, will clear the fail-fast state upon a successful call to super.rollback(savepoint).
void	setAutoCommit(boolean autoCommit)
void	setCatalog(String catalog)
void	setClientInfo(String name, String value)
void	setClientInfo(Properties properties)
void	setHoldability(int holdability)
void	setNetworkTimeout(Executor executor, int milliseconds)
void	setReadOnly(boolean readOnly)
FailFastSavepointImpl	setSavepoint()
FailFastSavepointImpl	setSavepoint(String name)
void	setSchema(String schema)
void	setTransactionIsolation(int level)
void	setTypeMap(Map<String,Class<?>> map)

Methods inherited from class com.aoapps.sql.wrapper.ConnectionWrapperImpl

getDriver, getWrapped, toString, unwrapArray, unwrapBlob, unwrapClob, unwrapInputStream, unwrapNClob, unwrapReader, unwrapRef, unwrapRowId, unwrapSavepoint, unwrapSQLXML, unwrapStruct, wrapArray, wrapBlob, wrapCallableStatement, wrapClob, wrapDatabaseMetaData, wrapInputStream, wrapNClob, wrapOutputStream, wrapParameterMetaData, wrapPreparedStatement, wrapReader, wrapRef, wrapResultSet, wrapResultSetMetaData, wrapRowId, wrapSavepoint, wrapSQLData, wrapSQLInput, wrapSQLOutput, wrapSQLXML, wrapStatement, wrapStruct, wrapWriter

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.sql.Connection

beginRequest, endRequest, setShardingKey, setShardingKey, setShardingKeyIfValid, setShardingKeyIfValid

Methods inherited from interface com.aoapps.sql.wrapper.ConnectionWrapper

getWrappedConnection

Methods inherited from interface com.aoapps.sql.failfast.FailFastConnection

getWrapped

Methods inherited from interface com.aoapps.sql.wrapper.Wrapper

isWrapperFor, unwrap

Constructor Details

FailFastConnectionImpl

public FailFastConnectionImpl(FailFastDriver driver,
 Connection wrapped)

FailFastConnectionImpl

public FailFastConnectionImpl(Connection wrapped)

Method Details

addFailFastCause

public void addFailFastCause(Throwable cause)

Description copied from interface: FailFastConnection

Registers a cause for the current failure. Multiple causes are merged in the following order:

1. TerminalSQLException take highest precedence, since these are non-recoverable.
2. All other Throwable are next precedence. These might be recoverable through FailFastConnection.rollback() or FailFastConnection.rollback(java.sql.Savepoint).

Higher precedence causes will suppress any existing cause of a lower precedence (new adds the current as suppressed).

Lower precedence causes will be suppressed by any existing cause of higher precedence (current adds the new as suppressed).

Causes within the same precedence are merged via Throwables.addSuppressed(java.lang.Throwable, java.lang.Throwable).

Specified by:

addFailFastCause in interface FailFastConnection

Parameters:

cause - The additional cause, ignored when null

getFailFastCause

public Throwable getFailFastCause()

Description copied from interface: FailFastConnection

Gets the cause of the current fail-fast state.

This might involve creating a new exception, so FailFastConnection.getFailFastState() may be faster when the exact cause is not required.

Specified by:

getFailFastCause in interface FailFastConnection

Returns:

The cause or null when not in failure state (operating normally).

See Also:

• FailFastConnection.getFailFastState()

getFailFastState

public FailFastConnection.State getFailFastState()

Description copied from interface: FailFastConnection

Gets the current fail-fail state.

Specified by:

getFailFastState in interface FailFastConnection

Returns:

The state or FailFastConnection.State.OK when not in failure state (operating normally).

See Also:

• FailFastConnection.getFailFastCause()

clearFailFast

public Throwable clearFailFast()
                        throws TerminalSQLException

Description copied from interface: FailFastConnection

Clears the cause of the current fail-fast state. This will typically be invoked automatically during one of the following successful operations:

1. Connection.rollback()
2. Connection.rollback(java.sql.Savepoint)

Specified by:

clearFailFast in interface FailFastConnection

Returns:

The cause or null when was not in failure state (operating normally).

Throws:

TerminalSQLException - if the connection is in a terminal fail-fast state, such as closed or aborted.

See Also:

• FailFastConnection.getFailFastCause()

failFastSQLException

protected void failFastSQLException()
                             throws SQLException

Performs fail-fast check.

Throws:

SQLException - if currently in a fail-fast state

See Also:

• Throwables.newSurrogate(java.lang.Throwable)

failFastSQLClientInfoException

protected void failFastSQLClientInfoException(Supplier<? extends Map<String,ClientInfoStatus>> failedPropertiesSupplier)
                                       throws SQLClientInfoException

Performs fail-fast check.

Throws:

SQLClientInfoException - if currently in a fail-fast state

failFastIOException

protected void failFastIOException()
                            throws IOException

Performs fail-fast check.

Throws:

IOException - if currently in a fail-fast state

See Also:

• Throwables.newSurrogate(java.lang.Throwable)

newArrayWrapper

protected FailFastArrayImpl newArrayWrapper(StatementWrapperImpl stmtWrapper,
 Array array)

Overrides:

newArrayWrapper in class ConnectionWrapperImpl

newBlobWrapper

protected FailFastBlobImpl newBlobWrapper(Blob blob)

Overrides:

newBlobWrapper in class ConnectionWrapperImpl

newCallableStatementWrapper

protected FailFastCallableStatementImpl newCallableStatementWrapper(CallableStatement cstmt)

Overrides:

newCallableStatementWrapper in class ConnectionWrapperImpl

newClobWrapper

protected FailFastClobImpl newClobWrapper(Clob clob)

Overrides:

newClobWrapper in class ConnectionWrapperImpl

newDatabaseMetaDataWrapper

protected FailFastDatabaseMetaDataImpl newDatabaseMetaDataWrapper(DatabaseMetaData metaData)

Overrides:

newDatabaseMetaDataWrapper in class ConnectionWrapperImpl

newInputStreamWrapper

protected FailFastInputStream newInputStreamWrapper(InputStream in)

Overrides:

newInputStreamWrapper in class ConnectionWrapperImpl

newNClobWrapper

protected FailFastNClobImpl newNClobWrapper(NClob nclob)

Overrides:

newNClobWrapper in class ConnectionWrapperImpl

newOutputStreamWrapper

protected FailFastOutputStream newOutputStreamWrapper(OutputStream out)

Overrides:

newOutputStreamWrapper in class ConnectionWrapperImpl

newParameterMetaDataWrapper

protected FailFastParameterMetaDataImpl newParameterMetaDataWrapper(ParameterMetaData metaData)

Overrides:

newParameterMetaDataWrapper in class ConnectionWrapperImpl

newPreparedStatementWrapper

protected FailFastPreparedStatementImpl newPreparedStatementWrapper(PreparedStatement pstmt)

Overrides:

newPreparedStatementWrapper in class ConnectionWrapperImpl

newReaderWrapper

protected FailFastReader newReaderWrapper(Reader in)

Overrides:

newReaderWrapper in class ConnectionWrapperImpl

newRefWrapper

protected FailFastRefImpl newRefWrapper(Ref ref)

Overrides:

newRefWrapper in class ConnectionWrapperImpl

newResultSetWrapper

protected FailFastResultSetImpl newResultSetWrapper(StatementWrapperImpl stmtWrapper,
 ResultSet results)

Overrides:

newResultSetWrapper in class ConnectionWrapperImpl

newResultSetMetaDataWrapper

protected FailFastResultSetMetaDataImpl newResultSetMetaDataWrapper(ResultSetMetaData metaData)

Overrides:

newResultSetMetaDataWrapper in class ConnectionWrapperImpl

newRowIdWrapper

protected FailFastRowIdImpl newRowIdWrapper(RowId rowId)

Overrides:

newRowIdWrapper in class ConnectionWrapperImpl

newSQLDataWrapper

protected SQLDataWrapperImpl newSQLDataWrapper(SQLData sqlData)

Overrides:

newSQLDataWrapper in class ConnectionWrapperImpl

newSQLInputWrapper

protected FailFastSQLInputImpl newSQLInputWrapper(SQLInput sqlInput)

Overrides:

newSQLInputWrapper in class ConnectionWrapperImpl

newSQLOutputWrapper

protected FailFastSQLOutputImpl newSQLOutputWrapper(SQLOutput sqlOutput)

Overrides:

newSQLOutputWrapper in class ConnectionWrapperImpl

newSQLXMLWrapper

protected FailFastSQLXMLImpl newSQLXMLWrapper(SQLXML sqlXml)

Overrides:

newSQLXMLWrapper in class ConnectionWrapperImpl

newSavepointWrapper

protected FailFastSavepointImpl newSavepointWrapper(Savepoint savepoint)

Overrides:

newSavepointWrapper in class ConnectionWrapperImpl

newStatementWrapper

protected FailFastStatementImpl newStatementWrapper(Statement stmt)

Overrides:

newStatementWrapper in class ConnectionWrapperImpl

newStructWrapper

protected FailFastStructImpl newStructWrapper(Struct struct)

Overrides:

newStructWrapper in class ConnectionWrapperImpl

newWriterWrapper

protected FailFastWriter newWriterWrapper(Writer out)

Overrides:

newWriterWrapper in class ConnectionWrapperImpl

createStatement

public FailFastStatementImpl createStatement()
                                      throws SQLException

Specified by:

createStatement in interface Connection

Specified by:

createStatement in interface ConnectionWrapper

Overrides:

createStatement in class ConnectionWrapperImpl

Throws:

SQLException

prepareStatement

public FailFastPreparedStatementImpl prepareStatement(String sql)
                                               throws SQLException

Specified by:

prepareStatement in interface Connection

Specified by:

prepareStatement in interface ConnectionWrapper

Overrides:

prepareStatement in class ConnectionWrapperImpl

Throws:

SQLException

prepareCall

public FailFastCallableStatementImpl prepareCall(String sql)
                                          throws SQLException

Specified by:

prepareCall in interface Connection

Specified by:

prepareCall in interface ConnectionWrapper

Overrides:

prepareCall in class ConnectionWrapperImpl

Throws:

SQLException

nativeSQL

public String nativeSQL(String sql)
                 throws SQLException

Specified by:

nativeSQL in interface Connection

Specified by:

nativeSQL in interface ConnectionWrapper

Throws:

SQLException

setAutoCommit

public void setAutoCommit(boolean autoCommit)
                   throws SQLException

Specified by:

setAutoCommit in interface Connection

Specified by:

setAutoCommit in interface ConnectionWrapper

Throws:

SQLException

getAutoCommit

public boolean getAutoCommit()
                      throws SQLException

Specified by:

getAutoCommit in interface Connection

Specified by:

getAutoCommit in interface ConnectionWrapper

Throws:

SQLException

commit

public void commit()
            throws SQLException

Specified by:

commit in interface Connection

Specified by:

commit in interface ConnectionWrapper

Throws:

SQLException

rollback

public void rollback()
              throws TerminalSQLException,
SQLException

Description copied from interface: FailFastConnection

When not in a terminal fail-fast state, will clear the fail-fast state upon a successful call to super.rollback().

Specified by:

rollback in interface Connection

Specified by:

rollback in interface ConnectionWrapper

Specified by:

rollback in interface FailFastConnection

Throws:

TerminalSQLException - if already in a terminal fail-fast state

SQLException - if any other failure occurs during rollback

close

public void close()
           throws SQLException

Description copied from interface: FailFastConnection

Puts the connection into a terminal ClosedSQLException fail-fast state then calls doClose(java.lang.Throwable).

When already in a terminal state (closed or aborted), is a no-op and does not call doClose(java.lang.Throwable).

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Connection

Specified by:

close in interface ConnectionWrapper

Specified by:

close in interface FailFastConnection

Overrides:

close in class ConnectionWrapperImpl

Throws:

SQLException

See Also:

• FailFastConnection.addFailFastCause(java.lang.Throwable)
• ClosedSQLException
• doClose(java.lang.Throwable)

isClosed

public boolean isClosed()
                 throws SQLException

Specified by:

isClosed in interface Connection

Specified by:

isClosed in interface ConnectionWrapper

Throws:

SQLException

getMetaData

public FailFastDatabaseMetaDataImpl getMetaData()
                                         throws SQLException

Specified by:

getMetaData in interface Connection

Specified by:

getMetaData in interface ConnectionWrapper

Overrides:

getMetaData in class ConnectionWrapperImpl

Throws:

SQLException

setReadOnly

public void setReadOnly(boolean readOnly)
                 throws SQLException

Specified by:

setReadOnly in interface Connection

Specified by:

setReadOnly in interface ConnectionWrapper

Throws:

SQLException

isReadOnly

public boolean isReadOnly()
                   throws SQLException

Specified by:

isReadOnly in interface Connection

Specified by:

isReadOnly in interface ConnectionWrapper

Throws:

SQLException

setCatalog

public void setCatalog(String catalog)
                throws SQLException

Specified by:

setCatalog in interface Connection

Specified by:

setCatalog in interface ConnectionWrapper

Throws:

SQLException

getCatalog

public String getCatalog()
                  throws SQLException

Specified by:

getCatalog in interface Connection

Specified by:

getCatalog in interface ConnectionWrapper

Throws:

SQLException

setTransactionIsolation

public void setTransactionIsolation(int level)
                             throws SQLException

Specified by:

setTransactionIsolation in interface Connection

Specified by:

setTransactionIsolation in interface ConnectionWrapper

Throws:

SQLException

getTransactionIsolation

public int getTransactionIsolation()
                            throws SQLException

Specified by:

getTransactionIsolation in interface Connection

Specified by:

getTransactionIsolation in interface ConnectionWrapper

Throws:

SQLException

getWarnings

public SQLWarning getWarnings()
                       throws SQLException

Specified by:

getWarnings in interface Connection

Specified by:

getWarnings in interface ConnectionWrapper

Throws:

SQLException

clearWarnings

public void clearWarnings()
                   throws SQLException

Specified by:

clearWarnings in interface Connection

Specified by:

clearWarnings in interface ConnectionWrapper

Throws:

SQLException

createStatement

public FailFastStatementImpl createStatement(int resultSetType,
 int resultSetConcurrency)
                                      throws SQLException

Specified by:

createStatement in interface Connection

Specified by:

createStatement in interface ConnectionWrapper

Overrides:

createStatement in class ConnectionWrapperImpl

Throws:

SQLException

prepareStatement

public FailFastPreparedStatementImpl prepareStatement(String sql,
 int resultSetType,
 int resultSetConcurrency)
                                               throws SQLException

Specified by:

prepareStatement in interface Connection

Specified by:

prepareStatement in interface ConnectionWrapper

Overrides:

prepareStatement in class ConnectionWrapperImpl

Throws:

SQLException

prepareCall

public FailFastCallableStatementImpl prepareCall(String sql,
 int resultSetType,
 int resultSetConcurrency)
                                          throws SQLException

Specified by:

prepareCall in interface Connection

Specified by:

prepareCall in interface ConnectionWrapper

Overrides:

prepareCall in class ConnectionWrapperImpl

Throws:

SQLException

getTypeMap

public Map<String,Class<?>> getTypeMap()
                                throws SQLException

Specified by:

getTypeMap in interface Connection

Specified by:

getTypeMap in interface ConnectionWrapper

Throws:

SQLException

setTypeMap

public void setTypeMap(Map<String,Class<?>> map)
                throws SQLException

Specified by:

setTypeMap in interface Connection

Specified by:

setTypeMap in interface ConnectionWrapper

Throws:

SQLException

setHoldability

public void setHoldability(int holdability)
                    throws SQLException

Specified by:

setHoldability in interface Connection

Specified by:

setHoldability in interface ConnectionWrapper

Throws:

SQLException

getHoldability

public int getHoldability()
                   throws SQLException

Specified by:

getHoldability in interface Connection

Specified by:

getHoldability in interface ConnectionWrapper

Throws:

SQLException

setSavepoint

public FailFastSavepointImpl setSavepoint()
                                   throws SQLException

Specified by:

setSavepoint in interface Connection

Specified by:

setSavepoint in interface ConnectionWrapper

Overrides:

setSavepoint in class ConnectionWrapperImpl

Throws:

SQLException

setSavepoint

public FailFastSavepointImpl setSavepoint(String name)
                                   throws SQLException

Specified by:

setSavepoint in interface Connection

Specified by:

setSavepoint in interface ConnectionWrapper

Overrides:

setSavepoint in class ConnectionWrapperImpl

Throws:

SQLException

rollback

public void rollback(Savepoint savepoint)
              throws SQLException

Description copied from interface: FailFastConnection

When not in a terminal fail-fast state, will clear the fail-fast state upon a successful call to super.rollback(savepoint).

Specified by:

rollback in interface Connection

Specified by:

rollback in interface ConnectionWrapper

Specified by:

rollback in interface FailFastConnection

Overrides:

rollback in class ConnectionWrapperImpl

Throws:

SQLException - if any other failure occurs during rollback

releaseSavepoint

public void releaseSavepoint(Savepoint savepoint)
                      throws SQLException

Specified by:

releaseSavepoint in interface Connection

Specified by:

releaseSavepoint in interface ConnectionWrapper

Overrides:

releaseSavepoint in class ConnectionWrapperImpl

Throws:

SQLException

createStatement

public FailFastStatementImpl createStatement(int resultSetType,
 int resultSetConcurrency,
 int resultSetHoldability)
                                      throws SQLException

Specified by:

createStatement in interface Connection

Specified by:

createStatement in interface ConnectionWrapper

Overrides:

createStatement in class ConnectionWrapperImpl

Throws:

SQLException

prepareStatement

public FailFastPreparedStatementImpl prepareStatement(String sql,
 int resultSetType,
 int resultSetConcurrency,
 int resultSetHoldability)
                                               throws SQLException

Specified by:

prepareStatement in interface Connection

Specified by:

prepareStatement in interface ConnectionWrapper

Overrides:

prepareStatement in class ConnectionWrapperImpl

Throws:

SQLException

prepareCall

public FailFastCallableStatementImpl prepareCall(String sql,
 int resultSetType,
 int resultSetConcurrency,
 int resultSetHoldability)
                                          throws SQLException

Specified by:

prepareCall in interface Connection

Specified by:

prepareCall in interface ConnectionWrapper

Overrides:

prepareCall in class ConnectionWrapperImpl

Throws:

SQLException

prepareStatement

public FailFastPreparedStatementImpl prepareStatement(String sql,
 int autoGeneratedKeys)
                                               throws SQLException

Specified by:

prepareStatement in interface Connection

Specified by:

prepareStatement in interface ConnectionWrapper

Overrides:

prepareStatement in class ConnectionWrapperImpl

Throws:

SQLException

prepareStatement

public FailFastPreparedStatementImpl prepareStatement(String sql,
 int[] columnIndexes)
                                               throws SQLException

Specified by:

prepareStatement in interface Connection

Specified by:

prepareStatement in interface ConnectionWrapper

Overrides:

prepareStatement in class ConnectionWrapperImpl

Throws:

SQLException

prepareStatement

public FailFastPreparedStatementImpl prepareStatement(String sql,
 String[] columnNames)
                                               throws SQLException

Specified by:

prepareStatement in interface Connection

Specified by:

prepareStatement in interface ConnectionWrapper

Overrides:

prepareStatement in class ConnectionWrapperImpl

Throws:

SQLException

createClob

public FailFastClobImpl createClob()
                            throws SQLException

Specified by:

createClob in interface Connection

Specified by:

createClob in interface ConnectionWrapper

Overrides:

createClob in class ConnectionWrapperImpl

Throws:

SQLException

createBlob

public FailFastBlobImpl createBlob()
                            throws SQLException

Specified by:

createBlob in interface Connection

Specified by:

createBlob in interface ConnectionWrapper

Overrides:

createBlob in class ConnectionWrapperImpl

Throws:

SQLException

createNClob

public FailFastNClobImpl createNClob()
                              throws SQLException

Specified by:

createNClob in interface Connection

Specified by:

createNClob in interface ConnectionWrapper

Overrides:

createNClob in class ConnectionWrapperImpl

Throws:

SQLException

createSQLXML

public FailFastSQLXMLImpl createSQLXML()
                                throws SQLException

Specified by:

createSQLXML in interface Connection

Specified by:

createSQLXML in interface ConnectionWrapper

Overrides:

createSQLXML in class ConnectionWrapperImpl

Throws:

SQLException

isValid

public boolean isValid(int timeout)
                throws SQLException

Specified by:

isValid in interface Connection

Specified by:

isValid in interface ConnectionWrapper

Throws:

SQLException

setClientInfo

public void setClientInfo(String name,
 String value)
                   throws SQLClientInfoException

Specified by:

setClientInfo in interface Connection

Specified by:

setClientInfo in interface ConnectionWrapper

Throws:

SQLClientInfoException

setClientInfo

public void setClientInfo(Properties properties)
                   throws SQLClientInfoException

Specified by:

setClientInfo in interface Connection

Specified by:

setClientInfo in interface ConnectionWrapper

Throws:

SQLClientInfoException

getClientInfo

public String getClientInfo(String name)
                     throws SQLException

Specified by:

getClientInfo in interface Connection

Specified by:

getClientInfo in interface ConnectionWrapper

Throws:

SQLException

getClientInfo

public Properties getClientInfo()
                         throws SQLException

Specified by:

getClientInfo in interface Connection

Specified by:

getClientInfo in interface ConnectionWrapper

Throws:

SQLException

createArrayOf

public FailFastArrayImpl createArrayOf(String typeName,
 Object[] elements)
                                throws SQLException

Specified by:

createArrayOf in interface Connection

Specified by:

createArrayOf in interface ConnectionWrapper

Overrides:

createArrayOf in class ConnectionWrapperImpl

Throws:

SQLException

createStruct

public FailFastStructImpl createStruct(String typeName,
 Object[] attributes)
                                throws SQLException

Specified by:

createStruct in interface Connection

Specified by:

createStruct in interface ConnectionWrapper

Overrides:

createStruct in class ConnectionWrapperImpl

Throws:

SQLException

getNetworkTimeout

public int getNetworkTimeout()
                      throws SQLException

Specified by:

getNetworkTimeout in interface Connection

Specified by:

getNetworkTimeout in interface ConnectionWrapper

Throws:

SQLException

setNetworkTimeout

public void setNetworkTimeout(Executor executor,
 int milliseconds)
                       throws SQLException

Specified by:

setNetworkTimeout in interface Connection

Specified by:

setNetworkTimeout in interface ConnectionWrapper

Throws:

SQLException

setSchema

public void setSchema(String schema)
               throws SQLException

Specified by:

setSchema in interface Connection

Specified by:

setSchema in interface ConnectionWrapper

Throws:

SQLException

getSchema

public String getSchema()
                 throws SQLException

Specified by:

getSchema in interface Connection

Specified by:

getSchema in interface ConnectionWrapper

Throws:

SQLException

abort

public void abort(Executor executor)
           throws SQLException

Description copied from interface: FailFastConnection

Puts the connection into a terminal AbortedSQLException fail-fast state then calls doAbort(java.lang.Throwable, java.util.concurrent.Executor).

When already in a terminal state (closed or aborted), is a no-op and does not call doAbort(java.lang.Throwable, java.util.concurrent.Executor)

Specified by:

abort in interface Connection

Specified by:

abort in interface ConnectionWrapper

Specified by:

abort in interface FailFastConnection

Overrides:

abort in class ConnectionWrapperImpl

Throws:

SQLException

See Also:

• FailFastConnection.addFailFastCause(java.lang.Throwable)
• AbortedSQLException
• doAbort(java.lang.Throwable, java.util.concurrent.Executor)

doClose

protected void doClose(Throwable failFastCause)
                throws SQLException

Either this method or doAbort(java.lang.Throwable, java.util.concurrent.Executor) is called, and at most once. Once either is called, additional close/abort requests are ignored.

This default implementation calls super.close().

Parameters:

failFastCause - The fail-fast state before close.

Throws:

SQLException

doAbort

protected void doAbort(Throwable failFastCause,
 Executor executor)
                throws SQLException

Either this method or doClose(java.lang.Throwable) is called, and at most once. Once either is called, additional close/abort requests are ignored.

This default implementation calls super.abort(executor).

Parameters:

failFastCause - The fail-fast state before close.

Throws:

SQLException