数据持久化实践：Java数据库连接、事务管理等实例解析

原创曾经终败给现在 2024-11-07 17:12 34阅读 0赞

数据持久化是指将数据保存到数据库中，以便在应用程序关闭后数据仍然可以被访问和使用。在Java中，数据持久化通常涉及到使用JDBC（Java Database Connectivity）API来连接数据库、执行SQL语句以及管理事务。以下是一些关于Java数据库连接和事务管理的基本实践和实例解析：

###1. JDBC连接数据库在Java中，使用JDBC连接数据库的基本步骤如下：

```javaimport java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;

public class DatabaseConnection {
 public static void main(String[] args) {
Connection conn = null;
 try {
// 加载数据库驱动Class.forName("com.mysql.cj.jdbc.Driver");
// 创建数据库连接 conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/mydb", "username", "password");
 System.out.println("数据库连接成功！");
} catch (ClassNotFoundException e) {
 System.out.println("数据库驱动加载失败！");
e.printStackTrace();
} catch (SQLException e) {
 System.out.println("数据库连接失败！");
e.printStackTrace();
} finally {
// 关闭连接 try {
if (conn != null) {
 conn.close();
 }
} catch (SQLException e) {
e.printStackTrace();
 }
 }
 }
}
```###2.执行SQL语句执行SQL语句通常涉及到`Statement`、`PreparedStatement`或`CallableStatement`对象。

```javaimport java.sql.*;

public class ExecuteSQL {
 public static void main(String[] args) {
Connection conn = null;
Statement stmt = null;
ResultSet rs = null;
 try {
 conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/mydb", "username", "password");
stmt = conn.createStatement();
//执行查询rs = stmt.executeQuery("SELECT * FROM mytable");
 while (rs.next()) {
 System.out.println(rs.getString("column_name"));
 }
} catch (SQLException e) {
e.printStackTrace();
} finally {
 try {
if (rs != null) rs.close();
if (stmt != null) stmt.close();
if (conn != null) conn.close();
} catch (SQLException e) {
e.printStackTrace();
 }
 }
 }
}
```###3.事务管理在JDBC中，事务可以通过设置连接的自动提交模式来管理。

```javaimport java.sql.*;

public class TransactionManagement {
 public static void main(String[] args) {
Connection conn = null;
 try {
 conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/mydb", "username", "password");
// 关闭自动提交 conn.setAutoCommit(false);
Statement stmt = conn.createStatement();
//执行一些数据库操作stmt.executeUpdate("INSERT INTO mytable (column1) VALUES ('value1')");
stmt.executeUpdate("UPDATE mytable SET column1 = 'value2' WHERE column1 = 'value1'");
// 提交事务 conn.commit();
} catch (SQLException e) {
 try {
//回滚事务if (conn != null) conn.rollback();
} catch (SQLException ex) {
ex.printStackTrace();
 }
e.printStackTrace();
} finally {
 try {
if (conn != null) conn.close();
} catch (SQLException e) {
e.printStackTrace();
 }
 }
 }
}
```### 注意事项-确保在finally块中关闭所有资源，如`Connection`、`Statement`和`ResultSet`，以避免内存泄漏。
- 使用`try-with-resources`语句可以自动管理资源，减少代码量并提高可读性。
-事务管理中，确保在发生异常时进行回滚，以保持数据的一致性。

这些是Java数据库连接和事务管理的一些基本实践。根据具体的数据库和业务需求，可能需要进行相应的调整和优化。