批處理、事務、批處理與事務結合

来源:http://www.cnblogs.com/lwj-0923/archive/2017/08/30/7454921.html
-Advertisement-
Play Games

批處理(batch) >好比快遞員【不能一件一件的送快遞】 - 批處理指的是一次操作中執行多條SQL語句- 批處理相比於一次一次執行效率會提高很多 - 批處理主要是分兩步： 1.將要執行的SQL語句保存 2.執行SQL語句 - Statement和PreparedStatement都支持批處理操作， ...


批處理(batch)------------>好比快遞員【不能一件一件的送快遞】
- 批處理指的是一次操作中執行多條SQL語句
- 批處理相比於一次一次執行效率會提高很多
         
- 批處理主要是分兩步：
1.將要執行的SQL語句保存
2.執行SQL語句
              
- Statement和PreparedStatement都支持批處理操作，這裡我們只需要掌握PreparedStatement的批處理方式：
- 方法：
   void addBatch()
  　　 - 將要執行的SQL先保存起來，先不執行
 　　  - 這個方法在設置完所有的占位符之後調用
   int[] executeBatch()
 　　  - 這個方法用來執行SQL語句，這個方法會將批處理中所有SQL語句執行                          - mysql預設批處理是關閉的，所以我們還需要去打開mysql的批處理： rewriteBatchedStatements=true

url="jdbc:mysql://localhost:3306/test?rewriteBatchedStatements=true"

我們需要將以上的參數添加到mysql的url地址中          
- 註意：低版本的mysql-jdbc驅動也不支持批處理,一般都是在修改的時候使用批處理，查詢的時候不使用！     案例演示：   1.創建一張新的數據表           2.反覆打開資料庫客戶端，插入語句【相當於每次獲取一個connection連接，執行executeUpdate語句】效率不高       3.引出批處理--->執行效率高,資源利用率好！   
public class TestBatch {

      @Test
      public void test() {
            Connection conn = null;
            PreparedStatement ps = null;
            String sql ="insert into test (name) values(?)";
            //Time:368236
            //Time:1393
            try {
                  //獲取連接
                  conn = JDBCUtil.getConnection();
                  ps = conn.prepareStatement(sql);
                  //設置參數
                  for(int i = 0; i < 5000 ;i++){
                        //填充占位符
                        ps.setString(1,"emp_"+i);
                        //添加到批處理方法中，調用無參的，有參的是Statement來調用的！
                        ps.addBatch();
                  }
                  long start = System.currentTimeMillis();
                  //執行批處理
                  ps.executeBatch();
                  long end = System.currentTimeMillis();
                  System.out.println("Time:"+(end-start));
            } catch (SQLException e) {
                  // TODO Auto-generated catch block
                  e.printStackTrace();
            }finally{
                  JDBCUtil.close(conn);
            }
      }
}

 

事務：   演示銀行轉賬的功能： 1.創建一張表示賬號的表               2.向表中插入幾個用戶           3.在資料庫執行sql語句，實現轉賬                 4.從java代碼中演示上面的案例： （1）創建Dao類 
public class AccountDao {
      public void update(Integer id,Integer count){
            Connection conn = null;
            PreparedStatement ps = null;
            try {
                  String sql="UPDATE t_account SET balance = balance + ? WHERE id = ?";
                  conn = JDBCUtil.getConnection();
                  ps = conn.prepareStatement(sql);
                  ps.setInt(1, count);
                  ps.setInt(2, id);

                  ps.executeUpdate();
            } catch (SQLException e) {
                  // TODO Auto-generated catch block
                  e.printStackTrace();
            }finally {
                  JDBCUtil.close(conn);
            }
      }
}

（2）.測試該DAO

@Test
public void test() {
     //孫悟空向豬八戒轉賬100元
     dao.update(1, -100);
     dao.update(2, 100);
}
上面是可以正常執行的   但是如果上面的程式在suwukong減去100元之後，shaheshang加錢之前，出現了異常 第二個 update() 就不會執行，導致數據不一致，一個減少了一個沒增加 
@Test
public void test() {
     //孫悟空向豬八戒轉賬100元
      dao.update(1, -100);
      int a = 10/0;//異常
      dao.update(2, 100);
}

