码迷,mamicode.com
首页 > 数据库 > 详细

mysql

时间:2015-06-05 15:18:03      阅读:185      评论:0      收藏:0      [点我收藏+]

标签:

实验步骤
同一台电脑装了两个mysql,端口号不同,mysql5.6安装好之后只有一个my-default的文件,将其中添加一些错误内容,改mysql依然可以启动成功
,说明使用的不是该文件,将my-default.ini改名为my.ini,再向其中添加一些错误内容,则启动失败,则说明,mysql5.6启动时读取的配置文件
名称默认为my.ini
使用框架springmvc+spring+hibernate,但是插入数据时使用的JdbcDaoSupport中的jdbcTemplete,所以在这里hibernate也算是没有使用到,
由于要获取同一个connection对象,所以在这里封装了个方法

public static final ThreadLocal<Connection> cs = new ThreadLocal<Connection>();
    
    public static Connection getConnection(DataSource dataSource) throws SQLException{
        Connection c = cs.get();
        if(null==c){
            c=dataSource.getConnection();
            cs.set(c);
        }
        return c;
    }

dao插入数据代码

package com.h3c.itac.alarm.dao;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

import javax.annotation.PostConstruct;
import javax.annotation.Resource;
import javax.sql.DataSource;

import org.springframework.jdbc.core.support.JdbcDaoSupport;
import org.springframework.stereotype.Repository;

import com.h3c.itac.alarm.po.SyslogAlarm;
import com.h3c.itac.util.ConnectionUtil;

@Repository
public class SyslogAlarmDao extends JdbcDaoSupport{
    @Resource
    public void setDatasource(DataSource dataSource){
        this.setDataSource(dataSource);
    }
    
    private long count = 0L;
    String sql1="";
    String sql2="";
    PreparedStatement ps1 = null;
    PreparedStatement ps2 = null;
    Connection con = null;
    @PostConstruct
    public void set() throws SQLException{
        sql1 = "insert into alarm(id,adesk_alarm_id,serial_no,level,source,type,device_id,create_time,upload_time,order_id,title,location,customer_id)"
                +"values(?,?,?,?,?,?,?,?,?,?,?,?,?)";
        sql2 = "insert into syslogalarm values(?,?,?,?,?,?,?,?)";
        con = ConnectionUtil.getConnection(this.getDataSource());
//        con.setAutoCommit(false);
        ps1 = con.prepareStatement(sql1);
        ps2 = con.prepareStatement(sql2);
        PreparedStatement ps3 = con.prepareStatement("select max(id) from alarm");
        ResultSet rs = ps3.executeQuery();
        while(rs.next()){
            count = rs.getLong(1);
        }
        System.out.println("alarm id最大值为 :"+count);
    }
    public void insert(SyslogAlarm sAlarm) throws SQLException{
        count++;
        ps1.setLong(1,count);
        ps1.setLong(2,sAlarm.getAlarm().getAdeskAlarmId());
        ps1.setString(3,sAlarm.getAlarm().getSerialNo());
        ps1.setInt(4, sAlarm.getAlarm().getLevel());
        ps1.setInt(5, sAlarm.getAlarm().getSource());
        ps1.setInt(6,sAlarm.getAlarm().getType());
        ps1.setLong(7, sAlarm.getAlarm().getDevice().getId());
        ps1.setLong(8, sAlarm.getAlarm().getCreateTime());
        ps1.setLong(9, sAlarm.getAlarm().getUploadTime());
        ps1.setLong(10,count);
        ps1.setString(11, sAlarm.getAlarm().getTitle());
        ps1.setString(12, sAlarm.getAlarm().getLocation());
        ps1.setLong(13,sAlarm.getAlarm().getDevice().getCustomer().getId());
        
        ps2.setLong(1,count);
        ps2.setString(2, sAlarm.getDescription());
        ps2.setString(4,sAlarm.getReason());
        ps2.setString(5,sAlarm.getAdvise());
        ps2.setString(3, sAlarm.getVariables());
        ps2.setString(6, sAlarm.getLogContent());
        ps2.setLong(7,sAlarm.getPriginalLogId());
        ps2.setLong(8, count);
        
        ps1.addBatch();
        ps2.addBatch();
        if(count%300==0){
            excuteRemainderBatchSQL();
        }
    }
    
    public void excuteRemainderBatchSQL() throws SQLException{
        ps1.executeBatch();
        ps1.clearBatch();
        ps2.executeBatch();
        ps2.clearBatch();
//        con.commit();
//        con.setAutoCommit(true);
    }
}

测试类

package com.h3c.itac.alarm.dao;

import java.sql.SQLException;
import java.util.Date;

import org.junit.Test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

import com.h3c.itac.alarm.po.Alarm;
import com.h3c.itac.alarm.po.SyslogAlarm;
import com.h3c.itac.customer.Customer;
import com.h3c.itac.device.Device;

public class TestSyslogAlarmDao {

