From fdd73087b960053806d62f2acebf94e7b5d49df8 Mon Sep 17 00:00:00 2001
From: emtunhei <emtunhei@stud.ntnu.no>
Date: Thu, 24 Feb 2022 09:52:53 +0100
Subject: [PATCH] Connection established!
---
.../java/com/application/Credentials.java | 2 +-
.../java/com/application/DataBase/DB.java | 20 +++++++++++--------
2 files changed, 13 insertions(+), 9 deletions(-)
diff --git a/src/main/java/com/application/Credentials.java b/src/main/java/com/application/Credentials.java
index 7f1a1f6..e0898e7 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 4f33282..fa8c89b 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);
}
}
--
GitLab