CREATE TABLE `auto_inc_test` (

  `id` bigint(20) NOT NULL AUTO_INCREMENT,

  `time` bigint(20) NOT NULL,

  PRIMARY KEY (`time`,`id`)

) ENGINE=TokuDB AUTO_INCREMENT=1001 DEFAULT CHARSET=latin1 `compression`='tokudb_zlib'

ALTER TABLE order_books partition by range (time) (

    partition p0 values less than (1507495611880)

);

public class MultipleClientsInsertingDataIntoPartitionedTokudbTable {

    public static final String INSERT_STATEMENT = "INSERT INTO test.auto_inc_test (time) values (?)";

    private final CountDownLatch countDownLatch;

    public MultipleClientsInsertingDataIntoPartitionedTokudbTable() {

        countDownLatch = new CountDownLatch(2);

    }

    public static void main(String[] args) throws InterruptedException {

        MultipleClientsInsertingDataIntoPartitionedTokudbTable multipleClientsInsertingDataIntoPartitionedTokudbTable = new MultipleClientsInsertingDataIntoPartitionedTokudbTable();

        multipleClientsInsertingDataIntoPartitionedTokudbTable.start();

    }

    private void start() throws InterruptedException {

        DataSource dataSource = createDataSource();

        new Thread(new InsertRunnable(dataSource)).start();

        new Thread(new InsertRunnable(dataSource)).start();

        countDownLatch.await();

    }

    private DataSource createDataSource() {

        String jdbcUrl = "jdbc:mysql://xxx.xxx.xxx.xxx/test?tcpNoDelay=true&tcpKeepAlive=true&rewriteBatchedStatements=true";

        String username = "user";

        String password = "password";

        MysqlDataSource mysqlDataSource = new MysqlDataSource();

        mysqlDataSource.setURL(jdbcUrl);

        mysqlDataSource.setUser(username);

        mysqlDataSource.setPassword(password);

        return mysqlDataSource;

    }

    private void insertData(DataSource dataSource) {

        try (Connection connection = dataSource.getConnection();

                PreparedStatement preparedStatement = connection

                        .prepareStatement(INSERT_STATEMENT)) {

            connection.setAutoCommit(false);

            for (int i = 0; i < 1000; i++) {

                preparedStatement.setLong(1, System.currentTimeMillis());

                preparedStatement.addBatch();

            }

            preparedStatement.executeBatch();

        } catch (SQLException e) {

            e.printStackTrace();

        }

    }

    private class InsertRunnable implements Runnable {

        private final DataSource dataSource;

        private InsertRunnable(DataSource dataSource) {

            this.dataSource = dataSource;

        }

        @Override

        public void run() {

            for (int i = 0; i < 1000; i++) {

                insertData(dataSource);

            }

            countDownLatch.countDown();

        }

    }

}