Condividi tramite

Uso della copia bulk con il driver JDBC

  • Articolo

Scaricare il driver JDBC

Microsoft SQL Server include un'utilità della riga di comando comune, denominata bcp, per la rapida copia bulk di file di grandi dimensioni in tabelle o visualizzazioni in database di SQL Server. La classe SQLServerBulkCopy consente di scrivere soluzioni di codice in Java che offrono funzionalità simili. Esistono altri modi per caricare dati in una tabella di SQL Server (ad esempio, istruzioni INSERT) ma SQLServerBulkCopy offre un significativo vantaggio in termini di prestazioni.

La classe SQLServerBulkCopy può essere usata per scrivere dati solo in tabelle di SQL Server. Tuttavia, l'origine dati non è limitata a SQL Server: può essere usata qualsiasi origine dati, purché i dati possano essere letti con un'implementazione di ResultSet, RowSet o ISQLServerBulkRecord.

Nota

ISQLServerBulkData come origine dati quando si usa la copia bulk non è al momento completamente supportato e gli utenti potrebbero riscontrare errori quando si usa questo tipo di origine dati. È consigliabile usare ResultSet, RowSet, o ISQLServerBulkRecord invece.

Con la classe SQLServerBulkCopy è possibile eseguire:

  • Una singola operazione di copia bulk

  • Più operazioni di copia bulk

  • Un'operazione di copia bulk con una transazione

Nota

Quando si utilizza Microsoft JDBC Driver 4.1 per SQL Server o una versione precedente (che non supporta la classe SQLServerBulkCopy), è invece possibile eseguire l'istruzione Transact-SQL BULK INSERT di SQL Server.

Installazione di esempio della copia bulk

La classe SQLServerBulkCopy può essere usata per scrivere dati solo in tabelle di SQL Server. Gli esempi di codice mostrati in questo articolo usano il database di esempio AdventureWorks di SQL Server. Per evitare di modificare le tabelle esistenti negli esempi di codice, creare prima di tutto tabelle in cui scrivere i dati.

Le tabelle BulkCopyDemoMatchingColumns e BulkCopyDemoDifferentColumns sono entrambe basate sulla tabella Production.Products di AdventureWorks. Negli esempi di codice che usano queste tabelle, i dati vengono aggiunti dalla tabella Production.Products a una di queste tabelle di esempio. La tabella BulkCopyDemoDifferentColumns viene usata quando l'esempio mostra come eseguire il mapping di colonne dai dati di origine alla tabella di destinazione, mentre BulkCopyDemoMatchingColumns viene usata per la maggior parte degli altri esempi.

Alcuni esempi di codice illustrano come usare una sola classe SQLServerBulkCopy per scrivere in più tabelle. Per questi esempi, vengono usate le tabelle BulkCopyDemoOrderHeader e BulkCopyDemoOrderDetail come tabelle di destinazione. Queste tabelle sono basate sulle tabelle Sales.SalesOrderHeader e Sales.SalesOrderDetail di AdventureWorks.

Nota

Gli esempi di codice di SQLServerBulkCopy vengono forniti solo per mostrare la sintassi per l'uso di SQLServerBulkCopy. Se le tabelle di origine e di destinazione si trovano nella stessa istanza di SQL Server, è più semplice e rapido usare l'istruzione Transact-SQL INSERISCI ... SELEZIONA per copiare i dati.

Impostazione delle tabelle

Per creare le tabelle necessarie per il corretto funzionamento degli esempi di codice, è necessario eseguire le seguenti istruzioni Transact-SQL in un database di SQL Server.

USE AdventureWorks2022;
GO
  
IF EXISTS (SELECT * FROM dbo.sysobjects
 WHERE id = object_id(N'[dbo].[BulkCopyDemoMatchingColumns]')
 AND OBJECTPROPERTY(id, N'IsUserTable') = 1)  
    DROP TABLE [dbo].[BulkCopyDemoMatchingColumns]  
  
CREATE TABLE [dbo].[BulkCopyDemoMatchingColumns]([ProductID] [int] IDENTITY(1,1) NOT NULL,  
    [Name] [nvarchar](50) NOT NULL,  
    [ProductNumber] [nvarchar](25) NOT NULL,  
 CONSTRAINT [PK_ProductID] PRIMARY KEY CLUSTERED
(  
    [ProductID] ASC  
) ON [PRIMARY]) ON [PRIMARY]  
  
IF EXISTS (SELECT * FROM dbo.sysobjects
 WHERE id = object_id(N'[dbo].[BulkCopyDemoDifferentColumns]')
 AND OBJECTPROPERTY(id, N'IsUserTable') = 1)  
    DROP TABLE [dbo].[BulkCopyDemoDifferentColumns]  
  
CREATE TABLE [dbo].[BulkCopyDemoDifferentColumns]([ProdID] [int] IDENTITY(1,1) NOT NULL,  
    [ProdNum] [nvarchar](25) NOT NULL,  
    [ProdName] [nvarchar](50) NOT NULL,  
 CONSTRAINT [PK_ProdID] PRIMARY KEY CLUSTERED
(  
    [ProdID] ASC  
) ON [PRIMARY]) ON [PRIMARY]  
  
IF EXISTS (SELECT * FROM dbo.sysobjects
 WHERE id = object_id(N'[dbo].[BulkCopyDemoOrderHeader]')
 AND OBJECTPROPERTY(id, N'IsUserTable') = 1)  
    DROP TABLE [dbo].[BulkCopyDemoOrderHeader]  
  
CREATE TABLE [dbo].[BulkCopyDemoOrderHeader]([SalesOrderID] [int] IDENTITY(1,1) NOT NULL,  
    [OrderDate] [datetime] NOT NULL,  
    [AccountNumber] [nvarchar](15) NULL,  
 CONSTRAINT [PK_SalesOrderID] PRIMARY KEY CLUSTERED
(  
    [SalesOrderID] ASC  
) ON [PRIMARY]) ON [PRIMARY]  
  
IF EXISTS (SELECT * FROM dbo.sysobjects
 WHERE id = object_id(N'[dbo].[BulkCopyDemoOrderDetail]')
 AND OBJECTPROPERTY(id, N'IsUserTable') = 1)  
    DROP TABLE [dbo].[BulkCopyDemoOrderDetail]  
  
CREATE TABLE [dbo].[BulkCopyDemoOrderDetail]([SalesOrderID] [int] NOT NULL,  
    [SalesOrderDetailID] [int] NOT NULL,  
    [OrderQty] [smallint] NOT NULL,  
    [ProductID] [int] NOT NULL,  
    [UnitPrice] [money] NOT NULL,  
 CONSTRAINT [PK_LineNumber] PRIMARY KEY CLUSTERED
(  
    [SalesOrderID] ASC,  
    [SalesOrderDetailID] ASC  
) ON [PRIMARY]) ON [PRIMARY]

Singole operazioni di copia bulk

