software.amazon.jdbc

Class DataSourceConnectionProvider

java.lang.Object

software.amazon.jdbc.DataSourceConnectionProvider

All Implemented Interfaces:

ConnectionProvider

public class DataSourceConnectionProvider
extends java.lang.Object
implements ConnectionProvider

This class is a basic implementation of ConnectionProvider interface. It creates and returns an instance of PgConnection.

Constructor Summary

Constructors

Constructor and Description
DataSourceConnectionProvider(@NonNull javax.sql.DataSource dataSource, @Nullable java.lang.String serverPropertyName, @Nullable java.lang.String portPropertyName, @Nullable java.lang.String urlPropertyName, @Nullable java.lang.String databasePropertyName)

Method Summary

Modifier and Type	Method and Description
java.sql.Connection	connect(@NonNull java.lang.String protocol, @NonNull HostSpec hostSpec, @NonNull java.util.Properties props) Called once per connection that needs to be created.
java.sql.Connection	connect(@NonNull java.lang.String url, @NonNull java.util.Properties props) Called once per connection that needs to be created.

Methods inherited from class java.lang.Object

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

Constructor Detail

DataSourceConnectionProvider

public DataSourceConnectionProvider(@NonNull javax.sql.DataSource dataSource,
                                    @Nullable java.lang.String serverPropertyName,
                                    @Nullable java.lang.String portPropertyName,
                                    @Nullable java.lang.String urlPropertyName,
                                    @Nullable java.lang.String databasePropertyName)

Method Detail

connect

public java.sql.Connection connect(@NonNull java.lang.String protocol,
                                   @NonNull HostSpec hostSpec,
                                   @NonNull java.util.Properties props)
                            throws java.sql.SQLException

Called once per connection that needs to be created.

Specified by:

connect 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:

Connection resulting from the given connection information

Throws:

java.sql.SQLException - if an error occurs

connect

public java.sql.Connection connect(@NonNull java.lang.String url,
                                   @NonNull java.util.Properties props)
                            throws java.sql.SQLException

Called once per connection that needs to be created.

Specified by:

connect in interface ConnectionProvider

Parameters:

url - The connection URL

props - The Properties to use for the connection

Returns:

Connection resulting from the given connection information

Throws:

java.sql.SQLException - if an error occurs