c# .net orm 框架 dapper.net 的应用

末蓝、 2022-06-16 07:45 206阅读 0赞

之前用过 entity framework 5.0 、sqlhelper 、mybatis[.NET][] 等 orm，当然 sqlhelper 不算。

感觉都是学习陈本挺高的，配置也比较复杂，尤其是 mybatis 全是 xml ，懵逼了 ~~~~~

ef 用着不错也挺灵活，就是有些[数据库][Link 1]不支持 如[MySQL][Link 1]，网上也找过ef 接入 mysql 的方法，觉得还是比较繁重

mybatis 支持大多数的数据库，实体映射也相对方便，就是灵活性太差，加一个表需要配置 好几个 xml

继续寻找及灵活又有实体映射的 orm，最后选择了 dapper[.Net][.NET]。用过之后你也会喜欢上它的，有以下几个特性

1.类似 ado.net 的写法，灵活拼接sql

2.有实体和数据集的映射（支持一对一、一对多实体映射）

3.学习成本超级低只有两个方法 query（）、execute（）

4.可以说是 0 配置，只要在 config 中配置连接字符串就 ok了

5.类库非常小 只有一个 sqlMapper.cs 的文件（还是喜欢vs2015以前的代码，所以我用的是 dapper.net 1.4.2，上传到我的资源中）

上代码，里面包含增、删、改、查，和事务的使用（这里[测试][Link 2]用的是mysql数据库）

一、数据脚本

