LambdaToSql/Realization/Deleteable.cs

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

using LambdaToSql.FrameWork;
using System;
using System.Collections.Generic;
using System.Data.SqlClient;
using System.Linq;
using System.Reflection;
using System.Text;
using System.Linq.Expressions;
using System.Diagnostics;
using Newtonsoft.Json;

namespace LambdaToSql.Realization
{
    internal class Deleteable<T> : LambdaToSql.Interface.IDeleteable<T> where T : class, new()
    {
        public virtual LambdaToSql.EntityModel.DbContext Context { get; set; }

        internal LambdaToSql.EntityModel.DeleteEntity<T> Entity { get; set; }
         
        public Deleteable(LambdaToSql.EntityModel.DbContext context)
        {
            this.Context = context;
            //Entity = new LambdaToSql.EntityModel.DeleteEntity<T>(this.Context);

            string assemblyName = "LambdaToSql";
            string fullTypeName = string.Format("LambdaToSql.EntityModel.{0}.{1}`1", this.Context.SqlType.ToString(), "DeleteEntity");
            Type objType = Assembly.Load(assemblyName).GetType(fullTypeName);
            Type type = objType.MakeGenericType(typeof(T));
            Entity = (LambdaToSql.EntityModel.DeleteEntity<T>)Activator.CreateInstance(type, new object[] { this.Context });
        }

        public virtual LambdaToSql.Interface.IDeleteable<T> Where(Expression<Func<T, bool>> expression)
        {
            if (expression != null)
            {
                Expression exp = expression.Body as Expression;

                var obj = new LambdaRouter(this.Entity.Parameters);
                var str = obj.ExpressionRouter(exp);
                this.Entity.Parameters = obj.Parameters;
                if (this.Entity.Where.Length > 0)
                {
                    this.Entity.Where.Append(" and ");
                }
                this.Entity.Where.Append(obj.Result);
            }
            return this;
        }

        public virtual LambdaToSql.Interface.IDeleteable<T> Delete(T obj)
        {
            var tableName = this.Entity.TableName;
            var properties = this.Entity.Properties;

            var primaryName = this.Context.Table[tableName].PrimaryName;
            var pi = properties.Where(ex => ex.Name == primaryName).FirstOrDefault();

            object name = pi.Name;
            string value = Convert.ToString(pi.GetValue(obj, null));