Package org.apache.flink.cdc.connectors.base.relational.connection

Class JdbcConnectionPools

java.lang.Object

org.apache.flink.cdc.connectors.base.relational.connection.JdbcConnectionPools

All Implemented Interfaces:

ConnectionPools<com.zaxxer.hikari.HikariDataSource,JdbcSourceConfig>

public class JdbcConnectionPools
extends Object
implements ConnectionPools<com.zaxxer.hikari.HikariDataSource,JdbcSourceConfig>

A Jdbc Connection pools implementation.

Method Summary

Modifier and Type	Method	Description
void	clear()
static JdbcConnectionPools	getInstance(JdbcConnectionPoolFactory jdbcConnectionPoolFactory)
String	getJdbcUrl(JdbcSourceConfig sourceConfig, String dataSourcePoolFactoryIdentifier)	this method is only supported for test.
com.zaxxer.hikari.HikariDataSource	getOrCreateConnectionPool(ConnectionPoolId poolId, JdbcSourceConfig sourceConfig)	Gets a connection pool from pools, create a new pool if the pool does not exists in the connection pools .

Methods inherited from class java.lang.Object

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

Method Detail

getInstance

public static JdbcConnectionPools getInstance(JdbcConnectionPoolFactory jdbcConnectionPoolFactory)

getOrCreateConnectionPool

public com.zaxxer.hikari.HikariDataSource getOrCreateConnectionPool(ConnectionPoolId poolId,
                                                                    JdbcSourceConfig sourceConfig)

Description copied from interface: ConnectionPools

Gets a connection pool from pools, create a new pool if the pool does not exists in the connection pools .

Specified by:

getOrCreateConnectionPool in interface ConnectionPools<com.zaxxer.hikari.HikariDataSource,JdbcSourceConfig>

getJdbcUrl

@VisibleForTesting
public String getJdbcUrl(JdbcSourceConfig sourceConfig,
                         String dataSourcePoolFactoryIdentifier)

this method is only supported for test.

clear

public void clear()
           throws IOException

Throws:

IOException