L'approccio più semplice per eseguire un'operazione di copia bulk di SQL Server consiste nell'eseguire una singola operazione su un database. Per impostazione predefinita, una copia bulk viene eseguita come un'operazione isolata: l'operazione di copia avviene in modalità non transazionale, senza la possibilità di eseguirne il rollback.

Nota

Se è necessario eseguire il rollback di una parte o dell'intera operazione di copia bulk quando si verifica un errore, è possibile usare una transazione gestita da SQLServerBulkCopy o eseguire l'operazione di copia bulk all'interno di una transazione esistente.
Per altre informazioni, vedere Transazioni e operazioni di copia bulk

I passaggi generali per eseguire un'operazione di copia bulk sono:

  1. Connettersi al server di origine e ottenere i dati da copiare. I dati possono provenire anche da altre origini, se possono essere recuperati da un oggetto ResultSet o un'implementazione di ISQLServerBulkRecord.

  2. Connettersi al server di destinazione, a meno che non si voglia che la connessione venga stabilita da SQLServerBulkCopy.

  3. Creare un oggetto SQLServerBulkCopy, impostando tutte le proprietà necessarie tramite setBulkCopyOptions.

  4. Chiamare il metodo setDestinationTableName per indicare la tabella di destinazione per l'operazione di inserimento bulk.

  5. Chiamare uno dei metodi writeToServer.

  6. Facoltativamente, aggiornare le proprietà tramite setBulkCopyOptions e, se necessario, chiamare di nuovo writeToServer.

  7. Chiamare close o eseguire il wrapping delle operazioni di copia bulk all'interno di un'istruzione try-with-resources.

Attenzione

È consigliabile che i tipi di dati delle colonne di origine e di destinazione corrispondano. Se i tipi di dati non corrispondono, SQLServerBulkCopy tenta di convertire ogni valore di origine nel tipo di dati di destinazione. Le conversioni possono influire sulle prestazioni, nonché provocare errori imprevisti. Ad esempio, un tipo di dati double può essere convertito in un tipo di dati decimal nella maggior parte dei casi, ma non sempre.

Esempio

L'applicazione seguente mostra come caricare dati usando la classe SQLServerBulkCopy. In questo esempio, viene usato un ResultSet per copiare i dati dalla tabella Production.Product del database AdventureWorks di SQL Server in una tabella simile dello stesso database.

Importante

Questo esempio non funzionerà, a meno che non siano state create le tabelle di lavoro come descritto in Impostazione delle tabelle. Questo codice viene fornito solo per mostrare la sintassi per l'uso di SQLServerBulkCopy. Se le tabelle di origine e di destinazione si trovano nella stessa istanza di SQL Server, è più semplice e rapido usare l'istruzione Transact-SQL INSERISCI ... SELEZIONA per copiare i dati.

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

import com.microsoft.sqlserver.jdbc.SQLServerBulkCopy;

public class BulkCopySingle {
    public static void main(String[] args) {
        String connectionUrl = "jdbc:sqlserver://<server>:<port>;encrypt=true;databaseName=AdventureWorks;user=<user>;password=<password>";
        String destinationTable = "dbo.BulkCopyDemoMatchingColumns";
        int countBefore, countAfter;
        ResultSet rsSourceData;

        try (Connection sourceConnection = DriverManager.getConnection(connectionUrl);
                Connection destinationConnection = DriverManager.getConnection(connectionUrl);
                Statement stmt = sourceConnection.createStatement();
                SQLServerBulkCopy bulkCopy = new SQLServerBulkCopy(destinationConnection)) {

            // Empty the destination table.
            stmt.executeUpdate("DELETE FROM " + destinationTable);

            // Perform an initial count on the destination table.
            countBefore = getRowCount(stmt, destinationTable);

            // Get data from the source table as a ResultSet.
            rsSourceData = stmt.executeQuery("SELECT ProductID, Name, ProductNumber FROM Production.Product");

            // In real world applications you would
            // not use SQLServerBulkCopy to move data from one table to the other
            // in the same database. This is for demonstration purposes only.

            // Set up the bulk copy object.
            // Note that the column positions in the source
            // table match the column positions in
            // the destination table so there is no need to
            // map columns.
            bulkCopy.setDestinationTableName(destinationTable);

            // Write from the source to the destination.
            bulkCopy.writeToServer(rsSourceData);

            // Perform a final count on the destination
            // table to see how many rows were added.
            countAfter = getRowCount(stmt, destinationTable);
            System.out.println((countAfter - countBefore) + " rows were added.");
        }
        // Handle any errors that may have occurred.
        catch (SQLException e) {
            e.printStackTrace();
        }
    }

    private static int getRowCount(Statement stmt,
            String tableName) throws SQLException {
        ResultSet rs = stmt.executeQuery("SELECT COUNT(*) FROM " + tableName);
        rs.next();
        int count = rs.getInt(1);
        rs.close();
        return count;
    }
}

Esecuzione di un'operazione di copia bulk con Transact-SQL

Nell'esempio seguente viene illustrato come usare il metodo executeUpdate per eseguire l'istruzione BULK INSERT.

Nota

Il percorso del file per l'origine dati è relativo al server. Affinché l'operazione di copia bulk abbia esito positivo, il processo server deve avere accesso a tale percorso.

try (Connection con = DriverManager.getConnection(connectionUrl);
        Statement stmt = con.createStatement()) {
    // Perform the BULK INSERT
    stmt.executeUpdate(
            "BULK INSERT Northwind.dbo.[Order Details] " + "FROM 'f:\\mydata\\data.tbl' " + "WITH ( FORMATFILE='f:\\mydata\\data.fmt' )");
}

Più operazioni di copia bulk

È possibile eseguire più operazioni di copia bulk usando una singola istanza di una classe SQLServerBulkCopy. Se i parametri delle operazioni cambiano tra copie, ad esempio il nome della tabella di destinazione, è necessario aggiornarli prima di qualsiasi chiamata successiva a uno dei metodi writeToServer, come mostrato nell'esempio seguente. A meno che non vengano modificati in modo esplicito, tutti i valori delle proprietà rimangono invariati rispetto alla precedente operazione di copia bulk per una determinata istanza.

Nota

L'esecuzione di più operazioni di copia bulk usando la stessa istanza di SQLServerBulkCopy in genere è più efficiente rispetto all'uso di un'istanza distinta per ogni operazione.

Se si eseguono più operazioni di copia bulk usando lo stesso oggetto SQLServerBulkCopy, non vi sono restrizioni relativamente al fatto che le informazioni di origine o di destinazione sono uguali o diverse in ogni operazione. È tuttavia necessario assicurarsi che le informazioni di associazione delle colonne siano impostate correttamente ogni volta che si esegue la scrittura nel server.

Importante

Questo esempio non funzionerà, a meno che non siano state create le tabelle di lavoro come descritto in Impostazione delle tabelle. Questo codice viene fornito solo per mostrare la sintassi per l'uso di SQLServerBulkCopy. Se le tabelle di origine e di destinazione si trovano nella stessa istanza di SQL Server, è più semplice e rapido usare l'istruzione Transact-SQL INSERISCI ... SELEZIONA per copiare i dati.

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

