Skip to content

Instantly share code, notes, and snippets.

@mh-github
Created July 13, 2014 09:06
Insert 20,000 records into MySQL
//STEP 1. Import required packages
import java.sql.*;
public class MySQL_Insert
{
// JDBC driver name and database URL
static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";
static final String DB_URL = "jdbc:mysql://localhost/test";
// Database credentials
static final String USER = "root";
static final String PASS = "root";
public static void main(String[] args)
{
Connection conn = null;
Statement stmt = null;
try {
// STEP 2: Register JDBC driver
Class.forName("com.mysql.jdbc.Driver");
// STEP 3: Open a connection
System.out.println("Connecting to test database...");
conn = DriverManager.getConnection(DB_URL, USER, PASS);
System.out.println("Connected database successfully...");
// STEP 4: Execute a query
System.out.println("Inserting records into the table...");
stmt = conn.createStatement();
long time1 = System.currentTimeMillis();
// Insert twenty thousand records
for (int i = 0; i < 20000; i++) {
String sql = "INSERT INTO seq " +
"VALUES (" + i +
", 'seq" +i +
"')";
stmt.executeUpdate(sql);
}
long time2 = System.currentTimeMillis();
System.out.println("------------------");
System.out.println("Inserted 20000 records into the table...");
System.out.println("Insert took " + (time2 - time1) + " ms");
}
catch (SQLException se) {
// Handle errors for JDBC
se.printStackTrace();
}
catch (Exception e) {
// Handle errors for Class.forName
e.printStackTrace();
}
finally {
// finally block used to close resources
try {
if (stmt != null)
conn.close();
}
catch (SQLException se) {
} // do nothing
try {
if (conn!=null)
conn.close();
}
catch (SQLException se) {
se.printStackTrace();
} //end finally try
} //end try
System.out.println("Goodbye!");
} // end main
} // end MySQL_Insert
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment