BigQuery NodeJS:删除行/DML支持

const { BigQuery } = require('@google-cloud/bigquery');

async function deleteRows() {
  const bigquery = new BigQuery();

  const query = `
    DELETE FROM dataset.users
    WHERE age > 30
  `;

  const options = {
    query: query,
    location: 'US', // 设置查询的位置
  };

  // 执行删除操作
  const [job] = await bigquery.createQueryJob(options);
  const [result] = await job.getQueryResults();

  console.log(`Deleted ${result.numDmlAffectedRows} rows.`);
}

deleteRows();

const { BigQuery } = require('@google-cloud/bigquery');

async function executeDML() {
  const bigquery = new BigQuery();

  const query = `
    INSERT INTO dataset.users (name, age)
    VALUES ('John', 35)
  `;

  const options = {
    query: query,
    location: 'US', // 设置查询的位置
  };

  // 执行插入操作
  const [job] = await bigquery.createQueryJob(options);
  const [result] = await job.getQueryResults();

  console.log(`Inserted ${result.numDmlAffectedRows} rows.`);
}

executeDML();