LINQ-to-SQL:将 Func 转换为表达式 >

2024-02-03

LINQ-to-SQL 对我来说是一个 PITA。我们使用它与数据库进行通信,然后通过 WCF 将实体发送到 Silverlight 应用程序。一切都工作正常,直到开始编辑 (CUD) 实体及其相关数据。

我终于能够设计出两个允许 CUD 的 for 循环。我尝试重构它们,而且非常接近,直到我发现我不能总是用 L2S 来做 Lambda。

public static void CudOperation<T>(this DataContext ctx, IEnumerable<T> oldCollection, IEnumerable<T> newCollection, Func<T, T, bool> predicate)
    where T : class
{
    foreach (var old in oldCollection)
    {
        if (!newCollection.Any(o => predicate(old, o)))
        {
            ctx.GetTable<T>().DeleteAllOnSubmit(ctx.GetTable<T>().Where(o => predicate(old, o)));
        }
    }

    foreach (var newItem in newCollection)
    {
        var existingItem = oldCollection.SingleOrDefault(o => predicate(o, newItem));
        if (existingItem != null)
        {
            ctx.GetTable<T>().Attach(newItem, existingItem);
        }
        else
        {
            ctx.GetTable<T>().InsertOnSubmit(newItem);
        }
    }
}

调用者:

ctx.CudOperation<MyEntity>(myVar.MyEntities, newHeader.MyEntities,
    (x, y) => x.PkID == y.PkID && x.Fk1ID == y.Fk1ID && x.Fk2ID == y.FK2ID);

这几乎奏效了。但是,我的 Func 需要是一个 Expression>,这就是我陷入困境的地方。

有谁可以告诉我这是否可能?由于 SharePoint 2010,我们必须使用 .NET 3.5。


只需更改参数:

 Func<T, T, bool> predicate

To:

 Expression<Func<T, T, bool>> predicate

表达式由编译器生成。

现在的问题是如何使用它。

就您而言,您需要两个Func and an Expression,因为你在使用它EnumerableLINQ 查询(基于函数)以及 SQL LINQ 查询(基于表达式)。

In:

.Where(o => predicate(old, o))

The old参数是固定的。所以我们可以将参数更改为:

Func<T, Expression<Func<T, bool>>> predicate

这意味着我们可以提供一个参数(“固定”参数)并返回一个表达式。

foreach (var old in oldCollection)
{
    var condition = predicate(old);
    // ...
    {
        ctx.GetTable<T>().DeleteAllOnSubmit(ctx.GetTable<T>().Where(condition));
    }
}

我们还需要在中使用它Any。要从表达式中获取 Func,我们可以调用Compile():

foreach (var old in oldCollection)
{
    var condition = predicate(old);
    if (!newCollection.Any(condition.Compile()))
    {
        ctx.GetTable<T>().DeleteAllOnSubmit(ctx.GetTable<T>().Where(condition));
    }
}

您可以对下一部分做同样的事情。

有两个问题:

  1. 性能可能会受到使用的影响Compile()很多。我不确定它实际上会产生多大的影响,但我会对其进行分析以进行检查。
  2. 现在的用法有点奇怪,因为这是一个柯里化的 lambda。而不是通过(x,y) => ...你将会经过x => y => ...。我不确定这对你来说是否是件大事。

可能有更好的方法来做到这一点:)

这是一个替代方法,这应该会快一点,因为表达式只需编译一次。创建一个将“应用”一个参数的重写器,如下所示:

class PartialApplier : ExpressionVisitor
{
    private readonly ConstantExpression value;
    private readonly ParameterExpression replace;

    private PartialApplier(ParameterExpression replace, object value)
    {
        this.replace = replace;
        this.value = Expression.Constant(value, value.GetType());
    }

    public override Expression Visit(Expression node)
    {
        var parameter = node as ParameterExpression;
        if (parameter != null && parameter.Equals(replace))
        {
            return value;
        }
        else return base.Visit(node);
    }

    public static Expression<Func<T2,TResult>> PartialApply<T,T2,TResult>(Expression<Func<T,T2,TResult>> expression, T value)
    {
        var result = new PartialApplier(expression.Parameters.First(), value).Visit(expression.Body);

        return (Expression<Func<T2,TResult>>)Expression.Lambda(result, expression.Parameters.Skip(1));
    }
}

然后像这样使用它:

public static void CudOperation<T>(this DataContext ctx,
    IEnumerable<T> oldCollection,
    IEnumerable<T> newCollection,
    Expression<Func<T, T, bool>> predicate)
    where T : class
{

    var compiled = predicate.Compile();

    foreach (var old in oldCollection)
    {
        if (!newCollection.Any(o => compiled(o, old)))
        {
            var applied = PartialApplier.PartialApply(predicate, old);
            ctx.GetTable<T>().DeleteAllOnSubmit(ctx.GetTable<T>().Where(applied));
        }
    }

    foreach (var newItem in newCollection)
    {
        var existingItem = oldCollection.SingleOrDefault(o => compiled(o, newItem));
        if (existingItem != null)
        {
            ctx.GetTable<T>().Attach(newItem, existingItem);
        }
        else
        {
            ctx.GetTable<T>().InsertOnSubmit(newItem);
        }
    }
}
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

LINQ-to-SQL:将 Func 转换为表达式 > 的相关文章

