Connecting to bigtable (#296)

* First draft of moving connecting to Cloud Bigtable code samples to github

* adding test for the helper with the configuration

* reformat code with google-java-format

* Writing tests for the bigtable helpers

* Add region tag for creating connection object

* Editing projectID for readme

* Enabling app profile id

* Formatting code

* Refining connecting examples by putting in same class, renaming the maven project, and reformating the code

* Rename package and fix tests

* Upgrade to Java Hbase client for Cloud Bigtable 1.5

* Adding bigtable.version to properties

* Adding additional example with/without app profiles

* Remove confusing comment about app profiles

* Connecting to Bigtable in one line

Author: billyjacobson

bigtable/hbase/snippets/src/main/java/com/example/cloud/bigtable/connect/BigtableConnect.java

@@ -0,0 +1,63 @@
+/*
+ * Copyright 2018 Google LLC
+ *
+ * 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.
+ */
+
+package com.example.cloud.bigtable.connect;
+
+import com.google.cloud.bigtable.hbase.BigtableConfiguration;
+import com.google.cloud.bigtable.hbase.BigtableOptionsFactory;
+import java.io.IOException;
+import org.apache.hadoop.conf.Configuration;
+import org.apache.hadoop.hbase.HBaseConfiguration;
+import org.apache.hadoop.hbase.client.Connection;
+import org.apache.hadoop.hbase.client.ConnectionFactory;
+
+public class BigtableConnect {
+
+  public static String projectId;
+  public static String instanceId;
+  public static String appProfileId = "default";
+  public static Connection connection = null;
+
+  public static void main(String... args) {
+    projectId = args[0];  // my-gcp-project-id
+    instanceId = args[1]; // my-bigtable-instance-id
+
+    if (args.length > 2) {
+      appProfileId = args[2];    // my-bigtable-app-profile-id or default if not provided.
+    }
+  }
+
+  // [START bigtable_connect]
+  public static void connect() throws IOException {
+    connection = BigtableConfiguration.connect(projectId, instanceId);
+  }
+  // [END bigtable_connect]
+
+  // [START bigtable_connect_app_profile]
+  public static void connectWithAppProfile() throws IOException {
+    connection = BigtableConfiguration.connect(projectId, instanceId, appProfileId);
+  }
+  // [END bigtable_connect_app_profile]
+
+  // [START bigtable_connect_with_configuration]
+  public static void connectWithConfiguration() throws IOException {
+    // Define the HBase configuration with the projectID, instanceID, and optional appProfileID
+    // from resources/hbase_site.xml
+    Configuration config = HBaseConfiguration.create();
+    connection = ConnectionFactory.createConnection(config);
+  }
+  // [END bigtable_connect_with_configuration]
+}

bigtable/hbase/snippets/src/main/resources/hbase-site.xml

@@ -0,0 +1,28 @@
+<!--Define the projectID, instanceID, and appProfileID by using system properties
+e.g. -Dbigtable.projectID=test-project -Dbigtable.instanceID=test-instance
+-->
+<!--[START bigtable_hbase_site_xml]-->
+<configuration>
+  <property>
+    <name>hbase.client.connection.impl</name>
+    <value>com.google.cloud.bigtable.hbase1_x.BigtableConnection</value>
+  </property>
+  <property>
+    <name>google.bigtable.project.id</name>
+    <value>${bigtable.projectID}</value>
+  </property>
+  <property>
+    <name>google.bigtable.instance.id</name>
+    <value>${bigtable.instanceID}</value>
+  </property>
+  <!--
+    Include the following property if you are using app profiles.
+    If you do not include the following property, the connection uses the
+    default app profile.
+  -->
+  <property>
+    <name>google.bigtable.app.profile.id</name>
+    <value>${bigtable.appProfileID || "default"}</value>
+  </property>
+</configuration>
+  <!--[END bigtable_hbase_site_xml]-->

bigtable/hbase/snippets/src/test/java/com/example/cloud/bigtable/connect/BigtableConnectTest.java

@@ -0,0 +1,64 @@
+/*
+ * Copyright 2018 Google LLC
+ *
+ * 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.
+ */
+
+package com.example.cloud.bigtable.connect;
+
+import static com.google.common.truth.Truth.assertThat;
+
+import org.junit.Before;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.junit.runners.JUnit4;
+
+@RunWith(JUnit4.class)
+@SuppressWarnings("checkstyle:abbreviationaswordinname")
+public class BigtableConnectTest {
+
+  // provide your project id as an env var
+  private final String projectId = System.getProperty("bigtable.projectID");
+  private final String instanceId = System.getProperty("bigtable.instanceID");
+  BigtableConnect helper;
+
+  @Before
+  public void prepare() throws Exception {
+    helper = new BigtableConnect();
+    helper.main(projectId, instanceId);
+  }
+
+  @Test
+  public void connection() throws Exception {
+    helper.connect();
+
+    assertThat(helper.connection.toString()).contains("project=" + projectId);
+    assertThat(helper.connection.toString()).contains("instance=" + instanceId);
+  }
+
+  @Test
+  public void connectionWithAppProfile() throws Exception {
+    helper.connectWithAppProfile();
+
+    assertThat(helper.connection.toString()).contains("project=" + projectId);
+    assertThat(helper.connection.toString()).contains("instance=" + instanceId);
+  }
+
+  @Test
+  public void connectionWithConfiguration() throws Exception {
+    helper.connectWithConfiguration();
+
+    assertThat(helper.connection.toString()).contains("project=" + projectId);
+    assertThat(helper.connection.toString()).contains("instance=" + instanceId);
+  }
+}