目录

​​​​​​​Connectors

JDBC

代码演示

Connectors

JDBC

https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/connectors/jdbc.html

代码演示

  

   

    

     

    
    

     

      package cn.itcast.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 itcast
     
    
   

    

     

    
    

     

       * Desc
     
    
   

    

     

    
    

     

       */
     
    
   

    

     

    
    

     

      public class ConnectorsDemo_JDBC {
     
    
   

    

     

    
    

     

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

    

     

    
    

     

              //1.env
     
    
   

    

     

    
    

     

              StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
     
    
   

    

     

    
    

     

              //2.Source
     
    
   

    

     

    
    

     

              env.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.execute
     
    
   

    

     

    
    

     

              env.execute();
     
    
   

    

     

    
    

     

          }
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

          @Data
     
    
   

    

     

    
    

     

          @NoArgsConstructor
     
    
   

    

     

    
    

     

          @AllArgsConstructor
     
    
   

    

     

    
    

     

          public static class Student {
     
    
   

    

     

    
    

     

              private Integer id;
     
    
   

    

     

    
    

     

              private String name;
     
    
   

    

     

    
    

     

              private Integer age;
     
    
   

    

     

    
    

     

          }
     
    
   

    

     

    
    

     

      }
     
    
  
 

文章来源: lansonli.blog.csdn.net，作者：Lansonli，版权归原作者所有，如需转载，请联系作者。

原文链接：lansonli.blog.csdn.net/article/details/116245172