关于 UNION、INTERSECT 和 EXCEPT 的 SqlException

Question

有人可以帮我解决这个例外吗？我不明白它的含义或如何解决它...这是一个带有以下消息的 SqlException：

使用 UNION、INTERSECT 或 EXCEPT 运算符组合的所有查询必须在其目标列表中具有相同数量的表达式。

我在伪代码中运行查询时得到它，如下所示：

// Some filtering of data
var query = data.Subjects
            .Where(has value)
            .Where(has other value among some set of values);

// More filtering, where I need to have two different options
var a = query
            .Where(some foreign key is null);
var b = query
            .Where(some foreign key is not null)
            .Where(and that foreign key has a property which is what I want);
query = a.Union(b);

// Final filter and then get result as a list
var list = query
            .Where(last requirement)
            .ToList();

如果我删除 a.Union(b) 部分，它会毫无例外地运行。所以我知道错误在那里。但为什么我会得到它？我该如何解决？我在这里做的事情太疯狂了吗？我是否误解了如何使用 Union 的东西？

基本上我所拥有的是一些实体，它们具有其他实体的外键。我需要获取所有将外键设置为null 或该外国实体满足某些要求的实体。

Answer 1

你能不能把它写在一个查询中？

.Where(row => row.ForeignKey == null || row.ForeignKey.SomeCondition);

也有合并表达式的方法 (OrElse)，但这并不是微不足道的。

但不确定错误来自哪里！

编辑：还没有测试过，但这在逻辑上应该等同于 UNION：

public static IQueryable<T> WhereAnyOf<T>(
    this IQueryable<T> source,
    params Expression<Func<T, bool>>[] predicates)
{
    if (source == null) throw new ArgumentNullException("source");
    if (predicates == null) throw new ArgumentNullException("predicates");
    if (predicates.Length == 0) return source.Where(row => false);
    if (predicates.Length == 1) return source.Where(predicates[0]);

    var param = Expression.Parameter(typeof(T), "row");
    Expression body = Expression.Invoke(predicates[0], param);
    for (int i = 1; i < predicates.Length; i++)
    {
        body = Expression.OrElse(body,
            Expression.Invoke(predicates[i], param));
    }
    return source.Where(Expression.Lambda<Func<T, bool>>(body, param));
}

Answer 2

查询 = a.Union(b);

改变捕获的变量不是一个好主意...可能是错误的原因。

更新：没关系

这是另一个想法。提示在错误消息中。

var a = query
         .Where(some foreign key is null)
         .Select(x => x);

或者通过添加另一个“假”来玩，直到它们变得相等:)

Answer 3

由于这看起来像是生成的 SQL 的问题，您应该尝试使用 SQL Profiler，或使用 this code for DebuggerWritter class 将 SQL 写入 Visual Studio 中的输出窗口。

SQL 错误通常是由于为 UNION 检索到的字段与 2 个查询不同。例如，如果第一个查询可能有 3 个字段，但第二个查询有 4 个字段，则会出现此错误。因此，在这种情况下，查看生成的 SQL 肯定会有所帮助。

Answer 4

我会调用data.GetCommand(query) 并分析生成的DbCommand（尤其是生成的SQL 字符串）。这应该可以为您提供有关问题所在的线索。

任何地方都没有投影，所以我希望两个目标列表是相同的。

您可以尝试将您的查询减少到一个仍然不起作用的较小的查询。从query.Union(query) 开始（这至少应该有效）。然后一一添加您的 Where 调用，看看它何时停止工作。

它必须是您的 Where 调用之一，它将额外的列添加到您的选择列表中。

Answer 5

您是否有机会将值传递给变量中的“选择”端，或者您是否多次返回相同的字段？ SP1 引入了一个错误，它试图“优化”此类事情，这可能导致联合查询中断（由于查询部分“优化”了不同的传入参数）。

如果您发布实际查询而不是伪代码，则更容易识别是否是这种情况。

（如果是这种情况，一种解决方法是先实现各个部分，然后执行客户端 (L2O) 联合）。

Answer 6

从您列出的 SQL 错误来看，您可能遇到了与我相同的问题。基本上，当在两个不同查询上使用 Concat 或 Union 扩展方法的 Linq to SQL 查询时，Linq to SQL 中似乎存在一个错误，该错误会分别优化每个投影，而不考虑投影必须保持不变才能完成的事实SQL 联合。

参考资料：

LINQ to SQL produces incorrect TSQL when using UNION or CONCAT

Linq to SQL Union Same Fieldname generating Error

如果这恰好是您的问题，我已经找到了一个适合我的解决方案，如下所示。

var queryA = 
    from a in context.TableA
    select new 
    {
        id,
        name,
        onlyInTableA,
    }

var queryB = 
    from b in context.TableB
    let onlyInTableA = default(string)
    select new 
    {
        id,
        name,
        onlyInTableA,
    }

var results = queryA.Union(queryB).ToList();

Answer 7

jpierson 正确总结了问题。
我也遇到了问题，这次是由select语句中的一些文字引起的：
Dim results = (From t in TestDataContext.Table1 _
Where t.ID = WantedID _
Select t.name, SpecialField = 0, AnotherSpecialField = 0, t.Address).Union _
From t in TestDataContext.Table1 _
Where t.SecondID = WantedSecondID _
Select t.name, SpecialField = 1, AnotherSpecialField = 0, t.Address)

优化了“SpecialField = 0”和“AnotherSpecialField = 0”的第一个子查询，导致union中使用一个字段而不是两个，显然会失败。
我必须更改第一个查询，以便 SpecialField 和 AnotherSpecialField 具有不同的值，就像在第二个子查询中一样。

Answer 8

好吧，我对此有疑问。使用 Sql 08 我有两个表函数，在这两种情况下都返回一个 int 和一个字符串。我创建了一个复杂的对象并使用 linq 来尝试 UNION。有一个 IEqualityComparer 进行比较。一切编译正常，但因不支持的重载而崩溃。好的，我意识到所讨论的问题似乎有点延迟执行。所以我得到了集合，并放置了 ToList()，然后执行 UNION，一切都很好。不确定这是否有帮助，但它对我有用