PostgreSQL异步复制架构下，如何轻松对同步从库执行SELECT查询？

以下是几种适配同步从库动态变化场景的可行方案：

1. 基于系统视图的动态路由（应用/中间件层实现） #

PostgreSQL内置的pg_stat_replication系统视图会实时记录复制节点的状态，可通过它快速定位当前的同步从库：

SELECT client_addr, client_port
FROM pg_stat_replication
WHERE sync_state = 'sync';

在应用代码或连接池中间件中，定期执行上述查询获取同步从库的地址和端口，将SELECT请求动态路由到该节点。比如在Java应用中可封装工具方法动态切换数据源；若使用PgBouncer，可通过脚本定期更新其配置的后端节点。

2. 利用dblink在主库代理查询 #

如果不想在应用层做路由逻辑，可在主库通过dblink扩展直接代理查询同步从库：

1. 先安装dblink扩展：

   CREATE EXTENSION IF NOT EXISTS dblink;
   

2. 创建PL/pgSQL函数自动识别同步从库并执行查询：

   CREATE OR REPLACE FUNCTION query_sync_standby(p_query text, p_result_schema text)
   RETURNS SETOF record AS $$
   DECLARE
       v_conn_str text;
   BEGIN
       -- 获取同步从库的连接字符串
       SELECT format('host=%s port=%s dbname=%s user=%s',
                     client_addr, client_port, current_database(), current_user)
       INTO v_conn_str
       FROM pg_stat_replication
       WHERE sync_state = 'sync'
       LIMIT 1;
   
       IF v_conn_str IS NULL THEN
           RAISE EXCEPTION '未找到同步状态的从库节点';
       END IF;
   
       -- 执行查询并返回结果
       RETURN QUERY EXECUTE format(
           'SELECT * FROM dblink(%L, %L) AS t(%s)',
           v_conn_str, p_query, p_result_schema
       );
   END;
   $$ LANGUAGE plpgsql;
   

3. 使用示例（需指定查询结果的列结构）：

   SELECT * FROM query_sync_standby(
       'SELECT id, name FROM users',
       'id int, name varchar'
   );
   

3. 借助高可用工具的自动路由能力 #

如果集群使用Patroni、Repmgr等高可用管理工具，这类工具通常配套支持动态路由的组件：

• Patroni可结合HAProxy或PgBouncer，配置规则将读请求自动转发到当前的同步从库；
• Repmgr可通过自身的节点状态维护能力，配合自定义脚本实现动态路由。

内容的提问来源于stack exchange，提问作者Kevin Meredith