使用 Z.EntityFramework.Plus 更新不会更新数据答案

【问题标题】：Updating using Z.EntityFramework.Plus is not updating data使用 Z.EntityFramework.Plus 更新不会更新数据
【发布时间】：2021-02-12 04:52:13
【问题描述】：

我的 UnitOfWork 存储库中有一个更新方法，如下所示：

public async Task<int> UpdateAsync(Expression<Func<T, bool>> predicate, Expression<Func<T, T>> updateExpression)
{
     return await dbSet.Where(predicate).UpdateAsync(updateExpression);
}

我的逻辑中也有一个更新方法，如下所示：其中 BetSelection 有一个选择 ID 作为外键。

private async Task UpdateBetSelections(Table table)
{
     await _unitOfWork.BetSelection
          .UpdateAsync(bs => bs.Selection.TableId == table.Id && bs.Selection.RoundId == table.CurrentRound,
     bs => new BetSelection()
     {
           Status = bs.Selection.Status
     });
}

我正在尝试将一轮的所有 BetSelection 记录状态更新为其相应选择状态的状态。查询没有抛出任何错误，也没有更新记录。

【问题讨论】：

不熟悉这个扩展。但是您要尝试将状态更新为相同的状态吗？
@SvyatoslavDanyliv 是的，我正在尝试将 BetSelection 记录的状态更新为选择记录的状态，其中该选择是 BetSelection 的模型
哦，它是一个导航属性...错过了。我认为这个扩展不能处理导航属性。如果你没有自己的 LINQ 翻译器，那就很难了。我不得不为此提出更好的扩展：github.com/linq2db/linq2db.EntityFrameworkCore

标签： c# sql database asp.net-core entity-framework-core

【解决方案1】：

更新

根据this，尚不支持复杂类型

Github issue

原答案

不幸的是，看起来有一个错误。我创建了小型复制器，它生成了以下 sql。没有提到导航属性。

UPDATE A
SET A.[Status] = B.[Status]
FROM [BetSelections] AS A
INNER JOIN ( SELECT [b].[Id], [b].[SelectionId], [b].[Status]
FROM [BetSelections] AS [b]
           ) AS B ON A.[Id] = B.[Id]

复制代码

using Microsoft.EntityFrameworkCore;
using System;
using System.Collections.Generic;
using System.Threading.Tasks;
using Z.EntityFramework.Plus;

namespace ConsoleApp1
{
    public class Selection
    {
        public int Id { get; set; }

        public int Status { get; set; }

        public virtual ICollection<BetSelection> Selections { get; set; }
    }

    public class BetSelection
    {
        public int Id { get; set; }

        public int Status { get; set; }

        public int SelectionId { get; set; }

        public virtual Selection Selection { get; set; }
    }

    public class AppDbContext : DbContext
    {
        public DbSet<Selection> Selections { get; set; }

        public DbSet<BetSelection> BetSelections { get; set; }

        protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
        {
            optionsBuilder.UseSqlServer("Server=DESKTOP-5PVJ0I5;Database=zefcore-so1;Integrated Security=true");

            base.OnConfiguring(optionsBuilder);
        }
    }

    class Program
    {
        static async Task Main(string[] args)
        {
            BatchUpdateManager.BatchUpdateBuilder = builder => {
                builder.Executing = c =>
                {
                    Console.WriteLine(c.CommandText);
                };
            };

            var db = new AppDbContext();

            var selection = db.Selections.Add(new Selection()
            {
                Status = 1,
            });

            db.BetSelections.Add(new BetSelection()
            {
                Selection = selection.Entity,
                Status = 2,
            });

            db.SaveChanges();

            await db.BetSelections
                .UpdateAsync(x => new BetSelection() { Status = x.Selection.Status });
        }
    }
}

此外，如果您将父字段重命名为其他名称，在我的情况下为 Status111，您将在下面的 sql 中获得无效列异常

UPDATE A
SET A.[Status] = B.[Status111]
FROM [BetSelections] AS A
INNER JOIN ( SELECT [b].[Id], [b].[SelectionId], [b].[Status]
FROM [BetSelections] AS [b]
           ) AS B ON A.[Id] = B.[Id]

【讨论】：