[Error 회고] Lock방지를 위한 Transaction 분리

운영·관리하는 사이트 중, 요근래 유독 속도가 저하된 사이트가 있다.

속도보다도 큰 문제가 있었는데 특정 테이블에서 DB Lock이 지속적으로 걸린다는 것이었다. 이것은 속도의 문제가 아닌 사용의 문제이기 때문에 커다란 이슈였다. '데이터 수정이 안된다, 수정 시 자꾸 화면이 멈춰버린다.' 라는 긴급 요청에 급한대로 우선 Lock을 kill하기를 여러번. 안되겠다싶어, 좀 더 자세히 들여다봤다.

 

Database가 Oracle인 사이트였고, 이에 Oacle lock이 걸려있는 테이블과 SQL query를 조회해보았다. 역시 특정 테이블에서 Lock이 걸려있었는데, 눈에 띄는 것은 해당 테이블과 업무적으로 엮여있는 특정한 테이블들이 함께 걸려있다는 점이었다.

'아, 저 테이블들이 공동으로 무언가 작업을 수행하다가 Lock이 걸렸구나. 저것들이 엮인 업무가 뭐가 있지?'

그러한 생각과 Lock을 발생시킨 SQL query을 따라 올라가다보니 인터페이스라는 결론이 나왔다.

 

해당 인터페이스의 로그 기록을 보니, 계속하여 Error Log가 떨어지고 있었다.

타 시스템과 데이터 송수신을 하는 인터페이스 시, 다량의 데이터를 주고받는다. 인터페이스를 개발한 개발자의 역량에 따라 Log의 질도 천차만별이기 때문에, Log만으로 Error의 원인을 추측하기 어려웠다. 

 

for(Object obj:resultList) {
    Map dataMap = (Map) obj;
    rowData = COMPANYCODE+"|"
            +dataMap.get("ID")+"|"
            +dataMap.get("DESCRIPTION")+"|"
    try {
        if(testDAO.checkMethod(dataMap > 0) {
            testDAO.updateMethod(dataMap);
        } else {
            testDAO.insertMethod(dataMap);
        }
    } catch (SqlIgnoreException se) {
        se.printStackTrace();
        isSuccess = false;
    }
}

 

코드의 아주 일부분을 가공하여 떼어온 것이다. 해당 인터페이스는 매일 새벽마다 1번씩 배치 서비스로 구동되고 있었다. 그간 성공하지 못한 십여만개의 데이터를 하루종일 받아오고 있는데(실제 Log파일을 뒤져보니 정말 하루종일 돌고 있었다. 공포스러웠다..) , 동일 테이블을 사용하는 다른 게시판에서 데이터 수정을 시도하니 Lock이 걸릴만도 했다. 그것도 모르고 그때그때 Lock만 kill하고 있으니, 다음날이 되면 또 Lock이 걸리는게 당연했다.

이 점을 개선하기 위하여, 저 try~catch의 method들의 트랜잭션 분리해주는 작업이 필요했다. 저 3개의 method를 하나의 작업으로 분류하고, 하나의 method에 담아 그 method를 트랜잭션으로 묶었다. 

 

@Transactional(propagation = Propagation.REQUIRES_NEW, rollbackFor = Exception.class, noRollbackFor = SqlIgnoreException.class)
public void testMethod(Map dataMap) throws SqlIgnoreException {
    if(testDAO.checkMethod(dataMap) > 0) {
        testDAO.updateMethod(dataMap);
    } else {
        testDAO.insertMethod(dataMap);
    }
}

for문으로 십여만개의 데이터를 받아오더라도, 건 당 Commit이 되므로 더이상 for문이 끝날때까지 대기하지 않아도 될 것이다. 실제로 코드를 변경한 후에는 한번도 Lock이 걸리지 않았다.