分布式列存索引

水平拆分（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   │
             └───────────────────────────┘