现在的位置: 首页 > 综合 > 正文

VC6.0连接sybase数据库

2013年09月09日 ⁄ 综合 ⁄ 共 4266字 ⁄ 字号 评论关闭

VC连接sybase数据库
首先,必须安装Sybase客户端并配置Sybase客户端。安装完成后要从程序中运行dsedit进行配置。
server为要访问的数据库的名字,还有Sybase数据库所在机子的IP和Port及访问的协议TCP。
当配置完毕后,可以用ping来检查配置的正确性。
下面就进入到编程了。
在此,你还要让你的工程包含Sybase的头文件和动态链接库。让程序能认识Sybase函数。
打Tool--->Options后,选择Directories标签,Show directories for 中选择Includefiles后,
你就可以增加Sybase的包含:例我这里Sybase是安装在C:所以我指定:C:/sybase/include;
同样,再选择Library files指定:C:/sybase/lib,就ok了。
1.包含头文件。
在你要连接Sybase数据库代码的头文件中添加#include <ctpublic.h>,
此时你就可以编译一下,如果说找不到此头文件,说明你上面包含指定的路径不正确。
2.声明两个连接 Sybase 数据库必须的变量。
CS_CONTEXT         *context;  /* 内容结构 */
CS_CONNECTION      *ptrconnection; /* 连接结构 */
我个人认为用ct-library接口访问sybase数据库与用ADO技术有很多相似之处,
也可以说访问数据库一般差不多,都是先创建空间,再创建连接。
并初始化context:      context = (CS_CONTEXT *)NULL;
3.我定义了下面几个函数:
BOOL  ConnectSybaseDB(CString strDBName,CString strUser,CStringstrPass);
//连接数据库:true成功,false失败其参数分别为:数据库名,访问数据库的用户名,密码。
这个strDBName就是Sybase客启端配置时的Server名字。
       void    DisConnectSybaseDB();         //断开数据库
       void    ShowDBError(int  nErrCode);   //显示连接数据库时的错误信息
4.具体实现:
//////////////**********建立连接函数***********//////////////
       ConnectSybaseDB(CString strDBName,CString strUser,CString strPass)
       {
          CS_RETCODE     ret; 
          char username[32],password[32];
          memset(username,0,sizeof(username));
          memset(password,0,sizeof(password));
          strcpy(username,strUser);
          strcpy(password,strPassword);
          /*分配内容结构*/
          if((ret=cs_ctx_alloc(CS_VERSION_100, &context)) != CS_SUCCEED)
          {   //不成功则调用ShowDBError显示错误代码
              ShowDBError(ret);
              return FALSE;
          }
          /*初始化Client_Library*/
          if((ret=ct_init(context,CS_VERSION_100)) != CS_SUCCEED)
          {
              ShowDBError(ret);
              return FALSE;
          }
          /*分配连接结构*/
          if((ret=ct_con_alloc(context,&ptrconnection))!=CS_SUCCEED)
          {
              ShowDBError(ret);
            return FALSE;
          }
          /*设置用户名和口令*/
          if((ret=ct_con_props(ptrconnection,CS_SET,CS_USERNAME,username,CS_NULLTERM,NULL))!=CS_SUCCEED)
          {
            ShowDBError(ret);
            return FALSE;
          } 

          if((ret=ct_con_props(ptrconnection,CS_SET,CS_PASSWORD,password,CS_NULLTERM,NULL))!=CS_SUCCEED)
          {
              ShowDBError(ret);
              return FALSE;
          }
          /*建立连接*/
          char instance[20];
          strcpy(instance,strDBName);
          if((ret=ct_connect(ptrconnection, (CS_CHAR *)instance, 

          sizeof(instance))) != CS_SUCCEED)
          {
              ShowDBError(ret);
              return FALSE;
          }
          else
             return TRUE;
        }
//////////////**********断开连接函数***********//////////////
        void    DisConnectSybaseDB()
        {
          CS_RETCODE ret;
           if ((ret = ct_close(ptrconnection, CS_UNUSED))!= CS_SUCCEED)
          {
              ShowDBError(ret);
          }
          if ((ret = ct_con_drop(ptrconnection)) != CS_SUCCEED)/*释放资源*/
          {
              ShowDBError(ret);
          } 
          if((ret=ct_exit(context,CS_UNUSED))!=CS_SUCCEED)/*关闭与服务器的所有连接,退出CT-L*/
          {
              ShowDBError(ret);
          }
          if((ret=cs_ctx_drop(context))!=CS_SUCCEED)/*释放环境结构占用的资源*/
          {
              ShowDBError(ret);
          } 
          context = (CS_CONTEXT *)NULL;
          return;
         }
//////////////**********显示错误代码函数***********//////////////
        void    ShowDBError(int  nErrCode)
        {
          CString strDBErrorInfo;
          switch(nErrCode)
          {
            case CS_MEM_ERROR:  
              strcpy(strDBErrorInfo, "内存不足或地址分配错误!");   
              break;
            case CS_PENDING:
              strcpy(strDBErrorInfo, "异步网络I/O正在进行!");   
              break;
            case CS_BUSY:
              strcpy(strDBErrorInfo, "当前连接内有一异步操作正在进行!");
              break;
            case CS_CANCELED:
              strcpy(strDBErrorInfo, "操作被取消!");
              break;
            case CS_END_RESULTS:
              strcpy(strDBErrorInfo, "从服务器返回的结果处理结束!");
              break;
            case CS_ROW_FAIL:
              strcpy(strDBErrorInfo, "提取当前行的数据失败!");
              break;
            case CS_END_DATA:
              strcpy(strDBErrorInfo, "数据提取结束!");
              break;
            case CS_FAIL:
              strcpy(strDBErrorInfo, "函数执行失败!");
              break;  
            default:
              strcpy(strDBErrorInfo, "系统不识别的错误!");
              break;  
            }
         AfxMessageBox(strDBErrorInfo);
}

抱歉!评论已关闭.