Oracle调用接口(OCI)源码剖析(2)：执行SQL语句并获取结果

概述
接着上一篇文章《Oracle调用接口(OCI)源码剖析(1)：创建数据库连接》，我们继续对OCI中执行SQL语句并获取结果的源码进行剖析。该操作主要是由两个函数完成的：CDbExecSql和CDbFetch，其中CDbExecSql函数用于执行普通SQL语句，CDbFetch函数用于获取数据库的返回结果。

下面对这两个函数的源码进行分析。

OCI中执行SQL语句并获取结果的源码剖析

1.执行普通SQL语句的操作
在OCI中，执行普通SQL语句的操作是由CDbExecSql函数实现的，其代码如下：

INT32 CDbExecSql(void *pHandle, INT8 *pSQL)
{
   CDb          *hDb  = (CDb *)pHandle;
   CDbRecordset *pRec = NULL;
   OCIHDBC       hdbc;
   sword         rc = (sword)0;
   INT32         row_num = 0;

   if ((NULL == hDb) || (NULL == hDb->hdbc) || (NULL == hDb->hRec))
   {
       return OCI_ERROR;
   }
   hdbc = hDb->hdbc;
   pRec = hDb->hRec;

   /* 初始化结果集行数据Buf */
   memset((void *)pRec, 0, sizeof(CDbRecordset));
   /* 申请语句句柄 */
   rc = OCIHandleAlloc((dvoid *)hdbc->envhp, (dvoid**)&hdbc->stmthp, (ub4)OCI_HTYPE_STMT, (size_t)0, (dvoid **)0);
   if (RETCODE_IS_FAILURE(rc))
   {
       DoDbErrProc(hdbc->errhp, rc,"OCIHandleAlloc[OCI_HTYPE_STMT]");
       return OCI_ERROR;
   }

   /* 准备执行数据库操作 */
   rc = DoDbSQLExecute(hDb, (text *)pSQL);
   if (RETCODE_IS_FAILURE(rc))
   {
       /************************************************
        * 如果语句是事务，则以下语句可保证不锁表;      *
        * 如果不是事务，也无关大局                     *
        ************************************************/
       if (OCI_STMT_SELECT != pRec->sqltype)
       {
           OCITransRollback(hdbc->svchp, hdbc->errhp, (ub4)0);
       }
       /* 需要释放stmt句柄 */
       DoStmtFree(hdbc->stmthp);
       return OCI_ERROR;
   }

   /* 对于非Select操作，直接返回 */
   if (OCI_STMT_SELECT != pRec->sqltype)
   {
       /* 获取受delete insert update所影响的列数 */
       rc = OCIAttrGet((dvoid *)hdbc->stmthp, (ub4)OCI_HTYPE_STMT
                      , (dvoid *)&row_num,(ub4 *)0
                      , OCI_ATTR_ROW_COUNT,hdbc->errhp);
       if (RETCODE_IS_FAILURE(rc))
       {
           row_num = OCI_ERROR;
       }
       /* 需要释放stmt句柄 */
       DoStmtFree(hdbc->stmthp);

       if ( row_num == OCI_ERROR )
       {
           return C_OS_FAIL;
       }

       return C_OS_SUCCESS;
   }

   /* 定义结果集 */
   rc = DoDbDefine(hDb);
   if ((OCI_ERROR == rc) || (0 == rc))
   {
       rc = DoDbErrProc(hdbc->errhp, rc, "DoDbDefine");
       /* 需要释放stmt句柄 */
       DoStmtFree(hdbc->stmthp);
       return rc;
   }
   return OCI_SUCCESS;
}

从该函数的代码实现中，我们可以看到：
1)执行普通SQL语句包括这几步主要操作：第一步，申请语句句柄；第二步，执行数据库操作；第三步，对于非Select操作直接返回，对于Select操作定义结果集。

2)申请语句句柄操作是由OCIHandleAlloc函数实现的，它是OCI底层自带的函数。

3)执行数据库操作是由DoDbSQLExecute函数实现的，该函数主要执行这几步操作：第一步，执行OCIStmtPrepare函数准备SQL语句；第二步，执行OCIAttrGet函数获取数据库操作类型；第三步，执行OCIStmtExecute函数进行具体的数据库操作。

