Package com.zendesk.maxwell.util

Class C3P0ConnectionPool

java.lang.Object

com.zendesk.maxwell.util.C3P0ConnectionPool

All Implemented Interfaces:

ConnectionPool

public class C3P0ConnectionPool
extends Object
implements ConnectionPool

Nested Class Summary

Nested classes/interfaces inherited from interface com.zendesk.maxwell.util.ConnectionPool

ConnectionPool.RetryableSQLFunction<T>

Constructor Summary

Constructors

Constructor	Description
C3P0ConnectionPool(String url, String user, String password)

Method Summary

Modifier and Type	Method	Description
Connection	getConnection()
void	probe()
void	release()
void	withSQLRetry(int nTries, ConnectionPool.RetryableSQLFunction<Connection> inner)

Methods inherited from class java.lang.Object

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

Constructor Detail

C3P0ConnectionPool

public C3P0ConnectionPool(String url,
                          String user,
                          String password)

Method Detail

getConnection

public Connection getConnection()
                         throws SQLException

Specified by:

getConnection in interface ConnectionPool

Throws:

SQLException

release

public void release()

Specified by:

release in interface ConnectionPool

probe

public void probe()
           throws SQLException

Specified by:

probe in interface ConnectionPool

Throws:

SQLException

withSQLRetry

public void withSQLRetry(int nTries,
                         ConnectionPool.RetryableSQLFunction<Connection> inner)
                  throws SQLException,
                         DuplicateProcessException,
                         NoSuchElementException

Specified by:

withSQLRetry in interface ConnectionPool

Throws:

SQLException

DuplicateProcessException

NoSuchElementException