C#数据仓储类

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了C#数据仓储类，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含12604字，纯文字阅读大概需要19分钟。

内容图文

https://ninesky.codeplex.com/SourceControl/latest

              1
            /*
            ==============================

              2
            版本：v0.1

              3
            创建：2016.2.6

              4
            作者：洞庭夕照

              5
            博客:
            http://mzwhj.cnblogs.com
              6
            -----------------------------

              7
            修改：2016.3.4

              8
            public int Delete(T entity, bool isSave)

              9
            Remove 改为Attach

             10
            -----------------------------

             11
            修改：2016.3.17

             12
            public IQueryable<T> FindPageList(int pageSize, int pageIndex, out int totalNumber, Expression<Func<T, bool>> where, OrderParam[] orderParams)

             13
            排序参数Expression<Func<T, TKey>> order, bool asc 改为  OrderParam[] orderParams

             14
            ==============================
            */
             15
             16
            using
             System;

             17
            using
             System.Collections.Generic;

             18
            using
             System.Data.Entity;

             19
            using
             System.Linq;

             20
            using
             System.Linq.Expressions;

             21
            using
             Ninesky.Auxiliary;

             22
             23
            namespace
             Ninesky.DataLibrary

             24
            {

             25
            ///
            <summary>
             26
            ///
             数据仓储类

             27
            ///
            </summary>
             28
            ///
            <typeparam name="T">
            实体模型
            </typeparam>
             29
            public
            class Repository<T> where T : class 30    {
 31///<summary> 32/// 数据上下文
 33///</summary> 34public DbContext DbContext { get; set; }
 35 36public Repository()
 37        { }
 38 39///<summary> 40/// 构造函数
 41///</summary> 42///<param name="dbContext">数据上下文</param> 43public Repository(DbContext dbContext)
 44        {
 45             DbContext = dbContext;
 46        }
 47 48//查找实体 49#region Find
 50///<summary> 51/// 查找实体
 52///</summary> 53///<param name="ID">实体主键值</param> 54///<returns></returns> 55public T Find(int ID)
 56        {
 57return DbContext.Set<T>().Find(ID);
 58        }
 59 60///<summary> 61/// 查找实体
 62///</summary> 63///<param name="where">查询Lambda表达式</param> 64///<returns></returns> 65public T Find(Expression<Func<T, bool>> where)
 66        {
 67return DbContext.Set<T>().SingleOrDefault(where);
 68        }
 69#endregion 70 71//查找实体列表 72#region FindList
 73///<summary> 74/// 查找实体列表
 75///</summary> 76///<returns></returns> 77public IQueryable<T> FindList()
 78        {
 79return DbContext.Set<T>();
 80        }
 81 82///<summary> 83/// 查找实体列表
 84///</summary> 85///<param name="where">查询Lambda表达式</param> 86///<returns></returns> 87public IQueryable<T> FindList(Expression<Func<T, bool>> where)
 88        {
 89return DbContext.Set<T>().Where(where);
 90        }
 91 92///<summary> 93/// 查找实体列表
 94///</summary> 95///<param name="where">查询Lambda表达式</param> 96///<param name="number">获取的记录数量</param> 97///<returns></returns> 98public IQueryable<T> FindList(Expression<Func<T, bool>> where, int number)
 99        {
100return DbContext.Set<T>().Where(where).Take(number);
101        }
102103///<summary>104/// 查找实体列表
105///</summary>106///<param name="where">查询Lambda表达式</param>107///<param name="orderParam">排序参数</param>108///<returns></returns>109public IQueryable<T> FindList(Expression<Func<T, bool>> where, OrderParam orderParam)
110        {
111return FindList(where, orderParam, 0);
112        }
113114///<summary>115/// 查找实体列表
116///</summary>117///<param name="where">查询Lambda表达式</param>118///<param name="orderParam">排序参数</param>119///<param name="number">获取的记录数量【0-不启用】</param>120public IQueryable<T> FindList(Expression<Func<T, bool>> where, OrderParam orderParam, int number)
121        {
122             OrderParam[] _orderParams = null;
123if (orderParam != null) _orderParams = new OrderParam[] { orderParam };
124return FindList(where, _orderParams, number);
125        }
126127///<summary>128/// 查找实体列表
129///</summary>130///<param name="where">查询Lambda表达式</param>131///<param name="orderParams">排序参数</param>132///<param name="number">获取的记录数量【0-不启用】</param>133///<returns></returns>134public IQueryable<T> FindList(Expression<Func<T, bool>> where, OrderParam[] orderParams, int number)
135        {
136var _list = DbContext.Set<T>().Where(where);
137var _orderParames = Expression.Parameter(typeof(T), "o");
138if (orderParams != null && orderParams.Length > 0)
139            {
140bool _isFirstParam = true;
141for (int i = 0; i < orderParams.Length; i++)
142                {
143//根据属性名获取属性144var _property = typeof(T).GetProperty(orderParams[i].PropertyName);
145//创建一个访问属性的表达式146var _propertyAccess = Expression.MakeMemberAccess(_orderParames, _property);
147var _orderByExp = Expression.Lambda(_propertyAccess, _orderParames);
148string _orderName;
149if (_isFirstParam)
150                    {
151                         _orderName = orderParams[i].Method == OrderMethod.ASC ? "OrderBy" : "OrderByDescending";
152                         _isFirstParam = false;
153                    }
154else _orderName = orderParams[i].Method == OrderMethod.ASC ? "ThenBy" : "ThenByDescending";
155                     MethodCallExpression resultExp = Expression.Call(typeof(Queryable), _orderName, new Type[] { typeof(T), _property.PropertyType }, _list.Expression, Expression.Quote(_orderByExp));
156                     _list = _list.Provider.CreateQuery<T>(resultExp);
157                }
158            }
159if (number > 0) _list = _list.Take(number);
160return _list;
161        }
162#endregion163164//查找实体分页列表165#region FindPageList
166167///<summary>168/// 查找分页列表
169///</summary>170///<param name="pageSize">每页记录数。必须大于1</param>171///<param name="pageIndex">页码。首页从1开始，页码必须大于1</param>172///<param name="totalNumber">总记录数</param>173///<returns></returns>174public IQueryable<T> FindPageList(int pageSize, int pageIndex, outint totalNumber)
175        {
176             OrderParam _orderParam = null;
177return FindPageList(pageSize, pageIndex, out totalNumber, _orderParam);
178        }
179180///<summary>181/// 查找分页列表
182///</summary>183///<param name="pageSize">每页记录数。必须大于1</param>184///<param name="pageIndex">页码。首页从1开始，页码必须大于1</param>185///<param name="totalNumber">总记录数</param>186///<param name="order">排序键</param>187///<param name="asc">是否正序</param>188///<returns></returns>189public IQueryable<T> FindPageList(int pageSize, int pageIndex, outint totalNumber, OrderParam orderParam)
190        {
191return FindPageList(pageSize, pageIndex, out totalNumber, (T) => true, orderParam);
192        }
193194///<summary>195/// 查找分页列表
196///</summary>197///<param name="pageSize">每页记录数。必须大于1</param>198///<param name="pageIndex">页码。首页从1开始，页码必须大于1</param>199///<param name="totalNumber">总记录数</param>200///<param name="where">查询表达式</param>201public IQueryable<T> FindPageList(int pageSize, int pageIndex, outint totalNumber, Expression<Func<T, bool>> where)
202        {
203             OrderParam _param = null;
204return FindPageList(pageSize, pageIndex, out totalNumber, where, _param);
205        }
206207///<summary>208/// 查找分页列表
209///</summary>210///<param name="pageSize">每页记录数。</param>211///<param name="pageIndex">页码。首页从1开始</param>212///<param name="totalNumber">总记录数</param>213///<param name="where">查询表达式</param>214///<param name="orderParam">排序【null-不设置】</param>215///<returns></returns>216public IQueryable<T> FindPageList(int pageSize, int pageIndex, outint totalNumber, Expression<Func<T, bool>> where, OrderParam orderParam)
217        {
218             OrderParam[] _orderParams = null;
219if (orderParam != null) _orderParams = new OrderParam[] { orderParam };
220return FindPageList(pageSize, pageIndex, out totalNumber, where, _orderParams);
221        }
222223///<summary>224/// 查找分页列表
225///</summary>226///<param name="pageSize">每页记录数。</param>227///<param name="pageIndex">页码。首页从1开始</param>228///<param name="totalNumber">总记录数</param>229///<param name="where">查询表达式</param>230///<param name="orderParams">排序【null-不设置】</param>231public IQueryable<T> FindPageList(int pageSize, int pageIndex, outint totalNumber, Expression<Func<T, bool>> where, OrderParam[] orderParams)
232        {
233if (pageIndex < 1) pageIndex = 1;
234if (pageSize < 1) pageSize = 10;
235             IQueryable<T> _list = DbContext.Set<T>().Where(where);
236var _orderParames = Expression.Parameter(typeof(T), "o");
237if (orderParams != null && orderParams.Length > 0)
238            {
239for (int i = 0; i < orderParams.Length; i++)
240                {
241//根据属性名获取属性242var _property = typeof(T).GetProperty(orderParams[i].PropertyName);
243//创建一个访问属性的表达式244var _propertyAccess = Expression.MakeMemberAccess(_orderParames, _property);
245var _orderByExp = Expression.Lambda(_propertyAccess, _orderParames);
246string _orderName = orderParams[i].Method == OrderMethod.ASC ? "OrderBy" : "OrderByDescending";
247                     MethodCallExpression resultExp = Expression.Call(typeof(Queryable), _orderName, new Type[] { typeof(T), _property.PropertyType }, _list.Expression, Expression.Quote(_orderByExp));
248                     _list = _list.Provider.CreateQuery<T>(resultExp);
249                }
250            }
251             totalNumber = _list.Count();
252return _list.Skip((pageIndex - 1) * pageSize).Take(pageSize);
253        }
254255#endregion256257//添加实体258#region Add
259260///<summary>261/// 添加实体【立即保存】
262///</summary>263///<param name="entity">实体</param>264///<returns>受影响的对象的数目</returns>265publicint Add(T entity)
266        {
267return Add(entity, true);
268        }
269270///<summary>271/// 添加实体
272///</summary>273///<param name="entity">实体</param>274///<param name="isSave">是否立即保存</param>275///<returns>在“isSave”为True时返回受影响的对象的数目，为False时直接返回0</returns>276publicint Add(T entity, bool isSave)
277        {
278             DbContext.Set<T>().Add(entity);
279return isSave ? DbContext.SaveChanges() : 0;
280        }
281282#endregion283284//更新实体285#region Update
286287///<summary>288/// 更新实体【立即保存】
289///</summary>290///<param name="entity">实体</param>291///<returns>受影响的对象的数目</returns>292publicint Update(T entity)
293        {
294return Update(entity, true);
295        }
296297///<summary>298/// 更新实体
299///</summary>300///<param name="entity">实体</param>301///<param name="isSave">是否立即保存</param>302///<returns>在“isSave”为True时返回受影响的对象的数目，为False时直接返回0</returns>303publicint Update(T entity, bool isSave)
304        {
305             DbContext.Set<T>().Attach(entity);
306             DbContext.Entry<T>(entity).State = EntityState.Modified;
307return isSave ? DbContext.SaveChanges() : 0;
308        }
309#endregion310311//删除312#region Delete
313314///<summary>315/// 删除实体【立即保存】
316///</summary>317///<param name="entity">实体</param>318///<returns>受影响的对象的数目</returns>319publicint Delete(T entity)
320        {
321return Delete(entity, true);
322        }
323324///<summary>325/// 删除实体
326///</summary>327///<param name="entity">实体</param>328///<param name="isSave">是否立即保存</param>329///<returns>在“isSave”为True时返回受影响的对象的数目，为False时直接返回0</returns>330publicint Delete(T entity, bool isSave)
331        {
332             DbContext.Set<T>().Attach(entity);
333             DbContext.Entry<T>(entity).State = EntityState.Deleted;
334return isSave ? DbContext.SaveChanges() : 0;
335        }
336337///<summary>338/// 批量删除实体
339///</summary>340///<param name="entities">实体集合</param>341///<returns>受影响的对象的数目</returns>342publicint Delete(IEnumerable<T> entities)
343        {
344             DbContext.Set<T>().RemoveRange(entities);
345return DbContext.SaveChanges();
346        }
347#endregion348349//记录数350#region Count
351352///<summary>353/// 记录数
354///</summary>355///<returns></returns>356publicint Count()
357        {
358return DbContext.Set<T>().Count();
359        }
360361///<summary>362/// 记录数
363///</summary>364///<param name="predicate">表达式</param>365///<returns></returns>366publicint Count(Expression<Func<T, bool>> predicate)
367        {
368return DbContext.Set<T>().Count(predicate);
369        }
370#endregion371372///<summary>373/// 记录是否存在
374///</summary>375///<param name="predicate">表达式</param>376///<returns></returns>377publicbool IsContains(Expression<Func<T, bool>> predicate)
378        {
379return Count(predicate) > 0;
380        }
381382///<summary>383/// 保存数据【在Add、Upate、Delete未立即保存的情况下使用】
384///</summary>385///<returns>受影响的记录数</returns>386publicint Save()
387        {
388return DbContext.SaveChanges();
389        }
390    }
391 }

