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

… debezium's origin class
apache · Dec 7, 2023 · 78fefd7 · 78fefd7
1 parent f15faac
commit 78fefd7
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.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 {