共用方式為

使用格式檔案大量複製 （ODBC）

  • 發行項

適用於：SQL Server Azure SQL 資料庫 Azure SQL 受控執行個體 Azure Synapse Analytics Analytics Platform System （PDW）

此範例示範如何搭配格式檔案使用 ODBC bcp_init 函式。

使用格式檔案大量複製

  1. 配置環境句柄和連接句柄。

  2. 設定SQL_COPT_SS_BCP和SQL_BCP_ON以啟用大量複製作業。

  3. 連接至 SQL Server。

  4. 呼叫 bcp_init 以設定下列資訊：

    • 要大量複製或複製到的數據表或檢視表名稱。

    • 包含要複製到資料庫之數據的數據檔名稱，或從資料庫複製時接收數據。

    • 要接收任何大量複製錯誤訊息的數據檔名稱（如果您不想要訊息檔，請指定 NULL）。

    • 複製的方向：從檔案DB_IN至數據表或檢視表。

  5. 呼叫 bcp_readfmt 讀取格式檔案，描述大量複製作業要使用的數據檔。

  6. 呼叫 bcp_exec 以執行大量複製作業。

範例

IA64 不支援此範例。

您將需要名為 AdventureWorks 的 ODBC 數據源，其預設資料庫是 AdventureWorks 範例資料庫。 （您可以從 下載 AdventureWorks 範例資料庫 Microsoft SQL Server 範例和社群專案 首頁。）此數據源必須以操作系統提供的 ODBC 驅動程式為基礎（驅動程式名稱為 “SQL Server” ）。 如果您要在 64 位作業系統上建置並執行此範例做為 32 位應用程式，您必須在 %windir%\SysWOW64\odbcad32.exe 中使用 ODBC 系統管理員建立 ODBC 數據源。

此範例會連線到計算機的預設 SQL Server 實例。 若要連線到具名實例，請變更 ODBC 數據源的定義，以使用下列格式指定實例：server\namedinstance。 根據預設，SQL Server Express 會安裝至具名執行個體。

執行第一個 （Transact-SQL） 程式代碼清單，以建立範例將使用的數據表。

複製第二個程式代碼清單，並將其貼到名為 Bcpfmt.fmt 的檔案中。 數據表中的每個數據行都會以製表符分隔。

複製第三個程式代碼清單，並將其貼到名為 Bcpodbc.bcp 的檔案中。 索引標籤字元在檔案中的每個歸位字元前面。

使用 odbc32.lib 和 odbcbcp.lib 編譯第四個 （C++） 程式代碼清單。 如果您使用 MSBuild.exe 建置，請將 Bcpfmt.fmt 和 Bcpodbc.bcp 從專案目錄複製到具有 .exe 的目錄，然後叫用.exe。

執行第五個 （Transact-SQL） 程式代碼清單，以刪除範例所使用的數據表。

USE AdventureWorks2022;
CREATE TABLE BCPDate (cola int, colb datetime)  

8.0  
2  
1SQLCHAR04"\t"1colaSQL_Latin1_General_Cp437_Bin  
2SQLCHAR08"\r\n"2colbSQL_Latin1_General_Cp437_Bin  

1  
2  
  

// compile with: odbc32.lib odbcbcp.lib  
#include <stdio.h>  
#include <windows.h>  
#include <sql.h>  
#include <sqlext.h>  
#include <odbcss.h>  
  
SQLHENV henv = SQL_NULL_HENV;  
HDBC hdbc1 = SQL_NULL_HDBC;   
  
void Cleanup() {  
   if (hdbc1 != SQL_NULL_HDBC) {  
      SQLDisconnect(hdbc1);  
      SQLFreeHandle(SQL_HANDLE_DBC, hdbc1);  
   }  
  
   if (henv != SQL_NULL_HENV)  
      SQLFreeHandle(SQL_HANDLE_ENV, henv);  
}  
  