原文：http://www.cnblogs.com/wanghaibin/p/6196003.html

内容总结

以上是互联网集市为您收集整理的C#数据仓储类全部内容，希望文章能够帮你解决C#数据仓储类所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/1307827.html

来源：【匿名】

【下一篇】assemblyinfo.csC#Assembly类访问程序集信息

更多 ►

【C#数据仓储类】教程文章相关的互联网学习教程文章

https://ninesky.codeplex.com/SourceControl/latest 1/*==============================2版本：v0.13创建：2016.2.64作者：洞庭夕照5博客:http://mzwhj.cnblogs.com 6-----------------------------7修改：2016.3.48public int Delete(T entity, bool isSave)9Remove 改为Attach10-----------------------------11修改：2016.3.1712public IQueryable<T> FindPageList(int pageSize, int pageIndex, out int totalNumber, Expre...

在C#中，不安装Oracle客户端如何连接Oracle数据库【代码】【图】

本方法优点： 1、程序内集成Oracle客户端，无需用户自行进行配置本方法缺点： 2、增加程序包的体积（Oracle instant client本身有几十兆大小）下面说一下如何实现。0、首先，从Oracle网站上下载对应版本的Oracle instant client包，网址在这里 http://www.oracle.com/technetwork/database/features/instant-client/index-097480.html 由于是Windows程序，只需要下载Win32或64版本就行了。1、下载来的.zip压缩包，解压后应该有如下...

