//异常信息的捕获
CATCH_ALL(e)
{
Close();
THROW_LAST();
}
END_CATCH_ALL
return TRUE;
//获取记录集信息
void CColumns::DoFieldExchange(CFieldExchange* pFX)
pFX->SetFieldType(CFieldExchange::outputColumn);
RFX_Text(pFX,_T("TABLE_QUALIFIER"),m_strTableQualifier);
RFX_Text(pFX,_T("TABLE_OWNER"),m_strTableOwner);
RFX_Text(pFX,_T("TABLE_NAME"),m_strTableName);
RFX_Text(pFX,_T("COLUMN_NAME"),m_strColumnName);
RFX_Int(pFX,_T("DATA_TYPE"),m_nDataType);
RFX_Text(pFX,_T("TYPE_NAME"),m_strTypeName);
RFX_Long(pFX,_T("PRECISION"),m_nPrecision);
RFX_Long(pFX,_T("LENGTH"),m_nLength);
RFX_Int(pFX,_T("SCALE"),m_nScale);
RFX_Int(pFX,_T("RADIX"),m_nRadix);
RFX_Int(pFX,_T("NULLABLE"),m_fNullable);
RFX_Text(pFX,_T("REMARKS"),m_strRemarks);
CColumns::CColumns(CDatabase* pDatabase): CRecordset(pDatabase)
m_strTableQualifier = _T("");
m_strTableOwner = _T("");
m_strTableName = _T("");
m_strColumnName = _T("");
m_nDataType = 0;
m_strTypeName = _T("");
m_nPrecision = 0;
m_nLength = 0;
m_nScale = 0;
m_nRadix = 0;
m_fNullable = 0;
m_strRemarks = _T("");
m_nFields = 12;
CTable::CTable(CDatabase* pDatabase): CRecordset(pDatabase)
m_strTableQualifier = _T("");
m_strTableOwner = _T("");
m_strTableName = _T("");
m_strTableType = _T("");
m_strRemarks = _T("");
m_nFields = 5;
BOOL CTable::Open(LPCSTR pszTableQualifier,
LPCSTR pszTableOwner,LPCSTR pszTableName,LPCSTR pszTableType,
UINT nOpenType)
RETCODE nRetCode;
UWORD bFunctionExists;
//检验是否支持SQLTables 函数
AFX_SQL_SYNC(::SQLGetFunctions(m_pDatabase->m_hdbc,
SQL_API_SQLTABLES,&bFunctionExists));
if (!Check(nRetCode) || !bFunctionExists)
{
if (!bFunctionExists)
TRACE(_T("SQLTables 不支持\n"));
return FALSE;
}
//设置缓冲区状态,分配语句句柄
SetState(nOpenType,NULL,readOnly);
if (!AllocHstmt())
return FALSE;
TRY
{
OnSetOptions(m_hstmt);
AllocStatusArrays();
//调用 ODBC的SQLTables函数
AFX_ODBC_CALL(::SQLTables(m_hstmt,
(UCHAR FAR*)pszTableQualifier,SQL_NTS,
(UCHAR FAR*)pszTableOwner,SQL_NTS,
(UCHAR FAR*)pszTableName,SQL_NTS,
(UCHAR FAR*)pszTableType,SQL_NTS));
if (!Check(nRetCode))
ThrowDBException(nRetCode,m_hstmt);
// 分配内存,填写信息
AllocAndCacheFieldInfo();
AllocRowset();
MoveNext();
m_bBOF = m_bEOF;
}
//异常信息的捕获
CATCH_ALL(e)
{
Close();
THROW_LAST();
}
END_CATCH_ALL
return TRUE;
void CTable::DoFieldExchange(CFieldExchange* pFX)
pFX->SetFieldType(CFieldExchange::outputColumn);
RFX_Text(pFX,_T("TABLE_QUALIFIER"),m_strTableQualifier);
RFX_Text(pFX,_T("TABLE_OWNER"),m_strTableOwner);
RFX_Text(pFX,_T("TABLE_NAME"),m_strTableName);
RFX_Text(pFX,_T("TABLE_TYPE"),m_strTableType);
RFX_Text(pFX,_T("REMARKS"),m_strRemarks);
以上两个类对CRecordset的Open和DoFieldExchange函数进行了重载。应用程序可以在
需要时创建CTable或Ccolumns类,并调用OPEN成员函数建立相应的表结构和字段结构记
录集。接下来就可以通过下列函数来遍历异构型数据库的结构信息了。
Void CRecordset::MoveFirst(); //移到第一条记录
Void CRecordset::MoveLast(); //移到最后一条记录
Void CRecordset::MovePrev(); //移到前一条记录
Void CRecordset::MoveNext(); //移到后一条记录
BOOL CRecordset::IsBOF(); //判断是否到达第一条记录前
BOOL CRecordset::IsEOF(); //判断是否到达最后一条记录后
四、结束语
利用自定义的CTable和Ccolumns类,应用程序能获取任何异构型数据库库结构信息。根据
获得的信息可以方便的对未知数据库进行相应的操作。若将CTable和Ccolumns类与文档类、
视类结合起来,就可以在窗口里以一定的方式显示结构信息。作者利用以上技术在异构型
数据库通信平台上成功实现了对各种异构型数据库库结构信息的获取。
参考文献:
Mircosoft 《ODBC 2.0 Programmer's Reference and SDK Guide》
利用VC++获取异构型数据库库结构信息
上一页 [1] [2]