SqlBulkCopy.WriteToServer Methode

Definition

Namespace:

Microsoft.Data.SqlClient

Assembly:

Microsoft.Data.SqlClient.dll

Paket:

Microsoft.Data.SqlClient v5.2.0

Überlädt

WriteToServer(DbDataReader)	Kopiert alle Zeilen aus dem angegebenen DbDataReader-Array in eine Zieltabelle, die durch die DestinationTableName-Eigenschaft des SqlBulkCopy-Objekts angegeben ist.
WriteToServer(DataRow[])	Kopiert alle Zeilen aus dem angegebenen DataRow-Array in eine Zieltabelle, die durch die DestinationTableName-Eigenschaft des SqlBulkCopy-Objekts angegeben ist.
WriteToServer(DataTable)	Hiermit werden alle Zeilen in der angegebenen DataTable in eine Zieltabelle kopiert, die durch die DestinationTableName-Eigenschaft des SqlBulkCopy-Objekts festgelegt wird.
WriteToServer(IDataReader)	Hiermit werden alle Zeilen in der angegebenen IDataReader in eine Zieltabelle kopiert, die durch die DestinationTableName-Eigenschaft des SqlBulkCopy-Objekts festgelegt wird.
WriteToServer(DataTable, DataRowState)	Kopiert nur die Zeilen, die dem angegebenen Zeilenstatus in der bereitgestellten DataTable entsprechen, in eine Zieltabelle, die durch die DestinationTableName-Eigenschaft des SqlBulkCopy-Objekts angegeben ist.

WriteToServer(DbDataReader)

Kopiert alle Zeilen aus dem angegebenen DbDataReader-Array in eine Zieltabelle, die durch die DestinationTableName-Eigenschaft des SqlBulkCopy-Objekts angegeben ist.

public:
 void WriteToServer(System::Data::Common::DbDataReader ^ reader);

public void WriteToServer (System.Data.Common.DbDataReader reader);

member this.WriteToServer : System.Data.Common.DbDataReader -> unit

Public Sub WriteToServer (reader As DbDataReader)

Parameter

reader

DbDataReader

Ein DbDataReader, deren Zeilen in die Zieltabelle kopiert werden.

Ausnahmen

InvalidOperationException

A SqlBulkCopyColumnOrderHint hat keinen gültigen Namen der Zielspalte angegeben.

WriteToServer(DataRow[])

Kopiert alle Zeilen aus dem angegebenen DataRow-Array in eine Zieltabelle, die durch die DestinationTableName-Eigenschaft des SqlBulkCopy-Objekts angegeben ist.

public:
 void WriteToServer(cli::array <System::Data::DataRow ^> ^ rows);

public void WriteToServer (System.Data.DataRow[] rows);

member this.WriteToServer : System.Data.DataRow[] -> unit

Public Sub WriteToServer (rows As DataRow())

Parameter

rows

DataRow[]

Ein Array von DataRow-Objekten, die in die Zieltabelle kopiert werden.

Ausnahmen

InvalidOperationException

A SqlBulkCopyColumnOrderHint hat keinen gültigen Namen der Zielspalte angegeben.

Beispiele

Die folgende Konsolenanwendung veranschaulicht das Massenladen von Daten aus einem DataRow Array. Die Zieltabelle ist eine Tabelle in der AdventureWorks-Datenbank .

In diesem Beispiel wird zur Laufzeit ein DataTable erstellt. Aus dem wird eine einzelne Zeile ausgewählt, die DataTable in die Zieltabelle kopiert werden soll.

Wichtig

Dieses Beispiel wird nur ausgeführt, wenn Sie die Arbeitstabellen erstellt haben, wie unter Massenkopierbeispielsetup beschrieben. Der angegebene Code dient nur zur Demonstration der Syntax für die Verwendung von SqlBulkCopy. Wenn sich die Quell- und Zieltabellen in derselben SQL Server Instanz befinden, ist es einfacher und schneller, eine Transact-SQL-Anweisung INSERT … SELECT zum Kopieren der Daten zu verwenden.

