回复：flink 从mysql读取数据异常

[guoyb]

可以读取的，还有内置flink cdc
select得用query方法，看看是不是用错了execute。



---原始邮件---
发件人: "air23"<wangfei23_...@163.com&gt;
发送时间: 2021年3月30日(周二) 上午10:25
收件人: "user-zh"<user-zh@flink.apache.org&gt;;
主题: flink 从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&nbsp; a = "-- register a MySQL table 'users' in Flink SQL\n" +
"CREATE TABLE MyUserTable (\n" +
"&nbsp; id BIGINT\n" +
") WITH (\n" +
"&nbsp;&nbsp; 'connector' = 'jdbc',\n" +
"&nbsp;&nbsp; 'url' = 'jdbc:mysql://***:3306/monitor',\n" +
"&nbsp;&nbsp; 'table-name' = 't1',\n" +
"&nbsp;&nbsp; 'username' = 'root',\n" +
"&nbsp;&nbsp; 'password' = '***'\n" +
") ";

String b ="-- scan data from the JDBC table\n" +
"SELECT id FROM MyUserTable\n";

tEnv.executeSql(a);



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