步驟一：設置WAL日志等級

在使用一站式HTAP功能前，請先設置wal_level參數為logical，否則無法在OLTP和OLAP引擎之間同步數據。

步驟二：增加分析節點

在使用一站式HTAP功能前，需要為PolarDB集群添加至少兩個分析節點。分析集群的計算能力將隨著分析節點數量的增加線性提升。

1. 登錄PolarDB控制臺。

2. 在控制臺左上角，選擇集群所在地域。

3. 您可以按照如下兩種方式進入增刪節點向導頁面。

   • 找到目標集群，在操作列單擊增刪節點。

   • 找到目標集群，單擊集群ID，進入基本信息頁面，在數據庫節點區域單擊增刪節點。

4. 選中增加分析節點并單擊確定。

   

5. 選擇分析節點規格，并設置分析節點數量。

   說明

   • 分析節點的規格無需與主節點規格保持一致，但分析節點之間其規格需要保持一致。例如，若您已添加2個4C16G的分析節點，若還需添加分析節點，其規格必須為4C16G。

   • 您無需選擇其存儲空間大小，將根據具體數據的存儲用量進行自動擴縮容。

6. 勾選服務協議，單擊立即購買。

7. 在支付頁面確認訂單信息，單擊支付。

步驟三：開啟HTAP功能

在連接到數據庫集群后，使用高權限用戶執行以下命令，創建polar_htap_db插件。

CREATE EXTENSION IF NOT EXISTS polar_htap_db;

該插件會提供三個函數，分別用于打開、查詢、關閉當前數據庫的HTAP功能。

開啟HTAP功能

執行以下命令，使用polar_htap_db.enable_htap()函數開啟當前數據庫的HTAP功能。

SELECT polar_htap_db.enable_htap();

該函數會使當前數據庫的HTAP狀態從初始的disable狀態變為init狀態：

 enable_htap
-------------

(1 row)

查詢HTAP狀態

后臺服務會自動響應當前數據庫開啟HTAP功能的請求，在OLAP引擎上建立相同的數據庫，并拉起一個空的同步鏈路，然后修改HTAP狀態。當HTAP狀態變為ready時，表示當前數據庫的HTAP功能已經開啟完畢，HTAP功能可以正常使用。

執行以下命令，使用polar_htap_db.get_htap_status()函數查看當前數據庫的HTAP狀態。

SELECT polar_htap_db.get_htap_status();

顯示結果如下：

 get_htap_status
-----------------
 ready
(1 row)

（可選）關閉HTAP功能

執行以下命令，使用polar_htap_db.disable_htap()函數關閉當前數據庫的HTAP功能。

SELECT polar_htap_db.disable_htap();

該函數會使當前數據庫的HTAP狀態變為cleanup，后臺服務將會自動響應，對當前數據庫在OLAP引擎上的數據副本和內置同步鏈路進行清理。清理完畢后，當前數據庫的HTAP狀態會恢復為disable：

 disable_htap
--------------

(1 row)

步驟四：創建HTAP表

創建HTAP表

在數據庫的HTAP狀態為ready后，您可以自行選擇將這個數據庫中的一部分表遷移同步到OLAP引擎上，以便后續進行分析查詢。

執行以下命令，開啟一張表的HTAP功能。

ALTER TABLE table1 SET (polar_htap=true);

在執行完上述命令后，內置同步鏈路會自動把這張表的全量數據遷移轉換到OLAP引擎上，并自動同步對該表的后續增量修改。

查詢HTAP表狀態

執行以下命令，查詢當前數據庫中所有的HTAP表，以及它們各自的同步狀態。

SELECT * FROM polar_htap.htap_tables;

顯示結果如下：

  oid  | relschema | relname  | relkind | dist_policy | dist_cols | sync_timeout | sync_status |        sync_start_time        |         sync_end_time         |  sync_duration  | synced_tuples | total_tuples | sync_percentage | table_size
-------+-----------+----------+---------+-------------+-----------+--------------+-------------+-------------------------------+-------------------------------+-----------------+---------------+--------------+-----------------+-------------
 17572 | public    | table1   | r       | p           | 1         |            0 | sync        | 2023-07-18 14:07:57.738061+00 | 2023-07-18 14:09:22.472374+00 | 00:01:24.734313 |             0 |        1e+06 |             100 |    37789696
 17305 | public    | lineitem | r       | p           | 1 4       |            0 | loading     | 2023-07-19 06:11:18.557619+00 |                               |                 |     600037902 |  5.99977e+08 |             100 | 92224692224
(2 row)

各列含義如下：

