PostgreSQL行级策略实验

TEST=# create table test(id serial primary key, user_name varchar(32), crt_time timestamp default now());
CREATE TABLE
TEST=# insert into test(user_name) values(‘U1‘);
INSERT 0 1
TEST=# insert into test(user_name) values(‘U2‘);
INSERT 0 1
TEST=# insert into test(user_name) values(‘U3‘);
INSERT 0 1
TEST=# insert into test(user_name) values(‘U1‘);
INSERT 0 1
TEST=# insert into test(user_name) values(‘U2‘);
INSERT 0 1
TEST=# insert into test(user_name) values(‘U3‘);
INSERT 0 1

TEST=# create user U1 password ‘u1‘;
TEST=# create user U2 password ‘u2‘;
TEST=# create user U3 password ‘u3‘;

TEST=# alter table test enable row level security;
ALTER TABLE

TEST=# \h create policy 
Command: CREATE POLICY
Description: define a new row level security policy for a table
Syntax:
CREATE POLICY name ON table_name
[ FOR { ALL | SELECT | INSERT | UPDATE | DELETE } ]
[ TO { role_name | PUBLIC | CURRENT_USER | SESSION_USER } [, ...] ]
[ USING ( using_expression ) ]
[ WITH CHECK ( check_expression ) ]

--name -- 策略名称
--table_name -- 适用于该策略的表
--FOR -- 该策略适用的DML命令，ALL表示所有
--TO -- 该策略适用的角色
--USING -- 应用在表上的CHECK表达式，返回true的行可见，false不可见
--WITH CHECK -- 应用在该表的INSERT或UPDATE的SQL表达式，true的可以操作，false操作失败

TEST=# create policy plcy1 on test for select using (user_name = current_user);
CREATE POLICY
TEST=# grant all on table test to u1, u2, u3;
GRANT
TEST=# \c TEST U1
Password for user U1: 
You are now connected to database "TEST" as user "U1".
TEST=> select * from test; 
ID | USER_NAME | CRT_TIME 
----+-----------+----------------------------
1 | U1 | 2020-02-04 01:18:32.744308
4 | U1 | 2020-02-04 01:18:46.369409
(2 rows)

TEST=> update test set crt_time = now() where id = 1;
UPDATE 0
TEST=> update test set crt_time = now() where id = 4;
UPDATE 0

只有查询的行级策略，也不能插入对应的数据：
TEST=> insert into test(user_name) values(‘U1‘);
ERROR: permission denied for sequence TEST_ID_SEQ
TEST=> insert into test(id, user_name) values(8,‘U1‘);
ERROR: new row violates row-level security policy for table "TEST"

TEST=# create policy plcy2 on test for all using (user_name = current_user);
CREATE POLICY
TEST=# \c TEST U1
Password for user U1: 
You are now connected to database "TEST" as user "U1".
TEST=> update test set crt_time = now() where id = 4; 
UPDATE 1
TEST=> insert into test(user_name) values(‘U1‘); 
ERROR: permission denied for sequence TEST_ID_SEQ
TEST=> insert into test(id,user_name) values(8,‘U1‘);
INSERT 0 1
TEST=> select * from test;
ID | USER_NAME | CRT_TIME 
----+-----------+----------------------------
1 | U1 | 2020-02-04 01:18:32.744308
4 | U1 | 2020-02-04 01:32:21.707241
8 | U1 | 2020-02-04 01:33:03.484166
(3 rows)

TEST=# create policy plcy5 on test for insert using (user_name = current_user) with check (user_name = current_user and id != 100);
ERROR: only WITH CHECK expression allowed for INSERT
TEST=# create policy plcy3 on test for insert with check (user_name = current_user and id != 100); 
CREATE POLICY
TEST=# \c TEST U1 
Password for user U1: 
You are now connected to database "TEST" as user "U1".
TEST=> select * from test;
ID | USER_NAME | CRT_TIME 
----+-----------+----------------------------
1 | U1 | 2020-02-04 01:18:32.744308
4 | U1 | 2020-02-04 01:32:21.707241
8 | U1 | 2020-02-04 01:33:03.484166
(3 rows)

TEST=> insert into test(id, user_name) values(22, ‘U1‘);
INSERT 0 1

还是能插入id为100的数据，因为前面有all的策略，导致所有只要是user_name = current_user 都可以插入，多个策略之间使用的是OR进行处理的：
TEST=> insert into test(id, user_name) values(100, ‘U1‘);
INSERT 0 1
TEST=> select * from test; 
ID | USER_NAME | CRT_TIME 
-----+-----------+----------------------------
1 | U1 | 2020-02-04 01:18:32.744308
4 | U1 | 2020-02-04 01:32:21.707241
8 | U1 | 2020-02-04 01:33:03.484166
22 | U1 | 2020-02-04 01:40:46.900007
100 | U1 | 2020-02-04 01:40:54.127757
(5 rows)

