通过Java连接到Amazon EC2上的PostgreSQL

Question

我想在java中连接到Amazon EC2上的PostgreSQL数据库。我可以使用Mac上名为Postico的postgres客户端连接到它。我指定下一个信息：

>

主机（ec2 xx xx xx xx.xx-xx-x.compute.amazonaws.com）

用户

密码

数据库名称

SSH主机

用户

密码-空白

私钥-. pem文件

我找不到任何关于如何在Java中连接它的例子。我找到了一些RedshiftJDBC驱动程序，并将其添加到项目中。然后我尝试了这个：

try {
            Class.forName("org.postgresql.Driver");
        } catch (ClassNotFoundException e) {
            System.out.println("Where is your MySQL JDBC Driver?");
            e.printStackTrace();
            return;
        }
        System.out.println("MySQL JDBC Driver Registered!");
        try {
            this.connection = DriverManager.getConnection("jdbc:postgresql://" +DNS+"/"+myDBname, MYSQLUSER, MYSQLPW);
        } catch (SQLException e) {
            System.out.println("Connection Failed! Check output console");
            e.printStackTrace();
        }

        if (connection != null) {
            System.out.println("You made it, take control your database now!");
        } else {
            System.out.println("Failed to make connection!");
        }

我知道这行不通，但至少我试过了。）我不知道如何在请求中指定私钥（如何发送它），或者其他什么。有人能帮我吗？非常感谢。

Answer 1

从Java连接时，您没有指定SSH信息（SSH主机、私钥等）。JDBC驱动程序希望能够直接连接到数据库服务器，并且不支持SSH隧道。如果需要使用SSH隧道，则必须在启动Java应用程序之前单独创建该连接。

如果Java应用程序在AWS上运行，那么您应该能够配置网络以允许直接连接。如果您在本地测试Java应用程序，并且需要连接到远程数据库，那么您可以在本地运行ssh命令以首先打开隧道。请参阅本文档：http://www.postgresql.org/docs/8.2/static/ssh-tunnels.html或者这个答案：PostgreSQL通过SSH隧道

Answer 2

使用PostgreSQL JDBC驱动程序尝试以下代码。您希望使代码更具弹性（例如，在连接和发送查询之间检查db是否为null，等等），但这应该可以让您继续。

private final String DB_HOST = "YOUR_EC2_HOSTNAME";
private final String DB_PORT = "5432";
private final String DB_USER = "YOUR_POSTGRES_USERNAME";
private final String DB_PASSWD = "YOUR_POSTGRES_PASSWORD";
private final String DB_NAME = "YOUR_POSTGRES_DBNAME";
private final String DB_URL = "jdbc:postgresql://" + DB_HOST + ":" + DB_PORT + "/" + DB_NAME;

private final String INSERT = "INSERT INTO articles (date, name, uuid) VALUES (?, ?, ?)";
private Connection db = null;

public PostgreSQLService() {
    try {
        Class.forName("org.postgresql.Driver");
        db = DriverManager.getConnection(DB_URL, DB_USER, DB_PASSWD);
    } catch (ClassNotFoundException | SQLException ex) {
        log.error(ex);
    }

    try (PreparedStatement st = db.prepareStatement(INSERT)) {
        st.setEscapeProcessing(false);

        st.setDate(1, new java.sql.Date(DateUtil.getToday().getTime()));
        st.setString(2, "YOUR_NAME");
        st.setObject(3, UUID.randomUUID());

        if (st.executeUpdate() <= 0) {
            throw new PostgreSQLServiceException("0 rows inserted while trying to insert a new row ::: " + st.toString());
        }

    } catch (SQLException sqle) {
        throw new PostgreSQLServiceException("Received an SQLException trying to insert a row", sqle);
    }
}

Maven依赖关系是：

<dependency>
    <groupId>org.postgresql</groupId>
    <artifactId>postgresql</artifactId>
    <version>9.4.1208</version>
</dependency>

请注意，如果您从AWS外部执行此代码，则需要在该EC2实例的安全组中打开端口5432。

我还建议看看亚马逊RDS。您可以使用上面的代码连接到它，就像运行在EC2上的Postgres实例一样。

我希望这有帮助！