org.davidmoten.rx.jdbc.internal

Interface DelegatedConnection

All Superinterfaces:

java.lang.AutoCloseable, java.sql.Connection, java.sql.Wrapper

All Known Implementing Classes:

PooledConnection

public interface DelegatedConnection
extends java.sql.Connection

Field Summary

Fields inherited from interface java.sql.Connection

TRANSACTION_NONE, TRANSACTION_READ_COMMITTED, TRANSACTION_READ_UNCOMMITTED, TRANSACTION_REPEATABLE_READ, TRANSACTION_SERIALIZABLE

Method Summary

Modifier and Type	Method and Description
default void	abort(java.util.concurrent.Executor executor)
default void	clearWarnings()
default void	close()
default void	commit()
java.sql.Connection	con()
default java.sql.Array	createArrayOf(java.lang.String typeName, java.lang.Object[] elements)
default java.sql.Blob	createBlob()
default java.sql.Clob	createClob()
default java.sql.NClob	createNClob()
default java.sql.SQLXML	createSQLXML()
default java.sql.Statement	createStatement()
default java.sql.Statement	createStatement(int resultSetType, int resultSetConcurrency)
default java.sql.Statement	createStatement(int resultSetType, int resultSetConcurrency, int resultSetHoldability)
default java.sql.Struct	createStruct(java.lang.String typeName, java.lang.Object[] attributes)
default boolean	getAutoCommit()
default java.lang.String	getCatalog()
default java.util.Properties	getClientInfo()
default java.lang.String	getClientInfo(java.lang.String name)
default int	getHoldability()
default java.sql.DatabaseMetaData	getMetaData()
default int	getNetworkTimeout()
default java.lang.String	getSchema()
default int	getTransactionIsolation()
default java.util.Map<java.lang.String,java.lang.Class<?>>	getTypeMap()
default java.sql.SQLWarning	getWarnings()
default boolean	isClosed()
default boolean	isReadOnly()
default boolean	isValid(int timeout)
default boolean	isWrapperFor(java.lang.Class<?> iface)
default java.lang.String	nativeSQL(java.lang.String sql)
default java.sql.CallableStatement	prepareCall(java.lang.String sql)
default java.sql.CallableStatement	prepareCall(java.lang.String sql, int resultSetType, int resultSetConcurrency)
default java.sql.CallableStatement	prepareCall(java.lang.String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability)
default java.sql.PreparedStatement	prepareStatement(java.lang.String sql)
default java.sql.PreparedStatement	prepareStatement(java.lang.String sql, int autoGeneratedKeys)
default java.sql.PreparedStatement	prepareStatement(java.lang.String sql, int[] columnIndexes)
default java.sql.PreparedStatement	prepareStatement(java.lang.String sql, int resultSetType, int resultSetConcurrency)
default java.sql.PreparedStatement	prepareStatement(java.lang.String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability)
default java.sql.PreparedStatement	prepareStatement(java.lang.String sql, java.lang.String[] columnNames)
default void	releaseSavepoint(java.sql.Savepoint savepoint)
default void	rollback()
default void	rollback(java.sql.Savepoint savepoint)
default void	setAutoCommit(boolean autoCommit)
default void	setCatalog(java.lang.String catalog)
default void	setClientInfo(java.util.Properties properties)
default void	setClientInfo(java.lang.String name, java.lang.String value)
default void	setHoldability(int holdability)
default void	setNetworkTimeout(java.util.concurrent.Executor executor, int milliseconds)
default void	setReadOnly(boolean readOnly)
default java.sql.Savepoint	setSavepoint()
default java.sql.Savepoint	setSavepoint(java.lang.String name)
default void	setSchema(java.lang.String schema)
default void	setTransactionIsolation(int level)
default void	setTypeMap(java.util.Map<java.lang.String,java.lang.Class<?>> map)
default <T> T	unwrap(java.lang.Class<T> iface)

Method Detail

con

java.sql.Connection con()

unwrap

default <T> T unwrap(java.lang.Class<T> iface)
              throws java.sql.SQLException

Specified by:

unwrap in interface java.sql.Wrapper

Throws:

java.sql.SQLException

isWrapperFor

default boolean isWrapperFor(java.lang.Class<?> iface)
                      throws java.sql.SQLException

Specified by:

isWrapperFor in interface java.sql.Wrapper

Throws:

java.sql.SQLException

createStatement

default java.sql.Statement createStatement()
                                    throws java.sql.SQLException

Specified by:

createStatement in interface java.sql.Connection

Throws:

java.sql.SQLException

prepareStatement

default java.sql.PreparedStatement prepareStatement(java.lang.String sql)
                                             throws java.sql.SQLException

Specified by:

prepareStatement in interface java.sql.Connection

Throws:

java.sql.SQLException

prepareCall

default java.sql.CallableStatement prepareCall(java.lang.String sql)
                                        throws java.sql.SQLException

Specified by:

prepareCall in interface java.sql.Connection

Throws:

java.sql.SQLException

nativeSQL

default java.lang.String nativeSQL(java.lang.String sql)
                            throws java.sql.SQLException

Specified by:

