EF Core中执行无关联表存储函数遇问题，求解决方案

你之前使用ExecuteSqlRaw失败的核心原因是：这个方法仅用于执行非查询语句（如INSERT/UPDATE/DELETE），返回的是受影响行数，而非查询结果。以下是几种无需直接使用ADO.NET的正确实现方式：

方法1：用ExecuteScalar直接获取单个返回值 #

通过EF Core的Database对象调用ExecuteScalar（或异步版本ExecuteScalarAsync），同时必须使用参数化查询避免SQL注入：

// 同步调用（参数化写法，推荐）
long maxNoteId = (long)db.Database.ExecuteScalar(
    "SELECT GetMaxNoteId(@UserId)", 
    new NpgsqlParameter("@UserId", ChatId)
);

// 异步版本
long maxNoteId = (long)await db.Database.ExecuteScalarAsync(
    "SELECT GetMaxNoteId(@UserId)", 
    new NpgsqlParameter("@UserId", ChatId)
);

方法2：映射到对象查询 #

如果需要将结果封装为实体或匿名对象，可使用FromSqlRaw：

先定义用于接收结果的类（无需映射到数据库表）：

public class NoteIdResult
{
    public long NoteId { get; set; }
}

再执行查询并获取结果：

var result = db.Set<NoteIdResult>()
               .FromSqlRaw("SELECT GetMaxNoteId(@UserId) AS NoteId", new NpgsqlParameter("@UserId", ChatId))
               .FirstOrDefault();

long maxNoteId = result?.NoteId ?? 0;

方法3：注册函数到EF Core模型（推荐长期复用） #

若该函数会频繁调用，可将其注册到EF Core模型，通过LINQ直接调用：

1. 在DbContext的OnModelCreating中注册函数：

protected override void OnModelCreating(ModelBuilder modelBuilder)
{
    modelBuilder.HasDbFunction(typeof(YourDbContext).GetMethod(nameof(GetMaxNoteId), new[] { typeof(long) }))
                .HasName("GetMaxNoteId")
                .HasSchema("public"); // 对应函数所在的数据库schema，默认是public
}

// 在DbContext中定义匹配的方法（仅用于EF Core翻译，无需实现）
public long GetMaxNoteId(long userId)
{
    throw new NotSupportedException("该方法仅用于EF Core LINQ查询翻译");
}

2. 直接通过LINQ调用：

long maxNoteId = db.GetMaxNoteId(ChatId);

优化你的ADO.NET写法 #

如果仍需使用ADO.NET，建议用using语句自动释放资源，避免泄漏：

using (var conn = new NpgsqlConnection(db.Database.GetConnectionString()))
{
    using (var cmd = new NpgsqlCommand("SELECT GetMaxNoteId(@UserId)", conn))
    {
        cmd.Parameters.AddWithValue("@UserId", ChatId);
        conn.Open();
        long maxNoteId = (long)cmd.ExecuteScalar();
    }
}

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