JAVA如何对数据库执行批量操作


转载自:   http://linduo168.iteye.com/blog/1887328

在传统关系型数据库当中,如何对数据库执行批量操作呢 ? 我们了解到在JDBC的底层有 executeBatch操作 。

 

实现批处理有两种方式, 
            第一种方式: Statement.addBatch(sql) (其实是将sql语句 放在了一个 list 集合中。) 
            第二种方式: PreparedStatement.addBatch() (其实是将sql语句 放在了一个 list 集合中。) 

   执行批处理SQL语句 
            executeBatch()方法:执行批处理命令 
            clearBatch()方法:清除批处理命令(实际上是清除 List集合中的SQL语句,否则会造成内存溢出。) 
    接下去比较2种方法的优缺点,可以更好的在实际工作场景中得以更好的应用。 
    第一种方式:Statement.addBatch(sql) 
   采用Statement.addBatch(sql)方式实现批处理的优缺点 
        优点:可以向数据库发送多条不同的SQL语句。 
        缺点:SQL语句没有预编译。当向数据库发送多条语句相同,但仅参数不同的SQL语句时,需重复写上很多条SQL语句。 
Demo样例: 
     @Test 
public void test1() throws SQLException{ 
            Connection conn = null; 
            Statement st = null; 
            ResultSet rs = null; 
            try { 
                    conn = JdbcUtil.getConnection(); 
                    String sql1 = "insert into user(name,password,email,birthday)  values('kkk','123','abc@sina.com','1978-08-08')"; 
                    String sql2 = "update user set password='123456' where id=3"; 
                    st = conn.createStatement(); 
                    st.addBatch(sql1);  //把SQL语句加入到批命令中 
                    st.addBatch(sql2);  //把SQL语句加入到批命令中 
                    st.executeBatch(); 
                    st.clearBatch(); 
            } finally{ 
                 JdbcUtil.free(conn, st, rs); 
            } 


方法二、实现批处理的第二种方式:PreparedStatement.addBatch() 
    优点:发送的是预编译后的SQL语句,执行效率高。 
    缺点:只能应用在SQL语句相同,但参数不同的批处理中。因此此种形式的批处理经常用于在同一个表中批量插入数据,或批量更新表的数据。 
    Demo样例: 
@Test 
public void test2() throws SQLException{ 
        conn = JdbcUtil.getConnection(); 
        String sql = "insert into user(name,password,email,birthday) values(?,?,?,?)"; 
        st = conn.prepareStatement(sql); 
        for(int i=0;i<50000;i++){ 
                st.setString(1, "aaa" + i); 
                st.setString(2, "123" + i); 
                st.setString(3, "aaa" + i + "@sina.com"); 
                st.setDate(4,new Date(1980, 10, 10)); 
                st.addBatch(); 
                if(i%1000==0){      //为防止(list集合) 内存溢出:设定每累加1000条数据就向数据库发送一次 
                        st.executeBatch(); 
                        st.clearBatch(); 
                } 
        } 
        st.executeBatch(); //当剩余的条数小于1000条时就不会被发送到数据库,所以此处要在发送一次。 


免责声明!

本站转载的文章为个人学习借鉴使用,本站对版权不负任何法律责任。如果侵犯了您的隐私权益,请联系本站邮箱yoyou2525@163.com删除。



 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM