Java 从关系型数据库读写数据334

Java 是一种流行的编程语言，广泛用于开发各种应用程序，包括与数据库交互的应用程序。为了与关系型数据库（如 MySQL、PostgreSQL 和 Oracle）进行交互，Java 提供了 JDBC（Java Database Connectivity）API。

JDBC API 提供了一组类和接口，使 Java 程序能够连接到数据库、执行查询和更新操作以及管理事务。使用 JDBC，开发人员可以轻松地与各种关系型数据库进行交互，而无需了解底层数据库协议的详细信息。

连接到数据库

要连接到数据库，Java 程序需要使用 JDBC DriverManager 类。DriverManager 类提供了一组方法来获取数据库连接：getConnection()、getConnection(String url, Properties info) 和 getConnection(String url, String user, String password)。这些方法返回一个 Connection 对象，该对象表示到数据库的连接。
import ;
import ;
public class ConnectToDatabase {
public static void main(String[] args) {
// JDBC URL, 用户名和密码
String url = "jdbc:mysql://localhost:3306/testdb";
String user = "root";
String password = "";
try {
// 获取数据库连接
Connection conn = (url, user, password);
("已成功连接到数据库！");
} catch (Exception e) {
();
}
}
}

执行查询

要执行查询，Java 程序可以使用 JDBC Statement 类。Statement 类提供了一组方法来执行 SQL 查询，包括 executeQuery()、executeUpdate() 和 execute()。这些方法返回一个 ResultSet 对象，该对象包含查询结果或更新计数。
import ;
import ;
import ;
import ;
public class ExecuteQuery {
public static void main(String[] args) {
// JDBC URL, 用户名和密码
String url = "jdbc:mysql://localhost:3306/testdb";
String user = "root";
String password = "";
try {
// 获取数据库连接
Connection conn = (url, user, password);
// 创建 Statement 对象
Statement stmt = ();
// 执行查询并获取结果集
ResultSet rs = ("SELECT * FROM employees");
// 遍历结果集并打印结果
while (()) {
(("id") + " " + ("name") + " " + ("salary"));
}
// 关闭结果集和语句
();
();
} catch (Exception e) {
();
}
}
}

更新数据

要更新数据，Java 程序可以使用 JDBC Statement 类。Statement 类提供了一组方法来执行更新操作，包括 executeUpdate()、execute() 和 addBatch()。这些方法返回一个整数，表示受影响的行数。
import ;
import ;
import ;
public class UpdateData {
public static void main(String[] args) {
// JDBC URL, 用户名和密码
String url = "jdbc:mysql://localhost:3306/testdb";
String user = "root";
String password = "";
try {
// 获取数据库连接
Connection conn = (url, user, password);
// 创建 Statement 对象
Statement stmt = ();
// 执行更新操作
int rowCount = ("UPDATE employees SET salary = salary * 1.10 WHERE department_id = 1");
// 打印受影响的行数
("受影响的行数：" + rowCount);
// 关闭语句
();
} catch (Exception e) {
();
}
}
}

事务

事务是一组原子操作，这些操作要么全部成功，要么全部失败。在 JDBC 中，事务由 Connection 对象管理。要开启一个事务，开发人员可以调用 setAutoCommit(false) 方法。要提交事务，开发人员可以调用 commit() 方法。要回滚事务，开发人员可以调用 rollback() 方法。
import ;
import ;
import ;
public class Transaction {
public static void main(String[] args) {
// JDBC URL, 用户名和密码
String url = "jdbc:mysql://localhost:3306/testdb";
String user = "root";
String password = "";
try {
// 获取数据库连接
Connection conn = (url, user, password);
// 禁用自动提交
(false);
// 创建 Statement 对象
Statement stmt = ();
// 执行更新操作
("UPDATE employees SET salary = salary * 1.10 WHERE department_id = 1");
("UPDATE employees SET salary = salary * 1.10 WHERE department_id = 2");
// 提交事务
();
// 打印成功消息
("事务成功提交！");
} catch (Exception e) {
// 回滚事务
();
();
} finally {
// 关闭语句和连接
();
();
}
}
}