allow sync of VirtualMList

signumsoftware · Jul 22, 2022 · 2293a2c · 2293a2c
1 parent 0619750
commit 2293a2c
Show file tree

Hide file tree

Showing 3 changed files with 185 additions and 82 deletions.
diff --git a/Signum.Engine/Engine/SqlPreCommand.cs b/Signum.Engine/Engine/SqlPreCommand.cs
@@ -368,14 +368,19 @@ public SqlPreCommandSimple AddComment(string? comment)
         return this;
     }
 
-    public SqlPreCommandSimple ReplaceFirstParameter(string? variableName)
+    internal SqlPreCommandSimple ReplaceFirstParameter(string? variableName)
     {
         if (variableName == null)
             return this;
 
-        var first = Parameters!.FirstEx();
-        Sql = Regex.Replace(Sql, $@"(?<toReplace>{first.ParameterName})(\b|$)", variableName); //HACK
-        Parameters!.Remove(first);
+        this.ReplaceParameter(this.Parameters!.FirstEx(), variableName);
+        return this;
+    }
+
+    internal SqlPreCommandSimple ReplaceParameter(DbParameter param, string variableName)
+    {
+        Sql = Regex.Replace(Sql, $@"(?<toReplace>{param.ParameterName})(\b|$)", variableName); //HACK
+        Parameters!.Remove(param);
         return this;
     }
 

diff --git a/Signum.Engine/Schema/Schema.Delete.cs b/Signum.Engine/Schema/Schema.Delete.cs
@@ -1,4 +1,5 @@
 using Signum.Engine.Linq;
+using Signum.Utilities.Reflection;
 
 namespace Signum.Engine.Maps;
 
@@ -19,13 +20,34 @@ public SqlPreCommand DeleteSqlSync<T>(T entity, Expression<Func<T, bool>>? where
                            select new SqlPreCommandSimple("DELETE FROM {0} WHERE {1} = {2}; --{3}"
                                .FormatWith(tml.Name, tml.BackReference.Name.SqlEscape(isPostgres), variableOrId, comment ?? entity.ToString()))).Combine(Spacing.Simple);
 
+        var vmis = VirtualMList.RegisteredVirtualMLists.TryGetC(this.Type);
+
+        SqlPreCommand? virtualMList = vmis?.Values
+            .Select(vmi => giDeleteVirtualMListSync.GetInvoker(this.Type, vmi.BackReferenceRoute.RootType)(entity, vmi))
+            .Combine(Spacing.Double);
+
         var main = new SqlPreCommandSimple("DELETE FROM {0} WHERE {1} = {2}; --{3}"
                 .FormatWith(Name, this.PrimaryKey.Name.SqlEscape(isPostgres), variableOrId, comment ?? entity.ToString()));
 
         if (isPostgres && declaration != null)
-            return PostgresDoBlock(entity.Id.VariableName!, declaration, SqlPreCommand.Combine(Spacing.Simple, pre, collections, main)!);
+            return PostgresDoBlock(entity.Id.VariableName!, declaration, SqlPreCommand.Combine(Spacing.Simple, pre, collections, virtualMList, main)!);
+
+        return SqlPreCommand.Combine(Spacing.Simple, declaration, pre, collections, virtualMList, main)!;
+    }
+
+    static GenericInvoker<Func<Entity, VirtualMListInfo, SqlPreCommand?>> giDeleteVirtualMListSync = new GenericInvoker<Func<Entity, VirtualMListInfo, SqlPreCommand?>>(
+      (e, vmi) => DeleteVirtualMListSync<Entity, Entity>(e, vmi));
+    static SqlPreCommand? DeleteVirtualMListSync<T, E>(T entity, VirtualMListInfo vmli)
+        where T : Entity
+        where E : Entity
+    {
+        var table = Schema.Current.Table(typeof(E));
+
+        var backRef = vmli.BackReferenceRoute.GetLambdaExpression<E, Lite<T>>(safeNullAccess: false);
+
+        var delete = Administrator.UnsafeDeletePreCommand(Database.Query<E>().Where(e => backRef.Evaluate(e).Is(entity)));
 
-        return SqlPreCommand.Combine(Spacing.Simple, declaration, pre, collections, main)!;
+        return delete;
     }
 
     int parameterIndex;