C#的dapper使用

Dapper是一款輕量級ORM工具（Github）。如果你在小的項目中，使用Entity Framework、NHibernate 來處理大數據訪問及關系映射，未免有點殺雞用牛刀。你又覺得ORM省時省力，這時Dapper 將是你不二的選擇。

為什么選擇Dapper

1. 輕量。只有一個文件（SqlMapper.cs），編譯完成之后只有120k(好象是變胖了)
2. 速度快。Dapper的速度接近與IDataReader，取列表的數據超過了DataTable。
3. 支持多種數據庫。Dapper可以在所有Ado.net Providers下工作，包括sqlite, sqlce, firebird, oracle, MySQL, PostgreSQL and SQL Server
4. 可以映射一對一，一對多，多對多等多種關系。
5. 性能高。通過Emit反射IDataReader的序列隊列，來快速的得到和產生對象，性能不錯。
6. 支持FrameWork2.0，3.0，3.5，4.0，4.5

Dapper的安裝

方法一：使用NuGet安裝
打開visual studio的項目，依次點擊工具，NuGet包管理器，管理解決方案的NuGet程序包； 

再點擊瀏覽，搜索dapper，點擊搜索結果中的Dapper，勾選項目，選擇安裝; 

在解決方案管理器中點擊項目，查看引用，如果有Dapper，說明安裝成功。 

 

方法二：直接在官網[2]下載源代碼，加入項目。這種方法哈希君沒有試，不過可以參考鏈接Dapper快速學習

 

Dapper的基本用法

插入操作

將一個對象person插入數據庫的方法如圖。 

插入代碼文本如下。@Name的意思是自動將person里的Name值綁定上去。

public static int Insert(Person person)
{
    using (IDbConnection connection = new SqlConnection(connectionString))
    {
        return connection.Execute("insert into Person(Name,Remark) values(@Name,@Remark)", person);
    }
}

批量插入：

/// <summary>
/// 批量插入Person數據，返回影響行數
/// </summary>
/// <param name="persons"></param>
/// <returns>影響行數</returns>
public static int Insert(List<Person> persons)
{
    using (IDbConnection connection = new SqlConnection(connectionString))
    {
        return connection.Execute("insert into Person(Name,Remark) values(@Name,@Remark)", persons);
    }
}

刪除操作

public static int Delete(Person person)
{
    using (IDbConnection connection = new SqlConnection(connectionString))
    {
        return connection.Execute("delete from Person where id=@ID", person);
    }
}

public static int Delete(List<Person> persons)
{
    using (IDbConnection connection = new SqlConnection(connectionString))
    {
        return connection.Execute("delete from Person where id=@ID", persons);
    }
}

修改操作

public static int Update(Person person)
{
    using (IDbConnection connection = new SqlConnection(connectionString))
    {
        return connection.Execute("update Person set name=@name where id=@ID", person);
    }
}

public static int Update(List<Person> persons)
{
    using (IDbConnection connection = new SqlConnection(connectionString))
    {
        return connection.Execute("update Person set name=@name where id=@ID", persons);
    }
}

查詢操作

/// <summary>
/// 無參查詢所有數據
/// </summary>
/// <returns></returns>
public static List<Person> Query()
{
    using (IDbConnection connection = new SqlConnection(connectionString))
    {
    return connection.Query<Person>("select * from Person").ToList();
    }
}

/// <summary>
/// 查詢指定數據
/// </summary>
/// <param name="person"></param>
/// <returns></returns>
public static Person Query(Person person)
{
    using (IDbConnection connection = new SqlConnection(connectionString))
    {
        return connection.Query<Person>("select * from Person where id=@ID",person).SingleOrDefault();
}
}

Dapper的復雜操作

查詢的In操作

/// <summary>
/// In操作
/// </summary>
public static List<Person> QueryIn()
{
    using (IDbConnection connection = new SqlConnection(connectionString))
    {
        var sql = "select * from Person where id in @ids";
        //參數類型是Array的時候，dappper會自動將其轉化
        return connection.Query<Person>(sql, new { ids = new int[2] { 1, 2 }, }).ToList();
    }
}

public static List<Person> QueryIn(int[] ids)
{
    using (IDbConnection connection = new SqlConnection(connectionString))
    {
        var sql = "select * from Person where id in @ids";
        //參數類型是Array的時候，dappper會自動將其轉化
        return connection.Query<Person>(sql, new { ids }).ToList();
    }
}

多語句操作

為此我們引入以下Book類，同樣在數據庫里設置這個表。

public class Book
{
    public int ID { get; set; }
    public int PersonID { get; set; }
    public string BookName { get; set; }
}

/// <summary>
/// 多語句操作
/// </summary>
public static void QueryMultiple()
{
    using (IDbConnection connection = new SqlConnection(connectionString))
    {
        var sql = "select * from Person; select * from Book";
        var multiReader = connection.QueryMultiple(sql);
        var personList = multiReader.Read<Person>();
        var bookList = multiReader.Read<Book>();
        multiReader.Dispose();
    }
}

Join操作

我們是面向對象編程，所以一個對象里面會有許多其他子對象，這個子對象里面又有其自己的子對象，這種關系在數據庫里的表示就是外鍵。
比如我們有一本書book，它有主人person，book是一個對象，主人又是一個對象。

public class BookWithPerson
{
    public int ID { get; set; }
    public Person Pers { get; set; }
    public string BookName { get; set; }
}

我們自然想要一個方法把數據庫里復雜的外鍵關系轉成我們需要的對象BookWithPerson，所有我們需要的信息都存在里面，取數據的時候只要找這個對象取數據就行了，比如我們需要一本書的主人的姓名，我們只需要bookWithPerson.Pers.Name。如果是一對多的關系我們用數組，如果是多對多我們加一層mapping。
現在我們想根據書的ID查詢書的信息，包括主人信息。那么

public static BookWithPerson QueryJoin(Book book)
{
    using (IDbConnection connection = new SqlConnection(connectionString))
    {
        var sql = @"select b.id,b.bookName,p.id,p.name,p.remark
                        from Person as p
                        join Book as b
                        on p.id = b.personId
                        where b.id = @id;";
        var result = connection.Query<BookWithPerson, Person, BookWithPerson>(sql,
        (bookWithPerson, person) =>
        {
            bookWithPerson.Pers = person;
            return bookWithPerson;
        },
        book);
    　　//splitOn: "bookName");
    　　return (BookWithPerson)result;
　　}
}

中，Query的三個泛型參數分別是 委托回調類型1， 委托回調類型2， 返回類型。形參的三個參數分別是 sql語句， map委托， 對象參數。所以整句的意思是先根據sql語句查詢；同時把查詢的person信息賦值給bookWithPerson.Pers，並且返回bookWithPerson；book是對象參數，提供參數綁定的值。
最終整個方法返回BookWithPerson，這樣我們所需要的所有信息就有了。

參考資料

---

1. Dapper快速學習 ↩

2. Dapper的git地址 ↩

3. Dapper，Net下無敵的ORM ↩

4. Dapper中的一些復雜操作 ↩

摘自於：https://www.jianshu.com/p/c4ca2989d26a