Package org.hibernate.resource.jdbc.internal

Class LogicalConnectionManagedImpl

java.lang.Object

org.hibernate.resource.jdbc.internal.AbstractLogicalConnectionImplementor

org.hibernate.resource.jdbc.internal.LogicalConnectionManagedImpl

All Implemented Interfaces:

LogicalConnection, LogicalConnectionImplementor, PhysicalJdbcTransaction, JdbcResourceTransaction

public class LogicalConnectionManagedImpl
extends AbstractLogicalConnectionImplementor

Represents a LogicalConnection where we manage obtaining and releasing the Connection as needed. This implementation does not claim to be thread-safe and is not designed to be used by multiple threads, yet we do apply a limited amount of care to be able to void obscure exceptions when this class is used in the wrong way.

Field Summary

Fields inherited from class org.hibernate.resource.jdbc.internal.AbstractLogicalConnectionImplementor

resourceRegistry

Constructor Summary

Constructors

Constructor	Description
LogicalConnectionManagedImpl(JdbcConnectionAccess jdbcConnectionAccess, JdbcSessionContext jdbcSessionContext, ResourceRegistry resourceRegistry, JdbcServices jdbcServices)

Method Summary

Modifier and Type	Method	Description
protected void	afterCompletion()
void	afterStatement()	Notification indicating a JDBC statement has been executed, to trigger ConnectionReleaseMode.AFTER_STATEMENT releasing if needed.
void	afterTransaction()	Notification indicating a transaction has just completed, to trigger ConnectionReleaseMode.AFTER_TRANSACTION releasing if needed.
void	beforeTransactionCompletion()	Notification indicating a transaction is about to be completed, to trigger release of the JDBC connection if needed, that is, if ConnectionReleaseMode.BEFORE_TRANSACTION_COMPLETION is enabled.
void	begin()	Begin the resource transaction
Connection	close()	Closes the logical connection, making it inactive and forcing release of any held resources.
static LogicalConnectionManagedImpl	deserialize(ObjectInputStream ois, JdbcConnectionAccess jdbcConnectionAccess, JdbcSessionContext jdbcSessionContext)
protected boolean	doConnectionsFromProviderHaveAutoCommitDisabled()
protected Connection	getConnectionForTransactionManagement()
PhysicalConnectionHandlingMode	getConnectionHandlingMode()
Connection	getPhysicalConnection()	Exposes access to the "real" Connection.
boolean	isOpen()	Is this (logical) JDBC connection still open/active?
boolean	isPhysicallyConnected()	Is this logical connection currently physically connected?
Connection	manualDisconnect()	Manually disconnect the underlying JDBC Connection.
void	manualReconnect(Connection suppliedConnection)	Manually reconnect the underlying JDBC Connection.
void	serialize(ObjectOutputStream oos)	Serialization hook.

Methods inherited from class org.hibernate.resource.jdbc.internal.AbstractLogicalConnectionImplementor

commit, determineInitialAutoCommitMode, errorIfClosed, getPhysicalJdbcTransaction, getResourceRegistry, getStatus, resetConnection, rollback

Methods inherited from class java.lang.Object

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

Constructor Detail

LogicalConnectionManagedImpl

public LogicalConnectionManagedImpl(JdbcConnectionAccess jdbcConnectionAccess,
                                    JdbcSessionContext jdbcSessionContext,
                                    ResourceRegistry resourceRegistry,
                                    JdbcServices jdbcServices)

Method Detail

isOpen

public boolean isOpen()

Description copied from interface: LogicalConnection

Is this (logical) JDBC connection still open/active?

That is, has LogicalConnection.close() not yet been called?

Returns:

true if still open, since LogicalConnection.close() has not yet been called; false if not open, since LogicalConnection.close() was called.

getConnectionHandlingMode

public PhysicalConnectionHandlingMode getConnectionHandlingMode()

isPhysicallyConnected

public boolean isPhysicallyConnected()

Description copied from interface: LogicalConnection

Is this logical connection currently physically connected?

That is, does it currently hold a physical JDBC Connection?

Returns:

true if currently holding a JDBC Connection; false if not.

getPhysicalConnection

public Connection getPhysicalConnection()

Description copied from interface: LogicalConnectionImplementor

Exposes access to the "real" Connection.

Returns:

The connection

afterStatement

public void afterStatement()

Description copied from interface: LogicalConnectionImplementor

Notification indicating a JDBC statement has been executed, to trigger ConnectionReleaseMode.AFTER_STATEMENT releasing if needed.

Specified by:

afterStatement in interface LogicalConnectionImplementor

Overrides:

afterStatement in class AbstractLogicalConnectionImplementor

beforeTransactionCompletion

public void beforeTransactionCompletion()

Description copied from interface: LogicalConnectionImplementor

Notification indicating a transaction is about to be completed, to trigger release of the JDBC connection if needed, that is, if ConnectionReleaseMode.BEFORE_TRANSACTION_COMPLETION is enabled.

Specified by:

beforeTransactionCompletion in interface LogicalConnectionImplementor

Overrides:

beforeTransactionCompletion in class AbstractLogicalConnectionImplementor

afterTransaction

public void afterTransaction()

Description copied from interface: LogicalConnectionImplementor

Notification indicating a transaction has just completed, to trigger ConnectionReleaseMode.AFTER_TRANSACTION releasing if needed.

Specified by:

afterTransaction in interface LogicalConnectionImplementor

Overrides:

afterTransaction in class AbstractLogicalConnectionImplementor

manualDisconnect

public Connection manualDisconnect()

Description copied from interface: LogicalConnectionImplementor

Manually disconnect the underlying JDBC Connection. The assumption here is that the manager will be reconnected at a later point in time.

Returns:

The connection maintained here at time of disconnect. null if there was no connection cached internally.

manualReconnect

public void manualReconnect(Connection suppliedConnection)

Description copied from interface: LogicalConnectionImplementor

Manually reconnect the underlying JDBC Connection. Should be called at some point after LogicalConnectionImplementor.manualDisconnect().

Parameters:

suppliedConnection - For user supplied connection strategy the user needs to hand us the connection with which to reconnect. It is an error to pass a connection in the other strategies.

serialize

public void serialize(ObjectOutputStream oos)
               throws IOException

Description copied from interface: LogicalConnectionImplementor

Serialization hook.

Parameters:

oos - The stream to write out state to

Throws:

IOException - Problem accessing stream

deserialize

public static LogicalConnectionManagedImpl deserialize(ObjectInputStream ois,
                                                       JdbcConnectionAccess jdbcConnectionAccess,
                                                       JdbcSessionContext jdbcSessionContext)
                                                throws IOException

Throws:

IOException

close

public Connection close()

Description copied from interface: LogicalConnection

Closes the logical connection, making it inactive and forcing release of any held resources.

Returns:

the JDBC Connection if the user passed in a Connection originally

getConnectionForTransactionManagement

protected Connection getConnectionForTransactionManagement()

Specified by:

getConnectionForTransactionManagement in class AbstractLogicalConnectionImplementor

begin

public void begin()

Description copied from interface: JdbcResourceTransaction

Begin the resource transaction

Specified by:

begin in interface JdbcResourceTransaction

Overrides:

begin in class AbstractLogicalConnectionImplementor

afterCompletion

protected void afterCompletion()

Overrides:

afterCompletion in class AbstractLogicalConnectionImplementor

doConnectionsFromProviderHaveAutoCommitDisabled

protected boolean doConnectionsFromProviderHaveAutoCommitDisabled()

Overrides:

doConnectionsFromProviderHaveAutoCommitDisabled in class AbstractLogicalConnectionImplementor