使用輕量級ORM Dapper進行增刪改查

本文轉載自查看原文 2015-07-12 09:57 23825 c#/ Orm/ 高性能ORM/ Dapper

項目背景

前一段時間，開始做一個項目，在考慮數據訪問層是考慮技術選型，考慮過原始的ADO.NET、微軟的EF、NH等。再跟經理討論后，經理強調不要用Ef，NH做ORM，后期的sql優化不好做，公司也沒有人對EF，Nh 等orm優化比較熟悉的。強調說的，我們的項目要做的得簡單，可以使用ADO.NET 寫原始的sql。但我自己還是喜歡ORM的，它可以提高數據訪問層的開發。有一天，在訂閱張善友 doNet跨平台微信公眾號里，看到Dapper的推薦。了解之后，我自己喜歡喜歡Dapper，可以滿足我這個項目的經理的要求，同時Dapper 對數據庫的訪問能做到Ado.net一樣快。

下面的鏈接是Dapper 在github的地址 https://github.com/StackExchange/dapper-dot-net。

使用 Dapper 進行簡單增刪改查示例

1、首先根據數據庫表定義實體對象，這個工作完全可以使用T4、Nvelocity或者RazorEngine 寫一個代碼生成器根據數據庫表對象自動生成數據庫表實體對象。這里我自己根據表寫了一個對象

 1    [Table("UserRole")]
 2    public class UserRoleDbEntity:DbEntityModelBase
 3     {
 4         [Description("用戶編號，來自用戶表")]
 5         public int UserId
 6         {
 7             get;
 8             set;
 9         }
10 
11        [Description("角色編號，來自於角色表")]
12         public int RoleId
13         {
14             get;
15             set;
16         }
17         /// <summary>
18         /// 備注：AuthorityEnum.AuthorityValue 的取值范圍是根據 AuthorityEnum位運算 或 與 的結果集；不可隨意賦值
19         /// </summary>
20         [Description("權限值")]
21         public int AuthorityValue { get; set; }
22 
23         /// <summary>
24         /// 根據 AuthorityEnum 枚舉值生成的描述
25         /// </summary>
26         [Description("權限描述")]
27         public string AuthorityDescription { get; set; }
28     }
29 
30     /// <summary>
31     /// 所有DbEntityModel項目中的實體必須繼承DbEntityModelBase或其子類，使用supperType模式控制共有子類的行為或者狀態，此項目中的類根據數據庫基本表或者視圖保持基本一致
32     /// </summary>
33    public abstract class DbEntityModelBase
34     {
35         [Description("Guid標識")]
36         public string GuidMark
37         {
38             get;
39             set;
40         }
41         [Description("自增Id列")]
42         public int Id
43         {
44             get;
45             set;
46         }
47        [Description("排序，倒序")]
48         public int Sort
49         {
50             get;
51             set;
52         }
53     }

View Code