Hinweise

Während der Massenkopiervorgang ausgeführt wird, ist das zugeordnete Ziel SqlConnection damit beschäftigt, ihn zu bedienen, und es können keine anderen Vorgänge für die Verbindung ausgeführt werden.

Die ColumnMappings Auflistung wird von den DataRow Spalten der Zieldatenbanktabelle zugeordnet.

WriteToServer(DataTable)

Hiermit werden alle Zeilen in der angegebenen DataTable in eine Zieltabelle kopiert, die durch die DestinationTableName-Eigenschaft des SqlBulkCopy-Objekts festgelegt wird.

public:
 void WriteToServer(System::Data::DataTable ^ table);

public void WriteToServer (System.Data.DataTable table);

member this.WriteToServer : System.Data.DataTable -> unit

Public Sub WriteToServer (table As DataTable)

Parameter

table

DataTable

Ein DataTable, deren Zeilen in die Zieltabelle kopiert werden.

Ausnahmen

InvalidOperationException

A SqlBulkCopyColumnOrderHint hat keinen gültigen Namen der Zielspalte angegeben.

Beispiele

Die folgende Konsolenanwendung veranschaulicht das Massenladen von Daten aus einem DataTable. Die Zieltabelle ist eine Tabelle in der AdventureWorks-Datenbank .

In diesem Beispiel wird ein DataTable zur Laufzeit erstellt und ist die Quelle des SqlBulkCopy Vorgangs.

Wichtig

Dieses Beispiel wird nur ausgeführt, wenn Sie die Arbeitstabellen erstellt haben, wie unter Massenkopierbeispielsetup beschrieben. Der angegebene Code dient nur zur Demonstration der Syntax für die Verwendung von SqlBulkCopy. Wenn sich die Quell- und Zieltabellen in derselben SQL Server Instanz befinden, ist es einfacher und schneller, eine Transact-SQL-Anweisung INSERT … SELECT zum Kopieren der Daten zu verwenden.

using Microsoft.Data.SqlClient;

