华为云用户手册

pg_stat_get_last_data_changed_time(oid) 描述：insert/update/delete，exchange/drop partition在该表上最后一次操作的时间，PG_STAT_ALL_TABLES视图last_data_changed列的数据是通过该函数求值，在表数量很大的场景中，通过视图获取表数据最后修改时间的性能较差，建议直接使用该函数获取表数据的最后修改时间。 返回值类型：timestamptz

GS_ALL_NODEGROUP_CONTROL_GROUP_INFO(text) 描述：提供了所有逻辑集群的控制组信息。该函数在调用的时候需要指定要查询逻辑集群的名称。例如要查询'installation'逻辑集群的控制组信息： 1 SELECT * FROM GS_ALL_NODEGROUP_CONTROL_GROUP_INFO('installation') 返回值类型：record 函数返回字段如下： 表3 GS_ALL_NODEGROUP_CONTROL_GROUP_INFO(text) 名称 类型 描述 name text 控制组的名称。 type text 控制组的类型。 gid bigint 控制组ID。 classgid bigint Workload所属Class的控制组ID。 class text Class控制组。 workload text Workload控制组。 shares bigint 控制组分配的CPU资源配额。 limits bigint 控制组分配的CPU资源限额。 wdlevel bigint Workload控制组层级。 cpucores text 控制组使用的CPU核的信息。

mask_partial(column_name [, input_format, output_format], mask_char, mask_from[, mask_to]) 描述：针对字符类型数据，对照指定的输入输出格式，将第mask_from到mask_to位的数字部分脱敏成mask_char指定的字符。 参数说明： input_format 输入格式是由V和F组成的字符序列，与脱敏列数据长度相同。V对应位置的字符可能会被脱敏，F对象位置的字符会被忽略跳过，V字符序列标识脱敏范围。输入输出格式参数适用于定长数据，比如，银行卡号、身份证号、手机号等。 output_format 输出格式是由V和其他任意字符组成的字符序列，与脱敏列数据长度相同。V字符位置与input_format的V位置对应，其他字符位置与input_format的F位置对应，且不会脱敏，通常为数据分隔符。 input_format和output_format可以缺省或指定为空串""，此时，无输入输出格式要求，原始字符序列范围即为脱敏范围。 mask_char 脱敏字符，仅允许长度为1的任意字符。场景的脱敏字符包括"*"，"#"等。 mask_from 脱敏范围的起始位置，要求大于0。 mask_to 脱敏范围的结束位置，允许缺省。缺省时，即脱敏到原始数据结束位置。 返回值类型：与入参column_name数据类型相同。

mask_partial(column_name, mask_field1, mask_value1, mask_field2, mask_value2, mask_field3, mask_value3) 描述：按指定三个时间域做部分脱敏，仅适用于日期或时间类型数据。若mask_value取-1，即此mask_field不脱敏。其中，mask_field可以取"month"、"day"、"year"、"hour"、"minute"、"second"六个时间域之一。各域的取值范围需满足实际时间单位的取值范围。 返回值类型：与入参column_name数据类型相同。

mask_partial(column_name, mask_digital, mask_from[, mask_to]) 描述：针对数值类型数据，将第mask_from到mask_to位的数字部分脱敏成mask_digital对应的数字。其中，参数mask_to允许缺省，缺省时即脱敏到数据结束位置。参数mask_digital只能取[0,9]区间内的数字。 返回值类型：与入参column_name数据类型相同。

自定义脱敏函数 支持用户使用PL/PGSQL语言自定义脱敏函数。 自定义脱敏函数需要严格遵循如下要求： 返回值与脱敏列类型一致。 函数必须可下推。 参数列表除脱敏格式外，只能包含一个脱敏列。 函数仅实现针对特定数据类型的格式化改写功能，不能涉及与其他表对象的复杂关联操作。 不满足前两项中任一项时，创建脱敏策略会报错。不满足后两项中任一项时，可成功创建脱敏策略，但查询执行结果可能会出现不可预知的问题。

pgxc_cgroup_reload_conf(text) 描述：在某个节点上进行cgroup配置文件在线加载。入参为节点的IP地址。 返回值类型：record 函数返回字段如下： 名称 类型 描述 node_name text 实例名称 node_host text 实例所在节点的IP地址 result text cgroup在线加载是否成功 示例： 1 2 3 4 5 6 7 8 9 SELECT * FROM pgxc_cgroup_reload_conf('192.168.178.35'); node_name | node_host | result --------------+----------------+--------- cn_5001 | 192.168.178.35 | success dn_6007_6008 | 192.168.178.35 | success dn_6003_6004 | 192.168.178.35 | success dn_6001_6002 | 192.168.178.35 | success dn_6005_6006 | 192.168.178.35 | success (5 rows)

gs_wlm_node_recover(boolean isForce) 描述：动态资源管理模式下，对CCN管控计数和作业信息进行更新恢复。该函数仅支持管理员执行，通常用于CN实例故障重启后的实例恢复，由集群管理组件（CM）调用，不建议用户直接调用。具体功能如下： CN执行：通知CCN清理该CN执行的作业信息和作业对应的管控计数信息。 CCN执行：重置管控计数信息，并从CN上获取最新的慢车道作业信息。 返回值类型：bool

pg_stat_get_wlm_node_resource_info(int4) 描述：显示所有DN资源的汇总信息。 返回值类型：record 函数返回字段如下： 名称 类型 描述 min_mem_util integer DN最小内存使用率。 max_mem_util integer DN最大内存使用率。 min_cpu_util integer DN最小CPU使用率。 max_cpu_util integer DN最大CPU使用率。 min_io_util integer DN最小IO使用率。 max_io_util integer DN最大IO使用率。 phy_usemem_rate integer 物理节点最大内存使用率。

gs_cgroup_reload_conf() 描述：在当前实例上进行cgroup配置文件在线加载。 返回值类型：record 函数返回字段如下： 名称 类型 描述 node_name text 实例名称 node_host text 实例所在节点的IP地址 result text cgroup在线加载是否成功 示例： 1 2 3 4 SELECT * FROM gs_cgroup_reload_conf(); node_name | node_host | result -----------+----------------+--------- cn_5001 | 192.168.178.35 | success

gs_wlm_get_queryband_action(cstring) 描述：查询query_band关联行为和次序。 返回值类型：record 函数返回字段如下： 名称 类型 描述 qband cstring query_band键值对 respool_id Oid query band关联资源池OID respool text query band关联资源池名 priority text query band关联队列内优先级 qborder int4 query_band搜索次序 示例： 1 2 3 4 5 SELECT * FROM gs_wlm_get_queryband_action('a=1'); qband | respool_id | respool | priority | qborder -------+------------+---------+----------+--------- a=1 | 16388 | p1 | Medium | -1 (1 row)

pgxc_cgroup_reload_conf() 描述：在系统所有实例上进行cgroup配置文件在线加载。 返回值类型：record 函数返回字段如下： 名称 类型 描述 node_name text 实例名称 node_host text 实例所在节点的IP地址 result text cgroup在线加载是否成功 示例： 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 39 40 41 42 43 44 45 46 SELECT * FROM pgxc_cgroup_reload_conf(); node_name | node_host | result --------------+-----------------+--------- dn_6025_6026 | 192.168.178.177 | success dn_6049_6050 | 192.168.179.79 | success dn_6051_6052 | 192.168.179.79 | success dn_6055_6056 | 192.168.179.79 | success dn_6067_6068 | 192.168.181.57 | success dn_6023_6024 | 192.168.178.39 | success dn_6009_6010 | 192.168.181.21 | success dn_6011_6012 | 192.168.181.21 | success dn_6015_6016 | 192.168.181.21 | success dn_6029_6030 | 192.168.178.177 | success dn_6031_6032 | 192.168.178.177 | success dn_6045_6046 | 192.168.179.45 | success cn_5001 | 192.168.178.35 | success cn_5003 | 192.168.178.39 | success dn_6061_6062 | 192.168.181.179 | success cn_5006 | 192.168.179.45 | success cn_5004 | 192.168.178.177 | success cn_5002 | 192.168.181.21 | success cn_5005 | 192.168.178.187 | success dn_6019_6020 | 192.168.178.39 | success dn_6007_6008 | 192.168.178.35 | success dn_6071_6072 | 192.168.181.57 | success dn_6003_6004 | 192.168.178.35 | success dn_6013_6014 | 192.168.181.21 | success dn_6035_6036 | 192.168.178.187 | success dn_6037_6038 | 192.168.178.187 | success dn_6001_6002 | 192.168.178.35 | success dn_6063_6064 | 192.168.181.179 | success dn_6005_6006 | 192.168.178.35 | success dn_6057_6058 | 192.168.181.179 | success dn_6069_6070 | 192.168.181.57 | success dn_6027_6028 | 192.168.178.177 | success dn_6059_6060 | 192.168.181.179 | success dn_6041_6042 | 192.168.179.45 | success dn_6043_6044 | 192.168.179.45 | success dn_6047_6048 | 192.168.179.45 | success dn_6033_6034 | 192.168.178.187 | success dn_6065_6066 | 192.168.181.57 | success dn_6021_6022 | 192.168.178.39 | success dn_6017_6018 | 192.168.178.39 | success dn_6039_6040 | 192.168.178.187 | success dn_6053_6054 | 192.168.179.79 | success (42 rows)

