트 랜 잭 션 과 SqlBulkCopy 를 사용 하여 데 이 터 를 일괄 삽입 합 니 다.

SqlBulkCopy 는.NET Framework 2.0 에 추 가 된 클래스 로 네 임 스페이스 System.Data.sql Client 에 위치 하여 다른 데이터 원본 의 데 이 터 를 SQL Server 표 에 효과적으로 대량으로 불 러 오 는 기능 을 제공 합 니 다.Microsoft SQL Server 패키지 의 bcp 라 는 명령 행 프로그램 과 유사 합 니 다.그러나 SqlBulkCopy 류 를 사용 하면 위탁 관리 코드 솔 루 션 을 작성 할 수 있 습 니 다.bcp 명령 행 프로그램 보다 성능 이 좋 고 Insert 방식 으로 SQL Server 표 에 대량의 데 이 터 를 불 러 오 는 것 이 좋 습 니 다.SqlBulkCopy 는 데이터 원본 이 무엇이든 대량의 데이터 이전 에 사용 할 수 있 습 니 다.
이전에 winform 개발 을 할 때 datagridview 데이터 의 양 이 비교적 많 을 때 for 순환 으로 시간 과 성능 을 많이 소모 하 는 것 을 발 견 했 고 자 료 를 조회 하여 SqlBulkCopy 와 같은 대량의 데이터 이전 도 구 를 알 게 되 었 다.
다음 코드 는 datagridview 의 대량 데이터 삽입 을 실현 합 니 다.
만약 datagridview 의 열 이 데이터베이스 에 있 는 표 구조 와 완전히 대응 하지 못 한다 면,우 리 는 먼저 datagridview 데 이 터 를 하나의 DataTable 에 저장 해 야 합 니 다.DataTable 의 열 은 곧 삽 입 될 표 의 열 형식 과 호 환 되 어야 하 며,이름과 열 순서 가 완전히 같 아야 합 니 다.자 증 열 은 int 형식의 값 을 마음대로 작성 하면 되 고 쓰 지 않 아 도 됩 니 다.자 증 열 에 지정 한 값 을 주지 않 았 다 면 후속 표 맵 관계 에서 대응 관 계 를 명확 하 게 밝 혀 야 합 니 다.저 는 순환 으로 표 의 대응 관 계 를 지정 하기 때문에 table 의 필드 에 대해 엄격 한 요 구 를 합 니 다.사실은 데이터 베이스 표 의 필드 이름과 다 를 수도 있 지만 표 간 의 대응 관 계 를 구체 적 으로 지적 해 야 합 니 다.

DataTable table = new DataTable();
table.Columns.AddRange(new DataColumn[]{
new DataColumn("flow_id",typeof(int)),
new DataColumn("sheet_no",typeof(string)),
new DataColumn("item_no",typeof(string)),
new DataColumn("unit_no",typeof(string)),
new DataColumn("unit_factor",typeof(string)),
new DataColumn("in_price",typeof(string)),
new DataColumn("order_qnty",typeof(string)),
new DataColumn("sub_amount",typeof(string)),
new DataColumn("real_qty",typeof(string)),
new DataColumn("tax_rate",typeof(string)),
new DataColumn("pay_percent",typeof(string)),
new DataColumn("out_qty",typeof(string))});
for (int i = 0; i < dt.Rows.Count; i++)
{
DataRow r = dt.Rows[i];
table.Rows.Add(i, sheet_no, r["item_no"], r["unit_no"], r["unit_factor"], r["in_price"], r["order_qnty"], r["sub_amount"], r["real_qty"], r["tax_rate"], r["pay_percent"], r["out_qty"]);

}

 

//        

using (SqlConnection conn = new SqlConnection(connectionString))
{
  conn.Open();

  SqlTransaction tran = conn.BeginTransaction();//    

 

  //            ，        sqlbulkTransaction  

  SqlBulkCopy bulkCopy = new SqlBulkCopy(conn, SqlBulkCopyOptions.CheckConstraints, tran);
  bulkCopy.DestinationTableName = "***";//***          
  foreach (DataColumn dc in table.Columns)  //    table
  {
    bulkCopy.ColumnMappings.Add(dc.ColumnName, dc.ColumnName);// table               
  }

    try
    {
        bulkCopy.WriteToServer(table);
        tran.Commit();
    }
    catch (Exception ex)
    {
        tran.Rollback();
    }
    finally
    {
        bulkCopy.Close();
        conn.Close();
    }