輕量級(jí)ORM框架——第二篇：Dapper中的一些復(fù)雜操作和inner join應(yīng)該注意的坑

2019-11-11 05:02:30

字體：大中小

來源：轉(zhuǎn)載

供稿：網(wǎng)友

上一篇博文中我們快速的介紹了dapper的一些基本CURD操作，也是我們manipulate db不可或缺的最小單元，這一篇我們介紹下相對(duì)復(fù)雜

一點(diǎn)的操作，源碼分析暫時(shí)就不在這里介紹了。

一：table sql

為了方便，這里我們生成兩個(gè)表，一個(gè)Users，一個(gè)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操作
      很多時(shí)候我們?cè)趍anipulate table的時(shí)候，或多或少的都會(huì)用到 ”in關(guān)鍵字”，比如:我要找到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" } });        }
看了上面的操作，是不是很簡(jiǎn)單，只要我們的參數(shù)類型是Array的時(shí)候，dappper會(huì)自動(dòng)將其轉(zhuǎn)化。。。
 
三：多條sql一起執(zhí)行
     有時(shí)候我們會(huì)想在一條sql中灌入很多的snippet sql，然后讓其一起執(zhí)行，此時(shí)讓我想起了一個(gè)操作，我會(huì)在db中l(wèi)oad data的時(shí)候會(huì)寫到
select ... from marketing where  id in (....); select .... from eventmarketing where in (...)類似這樣的語句，然后進(jìn)行結(jié)果合并，這篇
為了方便演示，在User上做一個(gè)*操作，在Product上做一個(gè)* 操作，比如下面這樣：
 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寫的多么好或者多么爛，接觸一個(gè)月還是接觸到十年，都必然跑不了多表查詢，那么在多表查詢上dapper該如何使用呢？？？比如
說我要找到2015-12-12之后的商品信息和個(gè)人信息，很顯然這是一個(gè)多表查詢，可以先來看一下users和product的關(guān)系。
可以發(fā)現(xiàn)其實(shí)他們有一個(gè)外鍵關(guān)系，然后我們?cè)赑roduct Entity上做一下小修改，將Users作為Product的一個(gè)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; }    } 
有了這些儲(chǔ)備，我們大概就可以寫出如下的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;                                    });        } 
結(jié)果就是”操?。。?！“。。。。。。。。。。。。
 
從錯(cuò)誤信息中可以看到：當(dāng)你使用multi-mapping的時(shí)候要確保設(shè)置了splitOn參數(shù)，除了Id。。。從這句話中好像也看不出什么名堂，也就是說
除了Id，你都需要設(shè)置SplitOn參數(shù)，好吧，這是逼著哥哥看源代碼。。。?？纯碨plitOn到底是個(gè)什么樣的鳥玩法。。。然后我從Call Stack往上
面找，發(fā)現(xiàn)了非?！敝陵P(guān)重要“的一段話。
 
    然來splitOn就是Dapper對(duì)DataReader進(jìn)行”從右到左“的掃描，這樣就可以從sequent中獲取到一個(gè)subsequent，然后遇到設(shè)置的splitOn
就停止。。。然來是這樣，哈哈。。。這回我就知道了，將splitOn設(shè)置為”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");        }
 
當(dāng)然如果你覺得我上面說的太啰嗦了，注意事項(xiàng)還tmd的多，又是泛型，又是Lambda的。。。你也可以不指定這些具體Type，而默認(rèn)使用
dynamic也是可以的，比如下面這樣：
 
五：支持存儲(chǔ)過程
   對(duì)于存儲(chǔ)過程，也是一個(gè)不得不說的話題，我們的dapper同樣也是可以執(zhí)行的，只需要在Query中的CommandType中標(biāo)記一下當(dāng)前就是一個(gè)
StoredProcedure就八九不離十了，比如現(xiàn)在在Users表上創(chuàng)建一個(gè)簡(jiǎn)單的StoredProcedure。
USE [Datamip]GO/****** Object:  StoredProcedure [dbo].[sp_GetUsers]    Script Date: 09/02/2016 09:14:04 ******/SET ANSI_NULLS ONGOSET QUOTED_IDENTIFIER ONGOCreate proc [dbo].[sp_GetUsers]   @id int   as  begin   select * from Users where UserID = @id ;   end  
在這里，我們需要向存儲(chǔ)過程塞入一個(gè)@id參數(shù)，返回具體的Users EntityList，好了，下面再看一下Query如何構(gòu)造。
  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是不是就這么簡(jiǎn)單，先就說到這里，希望對(duì)大家有幫助。
原文 http://www.cnblogs.com/huangxincheng/p/5832281.html