Bigquery PHP使用insert-select作业填充表 - Bigquery PHP populate table with insert select job

Bigquery PHP populate table with insert select job

我正试图用PHP中的insert-select作业填充以前创建的表。谷歌文档中有一小段话说下一个：

"运行异步查询，传入现有表的名称，并设置writeDisposition=WRITE_APPEND。"

现在我使用下面的句子从bigquery中获取行：

      // query request service
      $query = new Google_Service_Bigquery_QueryRequest();
      //armar query
      $selectQuery = "select source_year, year, month, day from publicdata:samples.natality LIMIT 100";
      if($whereQuery!=null && strlen($whereQuery)>0)$selectQuery = $selectQuery . " WHERE " . $whereQuery;
      //print_r(var_dump($selectQuery));
      $query->setQuery($selectQuery);
      $response = $service->jobs->query($project_id, $query);
      $jsonStr = "";
      if($response)if($response->getRows())$jsonStr = $response->getRows();
      print_r($jsonStr);

但是我需要从查询结果中填充另一个表。谢谢你的建议。再见

感谢Pentium10，但我收到错误消息"调用未定义的方法Google_Service_Bigquery_QueryRequest:：setDestinationTable（）"，因为我没有使用作业来执行查询。

我使用下面的句子来获得查询结果，但它不起作用：

  //query request service
  $query = new Google_Service_Bigquery_QueryRequest();
  //destination table
  $destinationTable = new Google_Service_Bigquery_TableReference();
  $destinationTable->setDatasetId($dataset);
  $destinationTable->setProjectId($project_id);
  $destinationTable->setTableId('ventastest');
  $query->setDestinationTable($destinationTable);
  $query->setWriteDisposition('WRITE_APPEND');
  //build query
  $selectQuery = "SELECT " . $fieldsQuery . " FROM " . $dataset . "." . $tableQuery;
  if($whereQuery!=null && strlen($whereQuery)>0)$selectQuery = $selectQuery . " WHERE " . $whereQuery;
  $query->setQuery($selectQuery);
  $response = $service->jobs->query($project_id, $query);
  $jsonStr = "";
  if($response)if($response->getRows())$jsonStr = $response->getRows();
  print_r($jsonStr);

即使我连接到服务->作业，我也会收到错误消息：

  $destinationTable = new Google_Service_Bigquery_TableReference();
  $destinationTable->setDatasetId($dataset);
  $destinationTable->setProjectId($project_id);
  $destinationTable->setTableId('ventastest');
  $service->jobs->setDestinationTable($destinationTable);
  $service->jobs->setWriteDisposition('WRITE_APPEND');

谢谢，再见！

$destinationTable = new Google_Service_Bigquery_TableReference();
$destinationTable->setDatasetId(DATASET_ID);
$destinationTable->setProjectId(PROJECT_ID);
$destinationTable->setTableId('name_of_the_table');
$queryConfig->setDestinationTable($destinationTable);
$queryConfig->setWriteDisposition('WRITE_APPEND');