這時候就需要用到 事務！

 

事務的特性（ACID）：   - 原子性（atomicity）      一個事務是一個不可分割的工作單位，事務中包括的諸操作要麼都做，要麼都不做。                     - 一致性（consistency）      事務必須是使資料庫從一個一致性狀態變到另一個一致性狀態。一致性與原子性是密切相關的。   - 隔離性（isolation）      一個事務的執行不能被其他事務干擾。      即一個事務內部的操作及使用的數據對併發的其他事務是隔離的，併發執行的各個事務之間不能互相干擾。                          - 持久性（durability）      持久性也稱永久性（permanence），指一個事務一旦提交，它對資料庫中數據的改變就應該是永久性的。      接下來的其他操作或故障不應該對其有任何影響。                          操作事務的基本步驟：      1.開啟事務           - 開啟事務以後，我們只後的所有操作將都會在同一個事務當中      2.操作資料庫           - 開啟事務以後再去操作資料庫，所有操作將不會直接提交到資料庫中      3.提交事務           - 將修改應用到資料庫      4.回滾事務           - 資料庫操作過程中出現異常了，回滾事務，回滾事務以後，資料庫變成開啟事務之前的狀態              提交事務與回滾事務只能執行其中一條   mysql中的事務控制      #開啟事務           START TRANSACTION      #回滾事務           ROLLBACK                    #提交事務           COMMIT                     ROLLBACK  要與 START TRANSACTION 連用，單獨使用沒用   JDBC中的事務主要通過Connection對象來控制的 1.開啟事務      void setAutoCommit(boolean autoCommit) throws SQLException;           - 設置事務是否自動提交，預設是自動提交           - 設置事務手動提交              conn.setAutoCommit(false);                     2.提交事務 
public class TestAccount {

      private AccountDao dao = new AccountDao();
      @Test
      public void test() {
            Connection conn = null;
            PreparedStatement ps = null;
            conn = JDBCUtil.getConnection();
            //預設true自動提交，false手動提交
            try {
            //開啟事務需要手動提交
                  conn.setAutoCommit(false);
                  //孫悟空向豬八戒轉賬100元
                  dao.update(conn,1, -100);
                  int a = 10/0;//異常
                  dao.update(conn,2, 100);
                  //提交事務
                  conn.commit();
            } catch (SQLException e) {
                  // TODO Auto-generated catch block
                  try {
                        //出現異常就回滾，保持數據一致性
                        conn.rollback();
                  } catch (SQLException e1) {
                        e1.printStackTrace();
                  }
            }finally {
                  try {
                        conn.close();
                  } catch (SQLException e) {
                        e.printStackTrace();
                  }
            }
      }
}
但是結果依舊是一個減少一個沒增加 因為兩次update調用了兩個Connection，本身還有個Connection，一共三個Connection 註意：我們在同一個事務中使用的資料庫連接（Connection）必須是同一個，否則事務還是不作用！             所以將conn 傳給 update() 此時原來的AccountDAO中的update方法要改為如下所示：   
public class AccountDao {
      public void update(Connection conn,Integer id,Integer count){

            PreparedStatement ps = null;
            try {
                  String sql="UPDATE t_account SET balance = balance + ? WHERE id = ?";

                  ps = conn.prepareStatement(sql);
                  ps.setInt(1, count);
                  ps.setInt(2, id);

                  ps.executeUpdate();
            } catch (SQLException e) {
                  e.printStackTrace();
            }finally {
                  //此時也不能在這關閉資料庫，要在外邊統一關閉
                  JDBCUtil.close(null);
            }
      }
}

 

事務與批處理結合   一般是將事務與批處理結合起來寫，更快 
public class TestAccount {

