.NET在EF中使用sql，用動態類吧！

 

前言

　　　　在.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