[Bug] About PostgresSql snapshot sql

[linzhicong1996]

Search before asking

• [X] I searched in the issues and found nothing similar.

Flink version

1.14.6

Flink CDC version

2.4.1

Database and its version

PostgreSQL 13.2

Minimal reproduce step

  In the version of flink-connector-postgres-cdc  2.4.1, snapshot SQL is generated during a full snapshot and is split according to the command of key,When running POSTGRESQL SQL, the column will be case-sensitive. But in fact, when the SQL is generated, double quotation marks are not added to this column. Therefore POSTGRESQL converts this column to lowercase, and lead to POSTGRESQL cannot identify this column, resulting in an error.

package com.ververica.cdc.connectors.postgres.source.utils;

What did you expect to see?

“key”

What did you see instead?

key

Anything else?

No response

Are you willing to submit a PR?

• [X] I'm willing to submit a PR!

[linzhicong1996]

I modified the relevant code and the program is already working, but because I am not familiar with the whole program, I don't know if it will raise the related GUG

[ruanhang1993]

@linzhicong1996 Assign this to you. Please ping me after you raise the PR. Thanks.

[linzhicong1996]

@ruanhang1993 Code has been submitted.

[postgres] PostgresSql snapshot sql #2389

[loserwang1024]

I don't understand why PostgresDialect#isDataCollectionIdCaseSensitive always returns true, meaning that is database always use case-sensitive strategy, but this PR will change it to no case-insensitive?

What kind of strategy is actually needed? @ruanhang1993 ， CC, WDYT?

[loserwang1024]

@linzhicong1996 , this issue has been migrated to https://issues.apache.org/jira/browse/FLINK-34805, Please modify your PR tittle with [FLINK-34805][xxx] xxxx as https://nightlies.apache.org/flink/flink-cdc-docs-master/docs/developer-guide/contribute-to-flink-cdc/#contributing shows

[PatrickRen]

Closing this issue as it has been migrated to Apache Jira.