目錄

Connectors

JDBC

代碼演示

---

Connectors

JDBC

Apache Flink 1.12 Documentation: JDBC Connector

代碼演示

package cn.it.connectors;import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.apache.flink.connector.jdbc.JdbcConnectionOptions;
import org.apache.flink.connector.jdbc.JdbcSink;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;/*** Author lanson* Desc*/
public class ConnectorsDemo_JDBC {public static void main(String[] args) throws Exception {//1.envStreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();//2.Sourceenv.fromElements(new Student(null, "tonyma", 18))//3.Transformation//4.Sink.addSink(JdbcSink.sink("INSERT INTO `t_student` (`id`, `name`, `age`) VALUES (null, ?, ?)",(ps, s) -> {ps.setString(1, s.getName());ps.setInt(2, s.getAge());},new JdbcConnectionOptions.JdbcConnectionOptionsBuilder().withUrl("jdbc:mysql://localhost:3306/bigdata").withUsername("root").withPassword("root").withDriverName("com.mysql.jdbc.Driver").build()));//5.executeenv.execute();}@Data@NoArgsConstructor@AllArgsConstructorpublic static class Student {private Integer id;private String name;private Integer age;}
}

總結

以上是生活随笔為你收集整理的2021年大数据Flink（十四）：流批一体API Connectors JDBC的全部內容，希望文章能夠幫你解決所遇到的問題。

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