使用asp.net 2.0中的SqlBulkCopy类批量复制数据

private static void PerformBulkCopy()    
{ 
    string connectionString = @"Server=localhost;Database=Northwind;Trusted_Connection=true"; 
                                                 
    // 源    
    using (SqlConnection sourceConnection = new SqlConnection(connectionString)) 
    { 
        SqlCommand myCommand = new SqlCommand("SELECT * FROM Products_Archive", sourceConnection); 
        sourceConnection.Open(); 
        SqlDataReader reader = myCommand.ExecuteReader();    
                                 
        // 目的    
        using (SqlConnection destinationConnection = new SqlConnection(connectionString)) 
        { 
            // 打开连接    
            destinationConnection.Open(); 
                                 
            using (SqlBulkCopy bulkCopy = new SqlBulkCopy(destinationConnection.ConnectionString)) 
            { 
                bulkCopy.BatchSize = 500; 
        bulkCopy.NotifyAfter = 1000; 
                bulkCopy.SqlRowsCopied += new SqlRowsCopiedEventHandler(bulkCopy_SqlRowsCopied); 
                bulkCopy.DestinationTableName = "Products_Latest"; 
                bulkCopy.WriteToServer(reader);                                         
            } 
        } 
 
        reader.Close();                                    
                                 
    }                     
}

private static void PerformBulkCopyDifferentSchema() 
{ 
    string connectionString = @"Server=localhost;Database=Northwind;Trusted_Connection=true"; 
 
    DataTable sourceData = new DataTable(); 
 
    // 源    
    using (SqlConnection sourceConnection = new SqlConnection(connectionString)) 
    { 
        SqlCommand myCommand = new SqlCommand("SELECT TOP 5 * FROM Products_Archive", sourceConnection); 
        sourceConnection.Open(); 
        SqlDataReader reader = myCommand.ExecuteReader(); 
 
        // 目的 
        using (SqlConnection destinationConnection = new SqlConnection(connectionString)) 
        { 
            // 打开连接 
            destinationConnection.Open(); 
 
            using (SqlBulkCopy bulkCopy = new SqlBulkCopy(destinationConnection.ConnectionString)) 
            { 
                bulkCopy.ColumnMappings.Add("ProductID", "ProductID"); 
                bulkCopy.ColumnMappings.Add("ProductName", "Name"); 
                bulkCopy.ColumnMappings.Add("QuantityPerUnit", "Quantity"); 
                bulkCopy.DestinationTableName = "Products_TopSelling"; 
                bulkCopy.WriteToServer(reader); 
            } 
        } 
 
        reader.Close(); 
 
    } 
}

<?xml version="1.0" encoding="utf-8" ?> 
<Products> 
    <Product productID="1" productName="Chai" /> 
    <Product productID="2" productName="Football" /> 
    <Product productID="3" productName="Soap" /> 
    <Product productID="4" productName="Green Tea" /> 
</Products>

private static void PerformBulkCopyXMLDataSource() 
{ 
    string connectionString = @"Server=localhost;Database=Northwind;Trusted_Connection=true"; 
 
    DataSet ds = new DataSet(); 
    DataTable sourceData = new DataTable();    
    ds.ReadXml(@"C:Products.xml"); 
 
    sourceData = ds.Tables[0]; 
 
    // 目的    
    using (SqlConnection destinationConnection = new SqlConnection(connectionString)) 
    { 
        // 打开连接    
        destinationConnection.Open(); 
 
        using (SqlBulkCopy bulkCopy = new SqlBulkCopy(destinationConnection.ConnectionString)) 
        { 
            // 列映射 
            bulkCopy.ColumnMappings.Add("productID", "ProductID"); 
            bulkCopy.ColumnMappings.Add("productName", "Name"); 
                                         
            bulkCopy.DestinationTableName = "Products_TopSelling"; 
            bulkCopy.WriteToServer(sourceData); 
        } 
    } 
}