added InsertAll and UpdateAll methods

Author: sglienke

Source/Persistence/Core/Spring.Persistence.Core.Session.pas

@@ -166,10 +166,15 @@   TSession = class(TAbstractSession)
     function FindAll<T: class, constructor>: IList<T>;
 
     /// <summary>
-    ///   Inserts model to the database .
+    ///   Inserts model to the database.
     /// </summary>
     procedure Insert(const entity: TObject);
 
+    /// <summary>
+    ///   Inserts model and its aggregations to the database.
+    /// </summary>
+    procedure InsertAll(const entity: TObject);
+
     /// <summary>
     ///   Inserts models to the database.
     /// </summary>
@@ -182,12 +187,17 @@   TSession = class(TAbstractSession)
     function IsNew(const entity: TObject): Boolean;
 
     /// <summary>
-    ///   Updates model in a database.
+    ///   Updates model in the database.
     /// </summary>
     procedure Update(const entity: TObject);
 
     /// <summary>
-    ///   Updates multiple models in a database.
+    ///   Updates model and its aggregations in the database.
+    /// </summary>
+    procedure UpdateAll(const entity: TObject);
+
+    /// <summary>
+    ///   Updates multiple models in the database.
     /// </summary>
     procedure UpdateList<T: class, constructor>(const entities: IEnumerable<T>);
 
@@ -447,6 +457,25 @@ procedure TSession.Insert(const entity: TObject);
   DoInsert(entity, inserter);
 end;
 
+procedure TSession.InsertAll(const entity: TObject);
+var
+  relations: IList<TObject>;
+  relation: TObject;
+  entityWrapper, foreignEntityWrapper: IEntityWrapper;
+begin
+  TRttiExplorer.GetRelationsOf(entity, ManyToOneAttribute).ForEach(Insert);
+  Insert(entity);
+
+  entityWrapper := TEntityWrapper.Create(entity);
+  relations := TRttiExplorer.GetRelationsOf(entity, OneToManyAttribute);
+  for relation in relations do
+  begin
+    foreignEntityWrapper := TEntityWrapper.Create(relation);
+    UpdateForeignKeysFor(foreignEntityWrapper, entityWrapper);
+    InsertAll(relation);
+  end;
+end;
+
 procedure TSession.InsertList<T>(const entities: IEnumerable<T>);
 var
   inserter: IInsertCommand;
@@ -515,10 +544,10 @@ procedure TSession.SaveAll(const entity: TObject);
   TRttiExplorer.GetRelationsOf(entity, ManyToOneAttribute).ForEach(Save);
   Save(entity);
 
+  entityWrapper := TEntityWrapper.Create(entity);
   relations := TRttiExplorer.GetRelationsOf(entity, OneToManyAttribute);
   for relation in relations do
   begin
-    entityWrapper := TEntityWrapper.Create(entity);
     foreignEntityWrapper := TEntityWrapper.Create(relation);
     UpdateForeignKeysFor(foreignEntityWrapper, entityWrapper);
     SaveAll(relation);
@@ -578,6 +607,25 @@ procedure TSession.Update(const entity: TObject);
   DoUpdate(entity, updater);
 end;
 
+procedure TSession.UpdateAll(const entity: TObject);
+var
+  relations: IList<TObject>;
+  relation: TObject;
+  entityWrapper, foreignEntityWrapper: IEntityWrapper;
+begin
+  TRttiExplorer.GetRelationsOf(entity, ManyToOneAttribute).ForEach(Update);
+  Update(entity);
+
+  entityWrapper := TEntityWrapper.Create(entity);
+  relations := TRttiExplorer.GetRelationsOf(entity, OneToManyAttribute);
+  for relation in relations do
+  begin
+    foreignEntityWrapper := TEntityWrapper.Create(relation);
+    UpdateForeignKeysFor(foreignEntityWrapper, entityWrapper);
+    UpdateAll(relation);
+  end;
+end;
+
 procedure TSession.UpdateList<T>(const entities: IEnumerable<T>);
 var
   updater: IUpdateCommand;