flink写入 mysql_flink sql实时计算当天pv写入mysql

要将实时计算的当天 PV 写入 MySQL，可以使用 Flink 的 JDBC Connector 连接器，将结果输出到 MySQL 数据库中。

以下是一个示例代码：

DataStream<Tuple2<String, Integer>> pvStream = ...; // 获取实时计算的当天 PV 数据流

// 将结果写入 MySQL
pvStream.addSink(JdbcSink.sink(
    "INSERT INTO pv_count(date, pv) VALUES (?, ?)",
    (ps, t) -> {
        ps.setDate(1, new java.sql.Date(System.currentTimeMillis()));
        ps.setInt(2, t.f1);
    },
    new JdbcConnectionOptions.JdbcConnectionOptionsBuilder()
        .withUrl("jdbc:mysql://localhost:3306/db")
        .withDriverName("com.mysql.jdbc.Driver")
        .withUsername("user")
        .withPassword("password")
        .build()
));

其中，`pvStream` 是一个包含了当天 PV 数量的数据流。`JdbcSink.sink` 方法将数据写入 MySQL 数据库中，第一个参数是 SQL 语句，第二个参数是将数据写入 PreparedStatement 中的逻辑，第三个参数是连接 MySQL 的配置信息。

在这个示例中，我们使用了一个 `pv_count` 表，用于存储每天的 PV 数量。表中包含两个字段：`date` 用于存储日期，`pv` 用于存储当天的 PV 数量。在 `JdbcSink.sink` 的第一个参数中，我们使用了一个占位符 `?` 来表示这两个字段。在第二个参数中，我们将当前时间作为日期写入了 PreparedStatement 中的第一个参数，将当天 PV 数量写入了第二个参数。在第三个参数中，我们指定了连接 MySQL 数据库的配置信息。

这样，当 Flink 实时计算出当天的 PV 数量后，就会自动将结果写入 MySQL 数据库中。