Spina Bifida - Code Module

adelaide.wilson
26 May 2025

Output path

SQL:[IDI_Community].[dsbl_spina_bifida].[spina_bifida_YYYYMM]
SAS: libname cmid dsn=idi_community_srvprd schema=dsbl_spina_bifida; run ;
How to access a code module in the Data Lab:Read here

Description

The purpose of this code module is to identify individuals in New Zealand in the IDI who have a recorded diagnosis of spina bifida.

The dataset will list individuals, the earliest event when an individual has a recorded diagnosis of spina bifida in the IDI, date of the earliest event, the individual’s age and whether they are alive at the time of the IDI refresh. For those individuals who have died, the dataset lists a date of death and age at death.

This module is not intended to be used to give a true prevalence rate of people in New Zealand with spina bifida due to limitations of the datasets included in the IDI. The code module allows researchers to have a consistent way of identifying people with spina bifida and will allow for comparisons of outcomes for people with spina bifida and people without spina bifida.

Key Concepts

Business history

Code history and ICD code notes

ICD codes used are based on the ICD clinical code system for the earliest date of data as per Health New Zealand (HNZ) | Te Whatu Ora best practice. This means ICD-9-CM-A codes have been used in line with the start of the health-related datasets in the IDI.

On advice from HNZ clinical coding/classification staff, codes have first been looked up directly in ICD-10-AM 12th Edition (current Edition used), then back mapped to ICD-10-AM 1st Edition and then back mapped to ICD-9-CM-A codes.

Due to the nature of how clinical coding and classifications using ICD codes work, there are some instances where ICD-10-AM 1st Edition codes back map to ICD-9-CM-A codes that may include more than just the intended diagnosis for this code module due to changes and decisions made with ICD code mapping overtime (see Table 1).

Notes for specific datasets

References

  1. Beltran-Castillon L and McLeod K (2023) From Data to Dignity: Health and Wellbeing Indicators for New Zealanders with Intellectual Disability. Published: IHC, Kōtātā Insight
  2. Borman B and Cryer C (1993) The prevalence of anencephalus and spina bifida in New Zealand. J Paediatr Child Health 29(4); 282-8
  3. Enviromental Health Intelligence New Zealand (EHINZ) (2019) Birth defects ascertained among livebirths 2012-19. URL: EHINZ

Community of Interest

Domain Agency Person
Initial code Social Investment Agency (SIA) Craig Wright
Module coder Whaikaha - Ministry of Disabled People Adelaide Wilson
Module coder Nicholson Consulting Sarah Underwood
Lead SME/Policy Whaikaha - Ministry of Disabled People Michelle Gezentsvey, Claire Bretherton

Key business rules