import com.microsoft.sqlserver.jdbc.SQLServerBulkCopy;
import com.microsoft.sqlserver.jdbc.SQLServerBulkCopyOptions;

public class BulkCopyMultiple {
    public static void main(String[] args) {
        String connectionUrl = "jdbc:sqlserver://<server>:<port>;encrypt=true;databaseName=AdventureWorks;user=<user>;password=<password>";
        String destinationHeaderTable = "dbo.BulkCopyDemoOrderHeader";
        String destinationDetailTable = "dbo.BulkCopyDemoOrderDetail";
        int countHeaderBefore, countDetailBefore, countHeaderAfter, countDetailAfter;
        ResultSet rsHeader, rsDetail;

        try (Connection sourceConnection1 = DriverManager.getConnection(connectionUrl);
                Connection sourceConnection2 = DriverManager.getConnection(connectionUrl);
                Statement stmt = sourceConnection1.createStatement();
                PreparedStatement preparedStmt1 = sourceConnection1.prepareStatement(
                        "SELECT [SalesOrderID], [OrderDate], [AccountNumber] FROM [Sales].[SalesOrderHeader] WHERE [AccountNumber] = ?;");
                PreparedStatement preparedStmt2 = sourceConnection2.prepareStatement(
                        "SELECT [Sales].[SalesOrderDetail].[SalesOrderID], [SalesOrderDetailID], [OrderQty], [ProductID], [UnitPrice] FROM "
                                + "[Sales].[SalesOrderDetail] INNER JOIN [Sales].[SalesOrderHeader] ON "
                                + "[Sales].[SalesOrderDetail].[SalesOrderID] = [Sales].[SalesOrderHeader].[SalesOrderID] WHERE [AccountNumber] = ?;");
                SQLServerBulkCopy bulkCopy = new SQLServerBulkCopy(connectionUrl);) {

            // Empty the destination tables.
            stmt.executeUpdate("DELETE FROM " + destinationHeaderTable);
            stmt.executeUpdate("DELETE FROM " + destinationDetailTable);

            // Perform an initial count on the destination
            // table with matching columns.
            countHeaderBefore = getRowCount(stmt, destinationHeaderTable);

            // Perform an initial count on the destination
            // table with different column positions.
            countDetailBefore = getRowCount(stmt, destinationDetailTable);

            // Get data from the source table as a ResultSet.
            // The Sales.SalesOrderHeader and Sales.SalesOrderDetail
            // tables are quite large and could easily cause a timeout
            // if all data from the tables is added to the destination.
            // To keep the example simple and quick, a parameter is
            // used to select only orders for a particular account
            // as the source for the bulk insert.
            preparedStmt1.setString(1, "10-4020-000034");
            rsHeader = preparedStmt1.executeQuery();

            // Get the Detail data in a separate connection.
            preparedStmt2.setString(1, "10-4020-000034");
            rsDetail = preparedStmt2.executeQuery();

            // Create the SQLServerBulkCopySQLServerBulkCopy object.
            SQLServerBulkCopyOptions copyOptions = new SQLServerBulkCopyOptions();
            copyOptions.setBulkCopyTimeout(100);
            bulkCopy.setBulkCopyOptions(copyOptions);
            bulkCopy.setDestinationTableName(destinationHeaderTable);

            // Guarantee that columns are mapped correctly by
            // defining the column mappings for the order.
            bulkCopy.addColumnMapping("SalesOrderID", "SalesOrderID");
            bulkCopy.addColumnMapping("OrderDate", "OrderDate");
            bulkCopy.addColumnMapping("AccountNumber", "AccountNumber");

            // Write rsHeader to the destination.
            bulkCopy.writeToServer(rsHeader);

            // Set up the order details destination.
            bulkCopy.setDestinationTableName(destinationDetailTable);

            // Clear the existing column mappings
            bulkCopy.clearColumnMappings();

            // Add order detail column mappings.
            bulkCopy.addColumnMapping("SalesOrderID", "SalesOrderID");
            bulkCopy.addColumnMapping("SalesOrderDetailID", "SalesOrderDetailID");
            bulkCopy.addColumnMapping("OrderQty", "OrderQty");
            bulkCopy.addColumnMapping("ProductID", "ProductID");
            bulkCopy.addColumnMapping("UnitPrice", "UnitPrice");

            // Write rsDetail to the destination.
            bulkCopy.writeToServer(rsDetail);

            // Perform a final count on the destination
            // tables to see how many rows were added.
            countHeaderAfter = getRowCount(stmt, destinationHeaderTable);
            countDetailAfter = getRowCount(stmt, destinationDetailTable);

            System.out.println((countHeaderAfter - countHeaderBefore) + " rows were added to the Header table.");
            System.out.println((countDetailAfter - countDetailBefore) + " rows were added to the Detail table.");
        }
        // Handle any errors that may have occurred.
        catch (SQLException e) {
            e.printStackTrace();
        }
    }

    private static int getRowCount(Statement stmt,
            String tableName) throws SQLException {
        ResultSet rs = stmt.executeQuery("SELECT COUNT(*) FROM " + tableName);
        rs.next();
        int count = rs.getInt(1);
        rs.close();
        return count;
    }
}

Transazioni e operazioni di copia bulk

Le operazioni di copia bulk possono essere eseguite come operazioni isolate oppure come parte di una transazione in più passaggi. Quest'ultima opzione consente di eseguire più di un'operazione di copia bulk all'interno della stessa transazione e di eseguire altre operazioni sul database (come inserimenti, aggiornamenti ed eliminazioni), mantenendo comunque la possibilità di eseguire il commit o il rollback dell'intera transazione.

Per impostazione predefinita, una copia bulk viene eseguita come un'operazione isolata. L'operazione di copia bulk avviene in modalità non transazionale, senza la possibilità di eseguirne il rollback. Se è necessario eseguire il rollback di tutta o parte della copia bulk quando si verifica un errore, è possibile usare una transazione gestita da SQLServerBulkCopy o eseguire l'operazione di copia bulk all'interno di una transazione esistente.

Copia bulk estesa per Azure Data Warehouse

La versione del driver v8.4.1 aggiunge la nuova proprietà di connessione sendTemporalDataTypesAsStringForBulkCopy. Questa proprietà booleana è true per impostazione predefinita.

Quando questa proprietà di connessione è impostata su false i tipi di dati DATE, DATETIME, DATIMETIME2, DATETIMEOFFSET, SMALLDATETIME e TIME vengono inviati come i rispettivi tipi anziché come valori stringa.

L'invio dei tipi di dati temporali come i rispettivi tipi consente all'utente di inviare dati in tali colonne per Azure Synapse Analytics, operazione che prima non era possibile perché il driver convertiva i dati in valori stringa. L'invio di dati stringa in colonne temporali funziona per SQL Server perché SQL Server esegue automaticamente la conversione implicita, ma lo stesso non vale con Azure Synapse Analytics.

