From 78fefd7a30ddfa63912db0ca60737f5a90369187 Mon Sep 17 00:00:00 2001
From: Hongshun Wang <loserwang1024@gmail.com>
Date: Thu, 7 Dec 2023 16:57:09 +0800
Subject: [PATCH] [postgres] Add commits of PostgresConnection back to
 distinguish with debezium's origin class

---
 .../postgresql/connection/PostgresConnection.java         | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/PostgresConnection.java b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/PostgresConnection.java
index e728f3b474b..980b2b1ca12 100644
--- a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/PostgresConnection.java
+++ b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/PostgresConnection.java
@@ -54,6 +54,14 @@
  * {@link JdbcConnection} connection extension used for connecting to Postgres instances.
  *
  * @author Horia Chiorean
+ *     <p>Copied from Debezium 1.6.4-Final with two additional methods:
+ *     <ul>
+ *       <li>Constructor PostgresConnection( Configuration config, PostgresValueConverterBuilder
+ *           valueConverterBuilder, ConnectionFactory factory) to allow passing a custom
+ *           ConnectionFactory
+ *       <li>override connection() to return a unwrapped PgConnection (otherwise, it will complain
+ *           about HikariProxyConnection cannot be cast to class org.postgresql.core.BaseConnection)
+ *     </ul>
  */
 public class PostgresConnection extends JdbcConnection {