`
alienchang
  • 浏览: 31602 次
  • 性别: Icon_minigender_1
  • 来自: 杭州
社区版块
存档分类
最新评论

Oracle OCI编程流程

oraclecoci 
阅读更多
这是在做OCI开发时写的一些测试的代码，基本流程很简单如下：

>>创建环境句柄 OCIEnvCreate(&envhp,OCI_DEFAULT,(dvoid *)0, 0,0,0,0,(dvoid **)0);
>>申请错误句柄 OCIHandleAlloc((dvoid *) envhp,(dvoid **)&errhp, OCI_HTYPE_ERROR,(size_t)0,(dvoid **)0);
>>申请服务器句柄 OCIHandleAlloc((dvoid *)envhp,(dvoid **)&srvhp, OCI_HTYPE_SERVER,(size_t)0,(dvoid **)0);
>>申请服务环境句柄 OCIHandleAlloc((dvoid *)envhp,(dvoid **)&svchp, OCI_HTYPE_SVCCTX,(size_t)0,(dvoid **)0);
>>设置服务环境的服务器属性 OCIAttrSet((dvoid *)svchp,OCI_HTYPE_SVCCTX, (dvoid *)srvhp,(ub4)0,OCI_ATTR_SERVER,(OCIError *)errhp);
>>连接数据库，建立会话 status = OCILogon(envhp,errhp,&svchp,(const OraText*)user,(ub4)strlen((char *)user), (text *)pass_word,(ub4)strlen((char *)pass_word),(text *)servername,(ub4)strlen((char *)servername));

>>申请语句句柄 OCIHandleAlloc((dvoid *)envhp,(dvoid **)&stmthp, OCI_HTYPE_STMT,(size_t)0,(dvoid **)0);
>>准备sql语句 OCIStmtPrepare(stmthp,errhp,(const OraText*)sqlstat, (ub4)strlen((char *) sqlstat),OCI_NTV_SYNTAX,OCI_DEFAULT));
>>定义输出变量 OCIDefineByPos(stmthp,&defhp[0],errhp,1,&sum, sizeof(sum),SQLT_INT,(sb2 *)0,0,(ub2 *)0,OCI_DEFAULT) );
>>执行sql语句 OCIStmtExecute(svchp,stmthp,errhp,(ub4)0, (ub4)0,(const OCISnapshot *)NULL, (OCISnapshot *)NULL, OCI_DEFAULT);

>>取结果OCIStmtFetch(stmthp,errhp,1,OCI_FETCH_NEXT,OCI_DEFAULT);

>>断开连接 OCILogoff(svchp,errhp);

几个需要注意的地方：

1.输出变量（存储过程参数除外）用OCIDefineByPos

2.在调用存储过程时要用OCIBindByPos绑定所有参数

3.Oracle存储过程返回结果集不像mysql和sqlserver，需要用cursor OUT出来，在程序中接收cursor让很多人很迷惑，cursor需要用OCIStmt来绑定，然后和正常STMT一样来读取结果


如果还有不懂的地方，下面是示例代码： 
#include "OCI.h" 
#include <conio.h>
#include <stdio.h>
#include <string>
#include <Windows.h>

using namespace std;

const char user[31] = "alien"; 
const char pass_word[31] = "alienchang"; 
const char servername[31] = "orcl"; 

void read();
void procedure();

typedef sword (*FuncOCIEnvCreate)(OCIEnv**,ub4, void*, void* (*malocfp)(void*, size_t),void* (*ralocfp)(void*, void*,size_t),void (*mfreefp)(void*, void*),size_t, void**);

void error_proc(dvoid *errhp, sword status) 
{ 
	text errbuf[512]; 
	sb4 errcode; 
	switch (status) 
	{ 
	case OCI_SUCCESS: 
		// printf("OCI_success\n"); 
		break; 
	case OCI_SUCCESS_WITH_INFO: 
		printf("OCI error: OCI_success_with_info\n"); 
		break; 
	case OCI_NEED_DATA: 
		printf("OCI error: OCI_need_data\n"); 
		break; 
	case OCI_NO_DATA: 
		printf("OCI error: OCI_no_data\n"); 
		break; 
	case OCI_ERROR: 
		(void)OCIErrorGet((dvoid *)errhp,(ub4)1,NULL,&errcode, 
			errbuf,(ub4)sizeof(errbuf),OCI_HTYPE_ERROR); 
		printf("错误号：%d\n错误信息：%s\n",errcode,errbuf); 
		break; 
	case OCI_INVALID_HANDLE: 
		printf("OCI error: OCI_invalid_handle\n"); 
		break; 
	case OCI_STILL_EXECUTING: 
		printf("OCI error: OCI_still_executing\n"); 
		break; 
	default: 
		break; 
	} 

} 

void main () 
{
	procedure();
	return ; 
} 

void procedure()
{
	OCIEnv *envhp = NULL;
	OCIError *errhp = NULL;
	OCIServer *srvhp = NULL;
	OCISvcCtx *svchp = NULL;
	OCIStmt *stmthp = NULL;
	OCIStmt *curstmthp = NULL;
	OCIBind *bndlp[3];
	OCIDefine *defhp[3];
	char account[30] = "D5SJ53WE06";
	int number = 0;
	sword status = 0;
	ub2 type = 0;
	char* sqlstat = "begin say(:v_text, :v_num); end;";//"begin pak_rc.get(:v_account, :v_cursor); end;"; 


	OCIEnvCreate(&envhp, OCI_DEFAULT, 0, 0, 0, 0, 0, (dvoid**)0);
	OCIHandleAlloc(envhp, (dvoid**)&errhp, OCI_HTYPE_ERROR, 0, (dvoid**)0);
	error_proc(errhp, OCIHandleAlloc((dvoid*)envhp, (dvoid**)&srvhp,
		OCI_HTYPE_SERVER, 0, (dvoid**)0));
	error_proc(errhp, OCIHandleAlloc((dvoid*)envhp, (dvoid**)&svchp,
		OCI_HTYPE_SVCCTX, 0, (dvoid**)0));

	status = OCILogon(envhp, errhp, &svchp, (const OraText*)user, (ub4)strlen(user),
		(const OraText*)pass_word, (ub4)strlen(pass_word), (const OraText*)servername, (ub4)strlen(servername));

	if ( OCI_SUCCESS == status )
		printf("Connect Successsfully!\n");
	else{
		printf("Connect Failed!");
		error_proc(errhp, status);
		return;
	}

	error_proc(errhp, OCIHandleAlloc((dvoid*)envhp, (dvoid**)&stmthp,
		OCI_HTYPE_STMT, 0, (dvoid**)0));

	error_proc(errhp, OCIHandleAlloc((dvoid*)envhp, (dvoid**)&curstmthp,
		OCI_HTYPE_STMT, 0, (dvoid**)0));

	error_proc(errhp, OCIStmtPrepare(stmthp, errhp, (const OraText*)sqlstat,
		(ub4)strlen(sqlstat), OCI_NTV_SYNTAX, OCI_DEFAULT));

	/*error_proc(errhp, OCIDefineByPos(stmthp, &defhp[0], errhp, 2, &curstmthp,
		0, SQLT_RSET, (ub2*)0, 0, (ub2*)0, OCI_DEFAULT));

	char test[32];*/

	int pnum = 0;
	OCIParam *param;
	/*error_proc(errhp, OCIAttrGet ((dvoid *)stmthp, (ub4)OCI_HTYPE_STMT,
		(dvoid *)&pnum, (ub4 *)0, (ub4)OCI_ATTR_PARAM_COUNT,
		errhp));*/
	/*error_proc(errhp, OCIParamGet (stmthp, OCI_HTYPE_STMT, errhp,
		(dvoid **)¶m, 1));
	error_proc(errhp, OCIAttrGet (param, OCI_DTYPE_PARAM,
		(dvoid *)&type, (ub4 *)0, OCI_ATTR_DATA_TYPE, errhp));*/
	printf("%d type: %d\n", pnum, type);
	printf("%d: %d %d: %d", account, &account, &curstmthp, curstmthp);
	
	error_proc(errhp, OCIBindByPos(stmthp, &bndlp[0], errhp, 1, &account, strlen(account) + 1,
		SQLT_STR, NULL, NULL, NULL, 0, NULL, (ub4)OCI_DEFAULT));
	error_proc(errhp, OCIBindByPos(stmthp, &bndlp[1], errhp, 2, &number, sizeof(number),
		SQLT_INT, NULL, NULL, NULL, 0, NULL, (ub4)OCI_DEFAULT));
	/*error_proc(errhp, OCIBindByPos(stmthp, &bndlp[1], errhp, 2, &curstmthp, sizeof(curstmthp),
		SQLT_RSET, NULL, NULL, NULL, 0, NULL, (ub4)OCI_DEFAULT));*/
	

	/*error_proc(errhp, OCIDefineByPos(stmthp, &defhp[0], errhp, 1,(dvoid *)test,
		(sb4)sizeof(test), SQLT_STR, (ub2*)0, 0, (ub2*)0, OCI_DEFAULT));*/

	if ( (status = OCIStmtExecute(svchp,stmthp,errhp,(ub4)1, 
		(ub4)0,(const OCISnapshot *)NULL, (OCISnapshot *)NULL, 
		OCI_COMMIT_ON_SUCCESS)) && status != OCI_SUCCESS_WITH_INFO )
	{
		error_proc(errhp, status);
		printf("-----ora_search,error in OCIStmtexecute-----\n"); 
		return;
	}
	printf("string: %s; number: %d\n", account, number);
	getch(); 

	int num = 0;
	/*error_proc(errhp, OCIAttrGet ((dvoid *)curstmthp, (ub4)OCI_HTYPE_STMT,
		(dvoid *)&num, (ub4 *)0, (ub4)OCI_ATTR_PARAM_COUNT,
		errhp));
	printf("%d\n", num);

	char c_account[64], pwd[64];
	error_proc(errhp, OCIDefineByPos(curstmthp, &defhp[1], errhp,1, c_account, sizeof(account), 
		SQLT_STR, (ub2)0, 0, 0,OCI_DEFAULT)); 
	error_proc(errhp, OCIDefineByPos(curstmthp, &defhp[2], errhp,2, pwd, sizeof(pwd), 
		SQLT_STR, (ub2*)0, 0, 0,OCI_DEFAULT)); 

	error_proc(errhp,OCIStmtFetch(curstmthp,errhp,1,OCI_FETCH_NEXT,OCI_DEFAULT));

	do
	{
		printf("status: %d Account:%s PWD:%s\n", status, c_account, pwd);
		status = OCIStmtFetch(stmthp,errhp,1,OCI_FETCH_NEXT,OCI_DEFAULT);
	}while( OCI_SUCCESS == status );*/

	//断开连接 
	error_proc(errhp,OCILogoff(svchp,errhp)); 
	OCIHandleFree(errhp, OCI_HTYPE_ERROR); 
}

void read()
{
	OCIEnv *envhp = NULL; //环境句柄 
	OCIError *errhp = NULL; //错误句柄 
	OCIServer *srvhp = NULL; //服务器句柄 
	OCISvcCtx *svchp = NULL; //服务环境句柄 
	OCIStmt *stmthp = NULL; //语句句柄 
	OCIBind *bnd1p = (OCIBind *)0; //结合句柄 
	OCIDefine *defhp[5]; //定义句柄 
	sword status; 
	int sum; //命中记录数 
	char account[50];
	char* sqlstat = "select id,account from hx_account"; 
	int li_ret; 

	li_ret = 0; 

	// char *summary_element=" rec_ctrl_id,title,first_author,book_search_no,publisher"; 

	//创建环境句柄 
	OCIEnvCreate(&envhp,OCI_DEFAULT,(dvoid *)0, 
		0,0,0,0,(dvoid **)0);
	//申请错误句柄 
	OCIHandleAlloc((dvoid *) envhp,(dvoid **)&errhp, 
		OCI_HTYPE_ERROR,(size_t)0,(dvoid **)0); 
	//申请服务器句柄 
	error_proc(errhp,OCIHandleAlloc((dvoid *)envhp,(dvoid **)&srvhp, 
		OCI_HTYPE_SERVER,(size_t)0,(dvoid **)0)); 
	//申请服务环境句柄 
	error_proc(errhp,OCIHandleAlloc((dvoid *)envhp,(dvoid **)&svchp, 
		OCI_HTYPE_SVCCTX,(size_t)0,(dvoid **)0)); 
	//设置服务环境的服务器属性 
	error_proc(errhp,OCIAttrSet((dvoid *)svchp,OCI_HTYPE_SVCCTX, 
		(dvoid *)srvhp,(ub4)0,OCI_ATTR_SERVER,(OCIError *)errhp)); 
	//连接数据库，建立会话 
	status = OCILogon(envhp,errhp,&svchp,(const OraText*)user,(ub4)strlen((char *)user), 
		(text *)pass_word,(ub4)strlen((char *)pass_word),(text *)servername,(ub4)strlen((char *)servername)); 

	if (status==OCI_SUCCESS) 
		printf("成功连接melinets数据库，已为%s用户建立会话.\n",user); 
	else { 
		printf("连接失败connect fail!\n"); 
		printf("-----ora_search,error in OCIlogon-----\n"); 
		error_proc(errhp,status); 
		return; 
	} 
	//申请语句句柄 
	error_proc(errhp,OCIHandleAlloc((dvoid *)envhp,(dvoid **)&stmthp, 
		OCI_HTYPE_STMT,(size_t)0,(dvoid **)0)); 

	//准备sql语句 
	error_proc(errhp,OCIStmtPrepare(stmthp,errhp,(const OraText*)sqlstat, 
		(ub4)strlen((char *) sqlstat),OCI_NTV_SYNTAX,OCI_DEFAULT)); 

	//-------定义输出变量 
	error_proc(errhp, OCIDefineByPos(stmthp,&defhp[0],errhp,1,&sum, 
		sizeof(sum),SQLT_INT,(sb2 *)0,0,(ub2 *)0,OCI_DEFAULT) ); 

	error_proc(errhp, OCIDefineByPos(stmthp,&defhp[1],errhp,2,&account, 
		sizeof(account),SQLT_STR,(sb2 *)0,0,(ub2 *)0,OCI_DEFAULT) ); 

	// ora_search(&li_ret); 
	// printf("li_ret is %d\n",li_ret); 

	//执行sql语句 
	if ((status=OCIStmtExecute(svchp,stmthp,errhp,(ub4)0, 
		(ub4)0,(const OCISnapshot *)NULL, (OCISnapshot *)NULL, 
		OCI_DEFAULT)) 
		&& status != OCI_SUCCESS_WITH_INFO) 
	{ //失败则退出 
		error_proc(errhp,status); 
		printf("-----ora_search,error in OCIStmtexecute-----\n"); 
		return; 
	} 
	getch(); 

	error_proc(errhp,OCIStmtFetch(stmthp,errhp,1,OCI_FETCH_NEXT,OCI_DEFAULT)); 

	do
	{
		string strValue;
		strValue = account;
		printf("ID:%d  Account:%s\n", sum, strValue.c_str());
		status = OCIStmtFetch(stmthp,errhp,1,OCI_FETCH_NEXT,OCI_DEFAULT);
	}while( OCI_SUCCESS == status );
	//断开连接 
	error_proc(errhp,OCILogoff(svchp,errhp)); 
}
分享到：
| ODBC访问Oracle实例（附代码）
评论
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

    oracle oci编程

    ### Oracle OCI 编程知识点详解 #### 一、Oracle OCI简介 Oracle Call Interface (OCI) 是 Oracle 提供的一套 C 语言应用程序接口，用于开发高性能的应用程序，这些应用程序可以直接调用 Oracle 数据库服务。OCI ...

    oracle 8i oci 编程手册

    ### Oracle 8i OCI 编程手册知识点概览 #### 一、OCI（Oracle Call Interface）简介 Oracle Call Interface (OCI) 是一个强大的程序接口，它允许开发人员使用 C 语言来开发高效的应用程序，这些应用程序可以访问 ...

    c#封装oracle的OCI

    总的来说，封装Oracle OCI是为了简化开发和部署流程，提高代码的可维护性和复用性。在实际开发中，可以根据项目需求进一步扩展和优化这个封装库，例如添加连接池管理、事务控制、性能监控等功能，以满足更复杂的应用...

    oci编程示例讲解.pdf

    ### OCI编程示例详解 #### 一、OCI简介 Oracle Call Interface (OCI) 是 Oracle 提供的一套 C/C++ 库接口，用于实现应用程序与 Oracle 数据库之间的交互。OCI 支持多种高级特性，如事务处理、大对象支持、安全模型...

    oci.dll oracle 12

    在Oracle 12版本中，oci.dll扮演着连接应用程序与数据库服务器的关键角色，使得开发者可以通过编程语言（如C、C++等）与Oracle数据库进行交互。 "Navicat Premium for Oracle" 是一个强大的数据库管理工具，它支持...

    OCI操作oracle数据库

    OCI（Oracle Call Interface）是Oracle公司提供的一套强大的应用程序编程接口（API），专门用于在各种编程语言（如C、C++、COBOL和FORTRAN）中开发能够直接操纵Oracle数据库的应用程序。OCI的引入极大地便利了数据库...

    oci 编程教程oci函数的详细介绍

    OCI 连接过程比较复杂，除了分配设置各个基本句柄外，还要明确彼此之间的联系，大致流程如下： 创建环境句柄： OCIEnvCreate(&envhp;, …); 创建一个指定环境的错误句柄： OCIHandleAlloc((dvoid *)envhp, (dvoid **...

    navicat_oracle11g_oci.zip

    OCI是Oracle公司提供的一个编程接口，允许开发者在C/C++环境中直接访问Oracle数据库。Navicat是一款流行的数据库管理工具，它支持多种数据库系统，包括Oracle，而这里的oci.zip可能是为了在Navicat中通过OCI驱动程序...

    OracleSpatial_OCI-code\code

    OCI（Oracle Call Interface）是 Oracle 提供的一种 C 语言编程接口，用于与 Oracle 数据库进行交互。这个压缩包"OracleSpatial_OCI-code\code"包含了与 Oracle Spatial 相关的 OCI 编码示例，是学习如何使用 OCI ...

    Oracle官方OCI(Oracle Call Interface)文档翻译.docx

    OCI编程基础 - **编程概述**：OCI应用程序的基本目标是代表多个用户进行数据库操作。基本的编程顺序包括初始化环境和线程、分配句柄并建立服务器连接、执行SQL语句进行数据交换、终止会话和断开连接以及释放句柄等...

    oracle数据库接口oci的封装ocilib

    Oracle数据库接口OCI（Oracle Call Interface）是Oracle公司提供的一个C编程接口，允许开发者直接与Oracle数据库进行交互。oci的封装ocilib则是为了简化这个过程，为C++开发者提供了一个更友好的API，使得在C++中...

    OCIProjects(已测试好的Demo).rar

    oci_projects 是一个基于C++利用Oracle Call Interface (OCI)库进行数据库操作的示例项目，已经过测试并可直接运行。这个项目对于那些想要学习如何在C++中与Oracle数据库进行交互的开发者来说，是非常有价值的资源。...

    Oracle ProC 编程入门.pdf

    总之，Oracle Pro*C编程入门不仅介绍了Pro*C的基本概念和编译流程，还深入探讨了其语法结构和动态SQL处理技巧，为开发者提供了全面的指南，帮助他们在Oracle数据库环境中构建高效、安全的C语言应用程序。

    Oracle OCI tracer-开源

    OCI（Oracle Call Interface）是Oracle数据库提供的一种编程接口，允许开发人员在各种编程语言中直接与Oracle数据库进行交互。这款工具的核心功能是对通过OCI接口进行的数据库操作进行详细追踪，帮助开发者和DBA分析...

    Oracle ProC 编程入门

    通过本文对 Oracle ProC 的介绍，我们不仅了解了 ProC 的基本概念和特点，还深入探讨了其编译流程、关键语法结构以及动态 SQL 的使用方法。这些知识点对于想要在 Oracle 平台上进行高效应用程序开发的开发者来说是...

    OCI 在 vc中

    OCI (Oracle Call Interface) 是由Oracle公司提供的一组头文件和库函数组成的API，允许开发者在C、C++、COBOL和FORTRAN等第三代编程语言中使用SQL来操纵Oracle数据库。OCI的主要特点包括： - **全面支持Oracle的...

    OCI.rar_C++ OCI_oci_visual c

    为了更深入地学习和实践OCI编程，可以参考Oracle官方文档、相关的书籍和在线教程。在Visual C++环境中，利用调试工具可以帮助理解函数调用和数据库操作的流程。 6. **最佳实践** - 总是正确处理错误，使用`...

    32位需要的OCI和plsql。exe文件.zip

    Oracle Call Interface (OCI) 是 Oracle 公司提供的一种 C 语言编程接口，它允许开发者编写能够直接与 Oracle 数据库交互的应用程序。而 PL/SQL，全称是 Procedural Language/SQL，是 Oracle 数据库内置的一种过程化...

Magicbox
Global site tag (gtag.js) - Google Analytics