linux数据库查询结果集,拼接查询sql中指定列的结果集

一时失言乱红尘 2023-01-20 15:52 71阅读 0赞

函数适用于：需要将指定查询sql中的某列拼接成以指定字符分隔连接的字符串。

不足：因函数的返回值为varchar2,且通常拼接得到的字符串会用于查询sql(因用在SQL中，不能大于varchar2的4000个字符限制)中，因此限制了返回长度小于等于4000

CREATEORREPLACEFUNCTIONf\_con\_colunn\_set(p\_sqlINVARCHAR2,

\--传入的sql语句

p\_column\_indexINTEGERDEFAULT1,

\--需要连接的字段索引位置(从1开始，默认为1)

p\_con\_strINVARCHAR2DEFAULT','

\--连接时的分隔符，默认为逗号

)RETURNVARCHAR2IS

/\*适用于需要将sql语句的某列查询结果(大于一条记录)拼接成一个字段返回，

限制了返回长度小于等于4000(因用在SQL中，不能大于varchar2的4000个字符限制)

\*/

v\_value       VARCHAR2(4000);

v\_return      VARCHAR2(8000) :='';

sqlstr\_cursorINTEGER;

v\_ignoreINTEGER;

v\_nameINTEGER;

v\_col\_countINTEGER;

v\_column\_desc dbms\_sql.desc\_tab;

BEGIN

v\_name := dbms\_sql.open\_cursor;

dbms\_sql.parse(v\_name, p\_sql, dbms\_sql.native);

dbms\_sql.describe\_columns(v\_name, v\_col\_count, v\_column\_desc);

DBMS\_SQL.close\_cursor(v\_name);

IF p\_column\_index > 0ANDp\_column\_index <= v\_col\_countTHEN

sqlstr\_cursor := DBMS\_SQL.open\_cursor;

DBMS\_SQL.parse(sqlstr\_cursor, p\_sql, DBMS\_SQL.native);

DBMS\_SQL.define\_column(sqlstr\_cursor,

p\_column\_index,

v\_column\_desc(p\_column\_index).col\_name,

4000);

v\_ignore := DBMS\_SQL.EXECUTE(sqlstr\_cursor);

LOOP

IF DBMS\_SQL.fetch\_rows(sqlstr\_cursor) > 0THEN

DBMS\_SQL.COLUMN\_VALUE(sqlstr\_cursor, p\_column\_index, v\_value);

IF length(v\_return || v\_value) > 4000THEN

EXIT;

ELSE

v\_return := v\_return || p\_con\_str || v\_value;

ENDIF;

ELSE

EXIT;

ENDIF;

ENDLOOP;

v\_return := substr(v\_return, length(p\_con\_str) + 1, 4000);

DBMS\_SQL.close\_cursor(sqlstr\_cursor);

ENDIF;

RETURNv\_return;

EXCEPTION

WHENOTHERSTHEN

IF DBMS\_SQL.is\_open(v\_name)THEN

DBMS\_SQL.close\_cursor(v\_name);

ENDIF;

IF DBMS\_SQL.is\_open(sqlstr\_cursor)THEN

DBMS\_SQL.close\_cursor(sqlstr\_cursor);

ENDIF;

RETURN'';

ENDf\_con\_colunn\_set;CREATE OR REPLACE FUNCTION f\_con\_colunn\_set(p\_sql IN VARCHAR2,

\--传入的sql语句

p\_column\_index INTEGER DEFAULT 1,

\--需要连接的字段索引位置(从1开始，默认为1)

p\_con\_str IN VARCHAR2 DEFAULT ','

\--连接时的分隔符，默认为逗号

) RETURN VARCHAR2 IS

/\*适用于需要将sql语句的某列查询结果(大于一条记录)拼接成一个字段返回，

限制了返回长度小于等于4000(因用在SQL中，不能大于varchar2的4000个字符限制)

\*/

v\_value VARCHAR2(4000);

v\_return VARCHAR2(8000) := '';

sqlstr\_cursor INTEGER;

v\_ignore INTEGER;

v\_name INTEGER;

v\_col\_count INTEGER;

v\_column\_desc dbms\_sql.desc\_tab;

BEGIN

v\_name := dbms\_sql.open\_cursor;

dbms\_sql.parse(v\_name, p\_sql, dbms\_sql.native);

dbms\_sql.describe\_columns(v\_name, v\_col\_count, v\_column\_desc);

DBMS\_SQL.close\_cursor(v\_name);

IF p\_column\_index > 0 AND p\_column\_index <= v\_col\_count THEN

sqlstr\_cursor := DBMS\_SQL.open\_cursor;

DBMS\_SQL.parse(sqlstr\_cursor, p\_sql, DBMS\_SQL.native);

DBMS\_SQL.define\_column(sqlstr\_cursor,

p\_column\_index,

v\_column\_desc(p\_column\_index).col\_name,

4000);

v\_ignore := DBMS\_SQL.EXECUTE(sqlstr\_cursor);

LOOP

IF DBMS\_SQL.fetch\_rows(sqlstr\_cursor) > 0 THEN

DBMS\_SQL.COLUMN\_VALUE(sqlstr\_cursor, p\_column\_index, v\_value);

IF length(v\_return || v\_value) > 4000 THEN

EXIT;

ELSE

v\_return := v\_return || p\_con\_str || v\_value;

END IF;