      private AccountDao dao = new AccountDao();
      @Test
      public void test() {
            Connection conn = null;
            PreparedStatement ps = null;
            conn = JDBCUtil.getConnection();
            try {
                  //預設true自動提交，false手動提交
                  //開啟事務需要手動提交
                  conn.setAutoCommit(false);

                  //批處理
                  String sql ="insert into test (name) values(?)";
                  ps = conn.prepareStatement(sql);
                  //設置參數
                  for(int i = 0; i < 5000 ;i++){
                        //填充占位符
                        ps.setString(1,"emp_"+i);
                        //添加到批處理方法中，調用無參的，有參的是Statement來調用的！
                        ps.addBatch();
                  }
                  long start = System.currentTimeMillis();
                  //執行批處理
                  ps.executeBatch();
                  long end = System.currentTimeMillis();
                  System.out.println("Time:"+(end-start));

                  //提交事務
                  conn.commit();
            } catch (SQLException e) {
                  try {
                        conn.rollback();
                  } catch (SQLException e1) {
                        e1.printStackTrace();
                  }
            }finally {
                  try {
                        conn.close();
                  } catch (SQLException e) {
                        e.printStackTrace();
                  }
            }
      }
}

 

 
您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • java-RandomAccessFile操作以及IO流簡單使用
    1.1RandomAccessFile--使用RAF讀寫基本類型數據，以及瞭解Raf的指針操作 write有相對應的寫入基本類型的方法 void seek(Long pos)調整RAF指針位置，可以在寫入時隨時調整指針位置 raf.write(bs);寫入一個字元串數組getBytes("UTF-8 ...
  • SpringBoot(1.5.6.RELEASE)源碼解析(二)
    上一篇分析了@SpringBootApplication註解，接下來從SpringApplication.run(Application.class, args);代碼開始一行行DEBUG進行分析 最終會創建一個SpringApplication的對象，然後調用它的run方法 SpringAppli ...
  • SpringBoot(1.5.6.RELEASE)源碼解析(一)
    啟動SpringBoot，需要在入口函數所在的類上添加@SpringBootApplication註解 我們來看一下@SpringBootApplication註解 從上面的代碼可以看出@SpringBootApplication = @Configuration + @EnableAutoConf ...
  • String的存儲過程
    我們知道字元有兩種初始化方式： String　s1 = “abc”; String　s2 = new String（"def"）; 這兩種有什麼區別呢？這時就需要我們看看String的在記憶體中是怎麼存儲的了。我們先看下麵的圖瞭解其在記憶體在是怎麼存儲的： 首先是 String　s1 = “abc”;它 ...
  • 爬蟲必備—BeautifulSoup
    BeautifulSoup是一個模塊，該模塊用於接收一個HTML或XML字元串，然後將其進行格式化，之後便可以使用他提供的方法進行快速查找指定元素，從而使得在HTML或XML中查找指定元素變得簡單。 1 from bs4 import BeautifulSoup 2 3 html_doc = """ ...
  • 1、python全棧之路-數據類型
    一、數據類型 數據類型，相同類的值（指定類的對象）具有相同的功能，功能保存在類中（只有一份） 1、整數（int類） 1,2,3,4.......99.... bit_length() 當前十進位用二進位表示時，最少使用的位數 v = 15# 當前十進位用二進位表示時，最少使用的位數data = v. ...
  • 學習正則表達式筆記（二）
    正則匹配的各種模式 1.擇一匹配（|） 擇一匹配用管道符號（|），也就是豎線表示。代表可以從多個模式中選擇一個，可用於分割正則表達式。例如： ABC | abc 表示即可以匹配 ABC，又可以匹配 abc。 2.匹配任意單個字元 3.從字元串起始或者結尾或者單詞邊界匹配 例如： \bthe，匹配以 ...
  • JSP的四個作用域
    JSP的作用域一般是對於變數而言的，描述的是變數在某處是否有效（可用） 1.第一個作用域是page，只在當前頁面有效。也就是用戶請求的頁面有效，噹噹前頁面關閉或轉到其他頁面時，page對象將在響應回饋給客戶端後釋放。 2.第二個作用域是request，在當前請求中有效。request可以通過setA ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類