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();      for (int i = 0; i < Count; i++)//循环往DataTable中赋值      {        DataRow r = dt.NewRow();        r[1] = ran.Next(10000000, 100000000);        r[2] = ran.Next(10000000, 100000000);        r[3] = classRoomId;        r[4] = DateTime.Now;        r[5] = 1;        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();        if (dt != null && dt.Rows.Count != 0)          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;      }    }  }}