ELSE

EXIT;

END IF;

END LOOP;

v\_return := substr(v\_return, length(p\_con\_str) + 1, 4000);

DBMS\_SQL.close\_cursor(sqlstr\_cursor);

END IF;

RETURN v\_return;

EXCEPTION

WHEN OTHERS THEN

IF DBMS\_SQL.is\_open(v\_name) THEN

DBMS\_SQL.close\_cursor(v\_name);

END IF;

IF DBMS\_SQL.is\_open(sqlstr\_cursor) THEN

DBMS\_SQL.close\_cursor(sqlstr\_cursor);

END IF;

RETURN '';

END f\_con\_colunn\_set;

\--测试方法

\--1)只传SQL,默认返回col1的以逗号分隔连接值：test1,test2

SELECT f\_con\_colunn\_set('select ''test1'' col1,1 col2 from dual union all select ''test2'' col1,2 col2 from dual')

FROM dual;

\--2)传SQL,传col2的索引值(从1开始),返回col2以逗号分隔的连接值： 1,2

SELECT f\_con\_colunn\_set('select ''test1'' col1,1 col2 from dual union all select ''test2'' col1,2 col2 from dual',

2)

FROM dual;

\--3)传SQL,传col2的索引值(从1开始),分隔值';'，返回col2以分号号分隔的连接值1;2

SELECT f\_con\_colunn\_set('select ''test1'' col1,1 col2 from dual union all select ''test2'' col1,2 col2 from dual',

2,

';')

FROM dual;

\--4)传SQL,传索引值(从1开始)3，传入的索引值超过SQL的列索引集合，不存在此列，返回空值

SELECT f\_con\_colunn\_set('select ''test1'' col1,1 col2 from dual union all select ''test2'' col1,2 col2 from dual',

3)

FROM dual;![0b1331709591d260c1c78e86d0c51c18.png][]

[0b1331709591d260c1c78e86d0c51c18.png]: /images/20221021/35054afb5f5347f286f52f09e74b0980.png

发表评论取消回复

表情：

评论列表（有 0 条评论，71人围观）

还没有评论，来说两句吧...

相关阅读

相关 Java数据库操作（JDBC）：查询结果集的例子

在Java中，使用JDBC进行数据库操作主要是通过Connection对象来执行SQL语句。以下是一个简单的例子，展示如何查询数据库并获取结果集： 1. 导入必要的库： ``

古城微笑少年丶/ 2024年10月21日 07:15/ 0 赞/ 38 阅读

相关 18. Mybatis 查询结果集映射

ybatis 最强大的特性大概就是结果集映射了吧. 相比Hibernate, Mybatis 的结果集映射不局限于PO, Mybatis可以将结果集映射为任意的java ...

谁借莪１个温暖的怀抱￠/ 2024年04月17日 14:59/ 0 赞/ 74 阅读

相关 linux数据库查询结果集,拼接查询sql中指定列的结果集

函数适用于：需要将指定查询sql中的某列拼接成以指定字符分隔连接的字符串。不足：因函数的返回值为varchar2,且通常拼接得到的字符串会用于查询sql(因用在SQL中，不

一时失言乱红尘/ 2023年01月20日 15:52/ 0 赞/ 72 阅读

相关 SpringBoot+Mybatis关联查询多表数据拼接结果集

SpringBoot+Mybatis关联查询多表数据集一、需求描述二、项目代码三、测试一、需求描述 sys\_column\_role的

矫情吗；*/ 2022年09月14日 02:20/ 0 赞/ 150 阅读

相关计算机sql查询同行并集,SQL 操作结果集 -并集、差集、交集、结果集排序(示例代码)...

操作结果集为了配合测试，特地建了两个表，并且添加了一些测试数据，其中重复记录为东吴的人物。表：Person\_1魏国人物 ![3cc8cc86038f4d9390e1

青旅半醒/ 2022年08月29日 10:48/ 0 赞/ 209 阅读

相关 PHP零基础遍历查询数据库结果集

使用mysql的方式访问 $link = mysql\_connect("localhost","root","snowdi"); mysql\_select\_db("数

谁践踏了优雅/ 2022年06月18日 02:28/ 0 赞/ 200 阅读

相关 Hibernate hql 查询指定字段并获取结果集

Hibernate hql 查询指定字段并获取结果集 -------------------- 在hibernate中，用hql语句查询实体类，采用list方法的返回结果为

蔚落/ 2022年06月13日 07:14/ 0 赞/ 223 阅读

相关 linux 导出sql查询结果

导出命令 > mysql -h172.0.0.1 -uXXXX -pXXXX -P3306 -e”select \ from user” > /temp/test.txt

╰+哭是因爲堅強的太久メ/ 2022年05月20日 06:47/ 0 赞/ 462 阅读

相关 sql查询结果列拼接成逗号分隔的字符串

背景：做SQL查询时会经常需要，把查询的结果拼接成一个字符串。解决方法：通过 group\_concat 函数 ![watermark_type_ZmFuZ3poZW5

港控/mmm°/ 2022年04月23日 04:10/ 0 赞/ 368 阅读

相关 oracle批量插入查询结果集

insert之后的括号不应该添加values insert into table1 (P_CODE, DEP_CODE, DOC_UUID, created, up

素颜马尾好姑娘i/ 2021年07月17日 01:03/ 0 赞/ 461 阅读