数据持久化：Java在数据库中的CRUD操作实例

原创矫情吗；* 2024-11-12 20:54 25阅读 0赞

数据持久化是指将数据保存到数据库中，以便在应用程序关闭后数据仍然可以被访问。在Java中，CRUD操作（Create, Read, Update, Delete）是数据库操作的基本组成部分。以下是使用Java进行数据库CRUD操作的一个简单实例，我们将使用JDBC（Java Database Connectivity）来实现这些操作。

###1. 创建数据库连接首先，你需要添加JDBC驱动到你的项目中。如果你使用的是Maven项目，可以在`pom.xml`文件中添加以下依赖：

```xml<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>8.0.23</version>
</dependency>
```###2. 创建表在数据库中创建一个表，例如：

```sqlCREATE TABLE users (
id INT AUTO_INCREMENT PRIMARY KEY,
name VARCHAR(100),
email VARCHAR(100)
);
```###3. Java代码实现CRUD操作```javaimport java.sql.*;

public class CrudExample {
 private static final String URL = "jdbc:mysql://localhost:3306/your_database";
 private static final String USER = "your_username";
 private static final String PASSWORD = "your_password";

public static void main(String[] args) {
Connection conn = null;
 try {
 conn = DriverManager.getConnection(URL, USER, PASSWORD);
 conn.setAutoCommit(false);

// CreateString insertSQL = "INSERT INTO users (name, email) VALUES (?, ?)";
 try (PreparedStatement pstmt = conn.prepareStatement(insertSQL)) {
 pstmt.setString(1, "John Doe");
 pstmt.setString(2, "john.doe@example.com");
int affectedRows = pstmt.executeUpdate();
 System.out.println("Inserted " + affectedRows + " row(s).");
 }

// ReadString selectSQL = "SELECT id, name, email FROM users";
 try (Statement stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery(selectSQL)) {
 while (rs.next()) {
 System.out.println("ID: " + rs.getInt("id") + ", Name: " + rs.getString("name") + ", Email: " + rs.getString("email"));
 }
 }

// UpdateString updateSQL = "UPDATE users SET email = ? WHERE name = ?";
 try (PreparedStatement pstmt = conn.prepareStatement(updateSQL)) {
 pstmt.setString(1, "john.doe@newdomain.com");
 pstmt.setString(2, "John Doe");
int affectedRows = pstmt.executeUpdate();
 System.out.println("Updated " + affectedRows + " row(s).");
 }

// DeleteString deleteSQL = "DELETE FROM users WHERE name = ?";
 try (PreparedStatement pstmt = conn.prepareStatement(deleteSQL)) {
 pstmt.setString(1, "John Doe");
int affectedRows = pstmt.executeUpdate();
 System.out.println("Deleted " + affectedRows + " row(s).");
 }

conn.commit();
} catch (SQLException e) {
if (conn != null) {
 try {
 conn.rollback();
} catch (SQLException ex) {
ex.printStackTrace();
 }
 }
e.printStackTrace();
} finally {
if (conn != null) {
 try {
 conn.close();
} {
 conn.close();
 }
 }
 }
 }
}
```### 注意事项-确保数据库驱动已正确添加到项目中。
-替换`URL`, `USER`, `PASSWORD`, 和`your_database`为你的数据库信息。
-异常处理和事务管理是必要的，以确保数据的一致性和完整性。

这个例子展示了如何在Java中使用JDBC进行基本的CRUD操作。你可以根据需要调整SQL语句和逻辑来适应你的具体需求。