229 lines
10 KiB
C#
229 lines
10 KiB
C#
using System;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using System.Linq.Expressions;
|
|
using System.Text;
|
|
using System.Threading.Tasks;
|
|
|
|
namespace SqlSugar
|
|
{
|
|
public class UpdateNavTaskInit<Root, T> where T : class, new() where Root : class, new()
|
|
{
|
|
|
|
internal SqlSugarProvider Context { get; set; }
|
|
internal UpdateNavProvider<Root, Root> UpdateNavProvider { get; set; }
|
|
internal NavContext NavContext { get; set; }
|
|
|
|
public UpdateNavTask<Root, TChild> Include<TChild>(Expression<Func<Root, TChild>> expression) where TChild : class, new()
|
|
{
|
|
this.Context = UpdateNavProvider._Context;
|
|
UpdateNavProvider.NavContext = this.NavContext;
|
|
UpdateNavTask<Root, TChild> result = new UpdateNavTask<Root, TChild>();
|
|
Func<UpdateNavProvider<Root, TChild>> func = () => UpdateNavProvider.ThenInclude(expression);
|
|
result.PreFunc = func;
|
|
result.Context = this.Context;
|
|
result.NavContext = this.NavContext;
|
|
return result;
|
|
}
|
|
public UpdateNavTask<Root, TChild> Include<TChild>(Expression<Func<Root, List<TChild>>> expression) where TChild : class, new()
|
|
{
|
|
this.Context = UpdateNavProvider._Context;
|
|
UpdateNavProvider.NavContext = this.NavContext;
|
|
UpdateNavTask<Root, TChild> result = new UpdateNavTask<Root, TChild>();
|
|
Func<UpdateNavProvider<Root, TChild>> func = () => UpdateNavProvider.ThenInclude(expression);
|
|
result.PreFunc = func;
|
|
result.Context = this.Context;
|
|
result.NavContext = UpdateNavProvider.NavContext;
|
|
return result;
|
|
}
|
|
|
|
public UpdateNavTask<Root, TChild> Include<TChild>(Expression<Func<Root, TChild>> expression,UpdateNavOptions options) where TChild : class, new()
|
|
{
|
|
this.Context = UpdateNavProvider._Context;
|
|
UpdateNavProvider.NavContext = this.NavContext;
|
|
UpdateNavTask<Root, TChild> result = new UpdateNavTask<Root, TChild>();
|
|
Func<UpdateNavProvider<Root, TChild>> func = () => UpdateNavProvider.ThenInclude(expression,options);
|
|
result.PreFunc = func;
|
|
result.Context = this.Context;
|
|
result.NavContext = UpdateNavProvider.NavContext;
|
|
return result;
|
|
}
|
|
public UpdateNavTask<Root, TChild> Include<TChild>(Expression<Func<Root, List<TChild>>> expression, UpdateNavOptions options) where TChild : class, new()
|
|
{
|
|
this.Context = UpdateNavProvider._Context;
|
|
UpdateNavProvider.NavContext = this.NavContext;
|
|
UpdateNavTask<Root, TChild> result = new UpdateNavTask<Root, TChild>();
|
|
Func<UpdateNavProvider<Root, TChild>> func = () => UpdateNavProvider.ThenInclude(expression,options);
|
|
result.PreFunc = func;
|
|
result.Context = this.Context;
|
|
result.NavContext = UpdateNavProvider.NavContext;
|
|
return result;
|
|
}
|
|
public UpdateNavMethodInfo IncludesAllFirstLayer(params string[] ignoreColumns)
|
|
{
|
|
if (ignoreColumns == null)
|
|
{
|
|
ignoreColumns = new string[] { };
|
|
}
|
|
this.Context = UpdateNavProvider._Context;
|
|
var navColumns = this.Context.EntityMaintenance.GetEntityInfo<Root>().Columns.Where(it=> !ignoreColumns.Contains(it.PropertyName) || !ignoreColumns.Any(z=>z.EqualCase(it.DbColumnName))).Where(it => it.Navigat != null).ToList();
|
|
var updateNavs = this;
|
|
UpdateNavMethodInfo methodInfo = updateNavs.IncludeByNameString(navColumns[0].PropertyName);
|
|
foreach (var item in navColumns.Skip(1))
|
|
{
|
|
methodInfo = methodInfo.IncludeByNameString(item.PropertyName);
|
|
}
|
|
return methodInfo;
|
|
}
|
|
|
|
public UpdateNavMethodInfo IncludesAllFirstLayer(UpdateNavOptions updateNavOptions,params string[] ignoreColumns)
|
|
{
|
|
if (ignoreColumns == null)
|
|
{
|
|
ignoreColumns = new string[] { };
|
|
}
|
|
this.Context = UpdateNavProvider._Context;
|
|
var navColumns = this.Context.EntityMaintenance.GetEntityInfo<Root>().Columns.Where(it => !ignoreColumns.Contains(it.PropertyName) || !ignoreColumns.Any(z => z.EqualCase(it.DbColumnName))).Where(it => it.Navigat != null).ToList();
|
|
var updateNavs = this;
|
|
UpdateNavMethodInfo methodInfo = updateNavs.IncludeByNameString(navColumns[0].PropertyName);
|
|
foreach (var item in navColumns.Skip(1))
|
|
{
|
|
methodInfo = methodInfo.IncludeByNameString(item.PropertyName, updateNavOptions);
|
|
}
|
|
return methodInfo;
|
|
}
|
|
public UpdateNavMethodInfo IncludeByNameString(string navMemberName, UpdateNavOptions updateNavOptions=null)
|
|
{
|
|
UpdateNavMethodInfo result = new UpdateNavMethodInfo();
|
|
result.Context = UpdateNavProvider._Context;
|
|
var entityInfo = result.Context.EntityMaintenance.GetEntityInfo<T>();
|
|
Type properyItemType;
|
|
bool isList;
|
|
Expression exp =UtilMethods.GetIncludeExpression(navMemberName, entityInfo, out properyItemType,out isList);
|
|
var method = this.GetType().GetMyMethod("Include", 2,isList)
|
|
.MakeGenericMethod(properyItemType);
|
|
var obj = method.Invoke(this, new object[] { exp, updateNavOptions });
|
|
result.MethodInfos = obj;
|
|
return result;
|
|
}
|
|
|
|
|
|
}
|
|
public class UpdateNavTask<Root, T> where T : class, new() where Root : class, new()
|
|
{
|
|
public SqlSugarProvider Context { get; set; }
|
|
public Func<UpdateNavProvider<Root, T>> PreFunc { get; set; }
|
|
internal NavContext NavContext { get; set; }
|
|
|
|
|
|
#region +1
|
|
public UpdateNavTask<Root, TChild> ThenInclude<TChild>(Expression<Func<T, TChild>> expression) where TChild : class, new()
|
|
{
|
|
UpdateNavTask<Root, TChild> result = new UpdateNavTask<Root, TChild>();
|
|
Func<UpdateNavProvider<Root, TChild>> func = () => PreFunc().ThenInclude(expression);
|
|
result.PreFunc = func;
|
|
result.Context = this.Context;
|
|
result.NavContext = this.NavContext;
|
|
return result;
|
|
}
|
|
public UpdateNavTask<Root, TChild> ThenInclude<TChild>(Expression<Func<T, List<TChild>>> expression) where TChild : class, new()
|
|
{
|
|
UpdateNavTask<Root, TChild> result = new UpdateNavTask<Root, TChild>();
|
|
Func<UpdateNavProvider<Root, TChild>> func = () => PreFunc().ThenInclude(expression);
|
|
result.PreFunc = func;
|
|
result.Context = this.Context;
|
|
result.NavContext = this.NavContext;
|
|
return result;
|
|
}
|
|
public UpdateNavTask<Root, TChild> Include<TChild>(Expression<Func<Root, TChild>> expression) where TChild : class, new()
|
|
{
|
|
return AsNav().ThenInclude(expression);
|
|
}
|
|
public UpdateNavTask<Root, TChild> Include<TChild>(Expression<Func<Root, List<TChild>>> expression) where TChild : class, new()
|
|
{
|
|
return AsNav().ThenInclude(expression);
|
|
}
|
|
|
|
#endregion
|
|
|
|
|
|
#region +2
|
|
public UpdateNavTask<Root, TChild> ThenInclude<TChild>(Expression<Func<T, TChild>> expression, UpdateNavOptions options) where TChild : class, new()
|
|
{
|
|
UpdateNavTask<Root, TChild> result = new UpdateNavTask<Root, TChild>();
|
|
Func<UpdateNavProvider<Root, TChild>> func = () => {
|
|
var nav = PreFunc().ThenInclude(expression, options);
|
|
nav.NavContext = this.NavContext;
|
|
return nav;
|
|
};
|
|
result.PreFunc = func;
|
|
result.Context = this.Context;
|
|
return result;
|
|
}
|
|
public UpdateNavTask<Root, TChild> ThenInclude<TChild>(Expression<Func<T, List<TChild>>> expression, UpdateNavOptions options) where TChild : class, new()
|
|
{
|
|
UpdateNavTask<Root, TChild> result = new UpdateNavTask<Root, TChild>();
|
|
Func<UpdateNavProvider<Root, TChild>> func = () => {
|
|
var nav = PreFunc().ThenInclude(expression, options);
|
|
result.NavContext = this.NavContext;
|
|
return nav;
|
|
};
|
|
result.PreFunc = func;
|
|
result.Context = this.Context;
|
|
return result;
|
|
}
|
|
public UpdateNavTask<Root, TChild> Include<TChild>(Expression<Func<Root, TChild>> expression, UpdateNavOptions options) where TChild : class, new()
|
|
{
|
|
return AsNav().ThenInclude(expression, options);
|
|
}
|
|
public UpdateNavTask<Root, TChild> Include<TChild>(Expression<Func<Root, List<TChild>>> expression, UpdateNavOptions options) where TChild : class, new()
|
|
{
|
|
return AsNav().ThenInclude(expression, options);
|
|
}
|
|
#endregion
|
|
|
|
|
|
public bool ExecuteCommand()
|
|
{
|
|
var hasTran = this.Context.Ado.Transaction != null;
|
|
if (hasTran)
|
|
{
|
|
PreFunc();
|
|
}
|
|
else
|
|
{
|
|
this.Context.Ado.UseTran(() =>
|
|
{
|
|
PreFunc();
|
|
}, ex => throw ex);
|
|
}
|
|
return true;
|
|
}
|
|
public async Task<bool> ExecuteCommandAsync()
|
|
{
|
|
await Task.Run(async () =>
|
|
{
|
|
ExecuteCommand();
|
|
await Task.Delay(0);
|
|
});
|
|
return true;
|
|
}
|
|
|
|
private UpdateNavTask<Root, Root> AsNav()
|
|
{
|
|
UpdateNavTask<Root, Root> result = new UpdateNavTask<Root, Root>();
|
|
Func<UpdateNavProvider<Root, Root>> func = () => {
|
|
var navres=PreFunc().AsNav();
|
|
navres.IsAsNav = true;
|
|
navres.NavContext = this.NavContext;
|
|
return navres;
|
|
};
|
|
result.PreFunc = func;
|
|
result.Context = this.Context;
|
|
result.NavContext = this.NavContext;
|
|
return result;
|
|
}
|
|
}
|
|
|
|
}
|