JDBC基礎(chǔ)

JDBC：

JDBC：Java DataBase Connectivity Java 數(shù)據(jù)庫連接， Java語言操作數(shù)據(jù)庫。JDBC本質(zhì)：其實是官方（sun公司）定義的一套操作所有關(guān)系型數(shù)據(jù)庫的規(guī)則，即接口炮车。各個數(shù)據(jù)庫廠商去實現(xiàn)這套接口，提供數(shù)據(jù)庫驅(qū)動jar包。我們可以使用這套接口（JDBC）編程巾腕，真正執(zhí)行的代碼是驅(qū)動jar包中的實現(xiàn)類。
快速入門：

步驟：

導(dǎo)入驅(qū)動jar包 mysql-connector-java-5.1.37-bin.jar
1.復(fù)制mysql-connector-java-5.1.37-bin.jar到項目的libs目錄下
2.右鍵-->Add As Library
注冊驅(qū)動
獲取數(shù)據(jù)庫連接對象 Connection
定義sql
獲取執(zhí)行sql語句的對象 Statement
執(zhí)行sql絮蒿，接受返回結(jié)果
處理結(jié)果
釋放資源

代碼實現(xiàn)：

public class JDBCDemo1 {
    public static void main(String[] args) throws Exception{
        //1\. 導(dǎo)入驅(qū)動jar包
        //2.注冊驅(qū)動
        Class.forName("com.mysql.jdbc.Driver");
        //3.獲取數(shù)據(jù)庫連接對象
        Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/info", "root", "root");
        //4.定義sql語句
        String sql = "update account set balance = 500 where id = 1";
        //5.獲取執(zhí)行sql的對象 Statement
        Statement stmt = conn.createStatement();
        //6.執(zhí)行sql
        int count = stmt.executeUpdate(sql);
        //7.處理結(jié)果
        System.out.println(count);
        //8.釋放資源
        stmt.close();
        conn.close();
    }
}

詳解各個對象：

DriverManager：驅(qū)動管理對象

功能：

