使用 Java 连接和检索 Oracle 数据库数据395

简介

Java 是一种强大的编程语言，广泛用于企业应用程序的开发。为了与数据库交互，Java 提供了多种选项，其中包括 JDBC（Java 数据库连接）。JDBC 是一种标准 API，允许 Java 程序员访问各种数据库，包括 Oracle 数据库。

连接到 Oracle 数据库

要连接到 Oracle 数据库，我们首先需要加载 JDBC 驱动程序。以下代码示例演示如何使用 DriverManager 类加载 Oracle 驱动程序：```java
import ;
public class OracleConnection {
public static void main(String[] args) {
try {
// 加载 Oracle 驱动程序
("");
// 建立数据库连接
String connectionUrl = "jdbc:oracle:thin:@//localhost:1521/orcl";
String username = "scott";
String password = "tiger";
connection = (connectionUrl, username, password);
// 检查连接是否成功
if (connection != null) {
("成功连接到 Oracle 数据库！");
} else {
("连接失败！");
}
} catch (Exception e) {
();
}
}
}
```

执行查询

连接到数据库后，我们可以执行查询以检索数据。以下代码示例演示如何使用 Statement 对象执行查询：```java
import ;
import ;
import ;
import ;
import ;
public class OracleSelectQuery {
public static void main(String[] args) {
try {
// 加载 Oracle 驱动程序
("");
// 建立数据库连接
String connectionUrl = "jdbc:oracle:thin:@//localhost:1521/orcl";
String username = "scott";
String password = "tiger";
Connection connection = (connectionUrl, username, password);
// 创建 Statement 对象
Statement statement = ();
// 执行查询
String query = "SELECT * FROM employees";
ResultSet resultSet = (query);
// 遍历结果集
while (()) {
("Employee ID: " + ("employee_id"));
("Employee Name: " + ("first_name") + " " + ("last_name"));
}
// 关闭结果集和语句对象
();
();
// 关闭连接
();
} catch (Exception e) {
();
}
}
}
```

更新数据

除了检索数据之外，我们还可以使用 Java 更新 Oracle 数据库中的数据。以下代码示例演示如何使用 PreparedStatement 对象执行更新查询：```java
import ;
import ;
import ;
import ;
public class OracleUpdateQuery {
public static void main(String[] args) {
try {
// 加载 Oracle 驱动程序
("");
// 建立数据库连接
String connectionUrl = "jdbc:oracle:thin:@//localhost:1521/orcl";
String username = "scott";
String password = "tiger";
Connection connection = (connectionUrl, username, password);
// 创建 PreparedStatement 对象
String query = "UPDATE employees SET salary = ? WHERE employee_id = ?";
PreparedStatement preparedStatement = (query);
// 设置参数
(1, 10000);
(2, 100);
// 执行更新查询
int rowCount = ();
// 检查受影响的行数
if (rowCount > 0) {
("更新成功！");
} else {
("更新失败！");
}
// 关闭 PreparedStatement 对象
();
// 关闭连接
();
} catch (Exception e) {
();
}
}
}
```

事务处理

在某些情况下，我们需要执行多项数据库操作并确保它们作为一个原子单元进行处理。在这种情况下，我们可以使用事务。以下代码示例演示如何使用事务处理更新多个表：```java
import ;
import ;
import ;
import ;
public class OracleTransaction {
public static void main(String[] args) {
try {
// 加载 Oracle 驱动程序
("");
// 建立数据库连接
String connectionUrl = "jdbc:oracle:thin:@//localhost:1521/orcl";
String username = "scott";
String password = "tiger";
Connection connection = (connectionUrl, username, password);
// 开始事务
(false);
// 创建 Statement 对象
Statement statement = ();
// 执行更新查询
String query1 = "UPDATE employees SET salary = salary * 1.10 WHERE department_id = 10";
(query1);
String query2 = "UPDATE departments SET budget = budget * 1.10 WHERE department_id = 10";
(query2);
// 提交事务
();
// 关闭 Statement 对象
();
// 关闭连接
();
("事务处理成功！");
} catch (Exception e) {
();
try {
// 回滚事务
();
} catch (SQLException ex) {
();
}
}
}
}
```