• oid：表 OID

• relschema：表所屬 schema 的名稱

• relname：表名

• relkind：表類型

• dist_policy/dist_cols：表在 OLAP 引擎上的分布模式和分布列

• sync_status：表數據的同步狀態

• sync_start_time：表數據同步的開始時間

• sync_end_time：表數據同步的結束時間

• sync_duration：表數據同步的持續時間

• synced_tuples：表中已被同步的元組數量

• total_tuples：表中的元組總量（估算值）

• sync_percentage：表的數據同步進度百分比

• table_size：表大小

當table1表數據的同步狀態sync_status變為sync時，表示這張表在OLAP引擎上的數據已經與OLTP存儲引擎一致，具備進行HTAP查詢的前提。

（可選）刪除HTAP表

執行以下命令，刪除HTAP表。

ALTER TABLE table1 RESET (polar_htap);

上述命令執行完成后，該表在OLAP引擎上的副本會被完全移除。后續如果將這張表重新設置為HTAP表，需要重新進行全量數據的同步。

步驟五：開啟HTAP查詢

當查詢中引用的所有表全都是HTAP表，且這些HTAP表的同步狀態都為sync后（可通過查詢HTAP表狀態查看所有HTAP表的同步狀態），即可開啟HTAP查詢。

ALTER DATABASE xxx SET polar_htap.enable_htap_query = ON;

ALTER ROLE xxx SET polar_htap.enable_htap_query = ON;

SET polar_htap.enable_htap_query = ON;

SELECT * FROM table1;

NOTICE: Query is under HTAP execution...

（可選）關閉HTAP查詢

執行以下命令，關閉HTAP查詢。

SET polar_htap.enable_htap_query = OFF;

步驟六：設置查詢一致性

在的一站式HTAP服務中，OLTP引擎（PolarDB）和OLAP引擎上分別保存了一份數據，兩份數據的一致性受到內置同步鏈路延遲的影響。

提供了數據查詢一致性的設置方法，您可通過polar_htap.forward_replay_wait和polar_htap.forward_replay_wait_lsn_diff參數對兩份數據的一致性進行把控：

1. 若您對兩份數據的一致性有強一致的需求：

   在進行HTAP查詢時，PolarDB默認啟用了polar_htap.forward_replay_wait參數，以及polar_htap.forward_replay_wait_lsn_diff參數默認取值為0。此時只有當OLAP引擎已經回放到當前查詢的LSN位點時，才會將查詢路由到OLAP引擎上執行，從而保證查詢結果的強一致性。

   此時您只需要保持這兩個參數的默認設置，即可達到強一致的目的。

2. 若能夠容忍在一段時間范圍以內的不一致性，則可在polar_htap.forward_replay_wait參數為開啟狀態下，設置polar_htap.forward_replay_wait_lsn_diff參數，指定OLTP引擎與OLAP引擎之間可以進行查詢路由的最大LSN位點差距：

   • 當OLAP引擎與OLTP引擎的LSN位點小于該差距時，查詢將會被立刻路由到OLAP引擎上執行；

   • 否則，將會等待OLAP引擎回放到小于這個位點差距后，再進行查詢路由。

   => SET polar_htap.forward_replay_wait = ON;
   => SET polar_htap.forward_replay_wait_lsn_diff = 8192;
   => SELECT * FROM test_2;
   NOTICE: Query is under HTAP execution...
   ...

3. 若無需保證查詢結果的強一致性，則可以關閉polar_htap.forward_replay_wait參數，使當前會話中執行HTAP查詢時無需等待OLAP引擎的回放進度，立刻將查詢路由到OLAP引擎：

   => SET polar_htap.forward_replay_wait = OFF;
   => SELECT * FROM test_2;
   NOTICE: Query is under HTAP execution...
   ...
   

步驟七：查看增量同步狀態

通過查詢以下視圖可以查詢到同步鏈路的增量同步狀態。

SELECT * FROM polar_htap.htap_replication_status;
-[ RECORD 1 ]-------+------------------------------------------------
slot_name           | dts_sync_i2a1165s14xy091
active              | t
wal_status          | reserved
restart_lsn         | 0/BFB096F8
confirmed_flush_lsn | 0/BFC48C88
current_insert_lsn  | 1/DD220A8
apply_lsn           | 0/C74711D8
apply_latency_size  | 1129 MB
apply_latency_time  | 00:00:27.393406
sync_update_time    | 2023-11-17 07:25:58.319876+00
sync_status         | {"last_commit_time": "2023-11-17 15:25:31+08"}

視圖各列含義如下表所示：