EF Core如何通过字符串参数从动态表取数并导出CSV

针对你需要根据字符串表名查询数据并导出CSV的需求，先明确你之前尝试的方法失败原因：

• _context.Set<object>().FromSqlRaw(...)：EF Core的Set<T>要求T是已在DbContext模型中注册的实体类型，object不在模型范围内，因此触发异常。
• _context.Database.ExecuteSqlRaw(...)：该方法仅用于执行非查询SQL语句（如增删改），返回受影响行数；执行SELECT时会返回-1，因为它不负责返回查询结果。

下面提供两种可行方案，可根据你的实际场景选择：

方案一：表对应已注册的实体类 #

如果数据库表在DbContext中已有对应的DbSet<T>（比如Users对应DbSet<User>），可通过反射获取指定表名的DbSet并查询：

步骤1：动态获取DbSet并查询数据 #

// 从DbContext中获取对应表名的DbSet属性（假设表名与DbSet属性名一致）
var dbSetProperty = _context.GetType().GetProperty(tableName);
if (dbSetProperty == null)
{
    throw new ArgumentException($"DbContext中不存在名为{tableName}的DbSet");
}

// 获取DbSet实例并转为IQueryable
var dbSet = dbSetProperty.GetValue(_context) as IQueryable;
var tableData = dbSet?.ToList();

步骤2：反射调用泛型ExportToCsv方法 #

由于ExportToCsv<T>是泛型方法，需明确具体实体类型才能调用，同样通过反射实现：

// 获取ExportToCsv方法的泛型版本（替换YourClass为该方法所在的类名）
var exportMethod = typeof(YourClass).GetMethod(nameof(ExportToCsv))
    .MakeGenericMethod(dbSet.ElementType);

// 调用方法生成CSV字节数组
var csvBytes = (byte[])exportMethod.Invoke(this, new object[] { tableData });

方案二：无对应实体类（完全动态表） #

如果表没有对应的实体类，直接用ADO.NET结合DataTable获取数据，再转换为动态对象适配导出方法：

步骤1：查询数据到DataTable #

// 先验证表名合法性，防范SQL注入
var tableExists = _context.Database.ExecuteSqlRaw(
    "SELECT COUNT(1) FROM sys.tables WHERE name = @tableName",
    new Microsoft.Data.SqlClient.SqlParameter("@tableName", tableName)) > 0;

if (!tableExists)
{
    throw new ArgumentException("指定的表不存在");
}

// 用ADO.NET查询数据到DataTable
using var command = _context.Database.GetDbConnection().CreateCommand();
command.CommandText = $"SELECT * FROM {tableName}";
await _context.Database.OpenConnectionAsync();
using var reader = await command.ExecuteReaderAsync();

var dataTable = new DataTable();
dataTable.Load(reader);
await _context.Database.CloseConnectionAsync();

步骤2：转换DataTable为动态对象集合 #

将DataTable转成IEnumerable<dynamic>，适配你的泛型导出方法：

var dynamicData = dataTable.AsEnumerable().Select(row => 
{
    dynamic obj = new ExpandoObject();
    var dict = (IDictionary<string, object>)obj;
    foreach (DataColumn col in dataTable.Columns)
    {
        dict[col.ColumnName] = row[col] == DBNull.Value ? null : row[col];
    }
    return obj;
});

// 调用导出方法
var csvBytes = ExportToCsv(dynamicData);

注意事项 #

• SQL注入风险：直接拼接表名存在注入风险，必须先验证表名合法性（比如通过查询sys.tables确认表存在）。
• 若使用异步场景，建议将查询和导出逻辑改为异步版本，提升性能。

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