postgresql实现影响分析

本文涉及的产品
云原生数据库 PolarDB MySQL 版,通用型 2核4GB 50GB
云原生数据库 PolarDB PostgreSQL 版,标准版 2核4GB 50GB
简介: 通过postgresql模仿分析假如城市发布通知,位于街道的人员是否受到了影响

1.建表
--城市表createtable country(Parent_id varchar(100),Parent_name varchar(500),Child_id varchar(100),Child_name varchar(500));/*数据来源网络https://baike.baidu.com/item/%E6%9D%AD%E5%B7%9E/147639#reference-[172]-18593808-wrap*/INSERTINTO COUNTRY VALUES('100','浙江省','1001','杭州市');INSERTINTO COUNTRY VALUES('100','浙江省','1002','温州市');INSERTINTO COUNTRY VALUES('100','浙江省','1003','嘉兴市');INSERTINTO COUNTRY VALUES('100','浙江省','1004','绍兴区');INSERTINTO COUNTRY VALUES('1001','杭州市','10011','上城区');INSERTINTO COUNTRY VALUES('1001','杭州市','10012','拱墅区');INSERTINTO COUNTRY VALUES('1001','杭州市','10013','西湖区');INSERTINTO COUNTRY VALUES('1001','杭州市','10014','滨江区');INSERTINTO COUNTRY VALUES('1001','杭州市','10015','萧山区');INSERTINTO COUNTRY VALUES('1001','杭州市','10016','余杭区');INSERTINTO COUNTRY VALUES('1001','杭州市','10017','临平区');INSERTINTO COUNTRY VALUES('1001','杭州市','10018','钱塘区');INSERTINTO COUNTRY VALUES('1001','杭州市','10019','富阳区');INSERTINTO COUNTRY VALUES('1001','杭州市','10020','临安区');INSERTINTO COUNTRY VALUES('1001','杭州市','10021','建德市');INSERTINTO COUNTRY VALUES('1001','杭州市','10022','桐庐县');INSERTINTO COUNTRY VALUES('1001','杭州市','10023','淳安县');INSERTINTO COUNTRY VALUES('10011','上城区','100111','望江街道');INSERTINTO COUNTRY VALUES('10012','拱墅区','100121','拱宸桥街道');INSERTINTO COUNTRY VALUES('10013','西湖区','100131','西湖街道');INSERTINTO COUNTRY VALUES('10014','滨江区','100141','西兴街道');INSERTINTO COUNTRY VALUES('10015','萧山区','100151','北干街道');INSERTINTO COUNTRY VALUES('10016','余杭区','100161','仓前街道');INSERTINTO COUNTRY VALUES('10017','临平区','100171','临平街道');INSERTINTO COUNTRY VALUES('10018','钱塘区','100181','河庄街道');INSERTINTO COUNTRY VALUES('10019','富阳区','100191','富春街道');INSERTINTO COUNTRY VALUES('10020','临安区','100201','锦城街道');INSERTINTO COUNTRY VALUES('10021','建德市','100211','新安江街道');INSERTINTO COUNTRY VALUES('10022','桐庐县','100221','城南街道');INSERTINTO COUNTRY VALUES('10023','淳安县','100231','千岛湖镇');--人员表createtable person(street_id varchar(100),street_name varchar(500),person_id varchar(100),person_name varchar(500));insertinto person values('100131','西湖街道','1001311','张三');insertinto person values('100141','西兴街道','1001411','李四');

2.创建函数

CREATEORREPLACEFUNCTION getInfluencedPerson(src_name varchar(100))RETURNS SETOF person AS $$
BEGIN/*创建临时表*/CREATE TEMP TABLEIFNOTEXISTS street(  Street_Id varchar(100),  Street_name varchar(500))ONCOMMIT PRESERVE rows;/*同一session可能调用多次,删除历史无效数据*/DELETEFROM street;/*获取受影响的街道*/INSERTINTO street
WITH RECURSIVE city AS(SELECTParent_id,Parent_name,Child_id,Child_name
FROM COUNTRY
WHERE Parent_name = src_name
UNIONALLSELECTchild.Parent_id,child.Parent_name,child.Child_id,child.Child_name
FROM COUNTRY child
INNER JOIN city AS parent ONchild.Parent_id = parent.Child_id
)SELECT Child_id
, Child_name
FROM city
GROUPBY Child_id, Child_name
;/*返回受影响的人*/RETURN QUERY 
SELECT S.Street_Id
, S.street_name
, S.Person_Id
, S.person_name
FROM street T
INNER JOIN person S ONT.Street_Id = S.Street_Id;END;$$ LANGUAGE PLPGSQL;

3.测试用例

SELECT*FROM getInfluencedPerson('浙江省');

图片.png

SELECT*FROM getInfluencedPerson('杭州市');

图片.png

SELECT*FROM getInfluencedPerson('温州市');

图片.png

SELECT*FROM getInfluencedPerson('滨江区');

图片.png

SELECT*FROM getInfluencedPerson('西湖区');

图片.png

SELECT*FROM getInfluencedPerson('萧山区');

图片.png

