使用JDBC插入多数据测试的3种实现方法

闲来无事，就想测试一下我的mysql插入数据的效率到底如何。
现在不清楚我的测试方法到位否，所以与大家分享一下，看看大家的意见。

测试的思路：
多次向表中插入1000条数据，看看每次使用了多少毫秒。现在我打算使用JDBC的方式去插入。

外话：
思路很简单，不过我这里使用了Spring JUnit,因为我上瘾了，非常地方便。想看看大家
是不是也这样子使用。所以我在后文中附贴出我一些关于JUnit Spring的配置代码，
想更多人来抛砖。
开始先看看表结构，非常简单的一个表，id是自动增长，ct里就是我会随加入内容的字段：

create table test (id int,ct chart);

Java代码

import mumu.junit.Base.BaseTest;   
  
public class MangInsertTest extends BaseTest {   
    private static Logger log = Logger.getLogger(MangInsertTest.class);   
    private static final int INSERT_COUNT = 5000;   
    private static final int TEST_COUNT = 10;   
       
    @Autowired  
    private UnitTestDAO unitDao;   
       
    @Test  
    public void test() throws Exception{   
        Connection conn = null;   
        try{   
            conn = unitDao.getConnection();   
            conn.setAutoCommit(false);//将事务改成手工提交   
               
            String inSql = "insert into mang(ct)value(?)";   
               
            for(int i = 0; i < TEST_COUNT; ++i){   
                long s = System.currentTimeMillis();   
                long d = 0;   
                PreparedStatement inPs = conn.prepareStatement(inSql);   
                for(int k = 0; k < INSERT_COUNT; ++k){   
                    inPs.setString(1, "prefix string " + System.currentTimeMillis());   
                    inPs.addBatch();//放入批处理   
                }   
                inPs.executeBatch();   
                conn.commit();//记得要提交喔   
                inPs.close();   
                d = System.currentTimeMillis() - s;   
                log.info("used time:" + d);   
            }              
               
            conn.setAutoCommit(true);//将conn改成自动提交   
               
        }catch(Exception excep){   
            throw excep;   
        }finally{   
            if(conn != null){   
                try {   
                    conn.close();   
                } catch (SQLException e) {   
                    // TODO Auto-generated catch block   
                    throw e;   
                }   
            }   
        }   
           
    }   
}  

第一个我给出了所有代码，这里使用的jdbc批处理还有手工提交事务。
测试结果为：

Java代码

INFO (MangInsertTest.java:42) - used time:822  
 INFO (MangInsertTest.java:42) - used time:522  
 INFO (MangInsertTest.java:42) - used time:540  
 INFO (MangInsertTest.java:42) - used time:531  
 INFO (MangInsertTest.java:42) - used time:500  
 INFO (MangInsertTest.java:42) - used time:541  
 INFO (MangInsertTest.java:42) - used time:500  
 INFO (MangInsertTest.java:42) - used time:521  
 INFO (MangInsertTest.java:42) - used time:490  
 INFO (MangInsertTest.java:42) - used time:721  

测试代码2：

Java代码

conn = unitDao.getConnection();   
            conn.setAutoCommit(false);//依然使用手动提交   
               
            String inSql = "insert into mang(ct)value(?)";   
               
            for(int i = 0; i < TEST_COUNT; ++i){   
                long s = System.currentTimeMillis();   
                long d = 0;   
                PreparedStatement inPs = conn.prepareStatement(inSql);   
                for(int k = 0; k < INSERT_COUNT; ++k){   
                    inPs.setString(1, "prefix string " + System.currentTimeMillis());   
                    inPs.executeUpdate();   
                }   
                conn.commit();   
                inPs.close();   
                d = System.currentTimeMillis() - s;   
                log.info("used time:" + d);  

只给出与测试不同的地方，其他地方基本相同。
这里只是将batch方式换成直接executeUpdate.
输出结果 如下：

Java代码

INFO (MangInsertTest2.java:41) - used time:692  
INFO (MangInsertTest2.java:41) - used time:590  
INFO (MangInsertTest2.java:41) - used time:531  
INFO (MangInsertTest2.java:41) - used time:560  
INFO (MangInsertTest2.java:41) - used time:681  
INFO (MangInsertTest2.java:41) - used time:500  
INFO (MangInsertTest2.java:41) - used time:511  
INFO (MangInsertTest2.java:41) - used time:510  
INFO (MangInsertTest2.java:41) - used time:683  
INFO (MangInsertTest2.java:41) - used time:510  

使用Spring框架作为数据源：

Java代码

package mumu.compass.unittest;   
  
import java.sql.Connection;   
import java.sql.SQLException;   
  
import org.springframework.jdbc.core.JdbcTemplate;   
  
public class UnitTestDAO {   
    private JdbcTemplate jdbcTemplate;   
       
    public Connection getConnection() throws SQLException{   
        return jdbcTemplate.getDataSource().getConnection();   
    }   
       
    public JdbcTemplate getJdbcTemplate() {   
        return jdbcTemplate;   
    }   
    public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {   
        this.jdbcTemplate = jdbcTemplate;   
    }   
       
}  

Java代码

package mumu.junit.Base;   
  
import org.junit.runner.RunWith;   
import org.springframework.test.context.ContextConfiguration;   
import org.springframework.test.context.TestExecutionListeners;   
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;   
import org.springframework.test.context.support.DependencyInjectionTestExecutionListener;   
import org.springframework.test.context.transaction.TransactionalTestExecutionListener;   
import org.springframework.transaction.annotation.Transactional;   
  
@RunWith(SpringJUnit4ClassRunner.class)   
@TestExecutionListeners({   
    DependencyInjectionTestExecutionListener.class})   
@Transactional  
@ContextConfiguration(locations={"classpath*:/testContext.xml"})    
public class BaseTest{   
       
  
}  

testContext.xml文件:

Java代码

<?xml version="1.0" encoding="UTF-8"?>   
<beans xmlns="http://www.springframework.org/schema/beans"  
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"    
     xmlns:context="http://www.springframework.org/schema/context"  
    xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd   
    http://www.springframework.org/schema/context   
    http://www.springframework.org/schema/context/spring-context-2.5.xsd">   
    <context:component-scan base-package="mumu.compass.unittest" />   
  
       
    <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource"           
        destroy-method="close">           
        <property name="driverClassName" value="com.mysql.jdbc.Driver" />          
        <property name="url" value="jdbc:mysql://localhost:3306/mutest" />          
        <property name="username" value="root" />          
        <property name="password" value="mysql" />          
    </bean>    
       
    <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">     
        <property name="dataSource" ref="dataSource"/>     
    </bean>     
       
    <bean id="unitTestDao" class="mumu.compass.unittest.UnitTestDAO">     
        <property name="jdbcTemplate" ref="jdbcTemplate"/>    
    </bean>   
       
</beans>