不得了!这个国产数据库居然实现了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

相关文章

SpringBoot集成redisson实现延时队列教程

《SpringBoot集成redisson实现延时队列教程》文章介绍了使用Redisson实现延迟队列的完整步骤,包括依赖导入、Redis配置、工具类封装、业务枚举定义、执行器实现、Bean创建、消费... 目录1、先给项目导入Redisson依赖2、配置redis3、创建 RedissonConfig 配

Python的Darts库实现时间序列预测

《Python的Darts库实现时间序列预测》Darts一个集统计、机器学习与深度学习模型于一体的Python时间序列预测库,本文主要介绍了Python的Darts库实现时间序列预测,感兴趣的可以了解... 目录目录一、什么是 Darts?二、安装与基本配置安装 Darts导入基础模块三、时间序列数据结构与

Python使用FastAPI实现大文件分片上传与断点续传功能

《Python使用FastAPI实现大文件分片上传与断点续传功能》大文件直传常遇到超时、网络抖动失败、失败后只能重传的问题,分片上传+断点续传可以把大文件拆成若干小块逐个上传,并在中断后从已完成分片继... 目录一、接口设计二、服务端实现(FastAPI)2.1 运行环境2.2 目录结构建议2.3 serv

C#实现千万数据秒级导入的代码

《C#实现千万数据秒级导入的代码》在实际开发中excel导入很常见,现代社会中很容易遇到大数据处理业务,所以本文我就给大家分享一下千万数据秒级导入怎么实现,文中有详细的代码示例供大家参考,需要的朋友可... 目录前言一、数据存储二、处理逻辑优化前代码处理逻辑优化后的代码总结前言在实际开发中excel导入很

SpringBoot+RustFS 实现文件切片极速上传的实例代码

《SpringBoot+RustFS实现文件切片极速上传的实例代码》本文介绍利用SpringBoot和RustFS构建高性能文件切片上传系统,实现大文件秒传、断点续传和分片上传等功能,具有一定的参考... 目录一、为什么选择 RustFS + SpringBoot?二、环境准备与部署2.1 安装 RustF

Nginx部署HTTP/3的实现步骤

《Nginx部署HTTP/3的实现步骤》本文介绍了在Nginx中部署HTTP/3的详细步骤,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学... 目录前提条件第一步:安装必要的依赖库第二步:获取并构建 BoringSSL第三步:获取 Nginx

MyBatis Plus实现时间字段自动填充的完整方案

《MyBatisPlus实现时间字段自动填充的完整方案》在日常开发中,我们经常需要记录数据的创建时间和更新时间,传统的做法是在每次插入或更新操作时手动设置这些时间字段,这种方式不仅繁琐,还容易遗漏,... 目录前言解决目标技术栈实现步骤1. 实体类注解配置2. 创建元数据处理器3. 服务层代码优化填充机制详

Python实现Excel批量样式修改器(附完整代码)

《Python实现Excel批量样式修改器(附完整代码)》这篇文章主要为大家详细介绍了如何使用Python实现一个Excel批量样式修改器,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一... 目录前言功能特性核心功能界面特性系统要求安装说明使用指南基本操作流程高级功能技术实现核心技术栈关键函

Java实现字节字符转bcd编码

《Java实现字节字符转bcd编码》BCD是一种将十进制数字编码为二进制的表示方式,常用于数字显示和存储,本文将介绍如何在Java中实现字节字符转BCD码的过程,需要的小伙伴可以了解下... 目录前言BCD码是什么Java实现字节转bcd编码方法补充总结前言BCD码(Binary-Coded Decima

Linux下MySQL数据库定时备份脚本与Crontab配置教学

《Linux下MySQL数据库定时备份脚本与Crontab配置教学》在生产环境中,数据库是核心资产之一,定期备份数据库可以有效防止意外数据丢失,本文将分享一份MySQL定时备份脚本,并讲解如何通过cr... 目录备份脚本详解脚本功能说明授权与可执行权限使用 Crontab 定时执行编辑 Crontab添加定