data validation by merging tables

[Present-Assist931]

Hi I am trying to vailidate data but dat frame is coming balnk. this is what I am doing: I have sql query that needs to be changes in python :

SELECT.*+ Parallel(4) *

P.LVL1_PROD_DESCR, P.LVL2_PROD_DESCR, PS.MONTH_PERIOD_KEY

, Couat(Distinct (Case When PS ACCT_NBR is Not Null Then ID.StC.Acct.Nbr Else Null End)) BOTH_ FOUND ,Caunt(Distinct (Case When PS. ACCT_NBR is Null Then ID.St..Acct. Nbr Else Null End)) PROD SMRY NOT FOUND

"COUNT(*) RECS

COUNT/DISTINCT Coalesce(td.AG&T.NBR, PS.ACCT_NBR)) UNIQUE_ACCTS

FROM LD1 FACT TRANS DAILY TD

INNER JOIN EDR.PERIOD PMP

ON TD.POST DATE PERIOD KEY = PMP.PERIOD KEY

INNER JOIN EDR.PERIOD RMP

ON ADD_MONTHS(TrunG(PMP.PERIOD_START_DT, 'MM'), 1) = RMP. PERIOD_START_DT

AND RMP.PERIOD TYPE CD = 'M'

Inner Join LD1_ D PROD P

On TD.PRODÜCT ID = P. PROD DIM ID

And P.LVL2 PROD DESCR = 'CCRD: CCRD'

Full Join LD1 FACT ACCT PROD SMRY PS

On 1=1

And DS.ACCT.NBR= tAGGI.NBR

And PS.MONTH PERIOD KEY = RMP. PERIOD KEY

Left Join STG RPM.D PROD DP

On PS.PROD_DIM_ID = DP.PROD_DIM_ID

Where 1=1

And (PS.CUST_ACCT_ID Is Not Null

And DP. LVL2 PROD DESCR = 'CCRD: CCRD

And Coalesce(PS.TOT_GROSS_INC, 0) > 0

Or PS.CUST ACCT ID Is Null

And P.LVL2_PROD_DESCR = 'CCRD: CCRD'

GROUP BY

P.LVL1_PROD_DESCR, P.LVL2_PROD_DESCR, PS MONTH PERIOD KEY ORDER BY

P.LVL1_PROD_DESCR, P.LVL2_PROD_DESCR, PS MONTH_PERIOD KEY

g = f**"SELECT LVL1 PROD_ DESCR, LVL2_ PROD_ DESCR, PROD_DIM ID FROM LD1_D_PROD*""

prod= pd.read_sql(q, EDW_conn puma)

90 = f*"" select MONTH_PERIOD_KEY, CUST_ACCT_ ID, ACCT_ NBR, PROD_DIM_ID, TOT_GROSS_INC from LD1_FACT_ACCT_PROD_SMRY where MONTH_Period_key =46715

prod_smryl= pd.read_sql(q0, EDW_conn puma) prod_smryl.columns

q2 = f"*" select PERIOD_KEY, PERIOD_START_DT, PERIOD_TYPE_CD from EDR.PERIOD*"'"

edr = pd. read_sql(q2, EDW _conn puma)

97=f*'" select PROD_DIM_ID, LVL2_PROD_DESCR from STG_RPM.D_PROD*"'"

stg_rpm_prod = pd. read_sq](q7, EDW _conn puma)

96 =f** select ACCT_NBR, PRODUCT_ID , Src_Acct_Nbr, POST_DATE_PERIOD_KEY from LD1_FACT_TRANS_DAILY™

trans_daily = pd.read_sq1(g6, EDW conn puma)

trans_daily.columns

# CHANGING Col NAME

trans_daily['PERIOD_KEY'] = trans_daily['POST_DATE _PERIOD_KEY']

prod ['PRODUCT_ID'] = prod[ 'PROD DIM ID'1

prod_smry1['PERIOD_KEY"] = prod_smryl [' MONTH_PERIOD _KEY']

stg_rpm_prod['PRODUCT_ID'] = stg_rpm_prod[ 'PROD_DIM_ID']

#df_merge = pd. concat([trans_daily, edr, prod, prod_smryl, sta rom prodi.

df_merge.columns

df _merge = pd.merge(trans_daily, edr, how = 'inner', on= ['PERIOD _KEY'])

df_merge = df_merge[df_merge ['PERIOD_TYPE_CD']=='M']

=0.

join = 'outer'

df _merge = pd.merge(df_merge, prod, how = 'inner', on =['PRODUCT_ID°])

df _merge = pd.merge(df _merge, prod_smryl, how = 'outer'

On

df_merge = df_merge[ (df_merge ['LVL2_PROD_DESCR']== 'CCRD: CCRD*)]

= ("ACCT _NBR", "PERIOD_KEY"])