如何针对不同泛型类使用反射实现动态数据库数据插入？

我希望借助泛型CRUD类实现从文件向数据库插入数据，场景示例代码如下：

public class SubjectTester<T>where T : class
{
    public void Create()
    {
        var db_context = new DbContext();
        // 读取文件内容并处理
        // 需要创建T的实例并将文件数据赋值给它
        // 调用DbContext的Add方法并保存更改
    }
}
public class DbContext 
{
    // 包含DbSet<T>等数据库操作相关内容
}
public class TestSubjectA
{
    public int Id { get; set; }
    public string Name { get; set; }
}
public class TestSubjectB
{
    public double Sum { get; set; }
}
public class TestSubjectC
{
    public int Id { get; set; }
    public string Name { get; set; }
    public bool IsRigged { get; set; }
}

不同实体类（对应数据库表）的属性数量、数据类型存在差异，我想根据传入的泛型类T动态添加数据，且不想通过大量if-else判断T的类型，请问该如何利用反射实现？

可以通过以下步骤利用反射实现动态处理不同类型的实体：

1. 解析文件内容为键值对 #

首先把文件内容解析成属性名-属性值的键值对集合（可根据实际文件格式调整解析逻辑，示例假设每行是属性名=值的格式，多个属性用分号分隔）：

// 读取文件并解析为键值对列表
var fileLines = File.ReadAllLines("data.txt");
foreach (var line in fileLines)
{
    var keyValuePairs = line.Split(';')
                           .Select(kv => kv.Split('='))
                           .ToDictionary(kv => kv[0].Trim(), kv => kv[1].Trim());
    // 针对每行数据创建实体并赋值
}

2. 动态创建T的实例并赋值 #

利用反射获取T的所有可写公共属性，遍历键值对匹配属性名，将字符串值转换为对应属性的类型后赋值：

// 创建T的实例
var entity = Activator.CreateInstance<T>();
// 获取T的所有可写公共属性
var properties = typeof(T).GetProperties(BindingFlags.Public | BindingFlags.Instance)
                          .Where(p => p.CanWrite);

foreach (var prop in properties)
{
    if (keyValuePairs.TryGetValue(prop.Name, out string valueStr))
    {
        try
        {
            // 将字符串转换为属性对应的类型
            var convertedValue = Convert.ChangeType(valueStr, prop.PropertyType);
            // 给属性赋值
            prop.SetValue(entity, convertedValue);
        }
        catch (Exception ex)
        {
            // 处理类型转换异常，比如记录日志
            Console.WriteLine($"属性{prop.Name}赋值失败：{ex.Message}");
        }
    }
}

3. 动态添加到DbContext并保存 #

如果使用EF Core的DbContext，直接获取对应的DbSet<T>并添加实体，最后批量保存更改：

// 获取DbSet<T>并添加实体
var dbSet = db_context.Set<T>();
dbSet.Add(entity);

// 批量保存更改
db_context.SaveChanges();

完整修改后的SubjectTester代码 #

public class SubjectTester<T>where T : class
{
    public void Create(string filePath)
    {
        using var db_context = new DbContext();
        var fileLines = File.ReadAllLines(filePath);

        foreach (var line in fileLines)
        {
            // 解析每行数据为键值对（可根据实际文件格式调整）
            var keyValuePairs = line.Split(';')
                                   .Select(kv => kv.Split('='))
                                   .ToDictionary(kv => kv[0].Trim(), kv => kv[1].Trim());

            // 创建实体实例
            var entity = Activator.CreateInstance<T>();
            var properties = typeof(T).GetProperties(BindingFlags.Public | BindingFlags.Instance)
                                      .Where(p => p.CanWrite);

            // 为属性赋值
            foreach (var prop in properties)
            {
                if (keyValuePairs.TryGetValue(prop.Name, out string valueStr))
                {
                    try
                    {
                        var convertedValue = Convert.ChangeType(valueStr, prop.PropertyType);
                        prop.SetValue(entity, convertedValue);
                    }
                    catch (Exception ex)
                    {
                        Console.WriteLine($"赋值属性{prop.Name}失败：{ex.Message}");
                    }
                }
            }

            // 添加到数据库上下文
            db_context.Set<T>().Add(entity);
        }

        // 批量保存更改
        db_context.SaveChanges();
    }
}

注意事项 #

• 类型转换：Convert.ChangeType支持大部分基础类型转换，如果涉及枚举、自定义复杂类型，需要额外编写转换逻辑。
• 性能优化：如果处理大量数据，可以缓存typeof(T).GetProperties()的结果，避免重复反射开销。
• 异常处理：必须添加异常捕获逻辑，处理类型转换失败、属性不存在等场景，避免程序崩溃。

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