nativeSQL in interface java.sql.Connection

Throws:

java.sql.SQLException

setAutoCommit

default void setAutoCommit(boolean autoCommit)
                    throws java.sql.SQLException

Specified by:

setAutoCommit in interface java.sql.Connection

Throws:

java.sql.SQLException

getAutoCommit

default boolean getAutoCommit()
                       throws java.sql.SQLException

Specified by:

getAutoCommit in interface java.sql.Connection

Throws:

java.sql.SQLException

commit

default void commit()
             throws java.sql.SQLException

Specified by:

commit in interface java.sql.Connection

Throws:

java.sql.SQLException

rollback

default void rollback()
               throws java.sql.SQLException

Specified by:

rollback in interface java.sql.Connection

Throws:

java.sql.SQLException

close

default void close()
            throws java.sql.SQLException

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.sql.Connection

Throws:

java.sql.SQLException

isClosed

default boolean isClosed()
                  throws java.sql.SQLException

Specified by:

isClosed in interface java.sql.Connection

Throws:

java.sql.SQLException

getMetaData

default java.sql.DatabaseMetaData getMetaData()
                                       throws java.sql.SQLException

Specified by:

getMetaData in interface java.sql.Connection

Throws:

java.sql.SQLException

setReadOnly

default void setReadOnly(boolean readOnly)
                  throws java.sql.SQLException

Specified by:

setReadOnly in interface java.sql.Connection

Throws:

java.sql.SQLException

isReadOnly

default boolean isReadOnly()
                    throws java.sql.SQLException

Specified by:

isReadOnly in interface java.sql.Connection

Throws:

java.sql.SQLException

setCatalog

default void setCatalog(java.lang.String catalog)
                 throws java.sql.SQLException

Specified by:

setCatalog in interface java.sql.Connection

Throws:

java.sql.SQLException

getCatalog

default java.lang.String getCatalog()
                             throws java.sql.SQLException

Specified by:

getCatalog in interface java.sql.Connection

Throws:

java.sql.SQLException

setTransactionIsolation

default void setTransactionIsolation(int level)
                              throws java.sql.SQLException

Specified by:

setTransactionIsolation in interface java.sql.Connection

Throws:

java.sql.SQLException

getTransactionIsolation

default int getTransactionIsolation()
                             throws java.sql.SQLException

Specified by:

getTransactionIsolation in interface java.sql.Connection

Throws:

java.sql.SQLException

getWarnings

default java.sql.SQLWarning getWarnings()
                                 throws java.sql.SQLException

Specified by:

getWarnings in interface java.sql.Connection

Throws:

java.sql.SQLException

clearWarnings

default void clearWarnings()
                    throws java.sql.SQLException

Specified by:

clearWarnings in interface java.sql.Connection

Throws:

java.sql.SQLException

createStatement

default java.sql.Statement createStatement(int resultSetType,
                                           int resultSetConcurrency)
                                    throws java.sql.SQLException

Specified by:

createStatement in interface java.sql.Connection

Throws:

java.sql.SQLException

prepareStatement

default java.sql.PreparedStatement prepareStatement(java.lang.String sql,
                                                    int resultSetType,
                                                    int resultSetConcurrency)
                                             throws java.sql.SQLException

Specified by:

prepareStatement in interface java.sql.Connection

Throws:

java.sql.SQLException

prepareCall

default java.sql.CallableStatement prepareCall(java.lang.String sql,
                                               int resultSetType,
                                               int resultSetConcurrency)
                                        throws java.sql.SQLException

Specified by:

prepareCall in interface java.sql.Connection

Throws:

java.sql.SQLException

getTypeMap

default java.util.Map<java.lang.String,java.lang.Class<?>> getTypeMap()
                                                               throws java.sql.SQLException

Specified by:

getTypeMap in interface java.sql.Connection

Throws:

java.sql.SQLException

setTypeMap

default void setTypeMap(java.util.Map<java.lang.String,java.lang.Class<?>> map)
                 throws java.sql.SQLException

Specified by:

setTypeMap in interface java.sql.Connection

Throws:

java.sql.SQLException

setHoldability

default void setHoldability(int holdability)
                     throws java.sql.SQLException

Specified by:

setHoldability in interface java.sql.Connection

Throws:

java.sql.SQLException

getHoldability

default int getHoldability()
                    throws java.sql.SQLException

Specified by:

getHoldability in interface java.sql.Connection

Throws:

java.sql.SQLException

setSavepoint

default java.sql.Savepoint setSavepoint()
                                 throws java.sql.SQLException

Specified by:

setSavepoint in interface java.sql.Connection

Throws:

java.sql.SQLException

setSavepoint

default java.sql.Savepoint setSavepoint(java.lang.String name)
                                 throws java.sql.SQLException

Specified by:

setSavepoint in interface java.sql.Connection

Throws:

java.sql.SQLException

rollback

default void rollback(java.sql.Savepoint savepoint)
               throws java.sql.SQLException

Specified by:

rollback in interface java.sql.Connection

Throws:

java.sql.SQLException

releaseSavepoint

default void releaseSavepoint(java.sql.Savepoint savepoint)
                       throws java.sql.SQLException

