首先引入PostgreSQL JDBC驱动，再通过DriverManager获取连接，使用try-with-resources管理资源并建议用配置文件存储参数，最后通过Statement执行SQL操作。
要让Java程序连接PostgreSQL数据库，主要通过JDBC（Java Database Connectivity）实现。你需要完成以下几个步骤：引入驱动、编写连接代码、处理异常并确保资源释放。
1. 添加PostgreSQL JDBC驱动
PostgreSQL官方提供了JDBC驱动，Java程序需要这个驱动才能与数据库通信。
推荐使用Maven管理依赖，在pom.xml中添加：
如果不用Maven，需手动下载org.postgresql postgresql 42.7.3
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. 处理连接配置和常见问题
立即学习“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());
}
}
}
注意事项：
- 务必使用try-with-resources自动关闭Connection、Statement和ResultSet，防止资源泄漏。
- 生产环境应使用连接池（如HikariCP、DBCP），而不是每次新建连接。
- 确保数据库用户有权限访问目标数据库，并开启远程连接（如需）。
