服务器之家

服务器之家 > 正文

sql server中批量插入与更新两种解决方案分享(asp.net)

时间:2019-10-04 20:10     来源/作者:asp.net教程网

若只是需要大批量插入数据使用bcp是最好的,若同时需要插入、删除、更新建议使用SqlDataAdapter我测试过有很高的效率,一般情况下这两种就满足需求了 
bcp方式 

复制代码代码如下:


/// <summary> 
/// 大批量插入数据(2000每批次) 
/// 已采用整体事物控制 
/// </summary> 
/// <param name="connString">数据库链接字符串</param> 
/// <param name="tableName">数据库服务器上目标表名</param> 
/// <param name="dt">含有和目标数据库表结构完全一致(所包含的字段名完全一致即可)的DataTable</param> 
public static void BulkCopy(string connString, string tableName, DataTable dt) 

using (SqlConnection conn = new SqlConnection(connString)) 

conn.Open(); 
using (SqlTransaction transaction = conn.BeginTransaction()) 

using (SqlBulkCopy bulkCopy = new SqlBulkCopy(conn, SqlBulkCopyOptions.Default, transaction)) 

bulkCopy.BatchSize = 2000; 
bulkCopy.BulkCopyTimeout = _CommandTimeOut; 
bulkCopy.DestinationTableName = tableName; 
try 

foreach (DataColumn col in dt.Columns) 

bulkCopy.ColumnMappings.Add(col.ColumnName, col.ColumnName); 

bulkCopy.WriteToServer(dt); 
transaction.Commit(); 

catch (Exception ex) 

transaction.Rollback(); 
throw ex; 

finally 

conn.Close(); 





SqlDataAdapter 

复制代码代码如下:


/// <summary> 
/// 批量更新数据(每批次5000) 
/// </summary> 
/// <param name="connString">数据库链接字符串</param> 
/// <param name="table"></param> 
public static void Update(string connString, DataTable table) 

SqlConnection conn = new SqlConnection(connString); 
SqlCommand comm = conn.CreateCommand(); 
comm.CommandTimeout = _CommandTimeOut; 
comm.CommandType = CommandType.Text; 
SqlDataAdapter adapter = new SqlDataAdapter(comm); 
SqlCommandBuilder commandBulider = new SqlCommandBuilder(adapter); 
commandBulider.ConflictOption = ConflictOption.OverwriteChanges; 
try 

conn.Open(); 
//设置批量更新的每次处理条数 
adapter.UpdateBatchSize = 5000; 
adapter.SelectCommand.Transaction = conn.BeginTransaction();/////////////////开始事务 
if (table.ExtendedProperties["SQL"] != null) 

adapter.SelectCommand.CommandText = table.ExtendedProperties["SQL"].ToString(); 

adapter.Update(table); 
adapter.SelectCommand.Transaction.Commit();/////提交事务 

catch (Exception ex) 

if (adapter.SelectCommand != null && adapter.SelectCommand.Transaction != null) 

adapter.SelectCommand.Transaction.Rollback(); 

throw ex; 

finally 

conn.Close(); 
conn.Dispose(); 

相关文章

热门资讯

玄元剑仙肉身有什么用 玄元剑仙肉身境界等级划分
玄元剑仙肉身有什么用 玄元剑仙肉身境界等级划分 2019-06-21
华为nova5pro和p30pro哪个好 华为nova5pro和华为p30pro对比详情
华为nova5pro和p30pro哪个好 华为nova5pro和华为p30pro对比详情 2019-06-22
男生常说24816是什么意思?女生说13579是什么意思?
男生常说24816是什么意思?女生说13579是什么意思? 2019-09-17
抖音撒撒累累是什么歌 撒撒累累张艺兴歌曲名字
抖音撒撒累累是什么歌 撒撒累累张艺兴歌曲名字 2019-06-05
超A是什么意思 你好a表达的是什么
超A是什么意思 你好a表达的是什么 2019-06-06
返回顶部