**\[sql\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  \#订单表  
2.  **CREATE** **TABLE** \`order\_info\` (  
3.    \`order\_id\` **int**(11) NOT NULL AUTO\_INCREMENT COMMENT '订单id',  
4.    \`user\_id\` **int**(11) **DEFAULT** NULL COMMENT '用户id',  
5.    \`order\_code\` **char**(50) **DEFAULT** NULL COMMENT '订单号',  
6.    \`amount\` **decimal**(10,0) **DEFAULT** NULL COMMENT '订单金额',  
7.    \`create\_time\` **timestamp**(6) NULL **DEFAULT** NULL COMMENT '下单时间',  
8.    \`goods\_count\` **int**(11) **DEFAULT** NULL COMMENT '商品数量',  
9.    **PRIMARY** **KEY** (\`order\_id\`)  
10. ) ENGINE=InnoDB AUTO\_INCREMENT=6 **DEFAULT** CHARSET=utf8  
11.   
12. \#订单商品表  
13. **CREATE** **TABLE** \`order\_item\` (  
14.   \`item\_id\` **int**(11) NOT NULL AUTO\_INCREMENT COMMENT '订单内容id',  
15.   \`order\_id\` **int**(11) NOT NULL COMMENT '商品id',  
16.   \`goods\_name\` **char**(150) **DEFAULT** NULL COMMENT '商品名',  
17.   \`unit\_price\` **decimal**(11,0) **DEFAULT** NULL COMMENT '单价',  
18.   \`goods\_count\` **int**(11) **DEFAULT** NULL COMMENT '商品数量',  
19.   \`amount\` **decimal**(11,0) **DEFAULT** NULL COMMENT '总金额',  
20.   \`create\_time\` **timestamp**(6) NULL **DEFAULT** NULL COMMENT '创建时间',  
21.   \`update\_time\` **timestamp**(6) NULL **DEFAULT** NULL COMMENT '修改时间',  
22.   **PRIMARY** **KEY** (\`item\_id\`)  
23. ) ENGINE=InnoDB AUTO\_INCREMENT=8 **DEFAULT** CHARSET=utf8  
24.   
25. \#用户表  
26. **CREATE** **TABLE** \`user\_info\` (  
27.   \`user\_id\` **int**(11) NOT NULL AUTO\_INCREMENT COMMENT '用户id',  
28.   \`user\_name\` **char**(50) **DEFAULT** NULL COMMENT '用户名',  
29.   \`upwd\` **char**(50) **DEFAULT** NULL COMMENT '密码',  
30.   \`create\_time\` **timestamp**(6) NULL **DEFAULT** NULL COMMENT '创建时间',  
31.   \`update\_time\` **timestamp**(6) NULL **DEFAULT** NULL COMMENT '修改时间',  
32.   \`age\` **int**(3) **DEFAULT** NULL COMMENT '年龄',  
33.   \`sex\` **char**(2) **DEFAULT** NULL COMMENT '性别',  
34.   **PRIMARY** **KEY** (\`user\_id\`)  
35. ) ENGINE=InnoDB AUTO\_INCREMENT=5 **DEFAULT** CHARSET=utf8

测试用的存储过程

**\[sql\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  \#带有输入输出参数的过程  
2.  DELIMITER $$  
3.  **CREATE** **PROCEDURE** \`p\_getUserCount\`(  
4.   \_sex **CHAR**,  
5.   **OUT** \_total **INT**)  
6.  **BEGIN**  
7.      **SET** @sex = \_sex;  
8.      **SELECT** COUNT(\*) **INTO** \_total **FROM** user\_info **WHERE** sex=@sex;    
9.  **END**$$  
10.   
11. \#返回数据集的过程  
12. DELIMITER ;  
13. **CREATE** DEFINER=\`root\`@\`localhost\` **PROCEDURE** \`p\_getUserInfo\`(  
14.         \_userid **INT**  
15.     )  
16. **BEGIN**  
17.         **SET** @uid = \_userid;  
18.         **SET** @sql = CONCAT('select \* from user\_info where user\_id=',@uid );  
19.         IF(@uid<=0) **THEN**  
20.             **SET**  @sql = 'select \* from user\_info';  
21.         **END** IF;  
22.         **PREPARE** strsql **FROM** @sql;\#定义预处理语句   
23.         **EXECUTE** strsql;   
24.         **DEALLOCATE** **PREPARE** strsql;  \#删除定义   
25.     **END**$$  
26. DELIMITER ;

二、实体&工具类

**\[csharp\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  **using** System;  
2.  **using** System.Collections.Generic;  
3.  **using** System.Linq;  
4.  **using** System.Text;  
5.    
6.  **namespace** TestDapperDotNet.Models  
7.  \{  
8.      **public** **class** order\_infoModel  
9.      \{  
10.         **public** order\_infoModel()  
11.         \{  
12.             goodsList = **new** List<order\_itemModel>();  
13.         \}  
14.   
15.         **public** **int** order\_id \{ **set**; **get**; \}  
16.         **public** **int** user\_id \{ **set**; **get**; \}  
17.         **public** **string** order\_code \{ **set**; **get**; \}  
18.         **public** **decimal** amount \{ **set**; **get**; \}  
19.         **public** DateTime create\_time \{ **set**; **get**; \}  
20.         **public** **int** goods\_count \{ **set**; **get**; \}  
21.         /// <summary>  
22.         /// 下单用户信息(测试一对一映射)  
23.         /// </summary>  
24.         **public** user\_infoModel userInfo \{ **set**; **get**; \}  
25.         /// <summary>  
26.         /// 订单商品信息(测试一对多映射)  
27.         /// </summary>  
28.         **public** List<order\_itemModel>  goodsList \{ **set**; **get**; \}  
29.     \}  
30.   
31.     **public** **class** order\_itemModel  
32.     \{  
33.         **public** **int** item\_id \{ **set**; **get**; \}  
34.         **public** **int** order\_id \{ **set**; **get**; \}  
35.         **public** **string** goods\_name \{ **set**; **get**; \}  
36.         **public** **decimal** unit\_price \{ **set**; **get**; \}  
37.         **public** **int** goods\_count \{ **set**; **get**; \}  
38.         **public** **decimal** amount \{ **set**; **get**; \}  
39.         **public** DateTime create\_time \{ **set**; **get**; \}  
40.         **public** DateTime update\_time \{ **set**; **get**; \}  
41.     \}  
42.   
43.     **public** **class** user\_infoModel  
44.     \{  
45.         **public** **int** user\_id \{ **set**; **get**; \}  
46.         **public** **string** user\_name \{ **set**; **get**; \}  
47.         **public** **string** upwd \{ **set**; **get**; \}  
48.         **public** DateTime create\_time \{ **set**; **get**; \}  
49.         **public** DateTime update\_time \{ **set**; **get**; \}  
50.         **public** **int** age \{ **set**; **get**; \}  
51.         **public** **string** sex \{ **set**; **get**; \}  
52.     \}  
53. \}  
54.   
55. **using** System;  
56. **using** System.Collections.Generic;  
57. **using** System.Configuration;  
58. **using** System.Linq;  
59. **using** System.Text;  
60.   
61. **namespace** TestDapperDotNet  
62. \{  
63.     **public** **class** DbConfig  
64.     \{  
65.         **public** **static** **readonly** **string** Test\_W =   
66.             ConfigurationManager.ConnectionStrings\["test\_w"\].ConnectionString;  
67.         **public** **static** **readonly** **string** Test\_R =   
68.             ConfigurationManager.ConnectionStrings\["test\_r"\].ConnectionString;  
69.     \}  
70. \}

三、dapper.net 测试类

**\[csharp\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  **using** System;  
2.  **using** System.Collections.Generic;  
3.  **using** System.Data;  
4.  **using** System.Linq;  
5.  **using** Dapper;  
6.  **using** Microsoft.VisualStudio.TestTools.UnitTesting;  
7.  **using** TestDapperDotNet.Models;  
8.    
9.  **namespace** TestDapperDotNet  
10. \{  
11.     \[TestClass\]  
12.     **public** **class** TestDapper  
13.     \{  
14.         /// <summary>  
15.         /// 获取连接字符串  
16.         /// </summary>  
17.         /// <returns></returns>  
18.         **public** IDbConnection GetSqlConnection()  
19.         \{  
20.             **return** **new** MySql.Data.MySqlClient.MySqlConnection(DbConfig.Test\_W); ;  
21.         \}  
22.         /// <summary>  
23.         /// 查询记录返回实体  
24.         /// </summary>  
25.         \[TestMethod\]  
26.         **public** **void** TestQueryT()  
27.         \{  
28.             **using** (var conn = GetSqlConnection())  
29.             \{  
30.                 //订单表映射单条记录  
31.                 var sql = @"SELECT \* FROM order\_info WHERE order\_id=@order\_id;";  
32.                 var list = conn.Query<order\_infoModel>(sql, **new**  
33.                 \{  
34.                     order\_id = 2  
35.                 \}).ToList();  
36.                 var itme = list.FirstOrDefault();  
37.                 Assert.IsTrue(itme.order\_id == 2);  
38.   
39.                 //订单表映射多条记录  
40.                 sql = @"SELECT \* FROM order\_info";  
41.                 list = conn.Query<order\_infoModel>(sql, **new**  
42.                 \{  
43.                     order\_id = 2  
44.                 \}).ToList();  
45.                 Assert.IsTrue(list != **null** && list.Count>0);  
46.   
47.             \}  
48.         \}  
49.   
50.         /// <summary>  
51.         /// 一对一映射  
52.         /// 订单实体下有个用户信息属性，通过user\_id关联  
53.         /// </summary>  
54.         \[TestMethod\]  
55.         **public** **void** TestOneToOne()  
56.         \{  
57.             **using** (IDbConnection conn = GetSqlConnection())  
58.             \{  
59.                 var sql = @"  
60. SELECT a.\*,b.\*   
61. FROM   
62.  order\_info a  
63.  JOIN user\_info b  
64.  ON a.\`user\_id\`=b.user\_id;";  
65.                 var list = conn.Query<order\_infoModel, user\_infoModel, order\_infoModel>(  
66.                     sql  
67.                     , (order, user) =>  
68.                     \{  
69.                         order.userInfo = user;  
70.                         **return** order;  
71.                     \}  
72.                     , **null**  
73.                     , **null**  
74.                     , **true**  
75.                     , "order\_id"  
76.                     , **null**  
77.                     , **null**).ToList();  
78.   
79.                 list.ForEach(x =>  
80.                 \{  
81.                     Assert.IsTrue(x.userInfo.user\_id == x.user\_id);  
82.                 \});  
83.                 Assert.IsTrue(**true**);  
84.             \}  
85.         \}  
86.   
87.         /// <summary>  
88.         /// 一对多映射  
89.         /// </summary>  
90.         \[TestMethod\]  
91.         **public** **void** TestOneToMore()  
92.         \{  
93.             **using** (IDbConnection conn = GetSqlConnection())  
94.             \{  
95.                 var sql = @"  
96. SELECT a.\*,b.\*   
97. FROM   
98.  order\_info a  
99.  JOIN order\_item b  
100.  ON a.order\_id=b.order\_id;";  
101.                 //合并后的订单数据  
102.                 var orderDic = **new** Dictionary<**int**, order\_infoModel>();  
103.                 var originList = conn.Query<order\_infoModel, order\_itemModel, order\_infoModel>(  
104.                     sql  
105.                     , (order, goods) =>  
106.                     \{  
107.                         //需要手动维护，一对多对象关系  
108.                         order\_infoModel ord;  
109.                         **if** (!orderDic.TryGetValue(order.order\_id, **out** ord))  
110.                         \{  
111.                             ord = order;  
112.                             orderDic.Add(order.order\_id, order);  
113.                         \}  
114.                         ord.goodsList.Add(goods);  
115.                         **return** order;  
116.                     \}  
117.                     , **null**  
118.                     , **null**  
119.                     , **true**  
120.                     , "order\_id"  
121.                     , **null**  
122.                     , **null**).ToList();  
123.                 //投影一个list  
124.                 var list = orderDic.Select(x => x.Value).ToList();  
125.   
126.                 list.ForEach(x =>  
127.                 \{  
128.                     x.goodsList.ForEach(o =>  
129.                     \{  
130.                         Assert.IsTrue(o.order\_id == x.order\_id);  
131.                     \});  
132.                 \});  
133.                 Assert.IsTrue(**true**);  
134.             \}  
135.         \}  
136.         \[TestMethod\]  
137.         **public** **void** TestInsertOne()  
138.         \{  
139.             var user = **new** user\_infoModel()  
140.             \{  
141.                 user\_name="tester",  
142.                 upwd="123",  
143.                 create\_time=DateTime.Now,  
144.                 update\_time=DateTime.Now,  
145.                 age=99,  
146.                 sex="女"  
147.             \};  
148.             var sql = @"  
149. INSERT INTO \`test\`.\`user\_info\` (  
150.   \`user\_id\`,  
151.   \`user\_name\`,  
152.   \`upwd\`,  
153.   \`create\_time\`,  
154.   \`update\_time\`,  
155.   \`age\`,  
156.   \`sex\`  
157. )   
158. VALUES  
159.   (  
160.     @user\_id,  
161.     @user\_name,  
162.     @upwd,  
163.     @create\_time,  
164.     @update\_time,  
165.     @age,  
166.     @sex  
167.   ) ;";  
168.             **using** (IDbConnection conn = GetSqlConnection())  
169.             \{  
170.                 var n = conn.Execute(sql, user);  
171.                 Assert.IsTrue(n == 1);  
172.             \}  
173.         \}  
174.   
175.         /// <summary>  
176.         /// 执行"返回数据集"的存储过程  
177.         /// </summary>  
178.         \[TestMethod\]  
179.         **public** **void** TestCallp\_getuserinfo()  
180.         \{  
181.             \#region mysql 存储过程脚本  
182.             /\* 
183. DELIMITER $$ 
184. CREATE 
185.     PROCEDURE \`test\`.\`p\_getUserInfo\`( 
186.         \_userid INT 
187.     ) 
188.     BEGIN 
189.         SET @uid = \_userid; 
190.         SET @sql = CONCAT('select \* from user\_info where user\_id=',@uid ); 
191.         IF(@uid<=0) THEN 
192.             SET  @sql = 'select \* from user\_info'; 
193.         END IF; 
194.         PREPARE strsql FROM @sql;\#定义预处理语句  
195.         EXECUTE strsql;  
196.         DEALLOCATE PREPARE strsql;  \#删除定义  
197.     END$$ 
198. DELIMITER ; 
199.              \*/  
200.             \#endregion  
201.             var sql = "p\_getuserinfo";  
202.             **using** (IDbConnection conn = GetSqlConnection())  
203.             \{  
204.                 var list = conn.Query<user\_infoModel>(sql,  
205.                      **new**  
206.                      \{  
207.                          \_userid = 0 //查询多个  
208.                      \},   
209.                     **null**,   
210.                     **true**,  
211.                     **null**,  
212.                     CommandType.StoredProcedure).ToList();  
213.                 Assert.IsTrue(list!=**null**);  
214.             \}  
215.         \}  
216.           
217.         /// <summary>  
218.         /// 执行“带有输入输出参数”的存储过程  
219.         /// </summary>  
220.         \[TestMethod\]  
221.         **public** **void** TestCallp\_getUserCount()  
222.         \{  
223.             \#region mysql 存储过程脚本  
224.             /\* 
225. DELIMITER $$ 
226.  
227. CREATE PROCEDURE \`p\_getUserCount\`( 
228.  \_sex CHAR, 
229.  OUT \_total INT) 
230. BEGIN 
231.     SET @sex = \_sex; 
232.     SELECT COUNT(\*) INTO \_total FROM user\_info WHERE sex=@sex;   
233. END$$ 
234.  
235. DELIMITER ; 
236.              \*/  
237.             \#endregion  
238.             var sql = "p\_getUserCount";  
239.             DynamicParameters pars = **new** DynamicParameters();  
240.             pars.Add("\_sex", "女");  
241.             pars.Add("\_total", "", DbType.Int32, ParameterDirection.Output);  
242.             **using** (IDbConnection conn = GetSqlConnection())  
243.             \{  
244.                 var n = conn.Execute(sql,  
245.                     pars,  
246.                     **null**,  
247.                     **null**,  
248.                     CommandType.StoredProcedure);  
249.                 var total = pars.Get<Int32>("\_total");  
250.                 Assert.IsTrue(total > 0);  
251.             \}  
252.         \}  
253.         \[TestMethod\]  
254.         **public** **void** TestTransaction()  
255.         \{  
256.             **using** (IDbConnection conn = GetSqlConnection())  
257.             \{  
258.                 conn.Open();  
259.                 //开始事务  
260.                 var transaction = conn.BeginTransaction();  
261.                 **try**  
262.                 \{  
263.                     var order = **new** order\_infoModel()  
264.                     \{  
265.                         amount = 100,  
266.                         create\_time = DateTime.Now,  
267.                         goods\_count = 3,  
268.                         order\_code = "20160608001",  
269.                         user\_id = 2,  
270.                     \};  
271.                     var item = **new** order\_itemModel()  
272.                     \{  
273.                         amount = 100,  
274.                         create\_time = DateTime.Now,  
275.                         goods\_count = 3,  
276.                         goods\_name = "001",  
277.                         order\_id = 2,  
278.                         unit\_price = 99.99M,  
279.                         update\_time = DateTime.Now  
280.                     \};  
281.                     var sql = @"  
282. INSERT INTO \`order\_info\` (  
283.   \`user\_id\`,  
284.   \`order\_code\`,  
285.   \`amount\`,  
286.   \`create\_time\`,  
287.   \`goods\_count\`  
288. )   
289. VALUES  
290.   (  
291.     @user\_id,  
292.     @order\_code,  
293.     @amount,  
294.     @create\_time,  
295.     @goods\_count  
296.   ) ;";  
297.                     **int** n = conn.Execute(sql, order, transaction);  
298.                     Assert.IsTrue(n == 1);  
299.                     **if** (n != 1)  
300.                     \{  
301.                         transaction.Rollback();  
302.                         **return**;  
303.                     \}  
304.                     sql = @"  
305. INSERT INTO \`order\_item\` (  
306.   \`order\_id\`,  
307.   \`goods\_name\`,  
308.   \`unit\_price\`,  
309.   \`goods\_count\`,  
310.   \`amount\`,  
311.   \`create\_time\`,  
312.   \`update\_time\`  
313. )   
314. VALUES  
315.   (  
316.     @order\_id,  
317.     @goods\_name,  
318.     @unit\_price,  
319.     @goods\_count,  
320.     @amount,  
321.     @create\_time,  
322.     @update\_time  
323.   ) ;";  
324.                     n = conn.Execute(sql, item, transaction);  
325.                     Assert.IsTrue(n == 1);  
326.                     **if** (n != 1)  
327.                     \{  
328.                         transaction.Rollback();  
329.                         **return**;  
330.                     \}  
331.                     //提交事务  
332.                     transaction.Commit();  
333.                 \}  
334.                 **catch** (Exception ex)  
335.                 \{  
336.                     //出现异常，事务Rollback  
337.                     transaction.Rollback();  
338.                 \}  
339.             \}  
340.         \}  
341.     \}  
342. \}

[.NET]: http://lib.csdn.net/base/dotnet
[Link 1]: http://lib.csdn.net/base/mysql
[Link 2]: http://lib.csdn.net/base/softwaretest
[view plain]: http://blog.csdn.net/xxj_jing/article/details/51612332#
[CODE]: https://code.csdn.net/assets/CODE_ico.png
[CODE_CODE]: https://code.csdn.net/snippets/1711554
[ico_fork.svg]: https://code.csdn.net/assets/ico_fork.svg
[ico_fork.svg 1]: https://code.csdn.net/snippets/1711554/fork