項目架構開發：數據訪問層之Query

接上文 項目架構開發：數據訪問層之Repository

 

上一章我們講了IRepository接口，這張我們來講IQuery

根據字面意思就可以知道，這次主要講數據查詢，上一章我們只針對單表做了查詢的操作，多表聯查並沒有實現

其實對於任何一個項目來說，多表聯查都是比較麻煩的地方，因為項目的“讀”操作，特別是多表的“讀”，至少占據所有“讀”的一半以上

然而至今，據我所知還沒有哪一款ORM工具可以靈活處理多表聯查；想要不寫sql語句，又想性能高，還想用強類型的ling查詢方法；這對於多表查詢來說比較難

鑒於此，也別做那些別扭的映射了（像NH），而如果用lingtosql我覺得還不如直接寫sql來的好；

是開發人員不可能不懂sql，那對多表查詢這一塊，干脆獨立一個Query類出來，專門處理這種事

 

好了這只是我的處理方式，我們來看看

IQuery.cs

    public interface IQuery
    {
        T QuerySingle<T>(string sql, object paramPairs) where T : class;
        IEnumerable<T> QueryList<T>(string sql, object paramPairs) where T : class;

        /// <summary>必須帶上row_number() over({0}) RowNumber</summary>
        Tuple<int, IEnumerable<T>> GetPage<T>(Page page, string sql, dynamic paramPairs = null) where T : class;
        
        Tuple<int, IEnumerable<T>> GetPage<T>(string sql, object paramPairs = null) where T : class;
        int Execute(string sql, dynamic paramPairs = null);
        long Count(string sql, dynamic paramPairs = null);
    }

 

上方法名就可以知道，寫sql，然后返回自定義的T或IEnumerable<T>

這里避免了用泛型類，因為某個實體大多數情況下可能也只是需要，上邊其中其中的1、2個而已

這里有一個Execute方法，其實不應該放在這的，但是也懶得寫另外一個類了，先放着吧

 

Query的實現

 

DapperQuery.cs

using Dapper;
using Dapper.Contrib.Extensions;
using LjrFramework.Common;
using LjrFramework.Interface;
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;

namespace LjrFramework.Data.Dapper
{
    public class DapperQuery : IQuery
    {
        protected IDbConnection Conn { get; private set; }

        public DapperQuery()
        {
            Conn = DbConnectionFactory.CreateDbConnection();
        }

        public void SetDbConnection(IDbConnection conn)
        {
            Conn = conn;
        }

        public T QuerySingle<T>(string sql, object paramPairs) where T : class
        {
            return Conn.Query<T>(sql, paramPairs).SingleOrDefault();
        }

        public IEnumerable<T> QueryList<T>(string sql, object paramPairs) where T : class
        {
            return Conn.Query<T>(sql, paramPairs);
        }

        /// <summary>自動分頁，必須帶上row_number() over({0}) RowNumber</summary>
        public Tuple<int, IEnumerable<T>> GetPage<T>(Page page, string sql, object paramPairs = null) where T : class
        {
            var multi = Conn.GetPage<T>(page.PageIndex, page.PageSize, sql, paramPairs);
            var count = multi.Read<int>().Single();
            var results = multi.Read<T>();
            return new Tuple<int, IEnumerable<T>>(count, results);
        }
        // 需自己實現分頁語句
        public Tuple<int, IEnumerable<T>> GetPage<T>(string sql, object paramPairs = null) where T : class
        {
            var multi = Conn.GetGridReader<T>(sql, paramPairs);
            var count = multi.Read<int>().Single();
            var results = multi.Read<T>();
            return new Tuple<int, IEnumerable<T>>(count, results);
        }


        public int Execute(string sql, object paramPairs = null)
        {
            return Conn.Execute(sql, paramPairs);
        }

        public long Count(string sql, object paramPairs = null)
        {
            return Conn.Query<long>(sql, paramPairs).SingleOrDefault();
        }
    }
}

 

