Java回顾之JDBC(Java基础回顾：深入理解JDBC应用与实践)

原创

ithorizon 6个月前 (10-19) 阅读数 28 #后端开发

Java回顾之JDBC - 深入懂得JDBC应用与实践

一、JDBC简介

Java Database Connectivity（JDBC）是Java语言中用于数据库连接的一种标准规范。它提供了一套API，令Java程序能够与拥护SQL的数据库进行交互。JDBC令开发者可以方便地连接各种数据库，如MySQL、Oracle、SQL Server等，从而实现数据的存取、更新、查询等操作。

二、JDBC核心组件

JDBC的核心组件首要包括以下几个部分：

DriverManager：负责管理不同数据库的驱动程序，并构建与数据库的连接。

Connection：代表与特定数据库的连接。

Statement：用于执行SQL语句。

ResultSet：代表SQL查询于是集。

三、JDBC连接数据库步骤

以下是使用JDBC连接数据库的基本步骤：

加载JDBC驱动。

构建数据库连接。

创建Statement对象。

执行SQL语句。

处理ResultSet于是集。

关闭连接。

四、JDBC连接MySQL数据库示例

以下是一个使用JDBC连接MySQL数据库的示例代码：


import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class JDBCExample {
    public static void main(String[] args) {
        // 数据库连接字符串
        String url = "jdbc:mysql://localhost:3306/test";
        // 数据库用户名
        String user = "root";
        // 数据库密码
        String password = "123456";
        Connection conn = null;
        Statement stmt = null;
        ResultSet rs = null;
        try {
            // 1. 加载JDBC驱动
            Class.forName("com.mysql.cj.jdbc.Driver");
            // 2. 构建数据库连接
            conn = DriverManager.getConnection(url, user, password);
            // 3. 创建Statement对象
            stmt = conn.createStatement();
            // 4. 执行SQL语句
            String sql = "SELECT * FROM user";
            rs = stmt.executeQuery(sql);
            // 5. 处理ResultSet于是集
            while (rs.next()) {
                System.out.println("ID: " + rs.getInt("id") + ", Name: " + rs.getString("name"));
            }
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            // 6. 关闭连接
            try {
                if (rs != null) {
                    rs.close();
                }
                if (stmt != null) {
                    stmt.close();
                }
                if (conn != null) {
                    conn.close();
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

五、JDBC事务管理

JDBC提供了事务管理机制，允许开发者对数据库操作进行事务控制。以下是怎样使用JDBC进行事务管理的步骤：

关闭自动提交。

执行多个SQL操作。

提交或回滚事务。

以下是一个使用JDBC进行事务管理的示例代码：


import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
public class TransactionExample {
    public static void main(String[] args) {
        // 数据库连接字符串
        String url = "jdbc:mysql://localhost:3306/test";
        // 数据库用户名
        String user = "root";
        // 数据库密码
        String password = "123456";
        Connection conn = null;
        PreparedStatement pstmt1 = null;
        PreparedStatement pstmt2 = null;
        try {
            // 1. 加载JDBC驱动
            Class.forName("com.mysql.cj.jdbc.Driver");
            // 2. 构建数据库连接
            conn = DriverManager.getConnection(url, user, password);
            // 3. 关闭自动提交
            conn.setAutoCommit(false);
            // 4. 执行多个SQL操作
            String sql1 = "UPDATE user SET name = ? WHERE id = ?";
            String sql2 = "UPDATE user SET age = ? WHERE id = ?";
            pstmt1 = conn.prepareStatement(sql1);
            pstmt2 = conn.prepareStatement(sql2);
            pstmt1.setString(1, "Alice");
            pstmt1.setInt(2, 1);
            pstmt1.executeUpdate();
            pstmt2.setInt(1, 30);
            pstmt2.setInt(2, 1);
            pstmt2.executeUpdate();
            // 5. 提交事务
            conn.commit();
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            // 6. 回滚事务
            try {
                if (conn != null) {
                    conn.rollback();
                }
            } catch (SQLException ex) {
                ex.printStackTrace();
            }
            e.printStackTrace();
        } finally {
            try {
                if (pstmt1 != null) {
                    pstmt1.close();
                }
                if (pstmt2 != null) {
                    pstmt2.close();
                }
                if (conn != null) {
                    conn.close();
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}