fix source comprehensive test (#5379)

airbytehq · Aug 16, 2021 · 797445d · 797445d
1 parent adb6e84
commit 797445d
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/...gration/java/io/airbyte/integrations/source/bigquery/BigQuerySourceComprehensiveTest.java b/...gration/java/io/airbyte/integrations/source/bigquery/BigQuerySourceComprehensiveTest.java
@@ -343,6 +343,18 @@ protected String getNameSpace() {
     return dataset.getDatasetId().getDataset();
   }
 
+  @Override
+  protected String getValueFromJsonNode(JsonNode jsonNode) {
+    if (jsonNode != null) {
+      String nodeText = jsonNode.asText();
+      String nodeString = jsonNode.toString();
+      String value = (nodeText != null && !nodeText.equals("") ? nodeText : nodeString);
+      value = (value != null && value.equals("null") ? null : value);
+      return value;
+    }
+    return null;
+  }
+
   @AfterAll
   public void cleanTestInstance() {
     database.getRealDatabase().cleanDataSet(getNameSpace());