.NET Core 5中如何结合PostgreSQL使用Entity Framework原生查询？

问题背景 #

将.NET 5应用从SQL Server迁移至PostgreSQL，使用的NuGet包如下：

<PackageReference Include="Microsoft.EntityFrameworkCore" Version="5.0.0" />
<PackageReference Include="Npgsql.EntityFrameworkCore.PostgreSQL" Version="5.0.0" />

Linq查询可正常运行：

public async Task<ActionResult<List<LoadEntity>>> GetLoadByIdAsync(long id, CancellationToken cancellationToken)
{
    var entity = await _dbContext.LoadEntities
                .Where(e => e.LoadId == id)
                .ToListAsync();

    if (entity == null)
    {
        return NotFound();
    }

    return entity;
}

但使用原生查询时抛出错误：

public async Task<ActionResult<List<LoadEntity>>> GetLoadByIdAsync(long id, CancellationToken cancellationToken)
{
    var sqlQuery = $"SELECT * FROM Load WHERE LoadID = {0}";
    var entity = await _dbContext.LoadEntities
               .FromSqlRaw(sqlQuery, id)
               .ToListAsync();
            
    if (entity == null)
    {
        return NotFound();
    }

    return entity;
}

错误信息：

Npgsql.PostgresException (0x80004005): 42P01: relation "tbload" does not exist

at Npgsql.NpgsqlConnector.g__ReadMessageLong|194_0(NpgsqlConnector connector, Boolean async, DataRowLoadingMode dataRowLoadingMode, Boolean readingNotifications, Boolean isReadingPrependedMessage)...

问题原因 #

1. 表名不匹配：PostgreSQL对标识符（表名、列名）大小写敏感，未加引号的标识符会被自动转为小写。错误提示找不到tbload，说明EF Core将LoadEntity映射的实际表名是tbload（可能是通过配置约定或显式指定），但原生SQL中写的是Load，与实际表名不符。
2. Linq查询能正常运行是因为EF Core会自动根据映射关系生成匹配数据库的SQL，而原生查询需要完全对应数据库的实际标识符。

解决方案 #

1. 确认实体对应的实际表名 #

• 查看DbContext的OnModelCreating方法，是否有显式表名配置：

  protected override void OnModelCreating(ModelBuilder modelBuilder)
  {
      modelBuilder.Entity<LoadEntity>().ToTable("tbload"); // 显式指定表名为tbload
  }
  

• 直接查看PostgreSQL数据库中的表名，确认实际表名。

2. 修正原生SQL的表名 #

将SQL中的表名改为实际匹配的名称，例如实际表名为tbload，则修正后的代码：

public async Task<ActionResult<List<LoadEntity>>> GetLoadByIdAsync(long id, CancellationToken cancellationToken)
{
    // 使用正确的表名tbload
    var sqlQuery = "SELECT * FROM tbload WHERE \"LoadID\" = @loadId";
    var entity = await _dbContext.LoadEntities
               .FromSqlRaw(sqlQuery, new NpgsqlParameter("@loadId", id))
               .ToListAsync();
            
    if (!entity.Any()) // ToListAsync返回空列表而非null，用Any()判断是否无数据
    {
        return NotFound();
    }

    return entity;
}

3. 额外注意事项 #

• 列名大小写处理：如果数据库列名是驼峰式（如LoadID），需要用双引号包裹，否则PostgreSQL会将其转为小写（loadid）导致列不存在。
• 安全的参数化查询：推荐使用FromSqlInterpolated简化参数化，避免SQL注入风险：

  var entity = await _dbContext.LoadEntities
      .FromSqlInterpolated($"SELECT * FROM tbload WHERE \"LoadID\" = {id}")
      .ToListAsync();
  

• 空结果判断：ToListAsync返回的是空列表而非null，所以应该用!entity.Any()替代entity == null来判断是否无数据。

内容的提问来源于stack exchange，提问作者Zichen Ma