//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);

        }

    }