SqlBulkCopyColumnMapping Kelas
Definisi
Penting
Beberapa informasi terkait produk prarilis yang dapat diubah secara signifikan sebelum dirilis. Microsoft tidak memberikan jaminan, tersirat maupun tersurat, sehubungan dengan informasi yang diberikan di sini.
Menentukan pemetaan antara kolom di SqlBulkCopy sumber data instans dan kolom dalam tabel tujuan instans.
public ref class SqlBulkCopyColumnMapping sealed
public sealed class SqlBulkCopyColumnMapping
type SqlBulkCopyColumnMapping = class
Public NotInheritable Class SqlBulkCopyColumnMapping
- Warisan
-
SqlBulkCopyColumnMapping
Contoh
Contoh berikut menyalin data secara massal dari tabel sumber dalam database sampel AdventureWorks ke tabel tujuan dalam database yang sama. Meskipun jumlah kolom di tujuan cocok dengan jumlah kolom di sumber, dan setiap kolom tujuan berada dalam posisi ordinal yang sama dengan kolom sumber terkait, nama kolom tidak cocok. SqlBulkCopyColumnMapping objek digunakan untuk membuat peta kolom untuk salinan massal.
Penting
Sampel ini tidak akan berjalan kecuali Anda telah membuat tabel kerja seperti yang dijelaskan dalam Penyiapan Contoh Salinan Massal.
Kode ini disediakan untuk mendemonstrasikan sintaks untuk menggunakan SqlBulkCopy saja. Jika tabel sumber dan tujuan berada dalam instans SQL Server yang sama, lebih mudah dan lebih cepat untuk menggunakan pernyataan Transact-SQL INSERT … SELECT
untuk menyalin data.
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 mapMumber =
new SqlBulkCopyColumnMapping("ProductNumber", "ProdNum");
bulkCopy.ColumnMappings.Add(mapMumber);
// 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;";
}
}
Keterangan
Pemetaan kolom menentukan pemetaan antara sumber data dan tabel target.
Jika pemetaan tidak ditentukan - yaitu, ColumnMappings koleksi kosong - kolom dipetakan secara implisit berdasarkan posisi ordinal. Agar ini berfungsi, skema sumber dan target harus cocok. Jika tidak, akan InvalidOperationException dilemparkan.
ColumnMappings Jika koleksi tidak kosong, tidak setiap kolom yang ada di sumber data harus ditentukan. Mereka yang tidak dipetakan oleh koleksi diabaikan.
Anda dapat merujuk ke kolom sumber dan target dengan nama atau ordinal. Anda juga dapat mencampur referensi kolom berdasarkan nama dan berdasarkan ordinal dalam koleksi pemetaan yang sama.
Konstruktor
SqlBulkCopyColumnMapping() |
Konstruktor tanpa parameter yang menginisialisasi objek baru SqlBulkCopyColumnMapping . |
SqlBulkCopyColumnMapping(Int32, Int32) |
Membuat pemetaan kolom baru, menggunakan ordinal kolom untuk merujuk ke kolom sumber dan tujuan. |
SqlBulkCopyColumnMapping(Int32, String) |
Membuat pemetaan kolom baru, menggunakan ordinal kolom untuk merujuk ke kolom sumber dan nama kolom untuk kolom target. |
SqlBulkCopyColumnMapping(String, Int32) |
Membuat pemetaan kolom baru, menggunakan nama kolom untuk merujuk ke kolom sumber dan kolom ordinal untuk kolom target. |
SqlBulkCopyColumnMapping(String, String) |
Membuat pemetaan kolom baru, menggunakan nama kolom untuk merujuk ke kolom sumber dan tujuan. |
Properti
DestinationColumn |
Nama kolom yang sedang dipetakan dalam tabel database tujuan. |
DestinationOrdinal |
Nilai ordinal kolom tujuan dalam tabel tujuan. |
SourceColumn |
Nama kolom yang sedang dipetakan di sumber data. |
SourceOrdinal |
Posisi ordinal kolom sumber dalam sumber data. |