這個實現跟上一章差不多，都是直接調用Conn的擴展方法，

我們進去看看（public Tuple<int, IEnumerable<T>> GetPage<T>(string sql, object paramPairs = null) where T : class）的實現

 

可以看到dapper是已經支持sql語句的查詢，並且返回多個記錄（SqlMapper.GridReader）

 

每次分頁都要去手動刷選 頁數 與 記錄開始行數的話比較麻煩

所有我做了一點小改動，武學用戶寫分頁語句，直接查詢就可以了，后台會自動生成分頁語句的格式

不過要帶上row_number() over({0}) RowNumber；就是上邊那個有注釋的方法

他的實現如下

 

這樣用戶只需要准守一點約束，就會方便很多

這些都是在dapper的Extensions里實現的，用戶需要自行修改，自己想要的自定義的功能

好了，Query有效代碼寫完了，我們看看運行效果

 

Query測試

using Autofac;
using Company.Project.PO;
using LjrFramework.Data.Dapper;
using LjrFramework.Common;
using LjrFramework.Infrastructure;
using LjrFramework.Interface;
using Microsoft.VisualStudio.TestTools.UnitTesting;
using System;
using LjrFramework.Data.UnitOfWork;

namespace LjrFramework.UnitTest
{
    [TestClass]
    public class QueryTest
    {
        private IQuery query;

        public QueryTest()
        {
            var builder = new ContainerBuilder();
            builder.RegisterType<DapperQuery>().As<IQuery>();

            var container = builder.Build();
            query = container.Resolve<IQuery>();

        }

        [TestMethod]
        public void QuerySingle()
        {
            var model = query.QuerySingle<LoginUser>("select * from LoginUser where Id = @Id", new { Id = "854B1FCA-F8D7-4B4B-AA5D-9075F1922721" });

            Assert.AreEqual(model.LoginName, "lanxiaoke-d318fd40-1b9d-42f8-a002-388b1228012d");
        }

        [TestMethod]
        public void QueryList()
        {
            var list = query.QueryList<LoginUser>("select * from LoginUser where LoginName like '%'+ @LoginName + '%'", new { LoginName = "lanxiaoke" });

            int index = 0;
            foreach (var user in list)
            {
                index++;
            }

            Assert.AreEqual(index > 0, true);
        }

        [TestMethod]
        public void GetPage()
        {
            var page = new Page()
            {
                PageIndex = 1,
                PageSize = 10
            };

            var results = query.GetPage<LoginUser>(page,
                @"select row_number() over(order by CreateTime) RowNumber,* from LoginUser where LoginName like '%'+ @LoginName + '%'", new { LoginName = "lanxiaoke" });

            var total = results.Item1;
            var list = results.Item2;

            int index = 0;
            foreach (var user in list)
            {
                index++;
            }

            Assert.AreEqual(index > 0, true);
        }

        [TestMethod]
        public void GetPage2()
        {
            var page = new Page()
            {
                PageIndex = 1,
                PageSize = 10
            };

            var results = query.GetPage<LoginUser>(
                @"select count(*) as TotalCount from LoginUser c where LoginName like '%'+ @LoginName + '%'
                  select row_number() over(order by CreateTime) RowNumber,* from LoginUser where LoginName like '%'+ @LoginName + '%'",
            new { LoginName = "lanxiaoke" });

            var total = results.Item1;
            var list = results.Item2;

            int index = 0;
            foreach (var user in list)
            {
                index++;
            }

            Assert.AreEqual(index > 0, true);
        }

        [TestMethod]
        public void Count()
        {
            var row = query.Count("select count(*) from LoginUser");

            Assert.AreEqual(row > 1, true);
        }

    }
}

自此，多表查詢就講完了

 

項目架構開發系列

• 項目架構開發：數據訪問層之Cache
• 項目架構開發：數據訪問層之Logger
• 項目架構開發：數據訪問層之Repository
• 項目架構開發：數據訪問層之Query
• 項目架構開發：數據訪問層之UnitOfWork