【郑州校区】JDBC的批处理操作 - 黑马程序员技术交流社区

【郑州校区】JDBC的批处理操作

之前进行JDBC的操作的时候，都是一条SQL语句执行。现在如果使用批处理，可以将一批SQL一起执行。

[AppleScript] 纯文本查看 复制代码

@Test

        /**

         * 批处理基本操作

         */

        public void demo1(){

                Connection conn = null;

                Statement stmt = null;

                try{

                        // 获得连接:

                        conn = JDBCUtils.getConnection();

                        // 创建执行批处理对象:

                        stmt = conn.createStatement();

                        // 编写一批SQL语句：

                        String sql1 = "create database test1";

                        String sql2 = "use test1";

                        String sql3 = "create table user(id int primary key auto_increment,name varchar(20))";

                        String sql4 = "insert into user values (null,'aaa')";

                        String sql5 = "insert into user values (null,'bbb')";

                        String sql6 = "insert into user values (null,'ccc')";

                        String sql7 = "update user set name = 'mmm' where id = 2";

                        String sql8 = "delete from user where id = 1";

                        // 添加到批处理

                        stmt.addBatch(sql1);

                        stmt.addBatch(sql2);

                        stmt.addBatch(sql3);

                        stmt.addBatch(sql4);

                        stmt.addBatch(sql5);

                        stmt.addBatch(sql6);

                        stmt.addBatch(sql7);

                        stmt.addBatch(sql8);

                        // 执行批处理:

                        stmt.executeBatch();

                }catch(Exception e){

                        e.printStackTrace();

                }finally{

                        JDBCUtils.release(stmt, conn);

                }

        }

[AppleScript] 纯文本查看 复制代码

@Test

        /**

         * 批量插入记录:

         * * 默认情况下MySQL批处理没有开启的，需要在url后面拼接一个参数即可。

         */

        public void demo2(){

                // 记录开始时间:

                long begin = System.currentTimeMillis();

                Connection conn = null;

                PreparedStatement pstmt = null;

                try{

                        // 获得连接:

                        conn = JDBCUtils.getConnection();

                        // 编写SQL语句：

                        String sql = "insert into user values (null,?)";

                        // 预编译SQL:

                        pstmt = conn.prepareStatement(sql);

                        for(int i=1;i<=10000;i++){

                                pstmt.setString(1, "name"+i);

                                // 添加到批处理

                                pstmt.addBatch();

                                // 注意问题：

                                // 执行批处理

                                if(i % 1000 == 0){

                                        // 执行批处理:

                                        pstmt.executeBatch();

                                        // 清空批处理:

                                        pstmt.clearBatch();

                                }

                        }

                }catch(Exception e){

                        e.printStackTrace();

                }finally{

                        JDBCUtils.release(pstmt, conn);

                }

                long end = System.currentTimeMillis();

                System.out.println((end-begin));

        }

传智播客·黑马程序员郑州校区地址

河南省郑州市高新区长椿路11号大学科技园（西区）东门8号楼三层

联系电话 0371-56061160/61/62

来校路线地铁一号线梧桐街站A口出