JDBC 在 Java 中查询数据库的实用指南323

简介

Java Database Connectivity (JDBC) 是 Java 编程语言与关系型数据库管理系统 (RDBMS) 之间交互的标准 API。使用 JDBC，您可以从 Java 应用程序中连接到数据库、执行查询和更新、检索结果并管理事务。

连接到数据库

要连接到数据库，您需要以下信息：
数据库 URL（例如，jdbc:mysql://localhost:3306/databasename）
用户名
密码

您可以使用以下代码连接到数据库：```java
import ;
import ;
public class DatabaseConnection {
public static void main(String[] args) {
// 替换以下值以匹配您的数据库信息
String url = "jdbc:mysql://localhost:3306/databasename";
String username = "user";
String password = "password";
try {
// 加载 JDBC 驱动程序
("");
// 建立连接
Connection connection = (url, username, password);
// 关闭连接
();
("已成功连接到数据库！");
} catch (Exception e) {
();
}
}
}
```

执行查询

一旦连接到数据库，您就可以执行查询来检索数据。您可以使用以下代码执行查询：```java
import ;
import ;
import ;
import ;
public class DatabaseQuery {
public static void main(String[] args) {
// 替换以下值以匹配您的数据库信息
String url = "jdbc:mysql://localhost:3306/databasename";
String username = "user";
String password = "password";
try {
// 加载 JDBC 驱动程序
("");
// 建立连接
Connection connection = (url, username, password);
// 创建一个声明对象
Statement statement = ();
// 执行查询
String query = "SELECT * FROM table_name";
ResultSet resultSet = (query);
// 处理结果集
while (()) {
(("column_name"));
}
// 关闭连接
();
();
();
} catch (Exception e) {
();
}
}
}
```

更新数据

您还可以使用 JDBC 更新数据库中的数据。您可以使用以下代码更新数据：```java
import ;
import ;
import ;
public class DatabaseUpdate {
public static void main(String[] args) {
// 替换以下值以匹配您的数据库信息
String url = "jdbc:mysql://localhost:3306/databasename";
String username = "user";
String password = "password";
try {
// 加载 JDBC 驱动程序
("");
// 建立连接
Connection connection = (url, username, password);
// 创建一个声明对象
Statement statement = ();
// 执行更新
String query = "UPDATE table_name SET column_name = 'new_value' WHERE condition";
int rowCount = (query);
// 检查更新是否成功
if (rowCount > 0) {
("数据已成功更新！");
}
// 关闭连接
();
();
} catch (Exception e) {
();
}
}
}
```

管理事务

事务是一组原子操作，要么一起成功，要么一起失败。您可以使用 JDBC 管理事务以确保数据的一致性。您可以使用以下代码管理事务：```java
import ;
import ;
import ;
import ;
public class DatabaseTransaction {
public static void main(String[] args) {
// 替换以下值以匹配您的数据库信息
String url = "jdbc:mysql://localhost:3306/databasename";
String username = "user";
String password = "password";
try {
// 加载 JDBC 驱动程序
("");
// 建立连接
Connection connection = (url, username, password);
// 设置自动提交为 false 以启用事务
(false);
// 创建一个声明对象
Statement statement = ();
// 执行更新
String query1 = "UPDATE table_name SET column_name = 'new_value1' WHERE condition1";
String query2 = "UPDATE table_name SET column_name = 'new_value2' WHERE condition2";
(query1);
(query2);
// 检查更新是否成功
if (true) { // 检查更新是否成功
// 提交事务
();
("事务已成功提交！");
} else {
// 回滚事务
();
("事务已回滚！");
}
// 关闭连接
();
();
} catch (Exception e) {
();
}
}
}
```