CREATE TABLE `test_page1`  (
  `id` int(11)  NULL,
  `username` int(252) not  NULL,
  `password` int(252)  NULL,
  `create_time` varchar(100) CHARACTER SET utf8 COLLATE utf8_general_ci not NULL ,
  `update_time` datetime(0) NULL DEFAULT NULL,
  PRIMARY KEY (`create_time`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 1000001 CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Dynamic;

public class Connect {
    //    導(dǎo)入驅(qū)動(dòng)jar包或添加Maven依賴（這里使用的是Maven，Maven依賴代碼附在文末）
    static {
        try {
            Class.forName("com.mysql.cj.jdbc.Driver");
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }
    }
    //  獲取數(shù)據(jù)庫連接對(duì)象
    public static Connection getConn() {
        Connection conn = null;
        try {
            //  rewriteBatchedStatements=true,一次插入多條數(shù)據(jù)，只插入一次
            conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/xxx?rewriteBatchedStatements=true", "root", "xxx");
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        }
        return conn;
    }
    //  釋放資源
    public static void closeAll(AutoCloseable... autoCloseables) {
        for (AutoCloseable autoCloseable : autoCloseables) {
            if (autoCloseable != null) {
                try {
                    autoCloseable.close();
                } catch (Exception e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }
        }
    }
}

public class InsertData {
    private static ThreadPoolExecutor getDefaultThreadPool() {
        ThreadPoolExecutor result = new ThreadPoolExecutor(0, 1000, 1, TimeUnit.SECONDS, new SynchronousQueue<>());
        result.setThreadFactory(new ThreadFactory() {
            @Override
            public Thread newThread(Runnable r) {
                return new Thread(r, "deterministic runner thread");
            }
        });
        return result;
    }
    /*  因?yàn)閿?shù)據(jù)庫的處理速度是非常驚人的 單次吞吐量很大 執(zhí)行效率極高
    addBatch()把若干sql語句裝載到一起，然后一次送到數(shù)據(jù)庫執(zhí)行，執(zhí)行需要很短的時(shí)間
    而preparedStatement.executeUpdate() 是一條一條發(fā)往數(shù)據(jù)庫執(zhí)行的 時(shí)間都消耗在數(shù)據(jù)庫連接的傳輸上面*/
    public static void main(String[] args) {
            for (int j = 0; j < 100; j++) {
                long start = System.currentTimeMillis();    //  獲取系統(tǒng)當(dāng)前時(shí)間，方法開始執(zhí)行前記錄
                Connection conn = Connect.getConn();        //  調(diào)用剛剛寫好的用于獲取連接數(shù)據(jù)庫對(duì)象的靜態(tài)工具類
                String sql = "insert into test_page1 values(null,?,?,?,NOW())";  //  要執(zhí)行的sql語句
                PreparedStatement ps = null;
                getDefaultThreadPool().execute(() -> {
                    try {
                    PreparedStatement finalPs = conn.prepareStatement(sql);
                        //  不斷產(chǎn)生sql
                        for (int i = 0; i < 20000; i++) {
                            finalPs.setString(1, Math.ceil(Math.random() * 1000000) + "");
                            finalPs.setString(2, Math.ceil(Math.random() * 1000000) + "");
                            finalPs.setString(3, UUID.randomUUID().toString());  //  UUID該類用于隨機(jī)生成一串不會(huì)重復(fù)的字符串
                            finalPs.addBatch();  //  將一組參數(shù)添加到此 PreparedStatement 對(duì)象的批處理命令中。
                        }
                        int[] ints = new int[0];//   將一批命令提交給數(shù)據(jù)庫來執(zhí)行，如果全部命令執(zhí)行成功，則返回更新計(jì)數(shù)組成的數(shù)組。
                        ints = finalPs.executeBatch();
                        //  如果數(shù)組長度不為0，則說明sql語句成功執(zhí)行，即數(shù)據(jù)添加成功！
                        if (ints.length > 0) {
                            System.out.println("數(shù)據(jù)添加成功！！");
                        }
                    } catch (SQLException e) {
                        throw new RuntimeException(e);
                    }finally {
                        Connect.closeAll(conn, ps);  //  調(diào)用剛剛寫好的靜態(tài)工具類釋放資源
                    }
                  });
                long end = System.currentTimeMillis();  //  再次獲取系統(tǒng)時(shí)間
                System.out.println("所用時(shí)長:" + (end - start) / 1000 + "秒");  //  兩個(gè)時(shí)間相減即為方法執(zhí)行所用時(shí)長
            }
    }
}

alter table test_page1 add index create_time_index(create_time)

BEGIN;
select * from test_page1 where username = 852;

alter table test_page1 add index create_time_index(create_time)

insert into test_page1(id,username,password,create_time,update_time) values(null,1,2,'6144423733',NOW());