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

["zl (Jira)" <ji...@apache.org>]

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)