c# 批量操作
2015-11-18 16:33
537 查看
/// <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();
}
}
}
}
}
/// <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();
}
}
批量修改方法二:
public void BatchUpdate(List<Card> list)
{
using (SqlConnection conn = new SqlConnection(DbHelperSQL.connectionString))
{
conn.Open();
using (SqlDataAdapter da = new SqlDataAdapter())
{
da.SelectCommand = new SqlCommand("select top 100 ScanFlag,CardId from Card",conn);
DataSet ds = new DataSet();
da.Fill(ds); da.UpdateCommand = new SqlCommand("update Card set ScanFlag = @ScanFlag where CardId = @CardId", conn);
da.UpdateCommand.Parameters.Add("@ScanFlag", SqlDbType.Bit, 1, "ScanFlag");
da.UpdateCommand.Parameters.Add("@CardId", SqlDbType.Int, 4, "CardId");
da.UpdateCommand.UpdatedRowSource = UpdateRowSource.None;
da.UpdateBatchSize = 0; for (int i = 0; i < list.Count; i++)
{
for (int j = 0; j < ds.Tables[0].Rows.Count; j++, i++)
{
ds.Tables[0].Rows[j].BeginEdit();
ds.Tables[0].Rows[j]["ScanFlag"] = true;
ds.Tables[0].Rows[j]["CardId"] = list[i].CardId;
ds.Tables[0].Rows[j].EndEdit();
if (i == list.Count - 1)
break;
}
da.Update(ds.Tables[0]);
}
ds.Clear();
ds.Dispose();
}
}
}
/// 大批量插入数据(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();
}
}
}
}
}
/// <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();
}
}
批量修改方法二:
public void BatchUpdate(List<Card> list)
{
using (SqlConnection conn = new SqlConnection(DbHelperSQL.connectionString))
{
conn.Open();
using (SqlDataAdapter da = new SqlDataAdapter())
{
da.SelectCommand = new SqlCommand("select top 100 ScanFlag,CardId from Card",conn);
DataSet ds = new DataSet();
da.Fill(ds); da.UpdateCommand = new SqlCommand("update Card set ScanFlag = @ScanFlag where CardId = @CardId", conn);
da.UpdateCommand.Parameters.Add("@ScanFlag", SqlDbType.Bit, 1, "ScanFlag");
da.UpdateCommand.Parameters.Add("@CardId", SqlDbType.Int, 4, "CardId");
da.UpdateCommand.UpdatedRowSource = UpdateRowSource.None;
da.UpdateBatchSize = 0; for (int i = 0; i < list.Count; i++)
{
for (int j = 0; j < ds.Tables[0].Rows.Count; j++, i++)
{
ds.Tables[0].Rows[j].BeginEdit();
ds.Tables[0].Rows[j]["ScanFlag"] = true;
ds.Tables[0].Rows[j]["CardId"] = list[i].CardId;
ds.Tables[0].Rows[j].EndEdit();
if (i == list.Count - 1)
break;
}
da.Update(ds.Tables[0]);
}
ds.Clear();
ds.Dispose();
}
}
}
相关文章推荐
- C# Process.Start()方法详解
- C# 文件操作
- C# 导出DataTable数据到Excel文件中
- 动态调用WebService(C#)
- C#调用本地Outlook发送邮件实例
- C# 预执行 事务回滚
- C#中的Dictionary简介
- C#中一种替换switch语句更优雅的写法
- C# 保留小数点后两位(方法总结)
- C#最基础窗体剖析
- C# 第二天
- C#中的volatile用法
- C#取得当前目录 转载
- 使用C#代码获取存储过程返回值
- C#怎样通过url调用接口
- C# 断点续传原理与实现
- (C#基础) ref 和out练习
- C#实现DataList里面嵌套DataList的折叠菜单
- C#获取年龄段 几零后
- C#指定时间和当前时间的相差的月份