Node.js对接BigQuery通过请求对象实现数据表更新的方法咨询

你需要先在请求体中补充用于匹配旧记录的oldName字段，之后通过BigQuery客户端的参数化查询能力执行更新操作即可，完整实现如下：

1. 补充请求体字段 #

var reqBody = {
  "oldName": "testing_old", // 需替换为你要更新的原有记录的Name值
  "Name":"testing11",
  "columns":[
    {
      "fieldExistsIn":"BOTH",
      "columnWidth":5,
      "hide":false
    },
    {
      "fieldExistsIn":"BOTH",
      "columnWidth":10,
      "hide":false
    }
  ],
  "Range":{
    "startDate":"20-Oct-2022",
    "endDate":"26-Oct-2022"
  }
}

2. 实现更新操作代码 #

// 构造参数化更新SQL，规避SQL注入风险
const updateQuery = `
  UPDATE \`${datasetId}.${tableId}\`
  SET requestData = @newRequestData
  WHERE requestData.Name = @oldName
`;

// 配置查询参数
const options = {
  query: updateQuery,
  params: {
    newRequestData: reqBody,
    oldName: reqBody.oldName
  },
  location: 'US', // 替换为你的数据集实际部署的区域，例如亚太区域可填 asia-southeast1
};

// 执行更新操作
async function runUpdate() {
  try {
    // 方式1：直接执行，客户端自动等待作业完成
    await bigquery.query(options);
    console.log('记录更新成功');

    // 方式2：如需追踪作业ID，可手动创建作业
    // const [job] = await bigquery.createQueryJob(options);
    // console.log(`更新作业ID：${job.id}`);
    // await job.getQueryResults();
  } catch (err) {
    console.error('更新执行失败：', err);
  }
}

// 调用执行
await runUpdate();

注意事项 #

• 确保你的服务账号具备对应数据表的UPDATE权限以及BigQuery作业创建权限
• BigQuery客户端会自动将JS对象映射为表结构中requestData对应的RECORD类型值，无需额外序列化处理
• 若更新涉及大量数据，建议在WHERE条件中加入分区、集群字段过滤，大幅提升执行效率

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