software.amazon.jdbc.plugin.encryption

Class IndependentDataSource

java.lang.Object

software.amazon.jdbc.plugin.encryption.IndependentDataSource

All Implemented Interfaces:

java.sql.Wrapper, javax.sql.CommonDataSource, javax.sql.DataSource

public class IndependentDataSource
extends java.lang.Object
implements javax.sql.DataSource

DataSource implementation that creates independent connections using PluginService. This ensures that MetadataManager gets its own connections and doesn't share with client applications.

Constructor Summary

Constructors

Constructor and Description
IndependentDataSource(PluginService pluginService) Creates an IndependentDataSource with the given PluginService.
IndependentDataSource(PluginService pluginService, java.util.Properties connectionProperties) Creates an IndependentDataSource with PluginService and connection properties.

Method Summary

Modifier and Type	Method and Description
java.sql.Connection	getConnection()
java.sql.Connection	getConnection(java.lang.String username, java.lang.String password)
long	getConnectionRequestCount() Gets the total number of connection requests made to this DataSource.
double	getConnectionSuccessRate() Calculates the connection success rate as a percentage.
long	getFailedConnectionCount() Gets the number of failed connection creation attempts.
java.lang.String	getHealthStatus() Gets a comprehensive status message about the DataSource health and metrics.
long	getLastFailedConnectionTime() Gets the timestamp of the last failed connection attempt.
long	getLastSuccessfulConnectionTime() Gets the timestamp of the last successful connection creation.
int	getLoginTimeout()
java.io.PrintWriter	getLogWriter()
java.util.logging.Logger	getParentLogger()
PluginService	getPluginService() Gets the PluginService used by this DataSource.
long	getSuccessfulConnectionCount() Gets the number of successful connection creations.
boolean	isHealthy() Checks if the DataSource is currently healthy based on recent connection attempts.
boolean	isWrapperFor(java.lang.Class<?> iface)
void	logHealthStatus() Logs the current health status and metrics.
void	setLoginTimeout(int seconds)
void	setLogWriter(java.io.PrintWriter out)
<T> T	unwrap(java.lang.Class<T> iface)
boolean	validateConnection() Validates that a connection can be created with the current PluginService.

Methods inherited from class java.lang.Object

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

Constructor Detail

IndependentDataSource

public IndependentDataSource(PluginService pluginService)

Creates an IndependentDataSource with the given PluginService.

Parameters:

pluginService - the PluginService to use for creating connections

Throws:

java.lang.IllegalArgumentException - if pluginService is null

IndependentDataSource

public IndependentDataSource(PluginService pluginService,
                             java.util.Properties connectionProperties)

Creates an IndependentDataSource with PluginService and connection properties.

Parameters:

pluginService - the PluginService to use for creating connections

connectionProperties - additional connection properties

Throws:

java.lang.IllegalArgumentException - if pluginService is null

Method Detail

getConnection

public java.sql.Connection getConnection()
                                  throws java.sql.SQLException

Specified by:

getConnection in interface javax.sql.DataSource

Throws:

java.sql.SQLException

getConnection

public java.sql.Connection getConnection(java.lang.String username,
                                         java.lang.String password)
                                  throws java.sql.SQLException

Specified by:

getConnection in interface javax.sql.DataSource

Throws:

java.sql.SQLException

validateConnection

public boolean validateConnection()

Validates that a connection can be created with the current PluginService.

Returns:

true if a connection can be created, false otherwise

getPluginService

public PluginService getPluginService()

Gets the PluginService used by this DataSource.

Returns:

the PluginService

unwrap

public <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

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

Specified by:

isWrapperFor in interface java.sql.Wrapper

Throws:

java.sql.SQLException

getLogWriter

public java.io.PrintWriter getLogWriter()
                                 throws java.sql.SQLException

Specified by:

getLogWriter in interface javax.sql.CommonDataSource

Throws:

java.sql.SQLException

setLogWriter

public void setLogWriter(java.io.PrintWriter out)
                  throws java.sql.SQLException

Specified by:

setLogWriter in interface javax.sql.CommonDataSource

Throws:

java.sql.SQLException

setLoginTimeout

public void setLoginTimeout(int seconds)
                     throws java.sql.SQLException

Specified by:

setLoginTimeout in interface javax.sql.CommonDataSource

Throws:

java.sql.SQLException

getLoginTimeout

public int getLoginTimeout()
                    throws java.sql.SQLException

Specified by:

getLoginTimeout in interface javax.sql.CommonDataSource

Throws:

java.sql.SQLException

getParentLogger

public java.util.logging.Logger getParentLogger()
                                         throws java.sql.SQLFeatureNotSupportedException

Specified by:

getParentLogger in interface javax.sql.CommonDataSource

Throws:

java.sql.SQLFeatureNotSupportedException

getConnectionRequestCount

public long getConnectionRequestCount()

Gets the total number of connection requests made to this DataSource.

Returns:

the total connection request count

getSuccessfulConnectionCount

public long getSuccessfulConnectionCount()

Gets the number of successful connection creations.

Returns:

the successful connection count

getFailedConnectionCount

public long getFailedConnectionCount()

Gets the number of failed connection creation attempts.

Returns:

the failed connection count

getLastSuccessfulConnectionTime

public long getLastSuccessfulConnectionTime()

Gets the timestamp of the last successful connection creation.

Returns:

the timestamp in milliseconds, or 0 if no successful connections

getLastFailedConnectionTime

public long getLastFailedConnectionTime()

Gets the timestamp of the last failed connection attempt.

Returns:

the timestamp in milliseconds, or 0 if no failed connections

getConnectionSuccessRate

public double getConnectionSuccessRate()

Calculates the connection success rate as a percentage.

Returns:

the success rate (0.0 to 1.0), or 1.0 if no attempts have been made

isHealthy

public boolean isHealthy()

Checks if the DataSource is currently healthy based on recent connection attempts.

Returns:

true if the DataSource appears healthy, false otherwise

getHealthStatus

public java.lang.String getHealthStatus()

Gets a comprehensive status message about the DataSource health and metrics.

Returns:

a detailed status message

logHealthStatus

public void logHealthStatus()

Logs the current health status and metrics.