Dataset name Diagnosis definition Dataset time period
Accident Compensation Corporation (ACC) Injury Claims Data Recorded as having an ACC read code on the ACC45 claim form of: 1974 -
‘P10..’ (spina bifida with hydrocephalus), or
‘P1033’ (Lumbar spina bifida with hydrocephalus - closed).
Publicly funded hospital discharges (NMDS) A publicly funded hospital discharge with a primary or secondary ICD-9-CM-A diagnosis code of: 1988 -
74100 (spina bifida with hydrocephalus, unspecified region),
74100 (spina bifida with hydrocephalus, unspecified region),
74101 (spina bifida with hydrocephalus, cervical region),
74102 (spina bifida with hydrocephalus, dorsal (thoracic) region),
74103 (spina bifida with hydrocephalus, lumbar region),
74190 (Spina bifida without mention of hydrocephalus, unspecified region),
74191 (spina bifida without mention of hydrocephalus, cervical region),
74192 (Spina bifida without mention of hydrocephalus, dorsal (thoracic) region),
74193 (Spina bifida without mention of hydrocepahlus, lumbar region), or
75617 (Spina bifida occulata).
Privately funded hospital discharges (NMDS) A privately funded hospital discharge with a primary or secondary ICD-9-CM-A diagnosis code of: 2001 -
74100 (spina bifida with hydrocephalus, unspecified region),
74100 (spina bifida with hydrocephalus, unspecified region),
74101 (spina bifida with hydrocephalus, cervical region),
74102 (spina bifida with hydrocephalus, dorsal (thoracic) region),
74103 (spina bifida with hydrocephalus, lumbar region),
74190 (Spina bifida without mention of hydrocephalus, unspecified region),
74191 (spina bifida without mention of hydrocephalus, cervical region),
74192 (Spina bifida without mention of hydrocephalus, dorsal (thoracic) region),
74193 (Spina bifida without mention of hydrocepahlus, lumbar region), or
75617 (Spina bifida occulata).
Mortality Collection (MORT) Identified as an underlying or contributing cause of death with an ICD-9-CM-A code of: 1988 -
74100 (spina bifida with hydrocephalus, unspecified region),
74100 (spina bifida with hydrocephalus, unspecified region),
74101 (spina bifida with hydrocephalus, cervical region),
74102 (spina bifida with hydrocephalus, dorsal (thoracic) region),
74103 (spina bifida with hydrocephalus, lumbar region),
74190 (Spina bifida without mention of hydrocephalus, unspecified region),
74191 (spina bifida without mention of hydrocephalus, cervical region),
74192 (Spina bifida without mention of hydrocephalus, dorsal (thoracic) region),
74193 (Spina bifida without mention of hydrocepahlus, lumbar region), or
75617 (Spina bifida occulata),
or an ICD-10-AM code of:
Q050 (cervical spina bifida with hydrocephalus),
Q051(thoracic spina bifida with hydrocephalus),
Q052 (lumbar spina bifida with hydrocephalus),
Q053 (sacral spina bifida with hydrocephalus),
Q054 (Unspecified spina bifida with hydrocephalus)
Q055 (cervical spina bifida without hydrocephalus),
Q056 (thoracic spina bifida without hydrocephalus),
Q057 (lumbar spina bifida without hydrocephalus),
Q058 (sacral spina bifida without hydrocephalus), or
Q059 (spina bifida, unspecified).
Disability Support Services database (SOCRATES) Recorded as having a developmental delay in the Referral Diagnosis/Health Condition field with the code of: 1998 -
1817 (Spina bifida).
Programme for the Integration of Mental Health Data (PRIMHD) There is no code for spina bifida in the DSM-IV classification system for secondary mental health and addiction services. Identified with an ICD-10-AM code of: 2009 -
Q050 (cervical spina bifida with hydrocephalus),
Q051(thoracic spina bifida with hydrocephalus),
Q052 (lumbar spina bifida with hydrocephalus),
Q053 (sacral spina bifida with hydrocephalus),
Q054 (Unspecified spina bifida with hydrocephalus)
Q055 (cervical spina bifida without hydrocephalus),
Q056 (thoracic spina bifida without hydrocephalus),
Q057 (lumbar spina bifida without hydrocephalus),
Q058 (sacral spina bifida without hydrocephalus), or
Q059 (spina bifida, unspecified).
Mental Health Information National Collection (MHINC) There is no code for spina bifida in the DSM-IV classification system for secondary mental health and addiction services. Identified with an ICD-9-CM-A diagnosis code of: July 2001 - 2008
74100 (spina bifida with hydrocephalus, unspecified region),
74101 (spina bifida with hydrocephalus, cervical region),
74102 (spina bifida with hydrocephalus, dorsal (thoracic) region),
74103 (spina bifida with hydrocephalus, lumbar region),
74190 (Spina bifida without mention of hydrocephalus, unspecified region),
74191 (spina bifida without mention of hydrocephalus, cervical region),
74192 (Spina bifida without mention of hydrocephalus, dorsal (thoracic) region),
74193 (Spina bifida without mention of hydrocepahlus, lumbar region), or
75617 (Spina bifida occulata).

Table 1: ICD-10-AM 1st Edition codes that back map to ICD-9-CM-A disease codes included in the code module

Backward mapping provides equivalent codes for new codes in the newer edition.

ICD-9-CM-A code and definition ICD-10-AM 1st Edition code and definition
74100 Spina bifida with hydrocephalus Q070 Arnold-Chiari syndrome

