1

Есть сущность с id и каким-то другим уникальным ключом (extId). Множество потоков (приложений) вставляют в БД сущности с незаполненным id, но известным extId по следующей логике:

  • Если extId уже найден в БД, то обновить сущность новыми данными.
  • Если не найден, то вставить новую запись.
@Transactional(propagation = REQUIRED_NEW)
public A createOrUpdate(A a) {
    A b = findByExtId(a.extId, LockModeType.PESSIMISTIC_WRITE);
    if (b != null) {
        a.id = b.id
    }
    return save(a); // hibernate merge
}

Update:

@Transactional(propagation = Propagation.SUPPORTS)
public A findByExtId(final Long extId,
                     final LockModeType lockMode) {
    CriteriaBuilder cb = entityManager.getCriteriaBuilder();
    CriteriaQuery<A> cq = cb.createQuery(A.class);
    Root<A> root = cq.from(A.class);
    cq.where(cb.equal(root.get("extId"), cb.parameter(Long.class, "extId")));
    TypedQuery<A> query = entityManager.createQuery(cq);
    query.setParameter("extId", extId);
    query.setLockMode(lockMode);
    List<A> list = query.getResultList();
    if (!list.isEmpty()) {
        return list.get(0);
    }
    return null;
}
@Transactional(propagation = Propagation.SUPPORTS)
public A save(A t) {
    return entityManager.merge(t);
}

Проблема в том, что данный код в редких случаях все равно вставляет сущность с одинаковым extId несколько раз. В чем может быть причина?

База данных PostgreSQL.

9
  • Покажите полную сигнатуру метода findByExtId()
    – Barmaley
    1 ноя 2017 в 12:32
  • А что делает findByExtId()?
    – Orthodox
    1 ноя 2017 в 13:41
  • @Barmaley, дополнил код 1 ноя 2017 в 14:03
  • Вроде с локами все верно... Единственное, что меня смущает - это merge - почему именно merge? Есть какая-то логика в этом?
    – Barmaley
    1 ноя 2017 в 14:25
  • 1
    Давайте продолжим обсуждение в чате.
    – Barmaley
    2 ноя 2017 в 5:30

2 ответа 2

1

Если два потока (с одним и тем же extID) примерно одновременно выполнят A b = findByExtId(a.extId, LockModeType.PESSIMISTIC_WRITE); и в БД еще нет строки с таким extID, то они оба вставят новую строчку.

Если у Вас много потоков, то решить данный вопрос с помощью функций save, update, merge не получится, потому что в каждом потоке свой хибернейтовский кеш сессии.

Если у Вас много потоков, но одно приложение, то можно блокировать метод или использовать хибернейтовский кеш второго уровня, который объединяет сессии хибернайта.

Если у Вас много потоков и много приложений, то тут, вероятно, нужно подключать уровень БД - сделать в таблице констрейн на уникальность значений поля extID, если произойдет попытка вставить дубль, констрейн поднимит ошибку, в java перехватить ошибку, найти имеющуюся строчку и ее обновить.

3
  • А подскажите как можно обойти эту проблему? 2 ноя 2017 в 10:59
  • "Красивого" способа решить проблему, скорее всего, не существует. Есть не очень "красивые" и оптимальные. Я в таких случаях применяю примерно такой подход: надо создать заблаговременно запись в любой таблице, а перед тем, как осуществлять проверку наличия extID - блокировать эту запись. Два потока одновременно пытаются заблокировать запись, но захват получит только один из них, другой будет ожидать завершения транзакции. За счёт этого гарантируется очередь доступа на выполнение проверки наличия extID. При очень высоких нагрузках, такая блокировка станет "узким местом"
    – bobzer
    3 ноя 2017 в 4:02
  • Я написал в ответе как можно обойти эту проблему
    – Orthodox
    3 ноя 2017 в 13:40
0

Потому что для обновления используется другая команда сессии. session.update(a); или session.merge(a);

2
  • В коде я отметил, что save зовет внутри себя merge 1 ноя 2017 в 13:56
  • Вы пробовали делать полный лог этого места, при каких значениях и условиях он дублирует запись? Я конечно сейчас может глупость предложу, но что если просто менять b, если такой id уже существует? 2 ноя 2017 в 4:30

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge you have read our privacy policy.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.