2. 在DAL層就可以使用實體對象傳參或者作為返回值

  1 using System;
  2 using System.Collections.Generic;
  3 using System.Linq;
  4 using System.Text;
  5 using OnlineExercise.DbAccess;
  6 using Dapper;
  7 using System.Configuration;
  8 using System.Data;
  9 using MySql.Data;
 10 using MySql.Data.MySqlClient;
 11 using OnlineExercise.DbEntityModel;
 12 using OnlineExercise.Log;
 13 using OnlineExercise.Infrastructrue;
 14 
 15 namespace OnlineExercise.DbAccess.SysAdminModule
 16 {
 17     public class UserRoleDB:DalBase<UserRoleDB>
 18     {
 19         public int AddUserRole(UserRoleDbEntity model)
 20         {
 21             int affecgtRow = 0;
 22             string sql = @"INSERT INTO  `userrole`
 23                                     (`GuidMark`,
 24                                      `UserId`,
 25                                      `RoleId`,
 26                                      `AuthorityValue`,
 27                                      `AuthorityDescription`)
 28                         VALUES (@GuidMark,
 29                                 @UserId,
 30                                 @RoleId,
 31                                 @AuthorityValue,
 32                                 @AuthorityDescription);";
 33             using (IDbConnection conn = new MySqlConnection(GlobalVariablesManager.G_Strconn))
 34             {
 35                 affecgtRow = conn.Execute(sql, model);
 36             }
 37             return affecgtRow;
 38         }
 39 
 40         public int UpdateUserRoleByRoleIdAndUserId(UserRoleDbEntity model)
 41         {
 42             int affecgtRow = 0;
 43             string sql = @"UPDATE  `userrole`
 44                             SET  `AuthorityValue` = @AuthorityValue,
 45                                 `AuthorityDescription` = @AuthorityDescription
 46                             WHERE `UserId` = @UserId
 47                                 AND `RoleId` = @RoleId;";
 48             using (IDbConnection conn = new MySqlConnection(GlobalVariablesManager.G_Strconn))
 49             {
 50                 affecgtRow = conn.Execute(sql, model);
 51             }
 52             return affecgtRow;
 53         }
 54 
 55         public int UpdateUserRoleByRoleId(UserRoleDbEntity model)
 56         {
 57             int affecgtRow = 0;
 58             string sql = @"UPDATE  `userrole`
 59                             SET  `AuthorityValue` = @AuthorityValue,
 60                                 `AuthorityDescription` = @AuthorityDescription
 61                             WHERE `RoleId` = @RoleId;";
 62             using (IDbConnection conn = new MySqlConnection(GlobalVariablesManager.G_Strconn))
 63             {
 64                 affecgtRow = conn.Execute(sql, model);
 65             }
 66             return affecgtRow;
 67         }
 68 
 69         public int UpdateUserRoleByUserId(UserRoleDbEntity model)
 70         {
 71             int affecgtRow = 0;
 72             string sql = @"UPDATE  `userrole`
 73                             SET  `AuthorityValue` = @AuthorityValue,
 74                                 `AuthorityDescription` = @AuthorityDescription
 75                             WHERE `UserId` = @UserId;";
 76             using (IDbConnection conn = new MySqlConnection(GlobalVariablesManager.G_Strconn))
 77             {
 78                 affecgtRow = conn.Execute(sql, model);
 79             }
 80             return affecgtRow;
 81         }
 82 
 83         public List<UserRoleDbEntity> GetUserRoleListByRoleId(UserRoleDbEntity model)
 84         {
 85             List<UserRoleDbEntity> modelList = null;
 86             string sql = @"SELECT
 87                               `Id`,
 88                               `GuidMark`,
 89                               `sort`,
 90                               `UserId`,
 91                               `RoleId`,
 92                               `AuthorityValue`,
 93                               `AuthorityDescription`
 94                             FROM `userrole`
 95                             WHERE RoleId=@RoleId;";
 96             using (IDbConnection conn = new MySqlConnection(GlobalVariablesManager.G_Strconn))
 97             {
 98                 modelList = conn.Query<UserRoleDbEntity>(sql, model).ToList<UserRoleDbEntity>();
 99             }
100             return modelList;
101         }
102 
103 
104         public List<UserRoleDbEntity> GetUserRoleListByUserId(string userId)
105         {
106             List<UserRoleDbEntity> modelList = null;
107             string sql = @"SELECT
108                               `Id`,
109                               `GuidMark`,
110                               `sort`,
111                               `UserId`,
112                               `RoleId`,
113                               `AuthorityValue`,
114                               `AuthorityDescription`
115                             FROM `userrole`
116                             WHERE UserId=@UserId;";
117             using (IDbConnection conn = new MySqlConnection(GlobalVariablesManager.G_Strconn))
118             {
119                 modelList = conn.Query<UserRoleDbEntity>(sql, new { UserId =userId}).ToList<UserRoleDbEntity>();
120             }
121             return modelList;
122         }
123 
124         public List<UserRoleDbEntity> GetUserRoleListByRoleIdAndUserId(UserRoleDbEntity model)
125         {
126             List<UserRoleDbEntity> modelList = null;
127             string sql = @"SELECT
128                               `Id`,
129                               `GuidMark`,
130                               `sort`,
131                               `UserId`,
132                               `RoleId`,
133                               `AuthorityValue`,
134                               `AuthorityDescription`
135                             FROM `userrole`
136                             WHERE RoleId=@RoleId and UserId=@UserId;";
137             using (IDbConnection conn = new MySqlConnection(GlobalVariablesManager.G_Strconn))
138             {
139                 modelList = conn.Query<UserRoleDbEntity>(sql, model).ToList<UserRoleDbEntity>();
140             }
141             return modelList;
142         }
143 
144         public int DeleteUserRoleByUserId(string userId)
145         {
146             int affecgtRow = 0;
147             string sql = @"DELETE
148                             FROM  `userrole`
149                             WHERE `UserId` = @UserId";
150             using (IDbConnection conn = new MySqlConnection(GlobalVariablesManager.G_Strconn))
151             {
152                 affecgtRow = conn.Execute(sql, new { UserId = userId });
153             }
154             return affecgtRow;
155         }
156 
157         public int DeleteUserRoleByRoleId(string roleId)
158         {
159             int affecgtRow = 0;
160             string sql = @"DELETE
161                             FROM  `userrole`
162                             WHERE `RoleId` = @RoleId;";
163             using (IDbConnection conn = new MySqlConnection(GlobalVariablesManager.G_Strconn))
164             {
165                 affecgtRow = conn.Execute(sql, new { RoleId = roleId });
166                  
167             }
168             return affecgtRow;
169         }
170 
171         public DataTable GetRoleInfoByUserId(string userId)
172         {
173             DataTable dt = null;
174 
175             string sql = @"SELECT b.*,a.userid,c.name as userName  FROM userrole AS a
176                                 INNER JOIN role AS b ON a.roleid=b.id
177                                 INNER JOIN USER AS c ON c.id=a.userid
178                                 WHERE a.userid=@userid;";
179             using (IDbConnection conn = new MySqlConnection(GlobalVariablesManager.G_Strconn))
180             {
181                 IDataReader reader = conn.ExecuteReader(sql, new { userid=userId });
182                 dt = CoreUtil.DataReader2Table(reader);
183                 reader.Dispose();
184             }
185 
186             return dt;
187         }
188 
189     }
190 }

