1

我已经解决这个问题一个星期了,我对 EF 感到非常沮丧。首先,我在数据库中有一个超级表-> 子表模式。它采用代码优先的方法设计。超类型称为 WorkflowTask,定义如下:

<!-- language: c# -->
public abstract class WorkflowTask 
{
    public int WorkflowTaskId { get; set; }
    public int Order { get; set; }        
    public WorkflowTaskType WorkflowTaskType { get; set; }
    public WorkFlowTaskState State { get; set; }
    public ParentTask ParentTask { get; set; }        
    public WorkflowDefinition WorkflowDefinition { get; set; }
}

一个示例子任务将从该任务继承并提供其他属性:

<!-- language: c# -->
public class DelayTask : WorkflowTask
{
    public int Duration { get; set; }
}

这被映射到数据库,如下所示:

<!-- language: c# -->
public class WorkflowTaskEntityConfiguration : EntityTypeConfiguration<WorkflowTask>
{
    public WorkflowTaskEntityConfiguration()
    {

        HasKey(w => w.WorkflowTaskId);
        Property(w => w.WorkflowTaskId).HasColumnName("Id");
        Property(w => w.Order).HasColumnName("Order");
        Property(w => w.WorkflowTaskType).HasColumnName("TaskTypeId");
        Property(w => w.State).HasColumnName("TaskStateId");
        HasOptional(c => c.ParentTask).WithMany()
                .Map(c => c.MapKey("ParentTaskId"));
    }
}

延迟任务映射如下:

<!-- language: c# -->
public class DelayTaskEntityConfiguration : EntityTypeConfiguration<DelayTask>
{
    public DelayTaskEntityConfiguration()
    {
        Property(d => d.WorkflowTaskId).HasColumnName("DelayTaskId");
        Property(d => d.Duration).HasColumnName("Duration");    
    }
} 

希望你明白这一点。现在我有另一种称为容器任务的子类型。此任务将持有其他任务,并且可能会持有其他容器任务。这是它的外观以及映射:

<!-- language: c# -->
public class ContainerTask : ParentTask
{
    public ContainerTask()
    {
        base.WorkflowTaskType = WorkflowTaskType.Container;
        base.ParentTaskType = ParentTaskType.ContainerTask;
    }        
    public List<WorkflowTask> ChildTasks { get; set; }
}

public class ContainerTaskEntityConfiguration : EntityTypeConfiguration<ContainerTask>
{
    public ContainerTaskEntityConfiguration()
    {            

        Property(x => x.WorkflowTaskId).HasColumnName("ContainerTaskId");           
        HasMany(c => c.ChildTasks).WithMany()
            .Map(c => c.ToTable("ContainerTaskChildren", WorkflowContext.SCHEMA_NAME)
                       .MapLeftKey("ContainerTaskId")
                       .MapRightKey("ChildTaskId"));                  
    }
}

并确保我包括所有内容;这是 ParentTask 对象及其映射:

<!-- language: c# -->
public abstract class ParentTask : WorkflowTask
{
    public ParentTaskType ParentTaskType {get; set;}
}

public class ParentTaskEntityConfiguration : EntityTypeConfiguration<ParentTask>
{
    public ParentTaskEntityConfiguration()
    {
        Property(w => w.WorkflowTaskId).HasColumnName("ParentTaskId");
        Property(w => w.ParentTaskType).HasColumnName("ParentTaskTypeId");
    }
}

现在我要保存的项目是 WorkflowDefinition 对象。它将按顺序执行一堆任务。定义如下:

<!-- language: c# -->
public class WorkflowDefinition 
{
    public int WorkflowDefinitionId { get; set; }
    public string WorkflowName { get; set; }
    public bool Enabled { get; set; }

    public List<WorkflowTask> WorkflowTasks { get; set; }
}

public class WorkflowDefinitionEntityConfiguration :
                                   EntityTypeConfiguration<WorkflowDefinition>
{
    public WorkflowDefinitionEntityConfiguration()
    {
        Property(w => w.WorkflowDefinitionId).HasColumnName("Id");
        HasMany(w => w.WorkflowTasks)
            .WithRequired(t=> t.WorkflowDefinition)               
            .Map(c => c.MapKey("WorkflowDefinitionId"));

        Property(w => w.Enabled).HasColumnName("Enabled");
        Property(w => w.WorkflowName).HasColumnName("WorkflowName");
    }
}

