十二、JDBC（復(fù)習(xí)）

目錄：JDBC、事務(wù)

1.JDBC

什么是JDBC：Java連接數(shù)據(jù)庫。

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,'張三','123456','zs@qq.com','2000-01-01');
INSERT INTO users(id,`name`,`password`,email,birthday)
VALUES(2,'李四','123456','ls@qq.com','2000-01-01');
INSERT INTO users(id,`name`,`password`,email,birthday)
VALUES(3,'王五','123456','ww@qq.com','2000-01-01');

導(dǎo)入數(shù)據(jù)庫依賴：

<dependency>
  <groupId>mysql</groupId>
  <artifactId>mysql-connector-java</artifactId>
  <version>5.1.47</version>
</dependency>

IDEA中連接數(shù)據(jù)庫：右側(cè)Database——>點(diǎn)擊+——>選擇Data Source——>選擇MySQL——>填寫數(shù)據(jù)庫的用戶名和密碼——>點(diǎn)擊Test Connection測試功能——>點(diǎn)擊Apply——>OK

點(diǎn)擊Database和+

填寫數(shù)據(jù)庫的用戶名和密碼

JDBC固定步驟：
①加載驅(qū)動。
② 連接數(shù)據(jù)庫。
③向數(shù)據(jù)庫發(fā)送SQL的對象Statement、PreparedStatement：CRUD。
④編寫SQL （根據(jù)業(yè)務(wù)編寫不同的SQL）。
⑤執(zhí)行SQL。
⑥關(guān)閉連接。

package com.ping.jdbc;
import java.sql.*;
public class TestJdbc {
  public static void main(String[] args) throws ClassNotFoundException, SQLException {
    //配置信息
    //useUnicode=true&characterEncoding=utf-8 解決中文亂碼
    String url="jdbc:mysql://localhost:3306/jdbc?useUnicode=true&characterEncoding=utf-8";
    String username = "root";
    String password = "123456";
    //加載驅(qū)動
    Class.forName("com.mysql.jdbc.Driver");
    //連接數(shù)據(jù)庫,代表數(shù)據(jù)庫
    Connection connection = DriverManager.getConnection(url, username, password);
    //向數(shù)據(jù)庫發(fā)送SQL的對象Statement,PreparedStatement : CRUD
    Statement statement = connection.createStatement();
    //編寫SQL
    String sql = "select * from users";
    //執(zhí)行查詢SQL，返回一個 ResultSet  ： 結(jié)果集
    ResultSet rs = statement.executeQuery(sql);
    while (rs.next()){
      System.out.println("id="+rs.getObject("id"));
      System.out.println("name="+rs.getObject("name"));
      System.out.println("password="+rs.getObject("password"));
      System.out.println("email="+rs.getObject("email"));
      System.out.println("birthday="+rs.getObject("birthday"));
    }
    //關(guān)閉連接，釋放資源一定要先開后關(guān)
    rs.close();
    statement.close();
    connection.close();
  }
}

預(yù)編譯SQL：

package com.ping.jdbc;
import java.sql.*;
public class TestJdbc2 {
  public static void main(String[] args) throws Exception {
    //配置信息
    String url="jdbc:mysql://localhost:3306/jdbc?useUnicode=true&characterEncoding=utf-8";
    String username = "root";
    String password = "123456";
    //加載驅(qū)動
    Class.forName("com.mysql.jdbc.Driver");
    //連接數(shù)據(jù)庫
    Connection connection = DriverManager.getConnection(url, username, password);
    //編寫SQL
    String sql = "insert into  users(id, name, password, email, birthday) values (?,?,?,?,?);";
    //預(yù)編譯
    PreparedStatement preparedStatement = connection.prepareStatement(sql);
    preparedStatement.setInt(1,2);
    preparedStatement.setString(2,"Ping");
    preparedStatement.setString(3,"123456");
    preparedStatement.setString(4,"2585801995@qq.com");
    preparedStatement.setDate(5,new Date(new java.util.Date().getTime()));
    //執(zhí)行SQL
    int i = preparedStatement.executeUpdate();
    if (i>0){
      System.out.println("插入成功@");
    }
    //關(guān)閉連接，釋放資源一定要先開后關(guān)
    preparedStatement.close();
    connection.close();
  }
}

2.事務(wù)

要么都成功，要么都失??！
ACID原則：保證數(shù)據(jù)的安全。
步驟：
①開啟事務(wù)
②事務(wù)提交 commit()
③事務(wù)回滾 rollback()
④關(guān)閉事務(wù)

Junit單元測試

導(dǎo)入依賴：

<dependency>
  <groupId>junit</groupId>
  <artifactId>junit</artifactId>
  <version>4.12</version>
</dependency>

簡單使用：@Test注解只有在方法上有效，只要加了這個注解的方法，就可以直接運(yùn)行。
創(chuàng)建測試數(shù)據(jù)庫中的表，用來模擬賬戶轉(zhuǎn)賬，可下載使用：https://share.weiyun.com/ddtKuOZf，也可以直接復(fù)制下方。

CREATE TABLE account(
   id INT PRIMARY KEY AUTO_INCREMENT,
   `name` VARCHAR(40),
   money FLOAT
);

INSERT INTO account(`name`,money) VALUES('A',1000);
INSERT INTO account(`name`,money) VALUES('B',1000);
INSERT INTO account(`name`,money) VALUES('C',1000);

模擬轉(zhuǎn)賬

@Test
public void test() {
  //配置信息
  String url="jdbc:mysql://localhost:3306/jdbc?useUnicode=true&characterEncoding=utf-8";
  String username = "root";
  String password = "123456";
  Connection connection = null;
  //加載驅(qū)動
  try {
    Class.forName("com.mysql.jdbc.Driver");
    //連接數(shù)據(jù)庫
    connection = DriverManager.getConnection(url, username, password);
    //通知數(shù)據(jù)庫開啟事務(wù)，false時開啟
    connection.setAutoCommit(false);
    String sql = "update account set money = money-100 where name = 'A'";
    connection.prepareStatement(sql).executeUpdate();
    //制造錯誤
    //int i = 1/0;
    String sql2 = "update account set money = money+100 where name = 'B'";
    connection.prepareStatement(sql2).executeUpdate();
    connection.commit();//以上兩條SQL都執(zhí)行成功了，就提交事務(wù)
    System.out.println("success");
  } catch (Exception e) {
    try {
      //如果出現(xiàn)異常，就通知數(shù)據(jù)庫回滾事務(wù)
      connection.rollback();
    } catch (SQLException e1) {
      e1.printStackTrace();
    }
    e.printStackTrace();
  }finally {
    try {
      connection.close();
    } catch (SQLException e) {
      e.printStackTrace();
    }
  }
}