如何使用EntityFramework处理数据库中实体的哈希表属性

本文关键字:实体 哈希表 属性 数据库 何使用 EntityFramework 处理 | 更新日期: 2023-09-27 18:07:08

我有一个使用ADO的旧项目。. NET访问持久存储。目前,我想把它迁移到EF(6.1.3,如果有必要的话),以便以最少的代码重复来支持几个DB提供程序。

存在一个包含Hashtable属性的实体:

public class Record
{
    ...
    public Hashtable data { get; set; }
}

ADO。. NET中,BinaryFormatter用于将data属性转换为BLOB,反之亦然:

using (MemoryStream stream = new MemoryStream())
{
    BinaryFormatter formatter = new BinaryFormatter();
    formatter.Serialize(stream, data);
    result = stream.GetBuffer();
}
//----------
using (MemoryStream serializationStream = new MemoryStream((byte[])value))
{
    BinaryFormatter formatter = new BinaryFormatter();
    result = (Hashtable)formatter.Deserialize(serializationStream);
}

现在我需要告诉EF它应该如何存储和检索该属性。

What have I try

我可以在实体中再存储一个属性:

public class Record
{
    public byte[] dataRaw { get; set; }
    [NotMapped]
    public Hashtable data {
        get {/*deserialize dataRaw */ }
        set { /*Serialize to dataRaw*/}
    }
}

但是这个解决方案容易出错,必须遵循带有该属性的特殊工作流程。

注:实际上,这个问题不仅仅是关于Hashtable,而是关于每一个必须以特殊方式存储和检索的自定义类。

如何使用EntityFramework处理数据库中实体的哈希表属性

这是基于我上面提到的答案的完整解决方案。
我在linqpad上进行了测试,效果相当不错。

你不需要一个特殊的工作流,因为属性访问器会在需要的时候保存和加载哈希表。

主要方法

void Main()
{
    using (var ctx = new TestContext())
    {
        var hash = new Hashtable();
        hash.Add("A", "A");
        ctx.Settings.Add(new Settings { Hash = hash });
        ctx.SaveChanges();
        // load them up...
        ctx.Settings.ToArray().Select(_ => _.Hash).Dump();
    }
}
<<p> 设置类/strong>
public class Settings
{
    // a primary key is necessary.
    public int Id { get; set; }
    [NotMapped]
    public Hashtable Hash
    {
        get;
        set;
    }
    // the backing field can be protected, this helps 'hide' it.
    protected virtual byte[] _Hash
    {
        get
        {
            return Hash.ToBinary();
        }
        set     
        {
            Hash = value.FromBinary<Hashtable>();
        }
    }
}

转换值的扩展

public static class Extensions
{
    public static BinaryPropertyConfiguration BinaryProperty<T>(
        this EntityTypeConfiguration<T> mapper,
        String propertyName) where T : class
    {
        Type type = typeof(T);
        ParameterExpression arg = Expression.Parameter(type, "x");
        Expression expr = arg;
        PropertyInfo pi = type.GetProperty(propertyName,
            BindingFlags.NonPublic | BindingFlags.Public | BindingFlags.Instance);
        expr = Expression.Property(expr, pi);
        LambdaExpression lambda = Expression.Lambda(expr, arg);
        Expression<Func<T, byte[]>> expression = (Expression<Func<T, byte[]>>)lambda;
        return mapper.Property(expression);
    }
    public static byte[] ToBinary<T>(this T instance)
    {
        if (instance == null)
            return null;
        using (var stream = new MemoryStream())
        {
            var formatter = new BinaryFormatter();
            formatter.Serialize(stream, instance);
            return stream.ToArray();
        }
    }
    public static T FromBinary<T>(this byte[] buffer)
    {
        if (buffer == null)
            return default(T);
        using (var stream = new MemoryStream(buffer, false))
        {
            var formatter = new BinaryFormatter();
            var instance = formatter.Deserialize(stream);
            return (T)instance;
        }
    }
}

数据上下文

public class TestContext : DbContext
{
    public DbSet<Settings> Settings { get; set; }
    protected override void OnModelCreating(DbModelBuilder modelBuilder)
    {
        base.OnModelCreating(modelBuilder);
        modelBuilder
            .Entity<Settings>()
            .BinaryProperty("_Hash")
            .HasColumnName("Hashtable");
    }       
}