因此,通过所有定义,我将 WorkflowDefinition 对象传递到我的数据存储库层并希望使用 EF 保存它。由于对象在 UI 中处理它时丢失了它的上下文;我必须重新关联它,以便它知道要保存什么。在 UI 中,我可以向工作流添加新任务、编辑现有任务以及删除任务。如果只有一级任务(定义 => 任务),这将是小菜一碟。我的问题在于存在无限级别的可能性(定义=>任务=>子任务=>子任务等...)。

目前,我从数据库中检索现有工作流并分配值(工作流是传入的值,属于 WorkflowDefinition 类型):

<!-- language: c# -->
// retrieve the workflow definition from the database so that it's within our context
var dbWorkflow = context.WorkflowDefinitions
                    .Where(w => w.WorkflowDefinitionId ==workflow.WorkflowDefinitionId)
                    .Include(c => c.WorkflowTasks).Single();

// transfer the values of the definition to the one we retrieved.
context.Entry(dbWorkflow).CurrentValues.SetValues(workflow);

然后我遍历任务列表并将它们添加到定义中或找到它们并设置它们的值。我向 WorkflowTask 对象添加了一个名为 SetDefinition 的函数,它将 WorkflowDefinition 设置为上下文中的工作流(以前我会收到一个关键错误,因为它认为父工作流是不同的,即使 Id 匹配)。如果它是一个容器,我会运行一个递归函数来尝试将所有子项添加到上下文中。

<!-- language: c# -->
foreach (var task in workflow.WorkflowTasks)
{
    task.SetDefinition(dbWorkflow);

    if (task.WorkflowTaskId == 0)
    {
        dbWorkflow.WorkflowTasks.Add(task);
    }
    else
    {
        WorkflowTask original = null;
        if (task is ContainerTask)
        {
            original = context.ContainerTasks.Include("ChildTasks")
                                .Where(w => w.WorkflowTaskId == task.WorkflowTaskId)
                                .FirstOrDefault();
            var container = task as ContainerTask;
            var originalContainer = original as ContainerTask;
            AddChildTasks(container, dbWorkflow, context, originalContainer);
        }
        else
        {
            original = dbWorkflow.WorkflowTasks.Find(t => t.WorkflowTaskId == 
                                                             task.WorkflowTaskId);
        }
        context.Entry(original).CurrentValues.SetValues(task);
    }
}

AddChildTasks 函数如下所示:

<!-- language: c# -->
private void AddChildTasks(ContainerTask container, WorkflowDefinition workflow, 
                           WorkflowContext context, ContainerTask original)
    {
        if (container.ChildTasks == null) return;

        foreach (var task in container.ChildTasks)
        {
            if (task is ContainerTask)
            {
                var subContainer = task as ContainerTask;
                AddChildTasks(subContainer, workflow, context, container);
            }

            if (task.WorkflowTaskId == 0)
            {
                if (container.ChildTasks == null) 
                    container.ChildTasks = new List<WorkflowTask>();
                original.ChildTasks.Add(task);
            }
            else
            {
                var originalChild = original.ChildTasks
                       .Find(t => t.WorkflowTaskId == task.WorkflowTaskId);
                context.Entry(originalChild).CurrentValues.SetValues(task);
            }
        }
    }

要删除任务,我ve found I必须执行两步过程。第 1 步涉及检查原始定义并将不再在传入定义中的任务标记为删除。第 2 步只是将这些任务的状态设置为已删除。

<!-- language: c# -->
var deletedTasks = new List<WorkflowTask>();
foreach (var task in dbWorkflow.WorkflowTasks)
{
    if (workflow.WorkflowTasks.Where(t => t.WorkflowTaskId == 
                  task.WorkflowTaskId).FirstOrDefault() == null)
        deletedTasks.Add(task);
}

foreach (var task in deletedTasks)
    context.Entry(task).State = EntityState.Deleted;

这是我遇到问题的地方。如果我删除一个容器,我会收到一个约束错误,因为该容器包含子项。UI 保存内存中的所有更改,直到我点击保存,所以即使我先删除了子项,它仍然会引发约束错误。我想我需要以不同的方式映射孩子,也许使用级联删除或其他方式。此外,当我遍历删除循环中的任务时,当我只希望容器被标记并因此子项被删除时,容器和子项都被标记为删除。

