无pg_dump和psql权限时如何以编程方式备份恢复PostgreSQL

可用的TypeScript NPM库方案 #

目前没有完全封装pg_dump能力的开箱即用npm包，但可以基于PostgreSQL官方生态库结合自定义逻辑实现完整的备份恢复能力：

• 核心依赖使用pg库，TypeScript项目可额外安装@types/pg获取类型定义，只要两个Pod在同一K8s集群下、PostgreSQL侧开放了5432端口的Service，就可以通过域名远程连接数据库。
• 全量备份逻辑：通过pg客户端查询information_schema、pg_index、pg_constraint、pg_trigger等系统表，获取表结构、索引、约束、触发器等元数据定义，再逐表执行SELECT * FROM 表名拉取数据，拼接为标准SQL插入语句落盘存储即可。如果需要流式处理大表数据，可以搭配pg-copy-streams库避免内存溢出。
• 增量备份逻辑：可通过pg客户端创建逻辑复制槽，搭配pg-logical-parser库解析WAL日志的增量变更，落盘为增量备份文件。
• 恢复逻辑：直接调用pg客户端的query方法按顺序执行备份的SQL语句即可，大批次数据可以用流式导入提升效率。

示例代码参考：

import { Client } from 'pg';
import * as fs from 'fs';

// 连接参数填PostgreSQL的K8s内部Service域名即可
const pgClient = new Client({
  host: 'postgresql-svc.default.svc.cluster.local',
  port: 5432,
  user: '数据库用户名',
  password: '数据库密码',
  database: '目标库名'
});

async function backupSingleTable(tableName: string, outputPath: string) {
  await pgClient.connect();
  // 导出表结构定义
  const schemaRes = await pgClient.query(`SELECT pg_get_tabledef($1)`, [tableName]);
  const createTableSql = schemaRes.rows[0].pg_get_tabledef + ';\n\n';
  // 导出表数据拼接为INSERT语句
  const dataRes = await pgClient.query(`SELECT * FROM ${tableName}`);
  const insertSqlList = dataRes.rows.map(row => {
    const values = Object.values(row).map(val => {
      if (typeof val === 'string') return `'${val.replace(/'/g, "''")}'`;
      if (val === null || val === undefined) return 'NULL';
      return val;
    }).join(', ');
    return `INSERT INTO ${tableName} VALUES (${values});`;
  }).join('\n');
  // 落盘存储
  fs.writeFileSync(outputPath, createTableSql + insertSqlList);
  await pgClient.end();
}

// 调用示例：备份user表到本地文件
backupSingleTable('user', './backup_user.sql');

通用SQL脚本备份恢复方案 #

完全不依赖外部工具，纯SQL即可实现备份恢复：

• 备份SQL语句：

  导出指定Schema下所有表结构：SELECT pg_get_tabledef(tablename) FROM pg_tables WHERE schemaname = 'public';
  导出所有约束、索引定义：SELECT pg_get_constraintdef(oid) FROM pg_constraint WHERE connamespace = 'public'::regnamespace;
  导出所有序列当前值：SELECT sequence_name, last_value FROM information_schema.sequences WHERE sequence_schema = 'public';
  逐表生成INSERT语句可使用动态SQL：SELECT 'INSERT INTO ' || table_name || ' VALUES (' || array_to_string(array_agg(quote_literal(column_value)), ',') || ');' FROM 目标表名

• 恢复逻辑：按「建表→建约束索引→插入数据→重置序列值」的顺序执行备份好的SQL即可，避免外键报错和序列值冲突。
• 注意：如果单库容量超过10G，不建议使用纯SQL方案，内存占用和执行效率会明显下降，更建议调整K8s RBAC权限，让执行器Pod调用K8s API直接在PostgreSQL Pod内执行pg_dump命令，性能和兼容性更好。

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