使用Dapper处理多个结果集和多重映射的教程

在本文中，我们将介绍如何使用dapper从单个数据库调用中读取数据库中的多个结果集。我们将看看我们可能希望这样做的场景，以及如何使用它的query和querymultiple方法更简洁地实现这一点。 当我们谈论以数据为中心的应用程序时，可能会出现一些场景，在这些场景中我们可能希望从数据库中检索多重结果。多个结果集既可以是相关的，也可以是无关的。要做到这一点，我们不需要对数据库进行多次往返，而是可以在一次数据库调用本身中实际使用dapper检索结果，然后将结果映射到代码中的所需对象。 在我们继续并开始研究如何做到这一点之前，让我们首先试着理解在我们的应用程序中可能希望做到这一点的场景： 1、查询无关实体：所请求的实体根本不相关。 2、查询具有1至多个关系的相关实体：被请求的实体具有1对多的关系，我们需要在代码中处理多个结果集 3、查询具有1至1关系的相关实体：被请求的实体具有1-1关系，我们需要在代码中执行处理多个映射 在第一个场景中，我们有完全不相关的实体，因此基本上，我们只想执行两个独立的查询来检索数据，然后将其映射到这些实体。在第二个场景中，返回的实体与1-多相关，因此我们希望检索数据，然后将结果映射到具有1至多个关系的poco中。最后，在第三个场景中，返回的实体是1-1，因此我们希望检索数据，然后将结果映射到具有1-1关系的poco中。 现在让我们看看一些代码，了解如何使用dapper来实现这一切。 所有这些都可以通过dapper的查询、querymultiple和read方法进行归档。现在让我们把重点放在如何在代码中执行这些操作。

查询无关实体

假设我们想从api中检索书籍和视频列表。我们可以通过两个简单的选择所有查询来实现这一点，数据库结果看起来如下：

现在，为了能够从代码中执行同样的操作，我们首先需要定义我们的实体：

 1 public class book
 2 {
 3     public int id { get; set; }
 4     public string bookname { get; set;}
 5     public string isbn { get; set; }
 6 }
 7 
 8 public class video
 9 {
10     public int id { get; set; }
11     public string videoname { get; set; }
12 }

使用这些模型，让我们看看如何只使用一个数据库调用来使用dapper检索这些结果：

 1 public iactionresult index()
 2 {
 3     // define our sql query - it contains mulitple queries seprated by ;
 4     var query = "select * from books; select * from videos";
 5 
 6     // execute the query
 7     var results = dbconnection.querymultiple(query);
 8 
 9     // retrieve the results into the respective models
10     var books = results.read<book>();
11     var videos = results.read<video>();
12 
13     return ok(new { books = books, videos = videos});
14 }

现在让我们在postman中运行，以查看行动中的结果：

注意：我已经创建了一个简单的api控制器来测试这个代码，所有的db访问代码都在里面运行。这只是为了演示目的和现实世界的应用，这样的代码根本不应该被使用。

查询具有1到多关系的查询相关实体

 

 检索相关实体的另一个典型场景是实体之间存在一对多关系。让我们尝试使用组织和联系人的例子来可视化这一点。组织通常具有与其关联的多个联系人。如果我们想要检索一个组织，并且想要检索所有关联的联系人，我们可以利用querymultiple来做到这一点。这就是关系在数据库中的样子。

首先让我们检查一下如何使用sql查询做同样的操作。

现在，如果我们必须在代码中做同样的事情，我们首先需要定义我们的实体。请注意，我们的实体也将建模一对多关系的方式，每个组织有一个联系人列表。

public class organization
{
    public int id { get; set; }
    public string organizationname { get; set; }

    public list<contact> contacts { get; set; }
}

public class contact
{
    public int id { get; set; }
    public int organizationid { get; set; }
    public string contactname { get; set; }
}
</contact>

现在让我们看一下用于检索这些相关实体的代码，并了解如何用dapper的querymultiple方法填充与1到多个关系相关的实体。

