java连接oracle数据库实现增删改查

运维百科 2025年11月18日 21:17 245 admin

Java连接Oracle数据库实现增删改查详解

在软件开发中，数据库是不可或缺的一部分，对于Java开发者来说，掌握如何与数据库交互是非常重要的技能，本文将详细介绍如何使用Java连接Oracle数据库,并实现基本的增删改查操作。

我们需要在项目中引入Oracle的JDBC驱动，这可以通过在项目的pom.xml文件中添加以下依赖来实现：

<dependency>
    <groupId>com.oracle.database.jdbc</groupId>
    <artifactId>ojdbc8</artifactId>
    <version>19.3.0.0</version>
</dependency>
我们需要编写代码来建立与Oracle数据库的连接,以下是一个简单的示例：

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class DatabaseConnection {
    private static final String URL = "jdbc:oracle:thin:@localhost:1521:orcl";
    private static final String USER = "your_username";
    private static final String PASSWORD = "your_password";
    public static Connection getConnection() throws SQLException {
        return DriverManager.getConnection(URL, USER, PASSWORD);
    }
}
在上面的代码中，我们定义了数据库的URL、用户名和密码，并使用DriverManager.getConnection方法建立了与数据库的连接。

现在我们已经有了一个数据库连接，接下来我们可以编写代码来实现增删改查操作,以下是一个简单的示例：
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
public class CRUDOperations {
    public static void main(String[] args) {
        try (Connection connection = DatabaseConnection.getConnection()) {
            // 插入数据
            insertData(connection);
            // 查询数据
            selectData(connection);
            // 更新数据
            updateData(connection);
            // 删除数据
            deleteData(connection);
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
    private static void insertData(Connection connection) throws SQLException {
        String sql = "INSERT INTO your_table (column1, column2) VALUES (?, ?)";
        try (PreparedStatement statement = connection.prepareStatement(sql)) {
            statement.setString(1, "value1");
            statement.setString(2, "value2");
            statement.executeUpdate();
        }
    }
    private static void selectData(Connection connection) throws SQLException {
        String sql = "SELECT * FROM your_table";
        try (PreparedStatement statement = connection.prepareStatement(sql); ResultSet resultSet = statement.executeQuery()) {
            while (resultSet.next()) {
                System.out.println("Column1: " + resultSet.getString("column1"));
                System.out.println("Column2: " + resultSet.getString("column2"));
            }
        }
    }
    private static void updateData(Connection connection) throws SQLException {
        String sql = "UPDATE your_table SET column1 = ? WHERE column2 = ?";
        try (PreparedStatement statement = connection.prepareStatement(sql)) {
            statement.setString(1, "new_value");
            statement.setString(2, "value2");
            statement.executeUpdate();
        }
    }
    private static void deleteData(Connection connection) throws SQLException {
        String sql = "DELETE FROM your_table WHERE column1 = ?";
        try (PreparedStatement statement = connection.prepareStatement(sql)) {
            statement.setString(1, "value1");
            statement.executeUpdate();
        }
    }
}
在上面的代码中，我们定义了四个方法：insertData用于插入数据，selectData用于查询数据，updateData用于更新数据，deleteData用于删除数据。