不得了!这个国产数据库居然实现了Oracle聚合函数vm_concat

本文主要是介绍不得了!这个国产数据库居然实现了Oracle聚合函数vm_concat,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

熟悉Oracle的朋友一定听过或者用过这个聚合函数vm_concat。说到这个函数,含泪的讲,给我们带来了很多故障,当然都是客户开发商的人员不了解Oracle版本变化带来的问题。

是的,实际上Oracle 11g之后就不再推荐使用这个函数了,在处理varchar2的时候会导致temp使用暴涨。

然而,很多应用程序在12c或19c中可能自定义了类似wm_concat的函数,例如 my_wm_concat。这些函数被广泛使用在应用程序中。当这些应用程序的数据库迁移到国产数据库如MogDB时,如果希望数据库层面兼容而不修改应用代码,通常迁移工具只能做语句规则替换;要么我们就需要实现函数兼容。

在开源PostgreSQL版本中有string_agg函数实现类型功能,MogDB中除了支持string_agg之外,同时还支持listagg(是的,你没有看错,兼容Oracle 12c的listagg函数),也自带了wm_concat。但需要注意一点的是,MogDB中vm_concat函数不支持像oracle一样的synonym给个别名,需要创建函数。

这里给大家简单分享一下:

MogDB=# \da+ wm_concatList of aggregate functionsSchema   |   Name    | Result data type | Argument data types | Description
------------+-----------+------------------+---------------------+-------------pg_catalog | wm_concat | text             | text                |
(1 row)SELECT p.proname AS function_name,pg_catalog.pg_get_function_result(p.oid) AS result_type,pg_catalog.pg_get_function_arguments(p.oid) AS argument_types,CASEWHEN p.proisagg THEN 'agg'ELSE 'normal'END AS function_type,a.aggtransfn,a.aggfinalfnFROM pg_catalog.pg_proc p
LEFT JOIN pg_catalog.pg_namespace n ON n.oid = p.pronamespace
LEFT JOIN pg_catalog.pg_aggregate a ON a.aggfnoid = p.oidWHERE a.aggfnoid IS NOT NULLAND p.proname like 'wm_concat%';function_name | result_type | argument_types | function_type |      aggtransfn      |      aggfinalfn
---------------+-------------+----------------+---------------+----------------------+----------------------wm_concat     | text        | text           | agg           | vm_concat_state_func | vm_concat_final_funcSELECT p.proname AS function_name,pg_catalog.pg_get_function_result(p.oid) AS result_type,pg_catalog.pg_get_function_arguments(p.oid) AS argument_types,CASEWHEN p.proisagg THEN 'agg'ELSE 'normal'END AS function_type,a.aggtransfn,a.aggfinalfnFROM pg_catalog.pg_proc p
LEFT JOIN pg_catalog.pg_namespace n ON n.oid = p.pronamespace
LEFT JOIN pg_catalog.pg_aggregate a ON a.aggfnoid = p.oidWHERE a.aggfnoid IS NOT NULLAND p.proname like 'string_agg%';function_name | result_type | argument_types | function_type |        aggtransfn        |        aggfinalfn
---------------+-------------+----------------+---------------+--------------------------+--------------------------string_agg    | text        | text, text     | agg           | string_agg_transfn       | string_agg_finalfnstring_agg    | bytea       | bytea, bytea   | agg           | bytea_string_agg_transfn | bytea_string_agg_finalfn
(2 rows)SELECT p.proname AS function_name,pg_catalog.pg_get_function_result(p.oid) AS result_type,pg_catalog.pg_get_function_arguments(p.oid) AS argument_types,CASEWHEN p.proisagg THEN 'agg'ELSE 'normal'END AS function_type,a.aggtransfn,a.aggfinalfnFROM pg_catalog.pg_proc p
LEFT JOIN pg_catalog.pg_namespace n ON n.oid = p.pronamespace
LEFT JOIN pg_catalog.pg_aggregate a ON a.aggfnoid = p.oidWHERE a.aggfnoid IS NOT NULLAND p.proname like 'listagg%';function_name | result_type |          argument_types           | function_type |             aggtransfn              |    aggfinalfn
---------------+-------------+-----------------------------------+---------------+-------------------------------------+------------------listagg       | text        | text, text                        | agg           | list_agg_transfn                    | list_agg_finalfnlistagg       | text        | text                              | agg           | list_agg_noarg2_transfn             | list_agg_finalfnlistagg       | text        | smallint, text                    | agg           | int2_list_agg_transfn               | list_agg_finalfnlistagg       | text        | smallint                          | agg           | int2_list_agg_noarg2_transfn        | list_agg_finalfnlistagg       | text        | integer, text                     | agg           | int4_list_agg_transfn               | list_agg_finalfnlistagg       | text        | integer                           | agg           | int4_list_agg_noarg2_transfn        | list_agg_finalfnlistagg       | text        | bigint, text                      | agg           | int8_list_agg_transfn               | list_agg_finalfnlistagg       | text        | bigint                            | agg           | int8_list_agg_noarg2_transfn        | list_agg_finalfnlistagg       | text        | real, text                        | agg           | float4_list_agg_transfn             | list_agg_finalfnlistagg       | text        | real                              | agg           | float4_list_agg_noarg2_transfn      | list_agg_finalfnlistagg       | text        | double precision, text            | agg           | float8_list_agg_transfn             | list_agg_finalfnlistagg       | text        | double precision                  | agg           | float8_list_agg_noarg2_transfn      | list_agg_finalfnlistagg       | text        | numeric, text                     | agg           | numeric_list_agg_transfn            | list_agg_finalfnlistagg       | text        | numeric                           | agg           | numeric_list_agg_noarg2_transfn     | list_agg_finalfnlistagg       | text        | date, text                        | agg           | date_list_agg_transfn               | list_agg_finalfnlistagg       | text        | date                              | agg           | date_list_agg_noarg2_transfn        | list_agg_finalfnlistagg       | text        | timestamp without time zone, text | agg           | timestamp_list_agg_transfn          | list_agg_finalfnlistagg       | text        | timestamp without time zone       | agg           | timestamp_list_agg_noarg2_transfn   | list_agg_finalfnlistagg       | text        | timestamp with time zone, text    | agg           | timestamptz_list_agg_transfn        | list_agg_finalfnlistagg       | text        | timestamp with time zone          | agg           | timestamptz_list_agg_noarg2_transfn | list_agg_finalfnlistagg       | text        | interval, text                    | agg           | interval_list_agg_transfn           | list_agg_finalfnlistagg       | text        | interval                          | agg           | interval_list_agg_noarg2_transfn    | list_agg_finalfn
(22 rows)MogDB=# \df string_aggList of functionsSchema   |    Name    | Result data type | Argument data types | Type | fencedmode | propackage | prokind
------------+------------+------------------+---------------------+------+------------+------------+---------pg_catalog | string_agg | bytea            | bytea, bytea        | agg  | f          | f          | fpg_catalog | string_agg | text             | text, text          | agg  | f          | f          | f
(2 rows)MogDB=# select wm_concat(name) from test2;wm_concat
-----------1,2,3
(1 row)MogDB=# select string_agg(name,',') from test2;string_agg
------------1,2,3
(1 row)MogDB=# select string_agg(name,',' order by id desc ) from test2;
select string_agg(name,',' order by id desc ) from test2;string_agg
------------3,2,1
(1 row)MogDB=# select listagg(name,',') within group(order by id desc ) from test2;
select listagg(name,',') within group(order by id desc ) from test2;listagg
---------3,2,1
(1 row)