Anche senza impostare questa stringa di connessione su "false", a partire da v8.4.1 e versioni successive, i tipi di dati MONEY e SMALLMONEY verranno inviati come tipi di dati MONEY / SMALLMONEY anziché come DECIMAL, e ciò consente anche la copia bulk di questi tipi di dati in Azure Synapse Analytics.

Limitazioni della copia bulk estesa per Azure Data Warehouse

Esistono attualmente due limitazioni:

  1. Con questa proprietà di connessione impostata su false il driver accetterà solo il formato predefinito dei valori letterali stringa per ogni tipo di dati, ad esempio:

    DATE: YYYY-MM-DD

    DATETIME: YYYY-MM-DD hh:mm:ss[.nnn]

    DATETIME2: YYYY-MM-DD hh:mm:ss[.nnnnnnn]

    DATETIMEOFFSET: YYYY-MM-DD hh:mm:ss[.nnnnnnn] [{+/-}hh:mm]

    SMALLDATETIME:YYYY-MM-DD hh:mm:ss

    TIME: hh:mm:ss[.nnnnnnn]

  2. Con questa proprietà di connessione impostata su false il tipo di colonna specificato per la copia bulk deve rispettare il diagramma di mapping dei tipi di dati specificato qui. Ad esempio, in precedenza gli utenti potevano specificare java.sql.Types.TIMESTAMP per eseguire la copia bulk dei dati in una colonna DATE, ma con questa funzionalità abilitata devono specificare java.sql.Types.DATE per eseguire la stessa operazione.

Esecuzione di un'operazione di copia bulk non transazionale

L'applicazione riportata di seguito illustra cosa accade quando si verifica un errore durante un'operazione di copia bulk non transazionale.

Nell'esempio la tabella di origine e la tabella di destinazione includono entrambe una colonna Identity denominata ProductID. Il codice innanzitutto prepara la tabella di destinazione eliminando tutte le righe e, quindi, inserendo una singola riga il cui ProductID è presente nella tabella di origine. Per impostazione predefinita, viene generato un nuovo valore per la colonna Identity nella tabella di destinazione per ogni riga aggiunta. In questo esempio all'apertura della connessione viene impostata un'opzione che impone al processo di caricamento bulk di usare invece i valori Identity dalla tabella di origine.

L'operazione di copia bulk viene eseguita con la proprietà BatchSizeimpostata su 10. Quando è rilevata la riga non valida, viene generata un'eccezione. In questo primo esempio, l'operazione di copia bulk è non transazionale. Viene eseguito il commit di tutti i batch copiati fino al punto dell'errore. Viene eseguito il rollback del batch che contiene la chiave duplicata e l'operazione di copia bulk viene interrotta prima dell'elaborazione di altri batch.

Nota

Questo esempio non funzionerà, a meno che non siano state create le tabelle di lavoro come descritto in Impostazione delle tabelle. Questo codice viene fornito solo per mostrare la sintassi per l'uso di SQLServerBulkCopy. Se le tabelle di origine e di destinazione si trovano nella stessa istanza di SQL Server, è più semplice e rapido usare l'istruzione Transact-SQL INSERISCI ... SELEZIONA per copiare i dati.

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

import com.microsoft.sqlserver.jdbc.SQLServerBulkCopy;
import com.microsoft.sqlserver.jdbc.SQLServerBulkCopyOptions;

public class BulkCopyNonTransacted {
    public static void main(String[] args) {
        String connectionUrl = "jdbc:sqlserver://<server>:<port>;encrypt=true;databaseName=AdventureWorks;user=<user>;password=<password>";
        String destinationTable = "dbo.BulkCopyDemoMatchingColumns";
        int countBefore, countAfter;
        ResultSet rsSourceData;

        try (Connection sourceConnection = DriverManager.getConnection(connectionUrl);
                Statement stmt = sourceConnection.createStatement();
                SQLServerBulkCopy bulkCopy = new SQLServerBulkCopy(connectionUrl)) {

            // Empty the destination table.
            stmt.executeUpdate("DELETE FROM " + destinationTable);

            // Add a single row that will result in duplicate key
            // when all rows from source are bulk copied.
            // Note that this technique will only be successful in
            // illustrating the point if a row with ProductID = 446
            // exists in the AdventureWorks Production.Products table.
            // If you have made changes to the data in this table, change
            // the SQL statement in the code to add a ProductID that
            // does exist in your version of the Production.Products
            // table. Choose any ProductID in the middle of the table
            // (not first or last row) to best illustrate the result.
            stmt.executeUpdate("SET IDENTITY_INSERT " + destinationTable + " ON;" + "INSERT INTO " + destinationTable
                    + "([ProductID], [Name] ,[ProductNumber]) VALUES(446, 'Lock Nut 23','LN-3416'); SET IDENTITY_INSERT " + destinationTable
                    + " OFF");

            // Perform an initial count on the destination table.
            countBefore = getRowCount(stmt, destinationTable);

            // Get data from the source table as a ResultSet.
            rsSourceData = stmt.executeQuery("SELECT ProductID, Name, ProductNumber FROM Production.Product");

            // Set up the bulk copy object using the KeepIdentity option and BatchSize = 10.
            SQLServerBulkCopyOptions copyOptions = new SQLServerBulkCopyOptions();
            copyOptions.setKeepIdentity(true);
            copyOptions.setBatchSize(10);

            bulkCopy.setBulkCopyOptions(copyOptions);
            bulkCopy.setDestinationTableName(destinationTable);

            // Write from the source to the destination.
            // This should fail with a duplicate key error
            // after some of the batches have been copied.
            try {
                bulkCopy.writeToServer(rsSourceData);
            }
            catch (SQLException e) {
                e.printStackTrace();
            }

            // Perform a final count on the destination
            // table to see how many rows were added.
            countAfter = getRowCount(stmt, destinationTable);
            System.out.println((countAfter - countBefore) + " rows were added.");
        }
        // Handle any errors that may have occurred.
        catch (SQLException e) {
            e.printStackTrace();
        }
    }

    private static int getRowCount(Statement stmt,
            String tableName) throws SQLException {
        ResultSet rs = stmt.executeQuery("SELECT COUNT(*) FROM " + tableName);
        rs.next();
        int count = rs.getInt(1);
        rs.close();
        return count;
    }
}

Esecuzione di un'operazione di copia bulk dedicata in una transazione

Per impostazione predefinita, un'operazione di copia bulk non crea in sé transazioni. Quando si vuole eseguire un'operazione di copia bulk dedicata, creare una nuova istanza di SQLServerBulkCopy con una stringa di connessione. In questo scenario il database esegue il commit implicito di ogni batch dell'operazione di copia bulk. È possibile impostare l'opzione UseInternalTransaction su true in SQLServerBulkCopyOptions per fare in modo che l'operazione di copia bulk crei transazioni, eseguendo un commit dopo ogni batch dell'operazione di copia bulk.