class Program
{
    static void Main()
    {
        string connectionString = GetConnectionString();
        // Open a connection to the AdventureWorks database.
        using (SqlConnection connection =
                   new SqlConnection(connectionString))
        {
            connection.Open();

            // Perform an initial count on the destination table.
            SqlCommand commandRowCount = new SqlCommand(
                "SELECT COUNT(*) FROM " +
                "dbo.BulkCopyDemoMatchingColumns;",
                connection);
            long countStart = System.Convert.ToInt32(
                commandRowCount.ExecuteScalar());
            Console.WriteLine("Starting row count = {0}", countStart);

            // Create a table with some rows. 
            DataTable newProducts = MakeTable();

            // Create the SqlBulkCopy object. 
            // Note that the column positions in the source DataTable 
            // match the column positions in the destination table so 
            // there is no need to map columns. 
            using (SqlBulkCopy bulkCopy = new SqlBulkCopy(connection))
            {
                bulkCopy.DestinationTableName =
                    "dbo.BulkCopyDemoMatchingColumns";

                try
                {
                    // Write from the source to the destination.
                    bulkCopy.WriteToServer(newProducts);
                }
                catch (Exception ex)
                {
                    Console.WriteLine(ex.Message);
                }
            }

            // 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 DataTable MakeTable()
    // Create a new DataTable named NewProducts. 
    {
        DataTable newProducts = new DataTable("NewProducts");

        // Add three column objects to the table. 
        DataColumn productID = new DataColumn();
        productID.DataType = System.Type.GetType("System.Int32");
        productID.ColumnName = "ProductID";
        productID.AutoIncrement = true;
        newProducts.Columns.Add(productID);

        DataColumn productName = new DataColumn();
        productName.DataType = System.Type.GetType("System.String");
        productName.ColumnName = "Name";
        newProducts.Columns.Add(productName);

        DataColumn productNumber = new DataColumn();
        productNumber.DataType = System.Type.GetType("System.String");
        productNumber.ColumnName = "ProductNumber";
        newProducts.Columns.Add(productNumber);

        // Create an array for DataColumn objects.
        DataColumn[] keys = new DataColumn[1];
        keys[0] = productID;
        newProducts.PrimaryKey = keys;

        // Add some new rows to the collection. 
        DataRow row = newProducts.NewRow();
        row["Name"] = "CC-101-WH";
        row["ProductNumber"] = "Cyclocomputer - White";

        newProducts.Rows.Add(row);
        row = newProducts.NewRow();
        row["Name"] = "CC-101-BK";
        row["ProductNumber"] = "Cyclocomputer - Black";

        newProducts.Rows.Add(row);
        row = newProducts.NewRow();
        row["Name"] = "CC-101-ST";
        row["ProductNumber"] = "Cyclocomputer - Stainless";
        newProducts.Rows.Add(row);
        newProducts.AcceptChanges();

        // Return the new DataTable. 
        return newProducts;
    }
    private static string GetConnectionString()
    // To avoid storing the connection string in your code, 
    // you can retrieve it from a configuration file. 
    {
        return "Data Source=(local); " +
            " Integrated Security=true;" +
            "Initial Catalog=AdventureWorks;";
    }
}

Hinweise

Alle Zeilen in der DataTable werden in die Zieltabelle kopiert, mit Ausnahme der zeilen, die gelöscht wurden.

Während der Massenkopiervorgang ausgeführt wird, ist das zugeordnete Ziel SqlConnection damit beschäftigt, ihn zu bedienen, und es können keine anderen Vorgänge für die Verbindung ausgeführt werden.

Die ColumnMappings Auflistung wird von den DataTable Spalten der Zieldatenbanktabelle zugeordnet.

Weitere Informationen

• Ausführen von Massenkopiervorgängen
• Übersicht über den SqlClient-Treiber

WriteToServer(IDataReader)

Hiermit werden alle Zeilen in der angegebenen IDataReader in eine Zieltabelle kopiert, die durch die DestinationTableName-Eigenschaft des SqlBulkCopy-Objekts festgelegt wird.

public:
 void WriteToServer(System::Data::IDataReader ^ reader);

public void WriteToServer (System.Data.IDataReader reader);

member this.WriteToServer : System.Data.IDataReader -> unit

Public Sub WriteToServer (reader As IDataReader)

Parameter

reader

IDataReader

Ein IDataReader, deren Zeilen in die Zieltabelle kopiert werden.

Ausnahmen

InvalidOperationException

A SqlBulkCopyColumnOrderHint hat keinen gültigen Namen der Zielspalte angegeben.

Beispiele

Die folgende Konsolenanwendung veranschaulicht das Massenladen von Daten aus einem SqlDataReader. Die Zieltabelle ist eine Tabelle in der AdventureWorks-Datenbank .

Wichtig

Dieses Beispiel wird nur ausgeführt, wenn Sie die Arbeitstabellen erstellt haben, wie unter Massenkopierbeispielsetup beschrieben. Der angegebene Code dient nur zur Demonstration der Syntax für die Verwendung von SqlBulkCopy. Wenn sich die Quell- und Zieltabellen in derselben SQL Server Instanz befinden, ist es einfacher und schneller, eine Transact-SQL-Anweisung INSERT … SELECT zum Kopieren der Daten zu verwenden.

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.BulkCopyDemoMatchingColumns;",
                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 a connection string. 
            // In the real world you would not use SqlBulkCopy to move
            // data from one table to the other in the same database.
            using (SqlBulkCopy bulkCopy =
                       new SqlBulkCopy(connectionString))
            {
                bulkCopy.DestinationTableName =
                    "dbo.BulkCopyDemoMatchingColumns";

                try
                {
                    // Write from the source to the destination.
                    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;";
    }
}

Hinweise

Der Kopiervorgang beginnt an der nächsten verfügbaren Zeile im Reader. Die meiste Zeit wurde der Reader einfach von ExecuteReader() oder einem ähnlichen Aufruf zurückgegeben, sodass die nächste verfügbare Zeile die erste Zeile ist. Um mehrere Ergebnisse zu verarbeiten, rufen Sie NextResult() den Datenleser auf, und rufen Sie erneut auf WriteToServer .

Beachten Sie, dass die Verwendung WriteToServer den Zustand des Lesers ändert. Die -Methode wird aufgerufen Read() , bis false zurückgegeben wird, der Vorgang abgebrochen wird oder ein Fehler auftritt. Dies bedeutet, dass sich der Datenleser in einem anderen Zustand befindet, wahrscheinlich am Ende des Resultsets, wenn der WriteToServer Vorgang abgeschlossen ist.

Während der Massenkopiervorgang ausgeführt wird, ist das zugeordnete Ziel SqlConnection damit beschäftigt, ihn zu bedienen, und es können keine anderen Vorgänge für die Verbindung ausgeführt werden.

Die ColumnMappings Auflistung wird von den Datenleserspalten der Zieldatenbanktabelle zugeordnet.

WriteToServer(DataTable, DataRowState)

Kopiert nur die Zeilen, die dem angegebenen Zeilenstatus in der bereitgestellten DataTable entsprechen, in eine Zieltabelle, die durch die DestinationTableName-Eigenschaft des SqlBulkCopy-Objekts angegeben ist.

public:
 void WriteToServer(System::Data::DataTable ^ table, System::Data::DataRowState rowState);

public void WriteToServer (System.Data.DataTable table, System.Data.DataRowState rowState);

member this.WriteToServer : System.Data.DataTable * System.Data.DataRowState -> unit

Public Sub WriteToServer (table As DataTable, rowState As DataRowState)

Parameter

table

DataTable

Ein DataTable, deren Zeilen in die Zieltabelle kopiert werden.

rowState

DataRowState

Ein Wert aus der DataRowState-Enumeration. Es werden nur die Zeilen mit dem entsprechenden Zeilenzustand ins Ziel kopiert.

Ausnahmen

InvalidOperationException

A SqlBulkCopyColumnOrderHint hat keinen gültigen Namen der Zielspalte angegeben.

Beispiele

Die folgende Konsolenanwendung veranschaulicht, wie nur die Zeilen in einem DataTable Massenladen ausgeführt werden, die einem angegebenen Zustand entsprechen. In diesem Fall werden nur unveränderte Zeilen hinzugefügt. Die Zieltabelle ist eine Tabelle in der AdventureWorks-Datenbank .

In diesem Beispiel wird zur Laufzeit ein DataTable erstellt, und es werden drei Zeilen hinzugefügt. Bevor die WriteToServer Methode ausgeführt wird, wird eine der Zeilen bearbeitet. Die WriteToServer Methode wird mit einem DataRowState.UnchangedrowState Argument aufgerufen, sodass nur die beiden unveränderten Zeilen massenhaft an das Ziel kopiert werden.

Wichtig

Dieses Beispiel wird nur ausgeführt, wenn Sie die Arbeitstabellen erstellt haben, wie unter Massenkopierbeispielsetup beschrieben. Der angegebene Code dient nur zur Demonstration der Syntax für die Verwendung von SqlBulkCopy. Wenn sich die Quell- und Zieltabellen in derselben SQL Server Instanz befinden, ist es einfacher und schneller, eine Transact-SQL-Anweisung INSERT … SELECT zum Kopieren der Daten zu verwenden.

using Microsoft.Data.SqlClient;

class Program
{
    static void Main()
    {
        string connectionString = GetConnectionString();
        // Open a connection to the AdventureWorks database.
        using (SqlConnection connection =
                   new SqlConnection(connectionString))
        {
            connection.Open();

            // Perform an initial count on the destination table.
            SqlCommand commandRowCount = new SqlCommand(
                "SELECT COUNT(*) FROM " +
                "dbo.BulkCopyDemoMatchingColumns;",
                connection);
            long countStart = System.Convert.ToInt32(
                commandRowCount.ExecuteScalar());
            Console.WriteLine("Starting row count = {0}", countStart);

            // Create a table with some rows. 
            DataTable newProducts = MakeTable();

            // Make a change to one of the rows in the DataTable.
            DataRow row = newProducts.Rows[0];
            row.BeginEdit();
            row["Name"] = "AAA";
            row.EndEdit();

            // Create the SqlBulkCopy object. 
            // Note that the column positions in the source DataTable 
            // match the column positions in the destination table so 
            // there is no need to map columns. 
            using (SqlBulkCopy bulkCopy = new SqlBulkCopy(connection))
            {
                bulkCopy.DestinationTableName =
                    "dbo.BulkCopyDemoMatchingColumns";

                try
                {
                    // Write unchanged rows from the source to the destination.
                    bulkCopy.WriteToServer(newProducts, DataRowState.Unchanged);
                }
                catch (Exception ex)
                {
                    Console.WriteLine(ex.Message);
                }
            }

            // 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 DataTable MakeTable()
    // Create a new DataTable named NewProducts. 
    {
        DataTable newProducts = new DataTable("NewProducts");

        // Add three column objects to the table. 
        DataColumn productID = new DataColumn();
        productID.DataType = System.Type.GetType("System.Int32");
        productID.ColumnName = "ProductID";
        productID.AutoIncrement = true;
        newProducts.Columns.Add(productID);

        DataColumn productName = new DataColumn();
        productName.DataType = System.Type.GetType("System.String");
        productName.ColumnName = "Name";
        newProducts.Columns.Add(productName);

        DataColumn productNumber = new DataColumn();
        productNumber.DataType = System.Type.GetType("System.String");
        productNumber.ColumnName = "ProductNumber";
        newProducts.Columns.Add(productNumber);

        // Create an array for DataColumn objects.
        DataColumn[] keys = new DataColumn[1];
        keys[0] = productID;
        newProducts.PrimaryKey = keys;

        // Add some new rows to the collection. 
        DataRow row = newProducts.NewRow();
        row["Name"] = "CC-101-WH";
        row["ProductNumber"] = "Cyclocomputer - White";

        newProducts.Rows.Add(row);
        row = newProducts.NewRow();
        row["Name"] = "CC-101-BK";
        row["ProductNumber"] = "Cyclocomputer - Black";

        newProducts.Rows.Add(row);
        row = newProducts.NewRow();
        row["Name"] = "CC-101-ST";
        row["ProductNumber"] = "Cyclocomputer - Stainless";
        newProducts.Rows.Add(row);
        newProducts.AcceptChanges();

        // Return the new DataTable. 
        return newProducts;
    }
    private static string GetConnectionString()
    // To avoid storing the connection string in your code, 
    // you can retrieve it from a configuration file. 
    {
        return "Data Source=(local); " +
            " Integrated Security=true;" +
            "Initial Catalog=AdventureWorks;";
    }
}

Hinweise

Nur Zeilen in der DataTable , die sich in den im rowState Argument angegebenen Zuständen befinden und nicht gelöscht wurden, werden in die Zieltabelle kopiert.

Hinweis

Wenn Deleted angegeben ist, werden auch alle UnchangedZeilen , Addedund Modified auf den Server kopiert. Es wird keine Ausnahme ausgelöst.

Während der Massenkopiervorgang ausgeführt wird, ist das zugeordnete Ziel SqlConnection damit beschäftigt, ihn zu bedienen, und es können keine anderen Vorgänge für die Verbindung ausgeführt werden.

Die ColumnMappings Auflistung wird von den DataTable Spalten der Zieldatenbanktabelle zugeordnet.