华为云用户手册

  • 数据仓库服务 GAUSSDB(DWS)-复制函数:pg_logical_slot_get_changes('slot_name', 'LSN', upto_nchanges, 'options_name', 'options_value')
    pg_logical_slot_get_changes('slot_name', 'LSN', upto_nchanges, 'options_name', 'options_value') 描述：解码并推进流复制槽。 参数说明： 与pg_logical_slot_peek_changes一致，详细内容请参见pg_logical_slot_peek_changes('slot_name', 'LSN', upto_nchanges, 'options_name', 'options_value')。
    数据仓库服务 GAUSSDB(DWS)
  • 数据仓库服务 GAUSSDB(DWS)-复制函数:pg_stat_get_data_senders()
    pg_stat_get_data_senders() 描述：显示当前DN上所有的数据页复制发送线程的统计信息。 返回值类型：record 函数返回信息如下： 表2 pg_stat_get_data_senders()字段 名称 类型 描述 pid bigint 线程pid sender_pid integer 当前sender的pid local_role text 本地的角色 peer_role text 对端的角色 state text 当前sender的复制状态 catchup_start timestamp with time zone catchup启动的时间 catchup_end timestamp with time zone catchup结束的时间 queue_size text 数据队列大小 queue_lower_tail text 数据队列尾1位置 queue_header text 数据队列头位置 queue_upper_tail text 数据队列尾2位置 send_position text 发送端发送的位置 receive_position text 接收端接收的位置 catchup_type text catchup方式为全量还是增量 catchup_bcm_filename text catchup当前执行的bcm文件 catchup_bcm_finished integer catchup已操作完成的bcm文件数量 catchup_bcm_total integer catchup总共需要操作的bcm文件数量 catchup_percent text catchup已经操作完成的百分比 catchup_remaining_time text catchup预估剩余时间
    数据仓库服务 GAUSSDB(DWS)
  • 数据仓库服务 GAUSSDB(DWS)-复制函数:pg_replication_slot_advance ('slot_name', 'LSN')
    pg_replication_slot_advance ('slot_name', 'LSN') 描述：直接推进流复制槽到指定LSN，不输出解码结果。 参数说明： slot_name 流复制槽名称。 取值范围：字符串，不支持除字母，数字，以及（_?-.）以外的字符。 LSN 推进到的日志LSN位置，下次解码时只会输出提交位置比该LSN大的事务结果。如果输入的LSN比当前流复制槽记录的推进位置还要小，则直接返回；如果输入的LSN比当前最新物理日志LSN还要大，则推进到当前最新物理日志LSN。 取值范围：字符串（LSN，格式为xlogid/xrecoff）。 返回值类型：name, text 备注：返回值分别对应slot_name和实际推进至的LSN。
    数据仓库服务 GAUSSDB(DWS)
  • 数据仓库服务 GAUSSDB(DWS)-复制函数:pg_create_physical_replication_slot ('slot_name', isDummyStandby)
    pg_create_physical_replication_slot ('slot_name', isDummyStandby) 描述：创建物理复制槽。 参数说明： slot_name 流复制槽名称。 取值范围：字符串，不支持除字母，数字，以及（_?-.）以外的字符。 isDummyStandby 复制槽是否为从备。 取值范围：布尔值，支持true或false。 返回值类型：name, text 备注：第一个返回值表示slot_name，第二个返回值表示该物理复制槽解码的起始LSN位置。
    数据仓库服务 GAUSSDB(DWS)
  • 数据仓库服务 GAUSSDB(DWS)-复制函数:pg_get_replication_slots()
    pg_get_replication_slots() 描述：显示当前DN上所有的复制槽信息。 返回值类型：record 函数返回信息如下： 表1 pg_get_replication_slots()字段 名称 类型 描述 slot_name text 复制槽的名称 plugin name 逻辑复制槽对应的输出插件名 slot_type text 复制槽的类型 datoid oid 复制槽的数据库OID active boolean 复制槽是否为激活状态 xmin xid 复制槽事务标识 catalog_xmin text 逻辑复制槽对应的最早解码事务标识 restart_lsn text 复制槽的Xlog文件信息 dummy_standby boolean 复制槽是否为从备 示例： 1 2 3 4 5 SELECT * FROM pg_get_replication_slots(); slot_name | plugin | slot_type | datoid | active | xmin | catalog_xmin | restart_lsn | dummy_standby -----------------+--------+-----------+--------+--------+------+--------------+-------------------+--------------- gs_roach_common | | physical | 0 | f | | 602861775 | FFFFFFFF/FFFFFFFF | f (1 row)
    数据仓库服务 GAUSSDB(DWS)
  • 数据仓库服务 GAUSSDB(DWS)-复制函数:pg_create_logical_replication_slot('slot_name', 'plugin_name')
    pg_create_logical_replication_slot('slot_name', 'plugin_name') 描述：创建逻辑复制槽。 参数说明： slot_name 流复制槽名称。 取值范围：字符串，不支持除字母，数字，以及（_?-.）以外的字符。 plugin_name 插件名称。 取值范围：字符串，当前只支持“mppdb_decoding”。 返回值类型：name, text 备注：第一个返回值表示slot_name，第二个返回值表示该逻辑复制槽解码的起始LSN位置。
    数据仓库服务 GAUSSDB(DWS)
  • 数据仓库服务 GAUSSDB(DWS)-咨询锁函数:pg_advisory_lock(key bigint)
    pg_advisory_lock(key bigint) 描述：获取会话级别的排它咨询锁。 返回值类型：void 备注：pg_advisory_lock锁定应用程序定义的资源，该资源可以用一个64位或两个不重叠的32位键值标识。如果已经有另外的会话锁定了该资源，则该函数将阻塞到该资源可用为止。这个锁是排它的。多个锁定请求将会被压入栈中，因此，如果同一个资源被锁定了三次，它必须被解锁三次以将资源释放给其他会话使用。
    数据仓库服务 GAUSSDB(DWS)
  • 数据仓库服务 GAUSSDB(DWS)-快照同步函数:create_wdr_snapshot()
    create_wdr_snapshot() 描述：创建性能数据快照。 返回值类型：text 该函数只有数据库管理员SYSADMIN才可以执行，非管理员执行会提示无权限。 该函数只能在CN上执行，在DN上执行会返回：“WDR snapshot can only be created on coordinator.”。 执行该函数前需确认enable_wdr_snapshot参数处于开启状态。如果enable_wdr_snapshot为off，执行该函数会返回：“WDR snapshot request can't be executed, because GUC parameter 'enable_wdr_snapshot' is off.”。 如果执行该函数时，快照线程由于节点重启等原因尚未启动，会提示错误：“WDR snapshot request can not be accepted, please retry later.”。 如果执行该函数失败，会提示：“Cannot respond to WDR snapshot request.”。 如果执行成功，会返回：“WDR snapshot request has been submitted.”。该提示表明创建快照请求已发送至后台快照线程，但不代表创建快照成功。
    数据仓库服务 GAUSSDB(DWS)
  • 数据仓库服务 GAUSSDB(DWS)-快照同步函数:pg_export_snapshot()
    pg_export_snapshot() 描述：保存当前的快照并返回它的标识符。 返回值类型：text 备注：函数pg_export_snapshot保存当前的快照并返回一个文本字符串标识此快照。这个字符串必须传递给想要导入快照的客户端。可用在set transaction snapshot snapshot_id时导入snapshot，但是应用的前提是该事务设置了REPEATABLE READ隔离级别。该函数的输出不可用做set transaction snapshot的输入。 示例： 1 2 3 4 5 SELECT pg_export_snapshot(); pg_export_snapshot -------------------- 00000000000A7128-1 (1 row)
    数据仓库服务 GAUSSDB(DWS)
  • 数据仓库服务 GAUSSDB(DWS)-快照同步函数:kill_snapshot(scope cstring)
    kill_snapshot(scope cstring) 描述：中止后台快照线程。该函数向后台快照线程发送中止信号并等待线程结束。 输入参数scope：表示操作范围。该参数取值范围为local和global。 local表示中止当前CN上的快照线程。 global表示不仅会中止当前CN上的快照线程，还会向集群中所有其他CN发送中止快照线程的请求，即中止集群中所有CN上的快照线程。 如果输入其他值，则报错“Scope is invalid, use "local" or "global".”。 输入参数可为空，表示默认取值为local。 返回值类型：无 该函数只有数据库管理员SYSADMIN才有权执行，非管理员执行会提示无权限。 该函数只能在CN上执行，在DN上执行会提示：“kill_snapshot can only be executed on coordinator.”； 执行该函数会向后台快照线程发送中止信号并等待其结束。如果100s内快照线程仍未中止则会报错：“Kill snapshot thread failed”；
    数据仓库服务 GAUSSDB(DWS)
  • 数据仓库服务 GAUSSDB(DWS)-服务器信号函数:pg_terminate_backend(pid int)
    pg_terminate_backend(pid int) 描述：终止一个后台线程。 返回值类型：boolean 备注：如果成功，函数返回true，否则返回false。 示例： 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 SELECT pid FROM pg_stat_activity; pid ----------------- 140657876268816 140433774061312 140433587902208 140433656592128 140433723717376 140433637189376 140433552770816 140433481983744 140433349310208 (9 rows) SELECT pg_terminate_backend(140657876268816); pg_terminate_backend ---------------------- t (1 row)
    数据仓库服务 GAUSSDB(DWS)
  • 数据仓库服务 GAUSSDB(DWS)-服务器信号函数:pgxc_cancel_query(queryId int)
    pgxc_cancel_query(queryId int) 描述：取消当前集群下正在执行的查询。该函数8.1.2及以上版本支持。 返回值类型：boolean 备注：如果所有节点的查询均已取消，函数返回true，否则返回false。 示例： 1 2 3 4 5 6 7 8 9 10 11 12 SELECT query_id FROM pgxc_stat_activity WHERE stmt_type ='RESET'; query_id ---------- 0 0 (2 rows) SELECT pgxc_cancel_query(0); pgxc_cancel_query ------------------- f (1 row)
    数据仓库服务 GAUSSDB(DWS)
  • 数据仓库服务 GAUSSDB(DWS)-服务器信号函数:pg_rotate_logfile()
    pg_rotate_logfile() 描述：滚动服务器的日志文件。 返回值类型：boolean 备注：pg_rotate_logfile通知日志文件管理器立即切换到一个新的输出文件。该函数仅在内置日志收集器运行时有效。 示例： 1 2 3 4 5 SELECT pg_rotate_logfile(); pg_rotate_logfile ------------------- t (1 row)
    数据仓库服务 GAUSSDB(DWS)
  • 数据仓库服务 GAUSSDB(DWS)-服务器信号函数:pg_wlm_jump_queue(pid int)
    pg_wlm_jump_queue(pid int) 描述：调整任务到CN队列的最前端。 返回值类型：boolean 备注：如果成功，函数返回true，否则返回false。 示例： 1 2 3 4 5 6 7 8 9 10 11 SELECT pid FROM pg_stat_activity WHERE stmt_type ='RESET'; pid ----------------- 281471222065200 (1 row) SELECT pg_wlm_jump_queue(281471222065200); pg_wlm_jump_queue ------------------- t (1 row)
    数据仓库服务 GAUSSDB(DWS)
  • 数据仓库服务 GAUSSDB(DWS)-服务器信号函数:pg_cancel_query(queryId int)
    pg_cancel_query(queryId int) 描述：取消一个后端的当前查询。该函数8.1.2及以上版本支持。 返回值类型：boolean 备注：pg_cancel_query向由query_id标识的后端进程发送一个查询取消（SIGINT）信号。一个活动的后端进程的query_id可以从pg_stat_activity视图的query_id字段找到。 示例： 1 2 3 4 5 6 7 8 9 10 11 12 SELECT query_id FROM pgxc_stat_activity WHERE stmt_type ='RESET'; query_id ---------- 0 0 (2 rows) SELECT pg_cancel_query(0); pg_cancel_query ----------------- f (1 row)
    数据仓库服务 GAUSSDB(DWS)
  • 数据仓库服务 GAUSSDB(DWS)-服务器信号函数:pg_terminate_query(queryId int)
    pg_terminate_query(queryId int) 描述：终止一个后端的当前查询。该函数8.1.2及以上版本支持。 返回值类型：boolean 示例： 1 2 3 4 5 6 7 8 9 10 11 12 SELECT query_id FROM pgxc_stat_activity WHERE stmt_type ='RESET'; query_id ---------- 0 0 (2 rows) SELECT pg_terminate_query(0); pg_terminate_query -------------------- f (1 row)
    数据仓库服务 GAUSSDB(DWS)
  • 数据仓库服务 GAUSSDB(DWS)-服务器信号函数:pgxc_terminate_query(queryId int)
    pgxc_terminate_query(queryId int) 描述：终止当前集群下正在执行的查询。该函数8.1.2及以上版本支持。 返回值类型：boolean 示例： 1 2 3 4 5 6 7 8 9 10 11 SELECT query_id FROM pgxc_stat_activity; query_id ----------------- 72339069014638631 (1 rows) SELECT pgxc_terminate_query(72339069014638631); pgxc_terminate_query ---------------------- t (1 row)
    数据仓库服务 GAUSSDB(DWS)
  • 数据仓库服务 GAUSSDB(DWS)-服务器信号函数:pg_cancel_backend(pid int)
    pg_cancel_backend(pid int) 描述：取消一个后端的当前查询。 返回值类型：boolean 备注：pg_cancel_backend向由pid标识的后端进程发送一个查询取消（SIGINT）信号。一个活动的后端进程的PID可以从pg_stat_activity视图的pid字段找到，或者在服务器上用ps列出数据库进程。 示例： 1 2 3 4 5 6 7 8 9 10 11 SELECT pid FROM pg_stat_activity WHERE stmt_type ='RESET'; pid ----------------- 281471222065200 (1 row) SELECT pg_cancel_backend(281471222065200); pg_cancel_backend ------------------- t (1 row)
    数据仓库服务 GAUSSDB(DWS)
  • 数据仓库服务 GAUSSDB(DWS)-通用文件访问函数:pg_read_binary_file(filename text [, offset bigint, length bigint,missing_ok boolean])
    pg_read_binary_file(filename text [, offset bigint, length bigint,missing_ok boolean]) 描述：返回一个二进制文件的内容。 返回值类型：bytea 备注：pg_read_binary_file的功能与pg_read_file类似，除了结果的返回值为bytea类型不一致，相应地不会执行编码检查。与convert_from函数结合，这个函数可以用来读取用指定编码的一个文件。 1 SELECT convert_from(pg_read_binary_file('filename'), 'UTF8');
    数据仓库服务 GAUSSDB(DWS)
  • 数据仓库服务 GAUSSDB(DWS)-通用文件访问函数:pg_read_file(filename text, offset bigint, length bigint)
    pg_read_file(filename text, offset bigint, length bigint) 描述：返回一个文本文件的内容。 返回值类型：text 备注：pg_read_file返回一个文本文件的一部分，从offset开始，最多返回length字节（如果先达到文件结尾，则小于这个数值）。如果offset是负数，则它是相对于文件结尾回退的长度。如果省略了offset和length，则返回整个文件。 示例： 1 2 3 4 5 6 7 8 9 10 11 SELECT pg_read_file('postmaster.pid',0,100); pg_read_file --------------------------------------- 53078 + /srv/BigData/hadoop/data1/coordinator+ 1500022474 + 8000 + /var/run/dws + localhost + 2 (1 row)
    数据仓库服务 GAUSSDB(DWS)
  • 数据仓库服务 GAUSSDB(DWS)-通用文件访问函数:pg_stat_file(filename text)
    pg_stat_file(filename text) 描述：返回一个文本文件的状态信息。 返回值类型：record 备注：pg_stat_file返回一条记录，其中包含：文件大小、最后访问时间戳、最后更改时间戳、最后文件状态修改时间戳以及标识传入参数是否为目录的boolean值。典型的用法： 1 SELECT * FROM pg_stat_file('filename'); 1 SELECT (pg_stat_file('filename')).modification; 示例： 1 2 3 4 5 6 7 8 9 SELECT * FROM pg_stat_file('postmaster.pid'); size | access | modification | change | creation | isdir ------+------------------------+------------------------+------------------------ +----------+------- 117 | 2017-06-05 11:06:34+08 | 2017-06-01 17:18:08+08 | 2017-06-01 17:18:08+08 | | f (1 row) 1 2 3 4 5 SELECT (pg_stat_file('postmaster.pid')).modification; modification ------------------------ 2017-06-01 17:18:08+08 (1 row)
    数据仓库服务 GAUSSDB(DWS)
  • 数据仓库服务 GAUSSDB(DWS)-通用文件访问函数:pg_ls_dir(dirname text)
    pg_ls_dir(dirname text) 描述：列出目录中的文件。 返回值类型：setof text 备注：pg_ls_dir返回指定目录里面的除了特殊项“.”和“..”之外所有名字。 示例： 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 SELECT pg_ls_dir('./'); pg_ls_dir ---------------------- .postgresql.conf.swp postgresql.conf pg_tblspc PG_VERSION pg_ident.conf core server.crt pg_serial pg_twophase postgresql.conf.lock pg_stat_tmp pg_notify pg_subtrans pg_ctl.lock pg_xlog pg_clog base pg_snapshots postmaster.opts postmaster.pid server.key.rand server.key.cipher pg_multixact pg_errorinfo server.key pg_hba.conf pg_replslot .pg_hba.conf.swp cacert.pem pg_hba.conf.lock global gaussdb.state (32 rows)
    数据仓库服务 GAUSSDB(DWS)
  • 数据仓库服务 GAUSSDB(DWS)-配置设置函数:current_setting(setting_name)
    current_setting(setting_name) 描述：当前的设置值。 返回值类型：text 备注：current_setting用于以查询形式获取setting_name的当前值。和SQL语句SHOW是等效的。比如： 1 2 3 4 5 6 SELECT current_setting('datestyle'); current_setting ----------------- ISO, MDY (1 row)
    数据仓库服务 GAUSSDB(DWS) 系统管理函数
  • 数据仓库服务 GAUSSDB(DWS)-配置设置函数:set_config(setting_name, new_value, is_local)
    set_config(setting_name, new_value, is_local) 描述：设置参数并返回新值。 返回值类型：text 备注：set_config将参数setting_name设置为new_value，如果is_local为true，则新值将只应用于当前事务。如果希望新值应用于当前会话，可以使用false，和SQL语句SET是等效的。比如： 1 2 3 4 5 6 SELECT set_config('log_statement_stats', 'off', false); set_config ------------ off (1 row)
    数据仓库服务 GAUSSDB(DWS) 系统管理函数
  • 数据仓库服务 GAUSSDB(DWS)-条件表达式函数:EMPTY_BLOB()
    EMPTY_BLOB() 描述：使用EMPTY_BLOB在INSERT或UPDATE语句中初始化一个BLOB变量，取值为NULL。 返回值类型：BLOB 示例： 1 2 3 4 5 6 --新建表 CREATE TABLE blob_tb(b blob,id int) DISTRIBUTE BY REPLICATION; --插入数据 INSERT INTO blob_tb VALUES (empty_blob(),1); --删除表 DROP TABLE blob_tb; 使用DBMS.GETLENGTH求得的长度为0。
    数据仓库服务 GAUSSDB(DWS)
  • 数据仓库服务 GAUSSDB(DWS)-条件表达式函数:greatest(expr1 [, ...])
    greatest(expr1 [, ...]) 描述：获取并返回参数列表中值最大的表达式的值。 ORA和TD兼容模式下，返回结果为所有非null参数的最大值。 MySQL兼容模式下，入参中存在null时，返回结果为null。 示例： 1 2 3 4 5 SELECT greatest(1*2,2-3,4-1); greatest ---------- 3 (1 row) 1 2 3 4 5 SELECT greatest('ABC', 'BCD', 'CDE'); greatest ---------- CDE (1 row)
    数据仓库服务 GAUSSDB(DWS)
  • 数据仓库服务 GAUSSDB(DWS)-条件表达式函数:least(expr1 [, ...])
    least(expr1 [, ...]) 描述：获取并返回参数列表中值最小的表达式的值。 ORA和TD兼容模式下，返回结果为所有非null参数的最小值。 MySQL兼容模式下，入参中存在null时，返回结果为null。 示例： 1 2 3 4 5 SELECT least(1*2,2-3,4-1); least ------- -1 (1 row) 1 2 3 4 5 SELECT least('ABC','BCD','CDE'); least -------- ABC (1 row)
    数据仓库服务 GAUSSDB(DWS)
  • 数据仓库服务 GAUSSDB(DWS)-条件表达式函数:ifnull(expr1, expr2)
    ifnull(expr1, expr2) 描述：当expr1不为NULL时，返回expr1，否则返回expr2。 ifnull(expr1, expr2) 逻辑上等价于CASE WHEN expr1 IS NOT NULL THEN expr1 ELSE expr2 END。 示例： 1 2 3 4 5 SELECT ifnull(NULL,'hello'); ifnull -------- hello (1 row) 参数expr1和expr2可以为任意类型，返回结果类型规则请参考UNION，CASE和相关构造。
    数据仓库服务 GAUSSDB(DWS)
  • 数据仓库服务 GAUSSDB(DWS)-条件表达式函数:sys_context( 'namespace' , 'parameter')
    sys_context( 'namespace' , 'parameter') 描述：获取并返回指定namespace下参数parameter的值。 返回值类型：VARCHAR 示例： 1 2 3 4 5 SELECT sys_context('USERENV', 'CURRENT_SCHEMA'); sys_context ------------- public (1 row) 根据当前所在的实际schema而变化。 目前仅支持SYS_CONTEXT('USERENV', 'CURRENT_SCHEMA') 和SYS_CONTEXT('USERENV', 'CURRENT_USER')两种格式。
    数据仓库服务 GAUSSDB(DWS)
  • 数据仓库服务 GAUSSDB(DWS)-条件表达式函数:decode(base_expr, compare1, value1, Compare2,value2, … default)
    decode(base_expr, compare1, value1, Compare2,value2, … default) 描述：把base_expr与后面的每个compare(n) 进行比较，如果匹配返回相应的value(n)。如果没有发生匹配，则返回default。 示例： 1 2 3 4 5 SELECT decode('A','A',1,'B',2,0); case ------ 1 (1 row)
    数据仓库服务 GAUSSDB(DWS)
共100000条
undefined

搜索反馈

您找到想要的内容了吗?

是的 没有

意见反馈

0/200

提交 取消

提交成功！非常感谢您的反馈，我们会继续努力做到更好 反馈提交失败！请稍后重试！
推荐文章