avoid hibernate errors by removing already saved objects

lformella · Apr 8, 2014 · 2d22e4c · 2d22e4c
1 parent f941ab5
commit 2d22e4c
Showing 1 changed file with 6 additions and 3 deletions.
diff --git a/XG.DB/Dao.cs b/XG.DB/Dao.cs
@@ -347,9 +347,10 @@ void WriteToDatabase()
 					{
 						using (ISession session = _sessions.OpenSession(new TrackingNumberInterceptor()))
 						{
-							foreach (AObject obj in _objectsAdded)
+							foreach (AObject obj in _objectsAdded.ToArray())
 							{
 								session.SaveOrUpdate(obj);
+								_objectsAdded.Remove(obj);
 							}
 							session.Flush();
 						}
@@ -370,9 +371,10 @@ void WriteToDatabase()
 					{
 						using (ISession session = _sessions.OpenSession(new TrackingNumberInterceptor()))
 						{
-							foreach (AObject obj in _objectsChanged)
+							foreach (AObject obj in _objectsChanged.ToArray())
 							{
 								session.SaveOrUpdate(obj);
+								_objectsChanged.Remove(obj);
 							}
 							session.Flush();
 						}
@@ -393,9 +395,10 @@ void WriteToDatabase()
 					{
 						using (ISession session = _sessions.OpenSession(new TrackingNumberInterceptor()))
 						{
-							foreach (AObject obj in _objectsRemoved)
+							foreach (AObject obj in _objectsRemoved.ToArray())
 							{
 								session.Delete(obj);
+								_objectsRemoved.Remove(obj);
 							}
 							session.Flush();
 						}