4)定义结果集操作是由DoDbDefine函数实现的，该函数主要执行这几步操作：第一步，执行OCIAttrGet函数提取数据库操作返回列的列数；第二步，执行OCIParamGet函数在语句句柄中指定参数描述符；第三步，执行OCIAttrGet函数获得返回结果集列数据类型；第四步，执行OCIAttrGet函数获得返回结果集列名称；第五步，执行OCIDefineByPos函数定义输出变量。

2.获取数据库的返回结果的操作
在OCI中，获取数据库的返回结果的操作是由CDbFetch函数实现的，其代码如下：

INT32 CDbFetch(void *pHandle, INT8 *pData,INT32 maxlen)
{
   CDb          *hDb = (CDb*)pHandle;
   CDbRecordset *pRec = NULL;
   OCIHDBC       hdbc;
   sword         rc =(sword)0;
   INT32         row_num = 0, iLoop, pos = 0;

   if ((NULL == hDb) || (NULL == hDb->hdbc) || (NULL == hDb->hRec))
   {
       return OCI_ERROR;
   }

   hdbc = hDb->hdbc;
   pRec = hDb->hRec;
   if ((NULL == hdbc->stmthp) || (NULL == hdbc->errhp))
   {
       return OCI_ERROR;
   }

   /* 获取结果数据 */
   memset((void *)pData, 0, maxlen);
   memset(pRec->pRecordBuf, 0, CDB_MAX_COL_NUM * CDB_MAX_COL_WIDTH);
   rc = OCIStmtFetch(hdbc->stmthp, hdbc->errhp, 1, OCI_FETCH_NEXT
                    , OCI_DEFAULT);
   if (OCI_NO_DATA == rc)
   {
       DoStmtFree(hdbc->stmthp);
       return CDB_FETCH_NO_DATA;
   }
   rc = DoDbErrProc(hdbc->errhp, rc, "OCIStmtFetch");
   if ((OCI_SUCCESS != rc) && (OCI_SUCCESS_WITH_INFO != rc))
   {
       /* 需要释放stmt句柄 */
       DoStmtFree(hdbc->stmthp);
       return OCI_ERROR;
   }

   /* 向pData填充结果集数据 */
   for (iLoop = 0; iLoop < pRec->colCount; iLoop++)
   {
       int len;

       /* 清除尾部空格 */
       len = pRec->pColWidth[iLoop];
       switch (pRec->pColType[iLoop])
       {
       case SQLT_AFC:
       case SQLT_AVC:
       case SQLT_CHR:
       case SQLT_STR:
           len = DoDbrTrim(pRec->pRecordBuf[iLoop]
                          ,sizeof(pRec->pRecordBuf[iLoop]));
           break;
       default:
           break;
       }
       /* 注意：如果长度不够，返回值也是成功的 */
       if (pos + pRec->pColWidth[iLoop] > maxlen)
       {
           break;
       }
       /* 拷贝实际长度数据 */
       memcpy((void *)(pData + pos)
            , (const void *)pRec->pRecordBuf[iLoop]
            , len);
       /* 偏转定义长度 */
       pos += pRec->pColWidth[iLoop];
   }

   return OCI_SUCCESS;
}

从该函数的代码实现中，我们可以看到：
1)该函数主要完成将CDbExecSql函数执行SQL语句之后的结果拷贝到输出缓存(pData)的操作。

2)在获取结果数据之前，先用OCIStmtFetch函数来提取固定数目的记录，同时也可判断数据库中是否有结果数据返回，如果没有，则不执行后续操作。

3)注意函数中的for循环，它将数据库返回的结果按照列的顺序依次拷贝到输出缓存中。其中，数据库返回数据的列数是pRec->colCount，每列宽度存放在pRec->pColWidth[CDB_MAX_COL_NUM]数组中，每列的具体内容存放在pRec->pRecordBuf[CDB_MAX_COL_NUM][CDB_MAX_COL_WIDTH]二维数组中。

执行SQL语句并获取结果的CDbExecSql和CDbFetch函数调用

CDbExecSql和CDbFetch函数调用要在获取了数据库的连接之后，也就是说，要连上数据库之后才能获取结果。

CDbExecSql和CDbFetch函数调用的示例代码如下：

