Создание файла форматирования массового копирования (ODBC)

В этом образце показано использование функций массового копирования для создания как файла данных, так и файла форматирования. Этот образец разработан для ODBC версии 3.0 или более поздней.

Примечание по безопасности
По возможности используйте проверку подлинности Windows. Если проверка подлинности Windows недоступна, запросите у пользователя ввод учетных данных во время выполнения. Избегайте хранения учетных данных в файле. Если необходимо сохранить учетные данные, зашифруйте их с помощью API-интерфейса шифрования Win32.

По возможности используйте проверку подлинности Windows. Если проверка подлинности Windows недоступна, запросите у пользователя ввод учетных данных во время выполнения. Избегайте хранения учетных данных в файле. Если необходимо сохранить учетные данные, зашифруйте их с помощью API-интерфейса шифрования Win32.

Создание файла формата массового копирования

Выделите дескриптор среды и дескриптор соединения.
Чтобы включить операции массового копирования, укажите параметры SQL_COPT_SS_BCP и SQL_BCP_ON.
Соединитесь с SQL Server.
Вызовите функцию bcp_init, указав следующие сведения.
- Имя таблицы или представления, из которого или в которое будет производиться массовое копирование.
- Имя файла данных, в котором содержатся данные для копирования в базу данных или который получает данные при копировании из базы данных.
- Имя файла данных, в который сохраняются все сообщения об ошибках массового копирования (укажите значение NULL, если файл для сообщений не требуется).
- Направление копирования: DB_OUT — в файл из таблицы или представления.
Вызовите функцию bcp_columns, чтобы задать количество столбцов.
Вызовите функцию bcp_colfmt для каждого столбца, чтобы определить его характеристики в файле данных.
Вызовите функцию bcp_writefmt, чтобы создать файл форматирования, описывающий файл данных, который будет создан операцией массового копирования.
Чтобы выполнить операцию массового копирования, вызовите функцию bcp_exec.

Операция копирования, которая выполняется этим способом, создает как файл данных, содержащий данные массового копирования, так и файл форматирования, описывающий макет файла данных.

Пример

Также необходим источник данных ODBC с именем AdventureWorks, для которого базой данных по умолчанию является образец базы данных AdventureWorks. (Образец базы данных AdventureWorks можно загрузить с домашней страницы Образцы кода и проекты сообщества Microsoft SQL Server (возможно, на английском языке).) Этот источник данных должен быть основан на драйвере ODBC, предоставленном операционной системой (имя драйвера — «SQL Server»). При построении и запуске этого образца как 32-разрядного приложения в 64-разрядной операционной системе необходимо создать источник данных ODBC с помощью программы администрирования ODBC (исполняемый файл %windir%\SysWOW64\odbcad32.exe).

Этот образец соединяется с установленным на компьютер экземпляром SQL Server по умолчанию. Чтобы соединиться с именованным экземпляром, измените определение источника данных ODBC, чтобы указать экземпляр с помощью следующего формата: сервер\именованный_экземпляр. По умолчанию SQL Server Express устанавливается на именованный экземпляр.

Выполните первый листинг кода (Transact-SQL), чтобы создать таблицу, которой пользуется образец.

Скомпилируйте второй листинг кода (C++) с библиотеками odbc32.lib и odbcbcp.lib.

Выполните третий листинг кода (Transact-SQL), чтобы удалить таблицу, которую использовал образец.

use AdventureWorks

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

CREATE TABLE BCPDate (cola int, colb datetime)
insert BCPDate(cola) values(1) 
insert BCPDate(cola) values(2) 
insert BCPDate(cola) values(3) 
insert BCPDate(cola) values(4)

// compile with: odbc32.lib odbcbcp.lib
#include <stdio.h>
#include <string.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;

   // BCP variables.
   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 bulk copy 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("SQLSetEnvAttr(ODBC version) 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_OUT);
   if (retcode != SUCCEED) {
      printf("bcp_init() Failed\n\n");
      Cleanup();
      return(9);
   }

   // Set the number of output columns.
   retcode = bcp_columns(hdbc1, 2);
   if (retcode != SUCCEED) {
      printf("bcp_init() Failed\n\n");
      Cleanup();
      return(9);
   }

   // Describe the format of column 1 in the data file.
   retcode = bcp_colfmt(hdbc1, 1, SQLCHARACTER, -1, 5, NULL, 0, 1);
   if (retcode != SUCCEED) {
      printf("bcp_init() Failed\n\n");
      Cleanup();
      return(9);
   }

   // Describe the format of column 2 in the data file.
   retcode = bcp_colfmt(hdbc1, 2, SQLCHARACTER, -1, 20, NULL, 0, 2);
   if (retcode != SUCCEED) {
      printf("bcp_init() Failed\n\n");
      Cleanup();
      return(9);
   }

   // Create the format file.
   retcode = bcp_writefmt(hdbc1, "c:\\BCPFMT.fmt");
   if (retcode != SUCCEED) {
      printf("bcp_init() Failed\n\n");
      Cleanup();
      return(9);
   }

   // Execute the bulk copy.
   retcode = bcp_exec(hdbc1, &cRows);
   if (retcode != SUCCEED) {
      printf("bcp_init() Failed\n\n");
      Cleanup();
      return(9);
   }

   printf("Number of rows bulk copied out = %d.\n", cRows);

   // Cleanup
   SQLDisconnect(hdbc1);
   SQLFreeHandle(SQL_HANDLE_DBC, hdbc1);
   SQLFreeHandle(SQL_HANDLE_ENV, henv);
   return(0);
}

use AdventureWorks
IF EXISTS (SELECT name FROM sysobjects WHERE name = 'BCPDate')
     DROP TABLE BCPDate
GO

См. также

Основные понятия

Использование файлов данных и файлов форматирования

Другие ресурсы

Инструкции по массовому копированию с помощью драйвера ODBC для SQL Server (ODBC)

Last updated on 2013-05-07