随机推荐

  • HTML 5 音频 .play() 在移动设备上的延迟

    我刚刚使用 socket io 构建了一个实时应用程序 其中 主 用户可以在接收设备 桌面浏览器 移动浏览器 上触发声音 该主用户会看到声音文件列表 并且可以在声音文件上单击 播放 音频播放在浏览器上是即时的 然而 在移动设备上 会出现 0
  • 无法在ExtJs中发送参数Ajax

    我在 View Extjs 中有代码 这是代码 var storeTree Ext create Ext data TreeStore proxy type ajax method POST url data newoss get pake
  • 使用或不使用“new”关键字创建 Mongoose 模式?

    我在网上看到的大多数例子都是这样做的 var UserSchema new mongoose Schema name String age String 然而 最近我发现一本书做了上述 但没有 new 关键字 var UserSchema
  • WCF Rest ERR_CONNECTION_RESET 响应不大

    错误代码绝对是可怕的 ERR CONNECTION RESET 有很多原因 我在其他问题上发现的原因与大型 Web 服务调用的 MaxRequestLength 太小有关 不过 我返回的数据只有几 kB 所以这不是问题 这是我的界面代码 W
  • 如何将 prettier 配置添加到 eslint 配置中?

    请注意 我不希望在我的 JS 项目中使用分号 Youtube 视频 https www youtube com watch v KfVPVmORnL4 我尝试在 eslintrc cjs 文件中禁用它 但奇怪的是semi 0无法禁用丢失警告
  • 如何在新进程中运行函数?

    现在我处于进程的线程之一A 我需要创建新流程B在当前线程中 并在进程中运行B功能MyFunc 我该怎么做 我找到了如何从当前进程创建子进程 click http msdn microsoft com en us library window
  • jqgrid - 添加新行并禁用restoreRow功能

    如果我要添加新行并且启用自动编辑新添加的行 那么我想执行验证并通过 ENTER 按钮保存行 但我不想通过 ESC 按钮恢复行 因为我设置了required true按所有字段 如果新添加的行将至少有一个字段为空 则按 ESC 按钮 rest
  • 如何将动态组件放入容器中

    我想创建动态组件并将这些组件的视图插入到容器中 我认为这可以通过以下方式实现视图容器引用 https angular io docs ts latest api core index ViewContainerRef class html
  • TypeError C 是未定义的数据表

    我试图将使用 ajax 获得的一些数据渲染到数据表中 但似乎我丢失了一些东西 因为它显示错误 TypeError c is undefined 我读过这篇文章 数据表类型错误 c 未定义 https stackoverflow com qu
  • 无论如何要将 Owin HTTPS 限制为 TLS 1.2?

    我想将我的 Webapi 锁定为 TLSv1 2 因此不允许使用 TLSv1 1 等 我看到了以下帖子 但它似乎只与 ASP NET Core 相关 有什么方法可以将 ASP NET Core 2 0 HTTPS 限制为 TLS 1 2 h
  • 无法使用 no_std/lang_items 编译 Rust

    我正在尝试建立一个非常类似于的项目dueboot https github com jensnockert dueboot 即嵌入式 ARM 上的 Rust 现在 我只完成了 Rust 代码的编译 但无法编译它 我基本上完全从该项目中复制了
  • IOS企业应用无法安装请稍后再试

    I know this question has been asked a lot on SO however I can ensure that my case is different I am unable to install an
  • 两点碰撞法线

    我正在尝试计算两点的碰撞法线 我需要这个碰撞响应方程来计算新的角速度和线速度 例如 当两个 2d 或 3d 盒子的角相互碰撞时 就会发生这种情况 他们的碰撞正常情况是怎样的 现在 在顶点和面碰撞的情况下 碰撞法线将只是面的法线 它是未定义的
  • 用于文件引用的c# xml代码注释

    xml代码注释中有文件引用的标签吗 该文件是一个sql脚本文件 只是想知道是否有比这样更好的方法
  • 通过 $resource angularjs 获取条件数据

    我正在使用 resource 服务进行增删改查操作 现在我想获取诸如开始日期为今天的约会之类的条件的数据 我正在通过以下方式获取所有数据 vm appointments AppointmentsService query 我的服务代码是 f
  • 过滤包含特定字符串的行

    我必须使用包含字符串的行作为标准来过滤数据框RTB 我在用着dplyr d del lt df gt group by TrackingPixel gt summarise MonthDelivery as integer sum Reve
  • 警告:文本内容不匹配。服务器:“我出去了” 客户端:“我进来了” div

    我在用着universal cookie在 Next js 项目中 这是在控制台中返回警告的简单代码 import React useState from react import Cookies from universal cookie
  • 如何在 Frama-C 中自定义机器依赖?

    我有一个 16 位 MPU 其大小与 x86 16 不同size t ptrdiff t等等 任何人都可以给我有关如何在 Frama C 中为我的 MPU 自定义机器依赖性的详细信息和明确说明吗 目前无法直接从命令行执行此操作 您必须编写一
  • SwiftUI Font 如何将 uppercased() 与 LocalizedStringKey 一起使用

    我正在尝试创建一种斜体和大写的字体样式 我还使用 LocalizedStringKey 来设置我的字符串 我尝试使用smallCaps 但这不适用于italic 如所回答HERE https stackoverflow com questi
  • LINQ-to-SQL:将 Func 转换为表达式 >

    LINQ to SQL 对我来说是一个 PITA 我们使用它与数据库进行通信 然后通过 WCF 将实体发送到 Silverlight 应用程序 一切都工作正常 直到开始编辑 CUD 实体及其相关数据 我终于能够设计出两个允许 CUD 的 f