flink实时写入mysql

在Flink中实时将数据写入MySQL，一般可以使用Flink提供的JDBC连接器。下面是一个简单的示例代码：

DataStream<Tuple2<String, Integer>> dataStream = ... // 从某个地方获取数据流

// 定义JDBC连接参数
final String jdbcUrl = "jdbc:mysql://localhost:3306/test";
final String username = "root";
final String password = "root";

// 定义JDBC连接器
JDBCAppendTableSink sink = JDBCAppendTableSink.builder()
    .setDrivername("com.mysql.jdbc.Driver")
    .setDBUrl(jdbcUrl)
    .setUsername(username)
    .setPassword(password)
    .setQuery("INSERT INTO mytable (word, count) VALUES (?, ?)")
    .setParameterTypes(Types.STRING, Types.INT)
    .build();

// 将数据写入MySQL
dataStream.addSink(sink);

在上面的示例中，我们首先从某个地方获取了一个数据流 `dataStream`，然后定义了JDBC连接参数 `jdbcUrl`、`username`和`password`。接着，我们使用Flink提供的 `JDBCAppendTableSink` 创建了一个JDBC连接器，并设置了插入数据的SQL语句和参数类型。最后，我们将数据流 `dataStream` 写入到MySQL中，使用了 `addSink(sink)` 方法。

需要注意的是，在上面的示例中，我们使用的是 `JDBCAppendTableSink`，即将数据追加到目标表中，如果需要更新数据，可以使用 `JDBCUpsertTableSink`。同时，如果需要对数据进行转换，可以使用Flink提供的 `MapFunction`、`FlatMapFunction` 等函数进行转换。