1%macro irmst_get_unagg_data(ds_in_agg_rules_config=,
3 ds_in_bsp_data_config=,
11 create table work.ds_out_agg_rules_config as
15 from &ds_in_agg_rules_config. as rules
16 inner join &ds_in_bep_summary. as summary
17 on upcase(rules.tgt_table_schema_nm) = upcase(summary.dataDefSchemaName)
18 and upcase(rules.src_table_schema_nm) ne upcase(rules.tgt_table_schema_nm)
19 and upcase(resolve(rules.tgt_table_schema_ver)) = upcase(resolve(summary.dataDefSchemaVersion))
20 ) as config, &ds_in_bsp_data_config. as bsp_cfg
21 where upcase(config.src_table_schema_nm) = upcase(bsp_cfg.source_data_name)
22 and upcase(resolve(config.src_table_schema_ver)) = upcase(bsp_cfg.source_data_version)
27 data work.data_extraction_config;
28 set &ds_in_bep_summary. (keep = planningDataKey dataDefSchemaName)
35 source_data_name = dataDefSchemaName;
36 analysis_data_key = planningDataKey;
39 call symputx(cats("planning_data_", put(_N_, 8.)), dataDefSchemaName, "L");
41 if last then call symputx("n_keys", _N_, "L");
45 %let out_libref_tmp = &out_libref.;
48 %irm_rgf_retrieve_data(dr_libref = &dr_libref.
49 , dr_library_name = &dr_library_name.
50 , ds_in = work.data_extraction_config
51 , ds_out = work.export_summary
53 , rgf_protocol = &rgf_protocol.
54 , rgf_host = &rgf_host.
55 , rgf_service = &rgf_service.
56 , rgf_solution = &rgf_solution.
57 , rgf_port = &rgf_port.
58 , tgt_ticket = &tgt_ticket.
62 %let out_libref = &out_libref_tmp.;
68 from work.ds_out_agg_rules_config
69 where tgt_table_schema_nm ="&&planning_data_&i.."
77 select distinct tgt_tbl_val_col
78 into: tgt_cols separated by ' '
81 %do m=1 %to %sysfunc(countw(&tgt_cols.," "));
82 %let var_exist=%rsk_varexist(&&planning_data_&i.., %scan(&tgt_cols.,&m.," "));
83 %if &var_exist.=0 %then %do;
85 alter table work.&&planning_data_&i.. add %scan(&tgt_cols.,&m.," ") num(8);
89 data &out_libref..&&planning_data_&i..;
90 set work.&&planning_data_&i..;
95data &ds_out_info_tbl.;