flink程序，storm代码的迁移

package com.grgbanking.dao; import java.sql.*; import java.util.Map; /** * Created by lwb on 2018/12/30. */ public class DbCon { private static Connection conn = null; public Connection DBConnection() { String driver = "org.postgresql.Driver"; String url= "jdbc:postgresql://10.2.5.1:5432/chunbai"; String user = "gpadmin"; String password = "tianhe@Pssw0rd"; try { Class.forName(driver);// 加载驱动程序 if(this.conn == null || this.conn.isClosed() || !testConnection(this.conn)) { this.conn = (Connection) DriverManager.getConnection(url, user, password);// 连续数据库 if (this.conn != null && !this.conn.isClosed()&&testConnection(this.conn)) System.out.println("Succeeded connecting to the Database!"); } return this.conn; } catch (Exception e) { e.printStackTrace(); return null; } } public boolean testConnection(Connection conn1){ String sql = "SELECT 1"; PreparedStatement st = null; try { st = conn1.prepareStatement(sql); ResultSet rs = st.executeQuery(); return true; } catch (SQLException e) { return false; } } public void close() { try { this.conn.close(); } catch (Exception e) { e.printStackTrace(); } } }