Data quality and other known issues

  1. Not all individuals in New Zealand diagnosed with spina bifida will be identified in this module. The module requires that the individual has had an ACC claim form, hospital discharge events, received Disability Support Services, or had their death recorded where the diagnosis of spina bifida has been specified.

  2. Datasets included have different lag times for having updated data available in the IDI. This means the completeness of the data at the time of analysis will depend on the lag time of the different datasets.

  3. Individuals identified in the SOCRATES disability dataset do not always appear in the referral or needs assessment datasets as well. Where an individual is only identified through the SOCRATES disability dataset there is no associated event date. In this case a proxy date of ‘3999-12-31’ will be seen in the final table.

  4. Spina bifida can be diagnosed through prenatal ultrasound and testing and so a diagnosis can be available from birth, although very mild forms may often go undiagnosed.

  5. Registerable stillbirths are included in the mortality dataset.

Comparison against other sources

Parameters

The following parameters should be supplied to this module to run it in the database:

  1. {targetdb}: The SQL database on which the datasets are to be created.
  2. {idicleanversion}: The IDI Clean version that the datasets need to be based on.
  3. {targetschema}: The project schema under the target database into which the datasets are to be created.

Dependencies

{idicleanrefresh}.[acc_clean].[claims]
{idicleanrefresh}.[acc_clean].[medical_codes]
{idicleanrefresh}.[moh_clean].[pub_fund_hosp_discharges_diag]
{idicleanrefresh}.[moh_clean].[pub_fund_hosp_discharges_event]
{idicleanrefresh}.[moh_clean].[priv_fund_hosp_discharges_diag]
{idicleanrefresh}.[moh_clean].[priv_fund_hosp_discharges_event]
{idicleanrefresh}.[moh_clean].[mortality_diagnosis]
{idicleanrefresh}.[moh_clean].[mortality_registrations]
{idicleanrefresh}.[security].[concordance]
{idicleanrefresh}.[moh_clean].[pop_cohort_demographics]
{idicleanrefresh}.[data].[personal_detail]
{idicleanrefresh}.[dia_clean].[deaths]

The following IDI_Adhoc are the most recent versions for this current refresh but changes to the code will need to be made as new datasets are uploaded into the IDI.

[IDI_Adhoc].[clean_read_MOH_SOCRATES].[moh_disability_2022]
[IDI_Adhoc].[clean_read_MOH_SOCRATES].[moh_needs_assessment_2022]
[IDI_Adhoc].[clean_read_MOH_SOCRATES].[moh_referral_2022]
[IDI_Adhoc].[clean_read_MOH_PRIMHD].[primhd_diagnoses_202502]
[IDI_Adhoc].[clean_read_MOH_PRIMHD].[moh_primhd_mhinc]

Outputs

{targetdb}.{targetschema}.spina_bifida
Column name Description
snz_uid The unique Stats NZ person identifier for the the individual
type A string indicating which condition or disability this table has identified (hard-coded to “SB”)
entity A string indicating the organisation or provider ID that has provided a service for mental health services, where relevant
source_table A string that states the data source for the earliest record of diagnosis for an individual in the IDI
min_date The earliest record of diagnosis for an individual in the IDI (Note: not a date of diagnosis or onset of a condition)
snz_sex_gender_code Code for an individual’s gender
snz_birth_month_nbr Month of an individual’s birth
snz_birth_year_nbr Year of an individual’s birth
snz_birth_date_proxy Proxy date of an individual’s birth
age Age of an individual at the time of the IDI refresh
death_status A binary indicator indicating whether an individual is recorded dead (value = 1) or alive (value = 0) at the time of refresh
snz_deceased_year_nbr Year of an individual’s death (if relevant)
snz_deceased_month_nbr Month of an individual’s death (if relevant)
dod Date of death (if relevant)
age_at_death Age of an individual at death (if relevant)

Variable descriptions

Granularity:
One row represents an individual, the earliest identification of their diagnosis in the IDI, birthdate, gender and death (if applicable).

Module Version & Change History

Date Version Comments
26 May 2025 Initial Version based on specifications from Commissioning document
09 June 2025 1.1 Update to ACC variable with 202506 refresh. acc_med_read_code updated to acc_med_injury_code and acc_cla_read_code to acc_cla_primary_inj_code with acc_cla_primary_inj_type_code added.
31 October 2025 1.2 Update to MoH publicly funded hospital discharge variable with 20510 refresh. Converted moh_evt_evst_date from datetime to date.

