PostgresConnectionPoolFactory (flink-cdc-parent 3.8-SNAPSHOT API)

java.lang.Object
- org.apache.flink.cdc.connectors.base.relational.connection.JdbcConnectionPoolFactory
- - org.apache.flink.cdc.connectors.postgres.source.PostgresConnectionPoolFactory

public class PostgresConnectionPoolFactory
extends JdbcConnectionPoolFactory

A connection pool factory to create pooled Postgres HikariDataSource.

Field Summary

Fields
Modifier and Type Field Description

static String JDBC_URL_PATTERN
- Fields inherited from class org.apache.flink.cdc.connectors.base.relational.connection.JdbcConnectionPoolFactory
  CONNECTION_POOL_PREFIX, MINIMUM_POOL_SIZE, SERVER_TIMEZONE_KEY

Constructor Summary

Constructors
Constructor Description

PostgresConnectionPoolFactory(String applicationName)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`String`	`getJdbcUrl(JdbcSourceConfig sourceConfig)`	due to relational database url of the forms are different, e.g.
`ConnectionPoolId`	`getPoolId(io.debezium.jdbc.JdbcConfiguration config, String dataSourcePoolFactoryIdentifier)`	The reuses of connection pools are based on databases in postgresql.

Methods inherited from class org.apache.flink.cdc.connectors.base.relational.connection.JdbcConnectionPoolFactory
createPooledDataSource

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - JDBC_URL_PATTERN
```
public static final String JDBC_URL_PATTERN
```
    See Also:
    
    Constant Field Values
- Constructor Detail
  - PostgresConnectionPoolFactory
```
public PostgresConnectionPoolFactory(String applicationName)
```
- Method Detail
  - getJdbcUrl
```
public String getJdbcUrl(JdbcSourceConfig sourceConfig)
```
    Description copied from class: JdbcConnectionPoolFactory
    
    due to relational database url of the forms are different, e.g. Mysql jdbc:mysql://hostname:port, Oracle Thin jdbc:oracle:thin:@hostname:port:dbName DB2 jdbc:db2://hostname:port/dbName Sybase jdbc:sybase:Tds:hostname:port, so generate a jdbc url by specific database.
    
    Specified by:
    
    getJdbcUrl in class JdbcConnectionPoolFactory
    
    Parameters:
    
    sourceConfig - a basic Source configuration.
    
    Returns:
    
    a database url.
  - getPoolId
```
public ConnectionPoolId getPoolId(io.debezium.jdbc.JdbcConfiguration config,
                                  String dataSourcePoolFactoryIdentifier)
```
    The reuses of connection pools are based on databases in postgresql. Different databases in same instance cannot reuse same connection pool to connect.
    
    Overrides:
    
    getPoolId in class JdbcConnectionPoolFactory