【MySql】Java 批量插入數據庫addBatch


//addBatch批量插入數據庫
    public static void insertCommentToMySql(Set<String> commentList) {
        
        Iterator<String> it = commentList.iterator(); 
        
        Statement st=null;
        try {
            st = DBConnection.getConnection(dbName,dbUser,dbPwd).createStatement();
        } catch (SQLException e1) {
            // TODO Auto-generated catch block
            e1.printStackTrace();
        };
        
        String sql = null;
        String[] strs=null;
        while (it.hasNext()) { 
            strs = it.next().split("\\|");
            //0zid,1zname,2zmid,3ztext,4zsource,5zzan,6ztime
            sql="insert into weibo_comment(uid,name,mid,text,source,zan,time) values ('"+strs[0]+"','"+strs[1]+"','"+strs[2]+"','"+strs[3]+"','"+strs[4]+"','"+strs[5]+"','"+strs[6]+"') ON DUPLICATE KEY UPDATE updatetime=NOW()";
//            System.out.println(sql);
            try {
                st.addBatch(sql);
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }  
        
        try {
            st.executeBatch();
            st.clearBatch();
            st.close();
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            logger.error(e);
        }

    }

  


免責聲明!

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



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