CLEAN CONNECTION
功能描述
清理CN节点到其他指定数据库节点(CN/DN)的网络连接,force模式下会强制清理CN/DN的客户端连接。允许清理CN节点中指定数据库、指定用户的相关空闲/无效连接、强制清理活跃的连接。
注意事项
- 在非force模式下,该功能只清理数据库集群节点(CN/DN)之间的连接,不会影响客户端连接。
- 在非force模式下,该功能只清理CN中已缓存的空闲/无效的连接,正在使用的正常连接不做清理。在force模式下,该功能同时会强制清理正在使用的正常连接以及客户端连接。
- 可以通过查询PG_STAT_GET_POOLER_STATUS()函数查看缓存的连接,检验清理的效果。
- 建议只在数据库出现网络连接异常时执行此功能。
- 在force模式下,该功能会清理DN中指定数据库、指定用户的连接。若分布式DN存在无法清理的残留连接,建议运维通过pg_terminate_session函数来清理该无效会话。
语法格式
CLEAN CONNECTION TO { COORDINATOR ( nodename [, ... ] ) | NODE ( nodename [, ... ] )| ALL [ CHECK ] [ FORCE ] } { FOR DATABASE dbname | TO USER username | FOR DATABASE dbname TO USER username };
参数说明
- CHECK
仅在节点列表为TO ALL时可以指定。如果指定该参数,会在清理连接之前检查数据库是否被其他会话连接访问。此参数主要用于DROP DATABASE之前的连接访问检查,如果发现有其他会话连接,则将报错并停止删除数据库。
- FORCE
仅在节点列表为TO ALL时可以指定,如果指定该参数,当前CN中所有和指定dbname和username相关的线程都会收到SIGTERM信号,相应的会话被强制关闭,事务会中止,网络连接被清理。DN中所有和指定dnname或username相关的线程都会收到SIGTERM信号,相应的会话被强制关闭。
- COORDINATOR ( nodename ,nodename ... } ) | NODE ( nodename , nodename ... ) | ALL
删除CN节点与指定节点的空闲/无效连接。有三种场景:
- COORDINATOR:删除CN到指定CN节点上的空闲/无效连接。
- NODE:删除CN到指定DN节点上的空闲/无效连接。
- ALL:删除CN到所有节点上的空闲/无效连接,包括CN和DN。
取值范围:可替换其中的nodename为已存在的节点名。
- dbname
删除当前CN节点中指定数据库相关的连接。如果不指定该属性,则删除所有数据库相关的连接。
取值范围:系统中已存在数据库名称。
- username
删除当前CN节点中指定用户相关连接。如果不指定,则删除所有用户相关的连接。
取值范围:已存在的用户。
示例
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 |
--创建数据库test_clean_connection。 gaussdb=# CREATE DATABASE test_clean_connection; --创建jack用户。 gaussdb=# CREATE USER jack PASSWORD '********'; --在另一个会话用jack用户登录该数据库之后,通过视图查询到该连接信息。 gaussdb=# SELECT datname,usename,application_name,waiting,state FROM pg_stat_activity WHERE datname = 'test_clean_connection'; datname | usename | application_name | waiting | state -----------------------+---------+------------------+---------+------- test_clean_connection | jack | gsql | f | idle (1 row) --此时直接删除数据库test_clean_connection会有如下报错: gaussdb=# DROP DATABASE test_clean_connection; ERROR: Database "test_clean_connection" is being accessed by other users. You can stop all connections by command: "clean connection to all force for database XXXX;" or wait for the sessions to end by querying view: "pg_stat_activity". DETAIL: There is 1 other session using the database. --删除登录数据库数据库test_clean_connection的当前CN节点与所有节点的连接。 --如果不使用FORCE参数是无法删除stat状态为其他的状态的连接。 gaussdb=# CLEAN CONNECTION TO ALL FORCE FOR DATABASE test_clean_connection; --查询登录数据库test_clean_connection的连接。 gaussdb=# SELECT datname,usename,application_name,waiting,state FROM pg_stat_activity WHERE datname = 'test_clean_connection'; datname | usename | application_name | waiting | state ---------+---------+------------------+---------+------- (0 rows) --删除数据库test_clean_connection。 gaussdb=# DROP DATABASE test_clean_connection; --删除用户jack。 gaussdb=# DROP USER jack; |