PostgreSQL的window函数整理

PostgreSQL的window函数整理

 

PG在8.4以后版本中添加了一些Window Function功能，下面简单介绍 

    A window function performs a calculation across a set of table rows that are somehow related to the current row. This is comparable to the type of calculation that can be done with an aggregate function. But unlike regular aggregate functions, use of a window function does not cause rows to become grouped into a single output row — the rows retain their separate identities. Behind the scenes, the window function is able to access more than just the current row of the query result. 

 

    Window Functions in SQL is an OLAP functionality that provides ranking, cumulative computation, and partitioning aggregation. Many commercial RDMBS such like Oracle, MS SQL Server and DB2 have implemented part of this specification, while open source RDMBS including PostgreSQL, MySQL and Firebird doesn't yet. To implement this functionality on PostgreSQL not only helps many users move from those RDBMS to PostgreSQL but encourages OLAP applications such as BI (Business Inteligence) to 易做图yze large data set. This specification is defined first in SQL:2003, and improved in SQL:2008   www.zzzyk.com  

 

简言之，聚合函数返回的各个分组的结果，窗口函数则为每一行返回结果,示例如下： 

1.建示例表,初始化数据

DROP TABLE IF EXISTS empsalary;

CREATE TABLE empsalary(

  depname varchar,

  empno bigint,

  salary int,

  enroll_date date

);  www.zzzyk.com  
 

INSERT INTO empsalary VALUES('develop',10, 5200, '2007/08/01');

INSERT INTO empsalary VALUES('sales', 1, 5000, '2006/10/01');

INSERT INTO empsalary VALUES('personnel', 5, 3500, '2007/12/10');

INSERT INTO empsalary VALUES('sales', 4, 4800, '2007/08/08');

INSERT INTO empsalary VALUES('sales', 6, 5500, '2007/01/02');

INSERT INTO empsalary VALUES('personnel', 2, 3900, '2006/12/23');

INSERT INTO empsalary VALUES('develop', 7, 4200, '2008/01/01');

INSERT INTO empsalary VALUES('develop', 9, 4500, '2008/01/01');

INSERT INTO empsalary VALUES('sales', 3, 4800, '2007/08/01');

INSERT INTO empsalary VALUES('develop', 8, 6000, '2006/10/01');

INSERT INTO empsalary VALUES('develop', 11, 5200, '2007/08/15');

 

postgres=# select * from empsalary ;

  depname  | empno | salary | enroll_date 

-----------+-------+--------+-------------

 develop   |    10 |   5200 | 2007-08-01

 sales     |     1 |   5000 | 2006-10-01

 personnel |     5 |   3500 | 2007-12-10

 sales     |     4 |   4800 | 2007-08-08

 sales     |     6 |   5500 | 2007-01-02

 personnel |     2 |   3900 | 2006-12-23

 develop   |     7 |   4200 | 2008-01-01

 develop   |     9 |   4500 | 2008-01-01

 sales     |     3 |   4800 | 2007-08-01

 develop   |     8 |   6000 | 2006-10-01

 develop   |    11 |   5200 | 2007-08-15

(11 rows)  www.zzzyk.com  
 

2.统计示例 

a.统计各部门的总薪水，平均薪水和部门的详细情况

postgres=# select sum(salary) OVER (PARTITION BY depname),avg(salary) OVER (PARTITION BY depname),* from empsalary;

  sum  |          avg          |  depname  | empno | salary | enroll_date 

-------+-----------------------+-----------+-------+--------+-------------

 25100 | 5020.0000000000000000 | develop   |    10 |   5200 | 2007-08-01

 25100 | 5020.0000000000000000 | develop   |     7 |   4200 | 2008-01-01

 25100 | 5020.0000000000000000 | develop   |     9 |   4500 | 2008-01-01

 25100 | 5020.0000000000000000 | develop   |     8 |   6000 | 2006-10-01

 25100 | 5020.0000000000000000 | develop   |    11 |   5200 | 2007-08-15

  7400 | 3700.0000000000000000 | personnel |     2 |   3900 | 2006-12-23

  7400 | 3700.0000000000000000 | personnel |     5 |   3500 | 2007-12-10

 20100 | 5025.0000000000000000 | sales     |     3 |   4800 | 2007-08-01

 20100 | 5025.0000000000000000 | sales     |     1 |   5000 | 2006-10-01

 20100 | 5025.0000000000000000 | sales     |     4 |   4800 | 2007-08-08

 20100 | 5025.0000000000000000 | sales     |     6 |   5500 | 2007-01-02

(11 rows)  www.zzzyk.com  
 

b.统计人员在所在部门的薪水排名情况

postgres=# select rank() OVER (PARTITION BY depname ORDER BY salary),* from empsalary;

 rank |  depname  | empno | salary | enroll_date 

------+-----------+-------+--------+-------------

    1 | develop   |     7 |   4200 | 2008-01-01

    2 | develop   |     9 |   4500 | 2008-01-01

    3 | develop   |    10 |   5200 | 2007-08-01

    3 | develop   |    11 |   5200 | 2007-08-15

    5 | develop   |     8 |   6000 | 2006-10-01

    1 | personnel |     5 |   3500 | 2007-12-10

    2 | personnel |     2 |   3900 | 2006-12-23

    1 | sales     |     4 |   4800 | 2007-08-08

    1 | sales     |     3 |   4800 | 2007-08-01

    3 | sales     |     1 |   5000 | 2006-10-01

    4 | sales     |     6 |   5500 | 2007-01-02

(11 rows)  www.zzzyk.com  
 

3.一个有趣的例子 注意使用order by,结果会两样

 create table foo(a int,b int) ;

insert into foo values (1,1);

insert into foo values (1,1);

insert into foo values (2,1);

insert into foo values (4,1);

insert into foo values (2,1);

insert into foo values (4,1);

insert into foo values (5,1);

insert into foo values (11,3);

insert into foo values (12,3);

insert into foo values (22,3);

insert into foo values (16,3);

insert into foo values (16,3);

insert into foo values (16,3);

 

postgres=# select sum(a) over (partition by b), a, b from foo;

 sum | a  | b 

-----+----+---

  19 |  1 | 1

  19 |  1 | 1

  19 |  2 | 1

  19 |  4 | 1

  19 |  2 | 1

  19 |  4 | 1

  19 |  5 | 1

  93 | 11 | 3

  93