Code


/*Set Parameters*/
/*Ref date should be the 15th of the month of the refresh used*/
:setvar targetdb "targetdb"
:setvar targetschema "targetschema" 
:setvar idicleanversion "idicleanversion"
:setvar refdate "refdate"
:setvar idimetadataversion "idimetadataversion"

USE $(targetdb);
GO

/*ACC claims with a code that includes spina bifida*/

DROP TABLE IF EXISTS #acc_sb;
SELECT
c.snz_uid
,'ACC' AS source_table
,c.code
,c.date AS event_date
,CAST(NULL AS VARCHAR(10)) AS entity
INTO #acc_sb
FROM 
(
SELECT 
[snz_uid]
,[acc_cla_accident_date] AS date
,[acc_cla_primary_inj_code] AS code
FROM  [$(idicleanversion)].[acc_clean].[claims]
      WHERE ([acc_cla_primary_inj_code] IN ('P10..', 'P1033') AND [acc_cla_primary_inj_type_code] = 'Read Code')
UNION ALL  
SELECT 
b.snz_uid
,b.acc_cla_accident_date AS date
,a.[acc_med_injury_code] AS code
FROM  [$(idicleanversion)].[acc_clean].[medical_codes] AS a
      LEFT JOIN  [$(idicleanversion)].[acc_clean].[claims] AS b ON a.[snz_acc_claim_uid] = b.[snz_acc_claim_uid]
      WHERE  a.[acc_med_injury_code] IN ('P10..', 'P1033')
      ) AS c;

/*Publicly-funded hospital discharges where clinical code matches a diagnosis of spina bifida*/

DROP TABLE IF EXISTS #moh_pub_sb;
SELECT
b.snz_uid
,'MOH_PUB' AS source_table
,a.[moh_dia_submitted_system_code] AS code_sys
,a.[moh_dia_diagnosis_type_code]
,a.[moh_dia_event_id_nbr]
,a.[moh_dia_clinical_code]
,b.moh_evt_birth_year_nbr
,CAST (b.[moh_evt_evst_date] AS DATE) AS event_date
,CAST (NULL AS VARCHAR(10)) AS entity
INTO #moh_pub_sb
FROM [$(idicleanversion)].[moh_clean].[pub_fund_hosp_discharges_diag] AS a
     LEFT JOIN [$(idicleanversion)].[moh_clean].[pub_fund_hosp_discharges_event] AS b ON a.moh_dia_event_id_nbr = b.moh_evt_event_id_nbr
     WHERE (SUBSTRING(a.[moh_dia_clinical_code],1,5) IN ('74100', '74101', '74102', '74103', '74190', '74191', '74192', '74193', '75617') AND a.[moh_dia_clinical_sys_code] ='06' AND a.[moh_dia_diagnosis_type_code] IN ('A','B'));

/*Privately-funded hospital discharges where clinical code matches a diagnosis of spina bifida*/

DROP TABLE IF EXISTS #moh_pri_sb;
SELECT
b.snz_uid
,'MOH_PRI' AS source_table
,a.[moh_pri_diag_event_id_nbr]
,a.[moh_pri_diag_clinic_sys_code]
,a.[moh_pri_diag_sub_sys_code]
,a.[moh_pri_diag_diag_type_code]
,a.[moh_pri_diag_clinic_code] 
,b.[moh_pri_evt_start_date] AS event_date
,CAST (NULL AS VARCHAR(10)) AS entity
INTO #moh_pri_sb
FROM [$(idicleanversion)].[moh_clean].[priv_fund_hosp_discharges_diag] AS a
     LEFT JOIN [$(idicleanversion)].[moh_clean].[priv_fund_hosp_discharges_event] AS b ON a.moh_pri_diag_event_id_nbr = b.moh_pri_evt_event_id_nbr
     WHERE (SUBSTRING(a.[moh_pri_diag_clinic_code],1,5) IN ('74100', '74101', '74102', '74103', '74190', '74191', '74192', '74193', '75617') AND a.[moh_pri_diag_clinic_sys_code]='06' AND a.[moh_pri_diag_diag_type_code] IN ('A','B'));
	