gs_wlm_set_queryband_action(cstring,cstring,int4) 描述：设置query_band关联行为和次序。 返回值类型：boolean 函数入参字段如下： 名称 类型 描述 qband cstring query_band键值对，长度上限为63个字符。 action cstring query_band关联行为。 order int4 query_band搜索次序，缺省参数，默认为-1。 示例： 1 2 3 4 5 6 7 8 9 10 SELECT * FROM gs_wlm_set_queryband_action('a=1','respool=p1'); gs_wlm_set_queryband_action ----------------------------- t (1 row) SELECT * FROM gs_wlm_set_queryband_action('a=3','respool=p1;priority=rush',1); gs_wlm_set_queryband_action ----------------------------- t (1 row)

gs_wlm_set_queryband_order(cstring,int4) 描述：设置query_band次序。 返回值类型：boolean 函数入参字段如下： 名称 类型 描述 qband cstring query_band键值对 order int4 query_band搜索次序，缺省参数，默认为-1 示例： 1 2 3 4 5 SELECT * FROM gs_wlm_set_queryband_order('a=1',2); gs_wlm_set_queryband_action ----------------------------- t (1 row)

pgxc_wlm_analyze_schema_space(cstring) 描述：在CN上查询某个逻辑集群下集群整体的Schema空间信息，入参为逻辑集群名称。 返回值类型：record 函数返回字段如下： 名称 类型 描述 schemaname text 模式名 databasename text 数据库名 nodegroup text 节点组名称 total_value bigint 该模式的集群空间总值 avg_value bigint 该模式的各实例空间平均值 skew_percent integer 倾斜率 extend_info text 提供信息包括：单实例空间最大值、单实例空间最小值以及最大最小空间所在的实例名 示例： 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 SELECT * FROM pgxc_wlm_analyze_schema_space('group1'); schemaname | databasename | nodegroup | total_value | avg_value | skew_percent | extend_info --------------------+--------------+--------------+-------------+-----------+--------------+----------------------------------------------- pg_catalog | test1 | installation | 56819712 | 9469952 | 0 | min:9469952 datanode1,max:9469952 datanode1 public | postgres | installation | 150495232 | 25082538 | 0 | min:24903680 datanode6,max:25280512 datanode1 pg_toast | test1 | installation | 11157504 | 1859584 | 0 | min:1859584 datanode1,max:1859584 datanode1 cstore | test1 | installation | 0 | 0 | 0 | min:0 datanode1,max:0 datanode1 data_redis | postgres | installation | 1966080 | 327680 | 50 | min:0 datanode4,max:655360 datanode1 data_redis | test1 | installation | 0 | 0 | 0 | min:0 datanode1,max:0 datanode1 public | test1 | installation | 98304 | 16384 | 0 | min:16384 datanode1,max:16384 datanode1 dbms_om | postgres | installation | 0 | 0 | 0 | min:0 datanode1,max:0 datanode1 dbms_job | postgres | installation | 0 | 0 | 0 | min:0 datanode1,max:0 datanode1 dbms_om | test1 | installation | 0 | 0 | 0 | min:0 datanode1,max:0 datanode1 dbms_job | test1 | installation | 0 | 0 | 0 | min:0 datanode1,max:0 datanode1 sys | postgres | installation | 0 | 0 | 0 | min:0 datanode1,max:0 datanode1 sys | test1 | installation | 0 | 0 | 0 | min:0 datanode1,max:0 datanode1 utl_file | postgres | installation | 0 | 0 | 0 | min:0 datanode1,max:0 datanode1 utl_raw | postgres | installation | 0 | 0 | 0 | min:0 datanode1,max:0 datanode1 dbms_sql | postgres | installation | 0 | 0 | 0 | min:0 datanode1,max:0 datanode1 dbms_output | postgres | installation | 0 | 0 | 0 | min:0 datanode1,max:0 datanode1 dbms_random | postgres | installation | 0 | 0 | 0 | min:0 datanode1,max:0 datanode1 dbms_lob | postgres | installation | 0 | 0 | 0 | min:0 datanode1,max:0 datanode1 information_schema | postgres | installation | 1769472 | 294912 | 0 | min:294912 datanode1,max:294912 datanode1 information_schema | test1 | installation | 1769472 | 294912 | 0 | min:294912 datanode1,max:294912 datanode1 utl_file | test1 | installation | 0 | 0 | 0 | min:0 datanode1,max:0 datanode1 dbms_output | test1 | installation | 0 | 0 | 0 | min:0 datanode1,max:0 datanode1 dbms_random | test1 | installation | 0 | 0 | 0 | min:0 datanode1,max:0 datanode1 utl_raw | test1 | installation | 0 | 0 | 0 | min:0 datanode1,max:0 datanode1 dbms_sql | test1 | installation | 0 | 0 | 0 | min:0 datanode1,max:0 datanode1 dbms_lob | test1 | installation | 0 | 0 | 0 | min:0 datanode1,max:0 datanode1 pg_catalog | postgres | installation | 75431936 | 12571989 | 3 | min:12124160 datanode4,max:13049856 datanode1 redisuser | postgres | installation | 1884160 | 314026 | 50 | min:16384 datanode4,max:630784 datanode1 pg_toast | postgres | installation | 17154048 | 2859008 | 7 | min:2637824 datanode4,max:3080192 datanode1 cstore | postgres | installation | 15294464 | 2549077 | 5 | min:2408448 datanode1,max:2703360 datanode6 (31 rows)

