EF Core从数据库下载varbinary大文件速度过慢的优化求助

以下是几个无需更改文件存储位置的优化方案：

• 启用流式读取，避免一次性加载大字段到内存
  EF Core默认会将整个varbinary(max)内容加载到内存中，大文件场景下会导致内存开销剧增、传输效率低下。可以通过原生ADO.NET配合CommandBehavior.SequentialAccess实现流式读取，让数据按顺序逐步传输，而非一次性加载：

using var command = context.Database.GetDbConnection().CreateCommand();
command.CommandText = "SELECT [ID_FILE], [FILE_BYTES] FROM [FILE] WHERE [ID_FILE] IN (@id1, @id2, @id3)";
// 添加参数避免SQL注入
command.Parameters.Add(new SqlParameter("@id1", SqlDbType.BigInt) { Value = 1 });
command.Parameters.Add(new SqlParameter("@id2", SqlDbType.BigInt) { Value = 2 });
command.Parameters.Add(new SqlParameter("@id3", SqlDbType.BigInt) { Value = 3 });

await context.Database.OpenConnectionAsync();
using var reader = await command.ExecuteReaderAsync(CommandBehavior.SequentialAccess);
while (await reader.ReadAsync())
{
    var fileId = reader.GetInt64(0);
    using var fileStream = reader.GetStream(1);
    // 将流直接写入本地文件或其他输出目标
    await fileStream.CopyToAsync(new FileStream($"file_{fileId}.bin", FileMode.Create));
}

• 关闭实体追踪减少额外开销
  如果下载文件后不需要对实体进行修改或追踪，使用AsNoTracking()可以关闭EF Core的实体追踪功能，减少内存占用和不必要的处理逻辑：

var targetFileIds = new[] { 1L, 2L, 3L };
var files = await context.Files
    .AsNoTracking()
    .Where(f => targetFileIds.Contains(f.IdFile))
    .ToListAsync();

• 调整数据库连接的数据包大小
  默认SQL Server连接数据包大小为4KB，对于大文件传输会增加网络往返次数。在连接字符串中设置最大数据包大小（32767字节），能减少交互次数提升传输速度：

Server=你的服务器地址;Database=你的数据库名;Trusted_Connection=True;Packet Size=32767;

• 使用EF Core原生SQL查询配合流式处理
  如果偏好EF Core的API风格，也可以通过ExecuteReaderAsync执行原生SQL并处理流：

var fileIds = new List<long> { 1, 2, 3 };
var parameterNames = fileIds.Select((_, idx) => $"@id{idx}").ToList();
var sql = $"SELECT ID_FILE, FILE_BYTES FROM FILE WHERE ID_FILE IN ({string.Join(", ", parameterNames)})";

var parameters = parameterNames.Zip(fileIds, (name, id) => new SqlParameter(name, id)).ToArray();

await using var reader = await context.Database.ExecuteReaderAsync(sql, parameters);
while (await reader.ReadAsync())
{
    var fileId = reader.GetInt64(0);
    using var fileStream = reader.GetStream(1);
    // 处理流数据
}

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