LambdaToSql/Realization/Updateable.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 LambdaToSql.Extended;
using Newtonsoft.Json;
using System.Diagnostics;

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

        internal virtual LambdaToSql.EntityModel.UpdateEntity<T> Entity { get; set; }

        public Updateable(LambdaToSql.EntityModel.DbContext context)
        {
            this.Context = context;
            //this.Entity = new LambdaToSql.EntityModel.UpdateEntity<T>(this.Context);

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

        public virtual LambdaToSql.Interface.IUpdateable<T> Update(T obj)
        {
            this.Entity.Obj = 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));

            if (!string.IsNullOrEmpty(value))
            {
                var ParaName = "@para" + this.Entity.Parameters.Count();
                if (this.Entity.Where.Length > 0)
                {
                    this.Entity.Where.Append(" and ");
                }
                this.Entity.Where.Append(primaryName + "=" + ParaName);
                this.Entity.Parameters.Add(new LambdaToSql.EntityModel.DataParameter(ParaName, value));
            }
            return this;
        }

        public virtual LambdaToSql.Interface.IUpdateable<T> UpdateColumns(Expression<Func<T, object>> exp)
        {