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;
      }
    }
  }
}