PolarDB：開啟和使用列存索引

對於不同的PolarDB PostgreSQL版核心版本，開啟列存索引的方式不同：

CREATE EXTENSION polar_csi;

1. 為指定列或所有列建立列存索引

-- 為部分列建立索引
CREATE INDEX [ CONCURRENTLY ] csi_index_name ON table_name USING CSI(column1,column2,...);
-- 為所有列建立索引
CREATE INDEX [ CONCURRENTLY ] csi_index_name ON table_name USING CSI;

2. 查看索引建立進度

為資料量較大的表建立列存索引可能耗時較長，可通過以下方式查看索引建立的進度。同時，您可以調整相關參數以提升索引建立的速度。

SELECT * FROM pg_stat_progress_create_index;

3. （可選）取消索引建立

當建立索引耗時較長，且建立索引的進程對現有業務產生了影響，您可通過pg_cancel_backend或pg_terminate_backend取消索引的建立，函數中需要的pid可通過2. 查看索引建立進度擷取。

SELECT pg_cancel_backend(pid);

SELECT pg_terminate_backend(pid);

4. 查看索引大小

可以使用pg_relation_size函數查看索引大小，並結合pg_size_pretty函數以更友好的方式進行顯示。

SELECT * FROM pg_size_pretty(pg_relation_size('csi_index_name'));

例如，查看之前建立的列存索引佔用的儲存空間大小。

SELECT * FROM pg_size_pretty(pg_relation_size('idx_csi_sales'));

5. （可選）列存索引資料即時性

PolarDB PostgreSQL版叢集不僅支援對歷史資料建立列存索引，還能夠自動將行存表中的新資料同步至列存索引。當使用CREATE INDEX語句為表建立列存索引後，之後新增的資料將即時寫入列存索引，且無需對該過程進行額外操作。

列存索引通過PolarDB PostgreSQL版的邏輯複製機制實現資料同步，需對WAL日誌進行解碼並將其同步至列存引擎，在預設配置下，該機制能夠承載約20萬QPS的寫入壓力（基於Sysbench oltp_insert標準測試）。

• 查詢當前資料同步延遲

  SELECT active_pid, database, slot_name, pg_size_pretty(pg_current_wal_lsn() - confirmed_flush_lsn) AS size FROM pg_replication_slots WHERE slot_name LIKE 'csi_sync_%';

  當size維持在50 MB以內時，列存資料可在秒級實現同步重新整理。

• 提高資料同步效率

  為滿足某些業務情境下的行列資料即時性的要求，您可以通過調整參數polar_csi.update_interval和polar_csi.update_batch_count來提升列存索引的即時性。

1. 配置參數

在建立完列存索引後，可以通過如下參數來控制SQL查詢語句是否使用列存索引。

SET polar_csi.enable_query = on;

SET polar_csi.cost_threshold = 0;

2. 配置參數生效範圍

SET polar_csi.enable_query = ON;

3. 查看SQL是否使用列存索引

通過Explain或Explain Analyze等工具列印查詢計劃，出現CSI Executor關鍵詞時即表示該查詢已經使用列存索引。

EXPLAIN SELECT COUNT(*) FROM sales;

返回結果如下：

  QUERY PLAN  
--------------
 CSI Executor
(1 row)

4. （可選）配置列存索引資料查詢一致性

PolarDB PostgreSQL版列存索引支援兩種查詢一致性層級，以滿足不同業務需求。

• 最終一致性（預設）：適用於寫入負載高，但對資料即時性要求低的查詢。

• 強一致性：在列存資料與行存資料完全一致後再返回查詢結果。

PolarDB PostgreSQL版的列存索引即時性可以達到秒級，但當寫入負載過大時，列存索引的資料延遲會升高。預設的一致性層級為最終一致性，所以當寫入負載過大，且SQL查詢使用列存索引時，可能無法查出最新的資料。

為滿足某些業務情境下的行列強一致性要求，您可以通過將參數polar_csi.forward_replay_wait調整為強一致性讀（on）來實現。當查詢時，系統會等待列存索引的資料與行存資料一致時才會執行。

提升索引建立速度

索引建立速度與多個參數有關，如下所示：

提升列存索引的即時性

通過調整這些參數，您可以提高行列轉換的速度，從而提升列存索引資料的即時性。

提升查詢速度

查詢效能主要與以下參數有關，可通過調整參數值提升查詢效能：