bulk方法主要思想是通過在客戶端把數(shù)據(jù)都緩存在Table中，然后利用SqlBulkCopy一次性把Table中的數(shù)據(jù)插入到數(shù)據(jù)庫

代碼如下：

public static void BulkToDB(DataTable dt){ SqlConnection sqlConn = new SqlConnection( ConfigurationManager.ConnectionStrings["ConnStr"].ConnectionString);
　　SqlBulkCopy bulkCopy = new SqlBulkCopy(sqlConn);
　　bulkCopy.DestinationTableName = "BulkTestTable";
　　bulkCopy.BatchSize = dt.Rows.Count;
　　try {
　　　　sqlConn.Open();
　　　　if (dt != null && dt.Rows.Count != 0) bulkCopy.WriteToServer(dt);
　　}
　　catch (Exception ex)
　　{
　　　　throw ex;
　　} finally
　　{
　　　　sqlConn.Close();
　　　　if (bulkCopy != null) bulkCopy.Close();
　　}
}
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("Pwd",typeof(string))}
　　);
　　return dt;
}
static void Main(string[] args)
{
　　Stopwatch sw = new Stopwatch();
　　for (int multiply = 0; multiply < 10; multiply++)
　　{
　　　　DataTable dt = Bulk.GetTableSchema();
　　　　for (int count = multiply * 100000; count < (multiply + 1) * 100000; count++)
　　　　{
　　　　　　DataRow r = dt.NewRow();
　　　　　　r[0] = count;
　　　　　　r[1] = string.Format("User-{0}", count * multiply);
　　　　　　r[2] = string.Format("Pwd-{0}", count * multiply);
　　　　　　dt.Rows.Add(r);
　　　　}
　　　sw.Start();
　　　　Bulk.BulkToDB(dt);
　　　　sw.Stop();
　　　　Console.WriteLine(string.Format("Elapsed Time is {0} Milliseconds", sw.ElapsedMilliseconds));
　 }
　　Console.ReadLine();
}

總結(jié)

以上是生活随笔為你收集整理的利用SqlBulkCopy插入数据的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。