LightDB Pro*C SQLDA介绍

2024-06-03 19:12
文章标签 介绍 pro lightdb sqlda

本文主要是介绍LightDB Pro*C SQLDA介绍，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

背景介绍

SQLDA（SQL Descriptor Area）是与数据库交互的程序所使用的数据结构。它通常用于在执行 SQL 语句时传递数据、参数和结果。
一个 SQLDA是一种处理SELECT、FETCH或者DESCRIBE语句结果的高级方法。一个 SQLDA把数据中一行的数据及元数据项组合到一个数据结构中。

使用 SQLDA 的程序的一般流程是：

  1. 准备一个查询，并且为它声明一个游标。
  2. 为结果行声明一个 SQLDA 。
  3. 为输入参数声明一个 SQLDA，并且初始化它们（内存分配、参数设置）。
  4. 用输入 SQLDA 打开一个游标。
  5. 从游标中取得行，并且把它们存储到一个输出 SQLDA。
  6. 从输出 SQLDA 读取值到主变量中（必要时使用转换）。
  7. 关闭游标。
  8. 关闭为输入 SQLDA 分配的内存区域。

常用的数据结构

SQLDA 使用三种数据结构类型：sqlda_t、sqlvar_t以及struct sqlname。

sqlda_t 结构

结构类型sqlda_t是实际 SQLDA 的类型。它保存一个记录。并且两个或者更多个sqlda_t结构能够以desc_next域中的指针连接成一个链表，这样可以表示一个有序的行集合。因此，当两个或多个行被取得时，应用可以通过沿着每一个sqlda_t节点中的desc_next指针读取它们。

sqlda_t的定义是：

struct sqlda_struct
{char            sqldaid[8];long            sqldabc;short           sqln;short           sqld;struct sqlda_struct *desc_next;struct sqlvar_struct sqlvar[1];
};typedef struct sqlda_struct sqlda_t;

域的含义是：

  • sqldaid
    它包含一个字符串"SQLDA "。
  • sqldabc
    它包含已分配空间的尺寸（以字节计）。
  • sqln
    当它被传递给使用USING关键词的OPEN、DECLARE或者EXECUTE语句时，它包含用于一个参数化查询实例的输入参数的数目。在它被用作SELECT、EXECUTE或FETCH语句的输出时，它的值和sqld一样
  • sqld
    它包含一个结果集中的域的数量。
  • desc_next
    如果查询返回不止一个记录，会返回多个链接在一起的 SQLDA 结构，并且desc_next保存一个指向下一个项的指针。sqlvar 这是结果集中列的数组。
sqlvar_t 结构

结构类型sqlvar_t保存一个列值和元数据（例如类型和长度）。
该类型的定义是：

struct sqlvar_struct
{short          sqltype;short          sqllen;char          *sqldata;short         *sqlind;struct sqlname sqlname;
};typedef struct sqlvar_struct sqlvar_t;

各个域的含义是：

  • sqltype
    包含该域的类型标识符。值可以参考ecpgtype.h中的enum ECPGttype。
  • sqllen
    包含域的二进制长度，例如ECPGt_int是 4 字节。
  • sqldata
    指向数据。数据的格式在Section 33.4.4中描述。
  • sqlind
    指向空指示符。0 表示非空，-1 表示空。
  • sqlname
    域的名称。
struct sqlname 结构

一个struct sqlname结构保持一个列名。它被用作sqlvar_t结构的一个成员。
该结构的定义是：

#define NAMEDATALEN 64struct sqlname
{short           length;char            data[NAMEDATALEN];
};

各个域的含义是：

  • length
    包含域名称的长度。
  • data
    包含实际的域名称。

使用一个 SQLDA 检索一个结果集

通过一个 SQLDA 检索一个查询结果集的一般步骤是：

  1. 声明一个sqlda_t结构来接收结果集。
  2. 执行 FETCH/EXECUTE/DESCRIBE 命令来处理一个指定已声明 SQLDA 的查询。
  3. 通过查看sqlda_t结构的成员sqln来检查结果集中记录的数量。
  4. 从sqlda_t结构的成员sqlvar[0]、sqlvar[1]等中得到每一列的值。
  5. 沿着sqlda_t结构的成员desc_next指针到达下一行（sqlda_t）。
  6. 根据你的需要重复上述步骤。

首先，声明一个sqlda_t结构来接收结果集。

