Dapper如何操作MSSQL批量新增或更新|极客教程

Dapper如何操作MSSQL批量新增或更新

简介

Dapper是一个.NET的微ORM，具有高效、轻量级和易用的特点。在实际项目中，我们经常会遇到需要批量新增或更新数据的场景，本文将详细介绍如何使用Dapper操作MSSQL数据库实现批量新增或更新功能。

环境准备

在开始之前，我们需要先安装Dapper和Dapper.Contrib这两个NuGet包。可以在NuGet包管理器中搜索“Dapper”和“Dapper.Contrib”进行安装。

批量新增数据

首先，我们来看一下如何使用Dapper实现批量新增数据的功能。假设我们有一个名为Product的实体类，包含Id、Name和Price三个属性。

public class Product
{
    public int Id { get; set; }
    public string Name { get; set; }
    public decimal Price { get; set; }
}

现在我们要批量新增多个产品信息，可以通过以下代码实现：

var products = new List<Product>
{
    new Product { Name = "Product A", Price = 100 },
    new Product { Name = "Product B", Price = 200 },
    new Product { Name = "Product C", Price = 300 }
};

using (var conn = new SqlConnection(connectionString))
{
    conn.Open();

    var sql = "INSERT INTO Product (Name, Price) VALUES (@Name, @Price)";
    conn.Execute(sql, products);
}

在上述代码中，我们首先创建了一个包含多个产品信息的products列表，然后通过Dapper的Execute方法执行SQL语句，实现了批量新增数据的功能。

批量更新数据

接下来，我们来看一下如何使用Dapper实现批量更新数据的功能。假设我们需要根据产品名称更新产品价格，可以通过以下代码实现：

var products = new List<Product>
{
    new Product { Name = "Product A", Price = 150 },
    new Product { Name = "Product B", Price = 250 },
    new Product { Name = "Product C", Price = 350 }
};

using (var conn = new SqlConnection(connectionString))
{
    conn.Open();

    var sql = "UPDATE Product SET Price = @Price WHERE Name = @Name";
    conn.Execute(sql, products);
}

在上述代码中，我们同样创建了一个包含多个产品信息的products列表，然后通过Dapper的Execute方法执行SQL语句，实现了批量更新数据的功能。

批量新增或更新数据

有时候我们需要根据数据库中已有的数据判断是新增还是更新，这时可以使用Dapper的Insert和Update方法实现批量新增或更新数据的功能。下面对这个操作进行详细说明。

准备工作

首先，我们需要在实体类上添加Key和Table特性，用于指定主键和表名。

[Table("Product")]
public class Product
{
    [Key]
    public int Id { get; set; }
    public string Name { get; set; }
    public decimal Price { get; set; }
}

批量新增或更新数据

接下来，我们可以通过以下代码实现批量新增或更新数据的功能。

var products = new List<Product>
{
    new Product { Name = "Product A", Price = 150 },
    new Product { Name = "Product B", Price = 250 },
    new Product { Name = "Product C", Price = 350 }
};

using (var conn = new SqlConnection(connectionString))
{
    conn.Open();

    conn.Insert(products);
}