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 @Nullable AtomicConnection.ConnectionCleanupAction	cleanupAction
protected boolean	logUnclosedConnections

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	clean()
boolean	compareAndSet(@Nullable java.sql.Connection expected, @Nullable java.sql.Connection updated)
@Nullable java.sql.Connection	get()
void	set(@Nullable java.sql.Connection connection)
void	set(@Nullable java.sql.Connection connection, boolean closePreviousConnection)
void	set(@Nullable java.sql.Connection connection, @Nullable 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 @Nullable AtomicConnection.ConnectionCleanupAction cleanupAction

Constructor Detail

AtomicConnection

public AtomicConnection(@NonNull java.lang.Object referent)

AtomicConnection

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

Method Detail

clean

public void clean()

get

public @Nullable java.sql.Connection get()

set

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

set

public void set(@Nullable java.sql.Connection connection)

set

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

compareAndSet

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