Practical SQL

Comparing tables with FULL OUTER JOIN

Constantin LunguUpdated 1 min read

Photo by Dietmar Becker on Unsplash

Does your Data Engineering project use a data-diffing tool?

Say you're preparing to deploy a change to a prod table. You've changed the way some metrics are calculated and twisted some filters. How do you find out what's different between two tables? Identify expected vs unexpected differences?

If lacking a specialized tool for data-diffing (like Datafold, Recce ) perhaps the simplest validation you can do when comparing two tables (dev and prod versions for example) leverages the FULL OUTER JOIN (or FULL JOIN in some RDBMS).

Start with the grain. Is there any way you can bring the tables to the same grain?

Once you have aligned them to the same grain, you can now join on the respective keys and COUNT the occurrences you care about - what's missing from A, what's missing from B, totals overall. Depending on attributes, you can use other aggregate functions to assess differences - for example, does the SUM of sales amounts match in prod vs dev?

You could also leverage a hashing function + TO_JSON_ARRAY (check my previous post) to see which rows are different in the two tables.

SELECT

  COUNTIF (prod.term IS NULL AND dev.term IS NOT NULL) AS cnt_missing_prod,
  COUNT (DISTINCT CASE WHEN prod.term IS NULL AND dev.term IS NOT NULL THEN dev.term END) AS distinct_terms_missing_from_prod,

  COUNTIF (dev.term IS NULL AND prod.term IS NOT NULL) AS cnt_missing_dev,
  COUNT (DISTINCT CASE WHEN dev.term IS NULL AND prod.term IS NOT NULL THEN prod.term END) AS distinct_terms_missing_from_dev,

  COUNT(1) AS total_rows,
  COUNT(DISTINCT COALESCE(prod.term, dev.term)) AS total_distinct_terms,

  COUNTIF(FARM_FINGERPRINT(TO_JSON_STRING(prod))  <> FARM_FINGERPRINT(TO_JSON_STRING(dev))) AS rows_different


FROM `learning_us.trends_us_prod` prod

FULL OUTER JOIN `learning_us.trends_us_dev` dev ON prod.refresh_date = dev.refresh_date AND
                                                   prod.week = dev.week AND
                                                   prod.dma_id = dev.dma_id AND
                                                   prod.term = dev.term

BigQuery results: cnt_missing_prod 3954227, distinct_terms_missing_from_prod 660, cnt_missing_dev 3956293, distinct_terms_missing_from_dev 660, total_rows 43514223, total_distinct_terms 660 and rows_different 7910520.


Enjoyed this? Here are some related articles you might find useful: