簡介

當(dāng)查詢使用ePQ特性時(shí)，PolarDB PostgreSQL版將通過ePQ優(yōu)化器，生成能夠被多個(gè)計(jì)算節(jié)點(diǎn)并行執(zhí)行的執(zhí)行計(jì)劃。ePQ的執(zhí)行引擎將在多個(gè)計(jì)算節(jié)點(diǎn)上協(xié)調(diào)執(zhí)行該計(jì)劃，同時(shí)利用多個(gè)節(jié)點(diǎn)的CPU、內(nèi)存、I/O帶寬來掃描、計(jì)算數(shù)據(jù)。

您可以通過GUC參數(shù)動(dòng)態(tài)調(diào)整參與ePQ并行執(zhí)行的計(jì)算節(jié)點(diǎn) (Scale Out)，以及節(jié)點(diǎn)上的單機(jī)并行度 (Scale Up)，從而實(shí)現(xiàn)Serverless彈性擴(kuò)展。

ePQ善于解決復(fù)雜、執(zhí)行時(shí)間長的OLAP長查詢，不適用于簡單、執(zhí)行時(shí)間短的OLTP短查詢。對于短查詢而言，計(jì)算節(jié)點(diǎn)之間建立連接、數(shù)據(jù)交換、銷毀連接的開銷反而會(huì)引發(fā)查詢性能的回退。PolarDB PostgreSQL版支持根據(jù)表的大小或執(zhí)行計(jì)劃的代價(jià)來控制對查詢使用ePQ還是單機(jī)執(zhí)行，從而在查詢不同大小的表和執(zhí)行不同代價(jià)的計(jì)劃時(shí)，能夠選擇性能更好的查詢執(zhí)行方式。

關(guān)于更多ePQ的原理介紹和性能數(shù)據(jù)，請參見PolarDB PostgreSQL版：ePQ架構(gòu)詳解。

一鍵開啟ePQ功能

如果當(dāng)前有張表t1，可以通過以下命令一鍵開啟ePQ功能。如輸出所示，如果計(jì)劃中出現(xiàn)PolarDB PX Optimizer，則說明ePQ已經(jīng)生效。

SET polar_enable_px = 1;
EXPLAIN SELECT * FROM t1;
                                  QUERY PLAN
-------------------------------------------------------------------------------
 PX Coordinator 6:1  (slice1; segments: 6)  (cost=0.00..431.00 rows=1 width=8)
   ->  Partial Seq Scan on t1  (cost=0.00..431.00 rows=1 width=8)
 Optimizer: PolarDB PX Optimizer
(3 rows)

SELECT * FROM t1;

GUC參數(shù)說明

=> CREATE EXTENSION polar_monitor;
CREATE EXTENSION

=> SELECT name,slot_name,type FROM polar_cluster_info WHERE type = 'Replica';
 name  | slot_name |  type
-------+-----------+---------
 node2 | replica1  | Replica
 node3 | replica2  | Replica
(2 rows)

=> SET polar_px_nodes = 'node2,node3';
=> SHOW polar_px_nodes;
 polar_px_nodes
----------------
 node2,node3
(1 row)

ERROR:  over px max workers, already xxx workers, max 30 workers

最佳實(shí)踐

允許特定的表使用ePQ

如果只想針對特定表執(zhí)行ePQ，可以開啟polar_px_enable_check_workers參數(shù)。同時(shí)對需要執(zhí)行ePQ的表顯式設(shè)置px_workers選項(xiàng)。

ALTER TABLE t1 SET (px_workers = 1);

開啟ePQ功能

全局級別

在PolarDB控制臺(tái)上設(shè)置polar_enable_px參數(shù)為on，即可全局啟用ePQ功能，無論是OLTP查詢還是OLAP查詢，都將默認(rèn)使用ePQ。

使用如下示例查看執(zhí)行計(jì)劃。如果計(jì)劃中出現(xiàn)PolarDB PX Optimizer，則說明ePQ已經(jīng)生效：

=> EXPLAIN SELECT * FROM t1;
                                  QUERY PLAN
-------------------------------------------------------------------------------
 PX Coordinator 6:1  (slice1; segments: 6)  (cost=0.00..431.00 rows=1 width=8)
   ->  Partial Seq Scan on t1  (cost=0.00..431.00 rows=1 width=8)
 Optimizer: PolarDB PX Optimizer
(3 rows)

會(huì)話級別

在會(huì)話內(nèi)設(shè)置polar_enable_px參數(shù)為ON，使當(dāng)前會(huì)話內(nèi)的所有查詢默認(rèn)使用ePQ：

SET polar_enable_px = ON;

數(shù)據(jù)庫級別/用戶級別

在全局級別或會(huì)話級別啟用ePQ后，會(huì)話內(nèi)的所有的查詢都會(huì)優(yōu)先使用ePQ。從最佳實(shí)踐的角度來說，ePQ更適用于需要進(jìn)行大量OLAP負(fù)載的長查詢，而不適用于OLTP短查詢。對于短查詢來說，ePQ在計(jì)算節(jié)點(diǎn)間的建立連接、數(shù)據(jù)交換、銷毀連接的開銷將會(huì)引發(fā)查詢性能的回退。

如果在業(yè)務(wù)設(shè)計(jì)上需要使用到ePQ，那么可以將業(yè)務(wù)中的分析型SQL提取出來，使用一個(gè)特定的數(shù)據(jù)庫來進(jìn)行ePQ查詢：

ALTER DATABASE ap_database SET polar_enable_px = ON;

或使用某個(gè)特定的賬戶，專門用來執(zhí)行分析型的SQL：

ALTER ROLE ap_role SET polar_enable_px = ON;

查詢級別

如果只想對一個(gè)會(huì)話內(nèi)的某幾條特定查詢（例如，夜間報(bào)表業(yè)務(wù)）使用ePQ，可以借助pg_hint_plan插件，通過SQL Hint對特定查詢啟用ePQ。為使SQL Hint生效，需要確保pg_hint_plan插件已經(jīng)被添加到GUC參數(shù)shared_preload_libraries中。

在查詢前添加/*+ PX() */表示對該查詢使用ePQ：

=> /*+ PX() */ EXPLAIN SELECT * FROM t1;
                                    QUERY PLAN
----------------------------------------------------------------------------------
 PX Coordinator 6:1  (slice1; segments: 6)  (cost=0.00..431.03 rows=1000 width=8)
   ->  Partial Seq Scan on t1  (cost=0.00..431.00 rows=167 width=8)
 Optimizer: PolarDB PX Optimizer
(3 rows)

在查詢前添加/*+ NoPX() */表示對該查詢不使用ePQ：

=> /*+ NoPX() */ EXPLAIN SELECT * FROM t1;
                      QUERY PLAN
------------------------------------------------------
 Seq Scan on t1  (cost=0.00..15.00 rows=1000 width=8)
(1 row)

在查詢前添加/*+ PX(N) */表示以N作為單節(jié)點(diǎn)并行度使用ePQ。例如，N取值為6：

=> /*+ PX(6) */ EXPLAIN SELECT * FROM t1;
                                     QUERY PLAN
------------------------------------------------------------------------------------
 PX Coordinator 12:1  (slice1; segments: 12)  (cost=0.00..431.02 rows=1000 width=8)
   ->  Partial Seq Scan on t1  (cost=0.00..431.00 rows=84 width=8)
 Optimizer: PolarDB PX Optimizer
(3 rows)