[httpget("{id}")]
public iactionresult getorganization(int id)
{
    // define our sql query - it contains mulitple queries seprated by ;
    var query = @"select* from organizations where id = @id;
                select * from contacts where organizationid = @id";

    // execute the query
    var results = dbconnection.querymultiple(query, new { @id = id });

    // retrieve the results into the respective models
    var org = results.readsingle<organization>();
    org.contacts = results.read<contact>().tolist();

    return ok(org);
}

在上面的代码中，我们可以看到我们是如何同时执行2个查询的。我们接受了第一个查询结果并填充了我们的组织对象。第二个查询结果作为同一个组织对象的联系人集合被推送。

 现在让我们在postman中运行，以查看行动中的结果：

 

具有1到1关系的查询相关实体

前两个场景非常简单，因为它们要求我们编写两个独立的查询，然后独立收集每个查询的结果，以便根据需要创建模型对象。

 但是有1到1个关系的场景是很棘手的。从数据库的角度来看，我们可以在单个sql查询本身中检索相关实体，但是随后我们希望将单个结果集映射到代码中的多个对象中。这可以使用在dapper中可用的多重映射特征来完成。让我们在一个例子的帮助下理解这一点。

 注意：我们仍然可以使用与1到许多关系相同的方法来检索与1到1相关的数据，但是本节将展示如何使用单个sql并映射结果。

 让我们举一个联系和护照的例子。每个联系人只能有一个护照。让我们先想象一下这个数据库关系。

现在，让我们看看是否需要从数据库中检索联系人列表及其护照信息，我们如何用sql实现这一点。

现在让我们看看我们的实体如何寻找联系和护照。

public class contact
{
    public int id { get; set; }
    public int organizationid { get; set; }
    public string contactname { get; set; }

    public passport passport { get; set; }
}

public class passport
{
    public int id { get; set; }
    public int contactid { get; set; }
    public string passportnumber { get; set; }
}

现在让我们看看如何从数据库中检索这些相关实体，并使用更简洁的多重映射完整地填充具有相同关系的pocos。

[httpget("{id}")]
public iactionresult getcontact(int id)
{
    var query = @"select
                c.id, c.organizationid, c.contactname,
                p.id as passportid, p.contactid, p.passportnumber
                from contacts c,
                passports p
                where c.id = p.contactid
                and c.id = @id";

    // execute the query
    var contact = dbconnection.query<contact, passport, contact>(query, mapresults, new { @id = id }, spliton: "passportid");

    return ok(contact);
}

private contact mapresults(contact contact, passport passport)
{
    contact.passport = passport;
    return contact;
}

在上面的代码中，我们使用的是查询方法的重载版本，它采用多个类型。传递的类型是我们要映射的每个对象的类型参数，最后一个类型参数是表示该查询将返回的对象类型的附加参数。

 

因此，在我们的查询中，我们希望将结果映射到类型contact和passsport，然后期望结果返回到类型contact的对象中。

 

现在，让我们看看在查询方法中传递的实际参数。

 

第一个参数是sql查询本身。

第二个参数是映射函数，它将获取结果，将它绑定到相应的类型，然后创建所需的返回类型并返回该返回类型。在我们的代码中，它采用contact和passport类型，并将contact的passport属性指定为正在传递的passport值。一旦这样做，结果接触类型返回。

第三个参数是命令参数@ id。

最后一个参数拆分是将告诉dapper哪些列必须映射到下一个对象的列名。在我们的示例中，我们将此值作为passportid传递，这意味着在找到passportid列之前，所有列都将映射到第一种类型，即contact，然后随后的列将被映射到下一个参数类型，即passport。

注意：如果我们有2个以上的对象需要映射，spliton将是一个逗号分隔的列表，其中每个列名将充当分隔符，并开始下一个对象类型的映射列。

 

现在让我们在postman中运行，以查看行动中的结果：

欧了，我们使用dapper从数据库中检索多个结果集，以避免数据库往返。

 

总结：

在本文中，我们讨论了如何使用dapper提供的特性在一次运行中检索多个相关或无关的实体，从而避免多次数据库往返。这是从初学者的角度写的。我希望这有一定的信息性。