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

sql server中批量插入与更新两种解决方案分享(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();

}

}
您可能感兴趣的文章:

  • C#.NET中如何批量插入大量数据到数据库中
  • C#/.Net 中快速批量给SQLite数据库插入测试数据
  • Asp.Net使用Bulk实现批量插入数据
  • .NET多种数据库大数据批量插入、更新(支持SqlServer、MySql、PgSql和Oracle)

本文由 华域联盟 原创撰写:华域联盟 » sql server中批量插入与更新两种解决方案分享(asp.net)

转载请保留出处和原文链接:https://www.cnhackhy.com/43751.htm

本文来自网络,不代表华域联盟立场,转载请注明出处。

作者: sterben

发表回复

联系我们

联系我们

2551209778

在线咨询: QQ交谈

邮箱: [email protected]

工作时间:周一至周五,9:00-17:30,节假日休息

关注微信
微信扫一扫关注我们

微信扫一扫关注我们

关注微博
返回顶部