.NET在EF中使用sql,用动态类吧!

1850 查看

前言

  在.NET中使用Entity Framework能快速、方便地结合LINQ来对数据库进行一系列的增删改查操作。但是由于EF根据表达式最后生成通用的sql来执行,进行具体的数据库操作。根据本人使用EF的经验,对于增、删、改的操作,可以直接使用EF的接口进行快速开发。但是对于查询的操作,最好是使用EF调用sql来操作。

问题呈现

  在EF中调用sql进行数据查询后,需要返回一个指定类型的数据列表,那么这个类型是需要在调用的时候指定的。我们就会遇到这种问题:我只需要查一些简单的数据,例如查询一下符合某条件的数据数量等等,就必须新建一个类型,增加了程序的冗余度。

解决方案

  需要实现动态生成类的方法,可以插入属性名称和属性类型,返回一个类型,提供给EF使用。

实现

//该类是用于定义属性节点的,包括属性的名称、属性的类型。
public class PropertyItem
    {
        public PropertyItem(string name, Type type)
        {
            this.Name = name;
            this.Type = type;
        }

        public string Name { set; get; }
        public Type Type { set; get; }
    }

     
//该类是提供接口,动态生成类型的。
public class UserTypeFactory
    {
        public static Type GetUserType(params PropertyItem[] itemList)
        {
            TypeBuilder builder = CreateTypeBuilder(
                    "MyDynamicAssembly", "MyModule", "MyType");
            foreach(var item in itemList)
            {
                CreateAutoImplementedProperty(builder, item.Name, item.Type);
            }

            Type resultType = builder.CreateType();
            return resultType;
        }

        private static TypeBuilder CreateTypeBuilder( 
            string assemblyName, string moduleName, string typeName)
        {
            TypeBuilder typeBuilder = AppDomain
                .CurrentDomain
                .DefineDynamicAssembly(new AssemblyName(assemblyName),
                                       AssemblyBuilderAccess.Run)
                .DefineDynamicModule(moduleName)
                .DefineType(typeName, TypeAttributes.Public);
            typeBuilder.DefineDefaultConstructor(MethodAttributes.Public);
            return typeBuilder;
        }

        private static void CreateAutoImplementedProperty(
            TypeBuilder builder, string propertyName, Type propertyType)
        {
            const string PrivateFieldPrefix = "m_";
            const string GetterPrefix = "get_";
            const string SetterPrefix = "set_";

            // 定义字段.
            FieldBuilder fieldBuilder = builder.DefineField(
                string.Concat(PrivateFieldPrefix, propertyName),
                              propertyType, FieldAttributes.Private);

            // 定义属性
            PropertyBuilder propertyBuilder = builder.DefineProperty(
                propertyName, System.Reflection.PropertyAttributes.HasDefault, propertyType, null);

            // 属性的getter和setter的特性
            MethodAttributes propertyMethodAttributes =
                MethodAttributes.Public | MethodAttributes.SpecialName |
                MethodAttributes.HideBySig;

            // 定义getter方法
            MethodBuilder getterMethod = builder.DefineMethod(
                string.Concat(GetterPrefix, propertyName),
                propertyMethodAttributes, propertyType, Type.EmptyTypes);

            ILGenerator getterILCode = getterMethod.GetILGenerator();
            getterILCode.Emit(OpCodes.Ldarg_0);
            getterILCode.Emit(OpCodes.Ldfld, fieldBuilder);
            getterILCode.Emit(OpCodes.Ret);

            // 定义setter方法
            MethodBuilder setterMethod = builder.DefineMethod(
                string.Concat(SetterPrefix, propertyName),
                propertyMethodAttributes, null, new Type[] { propertyType });


            ILGenerator setterILCode = setterMethod.GetILGenerator();
            setterILCode.Emit(OpCodes.Ldarg_0);
            setterILCode.Emit(OpCodes.Ldarg_1);
            setterILCode.Emit(OpCodes.Stfld, fieldBuilder);
            setterILCode.Emit(OpCodes.Ret);

            propertyBuilder.SetGetMethod(getterMethod);
            propertyBuilder.SetSetMethod(setterMethod);
        }

    }

使用

YmsEntities entities=new YmsEntities();
dynamic studentDic= entities.Database.SqlQuery(UserTypeFactory.GetUserType(new PropertyItem("ID", typeof(int)), new PropertyItem("num", typeof(string))),"select ID ,Name as num from student");
foreach (var student in studentDic)
{
  //业务
  var id=student.ID;
  var num=student.num;
}

补充

  还有另外一种方式能实现:

 public MainWindow()
 {
    InitializeComponent();

    hjf_jianzhengEntities entity = new hjf_jianzhengEntities();
    var context = ((IObjectContextAdapter)entity).ObjectContext;
    var result = new ObjectQuery<DbDataRecord>("Select dic_Town.CNAME from dic_Town", context).ToList();
    var s=result.First()[0];
  }
  • 该方法优点是不用定义多余的参数、类型、字段名。
  • 缺点是select语句中不能用”*“,并且字段必须带上表明,例如dic_Town.CNAME。
补充一个第三方提供的工具,github地址:https://github.com/StackExchange/dapper-dot-net