当前位置:首页 > 行业动态 > 正文

c语言调用oracle实现数据库交互连接

使用OCI库,通过设置环境变量、加载驱动、建立连接、执行SQL语句和关闭连接等步骤实现C语言调用Oracle数据库交互连接。

在C语言中调用Oracle数据库进行交互连接,可以使用Oracle提供的OCI(Oracle Call Interface)库,以下是详细的步骤和小标题:

1、安装Oracle客户端和OCI库

下载并安装Oracle客户端软件,例如Oracle Instant Client。

下载并安装OCI库,可以从Oracle官方网站下载。

2、配置环境变量

设置ORACLE_HOME环境变量,指向Oracle客户端的安装目录。

设置LD_LIBRARY_PATH环境变量,包含OCI库的路径。

3、编写C语言代码

包含必要的头文件,例如#include <stdio.h>、#include <oci.h>等。

定义回调函数,用于处理OCI错误。

初始化OCI环境,包括创建句柄、设置字符集等。

连接到Oracle数据库,使用OCI函数进行连接操作。

执行SQL语句,使用OCI函数执行查询或更新操作。

处理查询结果,将数据从OCI结构体中提取出来。

关闭OCI环境,释放资源。

4、编译和运行代码

使用C编译器编译代码,例如gcc。

运行生成的可执行文件,观察输出结果。

以下是一个简单的示例代码:

#include <stdio.h>
#include <oci.h>
void error(const char *err_msg) {
    printf("Error: %s
", err_msg);
}
int main() {
    OCIEnv *envhp;
    OCIServer *srvhp;
    OCIError *errhp;
    OCISvcCtx *svchp;
    OCISession *usrhp;
    OCIStmt *stmthp;
    text *sql;
    ub4 rowcount;
    ub4 columncount;
    ub2 status;
    sb4 retcode;
    char *username = "username";
    char *password = "password";
    char *dbname = "dbname";
    char *connstr = "(DESCRIPTION=(ADDRESS=(PROTOCOL=TCP)(HOST=hostname)(PORT=port))(CONNECT_DATA=(SERVICE_NAME=service_name)))";
    // 初始化OCI环境
    retcode = OCIInitialize(NULL, NULL, NULL, NULL, NULL);
    if (retcode != OCI_SUCCESS) {
        error("Failed to initialize OCI environment");
        return 1;
    }
    // 创建环境句柄、会话句柄、服务句柄等
    // ...省略具体代码...
    // 连接到Oracle数据库
    retcode = OCILogon2(svchp, errhp, &usrhp, (OraText *)username, strlen((char *)username), (OraText *)password, strlen((char *)password), dbname, strlen((char *)dbname), (OraText *)connstr, strlen((char *)connstr), OCI_DEFAULT);
    if (retcode != OCI_SUCCESS) {
        error("Failed to connect to database");
        return 1;
    }
    // 准备SQL语句
    sql = (text *)"SELECT * FROM table_name";
    retcode = OCIStmtPrepare(svchp, stmthp, errhp, (OraText *)sql, strlen((char *)sql), OCI_NTV_SYNTAX, OCI_DEFAULT);
    if (retcode != OCI_SUCCESS) {
        error("Failed to prepare SQL statement");
        return 1;
    }
    // 执行SQL语句并获取结果集
    retcode = OCIStmtExecute(svchp, stmthp, errhp, (ub4)1, (ub4)0, NULL, (ub4)0, OCI_DEFAULT);
    if (retcode != OCI_SUCCESS) {
        error("Failed to execute SQL statement");
        return 1;
    }
    // 获取结果集的元信息和列数、行数等信息
    // ...省略具体代码...
    // 处理查询结果,提取数据并打印输出
    while ((status = OCIFetchNext(svchp, stmthp, errhp, (ub4)1, (ub4)0, OCI_FETCH_BOTH)) == OCI_SUCCESS) {
        // ...省略具体代码...
        printf("Column1: %s
", column1); // 假设查询结果有两列,分别为column1和column2
        printf("Column2: %s
", column2); // ...省略具体代码...
    }
    if (status != OCI_NO_DATA) {
        error("Failed to fetch data from result set");
        return 1;
    } else {
        printf("No data found in result set
"); // ...省略具体代码...
    }
    // 关闭资源和断开连接
    // ...省略具体代码...
}
0