C# 批量導入 SqlBulkCopy

 

快速批量導入方法 SqlBulkCopy

        public string InsertSqlBulkCopy(DataTable dt, string tableName, ref string errinfo)
        {
            if (dt.Rows.Count < 1)
            {
                return "";
            }
            using (SqlConnection conn = new SqlConnection(SqlHelper.connectionString))
            {
                conn.Open();
                SqlTransaction sqlTran = conn.BeginTransaction(); // 開始事務
                //開始事務
                using (SqlBulkCopy bcp = new SqlBulkCopy(conn, SqlBulkCopyOptions.Default, sqlTran))
                {
                    string sql = @"
select  sourceColumn, destinationColumn from Importsolution where tableName='" + tableName + @"'";
                    DataTable Importsolution = SqlHelper.GetDataSet(sql).Tables[0];
                    foreach (DataRow dr in Importsolution.Rows)
                    {
                        bcp.ColumnMappings.Add(dr["sourceColumn"].ToString(), dr["destinationColumn"].ToString());
                    }

                    //指定目標數據庫的表名
                    bcp.DestinationTableName = tableName;

                    try
                    {
                        //bcp.BulkCopyTimeout = 180;
                        //寫入數據庫表?dt?是數據源DataTable
                        bcp.WriteToServer(dt);
                        sqlTran.Commit();

                    }
                    catch (Exception ex)
                    {
                        errinfo += ex.Message + "";
                        sqlTran.Rollback();
                    }
                    finally
                    {
                        sqlTran.Dispose();
                    }

                }
            }
            return "";
        }