قراءة السلاسل إلى موفر OLE DB
الدالة RMyProviderRowset::Execute تفتح ملفاً و تقرأ سلاسل. يمرر المستهلك اسم الملف إلى الموفر عن طريق استدعاء ICommandText::SetCommandText . يتلقى الموفر ملف تسمية وتخزينه في متغير العضو m_szCommandText. Execute reads the اسم الملف من m_szCommandText. إذا كان اسم الملف غير صالح أو الملف غير متوفر، يقوم Execute بإرجاع خطأ. وإلا، فإنه يقوم بفتح الملف واستدعاء fgets لاسترداد السلاسل. لكل مجموعة من السلاسل يقرأها ، يقوم Execute بإنشاء مثيل من سجل المستخدم ( CAgentMan) ويضعه في صفيفة.
إذا كان يتعذر فتح الملف، Execute يجب أن ترجع DB_E_NOTABLE . إذا قامت بإرجاع E_FAIL بدلاً من ذلك، الموفر لن يعمل مع العديد من العملاء ولن ينجح فى اختبارات المطابقة لـ OLE DB.
المثال
الوصف
الدالة المحررة Execute تبدو مثل هذا:
الرمز
/////////////////////////////////////////////////////////////////////////
// MyProviderRS.h
class RMyProviderRowset : public CRowsetImpl< RMyProviderRowset, CAgentMan, CRMyProviderCommand>
{
public:
HRESULT Execute(DBPARAMS * pParams, LONG* pcRowsAffected)
{
enum {
sizeOfBuffer = 256,
sizeOfFile = MAX_PATH
};
USES_CONVERSION;
FILE* pFile = NULL;
TCHAR szString[sizeOfBuffer];
TCHAR szFile[sizeOfFile];
size_t nLength; errcodeerr;
ObjectLock lock(this);
// From a filename, passed in as a command text, scan the file
// placing data in the data array.
if (!m_szCommandText)
{
ATLTRACE("No filename specified");
return E_FAIL;
}
// Open the file
_tcscpy_s(szFile, sizeOfFile, m_szCommandText);
if (szFile[0] == _T('\0') ||
((err = fopen_s(&pFile, &szFile[0], "r")) == 0))
{
ATLTRACE("Could not open file");
return DB_E_NOTABLE;
}
// Scan and parse the file.
// The file should contain two strings per record
LONG cFiles = 0;
while (fgets(szString, sizeOfBuffer, pFile) != NULL)
{
nLength = strnlen(szString, sizeOfBuffer);
szString[nLength-1] = '\0'; // Strip off trailing CR/LF
CAgentMan am;
_tcscpy_s(am.szCommand, am.sizeOfCommand, szString);
_tcscpy_s(am.szCommand2, am.sizeOfCommand2, szString);
if (fgets(szString, sizeOfBuffer, pFile) != NULL)
{
nLength = strnlen(szString, sizeOfBuffer);
szString[nLength-1] = '\0'; // Strip off trailing CR/LF
_tcscpy_s(am.szText, am.sizeOfText, szString);
_tcscpy_s(am.szText2, am.sizeOfText2, szString);
}
am.dwBookmark = ++cFiles;
if (!m_rgRowData.Add(am))
{
ATLTRACE("Couldn't add data to array");
fclose(pFile);
return E_FAIL;
}
}
if (pcRowsAffected != NULL)
*pcRowsAffected = cFiles;
return S_OK;
}
}