INT32 main(void)
{
   INT8  szDBServerName[50] = {0};
   INT8  szDBName[50]       = {0};
   INT8  szDBUser[50]       = {0};
   INT8  szDBPwd[50]        = {0};
   INT8  szSqlBuf[100]      = {0};
   INT8  szRcvBuf[100]      = {0};

   INT32 iRetVal            = 0;

   void *pDBHandle          = NULL;

   // 获取数据库各参数的值
   memcpy(szDBServerName, "db192_1_8_13",strlen("db192_1_8_13"));
   memcpy(szDBName,      "dbp_166",     strlen("dbp_166"));
   memcpy(szDBUser,      "dbp_166",     strlen("dbp_166"));
   memcpy(szDBPwd,       "dbp_166",     strlen("dbp_166"));

   // 连接数据库
   pDBHandle = CDbCreateDb("Oracle", szDBServerName, szDBName,szDBUser, szDBPwd);

   if (pDBHandle == NULL)    // 连接失败
   {
       printf("ConnectDB failed! ServiceName:%s, DBName:%s, User:%s,Pwd:%s\n", szDBServerName, szDBName, szDBUser, szDBPwd);

       return -1;
   }

   printf("ConnectDB success! ServiceName:%s, DBName:%s, User:%s,Pwd:%s\n", szDBServerName, szDBName, szDBUser, szDBPwd);

   // 执行SQL语句并获取结果
   // 获取SQL语句
   memcpy(szSqlBuf, "select boxnumber from tb_test where id=1",strlen("select boxnumber from tb_test where id=1"));

   // 调用CDbExecSql函数执行SQL语句
   iRetVal = CDbExecSql(pDBHandle, szSqlBuf);
   if (iRetVal != 0)    // 执行失败
   {
       printf("CDbExecSql failed! RetVal=%d (ServiceName:%s, DBName:%s,User:%s, Pwd:%s)\n", iRetVal, szDBServerName, szDBName, szDBUser,szDBPwd);

       return -1;
   }

   // 调用CDbFetch函数获取数据库返回的结果
   iRetVal = CDbFetch(pDBHandle, szRcvBuf, 100);
   if (iRetVal != 0)    // 执行失败
   {
       printf("CDbFetch failed! RetVal=%d (ServiceName:%s, DBName:%s,User:%s, Pwd:%s)\n", iRetVal, szDBServerName, szDBName, szDBUser,szDBPwd);

        return -1;
   }

   // 打印从数据库中获取到的结果
   printf("RcvBuf=%s\n", szRcvBuf);

   return 0;
}

说明：
1)CDbExecSql函数的两个输入参数分别是：数据库句柄和SQL语句缓存，CDbFetch函数的三个输入参数分别是：数据库句柄、结果集缓存及缓存大小。其中，数据库句柄是由CDbCreateDb函数执行之后获得的。

2)CDbFetch函数必须要在CDbExecSql函数执行成功之后才能执行，因为前者要靠后者从数据库中获取结果。

时间： 2024-04-27 00:01:56

Oracle调用接口(OCI)源码剖析(2)：执行SQL语句并获取结果的相关文章

Oracle调用接口(OCI)源码剖析(3)：关闭数据库连接

