#if netcore
#else
using FreeSql.DataAnnotations;
using System;
using System.Collections;
using System.Collections.Generic;
using System.Data;
using System.Diagnostics;
using System.Linq;
using System.Linq.Expressions;
using System.Threading;
namespace FreeSql
{
///
/// 包括 CreateTime/UpdateTime/IsDeleted 的实体基类
///
[Table(DisableSyncStructure = true)]
public abstract class BaseEntity
{
static IFreeSql _ormPriv;
///
/// 全局 IFreeSql orm 对象
///
public static IFreeSql Orm => _ormPriv ?? throw new Exception(@"使用前请初始化 BaseEntity.Initialization(new FreeSqlBuilder()
.UseAutoSyncStructure(true)
.UseConnectionString(DataType.Sqlite, ""data source=test.db;max pool size=5"")
.Build());");
///
/// 初始化BaseEntity
/// BaseEntity.Initialization(new FreeSqlBuilder()
///
/// .UseAutoSyncStructure(true)
///
/// .UseConnectionString(DataType.Sqlite, "data source=test.db;max pool size=5")
///
/// .Build());
///
/// IFreeSql orm 对象
public static void Initialization(IFreeSql fsql)
{
_ormPriv = fsql;
_ormPriv.Aop.CurdBefore += (s, e) => Trace.WriteLine(e.Sql + "\r\n");
}
}
public abstract class BaseEntityReadOnly : BaseEntity where TEntity : class
{
///
/// 查询数据
///
///
public static ISelect Select
{
get
{
var select = Orm.Select().TrackToList(TrackToList); //自动为每个元素 Attach;
return select;
}
}
static void TrackToList(object list)
{
if (list == null) return;
var ls = list as IList;
if (ls == null)
{
var ie = list as IEnumerable;
if (ie == null) return;
var isFirst = true;
foreach (var item in ie)
{
if (item == null) return;
if (isFirst)
{
isFirst = false;
var itemType = item.GetType();
if (itemType == typeof(object)) return;
if (itemType.FullName.Contains("FreeSqlLazyEntity__")) itemType = itemType.BaseType;
if (Orm.CodeFirst.GetTableByEntity(itemType)?.Primarys.Any() != true) return;
if (item is BaseEntity == false) return;
}
(item as BaseEntity)?.Attach();
}
return;
}
if (ls.Any() == false) return;
if (ls.FirstOrDefault() is BaseEntity == false) return;
if (Orm.CodeFirst.GetTableByEntity(typeof(TEntity))?.Primarys.Any() != true) return;
foreach (var item in ls)
(item as BaseEntity)?.Attach();
}
///
/// 查询条件,Where(a => a.Id > 10),支持导航对象查询,Where(a => a.Author.Email == "2881099@qq.com")
///
/// lambda表达式
///
public static ISelect Where(Expression> exp) => Select.Where(exp);
///
/// 查询条件,Where(true, a => a.Id > 10),支导航对象查询,Where(true, a => a.Author.Email == "2881099@qq.com")
///
/// true 时生效
/// lambda表达式
///
public static ISelect WhereIf(bool condition, Expression> exp) => Select.WhereIf(condition, exp);
///
/// 仓储对象
///
protected IBaseRepository Repository { get; set; }
///
/// 附加实体,在更新数据时,只更新变化的部分
///
public TEntity Attach()
{
if (this.Repository == null)
this.Repository = Orm.GetRepository();
var item = this as TEntity;
this.Repository.Attach(item);
return item;
}
}
}
#endif