用ADO编制SQLPlus程序

下载本文示例代码

我最近正在学习ADO,并试着做了一个简单的SQL Plus，在此过程中有一些经验希望和大家分享。

代码运行效果图如下：


编译时要在stdafx.h中指定正确的路径：#import "msado15.dll" no_namespace rename("EOF","adoEOF")

一、连接数据库
在此例子中我连接了3种常用的数据库：Access,Oracle,Sql server。关键是连接字符
串的不同，如下所示：

HRESULT hr;
_ConnectionPtr m_pConnTemp;
UpdateData();

//Oracle 的连接：
CString strConnection = "Provider=MSDAORA;Data Source=" + m_dbserver +
       ";User ID=" + m_username + "; Password=" + m_passwd;

//Sql server的连接：
CString strConnection = "Provider=SQLOLEDB.1;Data Source=" + m_dbserver +
       ";Initial Catalog=" + m_initDb  +    //初始时连接的数据库
       ";User ID=" + m_username + "; PWD=" + m_passwd;

//Access 的连接：
CString strConnection = "Provider=Microsoft.Jet.OLEDB.4.0;Data Source=" +
m_filename;

try
{
  hr = m_pConnTemp.CreateInstance("ADODB.Connection");

  if(SUCCEEDED(hr))
  {
    hr=m_pConnTemp->Open((_bstr_t)strConnection,"","",-1);
    OnOK();
  }
}
catch(_com_error e)
{
  CCommon common;
  AfxMessageBox(common.DisplayAdoError(m_pConnTemp));
}

二 、错误消息的获得

当连接或操作ADO时发生错误，可以利用_ConnectionPtr对象得到错误信息：

CString CCommon::DisplayAdoError(_ConnectionPtr m_pConnection)
{
 long errorcount = m_pConnection->GetErrors()->GetCount();
 _bstr_t add;
 CString ErrorMessage,temp;
 for(short i=0; iGetErrors()->GetItem(_variant_t((short)i))->GetDescription();
  temp = (char *)add;
  ErrorMessage += temp;
 }
 return ErrorMessage;
}

三、得到"update","insert"操作的记录数：

_variant_t fieldCount;
VariantInit (&fieldCount);
MainFrame->m_pUserSet = MainFrame->m_commandptr->Execute(&fieldCount,NULL,adCmdUnknown);
if(!MainFrame->m_pUserSet ->State) //当是Select操作时此条件为假
{
 //fieldCount.lVal中保存的就是"update","insert"操作的记录数
 View->ShowResult(fieldCount.lVal); 
}
VariantClear(&fieldCount);

四、"select"操作的处理：

首先得到所有的字段名作为列表的标题，然后再显示每一条记录。

listTable.ShowWindow (SW_SHOW);
listTable.DeleteAllItems();

int nColumnCount = listTable.GetHeaderCtrl()->GetItemCount();
// 删除所有的列
for (i=0;i < nColumnCount;i++)
{
   listTable.DeleteColumn (0);
}

int fieldCount=Rsc->Fields ->Count; //得到字段的总数
int fieldLength = 0;
FieldPtr m_fieldCtl;

for(i=0;iFields ->GetItem(long(i));    //得到字段名
  fieldLength = m_fieldCtl->DefinedSize*10;
  if (fieldLength >500)   //when field is very long then trim it
  {
    fieldLength = 500;
  }
  else if (fieldLength < 50)
  {
    fieldLength = 50;
  }
  if (fieldLengthName.length ()*12)
  {
    fieldLength = m_fieldCtl->Name.length ()*12;
  }
  listTable.InsertColumn(i,m_fieldCtl->Name,LVCFMT_LEFT,fieldLength);
}

int nItem = 0;
_variant_t varValue;
_bstr_t bstrValue;

while(!Rsc->adoEOF)
{
  m_fieldCtl = Rsc->Fields ->GetItem(long(0));    //得到字段的值
  varValue = m_fieldCtl->Value;
  if (varValue.vt == VT_NULL)  //注意：当值为空时，直接插入会导致异常
  {
    bstrValue = "";
  }
  else
  {
    bstrValue=varValue;
  }
  nItem=listTable.InsertItem(0xffff,bstrValue); //fisrt value

  for(i=1;iFields ->GetItem(long(i));
    varValue = m_fieldCtl->Value;
    if (varValue.vt == VT_NULL)
    {
      bstrValue = "";
    }
    else
    {
      bstrValue=varValue;
    }

    listTable.SetItem(nItem,i,1,bstrValue,NULL,0,0,0);
  }
  Rsc->MoveNext ();
}

五、其它
其它的就是一些和界面显示有关的内容，和ADO关系不大，在此就不做介绍了。有兴趣的朋友可以直接看代码。
如果还有什么疑问，请直接和我联系，非常希望和各位朋友一起探讨，共同进步。

下载本文示例代码

输入您的搜索字词 提交搜索表单