概述 继创建数据库连接和执行SQL语句并获取结果之后,我们继续对OCI中关闭数据库连接的源码进行剖析.该操作主要是由CDbCloseDb函数完成的. 下面对这个函数的源码进行分析. OCI中执行关闭数据库连接的源码剖析 在OCI中,CDbCloseDb函数的代码如下: void CDbCloseDb(void *hDb) { CDb *pCDb = NULL; if (NULL == hDb) { return; } pCDb = (CDb *)hDb; DoDbFree(pCDb->hdbc)

Oracle调用接口(OCI)源码剖析(1)：创建数据库连接

概述 在笔者所开发过的产品中,有很多都需要与Oracle数据库打交道.为了实现C代码与Oracle数据库的消息交互,Oracle公司为广大的开发者们提供了一个统一的调用接口OCI(Oracle Call Interface).只要按照规范来调用OCI中的函数,就能够实现C代码与Oracle数据库的交互. 具体而言,OCI的C语言API包括了两个文件:db_ora_oci_ux.h和db_ora_oci_ux.c.db_ora_oci_ux.h是头文件,而所有与数据库的交互操作的实现都是在db_o

ORACLE调用接口(OCI)简介及重要函数流程介绍

[文章摘要] 对于实现用户开销户的程序来说,与数据库进行交互是必不可少的.为了实现用户数据的存放.读取.删除等操作,我们需要频繁地访问数据库,这就对数据库的访问模式提出了较高的要求.ORACLE数据库具有系统可移植性好.使用方便.功能强等特点,因此在实际的软件开发项目中使用得非常的广泛.为了方便C语言程序操作ORACLE中的数据,ORACLE调用接口(OCI)应运而生. 本文首先简单介绍了OCI的基本情况,然后对OCI中两个重要的程序流程进行了一定的介绍.希望大家通过此文,能够对OCI有一个大致

《GDAL源码剖析与开发指南》一一1.9 简单的调用

1.9 简单的调用 GDAL源码剖析与开发指南关于GDAL的使用,关键是要熟悉GDAL的组织结构.类以及类的函数等.最常用的就是动态库的GDAL,当然我们也可以使用静态库,这里只是简单地介绍使用动态GDAL库来做开发. 下面我们简单地使用C++.C#.Python和Java 4种语言分别进行示例,来说明如何使用GDAL进行开发. 1.9.1 C ++使用GDAL首先我们打开Visual Studio2008,新建一个Win32的控制台工程(名字叫GDALCppTest),然后在工程的属性对话框中

Java集合源码剖析：TreeMap源码剖析

前言 本文不打算延续前几篇的风格(对所有的源码加入注释),因为要理解透TreeMap的所有源码,对博主来说,确实需要耗费大量的时间和经历,目前看来不大可能有这么多时间的投入,故这里意在通过于阅读源码对TreeMap有个宏观上的把握,并就其中一些方法的实现做比较深入的分析. 红黑树简介 TreeMap是基于红黑树实现的,这里只对红黑树做个简单的介绍,红黑树是一种特殊的二叉排序树,关于二叉排序树,参见:http://blog.csdn.net/ns_code/article/details/1982

Java集合源码剖析：Hashtable源码剖析

Hashtable简介 Hashtable同样是基于哈希表实现的,同样每个元素是一个key-value对,其内部也是通过单链表解决冲突问题,容量不足(超过了阀值)时,同样会自动增长. Hashtable也是JDK1.0引入的类,是线程安全的,能用于多线程环境中. Hashtable同样实现了Serializable接口,它支持序列化,实现了Cloneable接口,能被克隆. HashTable源码剖析 Hashtable的源码的很多实现都与HashMap差不多,源码如下(加入了比较详细的注释):

Java集合源码剖析：HashMap源码剖析

HashMap简介 HashMap是基于哈希表实现的,每一个元素是一个key-value对,其内部通过单链表解决冲突问题,容量不足(超过了阀值)时,同样会自动增长. HashMap是非线程安全的,只是用于单线程环境下,多线程环境下可以采用concurrent并发包下的concurrentHashMap. HashMap 实现了Serializable接口,因此它支持序列化,实现了Cloneable接口,能被克隆. HashMap源码剖析 HashMap的源码如下(加入了比较详细的注释): pac

Java集合源码剖析：Vector源码剖析

Vector简介 Vector也是基于数组实现的,是一个动态数组,其容量能自动增长. LinkedList是JDK1.0引入了,它的很多实现方法都加入了同步语句,因此是线程安全的(其实也只是相对安全,有些时候还是要加入同步语句来保证线程的安全),可以用于多线程环境. LinkedList没有丝线Serializable接口,因此它不支持序列化,实现了Cloneable接口,能被克隆,实现了RandomAccess接口,支持快速随机访问. Vector源码剖析 Vector的源码如下(加入了比较详

JS魔法堂：mmDeferred源码剖析

一.前言   avalon.js的影响力愈发强劲,而作为子模块之一的mmDeferred必然成为异步调用模式学习之旅的又一站呢!本文将记录我对mmDeferred的认识,若有纰漏请各位指正,谢谢.项目请见:mmDeferred@github   二.API说明    {Deferred} Deferred({Function|Object} mixin?) ,创建一个Deferred实例,当mixin的类型为Object时,将mixin的属性和函数附加到Deferred实例的Promise实例上