pgxc_wlm_readjust_relfilenode_size_table(integer) 描述：空间统计校准函数。 由于校准函数执行时与其余业务之间的事务隔离性，校准函数对其它的正在执行的业务不可见，导致校准函数会漏掉此类业务的空间变化，为避免校准之后出现空间差误，建议用户使用空间校准函数时，应选择空间大小稳定无变化的时候执行校准。 参数：取值范围为0~4，不同的入参值代表不同的校准粒度。 入参为0(默认入参为0)：不重建PG_RELFILENODE_SIZE系统表，重新校准用户和schema空间。 入参为1：重建PG_RELFILENODE_SIZE系统表，并且重新校准用户和schema空间。 入参为2：重建PG_RELFILENODE_SIZE系统表。 入参为3：重新校准schema空间。 入参为4：重新校准用户空间。 返回值类型：text 示例： 1 2 3 4 5 SELECT * FROM pgxc_wlm_readjust_relfilenode_size_table(1); result -------------- Exec success (1 row)

pgxc_wlm_get_schema_space(cstring) 描述：在CN上查询某个逻辑集群下各实例的Schema空间信息，入参为逻辑集群名称。 返回值类型：record 函数返回字段如下： 名称 类型 描述 schemaname text 模式名 schemaid oid 模式OID databasename text 数据库名 databaseid oid 数据库OID nodename text 实例名称 nodegroup text 节点组名称 usedspace bigint 已使用的空间大小 permspace bigint 空间上限值 示例： 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 39 40 41 42 43 44 45 SELECT * FROM pgxc_wlm_get_schema_space('group1'); schemaname | schemaid | databasename | databaseid | nodename | nodegroup | usedspace | permspace --------------------+----------+--------------+------------+--------------+--------------+-----------+----------- pg_catalog | 11 | test1 | 16384 | datanode1 | installation | 9469952 | -1 public | 2200 | postgres | 15253 | datanode1 | installation | 25280512 | -1 pg_toast | 99 | test1 | 16384 | datanode1 | installation | 1859584 | -1 cstore | 100 | test1 | 16384 | datanode1 | installation | 0 | -1 data_redis | 18106 | postgres | 15253 | datanode1 | installation | 655360 | -1 data_redis | 18116 | test1 | 16384 | datanode1 | installation | 0 | -1 public | 2200 | test1 | 16384 | datanode1 | installation | 16384 | -1 dbms_om | 3987 | postgres | 15253 | datanode1 | installation | 0 | -1 dbms_job | 3988 | postgres | 15253 | datanode1 | installation | 0 | -1 dbms_om | 3987 | test1 | 16384 | datanode1 | installation | 0 | -1 dbms_job | 3988 | test1 | 16384 | datanode1 | installation | 0 | -1 sys | 11693 | postgres | 15253 | datanode1 | installation | 0 | -1 sys | 11693 | test1 | 16384 | datanode1 | installation | 0 | -1 utl_file | 14644 | postgres | 15253 | datanode1 | installation | 0 | -1 utl_raw | 14669 | postgres | 15253 | datanode1 | installation | 0 | -1 dbms_sql | 14674 | postgres | 15253 | datanode1 | installation | 0 | -1 dbms_output | 14662 | postgres | 15253 | datanode1 | installation | 0 | -1 dbms_random | 14666 | postgres | 15253 | datanode1 | installation | 0 | -1 dbms_lob | 14701 | postgres | 15253 | datanode1 | installation | 0 | -1 information_schema | 14300 | postgres | 15253 | datanode1 | installation | 294912 | -1 information_schema | 14300 | test1 | 16384 | datanode1 | installation | 294912 | -1 utl_file | 14644 | test1 | 16384 | datanode1 | installation | 0 | -1 dbms_output | 14662 | test1 | 16384 | datanode1 | installation | 0 | -1 dbms_random | 14666 | test1 | 16384 | datanode1 | installation | 0 | -1 utl_raw | 14669 | test1 | 16384 | datanode1 | installation | 0 | -1 dbms_sql | 14674 | test1 | 16384 | datanode1 | installation | 0 | -1 dbms_lob | 14701 | test1 | 16384 | datanode1 | installation | 0 | -1 pg_catalog | 11 | postgres | 15253 | datanode1 | installation | 13049856 | -1 redisuser | 16387 | postgres | 15253 | datanode1 | installation | 630784 | -1 pg_toast | 99 | postgres | 15253 | datanode1 | installation | 3080192 | -1 cstore | 100 | postgres | 15253 | datanode1 | installation | 2408448 | -1 pg_catalog | 11 | test1 | 16384 | datanode2 | installation | 9469952 | -1 public | 2200 | postgres | 15253 | datanode2 | installation | 25214976 | -1 pg_toast | 99 | test1 | 16384 | datanode2 | installation | 1859584 | -1 cstore | 100 | test1 | 16384 | datanode2 | installation | 0 | -1 data_redis | 18106 | postgres | 15253 | datanode2 | installation | 655360 | -1 data_redis | 18116 | test1 | 16384 | datanode2 | installation | 0 | -1 public | 2200 | test1 | 16384 | datanode2 | installation | 16384 | -1 dbms_om | 3987 | postgres | 15253 | datanode2 | installation | 0 | -1 dbms_job | 3988 | postgres | 15253 | datanode2 | installation | 0 | -1 dbms_om | 3987 | test1 | 16384 | datanode2 | installation | 0 | -1 dbms_job | 3988 | test1 | 16384 | datanode2 | installation | 0 | -1

