flush the session for large inserts

2026-03-21 21:37:29 +00:00 · 2013-06-12 05:08:27 +02:00
parent 62a77278ff
commit c6a9fdc8c3
1 changed files with 5 additions and 0 deletions
--- a/src/main/java/com/commafeed/backend/dao/GenericDAO.java
+++ b/src/main/java/com/commafeed/backend/dao/GenericDAO.java
@@ -36,8 +36,13 @@ public abstract class GenericDAO<T extends AbstractModel> {

 	public void saveOrUpdate(Collection<? extends AbstractModel> models) {
 		Session session = em.unwrap(Session.class);
+		int i = 1;
 		for (AbstractModel model : models) {
 			session.saveOrUpdate(model);
+			if (i % 50 == 0) {
+				session.flush();
+				session.clear();
+			}
 		}
 	}