java怎么连接PostgreSQL数据库实现Java程序与PostgreSQL数据库连接-java教程-PHP中文网

java怎么连接PostgreSQL数据库实现Java程序与PostgreSQL数据库连接

星降

发布： 2025-11-06 22:51:02

原创

815人浏览过

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

java怎么连接postgresql数据库实现java程序与postgresql数据库连接

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

1. 添加PostgreSQL JDBC驱动

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

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

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

登录后复制

如果不用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. 处理连接配置和常见问题

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

ShopEx助理

一个类似淘宝助理、ebay助理的客户端程序，用来方便的在本地处理商店数据，并能够在本地商店、网上商店和第三方平台之间实现数据上传下载功能的工具。功能说明如下：1.连接本地商店：您可以使用ShopEx助理连接一个本地安装的商店系统，这样就可以使用助理对本地商店的商品数据进行编辑等操作，并且数据也将存放在本地商店数据库中。默认是选择“本地未安装商店”，本地还未安

查看详情

立即学习“Java免费学习笔记（深入）”；

例如使用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());
        }
    }
}

登录后复制

注意事项：