基于轻量级ORM框架Dapper的扩展说明
这里简单的介绍一下本人基于Dapper作的一些简单的扩展，供大家参考。
为何要使用这款框架，相信大家看到下面排名就清楚了
其实在各大网站上，我们大概都会看到这样的一个对比效果图，在超过500次poco serialization的过程中所表现的性能，我们发现dapper是第二名，
当然第一名谁也无法超越，越底层的当然久越快，同时也就越麻烦。
至于如何使用进行基本的数据操作，我这里就不再阐述，http://www.cnblogs.com/Sinte-Beuve/p/4231053.html这里介绍了Dapper的基本使用的方法。
一.文件说明，打包的文件如下
SqlMapperExtensions类：ORM扩展类，基于SQLMapper类的扩展。
SqlMapper类--Dapper原始类：一些底层封装代码，使用时可查看其实现原理。
生成实体类_Dapper_模板文件：用于动态生成实体类的模板，配合DOS生成工具使用。
二.扩展类新增的几个方法
SqlMapperExtensions类中新增： UpdateGiven()、InsertGiven()、GetPageList()方法。
UpdateGiven()：更新时只更新赋值的字段
InsertGiven()：插入时只插入赋值的字段
GetPageList()：新增分页查询
另新增数据库环境支持Oracle
三.举栗子
这里用上面的方法来简单的测试一下。
复制代码
1 using System;
2 using System.Collections.Generic;
3 using System.Data;
4 using System.Data.SqlClient;
5 using System.Linq;
6 using System.Text;
7 using System.Threading.Tasks;
8 using Dapper;
9 using System.Data.OracleClient;
10 using Dapper.Contrib.Extensions;
11 using Dapper.Contrib;
12 using Dapper.Model;
13 namespace ConsoleTest1
14 {
15 class Program
16 {
18 static IDbConnection conn = new OracleConnection("Data Source=(DESCRIPTION=(ADDRESS_LIST=(ADDRESS=(PROTOCOL=TCP)(HOST=*.*.*.*)(PORT=1521)))(CONNECT_DATA=(service_name =*)));Persist Security Info=True;User ID=*; Password=*;");
19 static void Main(string[] args)
20 {
21 //创建Book表
22 conn.Execute(@" create table Book (Id number, Name nvarchar2(100) not null),Remark nvarchar2(200)");
23 Console.WriteLine("Created database");
24 BOOK book = new BOOK();
25 book.NAME = "C#本质论";
26 book.ID = 1001;
27 string query = "INSERT INTO Book(Id,Name)VALUES(@Id,@Name)";
28 //对对象进行操作
29 conn.Execute(query, book);//原始操作 传入sql语句和参数
30
31 ////以下是扩展中的方式
32 //直接用Insert虽然只给了部分字段，但会插入所有字段，造成数据库的默认值会被覆盖的情况
33 conn.Insert(new BOOK { ID = 1004, NAME = "Dapper" });
34 conn.InsertGiven(new BOOK { ID = 1004, NAME = "Dapper" });
35 //每次执行Update方法也是会更新所有字段，没赋值的字段会覆盖掉原始数据库的值
36 conn.Update(new BOOK { ID = 1004, NAME = "Dapper" });
37 conn.UpdateGiven(new BOOK { ID = 1004, NAME = "update Dos way" });
38 ////以下是分页查询，有一个重载
39 long longCount;
40 var sortlist=new List();
41 sortlist.Add(new Sort{ PropertyName="id",Ascending=true});
42 //该方法要传入一个长整型变量供传递出查询的总量
43 var pagebook = conn.GetPageList(0, 10, out longCount, new BOOK { ID=1004}, sortlist);
44 //该重载不需要传入长整型变量
45 var pagebook2 = conn.GetPageList(0, 10, null, sortlist);
46
47 }
48 }
49
50 }
复制代码
其中具体方式的实现分别如下：
InsertGiven
UpdateGiven
复制代码
1 ///
2 /// Paging
3 ///
4 /// 传入实体类型
5 /// 此连接
6 /// 第几页:0为第一页开始
7 /// 每页数量
8 /// 返回满足条件总量
9 /// 条件:实体传入
10 /// 排序条件：ISort列表方式传入
11 /// 是否缓存
12 /// GetPageList(this IDbConnection connection, int pageIndex, int pageSize, out long allRowsCount,
14 T entityToPredicate = null, IList sort = null, bool buffered = true) where T : Entity
15 {
16 DynamicParameters dynamicParameters = new DynamicParameters();
17 var type = typeof(T);
18 SetSqlConnectTag(connection);//根据不同数据库设置标记符 SqlServer@ Oracle:
19 var keys = KeyPropertiesCache(type);
20 if (keys.Count() > 1)
21 throw new DataException("Get only supports an entity with a single [Key] property");
22 if (!keys.Any())
23 throw new DataException("Get only supports en entity with a [Key] property");
24
25 var onlyKey = keys.First();
26 StringBuilder innersql = new StringBuilder(string.Format("SELECT * FROM {0}",
27 GetTableName(type)));
28 if (entityToPredicate != null)
29 {
30 var mfields = entityToPredicate.GetModifyFields();
31 innersql.Append(" where ");
32 for (var i = 0; i < mfields.Count; i++)
33 {
34 innersql.AppendFormat("{0} = {2}{1}", mfields[i].Field, mfields[i].Field, SqlConnectTag);
35 if (i < mfields.Count - 1)
36 innersql.AppendFormat(", ");
37 dynamicParameters.Add(mfields[i].Field, mfields[i].NewValue);
38 }
39 }
40 if (sort != null && sort.Any())
41 {
42 innersql.Append(" ORDER BY ")
43 .Append(sort.Select(s => s.PropertyName + (s.Ascending ? " ASC" : " DESC")).AppendStrings());
44 }
45 allRowsCount = connection.Query(innersql.ToString(), entityToPredicate).Count();
46 Dictionary parameters = new Dictionary();
47 string sql = GetFormatter(connection).GetPagingSql(innersql.ToString(), pageIndex, pageSize, parameters);
48 foreach (var parameter in parameters)
49 {
50 dynamicParameters.Add(parameter.Key, parameter.Value);
51 }
52 return connection.Query(sql, dynamicParameters);
53 }
复制代码
下面我们来调试一下来看看Insert和InsertGiven、Update和UpdateGiven的区别吧
复制代码
1 ////以下是扩展中的方式
2 //直接用Insert虽然只给了部分字段，但会插入所有字段，造成数据库的默认值会被覆盖的情况
3 conn.Insert(new BOOK { ID = 1004, NAME = "Dapper" });
4 conn.InsertGiven(new BOOK { ID = 1004, NAME = "Dapper" });
5 //每次执行Update方法也是会更新所有字段，没赋值的字段会覆盖掉原始数据库的值
6 conn.Update(new BOOK { ID = 1004, NAME = "Dapper" });
7 conn.UpdateGiven(new BOOK { ID = 1004, NAME = "update Dos way" });
复制代码
Insert生成的sql语句：
InsertGiven生成的sql语句：
Update生成的sql语句:
UpdateGiven生成的sql语句：
想必扩展的方法个中缘由就一清二楚了。
四.实体类生成
其中BOOK实体类如何生成?这里借鉴了DOS生成实体类工具，并新增了一个模板文件->生成实体类_Dapper_模板文件.tpl
打开DOSTOOL的Debug文件，将其放入模板文件中，重新打开DOSTOOL文件便可看见新增了一个模板，选择其模板，生成代码即可。
以上。
分类: Dapper
标签: Dapper, 轻量级ORM, Dapper扩展, Dapper Extensionhttp://www.cnblogs.com/hxzblog/p/7462229.html