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

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

     [ https://issues.apache.org/jira/browse/FLINK-19829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Jark Wu closed FLINK-19829.
---------------------------
    Resolution: Duplicate

> 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
>            Priority: Major
>
> 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)