新视角下的 Java 链接 PostgreSQL 数据库

2024-02-04 15:31:26

在现代软件开发中，数据库已成为不可或缺的一部分。作为一种对象关系型数据库管理系统，PostgreSQL 以其出色的性能和强大的功能在众多应用中脱颖而出。如果您正在寻找一种方法来链接 Java 应用程序与 PostgreSQL 数据库，那么本文将为您提供详细的指导。

一、准备工作

1. 准备必要的 JAR 包

链接 Java 与 PostgreSQL 数据库需要用到 JDBC（Java Database Connectivity）技术。我们需要下载相应的 JDBC JAR 包。可以从官方网站下载最新版本的 JDBC JAR 包，也可以直接使用 Maven 依赖管理工具进行下载。

2. 将 JAR 包添加到项目中

将下载的 JDBC JAR 包添加到项目的依赖项中。如果您使用 Maven，可以在 pom.xml 文件中添加以下依赖项：

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

如果您使用 Gradle，则可以在 build.gradle 文件中添加以下依赖项：

dependencies {
  compile group: 'org.postgresql', name: 'postgresql', version: '42.3.6'
}

二、链接数据库

在准备好必要的 JAR 包后，就可以开始链接 Java 应用程序与 PostgreSQL 数据库了。

1. 创建数据库连接

首先，我们需要创建一个数据库连接。可以使用 DriverManager 类来创建数据库连接。代码如下：

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

public class DatabaseConnection {

  public static Connection getConnection() throws Exception {
    // 数据库连接 URL
    String url = "jdbc:postgresql://localhost:5432/testdb";

    // 数据库用户名和密码
    String username = "postgres";
    String password = "mypassword";

    // 加载 JDBC 驱动程序
    Class.forName("org.postgresql.Driver");

    // 创建数据库连接
    Connection connection = DriverManager.getConnection(url, username, password);

    // 返回数据库连接
    return connection;
  }
}

在上面的代码中，我们需要提供数据库连接 URL、用户名和密码。然后使用 Class.forName() 方法加载 JDBC 驱动程序，并使用 DriverManager.getConnection() 方法创建数据库连接。

2. 执行 SQL 语句

创建数据库连接后，就可以使用 Statement 或 PreparedStatement 对象来执行 SQL 语句。代码如下：

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

public class DatabaseOperations {

  public static void main(String[] args) throws SQLException {
    // 创建数据库连接
    Connection connection = DatabaseConnection.getConnection();

    // 创建一个 PreparedStatement 对象
    String sql = "SELECT * FROM customers WHERE id = ?";
    PreparedStatement preparedStatement = connection.prepareStatement(sql);

    // 设置查询参数
    preparedStatement.setInt(1, 1);

    // 执行 SQL 语句并获取结果集
    ResultSet resultSet = preparedStatement.executeQuery();

    // 遍历结果集
    while (resultSet.next()) {
      // 获取列值
      int id = resultSet.getInt("id");
      String name = resultSet.getString("name");
      int age = resultSet.getInt("age");

      // 打印结果
      System.out.println("ID: " + id + ", Name: " + name + ", Age: " + age);
    }

    // 关闭结果集、PreparedStatement 和数据库连接
    resultSet.close();
    preparedStatement.close();
    connection.close();
  }
}