Skip to content

Commit

Permalink
Debug
Browse files Browse the repository at this point in the history
  • Loading branch information
bharatgulati committed Jul 24, 2023
1 parent ee1dcf4 commit 3020212
Showing 1 changed file with 10 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -66,7 +66,11 @@ public static boolean validateDBToBQRecordValues(String schema, String sourceTab

String getSourceQuery = "SELECT * FROM " + schema + "." + sourceTable;
ResultSet resultSet = executeQuery(getSourceQuery);
return compareResultSetAndJsonData(resultSet, targetBigQueryResponse);
try {
return compareResultSetAndJsonData(resultSet, targetBigQueryResponse);
} finally {
resultSet.close();
}
}

public static boolean validateBQToDBRecordValues(String schema, String sourceTable, String targetTable)
Expand All @@ -81,7 +85,11 @@ public static boolean validateBQToDBRecordValues(String schema, String sourceTab
}
String getTargetQuery = "SELECT * FROM " + schema + "." + targetTable;
ResultSet resultSet = executeQuery(getTargetQuery);
return compareResultSetAndJsonData(resultSet, sourceBigQueryResponse);
try {
return compareResultSetAndJsonData(resultSet, sourceBigQueryResponse);
} finally {
resultSet.close();
}
}

/**
Expand Down

0 comments on commit 3020212

Please sign in to comment.