使用DDL 定义connector连接Mysql数据库，想通过发送sql的方式直接获取数据:
source_ddl = """
CREATE TABLE source_table(
yldrate DECIMAL,
pf_id VARCHAR,
symbol_id VARCHAR) WITH(
'connector' = 'jdbc',
'url' = 'jdbc:mysql://ip/db',
'dr
'table-name' = 'TS_PF_SEC_YLDRATE' 这一行后面少个逗号
> 在 2020年12月24日，下午2:02，肖越 <18242988...@163.com> 写道：
>
> 使用DDL 定义connector连接Mysql数据库，想通过发送sql的方式直接获取数据:
> source_ddl = """
> CREATE TABLE source_table(
>yldrate DECIMAL,
>pf_id VARCHAR,
>symbol_id VARCHAR)
hi! 试试这个
CREATE TABLE source_table(
yldrate DECIMAL,
pf_id VARCHAR,
symbol_id VARCHAR) WITH(
'connector' = 'jdbc',
'url' = 'jdbc:mysql://ip/db',
'driver' = 'com.mysql.cj.jdbc.Driver',
'u
Hi, 嘉伟
1.12 应该不支持 read.query， 社区还在讨论是否要开放这个，有些concern, 简单的讲，就如你这个query写的，创建的这张JDBC
表应该是一个 View 而不是对应一张JDBC 表，同时这个表只能用来作为source，不能用来作为sink。
祝好，
Leonard
> 在 2020年12月24日，19:16，冯嘉伟 <1425385...@qq.com> 写道：
>
> hi! 试试这个
>
> CREATE TABLE source_table(
>yldrate DECIMAL,
>
谢谢，老师们的指导，根据嘉伟的建议，发现pyflink1.12确实并不支持这个参数~
还是希望官方能够开放这个参数，就目前的工作情景来说，取数据就需要定义整张表，如果数据库更改，代码这边很不便于维护；
从本机的实验结果上看，pyflink内部进行query的效率并不高，正准备放到集群上试试~
在 2020-12-25 09:45:28，"Leonard Xu" 写道：
>Hi, 嘉伟
>
>1.12 应该不支持 read.query， 社区还在讨论是否要开放这个，有些concern, 简单的讲，就如你这个query写的，创建的这张JDBC
>表应该是一个 View
