使用SqlBulkCopy类批量复制大数据

时间:2024-05-09 20:06:31
 using System;
using System.Configuration;
using System.Data;
using System.Data.SqlClient;
using System.Diagnostics; namespace SqlBulkCopy1
{
class Program
{
static void Main(string[] args)
{
Stopwatch sw = new Stopwatch();
for (int multiply = ; multiply < ; multiply++)
{
DataTable dt = GetTableSchema();
for (int count = multiply * ; count < (multiply + ) * ; count++)
{
DataRow r = dt.NewRow();
r[] = count;
r[] = string.Format("username-{0}", count * multiply);
r[] = string.Format("userpwd-{0}", count * multiply);
r[] = string.Format("address-{0}", count * multiply);
dt.Rows.Add(r);
}
sw.Start();
BulkToDB(dt);
sw.Stop();
Console.WriteLine(string.Format("已消耗时间{0}毫秒", sw.ElapsedMilliseconds));
}
Console.ReadLine();
}
public static void BulkToDB(DataTable dt)
{
SqlConnection con = new SqlConnection(ConfigurationManager.ConnectionStrings["SqlConnString"].ConnectionString);
SqlBulkCopy bulkCopy = new SqlBulkCopy(con);
bulkCopy.DestinationTableName = "USERINFO";
bulkCopy.BatchSize = dt.Rows.Count;
try
{
con.Open();
if (dt != null && dt.Rows.Count != )
bulkCopy.WriteToServer(dt);
}
catch (Exception)
{ throw;
}
} public static DataTable GetTableSchema()
{
DataTable dt = new DataTable();
dt.Columns.AddRange(new DataColumn[] {
new DataColumn("id",typeof(int)),
new DataColumn("username",typeof(string)),
new DataColumn("userpwd",typeof(string)),
new DataColumn("address",typeof(string))
});
return dt;
}
}
}

100W条数据消耗时间:

使用SqlBulkCopy类批量复制大数据