sqlda_t *sqlda1;

接下来，指定一个命令中的 SQLDA。这是一个FETCH命令的例子。

EXEC SQL FETCH NEXT FROM cur1 INTO DESCRIPTOR sqlda1;

运行一个循环顺着链表来检索行。

sqlda_t *cur_sqlda;for (cur_sqlda = sqlda1;cur_sqlda != NULL;cur_sqlda = cur_sqlda->desc_next)
{...
}

在循环内部，运行另一个循环来检索行中每一列的数据（sqlvar_t结构）。

for (i = 0; i < cur_sqlda->sqld; i++)
{sqlvar_t v = cur_sqlda->sqlvar[i];char *sqldata = v.sqldata;short sqllen  = v.sqllen;...
}

要得到一列的值，应检查sqlvar_t结构的成员sqltype的值。然后，根据列类型切换到一种合适的方法从sqlvar域中复制数据到一个主变量。

char var_buf[1024];switch (v.sqltype)
{case ECPGt_char:memset(&var_buf, 0, sizeof(var_buf));memcpy(&var_buf, sqldata, (sizeof(var_buf) <= sqllen ? sizeof(var_buf) - 1 : sqllen));break;case ECPGt_int: /* integer */memcpy(&intval, sqldata, sqllen);snprintf(var_buf, sizeof(var_buf), "%d", intval);break;...
}

使用一个 SQLDA 传递查询参数

使用一个 SQLDA 传递输入参数给一个预备查询的一般步骤是：

  1. 创建一个预备查询（预备语句）。

  2. 声明一个 sqlda_t 结构作为输入 SQLDA。

  3. 为输入 SQLDA 分配内存区域（作为 sqlda_t 结构）。

  4. 在分配好的内存中设置（复制）输入值。

  5. 打开一个说明了输入 SQLDA 的游标。

首先，创建一个预备语句。

EXEC SQL BEGIN DECLARE SECTION;
char query[1024] = "SELECT d.oid, * FROM pg_database d, pg_stat_database s WHERE d.oid = s.datid AND (d.datname = ? OR d.oid = ?)";
EXEC SQL END DECLARE SECTION;EXEC SQL PREPARE stmt1 FROM :query;

接下来为一个 SQLDA 分配内存，并且在sqlda_t结构的sqln成员变量中设置输入参数的数量。当预备查询要求两个或多个输入参数时，应用必须分配额外的内存空间，空间的大小为 (参数数目 - 1) * sizeof(sqlvar_t)。这里的例子展示了为两个输入参数分配内存空间。

sqlda_t *sqlda2;sqlda2 = (sqlda_t *) malloc(sizeof(sqlda_t) + sizeof(sqlvar_t));
memset(sqlda2, 0, sizeof(sqlda_t) + sizeof(sqlvar_t));sqlda2->sqln = 2; /* 输入变量的数目 */

内存分配之后，把参数值存储到sqlvar[]数组（当 SQLDA 在接收结果集时，这也是用来检索列值的数组）。在这个例子中，输入参数是"postgres"（字符串类型）和1（整数类型）。

sqlda2->sqlvar[0].sqltype = ECPGt_char;
sqlda2->sqlvar[0].sqldata = "postgres";
sqlda2->sqlvar[0].sqllen  = 8;int intval = 1;
sqlda2->sqlvar[1].sqltype = ECPGt_int;
sqlda2->sqlvar[1].sqldata = (char *) &intval;
sqlda2->sqlvar[1].sqllen  = sizeof(intval);

通过打开一个游标并且说明之前已经建立好的 SQLDA，输入参数被传递给预备语句。

EXEC SQL OPEN cur1 USING DESCRIPTOR sqlda2;

最后，用完输入 SQLDA 后必须显式地释放已分配的内存空间，这与用于接收查询结果的 SQLDA 不同。

free(sqlda2);

完整样例代码

