Skip to content

Commit 568ed79

Browse files
[postgres] Add commits of PostgresConnection back to distinguish with debezium's origin class (#2839)
1 parent e6bb8e9 commit 568ed79

1 file changed

Lines changed: 8 additions & 0 deletions

File tree

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/PostgresConnection.java

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -54,6 +54,14 @@
5454
* {@link JdbcConnection} connection extension used for connecting to Postgres instances.
5555
*
5656
* @author Horia Chiorean
57+
* <p>Copied from Debezium 1.9.2-Final with two additional methods:
58+
* <ul>
59+
* <li>Constructor PostgresConnection( Configuration config, PostgresValueConverterBuilder
60+
* valueConverterBuilder, ConnectionFactory factory) to allow passing a custom
61+
* ConnectionFactory
62+
* <li>override connection() to return a unwrapped PgConnection (otherwise, it will complain
63+
* about HikariProxyConnection cannot be cast to class org.postgresql.core.BaseConnection)
64+
* </ul>
5765
*/
5866
public class PostgresConnection extends JdbcConnection {
5967

0 commit comments

Comments
 (0)