C# 利用 SqlBulkCopy 大批量導入excel文件進入SQL

 

   public void BuckCopy(DataTable dt, string destinationTableName)
        {
            using (SqlConnection sqlConn = (SqlConnection)this.CurrentDataBase.CreateConnection())
            {
                if (sqlConn.State != ConnectionState.Open)
                    sqlConn.Open();
                using (SqlBulkCopy buckCopy = new SqlBulkCopy(sqlConn))
                {
                    buckCopy.DestinationTableName = destinationTableName;
                    buckCopy.ColumnMappings.Add("ID", "ID");                    
                    buckCopy.WriteToServer(dt);
                }
            }
        }

 升級，動態mapping

  /// <summary>
        /// 將datatable數據bulkcopy進SQL table
        /// </summary>
        /// <param name="dt"></param>
        /// <param name="tablename"></param>
        /// <param name="_constring"></param>
        public static void SqlBulkCopy(DataTable dt, string tablename, string _constring)
        {
            try
            {
                using (SqlConnection sqlConn = new SqlConnection(_constring))
                {
                    if (sqlConn.State != ConnectionState.Open)
                        sqlConn.Open();
                    /*查詢數據 tablename對應的字段*/
                    string[] restrictions = new string[4];
                    restrictions[1] = "dbo";
                    restrictions[2] = tablename;
                    /*獲取table的列*/
                    DataTable tableinfo = sqlConn.GetSchema("Columns", restrictions);
                    if (tableinfo.Rows.Count > 0)
                    {
                        using (SqlBulkCopy bulkCopy = new SqlBulkCopy(sqlConn))
                        {
                            bulkCopy.BulkCopyTimeout = _timeout;
                            bulkCopy.DestinationTableName = tablename;
                            bulkCopy.BatchSize = 1000;//每1000條提交一次
                            foreach (DataColumn dc in dt.Columns)
                            {
                                foreach (DataRow dr in tableinfo.Rows)
                                {
                                    //動態mapping字段，大小寫可以忽略
                                    if (dc.ColumnName.ToLower() == dr["COLUMN_NAME"].ToString().ToLower())
                                    {
                                        bulkCopy.ColumnMappings.Add(dc.ColumnName, dr["COLUMN_NAME"].ToString());
                                        break;//只要匹配到就跳出該次循環，進行下一次
                                    }
                                }
                            }
                            bulkCopy.WriteToServer(dt);
                        }
                    }
                }
            }
            catch (Exception ex)
            {
                LogHelper.Error("Error:Connercthelper SqlBulkCopy", ex);
                throw;
            }



        }

測試6W條數據，大概9-10秒。如果mapping是寫死的，應該要快一些。

又重新重載了一下方法：支持調用的時候先mapping好。

        /// <summary>
        ///  將datatable數據bulkcopy進SQL table
        /// </summary>
        /// <param name="dt"></param>
        /// <param name="tablename"></param>
        /// <param name="_constring"></param>
        /// <param name="columnmapping">自定義mapping column</param>
        public static void SqlBulkCopy(DataTable dt, string tablename, string _constring, SqlBulkCopyColumnMapping[] columnmapping)
        {
            try
            {
                  using (SqlConnection sqlConn = new SqlConnection(_constring))
                  {
                      if (sqlConn.State != ConnectionState.Open)
                          sqlConn.Open();
                       using (SqlBulkCopy bulkCopy = new SqlBulkCopy(sqlConn))
                       {
                           bulkCopy.BulkCopyTimeout = _timeout;
                           bulkCopy.DestinationTableName = tablename;
                           bulkCopy.BatchSize = 1000;//每1000條提交一次
                           //循環mapping
                           foreach(SqlBulkCopyColumnMapping map in columnmapping)
                           {
                               bulkCopy.ColumnMappings.Add(map);
                           }
                           bulkCopy.WriteToServer(dt);
                       }
                  }
            }
            catch (Exception ex)
            {
                LogHelper.Error("Error:Connercthelper SqlBulkCopy", ex);
                throw;
            }
        }