conn = DriverManager.getConnection(JDBC_URL, JDBC_USER, JDBC_PASS);         pstmt = conn                 .prepareStatement("insert into loadtest (id, data) values (?, ?)");         for (int i = 1; i <= COUNT; i++) {             pstmt.clearParameters();             pstmt.setInt(1, i);             pstmt.setString(2, DATA);             pstmt.execute();         }

conn = DriverManager.getConnection(JDBC_URL, JDBC_USER, JDBC_PASS);         conn.setAutoCommit(false);         pstmt = conn                 .prepareStatement("insert into loadtest (id, data) values (?, ?)");         for (int i = 1; i <= COUNT; i++) {             pstmt.clearParameters();             pstmt.setInt(1, i);             pstmt.setString(2, DATA);             pstmt.execute();             if (i % COMMIT_SIZE == 0) {                 conn.commit();             }         }         conn.commit();

conn = DriverManager.getConnection(JDBC_URL                 + "?rewriteBatchedStatements=true", JDBC_USER, JDBC_PASS);         conn.setAutoCommit(false);         pstmt = conn                 .prepareStatement("insert into loadtest (id, data) values (?, ?)");         for (int i = 1; i <= COUNT; i += BATCH_SIZE) {             pstmt.clearBatch();             for (int j = 0; j < BATCH_SIZE; j++) {                 pstmt.setInt(1, i + j);                 pstmt.setString(2, DATA);                 pstmt.addBatch();             }             pstmt.executeBatch();             if ((i + BATCH_SIZE - 1) % COMMIT_SIZE == 0) {                 conn.commit();             }         }         conn.commit();

conn = DriverManager.getConnection(JDBC_URL, JDBC_USER, JDBC_PASS);         conn.setAutoCommit(false);         pstmt = conn.prepareStatement("load data local infile '' "                 + "into table loadtest fields terminated by ','");         StringBuilder sb = new StringBuilder();         for (int i = 1; i <= COUNT; i++) {             sb.append(i + "," + DATA + "\n");             if (i % COMMIT_SIZE == 0) {                 InputStream is = new ByteArrayInputStream(sb.toString()                         .getBytes());                 ((com.mysql.jdbc.Statement) pstmt)                         .setLocalInfileInputStream(is);                 pstmt.execute();                 conn.commit();                 sb.setLength(0);             }         }         InputStream is = new ByteArrayInputStream(sb.toString().getBytes());         ((com.mysql.jdbc.Statement) pstmt).setLocalInfileInputStream(is);         pstmt.execute();         conn.commit();