[jira] [Created] (FLINK-19829) should enclose column name in double quotes for PostgreSQL

[Shang Yuanchun (Jira)]

zl created FLINK-19829:
--------------------------

             Summary: should enclose column name in double quotes for PostgreSQL
                 Key: FLINK-19829
                 URL: https://issues.apache.org/jira/browse/FLINK-19829
             Project: Flink
          Issue Type: Bug
          Components: Connectors / JDBC
            Reporter: zl


when I run the sql in flink:
{code:sql}
create table pg_sink (
    Name VARCHAR,
    address VARCHAR,
    work VARCHAR)
with (   
    'connector' = 'jdbc',   
    'url' = 'jdbc:postgresql://***:***/***',   
    'table-name' = 'pg_sink',
    ...
)

create table kafka_source(   
    Name VARCHAR,   
    address VARCHAR,   
    work VARCHAR
) with (   
    'connector.type' = 'kafka',   
    'format.type' = 'json',
    ...
)

insert into pg_sink select * from kafka_source{code}
the following exception happens:
{code:java}
Caused by: org.postgresql.util.PSQLException: ERROR: column "Name" of relation "pg_sink" does not exist
...{code}
we can solve this problem by remove method *_quoteIdentifier_* in *_PostgresDialect.java_*, then the method *_quoteIdentifier_*  in _*JdbcDialect.java*_ will be used to enclose the column name in double quotes for PostgreSQL. 

could assign this issue to me ?



--
This message was sent by Atlassian Jira
(v8.3.4#803005)