Asp.Net使用Bulk批量插入数据

 using System; using System.Collections.Generic; using System.Linq; using System.Web; using System.Diagnostics; using System.Data; using System.Data.SqlClient; using System.Configuration; using Fx678Member.Framework.Exceptions; namespace MeiYuanJinYe.Admin.HttpHandler {     /// <summary>     /// CreateAccount 的摘要说明     /// </summary>     public class CreateAccount : IHttpHandler     {         public void ProcessRequest(HttpContext context)         {             context.Response.ContentType = "text/plain";             Guid classRoomId = Guid.Parse(context.Request["ClassRoomId"]);             int Count = int.Parse(context.Request["Count"]);             DataTable dt = GetTableSchema();             Random ran = new Random();             ; i < Count; i++)//循环往DataTable中赋值             {                 DataRow r = dt.NewRow();                 r[] = ran.Next(, );                 r[] = ran.Next(, );                 r[] = classRoomId;                 r[] = DateTime.Now;                 r[] = ;                 dt.Rows.Add(r);             }             BulkToDB(dt);             context.Response.Write(BulkToDB(dt) ? "ok" : "error");             context.Session["dataTable"] = dt;         }         public void BulkToDB(DataTable dt)         {             SqlConnection sqlConn = new SqlConnection(ConfigurationManager.AppSettings["ConnString"]);             SqlBulkCopy bulkCopy = new SqlBulkCopy(sqlConn);             bulkCopy.DestinationTableName = "ClassRoomAccount";//数据库表名             bulkCopy.BatchSize = dt.Rows.Count;             try             {                 sqlConn.Open();                 )                     bulkCopy.WriteToServer(dt);             }             catch (Exception ex)             {                 new AppException("批量生成直播室账号异常", ex);             }             finally             {                 sqlConn.Close();                 if (bulkCopy != null)                     bulkCopy.Close();             }         }         public DataTable GetTableSchema()         {             DataTable dt = new DataTable();             dt.Columns.AddRange(new DataColumn[]{                 new DataColumn("AccountId",typeof(int)),                 new DataColumn("AccountName",typeof(string)),                 new DataColumn("Password",typeof(string)),                 new DataColumn("ClassRoomId",typeof(Guid)),                 new DataColumn("AddDate",typeof(DateTime)),                 new DataColumn("IsActive",typeof(int))             });//数据库表结构             return dt;         }         public bool IsReusable         {             get             {                 return false;             }         }     } }