    public SyslogAlarmDao getSyslogAlarmDao() {
        ApplicationContext ac = new ClassPathXmlApplicationContext(
                "applicationContext.xml");
        return (SyslogAlarmDao) ac.getBean("syslogAlarmDao");
    }
    @Test
    public void init(){
        ApplicationContext ac = new ClassPathXmlApplicationContext(
                "applicationContext.xml");
    }
    /**每次清库1800
     * 2,自动提交(2.388,2.388,2.871,2.809,2.683)平均2.6278
     * 1,手动提交(2.825,2.717,2.294,2.076,2.169)平均2.4162
     * 不清库,每次1800
     * 2,自动提交(2.981,3.261,3.433,1.888,1.935)
     * 1,手动提交(2.091,2.293,3.354,1.95,2.371,)
     * 5000
     * 2,自动提交(6.397,5.43,6.584,6.35,4.853)                     平均5.9228
     * 1,手动提交(4.166,5.913,4.634,2.762,4.962) 平均4.4874
     */
    @Test
    public void testInsert() throws SQLException, ClassNotFoundException{
        double start = System.currentTimeMillis();
        SyslogAlarmDao sad = this.getSyslogAlarmDao();
        for(int i=1;i<5001;i++){
            Customer c = new Customer();
            c.setId(1L);
            Device d = new Device();
            d.setId(1L);
            d.setCustomer(c);
            
            Alarm alarm = new Alarm();
            alarm.setAdeskAlarmId((long) i);
            alarm.setCreateTime(new Date().getTime());
            alarm.setDevice(d);
            alarm.setLevel(1);
            alarm.setLocation("location "+i);
            alarm.setSerialNo("serialno "+i);
            alarm.setSource(1);
            alarm.setTitle("title "+i);
            alarm.setType(0);
            alarm.setUploadTime(new Date().getTime());
            
            SyslogAlarm sa = new SyslogAlarm();
            sa.setAdvise("advise "+i);
            sa.setAlarm(alarm);
            sa.setDescription("description "+i);
            sa.setLogContent("logcontent "+i);
            sa.setPriginalLogId(1);
            sa.setReason("reason "+i);
            sa.setVariables("variable "+1);
            
            sad.insert(sa);
        }
        sad.excuteRemainderBatchSQL();
        double end300 = System.currentTimeMillis();
        System.out.println((end300-start)/1000);
    }
    
}

如果只是将my-default.ini文件改名为my.ini文件,而不该内部配置,则在执行testInsert的时候速度超慢,即便是插入600条也需要将近二十多秒

然后找来其他版本的my.ini文件,替换掉改名后的my.ini文件,则速度比较快,可以想到问题就出在之前版本的my.ini和改名后的my.ini的文件配置内容上

然后用Compare对比改名前后的my.ini文件内容使用Compare辅助工具进行测试,(使用Compare对比在改名的my.ini文件中不存在的内容,将之前版本的my.ini文件内容逐行添加到改名后文件中,停止mysql服务,保存修改后文件,清空数据库,运行testInsert方法,观察运行时间,如果这条没有效果,继续添加下条配置)

后来就发现有一个配置起了作用

# If set to 1, InnoDB will flush (fsync) the transaction logs to the
# disk at each commit, which offers full ACID behavior. If you are
# willing to compromise this safety, and you are running small
# transactions, you may set this to 0 or 2 to reduce disk I/O to the
# logs. Value 0 means that the log is only written to the log file and
# the log file flushed to disk approximately once per second. Value 2
# means the log is written to the log file at each commit, but the log
# file is only flushed to disk approximately once per second.
innodb_flush_log_at_trx_commit = 2

一、当该配置为2的时候,代码还是如上,自动提交事务,则插入数据速度明显提升,和使用之前版本的my.ini文件几乎是相同的,

二、当该配置为1的时候,代码依然如上,自动提交事务,则插入数据速度又变得明显超慢

三、当该配置依然为1的时候,自动提交事务,即将上述代码con.setAutoCommit(false);和con.commit();的注释去掉,则插入数据也有明显提升,和第一种情况差不多,当插入数据过多时比第一种要快多一些

四、当该配置为2的时候,自动提交事务,即将上述代码con.setAutoCommit(false);和con.commit();的注释去掉,插入速度也会有明显提升。

五、去掉innodb_flush_log_at_trx_commit = 2配置,设置为手动提交事务,插入速度也会明显提升

六、去掉innodb_flush_log_at_trx_commit = 2配置,自动提交事务,速度又是明显超慢。

 

 

综上,如果用的是mysql5.6版本,要更改默认配置,目前我们采用的是将my-default.ini文件名改成,my.ini文件名,这样就可以在其中进行文件配置修改

通过上面测试结果也可看出,不管是配置为1或者2,只要是手动提交事务,则都可一提高插入速度,这个是在jdbc中进行的测试,至于hibernate需要就不清楚了

my.ini

# For advice on how to change settings please see
# http://dev.mysql.com/doc/refman/5.6/en/server-configuration-defaults.html
# *** DO NOT EDIT THIS FILE. Its a template which will be copied to the
# *** default location during install, and will be replaced if you
# *** upgrade to a newer version of MySQL.
[mysqld]

# generic configuration options
port        = 3306
socket        = /tmp/mysql.sock
character-set-server=utf8

innodb_print_all_deadlocks=1

innodb_locks_unsafe_for_binlog=1

expire_logs_days=2

event_scheduler=1

# If set to 1, InnoDB will flush (fsync) the transaction logs to the
# disk at each commit, which offers full ACID behavior. If you are
# willing to compromise this safety, and you are running small
# transactions, you may set this to 0 or 2 to reduce disk I/O to the
# logs. Value 0 means that the log is only written to the log file and
# the log file flushed to disk approximately once per second. Value 2
# means the log is written to the log file at each commit, but the log
# file is only flushed to disk approximately once per second.
innodb_flush_log_at_trx_commit = 2

 

mysql

标签:

原文地址:http://www.cnblogs.com/qq931399960/p/4554561.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!