【转载】C#.NET WebApi返回各种类型(图片/json数据/字符串)，.net图片转二进制流或byte【代码】

C#.NET WebApi返回各种类型(图片/json数据/字符串)，.net图片转二进制流或byte转载：http://www.itdos.com/Mvc/20150302/0741255.htmlusing System.IO; ///<summary>/// WebApi返回图片 ///</summary>public HttpResponseMessage GetQrCode() { var imgPath = @"D:\ITdosCom\Images\itdos.jpg"; //从图片中读取byte var imgByte = File.ReadAllBytes(imgPath); //从图片中读取流 var imgStream = new MemoryStream(File...

使用C#开发数据库应用系统

使用ListView控件展示数据笔记1:ImageList控件的属性: ImageList不能独立使用,只用来为Windows窗体中的其他控件提供图像图像列表的控件的主要属性:属性 ...

C#连接MySQL数据库【代码】

最近在做一个项目是.net+MySQL数据库，之前一直用的事SQL Server数据库，基本没接触过MySQL数据库，这次写.net连接MySQL数据库连接时发现个注意事项，写出来给大家做个提醒。其实C#连接MySQL的方式和连接SQL Server的方式很类似，简单的说一下供大家参考(我连接MySQL数据库是通过ADO.Net)：1.通过ADO.Net连接数据要用到MySql.Data.dll 这个类库，比较重要的一点是： MySql.Data.dll的版本有很多，程序中试用时，用到的MySql...

