[postgresql]postgresql自定义函数查询ETL作业依赖的实例

---------------------------------------------------
---需求：查找ETL依赖关系
---描述：根据作业ID，查找上游依赖的作业ID
---依赖表结构：TBL_METADATA_RELATION：
--id int
           --sourceid varchar2
           --targetid varchar2
--原理：对树结构进行深度遍历，使用栈的保存中间结果
--------------------------------------------------
SET serveroutput ON;
--创建类型
create or replace type id_list_table is table of varchar2(36);
/
--创建函数
drop function p_search_source;
CREATE OR REPLACE function p_search_source( id VARCHAR2)
return id_list_table
IS
   v_table_temp id_list_table;
   v_table_stack id_list_table;
   v_table_source id_list_table;
   i int;
   j int;
BEGIN
v_table_temp:=id_list_table();
v_table_stack:=id_list_table();
v_table_source:=id_list_table();

select SOURCE_ID bulk collect into v_table_temp from idata.TBL_METADATA_RELATION where target_id=id;
v_table_stack:=v_table_temp;
i:=v_table_stack.count;
dbe_output.print_line('[info] start i='|| i );
dbe_output.print_line('[info] v_table_stack count:'|| v_table_stack.count );

if v_table_stack.count<>0
then

while i>0 loop

dbe_output.print_line('[info] '|| v_table_stack(i) ||' add to v_table_source');
   v_table_source.extend(1);
   v_table_source(v_table_source.count):=v_table_stack(i);
   --初始化为空数据集
   v_table_temp:=id_list_table();
   select SOURCE_ID bulk collect into v_table_temp from idata.TBL_METADATA_RELATION where target_id=v_table_stack(i);

--栈顶元素出栈
   v_table_stack.trim;
   j:=v_table_temp.count;
   while j>0 loop
   v_table_stack.extend(1);
   v_table_stack(v_table_stack.count):=v_table_temp(j);

j:=j-1;
   end loop;
   i:=v_table_stack.count;
   dbe_output.print_line('[info] v_table_source.count='||v_table_source.count );
end loop;
end if;
return v_table_source;
END;
/
--执行
select COLUMN_VALUE as sources from table(cast(p_search_source('d6531654-f6ed-46dd-ac81-4efd9bf4afa4') as id_list_table ));

[postgresql]postgresql自定义函数查询ETL作业依赖的实例相关推荐

postgresql中自定义函数脚本的备份及恢复
[转自 housonglin1213 的博客]http://blog.csdn.net/housonglin1213/article/details/51005540 1.自定义函数脚本备份 CREA ...
查看oracle自定义函数,Oracle自定义函数查询数据字典项
/****************************** 假设存储数据字典表名:data_dict_entry 表结构如下: create table data_dict_entry ( DIC ...
oracle自定义函数获取省份,oracle自定义函数查询数据字典项
/****************************** 假设存储数据字典表名:data_dict_entry 表结构如下: create table data_dict_entry ( DIC ...
PostgreSQL · 实现分析 · PostgreSQL 10.0 并行查询和外部表的结合
前言大家都知道,PostgreSQL 近几大版本中加入了很多 OLAP 相关特性.9.6 的并行扫描应该算最大的相关特性.在今年发布的 10.0 中,并行扫描也在不断加强,新增了并行的索引扫描. 我 ...
MySQL自定义函数（CREATE FUNCTION）
在使用 MySQL 的过程中,MySQL 自带的函数可能完成不了我们的业务需求,这时候就需要自定义函数. 自定义函数是一种与存储过程十分相似的过程式数据库对象.它与存储过程一样,都是由 SQL 语句和 ...
rds支持mysql自带函数吗_MySQL自定义函数（CREATE FUNCTION）
在使用MySQL的过程中,MySQL 自带的函数可能完成不了我们的业务需求,这时候就需要自定义函数.自定义函数是一种与存储过程十分相似的过程式数据库对象.它与存储过程一样,都是由 SQL 语句和过程式 ...
MySQL如何自定义函数
在使用 MySQL 的过程中,MySQL 自带的函数可能完成不了我们的业务需求,这时候就需要自定义函数. 自定义函数是一种与存储过程十分相似的过程式数据库对象.它与存储过程一样,都是由 SQL 语句和 ...
mysql自定义函数 PHP_MySQL自定义函数（CREATE FUNCTION）
在使用 MySQL 的过程中,MySQL 自带的函数可能完成不了我们的业务需求,这时候就需要自定义函数. 自定义函数是一种与存储过程十分相似的过程式数据库对象.它与存储过程一样,都是由 SQL 语句和 ...
《手把手陪您学Python》26——自定义函数
在上一篇<手把手陪您学Python>25--列表推导式中,我们学习了推导式的相关概念和使用方法,使用推导式的方法,可以减少代码的输入量.提高可读性,是Python中非常受欢迎的一种形式. ...

[postgresql]postgresql自定义函数查询ETL作业依赖的实例

[postgresql]postgresql自定义函数查询ETL作业依赖的实例相关推荐

最新文章

热门文章