SqlBulkCopyColumnMapping Třída
Definice
Důležité
Některé informace platí pro předběžně vydaný produkt, který se může zásadně změnit, než ho výrobce nebo autor vydá. Microsoft neposkytuje žádné záruky, výslovné ani předpokládané, týkající se zde uváděných informací.
Definuje mapování mezi sloupcem ve SqlBulkCopy zdroji dat instance a sloupcem v cílové tabulce instance.
public ref class SqlBulkCopyColumnMapping sealed
public sealed class SqlBulkCopyColumnMapping
type SqlBulkCopyColumnMapping = class
Public NotInheritable Class SqlBulkCopyColumnMapping
- Dědičnost
-
SqlBulkCopyColumnMapping
Příklady
Následující příklad hromadně zkopíruje data ze zdrojové tabulky v ukázkové databázi AdventureWorks do cílové tabulky ve stejné databázi. I když počet sloupců v cíli odpovídá počtu sloupců ve zdroji a každý cílový sloupec je ve stejné řadové pozici jako odpovídající zdrojový sloupec, názvy sloupců se neshodují. SqlBulkCopyColumnMapping objekty se používají k vytvoření mapy sloupců pro hromadné kopírování.
Důležité
Tato ukázka se nespustí, pokud jste nevytvořili pracovní tabulky, jak je popsáno v příkladu hromadného kopírování.
Tento kód je k dispozici k předvedení syntaxe pouze pro použití SqlBulkCopy . Pokud jsou zdrojová a cílová tabulka ve stejné SQL Server instanci, je jednodušší a rychlejší zkopírovat data pomocí příkazu Jazyka Transact-SQLINSERT … SELECT
.
using System;
using System.Data;
using Microsoft.Data.SqlClient;
class Program
{
static void Main()
{
string connectionString = GetConnectionString();
// Open a sourceConnection to the AdventureWorks database.
using (SqlConnection sourceConnection =
new SqlConnection(connectionString))
{
sourceConnection.Open();
// Perform an initial count on the destination table.
SqlCommand commandRowCount = new SqlCommand(
"SELECT COUNT(*) FROM " +
"dbo.BulkCopyDemoDifferentColumns;",
sourceConnection);
long countStart = System.Convert.ToInt32(
commandRowCount.ExecuteScalar());
Console.WriteLine("Starting row count = {0}", countStart);
// Get data from the source table as a SqlDataReader.
SqlCommand commandSourceData = new SqlCommand(
"SELECT ProductID, Name, " +
"ProductNumber " +
"FROM Production.Product;", sourceConnection);
SqlDataReader reader =
commandSourceData.ExecuteReader();
// Set up the bulk copy object.
using (SqlBulkCopy bulkCopy =
new SqlBulkCopy(connectionString))
{
bulkCopy.DestinationTableName =
"dbo.BulkCopyDemoDifferentColumns";
// Set up the column mappings by name.
SqlBulkCopyColumnMapping mapID =
new SqlBulkCopyColumnMapping("ProductID", "ProdID");
bulkCopy.ColumnMappings.Add(mapID);
SqlBulkCopyColumnMapping mapName =
new SqlBulkCopyColumnMapping("Name", "ProdName");
bulkCopy.ColumnMappings.Add(mapName);
SqlBulkCopyColumnMapping mapNumber =
new SqlBulkCopyColumnMapping("ProductNumber", "ProdNum");
bulkCopy.ColumnMappings.Add(mapNumber);
// Write from the source to the destination.
try
{
bulkCopy.WriteToServer(reader);
}
catch (Exception ex)
{
Console.WriteLine(ex.Message);
}
finally
{
// Close the SqlDataReader. The SqlBulkCopy
// object is automatically closed at the end
// of the using block.
reader.Close();
}
}
// Perform a final count on the destination
// table to see how many rows were added.
long countEnd = System.Convert.ToInt32(
commandRowCount.ExecuteScalar());
Console.WriteLine("Ending row count = {0}", countEnd);
Console.WriteLine("{0} rows were added.", countEnd - countStart);
Console.WriteLine("Press Enter to finish.");
Console.ReadLine();
}
}
private static string GetConnectionString()
// To avoid storing the sourceConnection string in your code,
// you can retrieve it from a configuration file.
{
return "Data Source=(local); " +
" Integrated Security=true;" +
"Initial Catalog=AdventureWorks;";
}
}
Poznámky
Mapování sloupců definují mapování mezi zdrojem dat a cílovou tabulkou.
Pokud mapování nejsou definovaná – to znamená, ColumnMappings že kolekce je prázdná – sloupce se mapují implicitně na základě řadové pozice. Aby to fungovalo, musí se zdrojová a cílová schémata shodovat. Pokud to neudělají, InvalidOperationException bude vyhozena.
ColumnMappings Pokud kolekce není prázdná, není nutné zadat každý sloupec, který je ve zdroji dat. Ty, které kolekce nemapuje, se ignorují.
Na zdrojový a cílový sloupec můžete odkazovat podle názvu nebo pořadové řady. Ve stejné kolekci mapování můžete také kombinovat odkazy na sloupce podle názvu a podle řad.
Konstruktory
SqlBulkCopyColumnMapping() |
Konstruktor bez parametrů, který inicializuje nový SqlBulkCopyColumnMapping objekt. |
SqlBulkCopyColumnMapping(Int32, Int32) |
Vytvoří nové mapování sloupců pomocí řad sloupců, které odkazují na zdrojový a cílový sloupec. |
SqlBulkCopyColumnMapping(Int32, String) |
Vytvoří nové mapování sloupců pomocí řad sloupců odkazující na zdrojový sloupec a názvu sloupce pro cílový sloupec. |
SqlBulkCopyColumnMapping(String, Int32) |
Vytvoří nové mapování sloupců s použitím názvu sloupce odkazujícího na zdrojový sloupec a ordinálu sloupce pro cílový sloupec. |
SqlBulkCopyColumnMapping(String, String) |
Vytvoří nové mapování sloupců pomocí názvů sloupců, které odkazují na zdrojový a cílový sloupec. |
Vlastnosti
DestinationColumn |
Název sloupce mapovaného v cílové tabulce databáze |
DestinationOrdinal |
Ordinální hodnota cílového sloupce v cílové tabulce. |
SourceColumn |
Název sloupce mapovaného ve zdroji dat |
SourceOrdinal |
Řadová pozice zdrojového sloupce v rámci zdroje dat |