안녕하세요. 지나가는 개발자입니다.

코드를 구현하면서 제 자신의 부족함을, 이론적으로 이해하던 데이터베이스의 동시성 제어 측면의 사례를 느껴서 써봅니다.

이 코드를 보면서 고수들은 별것도 아닌데 하실터이니, 초급분들에게는 도움이 되실지 몰라서 올려봅니다.

오랫동안 개발을 했지만, 아직도 갈길이 부족하다는 생각이 드는 오전입니다. ㅎㅎ;

본문은 평어로 설명합니다. ^^

다음과 같은 중첩을 수행하면서, 업데이트를 하는 코드가 있었다.

public static void adjustAsgnAmounts(List<TrxResVo> billings, BigDecimal totalAmount) {

// 우선순위 기준으로 정렬

billings.sort(

Comparator.comparing(TrxResVo::getAllocRmndAmt, Comparator.reverseOrder()) //우선순위1

.thenComparing(TrxResVo::getAsgnAmt, Comparator.reverseOrder()) // 우선순위2

.thenComparing(TrxResVo::getAcntNo) //우선순위3

);

//현재 지급금액 총합

BigDecimal currentTotal = billings.stream().map(TrxResVo::getAsgnAmt).reduce(BigDecimal.ZERO, BigDecimal::add);

BigDecimal difference = totalAmount.subtract(currentTotal); // 기관의 배정금액-총합 차이금액

int index = 0;

UpdateVo updateVo = new UpdateVo();

while (difference.compareTo(BigDecimal.ZERO) > 0) {

TrxResVo billing = billings.get(index % billings.size()); //받을 사람 수

billing.setAsgnAmt(billing.getAsgnAmt().add(BigDecimal.ONE)); //차이금액에서 1원씩 더해준다.

difference = difference.subtract(BigDecimal.ONE); //차이금액 -1 차감 계산

updateVo.setAmt(setAsgnAmt);

int upCheck = mapper.update(updateVo); //데이터베이스 업데이트

index++;

}

이 로직을 수행시 재귀,반복 업데이트 Read Commited 연산에서 걸려서 Lock wait timeout exceeded; try restarting transaction, 즉 Lock이 걸린다. 동시성 문제인데, 읽고 커밋을 치고, 다시 읽어야 하는 로직이 없기 때문에 해당 로직은 최종적인 값만 합산해서 업데이트를 해야하는데, 중간 Commit이 안된 부분을 놓쳐서,생각하지 못해서 막 수행시키면, Lock에 걸린다.

해결방안은 Lock을 피하기 위해서는 1.해당하는 값을 업데이트 수행전에 다시 데이터베이스에서 최종금액값을 읽어오거나, 2.업데이트를 해야 할 값들을 모두 합산 해서 최종값만 업데이트를 쳐야 한다는 방법을 사용하는 것으로 수정했다.

while (difference.compareTo(BigDecimal.ZERO) > 0) {

.....

1.BigDecimal latestAsgnAmt = mapper.selectAsgnAmt(billing.getId()); // DB에서 최신값(금액,업데이트 된 값) 읽어오기

2.BigDecimal latestAsgnAmt= 업데이트를 해야 할 최종값 합산해서...

.....

UpdateVo updateVo = new UpdateVo(); // Vo도 루프안으로 들어와야 한다.ㅠㅠ

int upCheck = mapper.update(updateVo); // 데이터베이스 금액 업데이트

index++;

}

어찌보면 단순하고,간과하기 쉬운 부분이지만, 간만에 부족함을 느껴서 글을 남겨봅니다.

뭐 그렇다는 겁니다. ㅎㅎ

Lock wait timeout exceeded; try restarting transaction 오류가 발생했다. 이거 뭔가 했더니...