摘要：今天在網(wǎng)上看到一篇博文，題目是分鐘插入萬(wàn)條數(shù)據(jù)到數(shù)據(jù)庫(kù)中，覺(jué)得很有意思，就記錄下來(lái)供自己學(xué)習(xí)。版本，設(shè)置數(shù)據(jù)庫(kù)表的容量數(shù)據(jù)庫(kù)表的默認(rèn)容量是，如果存儲(chǔ)的數(shù)據(jù)超限的話會(huì)報(bào)錯(cuò)。在控制臺(tái)輸入進(jìn)入數(shù)據(jù)庫(kù)，輸入注意后邊的分號(hào)。

今天在網(wǎng)上看到一篇博文，題目是：4分鐘插入1000萬(wàn)條數(shù)據(jù)到mysql數(shù)據(jù)庫(kù)中，覺(jué)得很有意思，就記錄下來(lái)供自己學(xué)習(xí)。
MySQL版本：mysql-5.7.22-winx64

數(shù)據(jù)庫(kù)表的默認(rèn)容量是:4M，如果存儲(chǔ)的數(shù)據(jù)超限的話會(huì)報(bào)錯(cuò)。
在windows控制臺(tái)輸入mysql -uroot -p,進(jìn)入MySql數(shù)據(jù)庫(kù)，輸入set global max_allowed_packet = 100*1024*1024;注意后邊的分號(hào)。

    public static void main(String[] args) {
        final String driver = "com.mysql.jdbc.Driver";
        final String url = "jdbc:mysql://localhost:3306/project";
        final String user = "root";
        final String password = "253432";
        Connection conn = null;
        PreparedStatement pst =  null;
        long beginTime = 0;
        long endTime = 0;
        try {
            Class.forName(driver);//指定連接類型
            conn = DriverManager.getConnection(url, user, password);
            if(conn != null) {
                System.out.println("獲取連接成功");
                beginTime = new Date().getTime();//開(kāi)始計(jì)時(shí)
                String sqlPrefix = "insert into test (id,num) values ";
                // 保存sql后綴
                StringBuffer suffix = new StringBuffer();
                // 設(shè)置事務(wù)為非自動(dòng)提交
                conn.setAutoCommit(false);
                // 比起st，pst會(huì)更好些
                pst = (PreparedStatement) conn.prepareStatement("");//準(zhǔn)備執(zhí)行語(yǔ)句
                // 外層循環(huán)，總提交事務(wù)次數(shù)
                for (int i = 1; i <= 100; i++) {
                    suffix = new StringBuffer();
                    // 第j次提交步長(zhǎng)
                    for (int j = 1; j <= 100000; j++) {
                        // 構(gòu)建SQL后綴
                        suffix.append("(""+ UUID.randomUUID().toString()+"",""+i*j+"""+"),");
                    }
                    // 構(gòu)建完整SQL
                    String sql = sqlPrefix + suffix.substring(0, suffix.length() - 1);
                    // 添加執(zhí)行SQL
                    pst.addBatch(sql);
                    // 執(zhí)行操作
                    pst.executeBatch();
                    // 提交事務(wù)
                    conn.commit();
                    // 清空上一次添加的數(shù)據(jù)
                    suffix = new StringBuffer();
                }
                endTime = new Date().getTime();//開(kāi)始計(jì)時(shí)
            }else {
                System.out.println("數(shù)據(jù)庫(kù)連接失敗");
            }
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
            System.out.println("com.mysql.jdbc.Driver驅(qū)動(dòng)類沒(méi)有找到");
        } catch (SQLException e) {
            e.printStackTrace();
            System.out.println("數(shù)據(jù)庫(kù)地址錯(cuò)誤");
        }finally {//釋放資源
            System.out.println("插入成功，所有時(shí)間："+ (endTime-beginTime));
            if(conn != null) {
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if(pst != null) {
                try {
                    pst.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
        
    }

可以看到用了兩分鐘