diff --git a/src/main/java/com/application/Credentials.java b/src/main/java/com/application/Credentials.java index 7f1a1f68b7582cf0ac55fe6facac6fbf8016737b..e0898e751c8a0f41e4fb8688bd7bf94a4246e12b 100644 --- a/src/main/java/com/application/Credentials.java +++ b/src/main/java/com/application/Credentials.java @@ -1,5 +1,5 @@ package com.application; public class Credentials { - String projectId = "MY_PROJECT_ID"; + String projectId = "sf-drying-optimization"; } diff --git a/src/main/java/com/application/DataBase/DB.java b/src/main/java/com/application/DataBase/DB.java index 4f332822642eaabab90ad07f45919f59e4fc64f1..fa8c89b0ab44983f71eaa4f0746439338ae363e9 100644 --- a/src/main/java/com/application/DataBase/DB.java +++ b/src/main/java/com/application/DataBase/DB.java @@ -1,5 +1,7 @@ package com.application.DataBase; +import com.application.Credentials; + import com.google.auth.oauth2.GoogleCredentials; import com.google.auth.oauth2.ServiceAccountCredentials; import com.google.cloud.bigquery.BigQuery; @@ -23,9 +25,11 @@ import java.util.List; public class DB { + Credentials credentialsObject; + private static void insertSampleData() { // Step 1: Initialize BigQuery service - BigQuery bigquery = BigQueryOptions.newBuilder().setProjectId("sample-project-330313") + BigQuery bigquery = BigQueryOptions.newBuilder().setProjectId("sf-drying-optimization") .build().getService(); // Step 2: Create insertAll (streaming) request @@ -97,9 +101,9 @@ public class DB { // Step 2: Prepare query job // A "QueryJob" is a type of job that executes SQL queries // we create a new job configuration from our SQL query and - final String GET_WORD_COUNT = - "SELECT word, word_count FROM `bigquery-public-data.samples.shakespeare` WHERE corpus='juliuscaesar' ORDER BY word_count DESC limit 10;"; - QueryJobConfiguration queryConfig = + final String GET_WORD_COUNT = "SELECT VariantValue, TimeStamp FROM sf-drying-optimization.124.int_sd_winccsensordata WHERE TimeStamp BETWEEN \"2020-06-09\" AND \"2020-06-29\" ORDER BY TimeStamp"; + + QueryJobConfiguration queryConfig = QueryJobConfiguration.newBuilder(GET_WORD_COUNT).build(); // Step 3: Run the job on BigQuery @@ -120,14 +124,14 @@ public class DB { // Step 4: Display results // Print out a header line, and iterate through the // query results to print each result in a new line - System.out.println("word\tword_count"); + System.out.println("Timestamp\tVarient value"); TableResult result = queryJob.getQueryResults(); for (FieldValueList row : result.iterateAll()) { // We can use the `get` method along with the column // name to get the corresponding row entry - String word = row.get("word").getStringValue(); - int wordCount = row.get("word_count").getNumericValue().intValue(); - System.out.printf("%s\t%d\n", word, wordCount); + int variantValue = row.get("VariantValue").getNumericValue().intValue(); + String timeStamp = row.get("TimeStamp").getStringValue(); + System.out.printf("%s\t%d\n", timeStamp, variantValue); } }