software.amazon.jdbc

Class AtomicConnection

java.lang.Object

software.amazon.jdbc.AtomicConnection

public class AtomicConnection
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AtomicConnection.ConnectionCleanupAction

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.concurrent.atomic.AtomicReference<java.sql.Connection>	atomicReference
protected LazyCleaner.Cleanable	cleanable
protected AtomicConnection.ConnectionCleanupAction	cleanupAction
protected boolean	logUnclosedConnections

Constructor Summary

Constructors

Constructor and Description
AtomicConnection(java.lang.Object referent)
AtomicConnection(java.lang.Object referent, boolean logUnclosedConnections)

Method Summary

Modifier and Type	Method and Description
void	clean()
boolean	compareAndSet(java.sql.Connection expected, java.sql.Connection updated)
java.sql.Connection	get()
void	set(java.sql.Connection connection)
void	set(java.sql.Connection connection, boolean closePreviousConnection)
void	set(java.sql.Connection connection, java.lang.Throwable openConnectionStacktrace, boolean closePreviousConnection)

Methods inherited from class java.lang.Object

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

Field Detail

atomicReference

protected final java.util.concurrent.atomic.AtomicReference<java.sql.Connection> atomicReference

logUnclosedConnections

protected boolean logUnclosedConnections

cleanable

protected LazyCleaner.Cleanable cleanable

cleanupAction

protected AtomicConnection.ConnectionCleanupAction cleanupAction

Constructor Detail

AtomicConnection

public AtomicConnection(java.lang.Object referent)

AtomicConnection

public AtomicConnection(java.lang.Object referent,
                        boolean logUnclosedConnections)

Method Detail

clean

public void clean()

get

public java.sql.Connection get()

set

public void set(java.sql.Connection connection,
                boolean closePreviousConnection)

set

public void set(java.sql.Connection connection)

set

public void set(java.sql.Connection connection,
                java.lang.Throwable openConnectionStacktrace,
                boolean closePreviousConnection)

compareAndSet

public boolean compareAndSet(java.sql.Connection expected,
                             java.sql.Connection updated)