Merge pull request GoogleCloudPlatform#964 from GoogleCloudPlatform/hello-world

Putting Hello World into one file for more clarity on docs page.

Author: billyjacobson

bigtable/src/create_production_instance.php

@@ -85,7 +85,7 @@
         );
         $operationResponse->pollUntilComplete();
         if (!$operationResponse->operationSucceeded()) {
-            print('Error: ' . $operationResponse->getError());
+            print('Error: ' . $operationResponse->getError()->getMessage());
         } else {
             printf("Instance %s created.", $instance_id);
         }

bigtable/src/create_table.php

@@ -56,7 +56,7 @@
 
 try {
     $tableAdminClient->getTable($tableName, ['view' => View::NAME_ONLY]);
-    printf('Table %s alredy exists' . PHP_EOL, $table_id);
+    printf('Table %s already exists' . PHP_EOL, $table_id);
 } catch (ApiException $e) {
     if ($e->getStatus() === 'NOT_FOUND') {
         printf('Creating the %s table' . PHP_EOL, $table_id);

bigtable/src/helloworld/create_table.php renamed to bigtable/src/hello_world.php

@@ -23,42 +23,52 @@
  */
 
 // Include Google Cloud dependencies using Composer
-require_once __DIR__ . '/../../vendor/autoload.php';
+require_once __DIR__ . '/../vendor/autoload.php';
 
 if (count($argv) != 4) {
     return printf("Usage: php %s PROJECT_ID INSTANCE_ID TABLE_ID" . PHP_EOL, __FILE__);
 }
 list($_, $project_id, $instance_id, $table_id) = $argv;
 
-// [START bigtable_hw_create_table]
-
+// [START bigtable_hw_imports]
+use Google\ApiCore\ApiException;
 use Google\Cloud\Bigtable\Admin\V2\BigtableInstanceAdminClient;
 use Google\Cloud\Bigtable\Admin\V2\BigtableTableAdminClient;
 use Google\Cloud\Bigtable\Admin\V2\ColumnFamily;
 use Google\Cloud\Bigtable\Admin\V2\ModifyColumnFamiliesRequest\Modification;
-use Google\Cloud\Bigtable\Admin\V2\Table\View;
 use Google\Cloud\Bigtable\Admin\V2\Table;
-use Google\ApiCore\ApiException;
+use Google\Cloud\Bigtable\Admin\V2\Table\View;
+use Google\Cloud\Bigtable\BigtableClient;
+use Google\Cloud\Bigtable\Mutations;
+use Google\Cloud\Bigtable\V2\RowFilter;
 
+// [END bigtable_hw_imports]
+
+// [START bigtable_hw_connect]
 /** Uncomment and populate these variables in your code */
 // $project_id = 'The Google project ID';
 // $instance_id = 'The Bigtable instance ID';
 // $table_id = 'The Bigtable table ID';
 
 $instanceAdminClient = new BigtableInstanceAdminClient();
 $tableAdminClient = new BigtableTableAdminClient();
+$dataClient = new BigtableClient([
+    'projectId' => $project_id,
+]);
+// [END bigtable_hw_connect]
 
+// [START bigtable_hw_create_table]
 $instanceName = $instanceAdminClient->instanceName($project_id, $instance_id);
 $tableName = $tableAdminClient->tableName($project_id, $instance_id, $table_id);
 
 // Check whether table exists in an instance.
 // Create table if it does not exists.
 $table = new Table();
-printf('Creating a Table : %s' . PHP_EOL, $table_id);
+printf('Creating a Table: %s' . PHP_EOL, $table_id);
 
 try {
     $tableAdminClient->getTable($tableName, ['view' => View::NAME_ONLY]);
-    printf('Table %s alredy exists' . PHP_EOL, $table_id);
+    printf('Table %s already exists' . PHP_EOL, $table_id);
 } catch (ApiException $e) {
     if ($e->getStatus() === 'NOT_FOUND') {
         printf('Creating the %s table' . PHP_EOL, $table_id);
@@ -79,3 +89,59 @@
     }
 }
 // [END bigtable_hw_create_table]
+
+// [START bigtable_hw_write_rows]
+$table = $dataClient->table($instance_id, $table_id);
+
+printf('Writing some greetings to the table.' . PHP_EOL);
+$greetings = ['Hello World!', 'Hello Cloud Bigtable!', 'Hello PHP!'];
+$entries = [];
+$columnFamilyId = 'cf1';
+$column = 'greeting';
+foreach ($greetings as $i => $value) {
+    $row_key = sprintf('greeting%s', $i);
+    $rowMutation = new Mutations();
+    $rowMutation->upsert($columnFamilyId, $column, $value, time() * 1000);
+    $entries[$row_key] = $rowMutation;
+}
+$table->mutateRows($entries);
+// [END bigtable_hw_write_rows]
+
+// [START bigtable_hw_get_with_filter]
+printf('Getting a single greeting by row key.' . PHP_EOL);
+$key = 'greeting0';
+// Only retrieve the most recent version of the cell.
+$row_filter = (new RowFilter)->setCellsPerColumnLimitFilter(1);
+
+$column = 'greeting';
+$columnFamilyId = 'cf1';
+
+$row = $table->readRow($key, [
+    'rowFilter' => $row_filter
+]);
+printf('%s' . PHP_EOL, $row[$columnFamilyId][$column][0]['value']);
+// [END bigtable_hw_get_with_filter]
+
+// [START bigtable_hw_scan_all]
+$columnFamilyId = 'cf1';
+$column = 'greeting';
+printf('Scanning for all greetings:' . PHP_EOL);
+$partial_rows = $table->readRows([])->readAll();
+foreach ($partial_rows as $row) {
+    printf('%s' . PHP_EOL, $row[$columnFamilyId][$column][0]['value']);
+}
+// [END bigtable_hw_scan_all]
+
+// [START bigtable_hw_delete_table]
+try {
+    printf('Attempting to delete table %s.' . PHP_EOL, $table_id);
+    $tableAdminClient->deleteTable($tableName);
+    printf('Deleted %s table.' . PHP_EOL, $table_id);
+} catch (ApiException $e) {
+    if ($e->getStatus() === 'NOT_FOUND') {
+        printf('Table %s does not exists' . PHP_EOL, $table_id);
+    } else {
+        throw $e;
+    }
+}
+// [END bigtable_hw_delete_table]