最近闲来无事，看了下面试题目，看到mysql数据表的引擎模块，目前我们用的比较多的引擎应该是innodb和myisam，其他的引擎暂时抛开不谈，我们先来看看这两个数据表引擎有哪些异同：
纸上得来终觉浅，绝知此事要躬行，所以自己做了个实验，发现MyISAM引擎的表批量插入要优于Innodb
package com.sushi.jdbc;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
public class MyJDBC {
private static Connection conn = null;
private static PreparedStatement st = null;
private static final int COUNT = 1000;//条数
static{
try {
conn = JDBCUtils.getConnection();
} catch (SQLException e) {
e.printStackTrace();
}
}
public static void main(String[] args) throws Exception{
//myisam测试
long start = System.currentTimeMillis();
Thread thread1 = new Thread(new Runnable() {
@Override
public void run() {
addDataByTableName("person_myisam");
}
});
thread1.start();
thread1.join();
long ended = System.currentTimeMillis();
System.out.println("myisam:"+(ended - start));
//innodb测试
start = System.currentTimeMillis();
Thread thread2 = new Thread(new Runnable() {
@Override
public void run() {
addDataByTableName("person_innodb");
}
});
thread2.start();
thread2.join();
ended = System.currentTimeMillis();
System.out.println("innodb:"+(ended - start));
}
public static void addDataByTableName(String tableName){
try {
for(int i=0;i<COUNT;i++){
// 编写sql
String sql = "insert into "+tableName+"(name,age,address) values (?,?,?)";
// 创建语句执行者
st= conn.prepareStatement(sql);
//设置参数
st.setString(1, "曾昌"+i);
st.setInt(2, i+10);
st.setString(3, "孝感"+i);
// 执行sql
st.executeUpdate();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
}
下面是输出结果：
可以看出myiasm插入一千条数据大概需要7000毫秒左右，而innodb大概需要9000多毫秒
另外附上表结构（两张表结构一样，数据库引擎一个是myiasm，一个是innodb）
jdbc工具类也附上：
package com.sushi.jdbc;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public final class JDBCUtils {
private static String driver="com.mysql.jdbc.Driver";
private static String url="jdbc:mysql://192.168.18.5:3306/mydb";
private static String user="root";
private static String password="toor";
private JDBCUtils(){}
static {
/**
* 驱动注册
*/
try {
Class.forName(driver);
} catch (ClassNotFoundException e) {
throw new ExceptionInInitializerError(e);
}
}
/**
* 获取 Connetion
* @return
* @throws SQLException
*/
public static Connection getConnection() throws SQLException{
return DriverManager.getConnection(url, user, password);
}
/**
* 释放资源
* @param conn
* @param st
* @param rs
*/
public static void colseResource(Connection conn,Statement st,ResultSet rs) {
closeResultSet(rs);
closeStatement(st);
closeConnection(conn);
}
/**
* 释放连接 Connection
* @param conn
*/
public static void closeConnection(Connection conn) {
if(conn !=null) {
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
//等待垃圾回收
conn = null;
}
/**
* 释放语句执行者 Statement
* @param st
*/
public static void closeStatement(Statement st) {
if(st !=null) {
try {
st.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
//等待垃圾回收
st = null;
}
/**
* 释放结果集 ResultSet
* @param rs
*/
public static void closeResultSet(ResultSet rs) {
if(rs !=null) {
try {
rs.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
//等待垃圾回收
rs = null;
}
}
