本文章向大家介紹怎么在Java中利用JDBC實(shí)現(xiàn)一個(gè)事務(wù)功能，主要包括怎么在Java中利用JDBC實(shí)現(xiàn)一個(gè)事務(wù)功能的使用實(shí)例、應(yīng)用技巧、基本知識(shí)點(diǎn)總結(jié)和需要注意事項(xiàng)，具有一定的參考價(jià)值，需要的朋友可以參考一下。

目前成都創(chuàng)新互聯(lián)公司已為1000+的企業(yè)提供了網(wǎng)站建設(shè)、域名、虛擬空間、網(wǎng)站托管、服務(wù)器托管、企業(yè)網(wǎng)站設(shè)計(jì)、容縣網(wǎng)站維護(hù)等服務(wù)，公司將堅(jiān)持客戶導(dǎo)向、應(yīng)用為本的策略，正道將秉承"和諧、參與、激情"的文化，與客戶和合作伙伴齊心協(xié)力一起成長(zhǎng)，共同發(fā)展。

Java是什么

Java是一門(mén)面向?qū)ο缶幊陶Z(yǔ)言，可以編寫(xiě)桌面應(yīng)用程序、Web應(yīng)用程序、分布式系統(tǒng)和嵌入式系統(tǒng)應(yīng)用程序。

1. 轉(zhuǎn)賬業(yè)務(wù)

轉(zhuǎn)賬必須執(zhí)行2個(gè)sql語(yǔ)句（update更新）都成功的情況下，提交事務(wù)，如果有一個(gè)失敗，則2個(gè)都回滾事務(wù)

2. 事務(wù)應(yīng)該具有4個(gè)屬性：原子性、一致性、隔離性、持久性。這四個(gè)屬性通常稱為ACID特性。

① 原子性（atomicity）。一個(gè)事務(wù)是一個(gè)不可分割的工作單位，事務(wù)中包括的諸操作要么都做，要么都不做。
② 一致性（consistency）。事務(wù)必須是使數(shù)據(jù)庫(kù)從一個(gè)一致性狀態(tài)變到另一個(gè)一致性狀態(tài)。一致性與原子性是密切相關(guān)的。
③ 隔離性（isolation）。一個(gè)事務(wù)的執(zhí)行不能被其他事務(wù)干擾。即一個(gè)事務(wù)內(nèi)部的操作及使用的數(shù)據(jù)對(duì)并發(fā)的其他事務(wù)是隔離的，并發(fā)執(zhí)行的各個(gè)事務(wù)之間不能互相干擾。
④ 持久性（durability）。持久性也稱永久性（permanence），指一個(gè)事務(wù)一旦提交，它對(duì)數(shù)據(jù)庫(kù)中數(shù)據(jù)的改變就應(yīng)該是永久性的。接下來(lái)的其他操作或故障不應(yīng)該對(duì)其有任何影響。

3. 這里以轉(zhuǎn)賬操作為案例進(jìn)行演示說(shuō)明，其注意點(diǎn)如下：

(1)一個(gè)sql語(yǔ)句操作不需要手動(dòng)提交事務(wù)

(2)查詢操作也不需要手動(dòng)提交事務(wù)，

(3)但是更新，插入，刪除都需要手動(dòng)提交事務(wù)

(4)余額為負(fù)的可以先查詢出結(jié)果再進(jìn)行判斷，然后再操作

(5)con.setAutoCommit(false);手動(dòng)開(kāi)啟事務(wù)；con.commit();手動(dòng)提交事務(wù)；con.rollback();事務(wù)回滾操作

4. 首先創(chuàng)建一個(gè)數(shù)據(jù)表或者兩個(gè)數(shù)據(jù)表，這里為了演示清楚創(chuàng)建兩個(gè)數(shù)據(jù)表

5. 創(chuàng)建好數(shù)據(jù)庫(kù)和數(shù)據(jù)表，然后進(jìn)行工具類的書(shū)寫(xiě)B(tài)aseDao.java

package com.bie.utils;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
/**
* @author BieHongLi
* @version 創(chuàng)建時(shí)間：2017年2月27日 上午10:09:00
* 連接數(shù)據(jù)庫(kù)的工具類
*/
public class BaseDao {
  private static String driver="com.MySQL.jdbc.Driver";
  private static String url="jdbc:mysql:///test";
  private static String user="root";
  private static String password="123456";
  /***
   * 連接數(shù)據(jù)庫(kù)的方法
   * @return
   * @throws ClassNotFoundException
   * @throws SQLException
   */
  public static Connection getCon() throws ClassNotFoundException, SQLException{
    Class.forName(driver);//加載數(shù)據(jù)庫(kù)驅(qū)動(dòng)
    System.out.println("測(cè)試加載數(shù)據(jù)庫(kù)成功");
    Connection con=DriverManager.getConnection(url, user, password);
    System.out.println("測(cè)試數(shù)據(jù)庫(kù)鏈接成功");
    return con;
  }
  /***
   * 關(guān)閉數(shù)據(jù)庫(kù)的方法
   * @param con
   * @param ps
   * @param rs
   */
  public static void close(Connection con,PreparedStatement ps,ResultSet rs){
    if(rs!=null){//關(guān)閉資源，避免出現(xiàn)異常
      try {
        rs.close();
      } catch (SQLException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
      }
    }
    if(ps!=null){
      try {
        ps.close();
      } catch (SQLException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
      }
    }
    if(con!=null){
      try {
        con.close();
      } catch (SQLException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
      }
    }
  }
  /***
   * 同意增刪改的方法
   * @param sql
   * @param arr
   * @return
   */
  public static boolean addUpdateDelete(String sql,Object[] arr){
    Connection con=null;
    PreparedStatement ps=null;
    try {
      con=BaseDao.getCon();//第一步 ：連接數(shù)據(jù)庫(kù)的操作
      ps=con.prepareStatement(sql);//第二步：預(yù)編譯
      //第三步：設(shè)置值
      if(arr!=null && arr.length!=0){
        for(int i=0;i<arr.length;i++){
          ps.setObject(i+1, arr[i]);
        }
      }
      int count=ps.executeUpdate();//第四步：執(zhí)行sql語(yǔ)句
      if(count>0){
        return true;
      }else{
        return false;
      }
    } catch (ClassNotFoundException e) {
      // TODO Auto-generated catch block
      e.printStackTrace();
    } catch (SQLException e) {
      // TODO Auto-generated catch block
      e.printStackTrace();
    }
    return false;
  }
  /*public static void main(String[] args) {
    try {
      BaseDao.getCon();
    } catch (ClassNotFoundException e) {
      // TODO Auto-generated catch block
      e.printStackTrace();
    } catch (SQLException e) {
      // TODO Auto-generated catch block
      e.printStackTrace();
    }
  }*/
}

6. 這里直接在主方法里面進(jìn)行了測(cè)試，所以寫(xiě)了UserDao進(jìn)行測(cè)試，看效果即可。

package com.bie.dao;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import com.bie.utils.BaseDao;
/**
* @author BieHongLi
* @version 創(chuàng)建時(shí)間：2017年2月27日 下午3:19:49
*
*/
public class UserDao {
  /***
   * 注意點(diǎn)：
   *   (1)一個(gè)sql語(yǔ)句操作不需要手動(dòng)提交事務(wù)
   *   (2)查詢操作也不需要手動(dòng)提交事務(wù)，
   *   (3)但是更新，插入，刪除都需要手動(dòng)提交事務(wù)
   *  (4)余額為負(fù)的可以先查詢出結(jié)果再進(jìn)行判斷，然后再操作
   * @param args
   */
  public static void main(String[] args) {
    Connection con=null;
    PreparedStatement ps1=null;
    PreparedStatement ps2=null;
    try {
      //第一步：連接數(shù)據(jù)庫(kù)的操作
      con=BaseDao.getCon();
      //默認(rèn)自動(dòng)提交事務(wù)，所以默認(rèn)是true,現(xiàn)在將true改為false,禁止默認(rèn)自動(dòng)提交事務(wù)
      //con.setAutoCommit(true);
      //事務(wù)1:如果設(shè)置為false,則需要手動(dòng)提交事務(wù)
      con.setAutoCommit(false);
      //第二步：更新的sql語(yǔ)句
      String sql="update bank_a set usera_rmb=usera_rmb-500 where usera_id=1 ";
      String sql2="update bank_b set userb_rmb=userb_rmb+500 where userb_id=1 ";
      //第三步：預(yù)編譯sql
      ps1=con.prepareStatement(sql);
      //第四步：執(zhí)行sql語(yǔ)句,雖然執(zhí)行了sql，但是還沒(méi)持久化更新到數(shù)據(jù)庫(kù)
      ps1.executeUpdate();
      //第三步：預(yù)編譯sql2
      ps2=con.prepareStatement(sql2);
      //第四步：執(zhí)行sql2,雖然執(zhí)行了sql2，但是還沒(méi)持久化更新到數(shù)據(jù)庫(kù)
      ps2.executeUpdate();
      System.out.println("轉(zhuǎn)賬成功...");
      //事務(wù)2:手動(dòng)提交事務(wù)，如果兩個(gè)都執(zhí)行成功了，那么提交事務(wù)
      con.commit();
    } catch (ClassNotFoundException e) {
      e.printStackTrace();
      try {
        //事務(wù)3:如果拋出異常，那么回滾事務(wù)
        con.rollback();
      } catch (SQLException e1) {
        e1.printStackTrace();
      }
    } catch (SQLException e) {
      e.printStackTrace();
    }finally {
      //關(guān)閉資源，避免出現(xiàn)異常
      BaseDao.close(con, ps1, null);
      BaseDao.close(null, ps2, null);
    }
  }
}

到此這篇關(guān)于怎么在Java中利用JDBC實(shí)現(xiàn)一個(gè)事務(wù)功能的文章就介紹到這了，更多相關(guān)的內(nèi)容請(qǐng)搜索創(chuàng)新互聯(lián)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持創(chuàng)新互聯(lián)！

名稱欄目：怎么在Java中利用JDBC實(shí)現(xiàn)一個(gè)事務(wù)功能
當(dāng)前地址：http://aaarwkj.com/article2/gpigoc.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供軟件開(kāi)發(fā)、動(dòng)態(tài)網(wǎng)站、云服務(wù)器、定制網(wǎng)站、服務(wù)器托管、網(wǎng)站設(shè)計(jì)公司

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源： 創(chuàng)新互聯(lián)