PolarDB：分布式列存索引

水平分割（Sharding by tenant_id）

假設存在業務表orders，並以tenant_id作為分區鍵。

• 單租戶資訊彙總：統計某一租戶的本地訂單總金額與平均金額。

  SELECT SUM(amount) AS total_amount, AVG(amount) AS avg_amount
  FROM orders
  WHERE tenant_id = 1001;

• 全域租戶資訊統計：統計所有租戶的訂單總金額與平均金額，按租戶分組。

  SELECT tenant_id, SUM(amount) AS total_amount, AVG(amount) AS avg_amount
  FROM orders
  GROUP BY tenant_id;

垂直分割（Sharding by schema）

假設每個租戶的資料分布在單獨的Schema中，表名同為orders。

• 單個Schema資訊彙總：針對某個Schema的訂單總金額與平均金額彙總。

  SELECT SUM(amount) AS total_amount, AVG(amount) AS avg_amount
  FROM tenant_a.orders;

• 全域租戶資訊統計：匯總所有租戶的訂單總金額與平均金額，通過UNION ALL實現。

  SELECT 'tenant_a' AS tenant, SUM(amount) AS total_amount, AVG(amount) AS avg_amount FROM tenant_a.orders
  UNION ALL
  SELECT 'tenant_b' AS tenant, SUM(amount) AS total_amount, AVG(amount) AS avg_amount FROM tenant_b.orders;

步驟一：開啟分布式IMCI功能

您可以在PolarDB控制台或在資料庫會話中進行修改：

SET polar_cluster_enable_imci = on;
SET polar_csi.enable_anyall_to_in = on;
SET pg_hint_plan.polar_enable_distributed_hint = on;

步驟二：建立行列同步複製槽

用高許可權賬戶在主CN上執行以下命令，為所有節點建立行列同步複製槽：

SELECT run_command_on_all_nodes($$ SELECT polar_csi_start_sync() $$);

步驟三：建立並分區租戶表

-- 建立初始業務表（以 tenant_id 作為主鍵一部分）
CREATE TABLE orders (
  order_id   bigint,
  tenant_id  int NOT NULL,
  amount     numeric(20,2),
  status     text,
  create_time timestamp,
  PRIMARY KEY (tenant_id, order_id)
);

-- 轉為分布式分區表
SELECT create_distributed_table('orders', 'tenant_id');

-- 建立租戶 schema
CREATE SCHEMA tenant1;

-- 轉為分布式管理
SELECT polar_cluster_schema_distribute('tenant1');

-- 建立業務表
SET search_path TO tenant1;

CREATE TABLE orders (
  order_id   bigint,
  tenant_id  int NOT NULL,
  amount     numeric(20,2),
  status     text,
  create_time timestamp,
  PRIMARY KEY (tenant_id, order_id)
);

步驟四：建立列存索引

為表建立CSI列存索引：

-- 對所有列建立列存索引
CREATE INDEX csi_orders ON orders USING CSI;

-- 僅對部分列建立列存索引（如僅查詢 tenant_id, amount）
CREATE INDEX csi_orders_part ON orders1 USING CSI(tenant_id, order_id, amount);

-- 支援不鎖表建立列存索引（推薦）
CREATE INDEX CONCURRENTLY csi_orders ON orders USING CSI;

步驟五：使用列存索引執行查詢

有兩個參數控制是否執行列存查詢：

推薦通過HINT控制某次查詢強制使用列存索引：

/*+SET (polar_csi.enable_query on) SET(polar_csi.cost_threshold 0)*/
SELECT tenant_id, SUM(amount) AS total_amount, AVG(amount) AS avg_amount
FROM orders
GROUP BY tenant_id;

也可以全域或按帳號設定參數。全域設定參數需要在控制台修改，按帳號設定參數需要在主CN上執行以下語句：

-- 以 test 使用者優先啟用列存索引
ALTER ROLE test SET polar_csi.enable_query = ON;
ALTER ROLE test SET polar_csi.cost_threshold = 0;

步驟六：確認查詢是否使用列存索引

可用EXPLAIN分析，若計劃中出現CSI Executor字樣說明已成功使用列存索引：

/*+SET (polar_csi.enable_query on) SET(polar_csi.cost_threshold 0)*/
EXPLAIN (COSTS OFF) SELECT tenant_id, SUM(amount) AS total_amount, AVG(amount) AS avg_amount
FROM orders
GROUP BY tenant_id;

樣本輸出片段（含有CSI Executor說明使用了列存查詢）：

                       QUERY PLAN
---------------------------------------------------------
 Custom Scan (PolarCluster Adaptive)
   Task Count: 32
   Tasks Shown: One of 32
   ->  Task
         Node: host=127.0.0.1 port=45719 dbname=postgres
         ->  CSI Executor:
             ┌───────────────────────────┐
             │       HASH_GROUP_BY       │
             │    ────────────────────   │
             │        Aggregates:        │
             │          sum(#1)          │
             │          avg(#2)          │
             └─────────────┬─────────────┘
             ┌─────────────┴─────────────┐
             │         SEQ_SCAN          │
             │    ────────────────────   │
             │    Table: orders_102008   │
             │   Type: Sequential Scan   │
             └───────────────────────────┘