#include <stdlib.h>
#include <string.h>
#include <stdlib.h>
#include <stdio.h>
#include <unistd.h>EXEC SQL include sqlda.h;sqlda_t *sqlda1; /* 用于输出的描述符 */
sqlda_t *sqlda2; /* 用于输入的描述符 */EXEC SQL WHENEVER NOT FOUND DO BREAK;
EXEC SQL WHENEVER SQLERROR STOP;int
main(void)
{EXEC SQL BEGIN DECLARE SECTION;char query[1024] = "SELECT d.oid,* FROM pg_database d, pg_stat_database s WHERE d.oid=s.datid AND ( d.datname=? OR d.oid=? )";int intval;unsigned long long int longlongval;EXEC SQL END DECLARE SECTION;EXEC SQL CONNECT TO uptimedb AS con1 USER uptime;EXEC SQL SELECT pg_catalog.set_config('search_path', '', false); EXEC SQL COMMIT;EXEC SQL PREPARE stmt1 FROM :query;EXEC SQL DECLARE cur1 CURSOR FOR stmt1;/* 为一个输入参数创建一个 SQLDA 结构 */sqlda2 = (sqlda_t *)malloc(sizeof(sqlda_t) + sizeof(sqlvar_t));memset(sqlda2, 0, sizeof(sqlda_t) + sizeof(sqlvar_t));sqlda2->sqln = 2; /* 输入变量的数量 */sqlda2->sqlvar[0].sqltype = ECPGt_char;sqlda2->sqlvar[0].sqldata = "postgres";sqlda2->sqlvar[0].sqllen  = 8;intval = 1;sqlda2->sqlvar[1].sqltype = ECPGt_int;sqlda2->sqlvar[1].sqldata = (char *) &intval;sqlda2->sqlvar[1].sqllen  = sizeof(intval);/* 用输入参数打开一个游标。 */EXEC SQL OPEN cur1 USING DESCRIPTOR sqlda2;while (1){sqlda_t *cur_sqlda;/* 给游标分配描述符  */EXEC SQL FETCH NEXT FROM cur1 INTO DESCRIPTOR sqlda1;for (cur_sqlda = sqlda1 ;cur_sqlda != NULL ;cur_sqlda = cur_sqlda->desc_next){int i;char name_buf[1024];char var_buf[1024];/* 打印一行中的每一列。 */for (i=0 ; i<cur_sqlda->sqld ; i++){sqlvar_t v = cur_sqlda->sqlvar[i];char *sqldata = v.sqldata;short sqllen  = v.sqllen;strncpy(name_buf, v.sqlname.data, v.sqlname.length);name_buf[v.sqlname.length] = '\0';switch (v.sqltype){case ECPGt_char:memset(&var_buf, 0, sizeof(var_buf));memcpy(&var_buf, sqldata, (sizeof(var_buf)<=sqllen ? sizeof(var_buf)-1 : sqllen) );break;case ECPGt_int: /* 整数 */memcpy(&intval, sqldata, sqllen);snprintf(var_buf, sizeof(var_buf), "%d", intval);break;case ECPGt_long_long: /* 大整数 */memcpy(&longlongval, sqldata, sqllen);snprintf(var_buf, sizeof(var_buf), "%lld", longlongval);break;default:{int i;memset(var_buf, 0, sizeof(var_buf));for (i = 0; i < sqllen; i++){char tmpbuf[16];snprintf(tmpbuf, sizeof(tmpbuf), "%02x ", (unsigned char) sqldata[i]);strncat(var_buf, tmpbuf, sizeof(var_buf));}}break;}printf("%s = %s (type: %d)\n", name_buf, var_buf, v.sqltype);}printf("\n");}}free(sqlda2);EXEC SQL CLOSE cur1;EXEC SQL COMMIT;EXEC SQL DISCONNECT ALL;return 0;
}

这篇关于LightDB Pro*C SQLDA介绍的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1027865。

相关文章

性能测试介绍

性能测试介绍

性能测试是一种测试方法，旨在评估系统、应用程序或组件在现实场景中的性能表现和可靠性。它通常用于衡量系统在不同负载条件下的响应时间、吞吐量、资源利用率、稳定性和可扩展性等关键指标。 为什么要进行性能测试 通过性能测试，可以确定系统是否能够满足预期的性能要求，找出性能瓶颈和潜在的问题，并进行优化和调整。 发现性能瓶颈：性能测试可以帮助发现系统的性能瓶颈，即系统在高负载或高并发情况下可能出现的问题
阅读更多...
水位雨量在线监测系统概述及应用介绍

水位雨量在线监测系统概述及应用介绍

