[
https://issues.apache.org/jira/browse/FLINK-39726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-39726:
------------------------------------
Description:
Create table syntax using connection will be like below
{code:sql}
CREATE TABLE orders (
order_id INT,
customer_id INT,
amount DECIMAL(10, 2)
) USING CONNECTION mycat.mydb.mysql_prod
WITH (
'connector'= 'jdbc',
'tables'='orders'
...
);
{code}
Change parser to support this
was:
Create table syntax using connection will be like below
```
{{CREATE TABLE orders (}}
{{ }}{{order_id INT,}}
{{ }}{{customer_id INT,}}
{{ }}{{{}amount DECIMAL({}}}{{{}10{}}}{{{},{}}}{{{}2{}}}{{{}){}}}
{{) USING CONNECTION mycat.mydb.mysql_prod}}
{{WITH (}}
{{ }}{{'connector'}} {{= }}{{{}'jdbc'{}}}{{{},{}}}
{{ }}{{'tables'}} {{= }}{{'orders'}}
{{ }}{{...}}
{{);}}
{{```}}
{{Change parser to support this}}
> Update create table syntax with using connection
> ------------------------------------------------
>
> Key: FLINK-39726
> URL: https://issues.apache.org/jira/browse/FLINK-39726
> Project: Flink
> Issue Type: Sub-task
> Reporter: Hao Li
> Assignee: Hao Li
> Priority: Major
> Labels: pull-request-available
> Fix For: 2.4.0
>
>
> Create table syntax using connection will be like below
> {code:sql}
> CREATE TABLE orders (
> order_id INT,
> customer_id INT,
> amount DECIMAL(10, 2)
> ) USING CONNECTION mycat.mydb.mysql_prod
> WITH (
> 'connector'= 'jdbc',
> 'tables'='orders'
> ...
> );
> {code}
> Change parser to support this
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
