java 使用jdbc連接Greenplum數據庫和Postgresql數據庫

1、公司使用的Greenplum和Postgresql，確實讓我學到不少東西。簡單將使用jdbc連接Greenplum和Postgresql數據庫。由於使用maven倉庫，不能下載Greenplum的jar包，但是可以下載Postgresql的jar包，所以Greenplum的jar包，自己可以百度自行下載。名字就叫做greenplum.jar。

maven依賴如下所示：

<!-- https://mvnrepository.com/artifact/org.postgresql/postgresql -->
<dependency>
    <groupId>org.postgresql</groupId>
    <artifactId>postgresql</artifactId>
    <version>42.1.4</version>
</dependency>
<!-- https://mvnrepository.com/artifact/commons-beanutils/commons-beanutils -->
<dependency>
    <groupId>commons-beanutils</groupId>
    <artifactId>commons-beanutils</artifactId>
    <version>1.9.3</version>
</dependency>
<!-- https://mvnrepository.com/artifact/org.apache.commons/commons-lang3 -->
<dependency>
    <groupId>org.apache.commons</groupId>
    <artifactId>commons-lang3</artifactId>
    <version>3.4</version>
</dependency>
<!-- https://mvnrepository.com/artifact/commons-logging/commons-logging -->
<dependency>
    <groupId>commons-logging</groupId>
    <artifactId>commons-logging</artifactId>
    <version>1.1.1</version>
</dependency>
<!-- https://mvnrepository.com/artifact/commons-collections/commons-collections -->
<dependency>
    <groupId>commons-collections</groupId>
    <artifactId>commons-collections</artifactId>
    <version>3.2.1</version>
</dependency>

 2、db.properties配置文件里面如下所示：

# 1.posgresql
posgresql_driver=org.postgresql.Driver
posgresql_url=jdbc:postgresql://192.168.xx.xx:5432/數據庫名稱(即schema)
posgresql_user=賬號
posgresql_password=密碼

# 2.greenplum
greenplum_driver=com.pivotal.jdbc.GreenplumDriver
greenplum_url=jdbc:pivotal:greenplum://192.168.xx.xx:5432;DatabaseName=數據庫名稱(即schema)
greenplum_user=賬號
greenplum_password=密碼

 3、然后連接Greenplum數據庫和Postgresql數據庫如下所示：

public class JdbcUtils {

    // 1、Postgresql
    private static String postgresql_driver;
    private static String postgresql_url;
    private static String postgresql_user;
    private static String postgresql_password;
        
    // 2、Greenplum
    private static String greenplum_driver;
    private static String greenplum_url;
    private static String greenplum_user;
    private static String greenplum_password;

    // 1、Postgresql
    static {
        postgresql_driver = ResourceBundle.getBundle("db").getString("postgresql_driver");
        postgresql_url = ResourceBundle.getBundle("db").getString("postgresql_url");
        postgresql_user = ResourceBundle.getBundle("db").getString("postgresql_user");
        postgresql_password = ResourceBundle.getBundle("db").getString("postgresql_password");
    }

    // 2、Greenplum
    static {
        greenplum_driver = ResourceBundle.getBundle("db").getString("greenplum_driver");
        greenplum_url = ResourceBundle.getBundle("db").getString("greenplum_url");
        greenplum_user = ResourceBundle.getBundle("db").getString("greenplum_user");
        greenplum_password = ResourceBundle.getBundle("db").getString("greenplum_password");
    }    


    // 1、Postgresql
    public static Connection getPostgresqlConnection() throws ClassNotFoundException, SQLException {
        // 加載數據庫驅動
        Class.forName(postgresql_driver);
        // System.out.println("測試加載數據庫成功");
        Connection con = DriverManager.getConnection(postgresql_url, postgresql_user, postgresql_password);
        // System.out.println("測試數據庫鏈接成功");
        return con;
    }

    // 2、Greenplum
    public static Connection getGreenplumConnection() throws ClassNotFoundException, SQLException {
        // 加載數據庫驅動
        Class.forName(greenplum_driver);
        //System.out.println("測試加載數據庫成功");
        Connection con = DriverManager.getConnection(greenplum_url, greenplum_user, greenplum_password);
        //System.out.println("測試數據庫鏈接成功");
        return con;
    }

    public static void main(String[] args) {
            try {
                JdbcUtils.getPostgresqlConnection();
                System.out.println("匯聚數據區連接成功.....");
                System.out.println("=======================================");
                
                JdbcUtils.getGreenplumConnection();
                System.out.println("核心數據區連接成功.....");
                System.out.println("=======================================");
                
            } catch (ClassNotFoundException e) {
                e.printStackTrace();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
}        

4、最后，可以根據公司業務進行一些增刪改查操作。略。

待續......