在指定了DataSet的Input后，只需要指定一個OutputFormat即可，OutputFormat的作用就是將數據集寫入指定的存儲中。

//創建數據匯

public static OutputFormat insertMysql(){

OutputFormat insertMysql = JDBCOutputFormat.buildJDBCOutputFormat()

.setDrivername("com.mysql.jdbc.Driver")

.setDBUrl("jdbc:mysql://10.250.115.210:3306/jerry")

.setUsername("root")

.setPassword("123456")

.setQuery("insert into test(id, age) values(?,?)")

.finish();

return insertMysql;

}

public static void main(String[] args) throws Exception {

ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();

DataSet inputMysql = jdbcRead(env);

//輸出到mysql

inputMysql.output(insertMysql());

env.execute();

}

總結

以上是生活随笔為你收集整理的flink写入 mysql_flink写数据到mysql(java)的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。