An application that binds a Binary Large Object (BLOB)/binary field to
ISequentialStream objects may hang if
ISequentialStream is not completely read and another query is performed on the same connection. The CPU usage shown in Windows NT taskbar will be at 100 percent.
To access BLOB/binary data, an application can use
ISequentialStream to efficiently load data from a SQL Server database. However, any access to the data is blocked by the SQL Server OLE DB Provider (SQLOLEDB) connection object until
ISequentialStream is completely read. This is problematic for OLE DB consumer applications that may not always want to read all data from a BLOB field, or where you may be fetching an
ISequentialStream pointer and then not using it before executing the other query on the same connection.
This problem only occurs when the server-side cursors are being used.
NOTE: Releasing the
ISequentialStream pointer is not sufficient to resolve this problem.
The application stops responding (hangs) because of a bug in SQL Server OLE DB provider. The provider waits for the application to read all incoming stream data including the binary data before it can run any further queries on the same connection/session.
You can use one of the following three workarounds to resolve this problem:
- Flush the ISequentialStream object before running any further queries. For example:
while(S_OK==pBlobData->Read (buff, sizeof(buff), &iread) && iread==sizeof(buff));
- Don't set DBPROP_SERVERCURSOR to true.
- Instead of using ISequentialStream (DBTYPE_IUNKNOWN), use a byte array (DBTYPE_BYTES) to access data in a BLOB column.
Microsoft has confirmed that this is a bug in the Microsoft products that are listed at the beginning of this article.
To reproduce the problem, follow these steps:
- Create a console application in Visual C++.
- Create two ICommand objects, pICommand1 and pICommand2. pICommand1 selects at least one binary column.
- Call to get an IRowset; for example, pIRowset1. Set the properties of the rowset that server cursors are used.
- Create an accessor (IAccessor) for this IRowset object.
- Call and then
- Now, calling will cause your application to stop responding (hang).
To correct the problem, insert the following code between steps 5 and 6:
while(S_OK==pBlobData->Read (buff, sizeof(buff), &iread) && iread==sizeof(buff));
Here pBlobData is the pointer to
ISequentialStream object and buff is a BYTE buffer.
If you are using the Visual C++ ATL Consumer templates, the code might resemble the following:
class CImageRecordAccessor
{
public:
TCHAR m_field1[101];
ISequentialStream* m_field2;
BEGIN_COLUMN_MAP(CImageRecordAccessor)
COLUMN_ENTRY(1, m_field1)
BLOB_ENTRY(2, IID_ISequentialStream, STGM_READ, m_field2)
END_COLUMN_MAP()
...
}
class CImageRecordset : public CCommand<CAccessor<CImageRecordAccessor> >
{...
HRESULT OpenRowset()
{
CDBPropSet ps(DBPROPSET_ROWSET);
ps.AddProperty(DBPROP_SERVERCURSOR, true);
return CCommand<CAccessor<CImageRecordAccessor> >::Open(m_session, NULL, &ps);
}
...
}
void SomeFunction()
{...
CDataSource ds;
HRESULT hr;
CDBPropSet dbinit(DBPROPSET_DBINIT);
dbinit.AddProperty(DBPROP_AUTH_USERID, OLESTR("joey"));
dbinit.AddProperty(DBPROP_INIT_CATALOG, OLESTR("mydb"));
dbinit.AddProperty(DBPROP_INIT_DATASOURCE, OLESTR("joeyserver"));
dbinit.AddProperty(DBPROP_INIT_LCID, (long)1033);
dbinit.AddProperty(DBPROP_INIT_PROMPT, (short)4);
hr = ds.Open(_T("SQLOLEDB.1"), &dbinit);
if (FAILED(hr))
return;
CSession sn;
hr = sn.Open(ds);
CImageRecrdset rs1,rs2;
unsigned long iread;
char buff[5000];
rs1.m_session = sn;
rs1.OpenRowset();
rs1.MoveNext();
// The following code solves the problem:
//
// unsigned long iread;
// while(S_OK==rs1.m_field2->Read(buff, sizeof(buff), &iread) && iread==sizeof(buff));
rs2.m_session = sn;
rs2.OpenRowset();
hr = rs2.MoveNext();
while(S_OK==rs2.m_field2->Read(buff, sizeof(buff), &iread) && iread==sizeof(buff));
rs1.Close();
rs2.Close();
}
For additional information, click the article number below
to view the article in the Microsoft Knowledge Base:
190958Â
(http://kbalertz.com/Feedback.aspx?kbNumber=190958/EN-US/
)
SAMPLE: AOTBLOB Read/Writes BLOB Using OLE DB Consumer Template