注冊驅(qū)動：告訴程序該使用哪一個數(shù)據(jù)庫驅(qū)動jar
static void registerDriver(Driver driver) :注冊與給定的驅(qū)動程序 DriverManager 尊搬。
寫代碼使用： Class.forName("com.mysql.jdbc.Driver");
通過查看源碼發(fā)現(xiàn)：在com.mysql.jdbc.Driver類中存在靜態(tài)代碼塊

 static {
        try {
            java.sql.DriverManager.registerDriver(new Driver());
        } catch (SQLException E) {
            throw new RuntimeException("Can't register driver!");
        }
    }`

注意：mysql5之后的驅(qū)動jar包可以省略注冊驅(qū)動的步驟。

獲取數(shù)據(jù)庫連接：

方法：static Connection getConnection(String url, String user, String password)
參數(shù)：
- url：指定連接的路徑
  - 語法：jdbc:mysql://ip地址(域名):端口號/數(shù)據(jù)庫名稱
  - 例子：jdbc:mysql://localhost:3306/db3
  - 細節(jié)：如果連接的是本機mysql服務(wù)器土涝，并且mysql服務(wù)默認端口是3306，則url可以簡寫為：jdbc:mysql:///數(shù)據(jù)庫名稱
- user：用戶名
- password：密碼

Connection：數(shù)據(jù)庫連接對象
功能：
獲取執(zhí)行sql 的對象

Statement createStatement()
PreparedStatement prepareStatement(String sql)

管理事務(wù)：

開啟事務(wù)：setAutoCommit(boolean autoCommit) ：調(diào)用該方法設(shè)置參數(shù)為false，即開啟事務(wù)
提交事務(wù)：commit()
回滾事務(wù)：rollback()

Statement：執(zhí)行sql的對象
執(zhí)行sql
boolean execute(String sql) ：可以執(zhí)行任意的sql 了解
int executeUpdate(String sql) ：執(zhí)行DML（insert句柠、update凛驮、delete）語句、DDL(create蜡饵，alter弹渔、drop)語句

返回值：影響的行數(shù)，可以通過這個影響的行數(shù)判斷DML語句是否執(zhí)行成功返回值>0的則執(zhí)行成功溯祸，反之肢专，則失敗。

ResultSet executeQuery(String sql) ：執(zhí)行DQL（select)語句
練習：
account表添加一條記錄
account表修改記錄
account表刪除一條記錄

image

代碼：

public class JDBCDemo2 {

    public static void main(String[] args) {
        Statement stmt = null;
        Connection conn = null;
        try {
            //1\. 注冊驅(qū)動
            Class.forName("com.mysql.jdbc.Driver");
            //2\. 定義sql
            String sql = "insert into account values('王五',null,3000)";
            String sql = "update  account set balance = 1 where id = 2";
            String sql = "delete from account where id = 2";
            //3.獲取Connection對象
            conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/info", "root", "root");
            //4.獲取執(zhí)行sql的對象 Statement
            stmt = conn.createStatement();
            //5.執(zhí)行sql
            int count = stmt.executeUpdate(sql);//影響的行數(shù)
            //6.處理結(jié)果
            System.out.println(count);
            if(count > 0){
                System.out.println("添加成功焦辅！");
            }else{
                System.out.println("添加失敳┱取！");
            }

        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            //stmt.close();
            //7\. 釋放資源
            //避免空指針異常
            if(stmt != null){
                try {
                    stmt.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }

            if(conn != null){
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}

ResultSet：結(jié)果集對象,封裝查詢結(jié)果

boolean next(): 游標向下移動一行氨鹏，判斷當前行是否是最后一行末尾(是否有數(shù)據(jù))欧募，如果是，則返回false仆抵，如果不是則返回true
getXxx(參數(shù)):獲取數(shù)據(jù)
- Xxx：代表數(shù)據(jù)類型如： int getInt() , String getString()
- 參數(shù)：
  1. int：代表列的編號,從1開始如： getString(1)
  2. String：代表列名稱跟继。如： getDouble("balance")
注意：
- 使用步驟：
  1. 游標向下移動一行
  2. 判斷是否有數(shù)據(jù)
  3. 獲取數(shù)據(jù)

//循環(huán)判斷游標是否是最后一行末尾种冬。
while(rs.next()){
    //獲取數(shù)據(jù)
    //6.2 獲取數(shù)據(jù)
    int id = rs.getInt(1);
    String name = rs.getString("name");
    double balance = rs.getDouble(3);

    System.out.println(id + "---" + name + "---" + balance);
}

練習：
定義一個方法，查詢emp表的數(shù)據(jù)將其封裝為對象舔糖，然后裝載集合娱两，返回。

定義Emp類
定義方法 public List<Emp> findAll(){}
實現(xiàn)方法 select * from emp;
PreparedStatement：執(zhí)行sql的對象
SQL注入問題：在拼接sql時金吗，有一些sql的特殊關(guān)鍵字參與字符串的拼接十兢。會造成安全性問題
1. 輸入用戶隨便，輸入密碼：a' or 'a' = 'a
2. sql：select * from user where username = 'fhdsjkf' and password = 'a' or 'a' = 'a'
解決sql注入問題：使用PreparedStatement對象來解決
預(yù)編譯的SQL：參數(shù)使用?作為占位符
步驟：
1. 導(dǎo)入驅(qū)動jar包 mysql-connector-java-5.1.37-bin.jar
2. 注冊驅(qū)動
3. 獲取數(shù)據(jù)庫連接對象 Connection
4. 定義sql
  - 注意：sql的參數(shù)使用摇庙？作為占位符旱物。如：select * from user where username = ? and password = ?;
5. 獲取執(zhí)行sql語句的對象 PreparedStatement Connection.prepareStatement(String sql)
6. 給？賦值：
  - 方法： setXxx(參數(shù)1,參數(shù)2)
    - 參數(shù)1：卫袒？的位置編號從1 開始
    - 參數(shù)2：宵呛？的值
7. 執(zhí)行sql，接受返回結(jié)果夕凝，不需要傳遞sql語句
8. 處理結(jié)果
9. 釋放資源
注意：后期都會使用PreparedStatement來完成增刪改查的所有操作
1. 可以防止SQL注入
2. 效率更高

抽取JDBC工具類： JDBCUtils

目的：簡化書寫
分析：

注冊驅(qū)動也抽取
抽取一個方法獲取連接對象
- 需求：不想傳遞參數(shù)（麻煩）宝穗，還得保證工具類的通用性。
- 解決：配置文件
  jdbc.properties
  url=
  user=
  password=
抽取一個方法釋放資源
Druid：數(shù)據(jù)庫連接池實現(xiàn)技術(shù)码秉，由阿里巴巴提供的
1. 步驟：
  1. 導(dǎo)入jar包 druid-1.0.9.jar
  2. 定義配置文件：
    - 是properties形式的
    - 可以叫任意名稱逮矛，可以放在任意目錄下
  3. 加載配置文件。Properties
  4. 獲取數(shù)據(jù)庫連接池對象：通過工廠來來獲取 DruidDataSourceFactory
  5. 獲取連接：getConnection
- 代碼：
  //3.加載配置文件
  Properties pro = new Properties();
  InputStream is = DruidDemo.class.getClassLoader().getResourceAsStream("druid.properties");
  pro.load(is);
  //4.獲取連接池對象
  DataSource ds = DruidDataSourceFactory.createDataSource(pro);
  //5.獲取連接
  Connection conn = ds.getConnection();
1. 定義工具類
  1. 定義一個類 JDBCUtils
  2. 提供靜態(tài)代碼塊加載配置文件转砖，初始化連接池對象
  3. 提供方法
    1. 獲取連接方法：通過數(shù)據(jù)庫連接池獲取連接
    2. 釋放資源
    3. 獲取連接池的方法

代碼實現(xiàn)：

package com.neusoft.utils;

import com.alibaba.druid.pool.DruidDataSourceFactory;

import javax.sql.DataSource;
import java.io.IOException;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;

/**
 * Druid連接池的工具類
 */
public class JDBCUtils {

    //1.定義成員變量 DataSource
    private static DataSource ds ;

    static{
        try {
            //1.加載配置文件
            Properties pro = new Properties();
            pro.load(JDBCUtils.class.getClassLoader().getResourceAsStream("druid.properties"));
            //2.獲取DataSource
            ds = DruidDataSourceFactory.createDataSource(pro);
        } catch (IOException e) {
            e.printStackTrace();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    /**
     * 獲取連接
     */
    public static Connection getConnection() throws SQLException {
        return ds.getConnection();
    }

    /**
     * 釋放資源
     */
    public static void close(Statement stmt,Connection conn){
       /* if(stmt != null){
            try {
                stmt.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }

        if(conn != null){
            try {
                conn.close();//歸還連接
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }*/

       close(null,stmt,conn);
    }

    public static void close(ResultSet rs , Statement stmt, Connection conn){

        if(rs != null){
            try {
                rs.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }

        if(stmt != null){
            try {
                stmt.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }

        if(conn != null){
            try {
                conn.close();//歸還連接
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

    /**
     * 獲取連接池方法
     */

    public static DataSource getDataSource(){
        return  ds;
    }

}

druid.properties

driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/info
username=root
password=root
# 初始化連接數(shù)量
initialSize=5
# 最大連接數(shù)
maxActive=10
# 最大等待時間
maxWait=3000

JDBC查詢

public class JDBCDemo6 {
    public static void main(String[] args) {
        Connection conn = null;
        Statement stmt = null;
        ResultSet rs = null;
        try {
            //1\. 注冊驅(qū)動
            Class.forName("com.mysql.jdbc.Driver");
            //2.獲取連接對象
            conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/info", "root", "root");

            //3.定義sql
            String sql  = "select * from account";
            //4.獲取執(zhí)行sql對象
            stmt = conn.createStatement();
            //5.執(zhí)行sql
            rs = stmt.executeQuery(sql);
            //6.處理結(jié)果
            //6.1 讓游標向下移動一行
            rs.next();
            //6.2 獲取數(shù)據(jù)
            int id = rs.getInt(2);
            String name = rs.getString("name");
            double balance = rs.getDouble(3);

            System.out.println(id + "---" + name + "---" + balance);

            //6.1 讓游標向下移動一行
            rs.next();
            //6.2 獲取數(shù)據(jù)
            int id2 = rs.getInt(2);
            String name2 = rs.getString("name");
            double balance2 = rs.getDouble(3);

            System.out.println(id2 + "---" + name2 + "---" + balance2);

            //6.1 讓游標向下移動一行
            rs.next();
            //6.2 獲取數(shù)據(jù)
            int id3 = rs.getInt(2);
            String name3 = rs.getString("name");
            double balance3 = rs.getDouble(3);

            System.out.println(id3 + "---" + name3 + "---" + balance3);

        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            //7.釋放資源

            if(rs != null){
                try {
                    rs.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }

            if(stmt != null){
                try {
                    stmt.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }

            if(conn != null){
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    }

}

改寫成循環(huán)

package com.neusoft.jdbc1;

import java.sql.*;

public class JDBCDemo7 {
    public static void main(String[] args) {
        Connection conn = null;
        Statement stmt = null;
        ResultSet rs = null;
        try {
            //1\. 注冊驅(qū)動
            Class.forName("com.mysql.jdbc.Driver");
            //2.獲取連接對象
            conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/info", "root", "root");
            //3.定義sql
            String sql  = "select * from account";
            //4.獲取執(zhí)行sql對象
            stmt = conn.createStatement();
            //5.執(zhí)行sql
            rs = stmt.executeQuery(sql);
            //6.處理結(jié)果
            //循環(huán)判斷游標是否是最后一行末尾须鼎。
            while(rs.next()){

                //獲取數(shù)據(jù)
                //6.2 獲取數(shù)據(jù)
                int id = rs.getInt(2);
                String name = rs.getString("name");
                double balance = rs.getDouble(3);

                System.out.println(id + "---" + name + "---" + balance);
            }

        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            //7.釋放資源

            if(rs != null){
                try {
                    rs.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }

            if(stmt != null){
                try {
                    stmt.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }

            if(conn != null){
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    }

}

分別使用普通方法和連接池進行查詢emp

domain通常就代表了與數(shù)據(jù)庫表--一一對應(yīng)的javaBean

  private Integer id;
    private String ename;
    private String job;
    private Integer mgr;
    private Date hiredate;
    private int salary;
    private int bonus;
    private Integer deptno;

package com.neusoft.jdbc1;

import com.neusoft.domain.Emp;
import com.neusoft.utils.JDBCUtils;

import java.sql.*;
import java.util.ArrayList;
import java.util.List;

/**
 * * 定義一個方法，查詢emp表的數(shù)據(jù)將其封裝為對象堪藐，然后裝載集合莉兰，返回。
 */
public class JDBCDemo8 {

    public static void main(String[] args) {
//        List<Emp> list = new JDBCDemo8().findAll();
        List<Emp> list = new JDBCDemo8().findAll2();
        System.out.println(list);
        System.out.println(list.size());
    }
    /**
     * 查詢所有emp對象
     * @return
     */
    public List<Emp> findAll(){
        Connection conn = null;
        Statement stmt = null;
        ResultSet rs = null;
        List<Emp> list = null;
        try {
            //1.注冊驅(qū)動
            Class.forName("com.mysql.jdbc.Driver");
            //2.獲取連接
            conn = DriverManager.getConnection("jdbc:mysql:///info", "root", "root");
            //3.定義sql
            String sql = "select * from emp";
            //4.獲取執(zhí)行sql的對象
            stmt = conn.createStatement();
            //5.執(zhí)行sql
            rs = stmt.executeQuery(sql);
            //6.遍歷結(jié)果集礁竞，封裝對象糖荒，裝載集合
            Emp emp = null;
            list = new ArrayList<Emp>();
            while(rs.next()){
                //獲取數(shù)據(jù)
                int id = rs.getInt("empno");
                String ename = rs.getString("ename");
                String job = rs.getString("job");
                int mgr = rs.getInt("mgr");
                Date hiredate = rs.getDate("HIREDATE");
                int salary = rs.getInt("sal");
                int bonus = rs.getInt("comm");
                int deptno = rs.getInt("deptno");
                // 創(chuàng)建emp對象,并賦值
                emp = new Emp();
                emp.setId(id);
                emp.setEname(ename);
                emp.setJob(job);
                emp.setMgr(mgr);
                emp.setHiredate(hiredate);
                emp.setSalary(salary);
                emp.setBonus(bonus);
                emp.setDeptno(deptno);

                //裝載集合
                list.add(emp);
            }

        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            if(rs != null){
                try {
                    rs.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }

            if(stmt != null){
                try {
                    stmt.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }

            if(conn != null){
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
        return list;
    }

    /**
     * 演示JDBC工具類
     * @return
     */
    public List<Emp> findAll2(){
        Connection conn = null;
        Statement stmt = null;
        ResultSet rs = null;
        List<Emp> list = null;
        try {

            conn = JDBCUtils.getConnection();
            //3.定義sql
            String sql = "select * from emp";
            //4.獲取執(zhí)行sql的對象
            stmt = conn.createStatement();
            //5.執(zhí)行sql
            rs = stmt.executeQuery(sql);
            //6.遍歷結(jié)果集，封裝對象模捂，裝載集合
            Emp emp = null;
            list = new ArrayList<Emp>();
            while(rs.next()){
                int id = rs.getInt("empno");
                String ename = rs.getString("ename");
                String job = rs.getString("job");
                int mgr = rs.getInt("mgr");
                Date hiredate = rs.getDate("HIREDATE");
                int salary = rs.getInt("sal");
                int bonus = rs.getInt("comm");
                int deptno = rs.getInt("deptno");
                // 創(chuàng)建emp對象,并賦值
                emp = new Emp();
                emp.setId(id);
                emp.setEname(ename);
                emp.setJob(job);
                emp.setMgr(mgr);
                emp.setHiredate(hiredate);
                emp.setSalary(salary);
                emp.setBonus(bonus);
                emp.setDeptno(deptno);

                //裝載集合
                list.add(emp);
            }

        } catch (SQLException e) {
            e.printStackTrace();
        }finally {

            JDBCUtils.close(rs,stmt,conn);
        }
        return list;
    }

}

練習：
需求：

通過鍵盤錄入用戶名和密碼
判斷用戶是否登錄成功
- select * from user where username = "" and password = "";
- 如果這個sql有查詢結(jié)果捶朵，則成功，反之狂男，則失敗

步驟：

創(chuàng)建數(shù)據(jù)庫表 user
CREATE TABLE USER(
id INT PRIMARY KEY AUTO_INCREMENT,
username VARCHAR(32),
PASSWORD VARCHAR(32)
);
INSERT INTO USER VALUES(NULL,'zhangsan','123');
INSERT INTO USER VALUES(NULL,'lisi','234');

package com.neusoft.jdbc1;

import com.neusoft.utils.JDBCUtils;

import java.sql.*;
import java.util.Scanner;

/**
 * 練習：
 *      * 需求：
 *          1\. 通過鍵盤錄入用戶名和密碼
 *          2\. 判斷用戶是否登錄成功
 */
public class JDBCDemo9 {

    public static void main(String[] args) {
        //1.鍵盤錄入综看，接受用戶名和密碼
        Scanner sc = new Scanner(System.in);
        System.out.println("請輸入用戶名：");
        String username = sc.nextLine();
        System.out.println("請輸入密碼：");
        String password = sc.nextLine();
        //2.調(diào)用方法
        boolean flag = new JDBCDemo9().login2(username, password);
        //3.判斷結(jié)果，輸出不同語句
        if(flag){
            //登錄成功
            System.out.println("登錄成功岖食！");
        }else{
            System.out.println("用戶名或密碼錯誤红碑！");
        }

    }

    /**
     * 登錄方法
     */
    public boolean login(String username ,String password){
        if(username == null || password == null){
            return false;
        }
        //連接數(shù)據(jù)庫判斷是否登錄成功
        Connection conn = null;
        Statement stmt =  null;
        ResultSet rs = null;
        //1.獲取連接
        try {
            conn =  JDBCUtils.getConnection();
            //2.定義sql
            String sql = "select * from user where username = '"+username+"' and password = '"+password+"' ";
            System.out.println(sql);
            //3.獲取執(zhí)行sql的對象
            stmt = conn.createStatement();
            //4.執(zhí)行查詢
            rs = stmt.executeQuery(sql);
            //5.判斷
           /* if(rs.next()){//如果有下一行，則返回true
                return true;
            }else{
                return false;
            }*/
           return rs.next();//如果有下一行，則返回true

        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            JDBCUtils.close(rs,stmt,conn);
        }

        return false;
    }

    /**
     * 登錄方法,使用PreparedStatement實現(xiàn)
     */
    public boolean login2(String username ,String password){
        if(username == null || password == null){
            return false;
        }
        //連接數(shù)據(jù)庫判斷是否登錄成功
        Connection conn = null;
        PreparedStatement pstmt =  null;
        ResultSet rs = null;
        //1.獲取連接
        try {
            conn =  JDBCUtils.getConnection();
            //2.定義sql
            String sql = "select * from user where username = ? and password = ?";
            //3.獲取執(zhí)行sql的對象
            pstmt = conn.prepareStatement(sql);
            //給?賦值
            pstmt.setString(1,username);
            pstmt.setString(2,password);
            //4.執(zhí)行查詢,不需要傳遞sql
            rs = pstmt.executeQuery();
            //5.判斷
           /* if(rs.next()){//如果有下一行析珊，則返回true
                return true;
            }else{
                return false;
            }*/
            return rs.next();//如果有下一行羡鸥，則返回true

        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            JDBCUtils.close(rs,pstmt,conn);
        }

        return false;
    }

}

JDBC控制事務(wù)：

事務(wù)：一個包含多個步驟的業(yè)務(wù)操作。如果這個業(yè)務(wù)操作被事務(wù)管理忠寻，則這多個步驟要么同時成功惧浴，要么同時失敗。
操作：
開啟事務(wù)
提交事務(wù)
回滾事務(wù)
使用Connection對象來管理事務(wù)

開啟事務(wù)：setAutoCommit(boolean autoCommit) ：調(diào)用該方法設(shè)置參數(shù)為false奕剃，即開啟事務(wù)
在執(zhí)行sql之前開啟事務(wù)
提交事務(wù)：commit()
當所有sql都執(zhí)行完提交事務(wù)
回滾事務(wù)：rollback()
在catch中回滾事務(wù)

package com.neusoft.jdbc1;

import com.neusoft.utils.JDBCUtils;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;

/**
 * 事務(wù)操作
 */
public class JDBCDemo10 {

    public static void main(String[] args) {
        Connection conn = null;
        PreparedStatement pstmt1 = null;
        PreparedStatement pstmt2 = null;

        try {
            //1.獲取連接
            conn = JDBCUtils.getConnection();
            //開啟事務(wù)
            conn.setAutoCommit(false);

            //2.定義sql
            //2.1 張三 - 500
            String sql1 = "update account set balance = balance - ? where id = ?";
            //2.2 李四 + 500
            String sql2 = "update account set balance = balance + ? where id = ?";
            //3.獲取執(zhí)行sql對象
            pstmt1 = conn.prepareStatement(sql1);
            pstmt2 = conn.prepareStatement(sql2);
            //4\. 設(shè)置參數(shù)
            pstmt1.setDouble(1,500);
            pstmt1.setInt(2,1);

            pstmt2.setDouble(1,500);
            pstmt2.setInt(2,3);
            //5.執(zhí)行sql
            pstmt1.executeUpdate();
            // 手動制造異常
            int i = 3/0;

            pstmt2.executeUpdate();
            //提交事務(wù)
            conn.commit();
        } catch (Exception e) {
            //事務(wù)回滾
            try {
                if(conn != null) {
                    conn.rollback();
                }
            } catch (SQLException e1) {
                e1.printStackTrace();
            }
            e.printStackTrace();
        }finally {
            JDBCUtils.close(pstmt1,conn);
            JDBCUtils.close(pstmt2,conn);
        }

    }

}

作者：method
鏈接：http://www.reibang.com/p/12df3ffa1707
來源：簡書
著作權(quán)歸作者所有衷旅。商業(yè)轉(zhuǎn)載請聯(lián)系作者獲得授權(quán)，非商業(yè)轉(zhuǎn)載請注明出處纵朋。