第二篇:Dapper中的一些复杂操作和inner join应该注意的坑
上一篇博文中我們快速的介紹了dapper的一些基本CURD操作,也是我們manipulate db不可或缺的最小單元,這一篇我們介紹下相對復雜
一點的操作,源碼分析暫時就不在這里介紹了。?
一:table sql
? ? 為了方便,這里我們生成兩個表,一個Users,一個Product,sql如下:
<1> Users table
CREATE TABLE [dbo].[Users](
? ? [UserID] [int] IDENTITY(1,1) NOT NULL,
? ? [UserName] [varchar](50) NULL,
? ? [Email] [varchar](100) NULL,
? ? [Address] [varchar](100) NULL,
?CONSTRAINT [PK_Users] PRIMARY KEY CLUSTERED?
(
? ? [UserID] ASC
)WITH (PAD_INDEX ?= OFF, STATISTICS_NORECOMPUTE ?= OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS ?= ON, ALLOW_PAGE_LOCKS ?= ON) ON [PRIMARY]
) ON [PRIMARY]
<2> Product table
CREATE TABLE [dbo].[Product](
? ? [ProductID] [int] IDENTITY(1,1) NOT NULL,
? ? [ProductName] [varchar](220) NULL,
? ? [ProductDesc] [varchar](220) NULL,
? ? [UserID] [int] NULL,
? ? [CreateTime] [datetime] NULL,
?CONSTRAINT [PK_Product] PRIMARY KEY CLUSTERED?
(
? ? [ProductID] ASC
)WITH (PAD_INDEX ?= OFF, STATISTICS_NORECOMPUTE ?= OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS ?= ON, ALLOW_PAGE_LOCKS ?= ON) ON [PRIMARY]
) ON [PRIMARY]
二:in操作
? ? ? 很多時候我們在manipulate table的時候,或多或少的都會用到 ”in關鍵字”,比如:我要找到User表中Email in ('5qq.com','8qq.com')的
Users record。。。
static void Main(string[] args)
? ? ? ? {
? ? ? ? ? ? var connection = new SqlConnection("Data Source=.;Initial Catalog=Datamip;Integrated Security=True;MultipleActiveResultSets=True");
? ? ? ? ? ? var sql = "select * from Users where Email in @emails";
? ? ? ? ? ? var info = connection.Query<Users>(sql, new { emails = new string[2] { "5qq.com", "7qq.com" } });
? ? ? ? }
看了上面的操作,是不是很簡單,只要我們的參數類型是Array的時候,dappper會自動將其轉化。。。
?
三:多條sql一起執行
? ? ?有時候我們會想在一條sql中灌入很多的snippet sql,然后讓其一起執行,此時讓我想起了一個操作,我會在db中load data的時候會寫到
select ... from marketing where ?id in (....); select .... from eventmarketing where in (...)類似這樣的語句,然后進行結果合并,這篇
為了方便演示,在User上做一個*操作,在Product上做一個* 操作,比如下面這樣:
static void Main(string[] args)
? ? ? ? {
? ? ? ? ? ? var connection = new SqlConnection("Data Source=.;Initial Catalog=Datamip;Integrated Security=True;MultipleActiveResultSets=True");
? ? ? ? ? ? var sql = "select * from Product; select * from Users";
? ? ? ? ? ? var multiReader = connection.QueryMultiple(sql);
? ? ? ? ? ? var productList = multiReader.Read<Product>();
? ? ? ? ? ? var userList = multiReader.Read<Users>();
? ? ? ? ? ? multiReader.Dispose();
? ? ? ? }
?
四:多表join操作
? ? ?不管sql寫的多么好或者多么爛,接觸一個月還是接觸到十年,都必然跑不了多表查詢,那么在多表查詢上dapper該如何使用呢???比如
說我要找到2015-12-12之后的商品信息和個人信息,很顯然這是一個多表查詢,可以先來看一下users和product的關系。
可以發現其實他們有一個外鍵關系,然后我們在Product Entity上做一下小修改,將Users作為Product的一個entity property。。。
public class Product
? ? {
? ? ? ? public int ProductID { get; set; }
? ? ? ? public string ProductName { get; set; }
? ? ? ? public string ProductDesc { get; set; }
? ? ? ? public Users UserOwner { get; set; }
? ? ? ? public string CreateTime { get; set; }
? ? }
有了這些儲備,我們大概就可以寫出如下的sql。
static void Main(string[] args)
? ? ? ? {
? ? ? ? ? ? var connection = new SqlConnection("Data Source=.;Initial Catalog=Datamip;Integrated Security=True;MultipleActiveResultSets=True");
? ? ? ? ? ? var sql = @"select ?p.ProductName,p.CreateTime,u.UserName
? ? ? ? ? ? ? ? ? ? ? ? from Product as p
? ? ? ? ? ? ? ? ? ? ? ? join Users as u
? ? ? ? ? ? ? ? ? ? ? ? on p.UserID = u.UserID
? ? ? ? ? ? ? ? ? ? ? ? where p.CreateTime > '2015-12-12'; ";
? ? ? ? ? ? var result = connection.Query<Product, Users, Product>(sql,
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? (product, users) =>
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? product.UserOwner = users; return product;
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? });
? ? ? ? }
?
從錯誤信息中可以看到:當你使用multi-mapping的時候要確保設置了splitOn參數,除了Id。。。從這句話中好像也看不出什么名堂,也就是說
除了Id,你都需要設置SplitOn參數,好吧,這是逼著哥哥看源代碼。。。。看看SplitOn到底是個什么樣的鳥玩法。。。然后我從Call Stack往上
面找,發現了非常”至關重要“的一段話。
?
? ? 然來splitOn就是Dapper對DataReader進行”從右到左“的掃描,這樣就可以從sequent中獲取到一個subsequent,然后遇到設置的splitOn
就停止。。。然來是這樣,哈哈。。。這回我就知道了,將splitOn設置為”userName“就好了。。。比如
static void Main(string[] args)
? ? ? ? {
? ? ? ? ? ? var connection = new SqlConnection("Data Source=.;Initial Catalog=Datamip;Integrated Security=True;MultipleActiveResultSets=True");
? ? ? ? ? ? var sql = @"select ?p.ProductName,p.CreateTime,u.UserName
? ? ? ? ? ? ? ? ? ? ? ? from Product as p
? ? ? ? ? ? ? ? ? ? ? ? join Users as u
? ? ? ? ? ? ? ? ? ? ? ? on p.UserID = u.UserID
? ? ? ? ? ? ? ? ? ? ? ? where p.CreateTime > '2015-12-12'; ";
? ? ? ? ? ? var result = connection.Query<Product, Users, Product>(sql,
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? (product, users) =>
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? product.UserOwner = users; return product;
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? },splitOn: "UserName");
? ? ? ? }
?
當然如果你覺得我上面說的太啰嗦了,注意事項還tmd的多,又是泛型,又是Lambda的。。。你也可以不指定這些具體Type,而默認使用
dynamic也是可以的,比如下面這樣:
?
五:支持存儲過程
? ?對于存儲過程,也是一個不得不說的話題,我們的dapper同樣也是可以執行的,只需要在Query中的CommandType中標記一下當前就是一個
StoredProcedure就八九不離十了,比如現在在Users表上創建一個簡單的StoredProcedure。
USE [Datamip]
GO
/****** Object: ?StoredProcedure [dbo].[sp_GetUsers] ? ?Script Date: 09/02/2016 09:14:04 ******/
SET ANSI_NULLS ON
GO
SET QUOTED_IDENTIFIER ON
GO
Create proc [dbo].[sp_GetUsers] ?
?@id int ??
as ?
begin ??
select * from Users where UserID = @id ; ??
end
在這里,我們需要向存儲過程塞入一個@id參數,返回具體的Users EntityList,好了,下面再看一下Query如何構造。
static void Main(string[] args)
? ? ? ? {
? ? ? ? ? ? var connection = new SqlConnection("Data Source=.;Initial Catalog=Datamip;Integrated Security=True;MultipleActiveResultSets=True");
? ? ? ? ? ? var info = connection.Query<Users>("sp_GetUsers", new { id = 5 },
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?commandType: CommandType.StoredProcedure);
? ? ? ? }
?
搞定,感覺用Dapper是不是就這么簡單,先就說到這里,希望對大家有幫助。
相關文章
Net下無敵的Micro ORM — Dapper
.NET Core 使用Dapper 操作MySQL
Dapper、Entity Framework 和混合應用
第一篇:Dapper快速學習
原文地址:http://www.cnblogs.com/huangxincheng/p/5832281.html
.NET社區新聞,深度好文,微信中搜索dotNET跨平臺或掃描二維碼關注
總結
以上是生活随笔為你收集整理的第二篇:Dapper中的一些复杂操作和inner join应该注意的坑的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: 如何在 ASP.NET MVC 中集成
- 下一篇: Visual Studio “15”的第