SQLServerBulkCopyOptions copyOptions = new SQLServerBulkCopyOptions();
copyOptions.setKeepIdentity(true);
copyOptions.setBatchSize(10);
copyOptions.setUseInternalTransaction(true);

Utilizzo di transazioni esistenti

È possibile passare un oggetto Connection che include transazioni abilitate come parametro in un costruttore SQLServerBulkCopy. In questo caso, l'operazione di copia bulk viene eseguita in una transazione esistente e non viene apportata alcuna modifica allo stato della transazione, ovvero non ne viene eseguito il commit della transazione né questa viene interrotta. Questo consente a un'applicazione di includere l'operazione di copia bulk in una transazione con altre operazioni sul database. Se è necessario eseguire il rollback dell'intera operazione di copia bulk perché si verifica un errore o se la copia bulk deve essere eseguita come parte di un processo più ampio di cui sia possibile eseguire il roll back, è possibile eseguire il ripristino dello stato precedente sull'oggetto Connection in qualsiasi punto dopo l'operazione di copia bulk.

L'applicazione seguente è simile a BulkCopyNonTransacted con un'eccezione: in questo esempio l'operazione di copia bulk è inclusa in una transazione esterna più grande. Quando si verifica l'errore di violazione della chiave primaria, viene eseguito il rollback dell'intera transazione e non vengono aggiunte righe alla tabella di destinazione.

Nota

Questo esempio non funzionerà, a meno che non siano state create le tabelle di lavoro come descritto in Impostazione delle tabelle. Questo codice viene fornito solo per mostrare la sintassi per l'uso di SQLServerBulkCopy. Se le tabelle di origine e di destinazione si trovano nella stessa istanza di SQL Server, è più semplice e rapido usare l'istruzione Transact-SQL INSERISCI ... SELEZIONA per copiare i dati.

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

import com.microsoft.sqlserver.jdbc.SQLServerBulkCopy;
import com.microsoft.sqlserver.jdbc.SQLServerBulkCopyOptions;

public class BulkCopyExistingTransactions {
    public static void main(String[] args) {
        String connectionUrl = "jdbc:sqlserver://<server>:<port>;encrypt=true;databaseName=AdventureWorks;user=<user>;password=<password>";
        String destinationTable = "dbo.BulkCopyDemoMatchingColumns";
        int countBefore, countAfter;
        ResultSet rsSourceData;
        SQLServerBulkCopyOptions copyOptions;

        try (Connection sourceConnection = DriverManager.getConnection(connectionUrl);
                Connection destinationConnection = DriverManager.getConnection(connectionUrl);
                Statement stmt = sourceConnection.createStatement();
                SQLServerBulkCopy bulkCopy = new SQLServerBulkCopy(destinationConnection);) {

            // Empty the destination table.
            stmt.executeUpdate("DELETE FROM " + destinationTable);

            // Add a single row that will result in duplicate key
            // when all rows from source are bulk copied.
            // Note that this technique will only be successful in
            // illustrating the point if a row with ProductID = 446
            // exists in the AdventureWorks Production.Products table.
            // If you have made changes to the data in this table, change
            // the SQL statement in the code to add a ProductID that
            // does exist in your version of the Production.Products
            // table. Choose any ProductID in the middle of the table
            // (not first or last row) to best illustrate the result.
            stmt.executeUpdate("SET IDENTITY_INSERT " + destinationTable + " ON;" + "INSERT INTO " + destinationTable
                    + "([ProductID], [Name] ,[ProductNumber]) VALUES(446, 'Lock Nut 23','LN-3416'); SET IDENTITY_INSERT " + destinationTable
                    + " OFF");

            // Perform an initial count on the destination table.
            countBefore = getRowCount(stmt, destinationTable);

            // Get data from the source table as a ResultSet.
            rsSourceData = stmt.executeQuery("SELECT ProductID, Name, ProductNumber FROM Production.Product");

            // Set up the bulk copy object inside the transaction.
            destinationConnection.setAutoCommit(false);

            copyOptions = new SQLServerBulkCopyOptions();
            copyOptions.setKeepIdentity(true);
            copyOptions.setBatchSize(10);

            bulkCopy.setBulkCopyOptions(copyOptions);
            bulkCopy.setDestinationTableName(destinationTable);

            // Write from the source to the destination.
            // This should fail with a duplicate key error.
            try {
                bulkCopy.writeToServer(rsSourceData);
                destinationConnection.commit();
            }
            catch (SQLException e) {
                e.printStackTrace();
                destinationConnection.rollback();
            }

            // Perform a final count on the destination
            // table to see how many rows were added.
            countAfter = getRowCount(stmt, destinationTable);
            System.out.println((countAfter - countBefore) + " rows were added.");
        }
        catch (Exception e) {
            // Handle any errors that may have occurred.
            e.printStackTrace();
        }
    }

    private static int getRowCount(Statement stmt,
            String tableName) throws SQLException {
        ResultSet rs = stmt.executeQuery("SELECT COUNT(*) FROM " + tableName);
        rs.next();
        int count = rs.getInt(1);
        rs.close();
        return count;
    }
}

Copia bulk da un file CSV

L'applicazione seguente mostra come caricare dati usando la classe SQLServerBulkCopy. In questo esempio, viene utilizzato un file CSV per copiare i dati esportati dalla tabella Production.Product nel database AdventureWorks di SQL Server in una tabella simile del database.

Importante

Questo esempio non funzionerà, a meno che non siano state create le tabelle di lavoro come descritto in Impostazione delle tabelle.

  1. Aprire SQL Server Management Studio e connettersi a SQL Server con il database AdventureWorks.

  2. Espandere i database, fare clic con il pulsante destro del mouse sul database AdventureWorks e scegliere Attività, Esporta dati.

  3. In Origine dati selezionare l'origine dati che consente di connettersi a SQL Server, ad esempio SQL Server Native Client 11.0, controllare la configurazione e quindi fare clic su Avanti

  4. Per la destinazione, selezionare Destinazione file flat e immettere un nome in Nome file con una destinazione, ad esempio C:\Test\TestBulkCSVExample.csv. Verificare che Formato sia impostato su Delimitato, che Qualificatore di testo sia impostato su Nessuno e abilitare Nomi di colonne nella prima riga di dati, quindi selezionare Avanti

  5. Selezionare Scrivi una query per specificare i dati da trasferire e fare clic su Avanti. Immettere in Istruzione SQL SELECT ProductID, Name, ProductNumber FROM Production.Product e quindi fare clic su Avanti

  6. Controllare la configurazione: è possibile lasciare {CR}{LF} come delimitatore di riga e la virgola {,} come delimitatore di colonna. Selezionare Modifica mapping e verificare che l'impostazione di Tipo per i dati sia corretta per ogni colonna, ad esempio Integer per ProductID e stringa Unicode per le altre.

  7. Proseguire fino alla fine ed eseguire l'esportazione.

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