最后,上面的保存部分花了我一个星期的时间来弄清楚,它看起来很复杂。有没有更简单的方法来做到这一点?我对 EF 很陌生,我开始认为让代码生成 SQL 语句并按我想要的顺序运行它们会更容易。

这是我在这里的第一个问题,所以我为长度和格式道歉......希望它是清晰的:-)

4

2 回答 2

0

好吧,我花了比我希望的更长的时间,但我想我终于弄明白了。至少我所有的测试都通过了,到目前为止我保存的所有定义都在工作。可能有一些我没有考虑过的组合,但现在我至少可以继续做其他事情。

首先,我将对象作为树传递,并决定将其展平。这只是意味着所有任务都可以从根目录中看到,但我仍然需要设置父属性和子属性。

foreach (var task in workflow.WorkflowTasks)
    {
    taskIds.Add(task.WorkflowTaskId);  //adding the ids of all tasks to use later
    task.SetDefinition(dbWorkflow);    //sets the definition to record in context
    SetParent(context, task);          //Attempt to set the parent for any task

    if (task.WorkflowTaskId == 0)
    {
        // I found if I added a task as a child it would duplicate if I added it
        // here as well so I only add tasks with no parents
        if (task.ParentTask == null)
            dbWorkflow.WorkflowTasks.Add(task);
    }
    else
    {
        var dbTask = dbWorkflow.WorkflowTasks.Find(t => t.WorkflowTaskId == task.WorkflowTaskId);
        context.Entry(dbTask).CurrentValues.SetValues(task);
    }
}

SetParent 函数必须检查任务是否有父任务并确保父任务不是新任务(id == 0)。然后它会尝试在定义的上下文版本中找到父级,这样我就不会得到重复(即 - 如果父级没有被引用,它会尝试添加一个新的父级,即使它存在于数据库中)。一旦确定了父级,我检查它的子级以查看该任务是否已经存在,如果没有,我添加它。

private void SetParent(WorkflowContext context, WorkflowTask task)
    {
        if (task.ParentTask != null && task.ParentTask.WorkflowTaskId != 0)
        {
            var parentTask = context.WorkflowTasks.Where(t => t.WorkflowTaskId == task.ParentTask.WorkflowTaskId).FirstOrDefault();
            var parent = parentTask as ParentTask;
            task.ParentTask = parent;
            if (parentTask is ContainerTask)
            {
                var container = context.ContainerTasks.Where(c => c.WorkflowTaskId == parentTask.WorkflowTaskId).Include(c => c.ChildTasks).FirstOrDefault() as ContainerTask;
                if (container.ChildTasks == null)
                    container.ChildTasks = new List<WorkflowTask>();
                var childTask = container.ChildTasks.Find(t => t.WorkflowTaskId == task.WorkflowTaskId
                                                                && t.Order == task.Order);

                if(childTask == null)
                    container.ChildTasks.Add(task);
            }
        }
    }

您会在 SetParent 代码中注意到的一件事是我正在按 ID 和订单搜索任务。我必须这样做,因为如果我将两个新的孩子添加到容器中,那么两个 Id 都将为零,并且第二个不会被添加,因为它找到了第一个。每个任务都有一个独特的顺序,所以我用它来进一步区分它们。

我对这段代码感觉不太好,但我一直在研究这个问题很长时间,而且它有效,所以我现在要离开它。我希望我涵盖了所有信息,我不太确定有多少人真正需要这个,但你永远不知道。

于 2013-09-26T13:58:49.703 回答
0

一个建议,我没有在可能存在无限递归的情况下使用它,但是如果您希望删除时的级联在本地工作并且看起来所有任务都直接属于某个父任务,您可以通过定义来处理它识别关系:

modelBuilder.Entity<WorkFlowTask>().HasKey(c => new {c.WorkflowTaskID, 
                    c.ParentTask.WofkflowTaskId});

这个问题是相关的:EF可以自动删除未删除父项的孤立数据吗?

编辑:这个链接:https ://stackoverflow.com/a/4925040/1803682

于 2013-09-09T16:16:27.503 回答