IBCPSession::BCPDone(Native Client OLE DB Provider)
적용 대상:
SQL ServerAzure SQL DatabaseAzure SQL Managed InstanceAzure Synapse Analytics AnalyticsPlatform System(PDW)
Important
SQL Server Native Client(약칭 SNAC)는 SQL Server 2022(16.x) 및 SSMS(SQL Server Management Studio) 19에서 제거되었습니다. SQL Server Native Client OLE DB 공급자(SQLNCLI 또는 SQLNCLI11)와 레거시 Microsoft OLE DB Provider for SQL Server(SQLOLEDB)는 모두 새로운 개발에 권장되지 않습니다. 앞으로 SQL Server용 새 Microsoft OLE DB 드라이버(MSOLEDBSQL)로 전환합니다.
SQL Server로 보낼 나머지 행을 커밋합니다.
구문
HRESULT BCPDone(void);
설명
BCPDone 메서드를 호출한 후에는 IBCPSession 인터페이스에서 다른 작업을 호출할 수 없습니다. IBCPSession::BCPInit 메서드를 호출하여 새 대량 복사 작업을 시작하는 것만 가능합니다. 이는 IRowsetFastLoad::Commit 메서드를 호출하는 것과 유사합니다.
반환 코드 값
S_OK
메서드가 성공했습니다.
E_UNEXPECTED
예기치 않은 메서드가 호출되었습니다. 예를 들어 BCPInit 메서드는 이 메서드를 호출하기 전에 호출되지 않았습니다.
예
이 샘플에서는 IBCPSession 인터페이스를 사용하는 방법을 보여 줍니다.
이 예제를 실행하기 전에 다음 Transact-SQL을 실행해야 합니다.
create table fltest(col1 int, col2 int, col3 image)
insert into fltest values (1, 1, 0x0FF)
insert into fltest values (2, 2, 0xF00)
insert into fltest values (3, 3, 0xBAD)
insert into fltest values (4, 4, 0xFAD)
샘플은 master 데이터베이스에 연결합니다.
샘플이 실행되면 프로젝트 디렉터리에 outfile.dat를 만듭니다. outfile.dat에는 네이티브(이진) 모드로 테이블에서 복사한 데이터가 포함됩니다.
BCP를 사용하여 다음 명령을 사용하여 이 데이터를 테이블에 다시 추가할 수 있습니다.
bcp master.. fltest in outfile.dat -n -T -Sserver
이 샘플을 컴파일할 때 sqlncli11.lib를 지정해야 합니다.
#define DBINITCONSTANTS // Defined to initialize constants in oledb.h
#define INITGUID
#define MAX_ROWS 100
#include <windows.h>
#include <sqlext.h>
#include <sqlncli.h>
#include <oledberr.h>
#include <stdio.h>
#define SAFE_RELEASE(p) { \
if (p) { \
(p)->Release(); \
(p)=NULL; \
} \
}
// DumpErrorInfo queries error interfaces, retrieving available status or error information.
void DumpErrorInfo ( IUnknown* pObjectWithError, REFIID IID_InterfaceWithError ) {
// Interfaces used in the example.
IErrorInfo * pIErrorInfoAll = NULL;
IErrorInfo * pIErrorInfoRecord = NULL;
IErrorRecords * pIErrorRecords = NULL;
ISupportErrorInfo * pISupportErrorInfo = NULL;
ISQLErrorInfo * pISQLErrorInfo = NULL;
ISQLServerErrorInfo * pISQLServerErrorInfo = NULL;
// Number of error records.
ULONG nRecs;
ULONG nRec;
// Basic error information from GetBasicErrorInfo.
ERRORINFO errorinfo;
// IErrorInfo values.
BSTR bstrDescription;
BSTR bstrSource;
// ISQLErrorInfo parameters.
BSTR bstrSQLSTATE;
LONG lNativeError;
// ISQLServerErrorInfo parameter pointers.
SSERRORINFO * pSSErrorInfo = NULL;
OLECHAR * pSSErrorStrings = NULL;
// Hard-code a US English locale for the example.
DWORD MYLOCALEID = 0x0409;
// Only ask for error information if the interface supports it.
if (FAILED(pObjectWithError->QueryInterface(IID_ISupportErrorInfo, (void**) &pISupportErrorInfo))) {
wprintf(L"SupportErrorErrorInfo interface not supported\r\n");
return;
}
if (FAILED(pISupportErrorInfo->InterfaceSupportsErrorInfo(IID_InterfaceWithError))) {
wprintf(L"InterfaceWithError interface not supported\r\n");
return;
}
// Do not test the return of GetErrorInfo. It can succeed and return
// a NULL pointer in pIErrorInfoAll. Simply test the pointer.
GetErrorInfo(0, &pIErrorInfoAll);
if (pIErrorInfoAll != NULL) {
// Test to see if it's a valid OLE DB IErrorInfo interface exposing a list of records.
if (SUCCEEDED(pIErrorInfoAll->QueryInterface(IID_IErrorRecords, (void**) &pIErrorRecords))) {
pIErrorRecords->GetRecordCount(&nRecs);
// Within each record, retrieve information from each of the defined interfaces.
for (nRec = 0; nRec < nRecs; nRec++) {
// From IErrorRecords, get the HRESULT and a reference to the ISQLErrorInfo interface.
pIErrorRecords->GetBasicErrorInfo(nRec, &errorinfo);
pIErrorRecords->GetCustomErrorObject(nRec,IID_ISQLErrorInfo, (IUnknown**) &pISQLErrorInfo);
// Display the HRESULT, then use the ISQLErrorInfo.
wprintf(L"HRESULT:\t%#X\r\n", errorinfo.hrError);
if (pISQLErrorInfo != NULL) {
pISQLErrorInfo->GetSQLInfo(&bstrSQLSTATE, &lNativeError);
// Display the SQLSTATE and native error values.
wprintf(L"SQLSTATE:\t%s\r\nNative Error:\t%ld\r\n", bstrSQLSTATE, lNativeError);
// SysFree BSTR references.
SysFreeString(bstrSQLSTATE);
// Get the ISQLServerErrorInfo interface from ISQLErrorInfo before releasing the reference.
pISQLErrorInfo->QueryInterface( IID_ISQLServerErrorInfo, (void**) &pISQLServerErrorInfo);
pISQLErrorInfo->Release();
}
// Test to ensure the reference is valid, then get error information from ISQLServerErrorInfo.
if (pISQLServerErrorInfo != NULL) {
pISQLServerErrorInfo->GetErrorInfo(&pSSErrorInfo, &pSSErrorStrings);
// ISQLServerErrorInfo::GetErrorInfo succeeds even when it has nothing to return.
// Test the pointers before using.
if (pSSErrorInfo) {
// Display the state and severity from the returned information.
// The error message comes from IErrorInfo::GetDescription.
wprintf(L"Error state:\t%d\r\nSeverity:\t%d\r\n", pSSErrorInfo->bState, pSSErrorInfo->bClass);
// IMalloc::Free needed to release references on returned values.
CoTaskMemFree(pSSErrorStrings);
CoTaskMemFree(pSSErrorInfo);
}
pISQLServerErrorInfo->Release();
}
if (SUCCEEDED(pIErrorRecords->GetErrorInfo(nRec, MYLOCALEID, &pIErrorInfoRecord))) {
// Get the source and description (error message) from the record's IErrorInfo.
pIErrorInfoRecord->GetSource(&bstrSource);
pIErrorInfoRecord->GetDescription(&bstrDescription);
if (bstrSource != NULL) {
wprintf(L"Source:\t\t%s\r\n", bstrSource);
SysFreeString(bstrSource);
}
if (bstrDescription != NULL) {
wprintf(L"Error message:\t%s\r\n", bstrDescription);
SysFreeString(bstrDescription);
}
pIErrorInfoRecord->Release();
}
}
pIErrorRecords->Release();
}
else {
// IErrorInfo is valid; get the source and description to see what it is.
pIErrorInfoAll->GetSource(&bstrSource);
pIErrorInfoAll->GetDescription(&bstrDescription);
if (bstrSource != NULL) {
wprintf(L"Source:\t\t%s\r\n", bstrSource);
SysFreeString(bstrSource);
}
if (bstrDescription != NULL) {
wprintf(L"Error message:\t%s\r\n", bstrDescription);
SysFreeString(bstrDescription);
}
}
pIErrorInfoAll->Release();
}
else
wprintf(L"GetErrorInfo has not returned ErrorInfo.\r\n");
pISupportErrorInfo->Release();
return;
}
IDBCreateSession *Connect () {
// constant definitions
static LPCWSTR pwszProviderString = L"server=(local)\\dschwart3;Database=master;Trusted_Connection=yes;";
static LPCWSTR pwszDataSource = NULL;
static LPCWSTR pwszUserID = NULL;
static LPCWSTR pwszPassword = NULL;
IDBInitialize * pIDBInitialize = NULL;
IDBProperties * pIDBProperties = NULL;
IDBCreateSession * pIDBCreateSession = NULL;
HRESULT hr;
// Obtain the provider's clsid
CLSID clsidProv = CLSID_SQLNCLI10;
// Initialize COM
CoInitialize(NULL);
hr = CoCreateInstance(clsidProv, NULL, CLSCTX_ALL, IID_IDBInitialize,(void **)&pIDBInitialize);
if (!SUCCEEDED(hr))
return NULL;
hr = pIDBInitialize->QueryInterface(IID_IDBProperties, (void **)&pIDBProperties);
if (!SUCCEEDED(hr))
return NULL;
// Set Init properties
{
DBPROPSET rgPropSets[1];
ULONG cPropSets = 0;
DBPROP rgInitProperties[10];
// Initialize Data source properties (connection info)
{
ULONG cProperties = 0;
// DBPROP_INIT_DATASOURCE
if (pwszDataSource) {
rgInitProperties[cProperties].dwPropertyID = DBPROP_INIT_DATASOURCE;
rgInitProperties[cProperties].dwOptions = DBPROPOPTIONS_REQUIRED;
rgInitProperties[cProperties].dwStatus = DBPROPSTATUS_OK;
rgInitProperties[cProperties].colid = DB_NULLID;
rgInitProperties[cProperties].vValue.vt = VT_BSTR;
V_BSTR(&rgInitProperties[cProperties].vValue) = SysAllocString(pwszDataSource);
cProperties++;
}
// DBPROP_AUTH_USERID
if (pwszUserID) {
rgInitProperties[cProperties].dwPropertyID = DBPROP_AUTH_USERID;
rgInitProperties[cProperties].dwOptions = DBPROPOPTIONS_REQUIRED;
rgInitProperties[cProperties].dwStatus = DBPROPSTATUS_OK;
rgInitProperties[cProperties].colid = DB_NULLID;
rgInitProperties[cProperties].vValue.vt = VT_BSTR;
V_BSTR(&rgInitProperties[cProperties].vValue) = SysAllocString(pwszUserID);
cProperties++;
}
// DBPROP_AUTH_PASSWORD
if (pwszPassword) {
rgInitProperties[cProperties].dwPropertyID = DBPROP_AUTH_PASSWORD;
rgInitProperties[cProperties].dwOptions = DBPROPOPTIONS_REQUIRED;
rgInitProperties[cProperties].dwStatus = DBPROPSTATUS_OK;
rgInitProperties[cProperties].colid = DB_NULLID;
rgInitProperties[cProperties].vValue.vt = VT_BSTR;
V_BSTR(&rgInitProperties[cProperties].vValue) = SysAllocString(pwszPassword);
cProperties++;
}
// DBPROP_INIT_PROVIDERSTRING
if (pwszProviderString) {
rgInitProperties[cProperties].dwPropertyID = DBPROP_INIT_PROVIDERSTRING;
rgInitProperties[cProperties].dwOptions = DBPROPOPTIONS_REQUIRED;
rgInitProperties[cProperties].dwStatus = DBPROPSTATUS_OK;
rgInitProperties[cProperties].colid = DB_NULLID;
rgInitProperties[cProperties].vValue.vt = VT_BSTR;
V_BSTR(&rgInitProperties[cProperties].vValue) = SysAllocString(pwszProviderString);
cProperties++;
}
if (cProperties) {
rgPropSets[cPropSets].cProperties = cProperties;
rgPropSets[cPropSets].rgProperties = rgInitProperties;
rgPropSets[cPropSets].guidPropertySet = DBPROPSET_DBINIT;
cPropSets++;
}
}
// Initialize
hr = pIDBProperties->SetProperties(cPropSets, rgPropSets);
if (!SUCCEEDED(hr)) {
DumpErrorInfo(pIDBProperties, IID_IDBProperties);
return NULL;
}
}
SAFE_RELEASE(pIDBProperties);
hr = pIDBInitialize->Initialize();
if (!SUCCEEDED(hr)) {
DumpErrorInfo(pIDBInitialize, IID_IDBInitialize);
return NULL;
}
hr = pIDBInitialize->QueryInterface(IID_IDBProperties, (void **)&pIDBProperties);
if (!SUCCEEDED(hr)) {
DumpErrorInfo(pIDBInitialize, IID_IDBInitialize);
return NULL;
}
// Set SQL Server Specific properties
{
DBPROPSET rgPropSets[1];
ULONG cPropSets = 0;
DBPROP rgSqlProperties[10];
// Initialize the DBProps for fastload and BCP
{
ULONG cProperties = 0;
// SSPROP_ENABLEFASTLOAD
{
rgSqlProperties[cProperties].dwPropertyID = SSPROP_ENABLEFASTLOAD;
rgSqlProperties[cProperties].dwOptions = DBPROPOPTIONS_REQUIRED;
rgSqlProperties[cProperties].dwStatus = DBPROPSTATUS_OK;
rgSqlProperties[cProperties].colid = DB_NULLID;
rgSqlProperties[cProperties].vValue.vt = VT_BOOL;
V_BOOL(&rgSqlProperties[cProperties].vValue)= VARIANT_TRUE;
cProperties++;
}
// SSPROP_ENABLEBULKCOPY
{
rgSqlProperties[cProperties].dwPropertyID = SSPROP_ENABLEBULKCOPY;
rgSqlProperties[cProperties].dwOptions = DBPROPOPTIONS_REQUIRED;
rgSqlProperties[cProperties].dwStatus = DBPROPSTATUS_OK;
rgSqlProperties[cProperties].colid = DB_NULLID;
rgSqlProperties[cProperties].vValue.vt = VT_BOOL;
V_BOOL(&rgSqlProperties[cProperties].vValue)= VARIANT_TRUE;
cProperties++;
}
rgPropSets[cPropSets].cProperties = cProperties;
rgPropSets[cPropSets].rgProperties = rgSqlProperties;
rgPropSets[cPropSets].guidPropertySet = DBPROPSET_SQLSERVERDATASOURCE;
cPropSets++;
}
hr = pIDBProperties->SetProperties(cPropSets, rgPropSets);
if (!SUCCEEDED(hr)) {
DumpErrorInfo(pIDBProperties, IID_IDBProperties);
return NULL;
}
}
SAFE_RELEASE(pIDBProperties);
hr = pIDBInitialize->QueryInterface(IID_IDBCreateSession, (void **)&pIDBCreateSession);
if (!SUCCEEDED(hr)) {
DumpErrorInfo(pIDBInitialize, IID_IDBInitialize);
return NULL;
}
SAFE_RELEASE(pIDBInitialize);
return pIDBCreateSession;
}
void wmain() {
static LPCWSTR pwszTableName = L"fltest";
static LPCWSTR pwszOutFileName = L"outfile.dat";
static LPCWSTR pwszErrFileName = L"errfile.txt";
DBROWCOUNT icRowsCopied = 0;
IDBCreateSession * pIDBCreateSession = NULL;
IBCPSession * pIBCPSession = NULL;
HRESULT hr;
pIDBCreateSession = Connect();
if (!pIDBCreateSession) {
printf("Failed to connect\r\n");
exit(1);
}
// get an IBCPSession interface
hr = pIDBCreateSession->CreateSession(NULL, IID_IBCPSession, (IUnknown**) &pIBCPSession);
if (FAILED(hr)) {
printf("Failed to obtain an IBCPSession interface\r\n");
DumpErrorInfo(pIDBCreateSession, IID_IDBCreateSession);
exit(1);
}
SAFE_RELEASE(pIDBCreateSession);
// Initialize BCP
// Here we create the mapping between file and table, identifying
// which is the source and which is the destination through the final parameter
// (here we are copying out of the table and into the file).
hr = pIBCPSession->BCPInit(pwszTableName, pwszOutFileName, pwszErrFileName, BCP_DIRECTION_OUT);
if (FAILED(hr)) {
printf("BCPInit failed.\r\n");
DumpErrorInfo(pIBCPSession, IID_IBCPSession);
exit(1);
}
// You can set SSPROP_ASYNCH_BULKCOPY to TRUE to improve client latency here,
// at which point BCPExec can return DB_S_ASYNCHRONOUS.
do {
hr = pIBCPSession->BCPExec(&icRowsCopied);
} while (hr == DB_S_ASYNCHRONOUS);
if (FAILED(hr)) {
printf("BCPExec failed.\r\n");
DumpErrorInfo(pIBCPSession, IID_IBCPSession);
exit(1);
}
// flush the rest of the rows and finalize the transaction -- the process is complete.
hr = pIBCPSession->BCPDone();
if (FAILED(hr)) {
printf("BCPDone failed.\r\n");
DumpErrorInfo(pIBCPSession, IID_IBCPSession);
exit(1);
}
SAFE_RELEASE(pIBCPSession);
CoUninitialize();
}
참고 항목
피드백
출시 예정: 2024년 내내 콘텐츠에 대한 피드백 메커니즘으로 GitHub 문제를 단계적으로 폐지하고 이를 새로운 피드백 시스템으로 바꿀 예정입니다. 자세한 내용은 다음을 참조하세요. https://aka.ms/ContentUserFeedback
다음에 대한 사용자 의견 제출 및 보기