import com.microsoft.sqlserver.jdbc.SQLServerBulkCSVFileRecord;
import com.microsoft.sqlserver.jdbc.SQLServerBulkCopy;

public class BulkCopyCSV {
    public static void main(String[] args) {
        String connectionUrl = "jdbc:sqlserver://<server>:<port>;encrypt=true;databaseName=AdventureWorks;user=<user>;password=<password>";
        String destinationTable = "dbo.BulkCopyDemoMatchingColumns";
        int countBefore, countAfter;

        // Get data from the source file by loading it into a class that implements ISQLServerBulkRecord.
        // Here we are using the SQLServerBulkCSVFileRecord implementation to import the example CSV file.
        try (Connection destinationConnection = DriverManager.getConnection(connectionUrl);
                Statement stmt = destinationConnection.createStatement();
                SQLServerBulkCopy bulkCopy = new SQLServerBulkCopy(destinationConnection);
                SQLServerBulkCSVFileRecord fileRecord = new SQLServerBulkCSVFileRecord("C:\\Test\\TestBulkCSVExample.csv", true);) {

            // Set the metadata for each column to be copied.
            fileRecord.addColumnMetadata(1, null, java.sql.Types.INTEGER, 0, 0);
            fileRecord.addColumnMetadata(2, null, java.sql.Types.NVARCHAR, 50, 0);
            fileRecord.addColumnMetadata(3, null, java.sql.Types.NVARCHAR, 25, 0);

            // Empty the destination table.
            stmt.executeUpdate("DELETE FROM " + destinationTable);

            // Perform an initial count on the destination table.
            countBefore = getRowCount(stmt, destinationTable);

            // Set up the bulk copy object.
            // Note that the column positions in the source
            // data reader match the column positions in
            // the destination table so there is no need to
            // map columns.
            bulkCopy.setDestinationTableName(destinationTable);

            // Write from the source to the destination.
            bulkCopy.writeToServer(fileRecord);

            // Perform a final count on the destination
            // table to see how many rows were added.
            countAfter = getRowCount(stmt, destinationTable);
            System.out.println((countAfter - countBefore) + " rows were added.");
        }
        // Handle any errors that may have occurred.
        catch (SQLException e) {
            e.printStackTrace();
        }
    }

    private static int getRowCount(Statement stmt,
            String tableName) throws SQLException {
        ResultSet rs = stmt.executeQuery("SELECT COUNT(*) FROM " + tableName);
        rs.next();
        int count = rs.getInt(1);
        rs.close();
        return count;
    }
}

Uso di un carattere regex come delimitatore

Nota

Quando si imposta un delimitatore personalizzato, eseguire l'escape se si tratta di un carattere regex, ad esempio "|".

SQLServerBulkCSVFileRecord fileRecord = new SQLServerBulkCSVFileRecord(CSVFilePath, null, "\\|", true);

Copia bulk con delimitatori come dati in un file con estensione csv

La versione del driver 8.4.1 include una nuova API SQLServerBulkCSVFileRecord.setEscapeColumnDelimitersCSV(boolean). Se impostata su true, verranno applicate le regole seguenti:

  • Ogni campo può essere o meno racchiuso tra virgolette doppie.
  • Se i campi non sono racchiusi tra virgolette doppie, le virgolette doppie potrebbero non essere visualizzate all'interno dei campi.
  • I campi contenenti virgolette doppie e delimitatori devono essere racchiusi tra virgolette doppie.
  • Se si usano le virgolette doppie per delimitare i campi, un carattere virgolette doppie visualizzato all'interno di un campo deve essere preceduto da un altro carattere virgolette doppie che ha funzione di carattere di escape.

Copia bulk con colonne Always Encrypted

A partire da Microsoft JDBC Driver 6.0 per SQL Server è supportata la copia bulk con colonne Always Encrypted.

A seconda delle opzioni di copia bulk e del tipo di crittografia delle tabelle di origine e di destinazione il driver JDBC può decrittografare in modo trasparente e quindi crittografare i dati oppure può inviare i dati crittografati senza alcuna modifica. Ad esempio, quando si esegue una copia bulk dei dati da una colonna crittografata a una colonna non crittografata, il driver decrittografa in modo trasparente i dati prima dell'invio a SQL Server. Ad esempio, quando si esegue una copia bulk dei dati da una colonna crittografata a una colonna non crittografata, il driver decrittografa in modo trasparente i dati prima dell'invio a SQL Server. Se entrambe le colonne di origine e di destinazione sono crittografate, a seconda dell'opzione di copia bulk allowEncryptedValueModifications il driver invia i dati senza alcuna modifica oppure decripta i dati e li crittografa nuovamente prima di inviarli a SQL Server.

Per altre informazioni, vedere l'opzione di copia bulk allowEncryptedValueModifications di seguito e Uso di Always Encrypted con JDBC Driver.

Importante

Limitazione di Microsoft JDBC Driver 6.0 per SQL Server durante la copia bulk di dati da un file CSV a colonne crittografate:

Per i tipi date e time è supportato solo il formato di valori letterali di stringa predefinito di Transact-SQL

I tipi di dati DATETIME e SMALLDATETIME non sono supportati

API della copia bulk per il driver JDBC

SQLServerBulkCopy

Consente di eseguire in modo efficiente il caricamento bulk di una tabella di SQL Server con dati da un'altra origine.

Microsoft SQL Server include una popolare utilità del prompt dei comandi denominata bcp per lo spostamento dei dati da una tabella all'altra, sia in un singolo server che tra diversi server. La classe SQLServerBulkCopy consente di scrivere soluzioni di codice in Java che offrono funzionalità simili. Esistono altri modi per caricare dati in una tabella di SQL Server, ad esempio le istruzioni INSERT, ma SQLServerBulkCopy offre un vantaggio significativo in termini di prestazioni.

La classe SQLServerBulkCopy può essere usata per scrivere dati solo in tabelle di SQL Server. Tuttavia, l'origine dati non è limitata a SQL Server: può essere usata qualsiasi origine dati, purché i dati possano essere letti con un'istanza ResultSet o un'implementazione di ISQLServerBulkRecord.

Costruttore Descrizione
SQLServerBulkCopy(Connection connection) Inizializza una nuova istanza della classe SQLServerBulkCopy usando l'istanza aperta specificata di SQLServerConnection. Se Connection include transazioni abilitate, le operazioni di copia verranno eseguite all'interno della transazione.
SQLServerBulkCopy(String connectionURL) Inizializza e apre una nuova istanza di SQLServerConnection in base all'oggetto connectionURL fornito. Il costruttore usa SQLServerConnection per inizializzare una nuova istanza della classe SQLServerBulkCopy.
Proprietà Descrizione
String DestinationTableName Nome della tabella di destinazione nel server.

Se la proprietà DestinationTableName non è stata impostata quando viene chiamato writeToServer, viene generata un'eccezione SQLServerException.

