使用Java连接和操作数据库52

Java是一种强大的编程语言，因其跨平台兼容性和在构建各种应用程序中的广泛使用而广受欢迎。它可以通过JDBC（Java数据库连接）API轻松连接和操作数据库，该API提供了一组标准化接口，允许Java程序与各种数据库系统进行交互。

连接到数据库

要连接到数据库，您需要使用DriverManager类和getConnection方法。此方法需要三个参数：数据库URL、用户名和密码。
import .*;
public class DatabaseConnection {
public static void main(String[] args) {
// 数据库URL，用户名和密码
String url = "jdbc:mysql://localhost:3306/database_name";
String username = "root";
String password = "password";
try {
// 建立数据库连接
Connection connection = (url, username, password);
("成功连接到数据库！");
} catch (SQLException e) {
();
}
}
}

执行查询

一旦建立了数据库连接，就可以使用Statement或PreparedStatement对象执行查询。Statement对象用于执行基本的SQL查询，而PreparedStatement对象用于执行带参数的查询，从而防止SQL注入攻击。
import .*;
public class DatabaseQuery {
public static void main(String[] args) {
// 数据库URL，用户名和密码
String url = "jdbc:mysql://localhost:3306/database_name";
String username = "root";
String password = "password";
try {
// 建立数据库连接
Connection connection = (url, username, password);
// 创建Statement对象
Statement statement = ();
// 执行查询
ResultSet resultSet = ("SELECT * FROM table_name");
// 处理结果集
while (()) {
(("column_name"));
}
} catch (SQLException e) {
();
}
}
}

更新数据

除了执行查询之外，您还可以使用Statement或PreparedStatement对象更新数据。使用executeUpdate方法执行更新操作，该方法返回受影响的行数。
import .*;
public class DatabaseUpdate {
public static void main(String[] args) {
// 数据库URL，用户名和密码
String url = "jdbc:mysql://localhost:3306/database_name";
String username = "root";
String password = "password";
try {
// 建立数据库连接
Connection connection = (url, username, password);
// 创建Statement对象
Statement statement = ();
// 执行更新操作
int rowCount = ("UPDATE table_name SET column_name = 'new_value'");
// 打印受影响的行数
("受影响的行数：" + rowCount);
} catch (SQLException e) {
();
}
}
}

事务处理

事务处理是一种确保数据库操作要么全部执行，要么全部回滚的技术。在Java中，您可以使用Connection对象的setAutoCommit方法关闭自动提交，然后使用commit或rollback方法手动提交或回滚事务。
import .*;
public class DatabaseTransaction {
public static void main(String[] args) {
// 数据库URL，用户名和密码
String url = "jdbc:mysql://localhost:3306/database_name";
String username = "root";
String password = "password";
try {
// 建立数据库连接
Connection connection = (url, username, password);
// 关闭自动提交
(false);
// 执行更新操作
Statement statement = ();
int rowCount1 = ("UPDATE table_name1 SET column_name1 = 'new_value1'");
int rowCount2 = ("UPDATE table_name2 SET column_name2 = 'new_value2'");
// commit事务
();
// 打印受影响的行数
("受影响的行数（table_name1）：" + rowCount1);
("受影响的行数（table_name2）：" + rowCount2);
} catch (SQLException e) {
// 回滚事务
();
();
}
}
}

使用Java连接和操作数据库是一项相对简单的任务，利用JDBC API。通过使用DriverManager类、Statement或PreparedStatement对象，您可以轻松执行查询、更新数据并管理事务。这使Java开发者能够轻松地将数据库集成到他们的应用程序中，从而构建强大的基于数据的解决方案。

2024-11-19

上一篇：Java 二维 String 数组：全面指南

下一篇：Java 数据库更新