上一篇博文中我們快速的介紹了dapper的一些基本CURD操作,也是我們manipulate db不可或缺的最小單元,這一篇我們介紹下相對複雜 一點的操作,源碼分析暫時就不在這裡介紹了。 一:table sql 為了方便,這裡我們生成兩個表,一個Users,一個Product,sql如下: <1> ...
上一篇博文中我們快速的介紹了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是不是就這麼簡單,先就說到這裡,希望對大家有幫助。