View Code

Dapper的優勢

1、Dapper是一個輕型的ORM類

2、 Dapper語法簡單，如果你喜歡寫原始的sql，你一定喜歡Dapper。同時團隊人員也很容易上手

3、Dapper 速度快，速度接近ADO.NET訪問數據庫的效率。

4、多數據庫切換方便

    public int UpdateUserRoleByRoleId(UserRoleDbEntity model)
        {
            int affecgtRow = 0;
            string sql = @"UPDATE `userrole`
                            SET `AuthorityValue` = @AuthorityValue,
                                `AuthorityDescription` = @AuthorityDescription
                            WHERE `RoleId` = @RoleId;";
            using (IDbConnection conn = new MySqlConnection(GlobalVariablesManager.G_Strconn))
            {
                affecgtRow = conn.Execute(sql, model);
            }
            return affecgtRow;
        }

這里mysql如果要切換為Sql Server ，只要修改鏈接 MySqlConnection---》SqlConnection。

Dapper更多特性

1、支持動態dynamic綁定

 1 var rows = connection.Query("select 1 A, 2 B union all select 3, 4");
 2 
 3 ((int)rows[0].A)
 4    .IsEqualTo(1);
 5 
 6 ((int)rows[0].B)
 7    .IsEqualTo(2);
 8 
 9 ((int)rows[1].A)
10    .IsEqualTo(3);
11 
12 ((int)rows[1].B)
13     .IsEqualTo(4);

View Code

2、支持批量插入

1 connection.Execute(@"insert MyTable(colA, colB) values (@a, @b)",
2     new[] { new { a=1, b=1 }, new { a=2, b=2 }, new { a=3, b=3 } }
3   ).IsEqualTo(3); // 3 rows inserted: "1,1", "2,2" and "3,3"

View Code

3、支持多表關聯

 1 var sql = 
 2 @"select * from #Posts p 
 3 left join #Users u on u.Id = p.OwnerId 
 4 Order by p.Id";
 5 
 6 var data = connection.Query<Post, User, Post>(sql, (post, user) => { post.Owner = user; return post;});
 7 var post = data.First();
 8 
 9 post.Content.IsEqualTo("Sams Post1");
10 post.Id.IsEqualTo(1);
11 post.Owner.Name.IsEqualTo("Sam");
12 post.Owner.Id.IsEqualTo(99);

View Code

4、支持多結果查詢

 1 var sql = 
 2 @"
 3 select * from Customers where CustomerId = @id
 4 select * from Orders where CustomerId = @id
 5 select * from Returns where CustomerId = @id";
 6 
 7 using (var multi = connection.QueryMultiple(sql, new {id=selectedId}))
 8 {
 9    var customer = multi.Read<Customer>().Single();
10    var orders = multi.Read<Order>().ToList();
11    var returns = multi.Read<Return>().ToList();
12    ...
13 }

View Code

5 支持存儲過程

 1 var user = cnn.Query<User>("spGetUser", new {Id = 1}, 
 2         commandType: CommandType.StoredProcedure).SingleOrDefault();
 3 // 你還可以獲取存儲過程out參數的輸出值或者返回值
 4 var p = new DynamicParameters();
 5 p.Add("@a", 11);
 6 p.Add("@b", dbType: DbType.Int32, direction: ParameterDirection.Output);
 7 p.Add("@c", dbType: DbType.Int32, direction: ParameterDirection.ReturnValue);
 8 
 9 cnn.Execute("spMagicProc", p, commandType: CommandType.StoredProcedure); 
10 
11 int b = p.Get<int>("@b");
12 int c = p.Get<int>("@c");

View Code

6、參數自動綁定

1 new {A = 1, B = "b"} // A will be mapped to the param @A, B to the param @B

View Code

  
 看到Dapper那么特性，覺得使用Dapper非常方便，使用也非常方便，擴展性也非常高。 當我用Dapper寫一個demo給項目經理看的時候，項目經理就同意使用
Dapper 作為ORM 進行數據訪問層的開發。從此就愛上了Dapper。
 希望這篇文章給你帶來對Dapper清晰的了解。同時如果這文章給你到來了幫助，也別忘了幫忙推薦。

免責聲明！

本站轉載的文章為個人學習借鑒使用，本站對版權不負任何法律責任。如果侵犯了您的隱私權益，請聯系本站郵箱yoyou2525@163.com刪除。

猜您在找 Dapper.Contrib——更加優雅地使用Dapper進行增刪改查【Python 庫】輕量級 ORM 框架 peewee 用法詳解之——增刪改查使用Dapper.Contrib進行增刪改查輕量級ORM框架Dapper應用八：使用Dapper實現DTO ORM之輕量級框架--Dapper laravel orm進行增刪改查輕量級ORM框架初探-Dapper與PetaPoco的基本使用 ORM增刪改查基於輕量級ORM框架Dapper的擴展說明分享自己寫的基於Dapper的輕量級ORM框架~