|
4．执行一个SQL 查询，得到数据集（recordset）
_RecordsetPtr GetRecordSet(LPSTR strSql, _ConnectionPtr ptrConn)
{
try
{
RecordsetPtr ptrRS； // recordset 对象
// 创建recordset 对象实体
ptrRS.CreateInstance(__uuidof(Recordset));
ptrRS->Open( strSql,
ptrConn.GetInterfacePtr(),
adOpenForwardOnly,
adLockUnspecified,
adCmdText);
或者
ptrRS = ptrConn ->Execute(m_ strSql,NULL, adCmdText);
return ptrRS;
}
catch(_com_error &a_pComError)
{
….// 错误处理
return NULL;
}
} |
5．通过数据集（recordset）得到列的名称
HRESULT GetColumnNames(
_RecordsetPtr ptrRs, // recordset 对象
char strColNames[][255],
DataTypeEnum iColTypes[])
{
try
{ // 参数变量
_variant_t l_vaIndex;
l_vaIndex.vt = VT_I2;
// COLUMNS总数
long lColCount;
lColCount = ptrRs ->Fields->Count;
// 循环取得列的属性和名称
for(int iIndex = 0 ; iIndex < lColCount; iIndex++)
{
l_vaIndex.iVal = iIndex; // 设置循环索引
// 取得字段名称
sprintf(strColNames[iIndex], "%s",(LPSTR)ptrRs ->Fields->GetItem(l_vaIndex)->Name);
// 取得字段属性
iColTypes = ptrRs ->Fields->GetItem(l_vaIndex)->Type;
}
}
return S_OK;
}
catch(_com_error &a_pComError)
{
…. // 错误处理
return E_UNEXPECTED;
}
catch(...)
{
…. // 错误处理
return E_UNEXPECTED;
}
} |
6．通过数据集（recordset）得到当前行记录
HRESULT getOneRecord(
_RecordsetPtr ptrRs,
const long lNoOfColumns,
_variant_t varValue[])
{
try
{
// 参数变量
_variant_t l_vaIndex;
l_vaIndex.vt = VT_I2;
// 循环取得列的值
for(long lIndex = 0; lIndex < lNoOfColumns; lIndex ++)
{
l_vaIndex.iVal = lIndex;
// 取得字段值
varValue[lIndex]= ptrRs->Fields->GetItem(l_vaIndex)->Value;
}
return S_OK;
}
catch(_com_error &a_pComError)
{
…. // 错误处理
return E_UNEXPECTED;
}
catch(...)
{
…. // 错误处理
return E_UNEXPECTED;
}
} |
7．出错情况下错误信息的取得
void ErrorFunc(_com_error &pComError, _ConnectionPtr ptrConn);
{
// COM 错误取得
// 当执行COM功能的时候，如果出错，可以捕捉到_com_error的异常
char lpComErrorStr512];
sprintf(lpComErrorStr512,"ErrorCode = %08lx \
Error Message = %s \
Source = %s \
Description = %s ",
pComError.Error(), // 错误编号
pComError.ErrorMessage(),// 错误信息
(LPCSTR) pComError.Source(),// 错误源
(LPCSTR) pComError.Description());// 错误描述
// 通过上面的代码我们可以看出，_com_error对象中可以得到COM所有出错的信息
// ADO错误取得
ErrorPtr pErr = NULL;
if( (ptrConn ->Errors->Count) > 0)
{
long nCount = ptrConn ->Errors->Count;
for(long i = 0; i < nCount; i++)
{
pErr = a_pConnPtr->Errors->GetItem(i);
char l_pchErrorString[512];
sprintf(l_pchErrorString,"Error:\n Error number: %x\t%s",
pErr->Number, // 错误编号
pErr->Description); // 错误描述
}
}
// ADO 处理出错的情况下, 在connection对象里面都有记录，可以通过访问
// connection 对象取得错误编号和错误信息。
|
|