java使用jdbc

August 14, 2022

JDBC（Java Database Connectivity）

JDBC 定义了访问和处理（关系型）数据库的接口

主要有这两个包提供：java.sql 和 javax.sql

java.sql.Types 定义了数据库类型与 java 类型的映射

通过 jdbc 访问数据库需要项目安装对应数据库的驱动，依赖类型只需为<scope>runtime</scope>
例如，MySQL 的驱动：https://mvnrepository.com/artifact/mysql/mysql-connector-java
安装与 MySQL 服务器对应版本的驱动即可

xml

<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>x.x.x</version>
    <scope>runtime</scope>
</dependency>

执行 SQL

查询，executeQuery

java

import java.sql.*;

public class Main {
    public static void main(String[] args) throws Exception {
        final String JDBC_URL = "jdbc:mysql://localhost:3306/dbname?useSSL=false&characterEncoding=utf8";
        final String JDBC_USER = "root";
        final String JDBC_PASSWORD = "pa$$word";

        // 连接数据库
        try (Connection conn = DriverManager.getConnection(JDBC_URL, JDBC_USER, JDBC_PASSWORD)) {
            // 直接构造 SQL
            try (Statement stmt = conn.createStatement()) {
                try (ResultSet rs = stmt.executeQuery("SELECT id, grade, name, gender FROM students WHERE gender=1")) {
                    while (rs.next()) {
                        // 必须根据 SELECT 语句查询的顺序来调用ResultSet上面的方法，否则将抛出异常
                        long id = rs.getLong(1); // 注意：索引从1开始
                        long grade = rs.getLong(2);
                        String name = rs.getString(3);
                        int gender = rs.getInt(4);
                    }
                }
            }
            // 使用 PreparedStatement
            try (PreparedStatement ps = conn.prepareStatement("SELECT id, grade, name, gender FROM students WHERE gender=? AND grade=?")) {
                ps.setObject(1, "M"); // 注意：索引从1开始
                ps.setObject(2, 3);
                try (ResultSet rs = ps.executeQuery()) {
                    while (rs.next()) {
                        long id = rs.getLong("id");
                        long grade = rs.getLong("grade");
                        String name = rs.getString("name");
                        String gender = rs.getString("gender");
                    }
                }
            }
            // 释放 Connection
        }
    }
}

插入，executeUpdate
插入时应始终使用 PreparedStatement

java

try (PreparedStatement ps = conn.prepareStatement(
        "INSERT INTO students (grade, name, gender) VALUES (?,?,?)",
        Statement.RETURN_GENERATED_KEYS))
// 如果需要获取自增主键，需要指定 prepareStatement 函数的第二个参数
{
    ps.setObject(1, 1); // grade
    ps.setObject(2, "Bob"); // name
    ps.setObject(3, "M"); // gender
    int n = ps.executeUpdate(); // 返回表中受影响的行数，这里将返回 1
    try (ResultSet rs = ps.getGeneratedKeys()) {
        if (rs.next()) {
            long id = rs.getLong(1); // 注意：索引从1开始
        }
    }
}

更新和删除语句和插入语句调用方法一致。

Batch 批量操作

使用 addBatch/executeBatch 而不是直接循环来执行批量操作

java

try (PreparedStatement ps = conn.prepareStatement("INSERT INTO students (name, gender, grade, score) VALUES (?, ?, ?, ?)")) {
    for (Student s : students) {
        ps.setString(1, s.name);
        ps.setBoolean(2, s.gender);
        ps.setInt(3, s.grade);
        ps.setInt(4, s.score);
        ps.addBatch(); // 每次循环结束，执行addBatch方法
    }
    // 运行所有添加的batch
    int[] ns = ps.executeBatch();
    // 一般来说，此方法返回值类似于executeUpdate方法，只不过返回的是数组
}

SQL 事务

java

try (Connection conn = DriverManager.getConnection(JDBC_URL, JDBC_USER, JDBC_PASSWORD)) {
    // 手动修改隔离级别，否则使用默认值
    try {
        conn.setTransactionIsolation(Connection.TRANSACTION_READ_COMMITTED);
    } catch (SQLException e) {
        // ... ...
    }
    // 执行事务
    try {
        // 必须关闭自动提交，才可以执行事务
        conn.setAutoCommit(false);
        // 执行多条SQL语句:
        insert();
        update();
        delete();
        // 提交事务:
        conn.commit();
    } catch (SQLException e) {
        // 回滚事务:
        conn.rollback();
    } finally {
        // 必须开启自动提交，因为单条SQL语句是隐式事务
        conn.setAutoCommit(true);
    }
    // 自动释放 Connection（conn.close()）
}