오류 처리 Spring JdbcTemplate batchUpdate

Question

batchUpdate를 사용하여 테이블에서 수천 개의 행을 업데이트하려고합니다. 내 요구 사항은 다음과 같습니다.

1) 배치에 1000 개의 레코드가 있다고 가정합니다. 기록 번호 235로 인해 오류가 발생했습니다. 오류를 일으킨 레코드를 어떻게 찾을 수 있습니까?

2) 레코드 600이 업데이트되지 않았다고 가정합니다 (이유는 where 절과 일치하는 레코드가 아닐 수 있음). 업데이트를하지 않은 레코드를 어떻게 찾을 수 있습니까?

3) 위의 두 시나리오에서 어떻게 나머지 레코드 처리를 계속할 수 있습니까?

Answer 1

긴 검색 및 디버그 후 유일한 해결책은 BatchUpdateException 클래스로 이동하여 음수 요소를 찾아 MAP에서 오류가있는 삽입 값을 추론하는 것입니다.

import java.sql.BatchUpdateException; 
import java.sql.PreparedStatement; 
import java.sql.SQLException; 
import java.sql.Statement; 
import java.util.List; 
import java.util.Map; 


import org.springframework.jdbc.core.BatchPreparedStatementSetter; 
import org.springframework.stereotype.Repository; 
import org.springframework.transaction.annotation.Propagation; 
import org.springframework.transaction.annotation.Transactional; 


@Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class) 
@Repository("dao_") 
public class YouDao extends CommunDao implements IyouDao { 

    public void bulkInsert(final List<Map<String, String>> map) 
      throws BusinessException { 
     try { 

      String sql = " insert into your_table " + "( aa,bb )" 
        + "values " + "( ?,?)"; 
      BatchPreparedStatementSetter batchPreparedStatementSetter = new BatchPreparedStatementSetter() { 
       @Override 
       public void setValues(PreparedStatement ps, int i) 
         throws SQLException { 
        Map<String, String> bean = map.get(i); 

        ps.setString(1, bean.get("aa")); 
        ps.setString(2, bean.get("bb")); 
        //.. 
        //.. 

       } 

       @Override 
       public int getBatchSize() { 
        return map.size(); 
       } 
      }; 

      getJdbcTemplate().batchUpdate(sql, batchPreparedStatementSetter); 

     } 

     catch (Exception e) { 
      if (e.getCause() instanceof BatchUpdateException) { 
       BatchUpdateException be = (BatchUpdateException) e.getCause(); 
       int[] batchRes = be.getUpdateCounts(); 
       if (batchRes != null && batchRes.length > 0) { 
        for (int index = 0; index < batchRes.length; index++) { 
         if (batchRes[index] == Statement.EXECUTE_FAILED) { 
          logger.error("Error execution >>>>>>>>>>>" 
            + index + " --- , codeFail : " + batchRes[index] 
            + "---, line " + map.get(index)); 
         } 
        } 
       } 
      } 
      throw new BusinessException(e); 
     } 

    } 

} 

Answer 2

INT [] 행 = jdbcTemplate.batchUpdate (TbCareQueryConstant.SQL_UPDATE_BANKDETAILS_OF_USER, 새로운 BatchPreparedStatementSe 라 자세 히() {

..... 코드

}에 대한

(int i = 0; i < rows.length; i ++) {

 if(rows[i] == 0){ 


     }  
    }