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();
}
}
}
flinkcar.zip （20个子文件） 
flinkcar 
flinkcar.iml 81B pom.xml 20KB src test java main resources log4j.properties 1KB java com grgbanking dao DbCon.java 2KB scala com grgbanking test WindowWordCount.scala 626B LocalWordCount.scala 689B car sink GreenplumInsertSink.scala 394B source WordProduceSource.scala 659B NumProducerSource.scala 537B CarLanuching.scala 2KB constants Constants.scala 2KB log LogEventDeserializationSchema.scala 838B bean LogEvent.scala 319B .idea hydra.xml 389B sbt.xml 397B workspace.xml 35KB misc.xml 526B scala_compiler.xml 189B compiler.xml 541B encodings.xml 177B资源评论
