问题描述

使用Dapper如何向数据库中批量插入数据或者说使用Dapper如何插入一个集合(List)，在没有使用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; }

}

然后，循环调用Dapper的Execute方法：

foreach (var item in processList)

{

string processQuery = "INSERT INTO PROCESS_LOGS VALUES (@A, @B)";

connection.Execute(processQuery, item);

}以上的参数

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();