Java SQLServerBulkCopyを使用したデータベース・バッチ・オペレーション

Microsoft SQL Serverのbcpコマンドは、大規模なファイルをすばやくデータベースにコピーして挿入できます.C#はSqlBulkCopyメソッドでこの機能を実現しますが、javaではSQLServerBulkCopyクラスで同様の機能を実現できます.insert、updateなどのコマンドに比べて、このクラスの効率はずっと高いです.(よく使われるJDBCのBatchよりも方法が高いことが多い).
SQLServerBulkCopyクラスはSQL Severデータベースへの挿入にのみ使用できますが、データソースはSQL Severデータベースではありません.旧バージョンのMicrosoftSQL Server JDBCドライバはこのクラスを提供していません.MicrosoftSQL Server JDBCドライバ6.0のバージョンをダウンロードする必要があります.https://www.microsoft.com/zh-cn/download/confirmation.aspx?id=11774.MS公式の説明書はこの住所にあります.https://docs.microsoft.com/en-us/sql/connect/jdbc/using-bulk-copy-with-the-jdbc-driver.
SQLServerBulKCopyクラスは、Java自体が提供するResultSet、RowSet、JDBCが提供するISQLServerBulkRecordインタフェース実装クラスの3種類のパッケージデータをデータベースに挿入します.以下に実装を示します.

 /**
     *     CachedRowSet  
     *   BaseDao     JDBC  ,      ,       
     * @throws SQLException
     */
    public CachedRowSetImpl getCachedRowSet() throws SQLException{
        //         CachedRowSetImpl           
        ResultSet rs = baseDao.executeSQL("select * from FactMonthTimeTable where 1=0");
        CachedRowSetImpl crs = new CachedRowSetImpl();
        crs.populate(rs);
        //  crs         
        baseDao.closeResource();
        return crs;
    }

    /**
     *  CachedRowSet        
     *          ，              CachedRowSet   
     * @param crs
     * @param fmt
     * @return
     * @throws SQLException
     */
    public CachedRowSetImpl insertIntoCachedRowSet(CachedRowSetImpl crs,Student stu) throws SQLException{
        //     “   ”，         
        crs.moveToInsertRow();
        //        
        crs.updateString("name", stu.getName());
        crs.updateInt("id", stu.getId());
        //     
        crs.insertRow();
        //        
        crs.moveToCurrentRow();
        return crs;
    }

    /**
     *   BulkCopy RowSet      
     * @param crs
     * @param batchSize
     */
    public void insertBatch(CachedRowSetImpl crs,int batchSize)throws SQLException{
        //        
        String url = "jdbc:sqlserver://localhost:1433;DatabaseName=datebaseName"
                         +";user=userName;password=userPassword";
        SQLServerBulkCopyOptions copyOptions = new SQLServerBulkCopyOptions();
        copyOptions.setKeepIdentity(true);
        copyOptions.setBatchSize(8000);
        copyOptions.setUseInternalTransaction(true);
        SQLServerBulkCopy bulkCopy =
                new SQLServerBulkCopy(connectionUrl);
        bulkCopy.setBulkCopyOptions(copyOptions);
        bulkCopy.setDestinationTableName("tableName");
        bulkCopy.writeToServer(crs);
        crs.close();
        bulkCopy.close();
    }