如何实现从PostgreSQL数据库自动同步数据至Google Sheet并设置定时任务

一、JDBC 对接常见问题排查 #

先针对你之前对接失败的问题，优先排查以下常见配置错误：

• 驱动版本校验：必须使用和PostgreSQL服务端大版本匹配的postgresql-jdbc驱动包，比如PG14及以上版本需要对应42.5.x以上版本驱动，避免版本不兼容报错
• 网络权限校验：
  • 若PostgreSQL为公网部署，确认pg_hba.conf已经放通了对接服务的公网IP，默认5432端口没有被防火墙拦截
  • 若使用Google生态工具对接，需要放通Google服务器IP段，不要限制仅本地IP访问
• 连接配置校验：
  • JDBC连接字符串必须符合规范：jdbc:postgresql://<PG主机地址>:<端口>/<数据库名>?currentSchema=<你的模式名,默认public>，大量对接失败都是因为漏写schema参数，默认访问到非目标schema找不到表
  • 用户名密码中的特殊符号（&、?等）需要做URL编码后再放入连接串
  • 建议追加超时参数connectTimeout=30000&socketTimeout=60000，避免网络波动导致连接中断

二、全流程实现方案（含每小时定时调度） #

推荐使用Google App Script实现，无需额外搭建服务器，原生支持JDBC连接、Google Sheet操作和定时触发器，成本最低：

步骤1：打开脚本编辑器 #

打开目标Google Sheet，点击顶部菜单「扩展程序」->「Apps 脚本」进入编辑器

步骤2：编写同步代码 #

以下是可直接复用的核心代码，替换配置项即可使用：

// 自定义配置项，替换为你自己的实际信息
const PG_CONFIG = {
  host: '你的PG主机地址',
  port: 5432,
  db: '数据库名',
  user: '用户名',
  password: '密码',
  schema: 'public',
  targetTable: '要同步的表名',
  targetSheetName: 'Google Sheet中要写入的工作表名称'
}

function syncPGToSheet() {
  // 构建JDBC连接串
  const connStr = `jdbc:postgresql://${PG_CONFIG.host}:${PG_CONFIG.port}/${PG_CONFIG.db}?currentSchema=${PG_CONFIG.schema}&connectTimeout=30000&socketTimeout=60000`
  let conn = null
  try {
    // 建立数据库连接
    conn = Jdbc.getConnection(connStr, PG_CONFIG.user, PG_CONFIG.password)
    // 自定义查询语句，增量同步可自行加WHERE条件过滤
    const stmt = conn.createStatement()
    const rs = stmt.executeQuery(`SELECT * FROM ${PG_CONFIG.targetTable}`)
    
    // 获取目标工作表
    const sheet = SpreadsheetApp.getActiveSpreadsheet().getSheetByName(PG_CONFIG.targetSheetName)
    // 清空原有历史数据，不需要可注释该行
    sheet.clearContents()
    
    // 写入表头
    const metaData = rs.getMetaData()
    const colCount = metaData.getColumnCount()
    const headers = []
    for (let i = 1; i <= colCount; i++) {
      headers.push(metaData.getColumnName(i))
    }
    sheet.getRange(1, 1, 1, colCount).setValues([headers])
    
    // 写入数据行
    const rows = []
    while (rs.next()) {
      const row = []
      for (let i = 1; i <= colCount; i++) {
        row.push(rs.getObject(i))
      }
      rows.push(row)
    }
    if (rows.length > 0) {
      sheet.getRange(2, 1, rows.length, colCount).setValues(rows)
    }
    
    // 释放资源
    rs.close()
    stmt.close()
  } catch (e) {
    console.error('同步失败：', e.message, e.stack)
    throw e
  } finally {
    if (conn) {
      conn.close()
    }
  }
}

• 代码写完后先点击运行按钮测试一次，授权所需权限，确认数据正常写入Sheet即可
• 如需增量同步，可将上次同步时间存在Script Properties中，查询时追加WHERE update_time > 上次同步时间的过滤条件即可

步骤3：配置每小时定时触发器 #

• 在App Script编辑器左侧点击「触发器」菜单（闹钟图标）
• 点击右下角「添加触发器」
• 选择要运行的函数为syncPGToSheet
• 事件源选择「时间驱动」
• 触发器类型选择「小时计时器」
• 时间间隔选择「每1小时」
• 保存后系统会自动每小时执行一次同步任务

三、优化建议 #

• 数据量超过10万行时建议分批查询写入，避免触发App Script单次运行6分钟的上限
• 敏感配置不要明文写在代码中，可通过PropertiesService.getScriptProperties()存储读取
• 可自行添加告警逻辑，同步失败时自动发邮件通知负责人

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