用C语言写一个oci变成例子,sql语句为查询某个表
时间: 2023-08-04 16:18:48 浏览: 95
sql 语句查询 表
好的,下面是一个简单的 OCI 查询示例程序,可以查询指定表名的所有数据:
```c
#include <stdio.h>
#include <stdlib.h>
#include <oci.h>
#define USERNAME "username" // 数据库用户名
#define PASSWORD "password" // 数据库密码
#define DBNAME "dbname" // 数据库名
int main(void) {
OCIEnv *envhp; // 环境句柄
OCIError *errhp; // 错误句柄
OCISvcCtx *svchp; // 服务句柄
OCIServer *srvhp; // 服务器句柄
OCIStmt *stmthp; // SQL语句句柄
OCIDefine *defnp = (OCIDefine *)0; // 输出变量句柄
OCISession *usrhp; // 用户会话句柄
sword status = 0; // 执行状态
int row_count = 0; // 行数计数变量
text sqlstmt[200]; // SQL语句缓冲区
// 初始化 OCI 环境
OCIInitialize((ub4) OCI_DEFAULT, (dvoid *)0, (dvoid * (*)(dvoid *, size_t)) 0,
(dvoid * (*)(dvoid *, dvoid *, size_t))0, (void (*)(dvoid *, dvoid *)) 0 );
// 分配 OCI 环境句柄
OCIEnvInit(&envhp, OCI_DEFAULT, 0, 0);
OCIHandleAlloc((dvoid *) envhp, (dvoid **) &errhp, OCI_HTYPE_ERROR, 0, 0);
OCIHandleAlloc((dvoid *) envhp, (dvoid **) &srvhp, OCI_HTYPE_SERVER, 0, 0);
OCIHandleAlloc((dvoid *) envhp, (dvoid **) &svchp, OCI_HTYPE_SVCCTX, 0, 0);
OCIHandleAlloc((dvoid *) envhp, (dvoid **) &usrhp, OCI_HTYPE_SESSION, 0, 0);
OCIHandleAlloc((dvoid *) envhp, (dvoid **) &stmthp, OCI_HTYPE_STMT, 0, 0);
// 连接数据库
OCIServerAttach(srvhp, errhp, (text *) DBNAME, strlen(DBNAME), OCI_DEFAULT);
OCIAttrSet((dvoid *) svchp, OCI_HTYPE_SVCCTX, (dvoid *) srvhp, (ub4) 0, OCI_ATTR_SERVER, errhp);
OCIAttrSet((dvoid *) usrhp, OCI_HTYPE_SESSION, (dvoid *) USERNAME, strlen(USERNAME), OCI_ATTR_USERNAME, errhp);
OCIAttrSet((dvoid *) usrhp, OCI_HTYPE_SESSION, (dvoid *) PASSWORD, strlen(PASSWORD), OCI_ATTR_PASSWORD, errhp);
OCISessionBegin(svchp, errhp, usrhp, OCI_CRED_RDBMS, OCI_DEFAULT);
// 准备 SQL 语句
sprintf((char *) sqlstmt, "SELECT * FROM %s", "table_name");
OCIStmtPrepare(stmthp, errhp, sqlstmt, strlen((char *) sqlstmt), OCI_NTV_SYNTAX, OCI_DEFAULT);
// 执行 SQL 语句
status = OCIStmtExecute(svchp, stmthp, errhp, (ub4) 0, (ub4) 0, (CONST OCISnapshot *) NULL, (OCISnapshot *) NULL, OCI_DEFAULT);
if (status != OCI_SUCCESS && status != OCI_SUCCESS_WITH_INFO) {
printf("Error: OCIStmtExecute() failed.\n");
return -1;
}
// 获取结果
OCIDefineByPos(stmthp, &defnp, errhp, 1, (dvoid *) &row_count, sizeof(row_count), SQLT_INT, (dvoid *) 0, (ub2 *) 0, (ub2 *) 0, OCI_DEFAULT);
// 输出结果
printf("Number of rows returned: %d\n", row_count);
// 断开连接
OCISessionEnd(svchp, errhp, usrhp, OCI_DEFAULT);
OCIServerDetach(srvhp, errhp, OCI_DEFAULT);
// 释放资源
OCIHandleFree((dvoid *) stmthp, OCI_HTYPE_STMT);
OCIHandleFree((dvoid *) usrhp, OCI_HTYPE_SESSION);
OCIHandleFree((dvoid *) svchp, OCI_HTYPE_SVCCTX);
OCIHandleFree((dvoid *) srvhp, OCI_HTYPE_SERVER);
OCIHandleFree((dvoid *) errhp, OCI_HTYPE_ERROR);
OCIHandleFree((dvoid *) envhp, OCI_HTYPE_ENV);
return 0;
}
```
上述示例程序的执行流程如下:
1. 初始化 OCI 环境
2. 分配 OCI 环境句柄及其他句柄
3. 连接数据库
4. 准备 SQL 语句
5. 执行 SQL 语句
6. 获取结果
7. 输出结果
8. 断开连接
9. 释放资源
需要注意的是,上述程序中的 `USERNAME`、`PASSWORD` 和 `DBNAME` 常量需要替换为实际的值,同时需要包含 `oci.h` 头文件,并且需要链接 `oci` 库。
阅读全文