DestinationTableName è un nome in tre parti (<database>.<owningschema>.<name>). Se si desidera, è possibile qualificare il nome della tabella con i relativi database e schema. Tuttavia, se il nome della tabella contiene un carattere di sottolineatura ("_") o altri caratteri speciali, è necessario racchiudere il nome tra parentesi quadre. Per altre informazioni, vedere Identificatori del database.
ColumnMappings I mapping delle colonne definiscono le relazioni tra le colonne nell'origine dati e le colonne nella destinazione.

Se i mapping non sono definiti, il mapping delle colonne viene eseguito in modo implicito in base alla posizione ordinale. Per il corretto funzionamento, gli schemi di origine e di destinazione devono corrispondere. In caso contrario viene generata un'eccezione.

Se i mapping non sono vuoti, non tutte le colonne presenti nell'origine dati devono essere specificate. Le colonne di cui non viene eseguito il mapping sono ignorate.

È possibile fare riferimento alle colonne di origine e di destinazione in base al nome o alla posizione ordinale.
metodo Descrizione
void addColumnMapping(int sourceColumn, int destinationColumn) Aggiunge un nuovo mapping di colonne, usando numeri ordinali per specificare le colonne di origine e di destinazione.
void addColumnMapping (int sourceColumn, String destinationColumn) Aggiunge un nuovo mapping di colonne, usando un numero ordinale per la colonna di origine e un nome di colonna per la colonna di destinazione.
void addColumnMapping (String sourceColumn, int destinationColumn) Aggiunge un nuovo mapping di colonne, usando un nome colonna per descrivere la colonna di origine e un numero ordinale per specificare la colonna di destinazione.
void addColumnMapping (String sourceColumn, String destinationColumn) Aggiunge un nuovo mapping di colonne, usando nomi di colonna per specificare le colonne di origine e di destinazione.
void clearColumnMappings() Cancella il contenuto dei mapping di colonne.
void close() Chiude l'istanza di SQLServerBulkCopy.
SQLServerBulkCopyOptions getBulkCopyOptions() Recupera il set corrente di SQLServerBulkCopyOptions.
String getDestinationTableName() Recupera il nome della tabella di destinazione corrente.
void setBulkCopyOptions(SQLServerBulkCopyOptions copyOptions) Aggiorna il comportamento dell'istanza di SQLServerBulkCopy in base alle opzioni fornite.
void setDestinationTableName(String tableName) Imposta il nome della tabella di destinazione.
void writeToServer(ResultSet sourceData) Copia tutte le righe nell'oggetto ResultSet indicato in una tabella di destinazione specificata dalla proprietà DestinationTableName dell'oggetto SQLServerBulkCopy.
void writeToServer(RowSet sourceData) Copia tutte le righe nell'oggetto RowSet indicato in una tabella di destinazione specificata dalla proprietà DestinationTableName dell'oggetto SQLServerBulkCopy.
void writeToServer(ISQLServerBulkRecord sourceData) Copia tutte le righe nell'implementazione di ISQLServerBulkRecord indicato in una tabella di destinazione specificata dalla proprietà DestinationTableName dell'oggetto SQLServerBulkCopy.

SQLServerBulkCopyOptions

Raccolta di impostazioni che controllano il comportamento dei metodi writeToServer in un'istanza di SQLServerBulkCopy.

Costruttore Descrizione
SQLServerBulkCopyOptions() Inizializza una nuova istanza della classe SQLServerBulkCopyOptions usando i valori predefiniti per tutte le impostazioni.

Sono disponibili metodi di richiamo e di impostazione per le opzioni seguenti:

Opzione Descrizione Default
boolean CheckConstraints Controllare i vincoli durante l'inserimento dei dati. False - i vincoli non vengono controllati
boolean FireTriggers Causa l'attivazione dei trigger di inserimento da parte del server per le righe inserite nel database. False - non vengono generati trigger
boolean KeepIdentity Mantenere i valori Identity di origine. False - i valori Identity vengono assegnati dalla destinazione
boolean KeepNulls Mantenere i valori null nella tabella di destinazione indipendentemente dalle impostazioni per i valori predefiniti. False - i valori null vengono sostituiti dai valori predefiniti, dove applicabile.
boolean TableLock Ottenere un blocco di aggiornamento bulk per la durata dell'operazione di copia bulk. False - vengono utilizzati i blocchi a livello di riga.
boolean UseInternalTransaction Se impostata su true, ogni batch dell'operazione di copia bulk viene eseguito all'interno di una transazione. Se SQLServerBulkCopy usa una connessione esistente, come specificato dal costruttore, si verifica un'eccezione SQLServerException. Se SQLServerBulkCopy ha creato una connessione dedicata, per ogni batch verrà creata una transazione e ne verrà eseguito il commit. False - nessuna transazione
int BatchSize Numero di righe in ogni batch. Al termine di ogni batch, le righe nel batch vengono inviate al server.

Un batch è completo quando le righe BatchSize sono state elaborate o non sono più disponibili righe da inviare all'origine dati di destinazione. Se l'istanza di SQLServerBulkCopy è stata dichiarata con l'opzione UseInternalTransaction impostata su false, le righe vengono inviate alle righe BatchSize del server tutte insieme, ma non viene eseguita alcuna azione relativa alla transazione. Se UseInternalTransaction è impostato su true, ogni batch di righe viene eseguito all'interno di una transazione esplicita.		 0: indica che ogni operazione writeToServer è un singolo batch
int BulkCopyTimeout Numero di secondi per il completamento dell'operazione prima del timeout. Il valore 0 indica che non è previsto alcun limite; la copia bulk attende per un tempo illimitato. 60 secondi.
boolean allowEncryptedValueModifications Questa opzione è disponibile con Microsoft JDBC Driver 6.0 (o versioni successive) per SQL Server.

