com.github.davidmoten.rx.jdbc

Class ConnectionProviderPooled

java.lang.Object

com.github.davidmoten.rx.jdbc.ConnectionProviderPooled

All Implemented Interfaces:

ConnectionProvider

public final class ConnectionProviderPooled
extends Object
implements ConnectionProvider

Provides database connection pooling using HikariCP.

Constructor Summary

Constructors

Constructor and Description
ConnectionProviderPooled(String url, int minPoolSize, int maxPoolSize) Constructor.
ConnectionProviderPooled(String url, String username, String password, int minPoolSize, int maxPoolSize) Constructor.

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Closes the connection provider and releases its resources.
Connection	get() Returns a new Connection (perhaps from a Connection pool).

Methods inherited from class java.lang.Object

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

Constructor Detail

ConnectionProviderPooled

public ConnectionProviderPooled(String url,
                        int minPoolSize,
                        int maxPoolSize)

Constructor.

Parameters:

url -

minPoolSize -

maxPoolSize -

ConnectionProviderPooled

public ConnectionProviderPooled(String url,
                        String username,
                        String password,
                        int minPoolSize,
                        int maxPoolSize)

Constructor.

Parameters:

url - jdbc url

username - database login username

password - database login password

minPoolSize - minimum size of the connection pool

maxPoolSize - maximum size of the connection pool

Method Detail

get

public Connection get()

Description copied from interface: ConnectionProvider

Returns a new Connection (perhaps from a Connection pool).

Specified by:

get in interface ConnectionProvider

Returns:

a new Connection to a database

close

public void close()

Description copied from interface: ConnectionProvider

Closes the connection provider and releases its resources. For example, a connection pool may need formal closure to release its connections because connection.close() is actually just releasing a connection back to the pool for reuse. This method should be idempotent.

Specified by:

close in interface ConnectionProvider