批量插入到 SQL Server 2012 C# 中
本文关键字:2012 Server SQL 插入 | 更新日期: 2023-09-27 18:32:27
>我的列表中有大约一百万条记录。对于列表中的每个,我查询数据库以获取基于id的修改日期。一旦我得到它,它就会在插入或更新它的情况下进行测试..但是有没有办法批量(一次或批量)插入或更新..??
foreach (No_kemi no_list in newforSQL)
{
DateTime eModifiedDate = no_list.ModifiedDate.Value;
string Id = no_list.ID.ToString();
String selectQuery = "SELECT ModifiedDate FROM NO_table WHERE ID = '" + Id + "'";
DateTime? dbmoddate = null;
using (SqlCommand selectCommand = new SqlCommand(selectQuery, connection))
{
// Use the above SqlCommand object to create a SqlDataReader object.
using (SqlDataReader rdr = selectCommand.ExecuteReader())
{
while (rdr.Read())
{
dbmoddate = (DateTime)rdr["ModifiedDate"];
}
}
}
string eType = null;
string SubGUID = null;
string trimSubKey = no_list.SubscriberKey;
try
{
if ((trimSubKey.Length > 3) && (trimSubKey != ""))
{
if (trimSubKey.Contains(","))
{
string[] values = trimSubKey.Split(',');
SubGUID = values[0];
eType = values[1];
}
else
{
SubGUID = trimSubKey;
eType = "";
}
}
else
{
SubGUID = "";
eType = "";
}
}
catch (Exception ex)
{
logger.Error("Error : " + ex.Message );
}
if (dbmoddate == null)
{
DateTime no_listinsetdate = DateTime.Now;
String insertQuery = "INSERT INTO NO_table (CreatedDate, ModifiedDate, ID, eType, SubGUID, DbDate) VALUES (@CreatedDate, @ModifiedDate, @ID, @eType, @SubGUID, @DbDate,)";
using (SqlCommand insertCommand = new SqlCommand(insertQuery, connection))
{
insertCommand.Parameters.AddWithValue("@CreatedDate", no_list.CreatedDate);
insertCommand.Parameters.AddWithValue("@ModifiedDate", no_list.ModifiedDate);
insertCommand.Parameters.AddWithValue("@ID", no_list.ID);
insertCommand.Parameters.AddWithValue("@eType", eType);
insertCommand.Parameters.AddWithValue("@SubGUID", SubGUID);
insertCommand.Parameters.AddWithValue("@DbDate", no_listinsetdate);
insertCommand.ExecuteNonQuery(); // execute the query
}
}
else if (eModifiedDate > dbmoddate)
{
DateTime no_listinsetdate = DateTime.Now;
String updateQuery = "UPDATE NO_table SET CreatedDate = @CreatedDate, ModifiedDate = @ModifiedDate, ID = @ID, eType = @eType, SubGUID = @SubGUID, DbDate = @DbDate WHERE ID = '" + Id + "'";
using (SqlCommand updateCommand = new SqlCommand(updateQuery, connection))
{
updateCommand.Parameters.AddWithValue("@CreatedDate", no_list.CreatedDate);
updateCommand.Parameters.AddWithValue("@ModifiedDate", no_list.ModifiedDate);
updateCommand.Parameters.AddWithValue("@ID", no_list.ID);
updateCommand.Parameters.AddWithValue("@eType", eType);
updateCommand.Parameters.AddWithValue("@SubGUID", SubGUID);
updateCommand.Parameters.AddWithValue("@DbDate", no_listinsetdate);
updateCommand.ExecuteNonQuery(); // execute the query
}
}
}
任何加快过程的方法...完成操作需要花费大量时间...或者有时我收到超时错误...
感谢
这是在这里实际有一个编码解决方案的方法,但您应该能够根据一般建议自己创建一个:
如果您编写了一个执行此操作的 SQL 过程,则可能会节省大量网络往返。进一步的优化将导致此SQL过程获取成批的记录而不是单个记录,因此您可以发送1000条记录,该过程将循环访问它们,并为每个记录执行查询和结果更新/插入。这意味着结果不必在网络上来回传递,从而减少流量并缩短运行时间。
也许您的操作可以假定为单个 MERGE 命令,而不是查询和更新/插入。这取决于您的表结构、数据和意图。
谷歌术语:stored procedure
、table type
、MERGE
。