Chinaunix首页 | 论坛 | 博客
  • 博客访问: 2084571
  • 博文数量: 414
  • 博客积分: 10312
  • 博客等级: 上将
  • 技术积分: 4921
  • 用 户 组: 普通用户
  • 注册时间: 2007-10-31 01:49
文章分类

全部博文(414)

文章存档

2011年(1)

2010年(29)

2009年(82)

2008年(301)

2007年(1)

分类: C/C++

2008-10-05 16:59:10

      前段在做一个项目时,要用到通过Sybase客户端连接网络Sybase数据库的问题。

      在此之前,做过好多access,SQL server数据库的项目,都是用ADO技术来实现的。但是这一次,领导要求用Sybase数据库提供的ct-library接口,

所以一下子以前所知道的数据库访问技术都没有了用武之地,当时在发过贴子,问过这个问题,回应很少,现在这个问题已解决了,写出来,和大家一块探讨,

共同学习,也好给遇到这个问题的人一个入门指导。
    首先,必须安装并配置Sybase客户端。安装完成后要,从程序中运行dsedit进行配置。server为要访问的数据库的名字,还有Sybase数据库所在机子的IP和

Port及访问的协议TCP;不会配置的,可以请教一下身边的高手。
    当配置完毕后,可以用ping来检查配置的正确性。
    下面就进入到编程了。
    在此,还要让工程包含Sybase的头文件和动态链接库。让程序能认识Sybase函数。打Tool--->Options后,选择Directories标签,Show directories for

中选择 Include files后,就可以增加Sybase的包含:例如这里Sybase是安装在C:所以指定为:C:\sybase\include;同样,再选择Library files指定:C:\sybase\lib,

就ok了。
    1.包含头文件。在要连接Sybase数据库代码的头文件中添加#include,此时就可以编译一下,如果说找不到此头文件,说明上面包含指定的路径不正确。
    2.声明两个连接 Sybase 数据库必须的变量。
       CS_CONTEXT         *context;  /* 内容结构 */
       CS_CONNECTION      *ptrconnection; /* 连接结构 */
       用ct-library接口访问sybase数据库与用ADO技术有很多相似之处,也可以说访问数据库一般差不多,都是先创建空间,再创建连接。并初始化 context: context = (CS_CONTEXT *)NULL;
    3.定义下面几个函数:
        BOOL  ConnectSybaseDB(CString strDBName,CString strUser,CString strPass);

        //连接数据库: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);
        }

阅读(2769) | 评论(0) | 转发(0) |
给主人留下些什么吧!~~