bcp_setbulkmode
bcp_setbulkmode를 사용하면 단일 함수 호출에서 모든 열 특성을 설정함으로써 대량 복사 작업에서 열 형식을 지정할 수 있습니다.
구문
RETCODE bcp_setbulkmode (
HDBC hdbc,
INT property,
void * pField,
INT cbField,
void * pRow,
INT cbRow
);
인수
hdbc
대량 복사가 가능한 ODBC 연결 핸들입니다.property
BYTE 유형의 상수입니다. 상수 목록은 주의 섹션의 표를 참조하십시오.pField
필드 종결자 값에 대한 포인터입니다.cbField
필드 종결자 값의 길이(바이트)입니다.pRow
행 종결자 값에 대한 포인터입니다.cbRow
행 종결자 값의 길이(바이트)입니다.
반환 값
SUCCEED 또는 FAIL
주의
bcp_setbulkmode를 사용하여 쿼리 또는 테이블을 대량 복사할 수 있습니다. 쿼리 문을 대량 복사하는 데 사용되는 bcp_setbulkmode는 BCP_HINT로 bcp_control을 호출하기 전에 호출해야 합니다.
bcp_setbulkmode는 함수 호출당 열 하나에 대한 형식만 지정할 수 있는 bcp_setcolfmt 및 bcp_columns 대신 사용할 수 있습니다.
다음 표에서는 property 매개 변수에 대한 상수를 나열합니다.
속성 |
설명 |
---|---|
BCP_OUT_CHARACTER_MODE |
문자 출력 모드를 지정합니다. BCP.EXE의 –c 옵션 및 BCP_FMT_TYPE 속성이 SQLCHARACTER로 설정된 bcp_setcolfmt에 해당됩니다. |
BCP_OUT_WIDE_CHARACTER_MODE |
유니코드 출력 모드를 지정합니다. BCP.EXE의 –w 옵션 및 BCP_FMT_TYPE 속성이 SQLNCHAR로 설정된 bcp_setcolfmt에 해당됩니다. |
BCP_OUT_NATIVE_TEXT_MODE |
비문자 유형의 경우 네이티브 유형을 지정하고 문자 유형의 경우 유니코드를 지정합니다. BCP.EXE의 –N 옵션 및 BCP_FMT_TYPE 속성이 SQLNCHAR(열 유형이 문자열인 경우, 문자열이 아닌 경우 기본값)로 설정된 bcp_setcolfmt에 해당됩니다. |
BCP_OUT_NATIVE_MODE |
네이티브 데이터베이스 유형을 지정합니다. BCP.EXE의 –n 옵션 및 BCP_FMT_TYPE 속성이 기본값으로 설정된 bcp_setcolfmt에 해당됩니다. |
bcp_setcolfmt, bcp_control 및 bcp_readfmt를 포함하는 함수 호출 시퀀스와 함께 bcp_setbulkmode를 사용하지 않아야 합니다. 예를 들어 bcp_control(BCPTEXTFILE) 및 bcp_setbulkmode를 호출하지 않아야 합니다.
bcp_setbulkmode와 충돌하지 않는 bcp_control 옵션에 대해 bcp_control 및 bcp_setbulkmode를 호출할 수 있습니다. 예를 들어 bcp_control(BCPFIRST) 및 bcp_setbulkmode를 호출할 수 있습니다.
bcp_setcolfmt, bcp_control 및 bcp_readfmt를 포함하는 함수 호출 시퀀스와 함께 bcp_setbulkmode를 호출하는 경우 해당 함수 호출 중 하나에서 시퀀스 오류 실패를 반환합니다. 이러한 오류를 해결하도록 선택하는 경우 bcp_init를 호출하여 모든 설정을 재설정하고 다시 시작합니다.
다음 표에서는 함수 시퀀스 오류를 발생시키는 일부 함수 호출의 예를 제공합니다.
호출 시퀀스 |
---|
|
|
|
|
|
|
|
|
예
다음 예제에서는 bcp_setbulkmode의 서로 다른 설정을 사용하여 4개의 파일을 만듭니다.
// compile with: sqlncli11.lib odbc32.lib
#include <windows.h>
#include <stdio.h>
#include <tchar.h>
#include <sqlext.h>
#include "sqlncli.h"
// Global variables
SQLHENV g_hEnv = NULL;
SQLHDBC g_hDbc = NULL;
void ODBCCleanUp() {
if (g_hDbc) {
SQLDisconnect(g_hDbc);
SQLFreeHandle(SQL_HANDLE_DBC, g_hDbc);
g_hDbc = NULL;
}
if (g_hEnv) {
SQLFreeHandle(SQL_HANDLE_ENV, g_hEnv);
g_hEnv = NULL;
}
}
BOOL MakeODBCConnection(TCHAR * pszServer) {
TCHAR szConnectionString[500];
TCHAR szOutConnectionString[500];
SQLSMALLINT iLen;
SQLRETURN rc;
_sntprintf_s(szConnectionString, 500, TEXT("DRIVER={SQL Server Native Client 11.0};Server=%s;Trusted_connection=yes;"), pszServer);
rc = SQLAllocHandle(SQL_HANDLE_ENV, SQL_NULL_HANDLE,&g_hEnv);
if (SQL_SUCCESS != rc && SQL_SUCCESS_WITH_INFO != rc) {
printf("SQLAllocHandle(SQL_HANDLE_ENV...) failed\n");
return false;
}
rc = SQLSetEnvAttr(g_hEnv,SQL_ATTR_ODBC_VERSION, (SQLPOINTER)SQL_OV_ODBC3, SQL_IS_UINTEGER);
if (SQL_SUCCESS != rc && SQL_SUCCESS_WITH_INFO != rc) {
printf("SQLSetEnvAttr failed\n");
SQLFreeHandle(SQL_HANDLE_ENV, g_hEnv);
return false;
}
rc = SQLAllocHandle( SQL_HANDLE_DBC, g_hEnv , &g_hDbc);
if (SQL_SUCCESS != rc && SQL_SUCCESS_WITH_INFO != rc) {
printf("SQLAllocHandle(SQL_HANDLE_DBC...) failed\n");
SQLFreeHandle(SQL_HANDLE_ENV, g_hEnv);
return false;
}
// Enable BCP
rc = SQLSetConnectAttr(g_hDbc, SQL_COPT_SS_BCP, (SQLPOINTER)SQL_BCP_ON, SQL_IS_INTEGER);
if (SQL_SUCCESS != rc && SQL_SUCCESS_WITH_INFO != rc) {
printf("SQLSetConnectAttr(.. SQL_COPT_SS_BCP, (SQLPOINTER)SQL_BCP_ON ...) failed\n");
ODBCCleanUp();
return false;
}
// connecting ...
rc = SQLDriverConnect(g_hDbc,NULL, (SQLTCHAR*)szConnectionString, SQL_NTS, (SQLTCHAR*)szOutConnectionString, 500, &iLen, SQL_DRIVER_NOPROMPT);
if (SQL_SUCCESS != rc && SQL_SUCCESS_WITH_INFO != rc) {
printf("SQLDriverConnect(SQL_HANDLE_DBC...) failed\n");
ODBCCleanUp();
return false;
}
return true;
}
BOOL BCPSetBulkMode(TCHAR * pszServer, TCHAR * pszQureryOut, char BCPType, TCHAR * pszDataFile) {
SQLRETURN rc;
if (!MakeODBCConnection(pszServer))
return false;
rc = bcp_init(g_hDbc, NULL, pszDataFile, NULL, DB_OUT); // bcp init for queryout
if (SUCCEED != rc) {
printf("bcp_init failed\n");
ODBCCleanUp();
return false;
}
// setbulkmode
char ColTerm[] = "\t";
char RowTerm[] = "\r\n";
wchar_t wColTerm[] = L"\t";
wchar_t wRowTerm[] = L"\r\n";
BYTE * pColTerm = NULL;
int cbColTerm = NULL;
BYTE * pRowTerm = 0;
int cbRowTerm = 0;
int bulkmode = -1;
if (BCPType == 'c') { // bcp -c
pColTerm = (BYTE*)ColTerm;
pRowTerm = (BYTE*)RowTerm;
cbColTerm = 1;
cbRowTerm = 2;
bulkmode = BCP_OUT_CHARACTER_MODE;
}
else
if (BCPType == 'w') { // bcp -w
pColTerm = (BYTE*)wColTerm;
pRowTerm = (BYTE*)wRowTerm;
cbColTerm = 2;
cbRowTerm = 4;
bulkmode = BCP_OUT_WIDE_CHARACTER_MODE;
}
else
if (BCPType == 'n') // bcp -n
bulkmode = BCP_OUT_NATIVE_MODE;
else
if (BCPType == 'N') // bcp -n
bulkmode = BCP_OUT_NATIVE_TEXT_MODE;
else {
printf("unknown bcp mode\n");
ODBCCleanUp();
return false;
}
rc = bcp_setbulkmode(g_hDbc, bulkmode, pColTerm, cbColTerm, pRowTerm, cbRowTerm);
if (SUCCEED != rc) {
printf("bcp_setbulkmode failed\n");
ODBCCleanUp();
return false;
}
// set queryout TSQL statement
rc = bcp_control(g_hDbc, BCPHINTS , pszQureryOut);
if (SUCCEED != rc) {
printf("bcp_control(..BCP_OPTION_HINTS..) failed\n");
ODBCCleanUp();
return false;
}
// bcp copy
DBINT nRowsInserted = 0;
rc = bcp_exec(g_hDbc, &nRowsInserted);
if (SUCCEED != rc) {
printf("bcp_exec failed\n");
ODBCCleanUp();
return false;
}
printf("bcp done\n");
ODBCCleanUp();
return true;
}
int main() {
BCPSetBulkMode(TEXT("localhost"), TEXT("SELECT 'this is a bcp -c test', 1,2") , 'c', TEXT("bcpc.dat"));
BCPSetBulkMode(TEXT("localhost"), TEXT("SELECT 'this is a bcp -w test', 1,2") , 'w', TEXT("bcpw.dat"));
BCPSetBulkMode(TEXT("localhost"), TEXT("SELECT 'this is a bcp -c test', 1,2") , 'n', TEXT("bcpn.dat"));
BCPSetBulkMode(TEXT("localhost"), TEXT("SELECT 'this is a bcp -w test', 1,2") , 'N', TEXT("bcp_N.dat"));
}