在当今社会，随着科技的飞速发展，各种智能监测系统已成为保障公共安全、促进资源管理和环境保护的重要工具。其中，水位雨量在线监测系统作为自然灾害预警、水资源管理及水利工程运行的关键技术，其重要性不言而喻。 一、水位雨量在线监测系统的基本原理 水位雨量在线监测系统主要由数据采集单元、数据传输网络、数据处理中心及用户终端四大部分构成，形成了一个完整的闭环系统。 数据采集单元：这是系统的“眼睛”，
阅读更多...
Hadoop数据压缩使用介绍

Hadoop数据压缩使用介绍

一、压缩原则 （1）运算密集型的Job，少用压缩 （2）IO密集型的Job，多用压缩 二、压缩算法比较 三、压缩位置选择 四、压缩参数配置 1）为了支持多种压缩/解压缩算法，Hadoop引入了编码/解码器 2）要在Hadoop中启用压缩，可以配置如下参数
阅读更多...
图神经网络模型介绍（1）

图神经网络模型介绍（1）

我们将图神经网络分为基于谱域的模型和基于空域的模型，并按照发展顺序详解每个类别中的重要模型。 1.1基于谱域的图神经网络         谱域上的图卷积在图学习迈向深度学习的发展历程中起到了关键的作用。本节主要介绍三个具有代表性的谱域图神经网络：谱图卷积网络、切比雪夫网络和图卷积网络。 （1）谱图卷积网络 卷积定理：函数卷积的傅里叶变换是函数傅里叶变换的乘积，即F{f*g}
阅读更多...
C++——stack、queue的实现及deque的介绍

C++——stack、queue的实现及deque的介绍

目录 1.stack与queue的实现 1.1stack的实现  1.2 queue的实现 2.重温vector、list、stack、queue的介绍 2.1 STL标准库中stack和queue的底层结构  3.deque的简单介绍 3.1为什么选择deque作为stack和queue的底层默认容器  3.2 STL中对stack与queue的模拟实现 ①stack模拟实现
阅读更多...
Mysql BLOB类型介绍

Mysql BLOB类型介绍

BLOB类型的字段用于存储二进制数据 在MySQL中，BLOB类型，包括：TinyBlob、Blob、MediumBlob、LongBlob，这几个类型之间的唯一区别是在存储的大小不同。 TinyBlob 最大 255 Blob 最大 65K MediumBlob 最大 16M LongBlob 最大 4G
阅读更多...
FreeRTOS-基本介绍和移植STM32

FreeRTOS-基本介绍和移植STM32

FreeRTOS-基本介绍和STM32移植 一、裸机开发和操作系统开发介绍二、任务调度和任务状态介绍2.1 任务调度2.1.1 抢占式调度2.1.2 时间片调度 2.2 任务状态 三、FreeRTOS源码和移植STM323.1 FreeRTOS源码3.2 FreeRTOS移植STM323.2.1 代码移植3.2.2 时钟中断配置 一、裸机开发和操作系统开发介绍 裸机：前后台系
阅读更多...
nginx介绍及常用功能

nginx介绍及常用功能

什么是nginx nginx跟Apache一样，是一个web服务器（网站服务器），通过HTTP协议提供各种网络服务。 Apache：重量级的，不支持高并发的服务器。在Apache上运行数以万计的并发访问，会导致服务器消耗大量内存。操作系统对其进行进程或线程间的切换也消耗了大量的CPU资源，导致HTTP请求的平均响应速度降低。这些都决定了Apache不可能成为高性能WEB服务器  nginx：
阅读更多...
多路转接之select(fd_set介绍,参数详细介绍),实现非阻塞式网络通信

多路转接之select(fd_set介绍,参数详细介绍),实现非阻塞式网络通信

目录 多路转接之select 引入 介绍 fd_set 函数原型 nfds readfds / writefds / exceptfds readfds  总结  fd_set操作接口  timeout timevalue 结构体 传入值 返回值 代码 注意点 -- 调用函数 select的参数填充  获取新连接 注意点 -- 通信时的调用函数 添加新fd到
阅读更多...
火语言RPA流程组件介绍--浏览网页

火语言RPA流程组件介绍--浏览网页

🚩【组件功能】：浏览器打开指定网址或本地html文件 配置预览 配置说明 网址URL 支持T或# 默认FLOW输入项 输入需要打开的网址URL 超时时间 支持T或# 打开网页超时时间 执行后后等待时间(ms) 支持T或# 当前组件执行完成后继续等待的时间 UserAgent 支持T或# User Agent中文名为用户代理，简称 UA，它是一个特殊字符串头，使得服务器
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2