/*Registrations in the mortality dataset where clinical code matches a diagnosis of spina bifida*/

DROP TABLE IF EXISTS #mos_sb;
SELECT
 b.[snz_uid]
,b.[snz_moh_uid]
,'MOH_MOS' AS source_table
,DATEFROMPARTS(b.moh_mor_birth_year_nbr,b.moh_mor_birth_month_nbr,15) AS event_date
,a.[moh_mort_diag_clinical_code] AS code
,a.[moh_mort_diag_clinic_type_code]
,a.[moh_mort_diag_clinic_sys_code]
,a.[moh_mort_diag_diag_type_code]
,CAST (NULL AS VARCHAR(10)) AS entity
 INTO #mos_sb
 FROM [$(idicleanversion)].[moh_clean].[mortality_diagnosis] AS a
      LEFT JOIN [$(idicleanversion)].[moh_clean].[mortality_registrations] AS b ON a.snz_dia_death_reg_uid = b.snz_dia_death_reg_uid
      WHERE (SUBSTRING ([moh_mort_diag_clinical_code],1,5) IN ('74100', '74101', '74102', '74103', '74190', '74191', '74192', '74193', '75617') AND a.[moh_mort_diag_clinic_sys_code] ='06')
      OR (SUBSTRING(a.[moh_mort_diag_clinical_code],1,4) IN ('Q050', 'Q051', 'Q052', 'Q053', 'Q054', 'Q055', 'Q056', 'Q057', 'Q058','Q059', 'Q760') AND  a.[moh_mort_diag_clinic_sys_code] >= '10');

  
/* Individuals in the Ministry of Health SOCRATES database with code 1817. Date can either be first contact date or referral date. 
Where an individual appears only in the disability table but not the needs assessment or referral table, an event date of 3999-12-31 is added.
This date will be removed in the collation process if the individual appears in other datasets with an earlier event_date or kept if the 
diagnosis table is the only record for the individual*/

DROP TABLE IF EXISTS #moh_soc_sb;
SELECT
DISTINCT
b.snz_uid
,'SOC' AS source_table
,CASE WHEN CAST(SUBSTRING(c.[FirstContactDate],1,7) AS date) IS NOT NULL THEN CAST(SUBSTRING(c.[FirstContactDate],1,7) AS date) 
	  WHEN CAST(SUBSTRING(e.[ReferralDate],1,7) AS date) IS NOT NULL THEN CAST(SUBSTRING(e.[ReferralDate],1,7) AS date)
	  WHEN CAST(SUBSTRING(e.[ReferralDate],1,7) AS date) IS NULL AND CAST(SUBSTRING(c.[FirstContactDate],1,7) AS date) IS NULL THEN '3999-12-31'
	  END AS event_date
,CAST (a.code as VARCHAR(7)) AS code
,a.[Description] 
,CAST (NULL AS VARCHAR(10)) AS entity
INTO #moh_soc_sb
  FROM [IDI_Adhoc].[clean_read_MOH_SOCRATES].[moh_disability_2022] AS a 
       LEFT JOIN [$(idicleanversion)].[moh_clean].[pop_cohort_demographics] AS b ON a.snz_moh_uid = b.snz_moh_uid 
       LEFT JOIN (SELECT DISTINCT snz_moh_uid,[FirstContactDate] FROM [IDI_Adhoc].[clean_read_MOH_SOCRATES].[moh_needs_assessment_2022] ) AS c ON a.snz_moh_uid = c.snz_moh_uid 
       LEFT JOIN (SELECT DISTINCT snz_moh_uid,[ReferralDate] FROM [IDI_Adhoc].[clean_read_MOH_SOCRATES].[moh_referral_2022]) AS e ON a.snz_moh_uid = e.snz_moh_uid
  WHERE code IN ('1817');

 /*spina bifida diagnosis in PRIMHD diagnosis data*/

