EF Core Union查询未用Convert.ToString()时失败的原因排查

问题场景与代码 #

以下是将三个表查询结果通过Union合并并排序的EF Core代码：

var adjustments = DbContext.StorageAdjustments
    .Where(a => a.StorageId == id && a.TimeStamp >= start)
    .Select(a => new StorageUpdateModel
    {
        TimeStamp = a.TimeStamp,
        Change = a.Quantity,
        Product = a.Product.Name,
        UpdateType = StorageUpdateType.Adjustment,
        UpdateData = Convert.ToString(a.UserName),
        UpdateData2 = Convert.ToString(a.Comments),
        Id = 0,
    });

var trucks = DbContext.StorageTrucks
    .Where(t => t.StorageId == id && t.TimeStamp >= start)
    .Select(t => new StorageUpdateModel
    {
        TimeStamp = t.TimeStamp,
        Change = -t.Quantity,
        Product = "",
        UpdateType = StorageUpdateType.Truck,
        UpdateData = (t.Truck.BillOfLading.HasValue && t.Truck.BillOfLading.Value>0 ? Convert.ToString(t.Truck.BillOfLading.Value) :""),
        UpdateData2 = (t.Truck.ManualEntry ? "True" : "False"),
        Id = t.TruckId,
    });

var railcars = DbContext.StorageRailcars
    .Where(r => r.StorageId == id && r.TimeStamp >= start)
    .Select(r => new StorageUpdateModel
    {
        TimeStamp = r.TimeStamp,
        Change = -r.Quantity,
        Product = "",
        UpdateType = StorageUpdateType.Railcar,
        UpdateData = ((r.Railcar!=null && r.Railcar.RailcarNumber!=null)? Convert.ToString(r.Railcar.RailcarNumber) : ""),
        UpdateData2 = "",
        Id = r.RailcarId,
    });

var query = adjustments
    .Union(trucks)
    .Union(railcars)
    .OrderByDescending(u => u.TimeStamp)
    .AsQueryable();

var results = await query.ToListAsync();

抛出的异常 #

System.InvalidOperationException
  HResult=0x80131509
  Message=Unable to translate set operation when matching columns on both sides have different store types.
  Source=Microsoft.EntityFrameworkCore.Relational
  StackTrace:
   at Microsoft.EntityFrameworkCore.Query.SqlExpressions.SelectExpression.ApplySetOperation(SetOperationType setOperationType, SelectExpression select2, Boolean distinct)
   ...

已知条件 #

• a.Product.Name本身是string类型，StorageUpdateModel.Product同样为string类型且为必填项
• 项目禁用了可为空引用类型
• 使用EF Core 7.0.3

问题 #

为何将Product = a.Product.Name修改为Product = Convert.ToString(a.Product.Name)后，异常不再抛出？

解答 #

核心原因在于EF Core对Union操作的校验逻辑：它会严格检查数据库存储类型的一致性，而非仅.NET类型。即使.NET层面都是string，数据库中对应字段的类型元数据可能存在差异：

1. 类型映射差异：a.Product.Name对应的数据库列可能是带长度限制的字符串类型（比如NVARCHAR(255)），而直接写Product = ""时，EF Core会将这个常量解析为默认的字符串类型（比如VARCHAR(1)或无长度限制的字符串），两者的数据库存储类型不匹配，触发Union操作的类型校验失败。
2. 显式转换的作用：使用Convert.ToString(a.Product.Name)时，EF Core会将这个表达式翻译为SQL中的CAST或CONVERT语句，强制把Product.Name的列值转换为统一的字符串类型，和另外两个查询中Product = ""的解析类型对齐，消除了存储类型的差异，从而通过Union的校验。

简单来说，虽然.NET类型一致，但EF Core的SQL翻译会严格对应数据库的类型定义，显式转换能抹平实体属性与常量字符串之间的隐式类型映射差异，让Union操作的两边字段存储类型完全匹配。

内容的提问来源于stack exchange，提问作者Jonathan Wood