EF Core 6如何在单次数据库调用中执行多个存储过程？

问题场景 #

正在重构基于MS SQL Server的应用程序，当前业务依赖两个已存在的存储过程：

• InsertFile @fileId, @fileName：插入文件记录
• DeleteFile @fileId：删除文件记录

实际业务中存在单次请求批量调用多个存储过程的需求，例如一次请求中需要插入多条文件记录、同时删除若干过期文件记录，待执行的语句序列示例如下：

InsertFile 100, file1
InsertFile 101, file2
DeleteFile 5
InsertFile 108, file8

旧版应用通过拼接所有待执行语句为单条SQL字符串，调用SqlCommand单次提交即可完成所有操作。新版应用基于Entity Framework Core 6.0.5开发，当前单存储过程的调用写法如下：

var fileIdParameter = new SqlParameter("@Id", fileId);
var fileNameParameter = new SqlParameter("@FileName", fileName);
await _db.Database.ExecuteSqlRawAsync("InsertFile @Id, @FileName", fileIdParameter, fileNameParameter);

这种写法在批量操作场景下会发起多次独立数据库往返，性能较差，需要实现单次数据库调用完成所有存储过程执行。

可行实现方案 #

方案1：动态拼接参数化SQL（改造成本最低，兼容现有存储过程） #

不需要修改数据库侧任何现有对象，逻辑和旧版实现对齐：按执行顺序拼接所有存储过程调用语句，为每个参数分配全局唯一名称避免重名冲突，最后将所有参数一次性传入ExecuteSqlRawAsync，EF Core会生成单个SqlCommand提交，仅产生一次数据库交互。
实现代码示例：

var sqlBuilder = new List<string>();
var parameters = new List<SqlParameter>();
int paramCounter = 0;

// 实际业务中从请求参数组装待执行操作集合即可
var pendingOps = new List<(string OpType, int FileId, string FileName)>()
{
    ("Insert", 100, "file1"),
    ("Insert", 101, "file2"),
    ("Delete", 5, null),
    ("Insert", 108, "file8")
};

foreach (var op in pendingOps)
{
    if (op.OpType == "Insert")
    {
        string idParam = $"@p{paramCounter++}";
        string nameParam = $"@p{paramCounter++}";
        sqlBuilder.Add($"InsertFile {idParam}, {nameParam}");
        parameters.Add(new SqlParameter(idParam, op.FileId));
        parameters.Add(new SqlParameter(nameParam, op.FileName));
    }
    else if (op.OpType == "Delete")
    {
        string idParam = $"@p{paramCounter++}";
        sqlBuilder.Add($"DeleteFile {idParam}");
        parameters.Add(new SqlParameter(idParam, op.FileId));
    }
}

// 用分号拼接为单条合法T-SQL
string finalSql = string.Join(';', sqlBuilder);

// 单次提交执行
await _db.Database.ExecuteSqlRawAsync(finalSql, parameters.ToArray());

实现注意事项：

• 每个参数必须分配唯一名称，禁止重复使用@Id、@FileName这类固定参数名，否则会出现参数值覆盖导致执行逻辑错误
• 所有值通过SqlParameter传入，全程保持参数化，不存在SQL注入风险
• T-SQL语法要求同一批处理内的多条语句用分号分隔，拼接时不要遗漏

方案2：表值参数（TVP）批量提交（适合大操作量场景，性能更优） #

如果单次请求涉及的增删操作量级较大（几十到上百条），拼接长SQL会产生额外的字符串解析开销，此时可以通过表值参数将所有操作封装为单个结构化参数传入数据库，仅需一次存储过程调用即可完成全部逻辑，性能更稳定。
实现步骤：

1. 首先在数据库侧创建表值类型和统一入口存储过程：

-- 定义文件操作的表值结构
CREATE TYPE FileOperationTable AS TABLE
(
    OpType TINYINT NOT NULL, -- 1=插入 2=删除
    FileId INT NOT NULL,
    FileName NVARCHAR(255) NULL
);
GO

-- 统一执行入口存储过程
CREATE PROCEDURE BatchExecuteFileOps
    @Ops FileOperationTable READONLY
AS
BEGIN
    SET NOCOUNT ON;
    DECLARE @CurrentOp TINYINT, @CurrentId INT, @CurrentName NVARCHAR(255);
    DECLARE op_cursor CURSOR FAST_FORWARD FOR
        SELECT OpType, FileId, FileName FROM @Ops;
    OPEN op_cursor;
    FETCH NEXT FROM op_cursor INTO @CurrentOp, @CurrentId, @CurrentName;
    WHILE @@FETCH_STATUS = 0
    BEGIN
        IF @CurrentOp = 1
            EXEC InsertFile @CurrentId, @CurrentName;
        ELSE IF @CurrentOp = 2
            EXEC DeleteFile @CurrentId;
        FETCH NEXT FROM op_cursor INTO @CurrentOp, @CurrentId, @CurrentName;
    END
    CLOSE op_cursor;
    DEALLOCATE op_cursor;
END

2. EF Core侧调用代码：

// 构建结构化操作表
var opTable = new DataTable();
opTable.Columns.Add("OpType", typeof(byte));
opTable.Columns.Add("FileId", typeof(int));
opTable.Columns.Add("FileName", typeof(string));

// 填充待执行操作
opTable.Rows.Add(1, 100, "file1");
opTable.Rows.Add(1, 101, "file2");
opTable.Rows.Add(2, 5, DBNull.Value);
opTable.Rows.Add(1, 108, "file8");

var tvpParam = new SqlParameter("@Ops", SqlDbType.Structured)
{
    TypeName = "FileOperationTable",
    Value = opTable
};

// 单次调用入口存储过程
await _db.Database.ExecuteSqlRawAsync("EXEC BatchExecuteFileOps @Ops", tvpParam);

补充说明 #

两种方案都默认保障操作原子性：单条SQL命令内的所有语句会在隐式事务中执行，任意步骤抛出异常都会自动回滚全部操作；如果已经通过EF Core开启了显式事务，所有操作也会自动纳入事务范围，不需要额外编码处理。

内容的提问来源于stack exchange，提问作者Volodymyr V.