DROP TABLE IF EXISTS #moh_PRIMHD_sb; 
SELECT
b.snz_uid
,a.[snz_moh_uid]
,'MOH_PRIMHD' AS source_table
,CAST (a.[organisation_id] AS VARCHAR(10)) AS entity
,a.[classification_code_id]
,a.[diagnosis_type]
,CONVERT(date,a.[classification_start_date],103) AS event_date
,a.[clinical_coding_system_id]
,a.[clinical_code] AS code
INTO #moh_PRIMHD_sb
FROM [IDI_Adhoc].[clean_read_MOH_PRIMHD].[primhd_diagnoses_202502] AS a
     LEFT JOIN [$(idicleanversion)].[moh_clean].[pop_cohort_demographics] AS b ON a.snz_moh_uid = b.snz_moh_uid
     WHERE (SUBSTRING(a.[clinical_code],1,4) IN ('Q050', 'Q051', 'Q052', 'Q053', 'Q054', 'Q055', 'Q056', 'Q057', 'Q058','Q059', 'Q760') AND  a.[clinical_coding_system_id] >= '10');

 /* spina bifida diagnosis in PRIMHD MHINC data*/

DROP TABLE IF EXISTS #moh_mhinc_sb;
SELECT
b.snz_uid
,'MOH_MHINC' AS source_table
,CAST (a.[organisation_id] AS VARCHAR(10)) AS entity
,a.[classification_start] AS event_date
,a.[clinical_coding_system_id]
,a.[clinical_code] AS code
,a.[diagnosis_type]
INTO #moh_mhinc_sb
FROM [IDI_Adhoc].[clean_read_MOH_PRIMHD].[moh_primhd_mhinc] AS a
     LEFT JOIN [$(idicleanversion)].[moh_clean].[pop_cohort_demographics] AS b ON a.snz_moh_uid = b.snz_moh_uid
     WHERE (SUBSTRING(a.[clinical_code],1,5) IN ('74100', '74101', '74102', '74103', '74190', '74191','74192', '74193', '75617') AND a.[clinical_coding_system_id] = '06');
	 

 /* collate data from all sources into one table*/

DROP TABLE IF EXISTS #sb;
SELECT
a.snz_uid 
,MIN(event_date) AS min_date
,source_table
,entity
INTO #sb
FROM (
SELECT snz_uid, event_date, source_table, entity  FROM #moh_pub_sb
UNION ALL
SELECT snz_uid, event_date, source_table, entity  FROM #moh_pri_sb
UNION ALL
SELECT snz_uid, event_date, source_table, entity  FROM #mos_sb
UNION ALL
SELECT snz_uid, event_date, source_table, entity  FROM #moh_soc_sb
UNION ALL
SELECT snz_uid, event_date, source_table, entity  FROM #moh_primhd_sb
UNION ALL
SELECT snz_uid, event_date, source_table, entity  FROM #moh_mhinc_sb
)  AS a
GROUP BY snz_uid
, source_table
, entity;

 /* subset of individuals who are deceased and are in death data*/

DROP TABLE IF EXISTS #sb_dd;
SELECT 
a.*
,b.snz_birth_month_nbr
,b.snz_birth_year_nbr
,b.snz_sex_gender_code
,b.snz_deceased_year_nbr
,b.snz_deceased_month_nbr
,b.snz_birth_date_proxy
,NULL AS age
,DATEFROMPARTS(b.snz_deceased_year_nbr, b.snz_deceased_month_nbr, 15) AS dod
,'SB' AS [type]
INTO #sb_dd
FROM #sb as a
     INNER JOIN [$(idicleanversion)].[data].[personal_detail] AS b ON a.snz_uid = b.snz_uid
     WHERE a.snz_uid IN (SELECT DISTINCT snz_uid FROM [$(idicleanversion)].[dia_clean].[deaths])
     AND b.snz_deceased_year_nbr IS NOT NULL;

 /* subset of individuals who are deceased but not in death data*/

DROP TABLE IF EXISTS #sb_od;
SELECT
a.*
,b.snz_birth_month_nbr
,b.snz_birth_year_nbr
,b.snz_sex_gender_code
,b.snz_deceased_year_nbr
,b.snz_deceased_month_nbr
,b.snz_birth_date_proxy
,NULL AS age
,DATEFROMPARTS(b.snz_deceased_year_nbr, b.snz_deceased_month_nbr, 15) AS dod
,'SB' AS [type]
INTO #sb_od
FROM #sb AS a
      INNER JOIN [$(idicleanversion)].[data].[personal_detail] AS b ON a.snz_uid = b.snz_uid
      WHERE a.snz_uid NOT IN (SELECT DISTINCT snz_uid FROM [$(idicleanversion)].[dia_clean].[deaths])
      AND b.snz_deceased_year_nbr IS NOT NULL;

 /* subset of individuals who are alive*/

