一次Mysql 死鎖事故

故障描述：

簡單描述一下需求：我們寫的一個計步器的客戶端軟件，用戶通過手機客戶端將用戶的運動計步信息傳到服務器。

服務器側記錄每個用戶每次上傳明細，同時每個用戶有一個匯總值，參與全省排名。

1.加入明細記錄方法

List<EmployeeRecord> list = mEmployeeRecordService.uploadRecord(usercode, token, uploadStr, movement_id);

2.更新統計值（上面明細添加成功后，將實體返回，更新統計值）

this.mEmployeeReportService.updateUserReport(usercode, list);

3.更新統計值中有一個方法用來更新用戶在本活動中的排名信息，具體方法如下：

/**
     * 更新所有人的排名
     * 
     * @param movementId
     *            ：活動編號
     * @param orderType
     *            增加排名方式@2013.12.11
     */
    @SuppressWarnings("unchecked")
    private void updateRanks(String movementId, String orderType) {
String updateField = orderType.equals("0") ? "all_sport_steps"
                : "all_sport_distence";
        String sql = "update tb_c_employee_report  as rpt set rpt.current_rank="
                + "(select count(1)+1 from (select movement_id,all_sport_steps from tb_c_employee_report) as b where b.movement_id='"
                + movementId
                + "' and b."
                + updateField
                + ">rpt."
                + updateField
                + ")" + "where movement_id='" + movementId + "'";
        this.jdbcTemplate.execute(sql);

這個巧妙的方法可以用一條sql語句更新用戶的排名。

但問題也出在這個語句上：mysql的update語句或insert語句中如果包含select（如insert into select from），將會為select 表加鎖（可能是表鎖或行鎖），而且mysql的行鎖是加在索引上的。

這個方法上線后，一開始運行正常。但隨着並發數的增加，經常報一個如下的錯誤：

 nested exception is org.hibernate.exception.LockAcquisitionException: Could not execute JDBC batch update

通過mysql的show innodb status查看，產生一個死鎖。

 

解決方案：

網上有很多解決辦法。我這里更新排名沒有辦法了。只能拿出來遍歷了。方法雖然傻了點，但每個分公司是一個活動，活動內用戶最多也就1000多人。不會有太大效率上的問題。先解決問題。明天再想想有沒有別的辦法解決。

/**
     * 更新所有人的排名
     * 
     * @param movementId
     *            ：活動編號
     * @param orderType
     *            增加排名方式@2013.12.11
     */
    @SuppressWarnings("unchecked")
    private void updateRanks(String movementId, String orderType) {
//耗效率一點。反正一個活動里的人也不是太多。
String updateField = orderType.equals("0") ? "all_sport_steps"
                : "all_sport_distence";
String sql = "SELECT employee_report_id FROM tb_c_employee_report WHERE movement_id=? ORDER BY " + updateField + " DESC";
        List<Map<String,Object>> list = this.jdbcTemplate.queryForList(sql, movementId);
        int i = 1;
        for(Map<String,Object> map : list)
        {
            this.jdbcTemplate.execute("UPDATE tb_c_employee_report SET current_rank='"+i+"'" +
                    " WHERE employee_report_id='"+map.get("employee_report_id").toString()+"'");
            i++;
        }

 

附：

http://tech110.blog.51cto.com/438717/268954

這篇文章推薦如果有insert 和 select同時操作時使用MyISAM 表。明天有空試一下。

 

http://xu20cn.blog.51cto.com/274020/72574

這里有詳細的介紹innodb鎖機制。