EF 底层封装方法(供参考)

闲暇之余,整理了一下EF底层的一些基础方法,供查看,只有接口,具体实现需要你们自己写了。

  建议:接口的实现定义为虚方法,当父类的方法不满住子类需求时,可以重写此方法

  此接口都为公用方法,基本上满足小系统的实际开发需求,如果你觉得满足不了你,可以扩展此接口。

using System;
using System.Collections.Generic;
using System.Data;
using System.Data.Entity;
using System.Data.SqlClient;
using System.Linq;
using System.Linq.Expressions;
using System.Text;
using System.Threading.Tasks; namespace Basic.IRepository
{
public interface ICommonRepository<T> where T : class, new()
{
#region Other /// <summary>
/// 确定序列中的任何元素是否都满足条件
/// </summary>
/// <param name="whereLambda"></param>
/// <returns></returns>
bool Any(Expression<Func<T, bool>> whereLambda); /// <summary>
/// 返回序列中元素的数量
/// </summary>
/// <param name="whereLambda"></param>
/// <returns></returns>
int Count(Expression<Func<T, bool>> whereLambda); /// <summary>
/// 返回最大值
/// </summary>
/// <typeparam name="Tkey"></typeparam>
/// <param name="predicate"></param>
/// <param name="selector"></param>
/// <returns></returns>
Tkey Max<Tkey>(Expression<Func<T, bool>> whereLambda, Func<T, Tkey> selector); /// <summary>
/// 返回分组查询的数量
/// </summary>
/// <typeparam name="TKey"></typeparam>
/// <param name="whereLambda"></param>
/// <param name="groupBy"></param>
/// <returns></returns>
IDictionary<TKey, int> Count<TKey>(Expression<Func<T, bool>> whereLambda, Expression<Func<T, TKey>> groupBy); /// <summary>
/// 分组求和
/// </summary>
/// <typeparam name="TKey"></typeparam>
/// <param name="whereLambda"></param>
/// <param name="groupBy"></param>
/// <param name="selector"></param>
/// <returns></returns>
IDictionary<TKey, decimal> Sum<TKey>(Expression<Func<T, bool>> whereLambda, Expression<Func<T, TKey>> groupBy, Func<T, decimal> selector); /// <summary>
/// 获取表名
/// </summary>
/// <param name="type"></param>
/// <returns></returns>
string GetTableName(Type type); /// <summary>
/// 得到SqlServer 表相关信息(字段名,类型.....)
/// </summary>
/// <param name="tableName"></param>
/// <returns></returns>
IEnumerable<SqlServerColumnModel> GetSqlServerTableOrViewColumns(string tableName); /// <summary>
/// 得到MySql 表相关信息(字段名,类型.....)
/// </summary>
/// <param name="tableName"></param>
/// <returns></returns>
IEnumerable<MySqlColumnModel> GetMySqlTableOrViewColumns(string tableName); #endregion #region Insert
/// <summary>
/// 添加
/// </summary>
/// <param name="model"></param>
/// <returns></returns>
bool Add(T model); /// <summary>
/// 批量添加
/// </summary>
/// <param name="model"></param>
/// <returns></returns>
bool AddRange(IEnumerable<T> model); /// <summary>
/// 批量添加 生成Sql执行
/// </summary>
/// <param name="model"></param>
/// <param name="clearHistoryData"></param>
void BulkInsertToSql(IEnumerable<T> model, bool clearHistoryData = false); /// <summary>
/// 批量添加 SqlServer
/// 通过 SqlBulkCopy 实现
/// </summary>
/// <param name="model"></param>
/// <param name="clearHistoryData"></param>
void BulkInsertSqlServer(IEnumerable<T> model, bool clearHistoryData = false); /// <summary>
/// 批量添加 MySql
/// 通过 MySqlBulkLoader 实现
/// </summary>
/// <param name="model"></param>
/// <param name="clearHistoryData"></param>
int BulkInsertMySql(IEnumerable<T> model, string csvPath, bool clearHistoryData = false); #endregion #region Delete /// <summary>
/// 按主键删除
/// </summary>
/// <param name="id"></param>
bool DeleteById(dynamic id); /// <summary>
/// 删除
/// </summary>
/// <param name="model"></param>
/// <returns></returns>
bool Delete(T model); /// <summary>
/// 按条件删除
/// </summary>
/// <param name="id"></param>
bool DeleteByWhere(Expression<Func<T, bool>> whereLambda); /// <summary>
/// 批量删除
/// </summary>
/// <param name="model"></param>
/// <returns></returns>
bool DeleteRange(IEnumerable<T> model); /// <summary>
/// 批量删除
/// </summary>
/// <param name="where">条件:{Name="张三",性别="男"}</param>
/// <returns></returns>
bool BulkDelete(object where); /// <summary>
/// 批量删除
/// </summary>
/// <param name="where">条件:{Name="张三",性别="男"}</param>
/// <param name="notWhere">过滤的条件:{Name="张三",年龄="18"}</param>
/// <returns></returns>
bool BulkDelete(object where,object notWhere); #endregion #region Update
/// <summary>
/// 更新
/// </summary>
/// <param name="model"></param>
/// <returns></returns>
bool Update(T model); /// <summary>
/// 批量更新
/// </summary>
/// <param name="model"></param>
/// <returns></returns>
bool UpdateRange(IEnumerable<T> models); /// <summary>
/// 批量更新,不带条件
/// </summary>
/// <param name="set">修改的数据:{Name="张三",年龄=22}</param>
/// <returns></returns>
bool BulkUpdate(object set); /// <summary>
/// 批量更新,带条件
/// </summary>
/// <param name="set">修改的数据:{Name="张三",年龄=22}</param>
/// <param name="where">条件:{Name="张三",性别="男"}</param>
/// <returns></returns>
bool BulkUpdate(object set, object where); #endregion #region Select /// <summary>
/// 按主键查询
/// </summary>
/// <param name="id">主键</param>
/// <returns></returns>
T Find(dynamic id); /// <summary>
/// 通过id查看是否存在
/// </summary>
/// <param name="id">主键</param>
/// <returns></returns>
bool IsExist(dynamic id); /// <summary>
/// 返回序列中的第一个元素
/// </summary>
/// <param name="whereLambda">条件</param>
/// <returns></returns>
T FirstOrDefault(Expression<Func<T, bool>> whereLambda); /// <summary>
/// 获取数据
/// </summary>
/// <typeparam name="TObj">排序类型</typeparam>
/// <param name="whereLambda">条件</param>
/// <param name="orderBy">排序字段</param>
/// <param name="isASC">是否升序</param>
/// <returns></returns>
IEnumerable<T> Find<TObj>(Expression<Func<T, bool>> whereLambda, Expression<Func<T, TObj>> orderBy, bool isASC = true); /// <summary>
/// 获取数据
/// </summary>
/// <typeparam name="TKey">排序类型 1</typeparam>
/// <typeparam name="TObj">排序类型 2</typeparam>
/// <param name="whereLambda">条件</param>
/// <param name="orderBy">排序字段 1</param>
/// <param name="thenBy">排序字段 2</param>
/// <param name="isASC">是否升序</param>
/// <returns></returns>
IEnumerable<T> Find<TKey,TObj>(Expression<Func<T, bool>> whereLambda, Expression<Func<T, TKey>> orderBy, Expression<Func<T, TObj>> thenBy, bool isASC = true); /// <summary>
/// 分页查询 生成SQL执行 SQLSERVER
/// </summary>
/// <param name="name">表名/视图</param>
/// <param name="where">条件 name='Jamel' and age = 18</param>
/// <param name="pageIndex">页码</param>
/// <param name="pageSize">数量</param>
/// <param name="orderBy">排序字段</param>
/// <param name="isASC">是否升序</param>
/// <returns></returns>
IEnumerable<T> PagerToSqlServer(string name, string where, int pageIndex, int pageSize, object orderBy, bool isASC = true); /// <summary>
/// 分页查询 生成SQL执行 MYSQL
/// </summary>
/// <param name="name">表名/视图</param>
/// <param name="where">条件 name='Jamel' and age = 18</param>
/// <param name="pageIndex">页码</param>
/// <param name="pageSize">数量</param>
/// <param name="orderBy">排序字段</param>
/// <param name="isASC">是否升序</param>
/// <returns></returns>
IEnumerable<T> PagerToMySql(string name, string where, int pageIndex, int pageSize, object orderBy, bool isASC = true); /// <summary>
/// 分页查询
/// </summary>
/// <typeparam name="TObj">排序类型</typeparam>
/// <param name="whereLambda">条件</param>
/// <param name="orderBy">排序字段</param>
/// <param name="pageIndex">页码</param>
/// <param name="pageSize">数量</param>
/// <param name="isASC">是否升序</param>
/// <returns></returns>
IEnumerable<T> Pager<TObj>(Expression<Func<T, bool>> whereLambda, Expression<Func<T, TObj>> orderBy, int pageIndex,int pageSize, bool isASC = true); /// <summary>
/// 分页查询
/// </summary>
/// <typeparam name="TKey">排序类型 1</typeparam>
/// <typeparam name="TObj">排序类型 2</typeparam>
/// <param name="whereLambda">条件</param>
/// <param name="orderBy">排序字段 1</param>
/// <param name="thenBy">排序字段 2</param>
/// <param name="pageIndex">页码</param>
/// <param name="pageSize">数量</param>
/// <param name="isASC">是否升序</param>
/// <returns></returns>
IEnumerable<T> Pager<TKey, TObj>(Expression<Func<T, bool>> whereLambda, Expression<Func<T, TKey>> orderBy, Expression<Func<T, TObj>> thenBy, int pageIndex, int pageSize, bool isASC = true); #endregion #region Proc /// <summary>
/// 执行存储过程或自定义sql语句--返回集合(自定义返回类型)
/// SqlServer: exec getActionUrlId @name,@ID
/// MySql: call getActionUrlId(@name,@ID)
/// </summary>
/// <param name="sql">sql语句或存储过程</param>
/// <param name="parms">参数 new SqlParameter("@name","Jamel")</param>
/// <returns></returns>
IEnumerable<T> SqlQuery(string sql, IEnumerable<SqlParameter> parms); /// <summary>
/// 自定义语句和存储过程的增删改--返回影响的行数
/// SqlServer: exec getActionUrlId @name,@ID
/// MySql: call getActionUrlId(@name,@ID)
/// </summary>
/// <param name="sql">sql语句或存储过程</param>
/// <param name="parms">参数 new SqlParameter("@name","Jamel")</param>
/// <returns></returns>
int ExecuteSqlCommand(string sql, IEnumerable<SqlParameter> parms); #endregion }
}
上一篇:errors collectiions


下一篇:创建Windows服务(Windows Services)N种方式总结