[Dapper].NET/C#程序开发中使用Dapper批量插入数据集合的方法应该如何实现?

.NET 作者: Rector 246阅读 0评论 0收藏 收藏本文

郑重申明:本文未经许可,禁止任何形式转载

问题描述

使用Dapper如何向数据库中批量插入数据或者说使用Dapper如何插入一个集合(List<T>),在没有使用Dapper(使用Ado.net)的情况下,我们通常的实现方式如下:

try
    {
        connection.Open();
            for (int i = 0; i < processList.Count; i++)
            {
                string processQuery = "INSERT INTO PROCESS_LOGS VALUES (@Id, @st_Time, @ed_Time, @td_Time)";
                command = new SqlCommand(processQuery, connection);
                command.Parameters.Add("Id", SqlDbType.Int).Value = processList[i].ID;
                command.Parameters.Add("st_Time", SqlDbType.DateTime).Value = processList[i].ST_TIME;
                command.Parameters.Add("ed_Time", SqlDbType.DateTime).Value = processList[i].ED_TIME;
                command.Parameters.Add("td_Time", SqlDbType.DateTime2).Value = processList[i].TD_TIME;
                dataReader.Close();
                dataReader = command.ExecuteReader();
            }
        connection.Close();
    }
catch (SqlException ex)
    {
        //--Handle Exception
    }

Dapper中,是否有一种方式,可以批量向数据库中写入一个数据集合,而不需要进行循环就可以完成,比如这样的:

connection.Execute(processQuery ... );

示例涉及到的实体类:

ProcessLog.cs

class ProcessLog
    {
        public int ID { get; set; }
        public DateTime ST_TIME { get; set; }
        public DateTime ED_TIME { get; set; }
        public DateTime TD_TIME { get; set; }
        public string frequency { get; set; }
    }

方案一

创建一个实体类:

public class MyObject
{
    public int A { get; set; }

    public string B { get; set; }
}

然后,循环调用DapperExecute方法:

foreach (var item in processList)
{
    string processQuery = "INSERT INTO PROCESS_LOGS VALUES (@A, @B)";
    connection.Execute(processQuery, item);
}

以上的参数@A,@B 需要与实体类的属性一一对应,如果不想重命名参数,你也可以这样:

foreach (var item in processList)
{
    string processQuery = "INSERT INTO PROCESS_LOGS VALUES (@A, @B)";
    connection.Execute(processQuery, new { A = item.A, B = item.B });
}

当然,以上实现只是常规的方式,你也可以使用Dapper的批量插入方法,在Execute(...)方法的第二个参数中传入集合即可,如:

string processQuery = "INSERT INTO PROCESS_LOGS VALUES (@A, @B)";
connection.Execute(processQuery, processList);

方案二

使用事务处理和执行集合参数:

SqlTransaction trans = connection.BeginTransaction();

connection.Execute(@"
insert PROCESS_LOGS(Id, st_Time, ed_Time, td_Time)
values(@Id, @st_Time, @ed_Time, @td_Time)", processList, transaction: trans);

trans.Commit();

阅读了该文章的人还浏览了...

本文永久链接图享网 » [Dapper].NET/C#程序开发中使用Dapper批量插入数据集合的方法应该如何实现?

发布于: 2018-02-03 17:44:57
分享扩散:

文章评论

获取验证码