c#如何合并两个数据库表格【图】

表1.tb_1 表2.tb_2将表1和2合并代码：public partial class Form1 : Form { public Form1() { InitializeComponent(); } SqlConnection conn; private void Form1_Load(object sender, EventArgs e) { conn = new SqlConnection("server=.;database=k;uid=sa;pwd...

C# 数据结构--排序[上]【代码】【图】

概述　　看了几天的排序内容，现在和大家分享一些常见的排序方法。　　啥是排序？　　个人理解的排序：通过对数组中的值进行对比，交换位置最终得到一个有序的数组。排序分为内存排序和外部排序。本次分享排序方法都为内存排序。啥是排序的稳定性？假定在待排序的记录序列中，存在多个具有相同的关键字的记录，若经过排序，这些记录的相对次序保持不变，即在原序列中，ri=rj，且ri在rj之前，而在排序后的序列中，ri...

c# JD快速搜索工具，2015分析JD搜索报文，模拟请求搜索数据，快速定位宝贝排行位置。【代码】【图】

分析JD搜索报文搜索关键字女装第二页，分2次加载。 rt=1&stop=1&click=&psort=&page=3http://search.jd.com/Search?keyword=%E5%A5%B3%E8%A3%85&enc=utf-8#keyword=%E5%A5%B3%E8%A3%85&enc=utf-8&qrst=UNEXPAND&as=1&qk=title_key%2C%2C%E5%A5%B3%E8%A3%85&rt=1&stop=1&sttr=1&cid2=1343&click=2-1343&psort=&page=3http://search.jd.com/s.php?keyword=%E5%A5%B3%E8%A3%85&enc=utf-8&qrst=UNEXPAND&as=1&qk=title_key%2C%2C%E5%...

C# NPOI的数据批量导入数据库

public ActionResult Upload(HttpPostedFileBase Namefile) { //判断文件是否存在 if (Namefile == null) { return Content("没有文件"); } //获取上传文件的名称,位置 var fileName = DateTime.Now.ToString("yyyyMMddhhmmss") + Namefile.FileName.Substring(Namefile.FileName.LastIndexOf(‘.‘)); //执行上传 ...

C# 连接Oracle数据库，免安装oracle客户端【代码】【图】

一、方案1首先下面的内容，有待我的进一步测试和证实。18.12.20被证实了，还需要安装Oracle客户端，或者本机上安装oracle数据库软件。 18.12.20 1.下载Oracle.ManagedDataAccess.dll2.添加到C#引用3.命名空间引用using Oracle.ManagedDataAccess.Client;4. 连接参数的获取然后打开Oracle安装的文件夹，以Oracle10为例D:\Oracle10\NETWORK\ADMIN\tnsnames.ora,打开这个文件，会看到如果没有请按照图片内容输入即可，host=[主机名称]...

C#打开SDE数据库的几种方式总结【代码】

转自谢灿软件原文 C#打开SDE数据库的几种方式总结 1.通过指定连接属性参数打开数据库 ///<param name="server">数据库服务器名</param>///<param name="instance">SDE的端口，默认安装时"port:5151"</param>///<param name="user">SDE的用户名</param>///<param name="password">密码</param>///<param name="database">数据库的名字</param>///<param name="version">SDE的版本</param>///<returns></returns>public IWorkspace O...

C# 微信生活助手空气质量天气预报等效果展示数据抓取（一）【代码】【图】

第一次在博客园写博客写的不好，大家见谅。最近工作辞了，然后感冒发烧输了一个星期的液，感觉很烦躁，心情不是很好，在帝都感觉压力大，废话不说了开始正题把！还没有完全完成，后续考虑开源！可以关注微信公众帐号体验一下先看下效果把先介绍下工具我用的有 httpwatch，fiddler 国家环保部的数据链接 http://datacenter.mep.gov.cn/report/air_daily/airDairyCityHour.jsp原以为直接get请求就可以了试了下发现没有获取了然...

c#.net Excel中的数据导入到SQL数据库中

/// <summary> /// 从Excel 导入学生 /// </summary> /// <param name="sender"></param> /// <param name="e"></param> private void btnInport_Click(object sender, EventArgs e) { try { //取得用户选择的Excel文件的方法 string strFileName = GetUserSelectFile();//获得excel路径 //string strFileName = @...

关于c#数据库的简单应用-datagriview连接数据库及更相关操作【图】

先介绍下关于数据库的连接：我们首先通过connection对象对数据连接：string str1 = Application.StartupPath;string str = "provider=Microsoft.Jet.OLEDB.4.0; data Source="+str1+@"\telephone.mdb; Persist Security Info=False";OleDbConnection conn = new OleDbConnection(str);在连接字符串中：provider=指的是提供服务的文件，data sourc=指的是数据库文件所在的位置，persist security info=指的是是否保存安全信息，其实...

C#通过窗体应用程序操作数据库（增删改查）【代码】【图】

为了体现面向对象的思想，我们把“增删改查”这些函数封装到一个数据库操作类里；为了便于窗体程序与数据库之间进行数据交互，我们建一个具有数据库行数据的类，通过它方便的在窗体程序与数据库之间传输数据。首先，建立程序的主窗体㈠添加数据当点击“增加”，弹出一个子窗体，通过子窗体往数据库中添加一条数据privatevoid button1_Click(object sender, EventArgs e){Form5 insert= new Form5();insert.Owner = this;insert.Sh...

C# - 技术教程分类

C# 教程 C# 简介 C# 环境 C# 程序结构 C# 基本语法 C# 数据类型 C# 类型转换 C# 变量 C# 常量 C# 运算符 C# 判断 C# 循环 C# 封装 C# 方法 C# 可空类型 C# 数组（Array） C# 字符串（String） C# 结构体（Struct） C# 枚举（Enum） C# 类（Class） C# 继承 C# 多态性 C# 运算符重载 C# 接口（Interface） C# 命名空间（Namespace） C# 预处理器指令 C# 异常处理 C# 特性（Attribute） C# 反射（Reflection） C# 属性（Property） C# 索引器（Indexer） C# 委托（Delegate） C# 事件（Event） C# 集合（Collection） C# 泛型（Generic） C# 匿名方法 C# 不安全代码 C# 多线程 c# 全部

C# - 最热教程

c#编程连接oracle数据库无法加载DLL(oc...一个适合新手C#程序员编写练习的小项目...C# 异步UDP发送接收数据 C#程序执行时间长和慢查询解决：线程并...c# aspose操作word文档 C#继承讲解以及对象的创建 jquery+ajax+C#实现无刷新操作数据库数...C#精髓 GridView72大绝技学习gridview...c# static的全部用法收集整理 js模拟实现类似c#下的hashtable的简单功...