IRow::Open と ISequentialStream を使用した BLOB データのフェッチ
IRow::Open は、DBGUID_STREAM 型と DBGUID_NULL 型のオブジェクトを開くことだけをサポートします。
次の関数では、IRow::Open と ISequentialStream を使用して大きなデータをフェッチします。
void InitializeAndExecuteCommand()
{
ULONG iidx;
WCHAR* wCmdString=OLESTR("SELECT * FROM MyTable");
// Do the initialization, create the session, and set command text.
hr = pICommandText->Execute(NULL, IID_IRow, NULL,
&cNumRows,(IUnknown **)&pIRow)))
//Get 1 column at a time.
for(ULONG i=1; i <= NoOfColumns; i++)
GetSequentialColumn(pIRow, iidx);
// Do the clean up.
}
HRESULT GetSequentialColumn(IRow* pUnkRow, ULONG iCol)
{
HRESULT hr = NOERROR;
ULONG cbRead = 0;
ULONG cbTotal = 0;
ULONG cColumns = 0;
ULONG cReads = 0;
ISequentialStream* pIStream = NULL;
WCHAR* pBuffer[kMaxBuff]; //50 chars read by ISequentialStream::Read()
DBCOLUMNINFO* prgInfo;
OLECHAR* pColNames;
IColumnsInfo* pIColumnsInfo;
DBID columnid;
DBCOLUMNACCESS column;
hr = pUnkRow->QueryInterface(IID_IColumnsInfo,
(void**) &pIColumnsInfo);
hr = pIColumnsInfo->GetColumnInfo(&cColumns, &prgInfo, &pColNames);
// Get Column ID.
columnid = (prgInfo + (iCol - 1))->columnid;
// Get sequential stream object by calling IRow::Open.
hr = pUnkRow->Open(NULL, &columnid, DBGUID_STREAM, 0,
IID_ISequentialStream,(LPUNKNOWN *)&pIStream);
ZeroMemory(pBuffer, kMaxBuff * sizeof(WCHAR));
// Read 50 chars at a time until no more data.
do
{
hr = pIStream->Read(pBuffer, kMaxBuff, &cbRead);
cbTotal = cbTotal + cbRead;
// Process the data.
} while(cbRead > 0);
// Do the clean up.
return hr;
}
大きなデータは、ISequentialStream インターフェイスを使用してバインドまたは取得できます。 バインドされた列の場合、DBSTATUS_S_TRUNCATED を設定してデータが切り捨てられるかどうかが状態フラグで示されます。