此示例显示如何将 ODBC bcp_init 函数用于格式化文件。
使用格式化文件批量复制
分配环境句柄和连接句柄。
设置SQL_COPT_SS_BCP和SQL_BCP_ON以启用大容量复制作。
连接到 Microsoft SQL Server。
调用 bcp_init 以设置以下信息：
要从或向其中批量复制的表或视图的名称。
数据文件的名称，其中包含要复制到数据库中的数据，或者在从数据库复制时接收数据。
要接收任何大容量复制错误消息的数据文件的名称（如果不希望消息文件，请指定 NULL）。
副本的方向：从文件DB_IN到表或视图。
调用 bcp_readfmt 读取描述大容量复制作要使用的数据文件的格式化文件。
调用 bcp_exec 以执行大容量复制作。
示例：
IA64 不支持此示例。
需要一个名为 AdventureWorks 的 ODBC 数据源，其默认数据库是 AdventureWorks 示例数据库。 （可以从 Microsoft SQL Server 示例和社区项目 主页下载 AdventureWorks 示例数据库。此数据源必须基于作系统提供的 ODBC 驱动程序（驱动程序名称为“SQL Server”）。 如果要在 64 位作系统上生成并运行此示例作为 32 位应用程序，则必须在 %windir%\SysWOW64\odbcad32.exe中使用 ODBC 管理员创建 ODBC 数据源。
此示例连接到计算机的默认 SQL Server 实例。 若要连接到命名实例，请更改 ODBC 数据源的定义，以使用以下格式指定实例：服务器\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 AdventureWorks
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 AdventureWorks
IF EXISTS (SELECT name FROM sysobjects WHERE name = 'BCPDate')
DROP TABLE BCPDate
GO