关于Citus的10个为什么

Whoami：5年+金融、政府、医疗领域工作经验的DBA
Certificate：PGCM、OCP、YCP
Skill：Oracle、Mysql、PostgreSQL、国产数据库
Platform：CSDN、墨天轮、公众号（呆呆的私房菜）

-- 添加新 Worker 节点（假设新节点 IP 为 10.0.0.4，端口 5432）
SELECT master_add_node('10.0.0.4', 5432);
-- 查看所有 Worker 节点
SELECT * FROM master_get_active_worker_nodes();
-- 检查节点元数据
SELECT * FROM pg_dist_node;


-- 设置分片迁移阈值（默认 0.5，即节点间负载差异超过 50% 时触发迁移）
SET citus.shard_rebalancer.log_verbose = on;
-- 对所有表执行分片再平衡
SELECT rebalance_table_shards();
-- 或针对特定表（如 orders）
SELECT rebalance_table_shards('orders');


-- 查看正在迁移的分片
SELECT * FROM citus_shard_moves;
-- 查看历史任务
SELECT * FROM citus_move_shard_placement_events;


-- 查看所有分片的位置和大小
SELECT 
    shardid, 
    nodename, 
    nodeport,
    pg_size_pretty(shard_size) AS size 
FROM citus_shards 
WHERE table_name = 'orders'::regclass;

常规限制：
1. 不支持rule system；
2. 不支持INSERT INTO...SELECT；
3. 不支持多级分区表；
4. update查询中涉及的函数不能声明为volatile；
5. update查询使用stable函数要注意参数不能直接引用表的列；
6. 不支持对视图进行修改操作。


跨节点查询：
1. 仅支持单分片执行 select ... for update 查询；
2. 仅支持单分片执行 tablesample 查询；
3. 相关子查询仅支持基于分布列的关联；
4. 分布式表外连接仅支持分布列；
5. 递归CTE仅支持单分片查询；
6. 分组集仅支持单分片查询；
7. 仅常规表、外部分区表或分区表可被分布
8. merge 命令如下表类型的组合

基于schema的分片
1. 分布式schema之间不支持外键；
2. 分布式schema之间的join受跨节点查询限制；
3. 无法通过单条SQL创建分布式schema和table

-- citus提供了一个在所有工作节点上执行查询的函数
SELECT run_command_on_workers($cmd$
  /* the command to run */
  CREATE ROLE ...
$cmd$);

-- update worker node metadata on the coordinator
-- (remember to replace 'old-address' and 'new-address'
--  with the actual values for your situation)
select citus_update_node(nodeid, 'new-address', nodeport)
  from pg_dist_node
 where nodename = 'old-address';