TEST=> delete from test where id > 10;
DELETE 2

删除all的权限plcy2，plcy3就生效了：
TEST=> \c TEST SYSTEM 
Password for user SYSTEM: 
You are now connected to database "TEST" as user "SYSTEM".
TEST=# drop policy plcy2 on test; 
DROP POLICY
TEST=# \c TEST U1
Password for user U1: 
You are now connected to database "TEST" as user "U1".
TEST=> insert into test(id, user_name) values(22, ‘U1‘); 
INSERT 0 1
TEST=> insert into test(id, user_name) values(100, ‘U1‘);
ERROR: new row violates row-level security policy for table "TEST"
TEST=>

TEST=# create policy plcy4 on test for update using (user_name = current_user) with check (user_name = current_user and id = 1); 
CREATE POLICY
TEST=# \c TEST SYSTEM
You are now connected to database "TEST" as user "SYSTEM".
TEST=# \c TEST U1 
Password for user U1: 
You are now connected to database "TEST" as user "U1".
TEST=> select * from test; 
ID | USER_NAME | CRT_TIME 
----+-----------+----------------------------
1 | U1 | 2020-02-04 01:18:32.744308
4 | U1 | 2020-02-04 01:32:21.707241
8 | U1 | 2020-02-04 01:33:03.484166
22 | U1 | 2020-02-04 01:44:40.663172
(4 rows)

TEST=> update test set crt_time = now() where id = 4;
ERROR: new row violates row-level security policy for table "TEST"
TEST=> update test set crt_time = now() where id = 1;
UPDATE 1
TEST=> update test set crt_time = now() where id = 2;
UPDATE 0
TEST=>

create policy plcy2 on test for all using (user_name = current_user);

TEST=# select * from test;
ID | USER_NAME | CRT_TIME 
----+-----------+----------------------------
2 | U2 | 2020-02-04 01:18:35.119190
3 | U3 | 2020-02-04 01:18:37.341201
5 | U2 | 2020-02-04 01:18:49.056104
6 | U3 | 2020-02-04 01:18:51.435371
4 | U1 | 2020-02-04 01:32:21.707241
8 | U1 | 2020-02-04 01:33:03.484166
22 | U1 | 2020-02-04 01:44:40.663172
1 | U1 | 2020-02-04 01:48:59.705486
(8 rows)

TEST=# \c TEST U1
Password for user U1: 
You are now connected to database "TEST" as user "U1".
TEST=> select * from test;
ID | USER_NAME | CRT_TIME 
----+-----------+----------------------------
4 | U1 | 2020-02-04 01:32:21.707241
8 | U1 | 2020-02-04 01:33:03.484166
22 | U1 | 2020-02-04 01:44:40.663172
1 | U1 | 2020-02-04 01:48:59.705486
(4 rows)

TEST=> \d test
Table "PUBLIC.TEST"
Column | Type | Modifiers 
-----------+-----------------------------+---------------------------------------------------
ID | INTEGER | not null default NEXTVAL(‘TEST_ID_SEQ‘::REGCLASS)
USER_NAME | CHARACTER VARYING(32 byte) | 
CRT_TIME | TIMESTAMP WITHOUT TIME ZONE | default NOW()
Indexes:
"TEST_PKEY" PRIMARY KEY, BTREE (ID)
Policies:
POLICY "PLCY1" FOR SELECT
USING (((USER_NAME)::NAME = "CURRENT_USER"()))
POLICY "PLCY3" FOR INSERT
WITH CHECK ((((USER_NAME)::NAME = "CURRENT_USER"()) AND (ID <> 100)))
POLICY "PLCY4" FOR UPDATE
USING (((USER_NAME)::NAME = "CURRENT_USER"()))
WITH CHECK ((((USER_NAME)::NAME = "CURRENT_USER"()) AND (ID = 1)))

TEST=> select polname, polrelid, relname from pg_policy, pg_class c where polrelid = c.oid;
POLNAME | POLRELID | RELNAME 
-------------------+----------+-----------------------
DENY_MODIFICATION | 14749 | PATHMAN_CONFIG
DENY_MODIFICATION | 14759 | PATHMAN_CONFIG_PARAMS
ALLOW_SELECT | 14749 | PATHMAN_CONFIG
ALLOW_SELECT | 14759 | PATHMAN_CONFIG_PARAMS
PLCY1 | 25146 | TEST
PLCY3 | 25146 | TEST
PLCY4 | 25146 | TEST
(7 rows)