Package org.apache.flink.cdc.connectors.mysql.source.connection

Class JdbcConnectionPools

java.lang.Object

org.apache.flink.cdc.connectors.mysql.source.connection.JdbcConnectionPools

All Implemented Interfaces:

ConnectionPools

public class JdbcConnectionPools
extends Object
implements ConnectionPools

A Jdbc Connection pools implementation.

Method Summary

Modifier and Type	Method	Description
void	clear()
static JdbcConnectionPools	getInstance()
com.zaxxer.hikari.HikariDataSource	getOrCreateConnectionPool(ConnectionPoolId poolId, MySqlSourceConfig 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()

getOrCreateConnectionPool

public com.zaxxer.hikari.HikariDataSource getOrCreateConnectionPool(ConnectionPoolId poolId,
                                                                    MySqlSourceConfig 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

clear

public void clear()
           throws IOException

Throws:

IOException