使用 PostgreSQL 16.1 + Citus 12.1 作为多个微服务的分布式 Sharding 存储后端

-- 假设我们有一个用户表，需要根据用户的 ID 进行分片
 
-- 创建分布式表
CREATE TABLE distributed_users (
    user_id UUID PRIMARY KEY,
    username TEXT,
    email TEXT
) DISTRIBUTED BY (user_id);
 
-- 创建本地表，用于存储用户的密码信息
CREATE TABLE users_passwords (
    user_id UUID PRIMARY KEY,
    password TEXT
);
 
-- 将本地表与分布式表关联
ALTER TABLE users_passwords SET SCHEMA public;
 
-- 将本地表与分布式表关联
ALTER TABLE distributed_users ADD CHECK (user_id = replica_identity);
 
-- 将本地表与分布式表关联
INSERT INTO distributed_users (user_id, username, email)
SELECT user_id, username, email FROM users_passwords;
 
-- 查询分布式表，将自动路由到正确的分片
SELECT * FROM distributed_users WHERE user_id = '特定用户ID';

这个例子展示了如何在 PostgreSQL + Citus 环境中创建分布式表，并且如何将本地表与分布式表进行关联，以便在查询时能够自动路由到正确的分片。这是构建基于 PostgreSQL 和 Citus 的分布式数据库系统的一个基本示例。