DROP TABLE IF EXISTS #sb_ad;
SELECT 
a.*
,b.snz_birth_month_nbr
,b.snz_birth_year_nbr
,b.snz_sex_gender_code
,b.snz_deceased_year_nbr
,b.snz_deceased_month_nbr
,b.snz_birth_date_proxy
,DATEDIFF(YEAR, b.snz_birth_date_proxy, '$(refdate)') AS age 
,'3999-12-31' AS dod 
,'SB' AS [type]
 INTO #sb_ad
 FROM #sb AS a
      INNER JOIN [$(idicleanversion)].[data].[personal_detail] AS b ON a.snz_uid = b.snz_uid
      WHERE a.snz_uid NOT IN (SELECT DISTINCT snz_uid FROM [$(idicleanversion)].[dia_clean].[deaths])
      AND a.snz_uid NOT IN (SELECT DISTINCT snz_uid FROM #sb_dd)
      AND a.snz_uid NOT IN (SELECT DISTINCT snz_uid FROM #sb_od);
  

 /* join all tables together*/

DROP TABLE IF EXISTS #sb_final;
WITH sb_union AS (
SELECT
* 
FROM #sb_dd
UNION ALL
SELECT * FROM #sb_od
UNION ALL
SELECT * FROM #sb_ad
)

SELECT
* 
,DATEDIFF(YEAR, snz_birth_date_proxy, dod) AS age_at_death
,CASE WHEN age IS NOT NULL THEN 0 ELSE 1 END AS death_status
INTO #sb_final
FROM sb_union;

/* select all required variables */

DROP TABLE IF EXISTS #sb_min;
SELECT 
snz_uid
,[type]
,entity
,source_table
,min_date
,snz_sex_gender_code
,snz_birth_month_nbr
,snz_birth_year_nbr
,snz_birth_date_proxy
,age
,death_status
,snz_deceased_year_nbr
,snz_deceased_month_nbr
,CASE WHEN dod = '3999-12-31' THEN NULL ELSE dod END AS dod
,CASE WHEN age_at_death > 1000 THEN NULL ELSE age_at_death END AS age_at_death
INTO #sb_min
FROM #sb_final;

/*take earliest recorded date for each snz_uid and create table */
DROP TABLE IF EXISTS #sb_dbl;
SELECT 
snz_uid
,[type]
,entity
,source_table
,min_date
,snz_sex_gender_code
,snz_birth_month_nbr
,snz_birth_year_nbr
,snz_birth_date_proxy
,age
,death_status
,snz_deceased_year_nbr
,snz_deceased_month_nbr
,dod
,age_at_death
INTO #sb_dbl
FROM #sb_min a
WHERE min_date = (
SELECT MIN(min_date)
FROM #sb_min b
WHERE b.snz_uid = a.snz_uid)
ORDER BY snz_uid;

/* remove duplicate snz_uid with the same minimum date but different entities or sources. Create table in IDI_Sandpit */
DROP TABLE IF EXISTS [$(targetdb)].[$(targetschema)].[$(projprefix)_spina_bifida];

WITH cte AS 
(SELECT ROW_NUMBER() OVER(PARTITION BY snz_uid
ORDER BY snz_uid DESC) AS rn
FROM #sb_dbl)

DELETE FROM cte WHERE rn > 1;

SELECT 
snz_uid
,[type]
,entity
,source_table
,min_date
,snz_sex_gender_code
,snz_birth_month_nbr
,snz_birth_year_nbr
,snz_birth_date_proxy
,age
,death_status
,snz_deceased_year_nbr
,snz_deceased_month_nbr
,dod
,age_at_death

INTO [$(targetdb)].[$(targetschema)].[$(projprefix)_spina_bifida]

FROM #sb_dbl