adds create_table, create_dataset, and copy_table to bigquery samples (GoogleCloudPlatform#232)

Author: bshaffer

bigquery/api/bigquery.php

@@ -3,6 +3,7 @@
 require __DIR__ . '/vendor/autoload.php';
 
 use Google\Cloud\Samples\BigQuery\BrowseTableCommand;
+use Google\Cloud\Samples\BigQuery\CopyTableCommand;
 use Google\Cloud\Samples\BigQuery\DatasetsCommand;
 use Google\Cloud\Samples\BigQuery\ExportCommand;
 use Google\Cloud\Samples\BigQuery\ImportCommand;
@@ -14,6 +15,7 @@
 
 $application = new Application();
 $application->add(new BrowseTableCommand());
+$application->add(new CopyTableCommand());
 $application->add(new DatasetsCommand());
 $application->add(new ExportCommand());
 $application->add(new ImportCommand());

bigquery/api/composer.json

@@ -1,6 +1,6 @@
 {
     "require": {
-        "google/cloud": "0.10",
+        "google/cloud": "^0.11",
         "symfony/console": "^3.0"
     },
     "require-dev": {
@@ -13,6 +13,9 @@
         },
         "files": [
             "src/functions/browse_table.php",
+            "src/functions/copy_table.php",
+            "src/functions/create_dataset.php",
+            "src/functions/create_table.php",
             "src/functions/delete_table.php",
             "src/functions/export_table.php",
             "src/functions/import_from_file.php",

bigquery/api/composer.lock

@@ -0,0 +1,101 @@
+
+/**
+ * Copyright 2015 Google Inc. All Rights Reserved.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+namespace Google\Cloud\Samples\BigQuery;
+
+use Symfony\Component\Console\Command\Command;
+use Symfony\Component\Console\Input\InputInterface;
+use Symfony\Component\Console\Input\InputArgument;
+use Symfony\Component\Console\Input\InputOption;
+use Symfony\Component\Console\Output\OutputInterface;
+use Google\Cloud\ServiceBuilder;
+use InvalidArgumentException;
+
+/**
+ * Command line utility to copy a BigQuery table.
+ *
+ * Usage: php bigquery.php copy-table
+ */
+class CopyTableCommand extends Command
+{
+    use ProjectIdTrait;
+
+    protected function configure()
+    {
+        $this
+            ->setName('copy-table')
+            ->setDescription('Copy a BigQuery table into another BigQuery table')
+            ->setHelp(<<
+The %command.name% command copies your data and schema from a BigQuery
+table into another BigQuery Table.
+
+    php %command.full_name% DATASET SOURCE_TABLE DESTINATION_TABLE
+
+
+EOF
+            )
+            ->addArgument(
+                'dataset',
+                InputArgument::REQUIRED,
+                'The dataset for the copy'
+            )
+            ->addArgument(
+                'source-table',
+                InputArgument::REQUIRED,
+                'The BigQuery table to copy from'
+            )
+            ->addArgument(
+                'destination-table',
+                InputArgument::REQUIRED,
+                'The BigQuery table to copy to'
+            )
+            ->addOption(
+                'project',
+                null,
+                InputOption::VALUE_REQUIRED,
+                'The Google Cloud Platform project name to use for this invocation. ' .
+                'If omitted then the current gcloud project is assumed. '
+            )
+        ;
+    }
+
+    protected function execute(InputInterface $input, OutputInterface $output)
+    {
+        if (!$projectId = $input->getOption('project')) {
+            $projectId = $this->getProjectIdFromGcloud();
+        }
+        $datasetId = $input->getArgument('dataset');
+        $sourceTableId = $input->getArgument('source-table');
+        $builder = new ServiceBuilder([
+            'projectId' => $projectId,
+        ]);
+        $bigQuery = $builder->bigQuery();
+        $dataset = $bigQuery->dataset($datasetId);
+        $sourceTable = $dataset->table($sourceTableId);
+        $destinationTableId = $input->getArgument('destination-table');
+        if (!$dataset->exists()) {
+            throw new InvalidArgumentException('The supplied dataset does not exist for this project');
+        }
+        if (!$sourceTable->exists()) {
+            throw new InvalidArgumentException('The supplied source table does not exist for this project. ');
+        }
+        $message = sprintf('Copying table for project %s', $projectId);
+        $output->writeln($message);
+
+        copy_table($projectId, $datasetId, $sourceTableId, $destinationTableId);
+    }
+}

bigquery/api/src/CopyTableCommand.php

@@ -126,7 +126,7 @@ protected function execute(InputInterface $input, OutputInterface $output)
                     return $output->writeln('Task cancelled by user.');
                 }
             }
-            $dataset = $bigQuery->createDataset($datasetId);
+            $dataset = create_dataset($projectId, $datasetId);
         }
 
         if ($input->getOption('delete')) {
@@ -169,8 +169,8 @@ protected function execute(InputInterface $input, OutputInterface $output)
             }
         }
         try {
-            $options = ['schema' => ['fields' => $fields]];
-            $table = $dataset->createTable($tableId, $options);
+            $schema = ['fields' => $fields];
+            create_table($projectId, $datasetId, $tableId, $schema);
         } catch (BadRequestException $e) {
             $response = $e->getServiceException()->getResponse();
             $errorJson = json_decode((string) $response->getBody(), true);