software.amazon.jdbc

Class C3P0PooledConnectionProvider

java.lang.Object

software.amazon.jdbc.C3P0PooledConnectionProvider

All Implemented Interfaces:

CanReleaseResources, ConnectionProvider, PooledConnectionProvider, StateSnapshotProvider

public class C3P0PooledConnectionProvider
extends java.lang.Object
implements PooledConnectionProvider, CanReleaseResources

Field Summary

Fields

Modifier and Type	Field and Description
protected static java.util.Map<java.lang.String,HostSelector>	acceptedStrategies
protected static SlidingExpirationCache<java.lang.String,com.mchange.v2.c3p0.ComboPooledDataSource>	databasePools
protected static long	poolExpirationCheckNanos
protected static RdsUtils	rdsUtils

Constructor Summary

Constructors

Constructor and Description
C3P0PooledConnectionProvider()

Method Summary

Modifier and Type	Method and Description
boolean	acceptsStrategy(@Nullable HostRole role, @NonNull java.lang.String strategy) Indicates whether the selection strategy is supported by the connection provider.
boolean	acceptsUrl(@NonNull java.lang.String protocol, @NonNull HostSpec hostSpec, @NonNull java.util.Properties props) Indicates whether this ConnectionProvider can provide connections for the given host and properties.
@NonNull ConnectionInfo	connect(@NonNull java.lang.String protocol, @NonNull Dialect dialect, @NonNull TargetDriverDialect targetDriverDialect, @NonNull HostSpec hostSpec, @NonNull java.util.Properties props) Called once per connection that needs to be created.
protected com.mchange.v2.c3p0.ComboPooledDataSource	createDataSource(@NonNull java.lang.String protocol, @NonNull HostSpec hostSpec, @NonNull java.util.Properties props, TargetDriverDialect driverDialect)
@Nullable HostSpec	getHostSpecByStrategy(@NonNull java.util.List<HostSpec> hosts, @Nullable HostRole role, @NonNull java.lang.String strategy, @Nullable java.util.Properties props) Return a reader or a writer node using the specified strategy.
java.util.List<Pair<java.lang.String,java.lang.Object>>	getSnapshotState()
java.lang.String	getTargetName()
void	logConnections()
void	releaseResources() An object that implements this interface should release all acquired resources assuming it may be disposed at any time.

Methods inherited from class java.lang.Object

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

Field Detail

databasePools

protected static final SlidingExpirationCache<java.lang.String,com.mchange.v2.c3p0.ComboPooledDataSource> databasePools

acceptedStrategies

protected static final java.util.Map<java.lang.String,HostSelector> acceptedStrategies

poolExpirationCheckNanos

protected static final long poolExpirationCheckNanos

rdsUtils

protected static final RdsUtils rdsUtils

Constructor Detail

C3P0PooledConnectionProvider

public C3P0PooledConnectionProvider()

Method Detail

acceptsUrl

public boolean acceptsUrl(@NonNull java.lang.String protocol,
                          @NonNull HostSpec hostSpec,
                          @NonNull java.util.Properties props)

Description copied from interface: ConnectionProvider

Indicates whether this ConnectionProvider can provide connections for the given host and properties. Some ConnectionProvider implementations may not be able to handle certain URL types or properties.

Specified by:

acceptsUrl in interface ConnectionProvider

Parameters:

protocol - the connection protocol (example "jdbc:mysql://")

hostSpec - the HostSpec containing the host-port information for the host to connect to

props - the Properties to use for the connection

Returns:

true if this ConnectionProvider can provide connections for the given URL, otherwise return false

acceptsStrategy

public boolean acceptsStrategy(@Nullable HostRole role,
                               @NonNull java.lang.String strategy)

Description copied from interface: ConnectionProvider

Indicates whether the selection strategy is supported by the connection provider.

Specified by:

acceptsStrategy in interface ConnectionProvider

Parameters:

role - determines if the connection provider should return a reader host or a writer host. Null value means no preferences on host role.

strategy - the selection strategy to use

Returns:

whether the strategy is supported

getHostSpecByStrategy

public @Nullable HostSpec getHostSpecByStrategy(@NonNull java.util.List<HostSpec> hosts,
                                                @Nullable HostRole role,
                                                @NonNull java.lang.String strategy,
                                                @Nullable java.util.Properties props)
                                         throws java.sql.SQLException,
                                                java.lang.UnsupportedOperationException

Description copied from interface: ConnectionProvider

Return a reader or a writer node using the specified strategy. This method should raise an UnsupportedOperationException if the specified strategy is unsupported.

Specified by:

getHostSpecByStrategy in interface ConnectionProvider

Parameters:

hosts - the list of HostSpec to select from

role - determines if the connection provider should return a writer or a reader

strategy - the strategy determining how the HostSpec should be selected, e.g., random or round-robin

props - any properties that are required by the provided strategy to select a host

Returns:

the HostSpec selected using the specified strategy, or null if no host matches

Throws:

java.sql.SQLException - if an error occurred while returning the hosts

java.lang.UnsupportedOperationException - if the strategy is unsupported by the provider

connect

public @NonNull ConnectionInfo connect(@NonNull java.lang.String protocol,
                                       @NonNull Dialect dialect,
                                       @NonNull TargetDriverDialect targetDriverDialect,
                                       @NonNull HostSpec hostSpec,
                                       @NonNull java.util.Properties props)
                                throws java.sql.SQLException

Description copied from interface: ConnectionProvider

Called once per connection that needs to be created.

Specified by:

connect in interface ConnectionProvider

Parameters:

protocol - the connection protocol (example "jdbc:mysql://")

dialect - the database dialect

targetDriverDialect - the target driver dialect

hostSpec - the HostSpec containing the host-port information for the host to connect to

props - the Properties to use for the connection

Returns:

ConnectionInfo resulting from the given connection information

Throws:

java.sql.SQLException - if an error occurs

createDataSource

protected com.mchange.v2.c3p0.ComboPooledDataSource createDataSource(@NonNull java.lang.String protocol,
                                                                     @NonNull HostSpec hostSpec,
                                                                     @NonNull java.util.Properties props,
                                                                     TargetDriverDialect driverDialect)

getTargetName

public java.lang.String getTargetName()

Specified by:

getTargetName in interface ConnectionProvider

releaseResources

public void releaseResources()

Description copied from interface: CanReleaseResources

An object that implements this interface should release all acquired resources assuming it may be disposed at any time. This method may be called more than once.

Calling this method does NOT mean that an object is disposing and there won't be any further calls. An object should keep its functional state after calling this method.

Specified by:

releaseResources in interface CanReleaseResources

logConnections

public void logConnections()

getSnapshotState

public java.util.List<Pair<java.lang.String,java.lang.Object>> getSnapshotState()

Specified by:

getSnapshotState in interface StateSnapshotProvider