将 Expression<Func> 选择器绑定到 linq 查询

Question

我正在使用将 linq 表达式转换为事件查询的库。 （流洞察力）。

我需要解决这个问题：

给定一些值，以及一个组合值的表达式。

var a = new[] { "a", "b", "c" };
var b = new[] { "x", "y", "z" };
Expression<Func<string, string, string>> combine = (x, y) => x + ":" + y;

我需要将 combine 函数绑定到以下查询，同时仍保持表达式语法。

var query =
    from f in a
    from g in b
    select combine(f, g);

query.Dump();

很遗憾，此 linq 语句的目标应用程序不支持原始格式的 Func<string, string, string>，因为查询是在运行时解释的。

我收到此错误：其他信息：Microsoft 复杂事件处理 LINQ 提供程序不支持以下表达式：'Invoke(value(System.Func`3...

如果我可以重现表达式，我想我会解决这个问题：

var query =
    from f in a
    from g in b
    select x + ":" + y;

我想将查询的选择部分作为Expression<Func<... 参数传递给函数。

我试过了，显然不太好用：

var query =
    a.SelectMany(a1 => b, (x, y) => new { x, y })
     .Select(_ => combine(_.x, _.y));

我已经简化了这个问题，但作为参考，真正的查询看起来像这样：

        var ms =
            requestStream
                .AlterEventLifetime(
                    _ => _.StartTime - TimeSpan.FromMilliseconds(10000),
                    _ => _.EndTime + TimeSpan.FromMilliseconds(10000) - _.StartTime)
                .SelectMany(requestData => responseStream
                    .AlterEventLifetime(
                        _ => _.StartTime - TimeSpan.FromMilliseconds(10000),
                        _ => _.EndTime + TimeSpan.FromMilliseconds(10000) - _.StartTime),
                    (requestData, responseData) => new {requestData, responseData})
                .Where(@t => @t.requestData.CorrelationTicketId == @t.responseData.CorrelationTicketId)
                .Where(@t => @t.requestData.CorrelationTicketId > 0
                             && @t.requestData.SuccessFailureCode != 3001)
                .Select(@t => expression(@t.requestData, @t.responseData));

Answer 1

您必须先编译表达式，然后才能将其用作函数：

var a = new[] { "a", "b", "c" };
var b = new[] { "x", "y", "z" };

Expression<Func<string, string, string>> combine = (x, y) => x + ":" + y;
var fu = combine.Compile();
var query =
        from f in a
        from g in b
        select fu(f, g);

Answer 2

HimBromBeere 的答案将起作用，如果您只打算将它与内存中的 IEnumerable<string> 源一起用于 a 和 b，那么它就是您要选择的。

否则，虽然它仍然可以与 IQueryable<string> 一起使用，但它会通过将相关字符串拉入内存来实现这一点，而不是将表达式向下推送到提供程序以便它可以成为 SQL 查询等。

处理IQueryable<string> as IQueryable<string> 你会想要：

var query = a.AsQueryable().SelectMany(_ => b, combine);

（当在 IEnumerable<string> 上运行时，这会成为一种稍微昂贵的方式来执行 a.SelectMany(_ => b, combine.Compile());，这是编写 HimBromBeere 给出的答案的另一种方式）。

Answer 3

补充说明：

Expression<Func<T>> 是未编译的表达式树。如果您要将它发送给需要解析表达式树并转换它们（而不仅仅是运行代码）的提供程序，例如实体框架，则需要使用它。

您的案例涉及确实需要这样做的提供程序，而不是在使用前编译表达式（当您尝试使用实际的 StreamInsight 源重用该代码块时，这将不起作用）您最好直接调用 @987654322 @ 在模拟数组上，如下所示：

// using function form of LINQ because it's more flexible
// also, using the join because that's what your query does - a cartesian product
var query = a.AsQueryable().Join(b.AsQueryable(), x => 0, x => 0, combine);

我还建议您对 IQStreamable 接口提供程序和扩展方法（来自 StreamInsight）的实际工作方式进行一些研究，因为我不认为裸数组是模拟事件流的最佳选择。