开云官网平台介绍

3年前 (2023-06-19)
  • 1. 背景
  • 2. 查看Mysql表数据
  • 3. Flink DataStream查询数据程序
1. 背景

官网Jdbc DataStream Connector只有Sink，没有Source。 同题参见因此需要用其它方式从Mysql查询数据

2. 查看Mysql表数据
mysql> select * from person;
+------+------+
| id | name |
+------+------+
| 1 | yi |
| 2 | er |
+------+------+
2 rows in set (0.00 sec)
mysql>
3. Flink DataStream查询数据程序
import org.apache.flink.api.common.typeinfo.BasicTypeInfo
import org.apache.flink.api.java.typeutils.RowTypeInfo
import org.apache.flink.connector.jdbc.JdbcInputFormat
import org.apache.flink.streaming.api.scala.{DataStream, StreamExecutionEnvironment, createTypeInformation}
import org.apache.flink.types.Row
object FlinkTest {
def main(args: Array[String]): Unit = {
val senv:StreamExecutionEnvironment = StreamExecutionEnvironment.getExecutionEnvironment
senv.setParallelism(1)
val mysqlPersonDataInput:DataStream[Row] = senv.createInput(JdbcInputFormat.buildJdbcInputFormat()
.setDrivername("com.mysql.cj.jdbc.Driver")
.setDBUrl("jdbc:mysql://192.168.8.115:3306/test?serverTimezone=GMT%2B8&useSSL=false")
.setUsername("root")
.setPassword("Root_123")
.setQuery("select id, name from person")
.setRowTypeInfo(new RowTypeInfo(
BasicTypeInfo.LONG_TYPE_INFO,
BasicTypeInfo.STRING_TYPE_INFO))
.finish())
mysqlPersonDataInput.executeAndCollect().foreach(println)
}
}

运行程序，结果如下:

+I[1, yi]
+I[2, er]

你可能想看：

天龙八部搭建mysql教程_天龙八部私服架设mysql数据库安装 对照阅读

前面进行旳都正常 . 到了初始化数据库那一步好像就出了问题.support-files/mysql.server to the right place for your system. PLEASE ... 相关阅读

分享给朋友：

继续阅读

若需了解「开云官网平台介绍」的上下文，可结合站内栏目与相关篇目交叉阅读。

栏目用于追新，文内链接用于对照细节。两者配合可减少漏读与重复检索。

继续浏览时优先选择同栏目或相近主题，避免被站外镜像带偏。

站点导览

数据 · wiki · 科技 · 家长开云官网平台介绍

页面按栏目组织。可先看导读，再进入相关篇目或返回列表。