int main() {  
   RETCODE retcode;  
   SDWORD cRows;  
  
   // Allocate the ODBC environment and save handle.  
   retcode = SQLAllocHandle (SQL_HANDLE_ENV, NULL, &henv);  
   if ( (retcode != SQL_SUCCESS_WITH_INFO) && (retcode != SQL_SUCCESS)) {  
      printf("SQLAllocHandle(Env) Failed\n\n");  
      Cleanup();  
      return(9);  
   }  
  
   // Notify ODBC that this is an ODBC 3.0 app.  
   retcode = SQLSetEnvAttr(henv, SQL_ATTR_ODBC_VERSION, (SQLPOINTER) SQL_OV_ODBC3, SQL_IS_INTEGER);  
   if ( (retcode != SQL_SUCCESS_WITH_INFO) && (retcode != SQL_SUCCESS)) {  
      printf("SQLSetEnvAttr(ODBC version) Failed\n\n");  
      Cleanup();  
      return(9);      
   }  
  
   // Allocate ODBC connection handle, set BCP mode, and connect.  
   retcode = SQLAllocHandle(SQL_HANDLE_DBC, henv, &hdbc1);  
   if ( (retcode != SQL_SUCCESS_WITH_INFO) && (retcode != SQL_SUCCESS)) {  
      printf("SQLAllocHandle(hdbc1) Failed\n\n");  
      Cleanup();  
      return(9);  
   }  
  
   retcode = SQLSetConnectAttr(hdbc1, SQL_COPT_SS_BCP, (void *)SQL_BCP_ON, SQL_IS_INTEGER);  
   if ( (retcode != SQL_SUCCESS_WITH_INFO) && (retcode != SQL_SUCCESS)) {  
      printf("SQLSetConnectAttr(hdbc1) Failed\n\n");  
      Cleanup();  
      return(9);  
   }  
  
   // Sample uses Integrated Security. Create SQL Server DSN using Windows NT authentication.  
   retcode = SQLConnect(hdbc1, (UCHAR*)"AdventureWorks", SQL_NTS, (UCHAR*)"", SQL_NTS, (UCHAR*)"", SQL_NTS);  
   if ( (retcode != SQL_SUCCESS) && (retcode != SQL_SUCCESS_WITH_INFO) ) {  
      printf("SQLConnect() Failed\n\n");  
      Cleanup();  
      return(9);  
   }  
  
   // Initialize the bulk copy.  
   retcode = bcp_init(hdbc1, "BCPDate", "BCPODBC.bcp", NULL, DB_IN);  
   if ( (retcode != SUCCEED) ) {  
      printf("bcp_init(hdbc1) Failed\n\n");  
      Cleanup();  
      return(9);  
   }  
  
   // Read the format file.  
   retcode = bcp_readfmt(hdbc1, "BCPFMT.fmt");  
   if ( (retcode != SUCCEED) ) {  
      printf("bcp_readfmt(hdbc1) Failed\n\n");  
      Cleanup();  
      return(9);  
   }  
  
   // Execute the bulk copy.  
   retcode = bcp_exec(hdbc1, &cRows);  
   if ( (retcode != SUCCEED) ) {  
      printf("bcp_exec(hdbc1) Failed\n\n");  
      Cleanup();  
      return(9);  
   }  
  
   printf("Number of rows bulk copied in = %d.\n", cRows);  
  
   // Cleanup  
   SQLDisconnect(hdbc1);  
   SQLFreeHandle(SQL_HANDLE_DBC, hdbc1);  
   SQLFreeHandle(SQL_HANDLE_ENV, henv);  
}  

USE AdventureWorks2022;
IF EXISTS (SELECT name FROM sysobjects WHERE name = 'BCPDate')  
     DROP TABLE BCPDate  
GO

另請參閱

使用 SQL Server ODBC 驅動程式操作說明主題大量複製 （ODBC）
使用資料檔案和格式檔案