pgxc_wlm_readjust_relfilenode_size_table() 描述：空间统计校准函数，不重建PG_RELFILENODE_SIZE系统表，重新校准用户和schema空间。 由于校准函数执行时与其余业务之间的事务隔离性，校准函数对其它的正在执行的业务不可见，导致校准函数会漏掉此类业务的空间变化，为避免校准之后出现空间差误，建议用户使用空间校准函数时，应选择空间大小稳定无变化的时候执行校准。 返回值类型：text 示例： 1 2 3 4 5 SELECT pgxc_wlm_readjust_schema_space(); pgxc_wlm_readjust_relfilenode_size_table ----------------------------------------- Exec Success (1 row)

pgxc_wlm_readjust_schema_space() 描述：Schema永久存储空间校准函数。 返回值类型：text 示例： 1 2 3 4 5 SELECT pgxc_wlm_readjust_schema_space(); pgxc_wlm_readjust_schema_space -------------------------------- Exec Success (1 row)

gs_wlm_readjust_user_space(oid) 描述：用户永久存储空间校准函数。入参为用户oid，入参为0的情况下，会校准所有用户的永久存储空间。 返回值类型：text 示例： 1 2 3 4 5 SELECT gs_wlm_readjust_user_space(0); gs_wlm_readjust_user_space ---------------------------- Exec Success (1 row)

pg_stat_get_status(tid, num_node_display) 描述：查询当前实例中工作线程（backend thread）以及辅助线程（auxiliary thread）的阻塞等待情况，其返回结果的详细含义参见PG_THREAD_WAIT_STATUS视图。输入参数含义如下： tid：表示线程ID，bigint类型。如果为NULL，则返回所有工作线程和辅助线程的等待情况；否则只返回指定ID线程的等待情况。 num_node_display：integer类型。对于等待状态为“wait node”的记录，指定其wait_status列中显示的被等待节点的最大数量。 如果为空或者小于等于0，则只显示一个被等待节点。 如果大于20，则最多只显示20个节点。 如果大于0且小于等于20，则显示数量为num_node_display和实际被等待节点数量的最小者。例如查询“SELECT * from pg_stat_get_status(NULL, 10)”，如果实际被等待节点数量大于10，则只随机显示其中10个节点名称，如果实际被等待节点数量小于等于10，则显示全部被等待节点名称。当实际被等待节点数量大于显示数量时，被显示的节点名称为随机挑选。 返回值类型：record

wdr_xdb_query(db_name text, snapshot_id bigint, view_name text) 描述：查询指定数据库下的指定视图。有的视图在不同数据库中查询结果不同，例如global_table_stat视图用于查询表格的统计信息，由于不同数据库下表格不同，在不同数据库中查询该视图得到的结果也不同。wdr_xdb_query函数可以在当前连接中访问db_name指定的数据库，并在该数据库中查询view_name指定的视图。输入参数含义如下： db_name：指定的数据库名称，text型。 snapshot_id：快照ID，bigint型，参见“性能视图快照”。 view_name：指定视图名称，text型。视图名称必须在如下白名单中： global_table_stat global_table_change_stat global_column_table_io_stat global_row_table_io_stat 返回值类型：record，其第一列为snapshot_id bigint，第二列为db_name text，其他列的名称、类型和顺序与view_name指定的视图相同。 示例： 1 2 SELECT snapshot_id, db_name, schemaname, relname, distribute_mode, seq_scan ,seq_tuple_read ,index_scan ,index_tuple_read ,tuple_inserted ,tuple_updated ,tuple_deleted ,tuple_hot_updated ,live_tuples ,dead_tuples from wdr_xdb_query('postgres'::text, 1, 'global_table_stat'::text) as i(snapshot_id bigint, db_name text, schemaname name, relname name, distribute_mode char, seq_scan bigint, seq_tuple_read bigint, index_scan bigint, index_tuple_read bigint, tuple_inserted bigint, tuple_updated bigint, tuplee_deleted bigint, tuple_hot_updated bigint, live_tuples bigint, dead_tuples bigint); 该函数仅8.1.2及以上版本支持。 该函数只有数据库管理员SYSADMIN才有权执行，非管理员执行会提示无权限。 该函数只能查询白名单中的视图，如果查询其他视图，会报错：“Input view name is invalid.”。

