From bcbdc451f6c198938513f8954c9063ec93537149 Mon Sep 17 00:00:00 2001 From: Jonathan Cobb Date: Wed, 5 Feb 2020 10:36:22 -0500 Subject: [PATCH] force tx commit for bulk operations --- .../java/org/cobbzilla/wizard/dao/AbstractCRUDDAO.java | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/wizard-server/src/main/java/org/cobbzilla/wizard/dao/AbstractCRUDDAO.java b/wizard-server/src/main/java/org/cobbzilla/wizard/dao/AbstractCRUDDAO.java index 092283a..7dae87f 100644 --- a/wizard-server/src/main/java/org/cobbzilla/wizard/dao/AbstractCRUDDAO.java +++ b/wizard-server/src/main/java/org/cobbzilla/wizard/dao/AbstractCRUDDAO.java @@ -303,7 +303,10 @@ public abstract class AbstractCRUDDAO } else { query = queryBase; } - return query.executeUpdate(); + final int count = query.executeUpdate(); + session.setFlushMode(FlushMode.COMMIT); + session.flush(); + return count; } public int bulkDelete(String field, Object value) { @@ -315,7 +318,10 @@ public abstract class AbstractCRUDDAO query = session.createQuery("DELETE FROM "+getEntityClass().getSimpleName()+" WHERE "+field+" = :"+field) .setParameter(field, value); } - return query.executeUpdate(); + final int count = query.executeUpdate(); + session.setFlushMode(FlushMode.COMMIT); + session.flush(); + return count; } @Transactional(readOnly=true)