JDBC：Java Database Connectivity，Java 數據庫連接

需要 jar 包支持：

java.sql

javax.sql

mysql-connector-java（連接驅動，必須導入）

在 MySQL 先建個 jdbc 數據庫后?USE jdbc;

執行后再 CREATE TABLE?創建表

執行后插入數據 INSERT INTO

USE jdbc;
create table users(id int primary key,`name` varchar(40),`password` varchar(40),email varchar(60),birthday date
);
insert into users(id,`name`,`password`,email,birthday)
values(1,'張三1','123','zs1@qq.com','2024-06-30');
insert into users(id,`name`,`password`,email,birthday)
values(2,'張三2','123','zs2@qq.com','2024-06-30');
insert into users(id,`name`,`password`,email,birthday)
values(3,'張三3','123','zs3@qq.com','2024-06-30');
insert into users(id,`name`,`password`,email,birthday)
values(4,'張三4','123','zs4@qq.com','2024-06-30');select * from users;

點這個執行

查詢結果：

pom.xml 導入數據庫依賴：

    <!-- 連接數據庫 --><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>8.0.33</version></dependency>

?IDEA 連接數據庫（沒有的去 Settings Plugins 搜索 DataBase 下載）

JDBC 固定步驟：

1.加載驅動

2.連接數據庫

3.向數據庫發送 SQL 對象 Statement

4.編寫 SQL

5.執行 SQL

6.關閉連接

代碼如下：

package com.demo.jdbc;import java.sql.*;public class Demo {public static void main(String[] args) throws ClassNotFoundException, SQLException {//配置信息 useUnicode=true&characterEncoding=utf-8 解決中文亂碼String url = "jdbc:mysql://localhost:3306/jdbc?useSSL=true&useUnicode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai";String username = "root";String password = "root";//1.加載驅動Class.forName("com.mysql.jdbc.Driver");//2.連接數據庫Connection connection = DriverManager.getConnection(url, username, password);//3.向數據庫發送SQL對象Statement：CRUD：create添加 read讀取 update修改 delete刪除Statement statement = connection.createStatement(); //4.編寫SQLString sql = "select * from users";//5.執行查詢SQL，返回一個ResultSet結果集ResultSet resultSet = statement.executeQuery(sql);while (resultSet.next()){System.out.println("id="+resultSet.getObject("id"));System.out.println("name="+resultSet.getObject("name"));System.out.println("password="+resultSet.getObject("password"));System.out.println("email="+resultSet.getObject("email"));System.out.println("birthday="+resultSet.getObject("birthday"));}//6.關閉連接，釋放資源，先開后關resultSet.close();statement.close();connection.close();}
}

編寫 SQL 時，因為引號里沒有顯示，可以在 IDEA 提供連接的數據庫里編寫 sql 語句然后復制過去

代碼執行效果如下：

同理，刪除語句：

delete from users where id = 4;

增刪改都用 executeUpdate，int 型是受影響的行數

int i = statement.executeUpdate(sql);??

JDBC 事務：

要么都成功，要么都失敗

ACID 原則：保證數據的安全

原子性 (Atomicity)、 一致性(Consistency)、隔離性(Isolation) 、?持久性(Durability)

Junit 單元測試依賴：

（從?導入 jar 包?復制過來的 junit 把 <scope> 這行刪除，不然沒有 @Test 注解）

    <!-- 單元測試 --><dependency><groupId>junit</groupId><artifactId>junit</artifactId><version>4.13.2</version></dependency>

@Test 注解只在方法上有效，不需要 main 方法，只要加了這個注解的方法就能運行

public class Test {@org.junit.Testpublic void test(){System.out.println("Hello");}
}

舉個事務的例子：轉賬

建表，插入數據

use jdbc;
create table account(id int primary key auto_increment,`name` varchar(40),money float
);insert into account(`name`,money) value('A',100);
insert into account(`name`,money) value('B',100);

通知數據庫開啟事務，false開啟

connection.setAutoCommit(false);

代碼如下：

package com.demo.jdbc;import org.junit.Test;import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;public class JdbcDemo {@Testpublic void test(){//配置信息 useUnicode=true&characterEncoding=utf-8 解決中文亂碼String url = "jdbc:mysql://localhost:3306/jdbc?useSSL=true&useUnicode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai";String username = "root";String password = "root";Connection connection = null;try {//1.加載驅動Class.forName("com.mysql.jdbc.Driver");//2.連接數據庫connection = DriverManager.getConnection(url, username, password);//3.通知數據庫開啟事務，false開啟connection.setAutoCommit(false);String sql = "update account set money = money-10 where name = 'A'";connection.prepareStatement(sql).executeUpdate();String sql1 = "update account set money = money+10 where name = 'B'";connection.prepareStatement(sql1).executeUpdate();//提交事務connection.commit();System.out.println("success");} catch (Exception e) {try {//如果出現異常，就通知數據庫回滾事務connection.rollback();} catch (SQLException e1) {e1.printStackTrace();}e.printStackTrace();}finally {try {connection.close();} catch (SQLException e) {e.printStackTrace();}}}
}