Se impostata su true, allowEncryptedValueModifications consente la copia bulk di dati crittografati tra tabelle o database, senza decrittografare i dati. Solitamente un'applicazione seleziona i dati dalle colonne crittografate di un'unica tabella senza decrittografarli (l'app si connette al database con la parola chiave di impostazione della crittografia delle colonne impostata sullo stato disabilitato) e quindi usa questa opzione per eseguire l'inserimento bulk dei dati che sono ancora crittografati. Per altre informazioni, vedere Utilizzo di Always Encrypted con il driver JDBC.

Prestare attenzione quando si imposta allowEncryptedValueModifications su true, in quanto questa operazione può danneggiare il database, perché il driver non verifica se i dati vengono effettivamente crittografati o se vengono crittografati correttamente usando lo stesso tipo di crittografia, algoritmo e chiave della colonna di destinazione.

Getter e setter:

Metodi Descrizione
boolean isCheckConstraints() Indica se i vincoli devono essere controllati durante l'inserimento dei dati.
void setCheckConstraints(boolean checkConstraints) Specifica se i vincoli devono essere controllati durante l'inserimento dei dati.
boolean isFireTriggers() Indica se il server deve generare i trigger di inserimento per le righe da inserire nel database.
void setFireTriggers(boolean fireTriggers) Specifica se il server deve essere impostato per la generazione dei trigger per le righe da inserire nel database.
boolean isKeepIdentity() Indica se mantenere i valori dell'identità di origine.
void setKeepIdentity(boolean keepIdentity) Specifica se mantenere i valori dell'identità.
boolean isKeepNulls() Indica se mantenere i valori Null nella tabella di destinazione indipendentemente dalle impostazioni per i valori predefiniti o se sostituirli con i valori predefiniti (se applicabile).
void setKeepNulls(boolean keepNulls) Specifica se mantenere i valori Null nella tabella di destinazione indipendentemente dalle impostazioni per i valori predefiniti o se sostituirli con i valori predefiniti (se applicabile).
boolean isTableLock() Indica se SQLServerBulkCopy deve ottenere un blocco di aggiornamento bulk per la durata dell'operazione di copia bulk.
void setTableLock(boolean tableLock) Specifica se SQLServerBulkCopy deve ottenere un blocco di aggiornamento bulk per la durata dell'operazione di copia bulk.
boolean isUseInternalTransaction() Indica se ogni batch dell'operazione di copia bulk viene eseguito all'interno di una transazione.
void setUseInternalTransaction(boolean useInternalTransaction) Determina se ogni batch delle operazioni di copia bulk viene eseguito all'interno di una transazione.
int getBatchSize() Ottiene il numero di righe in ogni batch. Al termine di ogni batch, le righe nel batch vengono inviate al server.
void setBatchSize(int batchSize) Imposta il numero di righe in ogni batch. Al termine di ogni batch, le righe nel batch vengono inviate al server.
int getBulkCopyTimeout() Ottiene il numero di secondi per il completamento dell'operazione prima del timeout.
void setBulkCopyTimeout(int timeout) Imposta il numero di secondi per il completamento dell'operazione prima del timeout.
boolean isAllowEncryptedValueModifications() Indica se l'impostazione allowEncryptedValueModifications è abilitata o disabilitata.
void setAllowEncryptedValueModifications(boolean allowEncryptedValueModifications) Configura l'impostazione allowEncryptedValueModifications usata per la copia bulk con colonne Always Encrypted.

ISQLServerBulkRecord

L'interfaccia ISQLServerBulkRecord può essere usata per creare classi che leggono in dati di qualsiasi origine (ad esempio un file) e consentono a un'istanza di SQLServerBulkCopy di eseguire il caricamento bulk di una tabella di SQL Server con tali dati.

Metodi di interfaccia Descrizione
set<Integer> getColumnOrdinals() Ottenere gli ordinali per ognuna delle colonne rappresentate nel record di dati.
String getColumnName(int column) Ottenere il nome della colonna specificata.
int getColumnType(int column) Ottenere il tipo di dati JDBC della colonna specificata.
int getPrecision(int column) Ottenere la precisione per la colonna specificata.
object[] getRowData() Ottenere i dati per la riga corrente come una matrice di oggetti.

Ogni oggetto deve corrispondere al tipo di linguaggio Java utilizzato per rappresentare il tipo di dati JDBC indicato per la colonna specificata. Per altre informazioni sui mapping appropriati, vedere Informazioni sui tipi di dati di JDBC Driver.
int getScale(int column) Ottenere la scala per la colonna specificata.
boolean isAutoIncrement(int column) Indica se la colonna rappresenta una colonna Identity.
boolean next() Passa alla riga di dati successiva.

SQLServerBulkCSVFileRecord

Semplice implementazione dell'interfaccia ISQLServerBulkRecord, che può essere usata per leggere nei tipi di dati Java di base da un file delimitato in cui ogni riga rappresenta una riga di dati.

Note sull'implementazione e limitazioni:

  1. La quantità massima di dati consentiti in una determinata riga è limitata dalla memoria disponibile, poiché i dati vengono letti una riga alla volta.

  2. Lo streaming di tipi di dati di grandi dimensioni, come varchar(max), varbinary(max), nvarchar(max), sqlxml e ntext, non è supportato.

  3. Il delimitatore specificato per il file CSV non deve essere contenuto nei dati e deve essere sottoposto a escape in modo appropriato se è un carattere con limitazioni nelle espressioni regolari di Java.

  4. Nell'implementazione del file CSV le virgolette doppie vengono considerate parte dei dati. Ad esempio, la riga hello,"world","hello,world" viene interpretata come contenente quattro colonne con i valori hello, "world", "hello e world" se il delimitatore è una virgola.

  5. I caratteri a capo vengono usati come caratteri di terminazione della riga e non sono consentiti nei dati.

Costruttore Descrizione
SQLServerBulkCSVFileRecord(String fileToParse, String encoding, String delimiter, boolean firstLineIsColumnNames) Inizializza una nuova istanza della classe SQLServerBulkCSVFileRecord che analizza ogni riga in fileToParse con la codifica e il delimitatore forniti. Se firstLineIsColumnNames è impostato su True, la prima riga nel file verrà analizzata come nomi di colonna. Se la codifica è NULL, verrà utilizzata la codifica predefinita.
SQLServerBulkCSVFileRecord(String fileToParse, String encoding, boolean firstLineIsColumnNames) Inizializza una nuova istanza della classe SQLServerBulkCSVFileRecord che analizza ogni riga in fileToParse con una virgola come delimitatore e la codifica specificata. Se firstLineIsColumnNames è impostato su True, la prima riga nel file verrà analizzata come nomi di colonna. Se la codifica è NULL, verrà utilizzata la codifica predefinita.
SQLServerBulkCSVFileRecord(String fileToParse, boolean firstLineIsColumnNames Inizializza una nuova istanza della classe SQLServerBulkCSVFileRecord che analizza ogni riga in fileToParse con una virgola come delimitatore e la codifica predefinita. Se firstLineIsColumnNames è impostato su True, la prima riga nel file verrà analizzata come nomi di colonna.
metodo Descrizione
void addColumnMetadata(int positionInFile, String columnName, int jdbcType, int precision, int scale) Aggiunge i metadati per la colonna specificata nel file.
void close() Rilascia le risorse associate al lettore di file.
void setTimestampWithTimezoneFormat(DateTimeFormatter dateTimeFormatter) Imposta il formato per l'analisi dei dati Timestamp del file come java.sql.Types.TIMESTAMP_WITH_TIMEZONE.
void setTimestampWithTimezoneFormat(String dateTimeFormat) Imposta il formato per l'analisi dei dati Time del file come java.sql.Types.TIME_WITH_TIMEZONE.
void setTimeWithTimezoneFormat(DateTimeFormatter dateTimeFormatter) Imposta il formato per l'analisi dei dati Time del file come java.sql.Types.TIME_WITH_TIMEZONE.
void setTimeWithTimezoneFormat(String timeFormat) Imposta il formato per l'analisi dei dati Time del file come java.sql.Types.TIME_WITH_TIMEZONE.

Vedi anche

Panoramica del driver JDBC