MogDB中的wm_concat、string_agg、listagg都可以实现类似oracle 中的wm_concat函数功能。

MogDB=# CREATE OR REPLACE FUNCTION pg_catalog.my_wm_concat_state_func (results text, val text)
MogDB-#  RETURNS text
MogDB-#  LANGUAGE sql COST 50 IMMUTABLE
MogDB-#  AS $$ select results || ',' ||val; $$;
CREATE FUNCTION
MogDB=# 
MogDB=#  CREATE OR REPLACE FUNCTION pg_catalog.my_wm_concat_final_func (results text)
MogDB-#  RETURNS text
MogDB-#  LANGUAGE sql COST 111 IMMUTABLE
MogDB-#  AS $$ select substr(results, 2); $$;
CREATE FUNCTION
MogDB=# 
MogDB=# CREATE AGGREGATE pg_catalog.my_wm_concat(text)
MogDB-#  (
MogDB(#    sfunc = pg_catalog.my_wm_concat_state_func,
MogDB(#    stype = text,
MogDB(#    initcond = '',
MogDB(#    FINALFUNC = pg_catalog.my_wm_concat_final_func
MogDB(#  );
CREATE AGGREGATE
MogDB=# 
MogDB=# 
MogDB=# select my_wm_concat(name) from test2;my_wm_concat   
-----------------aaa,bbb,ccc,ddd
(1 row)MogDB=# 

欢迎大家多多体验MogDB,并发现其中的一些乐趣!

关于聚合函数的一些更多内容,详见官方文档:https://docs.mogdb.io/zh/mogdb/v5.0/aggregate-functions

这篇关于不得了!这个国产数据库居然实现了Oracle聚合函数vm_concat的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1030721

相关文章

MySQL常用字符串函数示例和场景介绍

《MySQL常用字符串函数示例和场景介绍》MySQL提供了丰富的字符串函数帮助我们高效地对字符串进行处理、转换和分析,本文我将全面且深入地介绍MySQL常用的字符串函数,并结合具体示例和场景,帮你熟练... 目录一、字符串函数概述1.1 字符串函数的作用1.2 字符串函数分类二、字符串长度与统计函数2.1

Redis客户端连接机制的实现方案

《Redis客户端连接机制的实现方案》本文主要介绍了Redis客户端连接机制的实现方案,包括事件驱动模型、非阻塞I/O处理、连接池应用及配置优化,具有一定的参考价值,感兴趣的可以了解一下... 目录1. Redis连接模型概述2. 连接建立过程详解2.1 连php接初始化流程2.2 关键配置参数3. 最大连

Python实现网格交易策略的过程

《Python实现网格交易策略的过程》本文讲解Python网格交易策略,利用ccxt获取加密货币数据及backtrader回测,通过设定网格节点,低买高卖获利,适合震荡行情,下面跟我一起看看我们的第一... 网格交易是一种经典的量化交易策略,其核心思想是在价格上下预设多个“网格”,当价格触发特定网格时执行买

Oracle数据库定时备份脚本方式(Linux)

《Oracle数据库定时备份脚本方式(Linux)》文章介绍Oracle数据库自动备份方案,包含主机备份传输与备机解压导入流程,强调需提前全量删除原库数据避免报错,并需配置无密传输、定时任务及验证脚本... 目录说明主机脚本备机上自动导库脚本整个自动备份oracle数据库的过程(建议全程用root用户)总结

python设置环境变量路径实现过程

《python设置环境变量路径实现过程》本文介绍设置Python路径的多种方法:临时设置(Windows用`set`,Linux/macOS用`export`)、永久设置(系统属性或shell配置文件... 目录设置python路径的方法临时设置环境变量(适用于当前会话)永久设置环境变量(Windows系统

python使用try函数详解

《python使用try函数详解》Pythontry语句用于异常处理,支持捕获特定/多种异常、else/final子句确保资源释放,结合with语句自动清理,可自定义异常及嵌套结构,灵活应对错误场景... 目录try 函数的基本语法捕获特定异常捕获多个异常使用 else 子句使用 finally 子句捕获所

Python对接支付宝支付之使用AliPay实现的详细操作指南

《Python对接支付宝支付之使用AliPay实现的详细操作指南》支付宝没有提供PythonSDK,但是强大的github就有提供python-alipay-sdk,封装里很多复杂操作,使用这个我们就... 目录一、引言二、准备工作2.1 支付宝开放平台入驻与应用创建2.2 密钥生成与配置2.3 安装ali

Spring Security 单点登录与自动登录机制的实现原理

《SpringSecurity单点登录与自动登录机制的实现原理》本文探讨SpringSecurity实现单点登录(SSO)与自动登录机制,涵盖JWT跨系统认证、RememberMe持久化Token... 目录一、核心概念解析1.1 单点登录(SSO)1.2 自动登录(Remember Me)二、代码分析三、

PyCharm中配置PyQt的实现步骤

《PyCharm中配置PyQt的实现步骤》PyCharm是JetBrains推出的一款强大的PythonIDE,结合PyQt可以进行pythion高效开发桌面GUI应用程序,本文就来介绍一下PyCha... 目录1. 安装China编程PyQt1.PyQt 核心组件2. 基础 PyQt 应用程序结构3. 使用 Q

Python实现批量提取BLF文件时间戳

《Python实现批量提取BLF文件时间戳》BLF(BinaryLoggingFormat)作为Vector公司推出的CAN总线数据记录格式,被广泛用于存储车辆通信数据,本文将使用Python轻松提取... 目录一、为什么需要批量处理 BLF 文件二、核心代码解析:从文件遍历到数据导出1. 环境准备与依赖库