test: do not merge

google-cloud-bigquery/src/main/java/com/google/cloud/bigquery/BigQueryOptions.java

@@ -33,6 +33,7 @@ public class BigQueryOptions extends ServiceOptions<BigQuery, BigQueryOptions> {
   private static final String API_SHORT_NAME = "BigQuery";
   private static final int DEFAULT_READ_API_TIME_OUT = 60000;
   private static final String BIGQUERY_SCOPE = "https://www.googleapis.com/auth/bigquery";
+  // TODO(NOW)
   private static final Set<String> SCOPES = ImmutableSet.of(BIGQUERY_SCOPE);
   private static final long serialVersionUID = -2437598817433266048L;
   private final String location;

samples/snippets/src/main/java/com/example/bigquery/AuthDriveScope.java

@@ -42,17 +42,29 @@ public static void setAuthDriveScope() throws IOException {
                     "https://www.googleapis.com/auth/bigquery",
                     "https://www.googleapis.com/auth/drive"));
 
+    // TODO(NOW)
+    // if (ServiceAccountCredentials.getApplicationDefault().equals(credentials)) {
+    //   System.out.println("CHUONGPH: equal error: \n");
+    //   throw new IOException();
+    // } else {
+    //   System.out.println("CHUONGPH: not equal error: \n");
+    //   throw new IOException();
+    // }
+
     try {
       // Initialize client that will be used to send requests. This client only needs to be created
       // once, and can be reused for multiple requests.
       BigQuery bigquery =
           BigQueryOptions.newBuilder().setCredentials(credentials).build().getService();
 
+      // System.out.println("CHUONGPH: Scopes \n" + BigQueryOptions.newBuilder().setCredentials(credentials).build().getScopes());
+
       // Use the client.
       System.out.println("Auth succeeded with multiple scopes. Datasets:");
       for (Dataset dataset : bigquery.listDatasets().iterateAll()) {
         System.out.printf("Dataset: %s%n", dataset.getDatasetId().getDataset());
       }
+      // throw new IOException();
     } catch (BigQueryException e) {
       System.out.println("Auth failed due to error: \n" + e.toString());
     }

samples/snippets/src/main/java/com/example/bigquery/CreateTable.java

@@ -17,6 +17,8 @@
 package com.example.bigquery;
 
 // [START bigquery_create_table]
+import com.google.auth.oauth2.GoogleCredentials;
+import com.google.auth.oauth2.ServiceAccountCredentials;
 import com.google.cloud.bigquery.BigQuery;
 import com.google.cloud.bigquery.BigQueryException;
 import com.google.cloud.bigquery.BigQueryOptions;
@@ -27,6 +29,10 @@
 import com.google.cloud.bigquery.TableDefinition;
 import com.google.cloud.bigquery.TableId;
 import com.google.cloud.bigquery.TableInfo;
