Apache Flink是一個開源的流處理框架，擁有強大的批處理和流式處理能力。在實際應用場景中，我們經常需要將處理后的數據批量寫入MySQL數據庫中。本文將介紹如何使用Flink批量寫MySQL每次5000條數據。

首先，我們需要引入Flink-MySQL連接器的依賴。在Maven項目中，添加以下依賴：

<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-connector-jdbc_2.11</artifactId>
<version>1.14.0</version>
</dependency>

接著，我們需要創建一個JDBCOutputFormat對象，并設置連接信息：

JDBCOutputFormat jdbcOutputFormat = JDBCOutputFormat.buildJDBCOutputFormat()
.setDrivername("com.mysql.jdbc.Driver")
.setDBUrl("jdbc:mysql://localhost:3306/test")
.setUsername("root")
.setPassword("123456")
.setQuery("INSERT INTO user(name, age) VALUES (?, ?)")
.setBatchInterval(5000)
.finish();

在上面的代碼中，我們使用了鏈式編程來設置MySQL連接信息。其中，setQuery()方法設置要執行的SQL語句，setBatchInterval()方法設置每次批量寫入數據的數量。

接著，我們可以使用Flink的Map算子進行數據轉換，并將結果寫入MySQL數據庫：

DataStream<Row> result = dataStream
.map(new MapFunction<InputData, Row>() {
@Override
public Row map(InputData inputData) throws Exception {
Row row = new Row(2);
row.setField(0, inputData.getName());
row.setField(1, inputData.getAge());
return row;
}
});
result.writeUsingOutputFormat(jdbcOutputFormat);

在上面的代碼中，我們使用了Flink的Map算子將輸入數據轉換為Row對象，并將結果寫入MySQL數據庫中。

最后，我們需要調用Flink的execute()方法來啟動任務：

env.execute("Flink MySQL Batch Writer");

以上就是使用Flink批量寫MySQL每次5000條數據的簡單示例。通過設置BatchInterval參數，我們可以靈活地控制每次寫入數據的數量，從而更好地管理MySQL數據庫。