7_ PreparedStatement批处理

向右看齐 2023-09-30 19:53 3阅读 0赞

PreparedStatement批处理

什么是批处理?

当我们有多条sql语句需要发送到数据库执行的时候，有两种发送方式，一种是执行一条发送一条sql语句给数据库,另一个种是发送一个sql集合给数据库，也就是发送一个批sql到数据库。普通的执行过程是：每处理一条数据，就访问一次数据库；而批处理是：累积到一定数量，再一次性提交到数据库，减少了与数据库的交互次数，所以效率会大大提高,很显然两者的数据库执行效率是不同的，我们发送批处理sql的时候数据库执行效率要高

statement语句对象实现批处理有如下问题

缺点：采用硬编码效率低，安全性较差。

原理：硬编码，每次执行时相似SQL都会进行编译

PreparedStatement+批处理

优点：语句只编译一次，减少编译次数。提高了安全性（阻止了SQL注入）

原理：相似SQL只编译一次，减少编译次数

注意: 需要设置批处理开启&rewriteBatchedStatements=true

package com.msb.test4;
    import java.sql.*;
    /**
     * @Author: Ma HaiYang
     * @Description: MircoMessage:Mark_7001
     */
    public class TestBatch {
        private static String driver ="com.mysql.cj.jdbc.Driver";
        private static String url="jdbc:mysql://127.0.0.1:3306/mydb?useSSL=false&useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true&useServerPrepStmts=true&cachePrepStmts=true&&rewriteBatchedStatements=true";
        private static String user="root";
        private static String password="root";
        public static void main(String[] args) {
            testAddBatch();
        }
        // 定义一个方法,向部门表增加1000条数据
        public static void testAddBatch(){
            Connection connection = null;
            PreparedStatement preparedStatement=null;
            try{
                Class.forName(driver);
                connection = DriverManager.getConnection(url, user,password);
                String sql="insert into dept values (DEFAULT ,?,?)";
                preparedStatement = connection.prepareStatement(sql);//这里已经传入SQL语句
                //设置参数
                for (int i = 1; i <= 10663; i++) {
                    preparedStatement.setString(1, "name");
                    preparedStatement.setString(2, "loc");
                    preparedStatement.addBatch();// 将修改放入一个批次中
                    if(i%1000==0){
                        preparedStatement.executeBatch();
                        preparedStatement.clearBatch();// 清除批处理中的数据
                    }
                }
                /*
                * 整数数组中的元素代表执行的结果代号
                * SUCCESS_NO_INFO -2
                * EXECUTE_FAILED  -3
                * */
                /*int[] ints = */
                preparedStatement.executeBatch();
                preparedStatement.clearBatch();
            }catch (Exception e){
                e.printStackTrace();
            }finally {
                if(null != preparedStatement){
                    try {
                        preparedStatement.close();
                    } catch (SQLException e) {
                        e.printStackTrace();
                    }
                }
                if(null != connection){
                    try {
                        connection.close();
                    } catch (SQLException e) {
                        e.printStackTrace();
                    }
                }
            }
        }
    }

![df35a1ccca6b8b3b513450542daca366.gif][]

![9f55f3149dddc69e2b3dbf943695555a.gif][]

[df35a1ccca6b8b3b513450542daca366.gif]: https://img-blog.csdnimg.cn/img_convert/df35a1ccca6b8b3b513450542daca366.gif
[9f55f3149dddc69e2b3dbf943695555a.gif]: https://img-blog.csdnimg.cn/img_convert/9f55f3149dddc69e2b3dbf943695555a.gif