使用blink planner读取mysql数据
hi，All请问，在blink planner的batch mode下，读取mysql数据，依照官网的JDBC Connector的操作：
CREATE TABLE MyUserTable ( ... ) WITH ( 'connector.type' = 'jdbc', -- required: specify this table type is jdbc 'connector.url' = 'jdbc:mysql://localhost:3306/flink-test', -- required: JDBC DB url 'connector.table' = 'jdbc_table_name', -- required: jdbc table name 'connector.driver' = 'com.mysql.jdbc.Driver', -- optional: the class name of the JDBC driver to use to connect to this URL. -- If not set, it will automatically be derived from the URL. 'connector.username' = 'name', -- optional: jdbc user name and password 'connector.password' = 'password',
'connector.write.flush.max-rows' = '5000'
我理解的是创建一个名字叫“ MyUserTable”的临时表，这个表是属于flink env的。但是从MySQL读取的sql（比如说“select * from student where score > 60"）在哪儿能体现呢？看上面的用法好像是把全部的数据都取出来或者取多少条？这是让我困惑的地方，另外blink planner 的batch mode读取JDBC有别的方法吗？Thanks!*来自志愿者整理的flink邮件归档
写回答
-
DDL 是定义了元数据，首先你需要先在 Flink SQL 中用 DDL 定义你在 mysql 中的 student 表。比如
CREATE TABLE student (
id BIGINT,
score INT
) WITH (
'connector.type' = 'jdbc',
'connector.url' = 'jdbc:mysql://localhost:3306/flink-test',
'connector.table' = 'student',
...
)
然后，如果你想要查询数据，可以通过 Flink SQL query 来查询，如：
SELECT * from student WHERE score > 60
注：以上命令都可以在 Flink SQL CLI 中运行 [1]。[1]:
https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/sqlClient.html*来自志愿者整理的FLINK邮件归档
2021-12-02 17:32:55赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