+import com.google.cloud.bigquery.QueryJobConfiguration;
+import com.google.cloud.bigquery.TableResult;
+import com.google.common.collect.ImmutableSet;
+import java.io.IOException;
 
 public class CreateTable {
 
@@ -43,17 +49,50 @@ public static void main(String[] args) {
 
   public static void createTable(String datasetName, String tableName, Schema schema) {
     try {
+      // Create credentials with Drive & BigQuery API scopes.
+      // Both APIs must be enabled for your project before running this code.
+      GoogleCredentials credentials =
+          ServiceAccountCredentials.getApplicationDefault()
+              .createScoped(
+                  ImmutableSet.of(
+                      "https://www.googleapis.com/auth/bigquery",
+                      "https://www.googleapis.com/auth/drive"));
+
       // Initialize client that will be used to send requests. This client only needs to be created
       // once, and can be reused for multiple requests.
-      BigQuery bigquery = BigQueryOptions.getDefaultInstance().getService();
+      BigQuery bigquery =
+          BigQueryOptions.newBuilder().setCredentials(credentials).build().getService();
+      // // Initialize client that will be used to send requests. This client only needs to be created
+      // // once, and can be reused for multiple requests.
+      // BigQuery bigquery = BigQueryOptions.getDefaultInstance().getService();
 
       TableId tableId = TableId.of(datasetName, tableName);
       TableDefinition tableDefinition = StandardTableDefinition.of(schema);
       TableInfo tableInfo = TableInfo.newBuilder(tableId, tableDefinition).build();
 
       bigquery.create(tableInfo);
-      System.out.println("Table created successfully");
-    } catch (BigQueryException e) {
+
+      // TODO(NOW)
+      // String query = String.format("SELECT * FROM %s.INFORMATION_SCHEMA.SESSIONS_BY_USER", datasetName);
+      String query = "SELECT * FROM region-us.INFORMATION_SCHEMA.SESSIONS_BY_USER";
+      // Create the query job.
+      QueryJobConfiguration queryConfig = QueryJobConfiguration.newBuilder(query).build();
+
+      // Execute the query.
+      TableResult result = bigquery.query(queryConfig);
+
+      // Print the results.
+      result
+          .iterateAll()
+          .forEach(
+              row -> {
+                System.out.print("creation_time:" + row.get("creation_time").getStringValue());
+                System.out.print(", project_id:" + row.get("project_id").getStringValue());
+                System.out.print(", session_id:" + row.get("session_id").getStringValue());
+                System.out.print(", user_email:" + row.get("user_email").getStringValue());
+                System.out.println();
+              });
+    } catch (BigQueryException | InterruptedException | IOException e) {
       System.out.println("Table was not created. \n" + e.toString());
     }
   }

samples/snippets/src/main/java/com/example/bigquery/QueryExternalSheetsPerm.java

@@ -37,7 +37,7 @@
 // Sample to queries an external data source using a permanent table
 public class QueryExternalSheetsPerm {
 
-  public static void main(String[] args) {
+  public static void main(String[] args) throws BigQueryException, InterruptedException, IOException  {
     // TODO(developer): Replace these variables before running the sample.
     String datasetName = "MY_DATASET_NAME";
     String tableName = "MY_TABLE_NAME";
@@ -53,8 +53,8 @@ public static void main(String[] args) {
   }
 
   public static void queryExternalSheetsPerm(
-      String datasetName, String tableName, String sourceUri, Schema schema, String query) {
-    try {
+      String datasetName, String tableName, String sourceUri, Schema schema, String query) throws BigQueryException, InterruptedException, IOException {
+    // try {
 
       // Create credentials with Drive & BigQuery API scopes.
       // Both APIs must be enabled for your project before running this code.
@@ -91,9 +91,9 @@ public static void queryExternalSheetsPerm(
           .forEach(row -> row.forEach(val -> System.out.printf("%s,", val.toString())));
 
       System.out.println("Query on external permanent table performed successfully.");
-    } catch (BigQueryException | InterruptedException | IOException e) {
-      System.out.println("Query not performed \n" + e.toString());
-    }
+    // } catch (BigQueryException | InterruptedException | IOException e) {
+    //   System.out.println("Query not performed \n" + e.toString());
+    // // }
   }
 }
 // [END bigquery_query_external_sheets_perm]

samples/snippets/src/test/java/com/example/bigquery/AuthDriveScopeIT.java

@@ -26,7 +26,9 @@
 import org.junit.After;
 import org.junit.Before;
 import org.junit.Test;
+import org.junit.Ignore;
 
+@Ignore
 public class AuthDriveScopeIT {
 
   private final Logger log = Logger.getLogger(this.getClass().getName());
@@ -55,4 +57,4 @@ public void setAuthDriveScope() throws IOException {
     AuthDriveScope.setAuthDriveScope();
     assertThat(bout.toString()).contains("Auth succeeded with multiple scopes.");
   }
-}
+}