4.结束

相关实践学习
使用PolarDB和ECS搭建门户网站
本场景主要介绍基于PolarDB和ECS实现搭建门户网站。
阿里云数据库产品家族及特性
阿里云智能数据库产品团队一直致力于不断健全产品体系,提升产品性能,打磨产品功能,从而帮助客户实现更加极致的弹性能力、具备更强的扩展能力、并利用云设施进一步降低企业成本。以云原生+分布式为核心技术抓手,打造以自研的在线事务型(OLTP)数据库Polar DB和在线分析型(OLAP)数据库Analytic DB为代表的新一代企业级云原生数据库产品体系, 结合NoSQL数据库、数据库生态工具、云原生智能化数据库管控平台,为阿里巴巴经济体以及各个行业的企业客户和开发者提供从公共云到混合云再到私有云的完整解决方案,提供基于云基础设施进行数据从处理、到存储、再到计算与分析的一体化解决方案。本节课带你了解阿里云数据库产品家族及特性。
目录
相关文章
|
关系型数据库 物联网 PostgreSQL
沉浸式学习PostgreSQL|PolarDB 11: 物联网(IoT)、监控系统、应用日志、用户行为记录等场景 - 时序数据高吞吐存取分析
物联网场景, 通常有大量的传感器(例如水质监控、气象监测、新能源汽车上的大量传感器)不断探测最新数据并上报到数据库. 监控系统, 通常也会有采集程序不断的读取被监控指标(例如CPU、网络数据包转发、磁盘的IOPS和BW占用情况、内存的使用率等等), 同时将监控数据上报到数据库. 应用日志、用户行为日志, 也就有同样的特征, 不断产生并上报到数据库. 以上数据具有时序特征, 对数据库的关键能力要求如下: 数据高速写入 高速按时间区间读取和分析, 目的是发现异常, 分析规律. 尽量节省存储空间
769 1
|
3月前
|
Oracle NoSQL 关系型数据库
主流数据库对比:MySQL、PostgreSQL、Oracle和Redis的优缺点分析
主流数据库对比:MySQL、PostgreSQL、Oracle和Redis的优缺点分析
547 2
|
关系型数据库 定位技术 分布式数据库
沉浸式学习PostgreSQL|PolarDB 18: 通过GIS轨迹相似伴随|时态分析|轨迹驻点识别等技术对拐卖、诱骗场景进行侦查
本文主要教大家怎么用好数据库, 而不是怎么运维管理数据库、怎么开发数据库内核.
1319 1
|
7月前
|
存储 关系型数据库 MySQL
TiDB与MySQL、PostgreSQL等数据库的比较分析
【2月更文挑战第25天】本文将对TiDB、MySQL和PostgreSQL等数据库进行详细的比较分析,探讨它们各自的优势和劣势。TiDB作为一款分布式关系型数据库,在扩展性、并发性能等方面表现突出;MySQL以其易用性和成熟性受到广泛应用;PostgreSQL则在数据完整性、扩展性等方面具有优势。通过对比这些数据库的特点和适用场景,帮助企业更好地选择适合自己业务需求的数据库系统。
1166 4
|
7月前
|
SQL 关系型数据库 MySQL
PostgreSQL【异常 01】java.io.IOException:Tried to send an out-of-range integer as a 2-byte value 分析+解决
PostgreSQL【异常 01】java.io.IOException:Tried to send an out-of-range integer as a 2-byte value 分析+解决
475 1
|
SQL 关系型数据库 MySQL
《PostgreSQL与MySQL:详细对比与分析》
《PostgreSQL与MySQL:详细对比与分析》
626 0
|
存储 关系型数据库 PostgreSQL
Postgresql内核源码分析-heapam分析
Postgresql内核源码分析-heapam分析
188 1
|
SQL 存储 自然语言处理
玩转阿里云PostgreSQL,通过pg_jieba对豆瓣影评进行热评分析
在当今社交媒体的时代,人们通过各种平台分享自己的生活、观点和情感。然而,对于平台管理员和品牌经营者来说,了解用户的情感和意见变得至关重要。为了帮助他们更好地了解用户的情感倾向,我们可以使用PostgreSQL中的pg_jieba插件对这些发帖进行分词和情感分析,来构建一个社交媒体情感分析系统,系统将根据用户的发帖内容,自动判断其情感倾向是积极、消极还是中性,并将结果存储在数据库中。 本文通过针对kaggle数据集中的豆瓣影评的中文评论数据,通过阿里云的PostgreSQL中的pg_jieba插件进行分词(可自定义多个词典,并且切换自定义词典进行分词),基于分词的结果进行统计分析。
|
关系型数据库 分布式数据库 PolarDB
沉浸式学习PostgreSQL|PolarDB 15: 企业ERP软件、网站、分析型业务场景、营销场景人群圈选, 任意字段组合条件数据筛选
本篇文章目标学习如何快速在任意字段组合条件输入搜索到满足条件的数据.
612 0
|
关系型数据库 数据库 PostgreSQL
PostgreSQL pg_rewind报错分析
PostgreSQL pg_rewind报错分析
203 0