pgxc_get_node_env() 描述：提供获取集群中所有节点的环境变量信息。 返回值类型：record 示例： 1 2 3 4 5 6 7 8 9 10 SELECT * FROM pgxc_get_node_env(); node_name | host | process | port | installpath | datapath | log_directory --------------+---------------+---------+-------+------------------+---------------------------+-------------------------------------- dn_6001_6002 | 172.16.102.5 | 24443 | 40000 | /DWS/manager/app | /DWS/data1/h0dn1/primary0 | /DWS/manager/log/Ruby/pg_log/dn_6001 dn_6003_6004 | 172.16.70.17 | 21823 | 40000 | /DWS/manager/app | /DWS/data1/h1dn1/primary0 | /DWS/manager/log/Ruby/pg_log/dn_6003 dn_6005_6006 | 172.16.120.50 | 22331 | 40000 | /DWS/manager/app | /DWS/data1/h2dn1/primary0 | /DWS/manager/log/Ruby/pg_log/dn_6005 cn_5003 | localhost | 28811 | 8000 | /DWS/manager/app | /DWS/data1/coordinator | /DWS/manager/log/Ruby/pg_log/cn_5003 cn_5001 | 172.16.102.5 | 30873 | 8000 | /DWS/manager/app | /DWS/data1/coordinator | /DWS/manager/log/Ruby/pg_log/cn_5001 cn_5002 | 172.16.70.17 | 29229 | 8000 | /DWS/manager/app | /DWS/data1/coordinator | /DWS/manager/log/Ruby/pg_log/cn_5002 (6 rows)

reset_instr_unique_sql(cstring, cstring, INT8) 描述：清理已收集的Unique SQL信息。输入参数含义如下： GLOBAL/LOCAL：清理范围为所有节点或当前节点。 ALL/BY_USERID/BY_CNID/BY_GUC：ALL表示清理所有，BY_USERID/BY_CNID表示按照USERID或CNID进行清理，BY_GUC表示清理操作是由GUC参数instr_unique_sql_count设置值变小引起的。 第三个参数值对应第二个参数设置，ALL/BY_GUC的情况下该值无意义。 返回值类型：bool

pgxc_parallel_query(text, text) 描述：在指定类型的 数据实例 上执行指定的SQL查询语句，并把查询语句的结果返回给当前CN。该函数8.1.2及以上版本支持。 函数有两个参数： 第一个参数：SQL语句在哪些实例上执行。当前支持的有效入参是 'dn'， 'datanode'，'cn'， 'coordinator'， 'all'， 其它值会导致函数执行报错。其中 'dn'， 'datanode'表示在所有DN上执行，'cn'， 'coordinator'表示在所有CN上执行， all表示在所有的CN和所有的DN上执行。 第二个参数：需要发往远程节点执行的SQL语句，函数内部会对SQL语句中查询的对象进行校验，不支持用户表、分布式表和自定义的多结果集函数。 返回值类型：record 该函数功能仅为便于开发人员高效的收集集群内实例执行信息或者状态的视图，不建议用户直接使用。 该函数为多结果集函数，返回的数据类型为record，所以需要在函数调用后面增加AS语句显示的指出输出的列名和数据类型，如下所示： SELECT * FROM pgxc_parallel_query('all', 'select node_name, db_name, thread_name, query_id, tid, lwtid, ptid, tlevel, smpid, wait_status, wait_event from pg_thread_wait_status') AS (node_name text, db_name text, thread_name text, query_id bigint, tid bigint, lwtid integer , ptid integer, tlevel integer , smpid integer, wait_status text, wait_event text); 函数第二个参数指定的SQL语句输出结果的数据类型必须跟AS后面指明的数据类型一致，否则执行时可能会因为类型不匹配而报错。 函数第二个参数指定的SQL语句中不能触发跨节点的查询动作，否则会触发执行报错。 函数第二个参数指定的SQL语句只能是SELECT/UPDATE/DELETE/INSERT语句中的一种，且 不支持语句中有returning语句。 函数调用用户需具有SQL语句中对象相应的操作权限。 如果是INSERT语句，不支持INSERT OVERWRITE、UPSERT、和INSERT INTO。 对于UPDATE/DELETE/INSERT语句，只允许初始化用户在就地升级模式下或者管理员用户在重分布模式下执行；要求语句在每个实例上修改的记录数相同，否则执行会报错；函数会输出一条一列bigint类型的数值，此数值表示语句在每个实例上操作的记录数。 SELECT * FROM pgxc_parallel_query('cn', 'UPDATE pg_partition SET relpages = 0') AS (updated bigint);

