[postgres] Add commits of PostgresConnection back to distinguish with…

… debezium's origin class (apache#2839)
ChaomingZhangCN · Jan 3, 2025 · cdae972 · cdae972
1 parent 69a2811
commit cdae972
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/...res-cdc/src/main/java/io/debezium/connector/postgresql/connection/PostgresConnection.java b/...res-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.9.2-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 {