new scenarios e2e bq

Author: priyabhatnagar25

src/e2e-test/java/io/cdap/plugin/bigquery/stepsdesign/BQValidationExistingTables.java

@@ -38,7 +38,7 @@ public static boolean validateActualDataToExpectedData(String table, String file
     InterruptedException, URISyntaxException {
     Map<String, JsonObject> bigQueryMap = new HashMap<>();
     Map<String, JsonObject> fileMap = new HashMap<>();
-    Path  bqExpectedFilePath = Paths.get(BQValidationExistingTables.class.getResource("/" + fileName).toURI());
+    Path bqExpectedFilePath = Paths.get(BQValidationExistingTables.class.getResource("/" + fileName).toURI());
 
     getBigQueryTableData(table, bigQueryMap);
     getFileData(bqExpectedFilePath.toString(), fileMap);
@@ -113,4 +113,4 @@ private static String getIdKey(JsonObject json) {
       return null;
     }
   }
-  }
+}

src/e2e-test/java/io/cdap/plugin/common/stepsdesign/TestSetupHooks.java

@@ -1123,7 +1123,7 @@ public static void createSourceBQDedupeUpsertTable() throws IOException, Interru
       io.cdap.e2e.utils.BigQueryClient.getSoleQueryResult("INSERT INTO `" + datasetName + "." + bqSourceTable + "` " +
                                                             "(ID,  Name, Price, Customer_Exists)" +
                                                             "VALUES" + "(1, 'string_1', 0.1, true)," +
-                                                            "(2, 'string_1', 0.2, false)" +
+                                                            "(2, 'string_1', 0.2, false)," +
                                                             "(3, 'string_3', 0.3, false)");
     } catch (NoSuchElementException e) {
       // Insert query does not return any record.
@@ -1145,7 +1145,7 @@ public static void createSinkBQDeupeUpsertTable() throws IOException, Interrupte
     try {
       io.cdap.e2e.utils.BigQueryClient.getSoleQueryResult("INSERT INTO `" + datasetName + "." + bqTargetTable + "` " +
                                                             "(ID,  Name, Price, Customer_Exists)" +
-                                                            "VALUES" + "(0, 'string_0', 0, true)" +
+                                                            "VALUES" + "(0, 'string_0', 0, true)," +
                                                             "(10, 'string_1', 1.1, false)");
     } catch (NoSuchElementException e) {
       // Insert query does not return any record.

src/e2e-test/resources/testdata/BigQuery/BQUpsertDedupeFile

@@ -1,3 +1,3 @@
-{"string_value":string_1,"int_value":2,"float_value":"0.2","boolean_value":false}
-{"string_value":string_3,"int_value":3,"float_value":"0.3","boolean_value":false}
-{"string_value":string_0,"int_value":0,"float_value":"0.0","boolean_value":true}
+{"Customer_Exists":false,"ID":3,"Name":"string_3","Price":0.3}
+{"Customer_Exists":false,"ID":2,"Name":"string_1","Price":0.2}
+{"Customer_Exists":true,"ID":0,"Name":"string_0","Price":0.0}