pgxc_get_workload_sql_count() 描述：提供当前集群所有CN上所有Workload控制组内执行的SELECT/UPDATE/INSERT/DELETE语句的计数统计结果以及DDL、DML、DCL类型语句的计数统计结果。 返回值类型：record 示例： 1 2 3 4 5 6 7 SELECT * FROM pgxc_get_workload_sql_count(); node_name | workload | select_count | update_count | insert_count | delete_count | ddl_count | dml_count | dcl_count -----------+--------------+--------------+--------------+--------------+--------------+-----------+-----------+----------- cn_5003 | default_pool | 2079352 | 3264 | 22858 | 3 | 10460 | 2243738 | 16988 cn_5001 | default_pool | 2201345 | 9 | 0 | 0 | 10474 | 2359633 | 10465 cn_5002 | default_pool | 3784696 | 0 | 103106 | 136 | 10438 | 4039090 | 10498 (3 rows)

pgxc_get_workload_sql_elapse_time() 描述：提供当前集群所有CN上所有Workload控制组内执行的SELECT/UPDATE/INSERT/DELETE语句的响应时间统计结果。 返回值类型：record 示例： 1 2 3 4 5 6 7 8 9 10 11 12 SELECT * FROM pgxc_get_workload_sql_elapse_time(); node_name | workload | total_select_elapse | max_select_elapse | min_select_elapse | avg_select_elapse | total_update_elapse | max_update_elapse | min_update_elapse | avg_update_elapse | total_insert_el apse | max_insert_elapse | min_insert_elapse | avg_insert_elapse | total_delete_elapse | max_delete_elapse | min_delete_elapse | avg_delete_elapse -----------+--------------+---------------------+-------------------+-------------------+-------------------+---------------------+-------------------+-------------------+-------------------+---------------- -----+-------------------+-------------------+-------------------+---------------------+-------------------+-------------------+------------------- cn_5003 | default_pool | 3776420502 | 8140206 | 0 | 1816 | 67505332 | 38076 | 0 | 20682 | 29178 9830 | 62102 | 0 | 12765 | 19255 | 10656 | 0 | 6418 cn_5001 | default_pool | 8599339496 | 3390159 | 0 | 3906 | 52789 | 18207 | 0 | 5865 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 cn_5002 | default_pool | 40483096221 | 2178781 | 0 | 10695 | 0 | 0 | 0 | 0 | 13310238 8148 | 2398854 | 0 | 1290752 | 2072031 | 52877 | 0 | 15236 (3 rows)

pg_stat_get_sql_count() 描述：提供当前节点中所有用户执行的SELECT/UPDATE/INSERT/DELETE/MERGE INTO语句的计数和响应时间的统计结果以及DDL、DML、DCL语句的计数结果。 返回值类型：record 示例： 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 SELECT * FROM pg_stat_get_sql_count(); node_name | user_name | select_count | update_count | insert_count | delete_count | mergeinto_count | ddl_count | dml_count | dcl_count | total_select_elapse | avg_select_elapse | max_select_el apse | min_select_elapse | total_update_elapse | avg_update_elapse | max_update_elapse | min_update_elapse | total_insert_elapse | avg_insert_elapse | max_insert_elapse | min_insert_elapse | total_delete_ela pse | avg_delete_elapse | max_delete_elapse | min_delete_elapse -----------+------------------------+--------------+--------------+--------------+--------------+-----------------+-----------+-----------+-----------+---------------------+-------------------+-------------- -----+-------------------+---------------------+-------------------+-------------------+-------------------+---------------------+-------------------+-------------------+-------------------+----------------- ----+-------------------+-------------------+------------------- cn_5003 | gs_role_read_all_stats | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 cn_5003 | gs_role_signal_backend | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 cn_5003 | gs_role_analyze_any | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 cn_5003 | gs_role_vacuum_any | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 cn_5003 | dbadmin | 641 | 0 | 3 | 0 | 0 | 18 | 651 | 5 | 19236129 | 30009 | 814 0206 | 357 | 0 | 0 | 0 | 0 | 70595 | 23531 | 62102 | 2750 | 0 | 0 | 0 | 0 cn_5003 | Ruby | 2078187 | 3263 | 22841 | 0 | 0 | 10436 | 2242517 | 16979 | 3753441293 | 1806 | 52 6891 | 191 | 67483165 | 20681 | 38076 | 15444 | 291598980 | 12766 | 35376 | 3791 | 0 | 0 | 0 | 0 cn_5003 | joe | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 cn_5003 | sea | 192 | 0 | 5 | 3 | 0 | 3 | 205 | 0 | 2561878 | 13343 | 68 1866 | 388 | 0 | 0 | 0 | 0 | 11349 | 2269 | 3241 | 1521 | 19 255 | 6418 | 10656 | 2798 cn_5003 | jj | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 cn_5003 | u1 | 2 | 0 | 2 | 0 | 0 | 1 | 4 | 0 | 3712 | 1856 | 2407 | 1305 | 0 | 0 | 0 | 0 | 5366 | 2683 | 3359 | 2007 | 0 | 0 | 0 | 0 (10 rows)

