software.amazon.jdbc.plugin

Class TrackedConnectionList

java.lang.Object

software.amazon.jdbc.plugin.TrackedConnectionList

public class TrackedConnectionList
extends java.lang.Object

A thread-safe doubly-linked list for tracking opened connections. Uses a lock-per-list approach for concurrency control. Supports O(1) removal when a direct node reference is available.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TrackedConnectionList.Node A node in the doubly-linked list holding a weak reference to a connection.

Constructor Summary

Constructors

Constructor and Description
TrackedConnectionList()

Method Summary

Modifier and Type	Method and Description
TrackedConnectionList.Node	add(java.sql.Connection connection) Adds a connection to the tail of the list.
void	appendTo(java.lang.StringBuilder builder) Iterates over all nodes and collects connection string representations.
java.util.List<java.sql.Connection>	drainAll() Removes all nodes from the list and returns the connections.
boolean	isEmpty()
void	remove(TrackedConnectionList.Node node) Removes a node from the list in O(1) time.
void	removeIf(java.util.function.Predicate<java.lang.ref.WeakReference<java.sql.Connection>> predicate) Removes nodes matching the predicate.
int	size()

Methods inherited from class java.lang.Object

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

Constructor Detail

TrackedConnectionList

public TrackedConnectionList()

Method Detail

add

public TrackedConnectionList.Node add(java.sql.Connection connection)

Adds a connection to the tail of the list.

Parameters:

connection - the connection to track

Returns:

the node representing this connection, for O(1) removal later

remove

public void remove(TrackedConnectionList.Node node)

Removes a node from the list in O(1) time. Safe to call multiple times on the same node.

Parameters:

node - the node to remove

drainAll

public java.util.List<java.sql.Connection> drainAll()

Removes all nodes from the list and returns the connections. Used during invalidation to drain and abort all tracked connections.

Returns:

list of connections that were in the list (may contain nulls from GC'd weak refs)

removeIf

public void removeIf(java.util.function.Predicate<java.lang.ref.WeakReference<java.sql.Connection>> predicate)

Removes nodes matching the predicate. Used for pruning GC'd or closed connections.

Parameters:

predicate - test applied to each node's weak reference

isEmpty

public boolean isEmpty()

size

public int size()

appendTo

public void appendTo(java.lang.StringBuilder builder)

Iterates over all nodes and collects connection string representations. Used for logging only.

Parameters:

builder - the StringBuilder to append to