java怎么连接PostgreSQL数据库实现Java程序与PostgreSQL数据库连接_技术教程

首先引入PostgreSQL JDBC驱动，再通过DriverManager获取连接，使用try-with-resources管理资源并建议用配置文件存储参数，最后通过Statement执行SQL操作。

要让Java程序连接PostgreSQL数据库，主要通过JDBC（Java Database Connectivity）实现。你需要完成以下几个步骤：引入驱动、编写连接代码、处理异常并确保资源释放。

1. 添加PostgreSQL JDBC驱动

PostgreSQL官方提供了JDBC驱动，Java程序需要这个驱动才能与数据库通信。

推荐使用Maven管理依赖，在pom.xml中添加：


    org.postgresql
    postgresql
    42.7.3

如果不用Maven，需手动下载postgresql-x.x.x.jar并加入项目classpath。

2. 编写数据库连接代码

使用java.sql包中的类建立连接。基本流程包括加载驱动、提供连接URL、用户名和密码。

示例代码：

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;

public class PostgreSQLConnection {
    public static void main(String[] args) {
        String url = "jdbc:postgresql://localhost:5432/your_database";
        String user = "your_username";
        String password = "your_password";

        try (Connection conn = DriverManager.getConnection(url, user, password)) {
            if (conn != null) {
                System.out.println("成功连接到PostgreSQL数据库！");
            }
        } catch (SQLException e) {
            System.err.println("连接失败：" + e.getMessage());
            e.printStackTrace();
        }
    }
}

说明：

jdbc:postgresql://host:port/database 是标准的JDBC连接字符串。
确保PostgreSQL服务正在运行，且允许对应IP连接（检查pg_hba.conf和postgresql.conf）。
默认端口是5432。

3. 处理连接配置和常见问题

实际开发中建议将连接参数提取到配置文件中，避免硬编码。

例如使用db.properties：

db.url=jdbc:postgresql://localhost:5432/mydb
db.user=postgres
db.password=123456

读取配置并连接：

import java.io.FileInputStream;
import java.sql.Connection;
import java.util.Properties;

public class DBUtil {
    private static Properties props = new Properties();

    static {
        try (FileInputStream fis = new FileInputStream("db.properties")) {
            props.load(fis);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    public static Connection getConnection() throws SQLException {
        String url = props.getProperty("db.url");
        String user = props.getProperty("db.user");
        String password = props.getProperty("db.password");
        return DriverManager.getConnection(url, user, password);
    }
}

4. 使用连接执行SQL操作

获取Connection后，可创建Statement或PreparedStatement来执行查询或更新。

简单查询示例：

import java.sql.*;

public class QueryExample {
    public static void main(String[] args) {
        String sql = "SELECT id, name FROM users";

        try (Connection conn = DBUtil.getConnection();
             Statement stmt = conn.createStatement();
             ResultSet rs = stmt.executeQuery(sql)) {

            while (rs.next()) {
                int id = rs.getInt("id");
                String name = rs.getString("name");
                System.out.println("ID: " + id + ", Name: " + name);
            }
        } catch (SQLException e) {
            System.err.println("查询出错：" + e.getMessage());
        }
    }
}