輕量級ORM框架——第二篇:Dapper中的一些複雜操作和inner join應該註意的坑

来源:http://www.cnblogs.com/huangxincheng/archive/2016/09/02/5832281.html
-Advertisement-
Play Games

上一篇博文中我們快速的介紹了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是不是就這麼簡單,先就說到這裡,希望對大家有幫助。

 


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 開始使用 LINQ 在此之前曾發表過三篇關於 LINQ 的隨筆: 進階:《LINQ 標準查詢操作概述》(強烈推薦) 技巧:《Linq To Objects - 如何操作字元串》 和 《Linq To Objects - 如何操作文件目錄》 現在,自己打算再整理一篇關於 LINQ 入門的隨筆。 序 語 ...
  • 第一次在博客園發表文章,不多說,先上系統截圖。此系統是自己全程參與項目過程,從前期的技術方案整理到整個項目驗收,具體功能代碼實現,後續發表。 1、登錄: 2、客戶端主頁面 3、系統-切換機組伺服器 4、系統-配置伺服器 5、系統-數據下載 6、系統-更換皮膚 7、基礎數據-承包商檢驗人員 8、基礎數 ...
  • 字元串必須是數字,不要超過轉換成目標數字類型的範圍。超過的話系統也會報錯(溢出)。 static void Main(string[] args) { string s; int i; Console.WriteLine("please enter a number"); s = Console.R ...
  • 系統代碼是平臺內置的、通用的、統一的數據描述。代碼管理(數據字典)是整個平臺中數據描述的有效機制。通過界面進行可視化的操作和維護,能快速錄入和修改平臺上統一的字典數據。有效提高了數據的重覆利用率和產品、項目的開發效率。整個數據字典數據為框架平臺所共用,用戶可以更好地對系統進行自定義管理,以滿足自己的... ...
  • 一、項目背景: 最近,做項目,因為是金融項目,客戶登錄交易的時候,有一個提示框,就是告知客戶要“入市需謹慎”等等,想必大家都遇到這樣的場景,當然,這種提示是沒人會看的,不過作為交易所,這樣的提示又必不可少的。 其實只有一個要求: 必須客戶讀完“確定”按鈕和CheckBox才會生效 客戶只要把滾動條拉 ...
  • 刪除引用中的該dll,重新引用選擇解決方案下的項目引用,下次F12就不會進入到元數據而是進入到源代碼中方便調試 ...
  • 近來一直翻閱國內網站,發現擴展欄位的時候僅僅做到了可以註冊時候添加,並修改資料庫,但是後續的操作就沒有了,那麼列如我添加了昵稱欄位,怎麼顯示呢?不知是不是因為我剛入門的原因,一直沒有找不到方法,最後再國外論壇找到了方法。核心為下麵4句話,簡單記錄,晚上後續展開修改 指路地址 https://blog ...
  • 1. 利用“命名實參”,您將能夠為特定形參指定實參,方法是將實參與該形參的名稱關聯,而不是與形參在形參列表中的位置關聯。 static void Main(string[] args) { Console.WriteLine(CalculateBMI(weight: 123, height: 64) ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...