Mysql的預編譯和批處理


MySQL的預編譯功能

預編譯的好處

大家平時都使用過JDBC中的PreparedStatement接口,它有預編譯功能。什么是預編譯功能呢?它有什么好處呢?

當客戶發送一條SQL語句給服務器后,服務器總是需要校驗SQL語句的語法格式是否正確,然后把SQL語句編譯成可執行的函數,最后才是執行SQL語句。其中校驗語法,和編譯所花的時間可能比執行SQL語句花的時間還要多。

如果我們需要執行多次insert語句,但只是每次插入的值不同,MySQL服務器也是需要每次都去校驗SQL語句的語法格式,以及編譯,這就浪費了太多的時間。如果使用預編譯功能,那么只對SQL語句進行一次語法校驗和編譯,所以效率要高。

 

MySQL執行預編譯

MySQL執行預編譯分為如三步:

  • 執行預編譯語句,例如:prepare myfun from 'select * from t_book where bid=?'
  • 設置變量,例如:set @str='b1'
  • 執行語句,例如:execute myfun using @str

 

如果需要再次執行myfun,那么就不再需要第一步,即不需要再編譯語句了:

  • 設置變量,例如:set @str='b2'
  • 執行語句,例如:execute myfun using @str

 

通過查看MySQL日志可以看到執行的過程:

 

使用Statement執行預編譯

使用Statement執行預編譯就是把上面的SQL語句執行一次。

        Connection con = JdbcUtils.getConnection();

        Statement stmt = con.createStatement();

        stmt.executeUpdate("prepare myfun from 'select * from t_book where bid=?'");

        stmt.executeUpdate("set @str='b1'");

        ResultSet rs = stmt.executeQuery("execute myfun using @str");

        while(rs.next()) {

            System.out.print(rs.getString(1) + ", ");

            System.out.print(rs.getString(2) + ", ");

            System.out.print(rs.getString(3) + ", ");

            System.out.println(rs.getString(4));

        }

        

        stmt.executeUpdate("set @str='b2'");

        rs = stmt.executeQuery("execute myfun using @str");

        

        while(rs.next()) {

            System.out.print(rs.getString(1) + ", ");

            System.out.print(rs.getString(2) + ", ");

            System.out.print(rs.getString(3) + ", ");

            System.out.println(rs.getString(4));

        }

        

        rs.close();

        stmt.close();

        con.close();

 

useServerPrepStmts參數

默認使用PreparedStatement是不能執行預編譯的,這需要在url中給出useServerPrepStmts=true參數(MySQL Server 4.1之前的版本是不支持預編譯的,而Connector/J在5.0.5以后的版本,默認是沒有開啟預編譯功能的)。

例如:jdbc:mysql://localhost:3306/test?useServerPrepStmts=true

  這樣才能保證mysql驅動會先把SQL語句發送給服務器進行預編譯,然后在執行executeQuery()時只是把參數發送給服務器。

        Connection con = JdbcUtils.getConnection();

        String sql = "select * from t_book where bid=?";

        PreparedStatement pstmt = con.prepareStatement(sql);

        

        pstmt.setString(1, "b1");

        ResultSet rs = pstmt.executeQuery();

        while(rs.next()) {

            System.out.print(rs.getString(1) + ", ");

            System.out.print(rs.getString(2) + ", ");

            System.out.print(rs.getString(3) + ", ");

            System.out.println(rs.getString(4));

        }

        

        pstmt.setString(1, "b2");

        rs = pstmt.executeQuery();

        while(rs.next()) {

            System.out.print(rs.getString(1) + ", ");

            System.out.print(rs.getString(2) + ", ");

            System.out.print(rs.getString(3) + ", ");

            System.out.println(rs.getString(4));

        }

        

        rs.close();

        pstmt.close();

        con.close();

 

cachePrepStmts參數

當使用不同的PreparedStatement對象來執行相同的SQL語句時,還是會出現編譯兩次的現象,這是因為驅動沒有緩存編譯后的函數key,導致二次編譯。如果希望緩存編譯后函數的key,那么就要設置cachePrepStmts參數為true。例如:

jdbc:mysql://localhost:3306/test?useServerPrepStmts=true&cachePrepStmts=true

 

        Connection con = JdbcUtils.getConnection();

        String sql = "select * from t_book where bid=?";

        PreparedStatement pstmt = con.prepareStatement(sql);

        

        pstmt.setString(1, "b1");

        ResultSet rs = pstmt.executeQuery();

        while(rs.next()) {

            System.out.print(rs.getString(1) + ", ");

            System.out.print(rs.getString(2) + ", ");

            System.out.print(rs.getString(3) + ", ");

            System.out.println(rs.getString(4));

        }

        

        pstmt = con.prepareStatement(sql);

        pstmt.setString(1, "b2");

        rs = pstmt.executeQuery();

        while(rs.next()) {

            System.out.print(rs.getString(1) + ", ");

            System.out.print(rs.getString(2) + ", ");

            System.out.print(rs.getString(3) + ", ");

            System.out.println(rs.getString(4));

        }

        

        rs.close();

        pstmt.close();

        con.close();

 

打開批處理

MySQL的批處理也需要通過參數來打開:rewriteBatchedStatements=true

 

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM