Skip to content

Commit 797445d

Browse files
authored
fix source comprehensive test (#5379)
1 parent adb6e84 commit 797445d

File tree

1 file changed

+12
-0
lines changed

1 file changed

+12
-0
lines changed

airbyte-integrations/connectors/source-bigquery/src/test-integration/java/io/airbyte/integrations/source/bigquery/BigQuerySourceComprehensiveTest.java

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -343,6 +343,18 @@ protected String getNameSpace() {
343343
return dataset.getDatasetId().getDataset();
344344
}
345345

346+
@Override
347+
protected String getValueFromJsonNode(JsonNode jsonNode) {
348+
if (jsonNode != null) {
349+
String nodeText = jsonNode.asText();
350+
String nodeString = jsonNode.toString();
351+
String value = (nodeText != null && !nodeText.equals("") ? nodeText : nodeString);
352+
value = (value != null && value.equals("null") ? null : value);
353+
return value;
354+
}
355+
return null;
356+
}
357+
346358
@AfterAll
347359
public void cleanTestInstance() {
348360
database.getRealDatabase().cleanDataSet(getNameSpace());

0 commit comments

Comments
 (0)