开发者社区> 问答> 正文

请问是不可以从mysql读取数据吗?

你好 参考官网 https://ci.apache.org/projects/flink/flink-docs-release-1.12/zh/dev/table/connectors/jdbc.html

这边读取mysql jdbc数据报错Exception in thread "main" org.apache.flink.table.api.TableException: Only insert statement is supported now.

String  a = "-- register a MySQL table 'users' in Flink SQL\n" +

"CREATE TABLE MyUserTable (\n" +

"  id BIGINT\n" +

") WITH (\n" +

"   'connector' = 'jdbc',\n" +

"   'url' = 'jdbc:mysql://***:3306/monitor',\n" +

"   'table-name' = 't1',\n" +

"   'username' = 'root',\n" +

"   'password' = '***'\n" +

") ";

String b ="-- scan data from the JDBC table\n" +

"SELECT id FROM MyUserTable\n";

tEnv.executeSql(a);

展开
收起
EXCEED 2021-11-25 16:39:56 502 0
0 条回答
写回答
取消 提交回答
问答排行榜
最热
最新

相关电子书

更多
搭建电商项目架构连接MySQL 立即下载
搭建4层电商项目架构,实战连接MySQL 立即下载
PolarDB MySQL引擎重磅功能及产品能力盛大发布 立即下载

相关镜像