Specified by:

releaseSavepoint in interface java.sql.Connection

Throws:

java.sql.SQLException

createStatement

default java.sql.Statement createStatement(int resultSetType,
                                           int resultSetConcurrency,
                                           int resultSetHoldability)
                                    throws java.sql.SQLException

Specified by:

createStatement in interface java.sql.Connection

Throws:

java.sql.SQLException

prepareStatement

default java.sql.PreparedStatement prepareStatement(java.lang.String sql,
                                                    int resultSetType,
                                                    int resultSetConcurrency,
                                                    int resultSetHoldability)
                                             throws java.sql.SQLException

Specified by:

prepareStatement in interface java.sql.Connection

Throws:

java.sql.SQLException

prepareCall

default java.sql.CallableStatement prepareCall(java.lang.String sql,
                                               int resultSetType,
                                               int resultSetConcurrency,
                                               int resultSetHoldability)
                                        throws java.sql.SQLException

Specified by:

prepareCall in interface java.sql.Connection

Throws:

java.sql.SQLException

prepareStatement

default java.sql.PreparedStatement prepareStatement(java.lang.String sql,
                                                    int autoGeneratedKeys)
                                             throws java.sql.SQLException

Specified by:

prepareStatement in interface java.sql.Connection

Throws:

java.sql.SQLException

prepareStatement

default java.sql.PreparedStatement prepareStatement(java.lang.String sql,
                                                    int[] columnIndexes)
                                             throws java.sql.SQLException

Specified by:

prepareStatement in interface java.sql.Connection

Throws:

java.sql.SQLException

prepareStatement

default java.sql.PreparedStatement prepareStatement(java.lang.String sql,
                                                    java.lang.String[] columnNames)
                                             throws java.sql.SQLException

Specified by:

prepareStatement in interface java.sql.Connection

Throws:

java.sql.SQLException

createClob

default java.sql.Clob createClob()
                          throws java.sql.SQLException

Specified by:

createClob in interface java.sql.Connection

Throws:

java.sql.SQLException

createBlob

default java.sql.Blob createBlob()
                          throws java.sql.SQLException

Specified by:

createBlob in interface java.sql.Connection

Throws:

java.sql.SQLException

createNClob

default java.sql.NClob createNClob()
                            throws java.sql.SQLException

Specified by:

createNClob in interface java.sql.Connection

Throws:

java.sql.SQLException

createSQLXML

default java.sql.SQLXML createSQLXML()
                              throws java.sql.SQLException

Specified by:

createSQLXML in interface java.sql.Connection

Throws:

java.sql.SQLException

isValid

default boolean isValid(int timeout)
                 throws java.sql.SQLException

Specified by:

isValid in interface java.sql.Connection

Throws:

java.sql.SQLException

setClientInfo

default void setClientInfo(java.lang.String name,
                           java.lang.String value)
                    throws java.sql.SQLClientInfoException

Specified by:

setClientInfo in interface java.sql.Connection

Throws:

java.sql.SQLClientInfoException

setClientInfo

default void setClientInfo(java.util.Properties properties)
                    throws java.sql.SQLClientInfoException

Specified by:

setClientInfo in interface java.sql.Connection

Throws:

java.sql.SQLClientInfoException

getClientInfo

default java.lang.String getClientInfo(java.lang.String name)
                                throws java.sql.SQLException

Specified by:

getClientInfo in interface java.sql.Connection

Throws:

java.sql.SQLException

getClientInfo

default java.util.Properties getClientInfo()
                                    throws java.sql.SQLException

Specified by:

getClientInfo in interface java.sql.Connection

Throws:

java.sql.SQLException

createArrayOf

default java.sql.Array createArrayOf(java.lang.String typeName,
                                     java.lang.Object[] elements)
                              throws java.sql.SQLException

Specified by:

createArrayOf in interface java.sql.Connection

Throws:

java.sql.SQLException

createStruct

default java.sql.Struct createStruct(java.lang.String typeName,
                                     java.lang.Object[] attributes)
                              throws java.sql.SQLException

Specified by:

createStruct in interface java.sql.Connection

Throws:

java.sql.SQLException

setSchema

default void setSchema(java.lang.String schema)
                throws java.sql.SQLException

Specified by:

setSchema in interface java.sql.Connection

Throws:

java.sql.SQLException

getSchema

default java.lang.String getSchema()
                            throws java.sql.SQLException

Specified by:

getSchema in interface java.sql.Connection

Throws:

java.sql.SQLException

abort

default void abort(java.util.concurrent.Executor executor)
            throws java.sql.SQLException

Specified by:

abort in interface java.sql.Connection

Throws:

java.sql.SQLException

setNetworkTimeout

default void setNetworkTimeout(java.util.concurrent.Executor executor,
                               int milliseconds)
                        throws java.sql.SQLException

Specified by:

setNetworkTimeout in interface java.sql.Connection

Throws:

java.sql.SQLException

getNetworkTimeout

default int getNetworkTimeout()
                       throws java.sql.SQLException

Specified by:

getNetworkTimeout in interface java.sql.Connection

Throws:

java.sql.SQLException