pg_stat_get_thread() 描述：提供当前节点下所有线程的状态信息。 返回值类型：record 示例： 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 SELECT * FROM pg_stat_get_thread(); node_name | pid | lwpid | thread_name | creation_time -----------+-----------------+---------+--------------------+------------------------------- cn_5003 | 281471515199536 | 28930 | JobScheduler | 2023-01-04 07:03:16.086885+00 cn_5003 | 281471498418224 | 28931 | StatCollector | 2000-01-01 00:00:00+00 cn_5003 | 281471464855600 | 28933 | WDRSnapshot | 2023-01-04 07:03:16.086775+00 cn_5003 | 281471380949040 | 28938 | WorkloadMonitor | 2023-01-04 07:03:16.074454+00 cn_5003 | 281471414511664 | 28936 | workload | 2023-01-04 07:03:16.075457+00 cn_5003 | 281471364167728 | 28939 | WLMArbiter | 2023-01-04 07:03:16.076753+00 cn_5003 | 281471397730352 | 28937 | CalculateSpaceInfo | 2023-01-04 07:03:16.078981+00 cn_5003 | 281470777964592 | 1933534 | wlm | 2023-01-13 08:01:32.350808+00 cn_5003 | 281470889130032 | 1786064 | cn_5002 | 2023-01-13 07:01:50.173568+00 cn_5003 | 281471299672112 | 29006 | cm_agent | 2023-01-04 07:03:18.03415+00 cn_5003 | 281471222065200 | 29970 | cn_5002 | 2023-01-04 07:03:39.694702+00 cn_5003 | 281471238846512 | 1897367 | cn_5002 | 2023-01-04 20:01:40.611019+00 cn_5003 | 281470905911344 | 30053 | cn_5002 | 2023-01-04 07:03:44.065774+00 cn_5003 | 281470410537008 | 1933902 | cn_5002 | 2023-01-13 08:01:38.972574+00 cn_5003 | 281470872348720 | 1880248 | cn_5001 | 2023-01-13 07:39:24.231418+00 cn_5003 | 281471316453424 | 1883059 | cn_5001 | 2023-01-13 07:40:16.885667+00 cn_5003 | 281470845081648 | 1305053 | cn_5001 | 2023-01-13 03:40:17.366784+00 cn_5003 | 281470700357680 | 1500466 | wlm | 2023-01-13 05:02:05.714544+00 cn_5003 | 281470473455664 | 1883060 | cn_5001 | 2023-01-13 07:40:16.885963+00 cn_5003 | 281470717138992 | 32065 | cm_agent | 2023-01-04 07:04:23.906691+00 cn_5003 | 281470807328816 | 1977925 | gsql | 2023-01-13 08:20:04.509437+00 cn_5003 | 281470683576368 | 1835242 | cn_5001 | 2023-01-13 07:20:16.549546+00 cn_5003 | 281471584946224 | 28927 | Background writer | 2023-01-04 07:03:16.065631+00 cn_5003 | 281471633184816 | 28926 | CheckPointer | 2023-01-04 07:03:16.065872+00 cn_5003 | 281471548762160 | 28928 | Wal Writer | 2023-01-04 07:03:16.066366+00 cn_5003 | 281471448074288 | 28934 | TwoPhase Cleaner | 2023-01-04 07:03:16.071172+00 cn_5003 | 281471431292976 | 28935 | LWLock Monitor | 2023-01-04 07:03:16.072897+00 cn_5003 | 281470666795056 | 1210459 | CBM Writer | 2023-01-04 15:16:05.543143+00 (28 rows)

pg_stat_get_env() 描述：提供获取当前节点的环境变量信息。 返回值类型：record 示例： 1 2 3 4 5 SELECT * FROM pg_stat_get_env(); node_name | host | process | port | installpath | datapath | log_directory -----------+-----------+---------+------+------------------+------------------------+-------------------------------------- cn_5003 | localhost | 28811 | 8000 | /DWS/manager/app | /DWS/data1/coordinator | /DWS/manager/log/Ruby/pg_log/cn_5003 (1 row)