Browse Source

force tx commit for bulk operations

tags/2.0.1
Jonathan Cobb 4 years ago
parent
commit
bcbdc451f6
1 changed files with 8 additions and 2 deletions
  1. +8
    -2
      wizard-server/src/main/java/org/cobbzilla/wizard/dao/AbstractCRUDDAO.java

+ 8
- 2
wizard-server/src/main/java/org/cobbzilla/wizard/dao/AbstractCRUDDAO.java View File

@@ -303,7 +303,10 @@ public abstract class AbstractCRUDDAO<E extends Identifiable>
} else { } else {
query = queryBase; 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) { public int bulkDelete(String field, Object value) {
@@ -315,7 +318,10 @@ public abstract class AbstractCRUDDAO<E extends Identifiable>
query = session.createQuery("DELETE FROM "+getEntityClass().getSimpleName()+" WHERE "+field+" = :"+field) query = session.createQuery("DELETE FROM "+getEntityClass().getSimpleName()+" WHERE "+field+" = :"+field)
.setParameter(field, value); .setParameter(field, value);
} }
return query.executeUpdate();
final int count = query.executeUpdate();
session.setFlushMode(FlushMode.COMMIT);
session.flush();
return count;
} }


@Transactional(readOnly=true) @Transactional(readOnly=true)


Loading…
Cancel
Save