sasjs/core
1
0
Fork 0
mirror of https://github.com/sasjs/core.git synced 2025-12-11 06:24:35 +00:00
Code Issues Projects Releases Wiki Activity

fix: enabling further debugging in mp_filterstore.sas

Browse Source
This commit is contained in:
munja
2021-12-26 20:32:56 +00:00
parent 9b1f0d7bcb
commit fdfe9b8250
2 changed files with 96 additions and 62 deletions
Download Patch File Download Diff File Expand all files Collapse all files

79
all.sas
View File

@@ -5311,42 +5311,16 @@ run;
,mac=mp_filterstore ,mac=mp_filterstore
,msg=%str(syscc=&syscc after hash check) ,msg=%str(syscc=&syscc after hash check)
) )
%mp_abort(iftrue= ("&filter_hash"=" ") %mp_abort(iftrue= ("&filter_hash "=" ")
,mac=mp_filterstore ,mac=mp_filterstore
,msg=%str(problem with filter_hash generation) ,msg=%str(problem with filter_hash generation)
) )
%if %mf_nobs(&outresult)=0 %then %do; %if %mf_nobs(&outresult)=0 %then %do;
/* update detail table first */ /* first update summary table */
%let ds2=%mf_getuniquename(prefix=filterdetail);
data &ds2;
if 0 then set &filter_detail;
set &queryds;
format filter_hash $hex32. filter_line 8.;
filter_hash="&filter_hash";
filter_line=_n_;
PROCESSED_DTTM=%sysfunc(datetime());
run;
%mp_lockanytable(LOCK,
lib=%scan(&filter_detail,1,.)
,ds=%scan(&filter_detail,2,.)
,ref=MP_FILTERSTORE update - &filter_hash
,ctl_ds=&lock_table
)
proc append base=&filter_detail data=&ds2;
run;
%mp_lockanytable(UNLOCK,
lib=%scan(&filter_detail,1,.)
,ds=%scan(&filter_detail,2,.)
,ref=MP_FILTERSTORE update - &filter_hash
,ctl_ds=&lock_table
)
/* now update summary table */
%let ds3=%mf_getuniquename(prefix=filtersum); %let ds3=%mf_getuniquename(prefix=filtersum);
data &ds3; data work.&ds3;
if 0 then set &filter_summary; if 0 then set &filter_summary;
filter_table=symget('libds'); filter_table=symget('libds');
filter_hash="&filter_hash"; filter_hash="&filter_hash";
@@ -5358,7 +5332,7 @@ run;
%mp_lockanytable(LOCK, %mp_lockanytable(LOCK,
lib=%scan(&filter_summary,1,.) lib=%scan(&filter_summary,1,.)
,ds=%scan(&filter_summary,2,.) ,ds=%scan(&filter_summary,2,.)
,ref=MP_FILTERSTORE update - &filter_hash ,ref=MP_FILTERSTORE summary update - &filter_hash
,ctl_ds=&lock_table ,ctl_ds=&lock_table
) )
@@ -5380,21 +5354,64 @@ run;
%mp_lockanytable(UNLOCK, %mp_lockanytable(UNLOCK,
lib=%scan(&filter_summary,1,.) lib=%scan(&filter_summary,1,.)
,ds=%scan(&filter_summary,2,.) ,ds=%scan(&filter_summary,2,.)
,ref=MP_FILTERSTORE update - &filter_hash ,ref=MP_FILTERSTORE summary update - &filter_hash
,ctl_ds=&lock_table ,ctl_ds=&lock_table
) )
%if &syscc ne 0 %then %do;
data _null_;
set &ds4;
putlog (_all_)(=);
run;
%goto err;
%end;
data &outresult; data &outresult;
set &filter_summary; set &filter_summary;
where filter_hash="&filter_hash"; where filter_hash="&filter_hash";
run; run;
/* Next, update detail table */
%let ds2=%mf_getuniquename(prefix=filterdetail);
data &ds2;
if 0 then set &filter_detail;
set &queryds;
format filter_hash $hex32. filter_line 8.;
filter_hash="&filter_hash";
filter_line=_n_;
PROCESSED_DTTM=%sysfunc(datetime());
run;
%mp_lockanytable(LOCK,
lib=%scan(&filter_detail,1,.)
,ds=%scan(&filter_detail,2,.)
,ref=MP_FILTERSTORE update - &filter_hash
,ctl_ds=&lock_table
)
proc append base=&filter_detail data=&ds2;
run;
%mp_lockanytable(UNLOCK,
lib=%scan(&filter_detail,1,.)
,ds=%scan(&filter_detail,2,.)
,ref=MP_FILTERSTORE detail update &filter_hash
,ctl_ds=&lock_table
)
%if &syscc ne 0 %then %do;
data _null_;
set &ds2;
putlog (_all_)(=);
run;
%goto err;
%end;
%end; %end;
proc sort data=&filter_detail(where=(filter_hash="&filter_hash")) out=&outquery; proc sort data=&filter_detail(where=(filter_hash="&filter_hash")) out=&outquery;
by filter_line; by filter_line;
run; run;
%err:
%mp_abort(iftrue= (&syscc ne 0) %mp_abort(iftrue= (&syscc ne 0)
,mac=mp_filterstore ,mac=mp_filterstore
,msg=%str(syscc=&syscc on macro exit) ,msg=%str(syscc=&syscc on macro exit)

79
base/mp_filterstore.sas
View File

@@ -121,42 +121,16 @@ run;
,mac=mp_filterstore ,mac=mp_filterstore
,msg=%str(syscc=&syscc after hash check) ,msg=%str(syscc=&syscc after hash check)
) )
%mp_abort(iftrue= ("&filter_hash"=" ") %mp_abort(iftrue= ("&filter_hash "=" ")
,mac=mp_filterstore ,mac=mp_filterstore
,msg=%str(problem with filter_hash generation) ,msg=%str(problem with filter_hash generation)
) )
%if %mf_nobs(&outresult)=0 %then %do; %if %mf_nobs(&outresult)=0 %then %do;
/* update detail table first */ /* first update summary table */
%let ds2=%mf_getuniquename(prefix=filterdetail);
data &ds2;
if 0 then set &filter_detail;
set &queryds;
format filter_hash $hex32. filter_line 8.;
filter_hash="&filter_hash";
filter_line=_n_;
PROCESSED_DTTM=%sysfunc(datetime());
run;
%mp_lockanytable(LOCK,
lib=%scan(&filter_detail,1,.)
,ds=%scan(&filter_detail,2,.)
,ref=MP_FILTERSTORE update - &filter_hash
,ctl_ds=&lock_table
)
proc append base=&filter_detail data=&ds2;
run;
%mp_lockanytable(UNLOCK,
lib=%scan(&filter_detail,1,.)
,ds=%scan(&filter_detail,2,.)
,ref=MP_FILTERSTORE update - &filter_hash
,ctl_ds=&lock_table
)
/* now update summary table */
%let ds3=%mf_getuniquename(prefix=filtersum); %let ds3=%mf_getuniquename(prefix=filtersum);
data &ds3; data work.&ds3;
if 0 then set &filter_summary; if 0 then set &filter_summary;
filter_table=symget('libds'); filter_table=symget('libds');
filter_hash="&filter_hash"; filter_hash="&filter_hash";
@@ -168,7 +142,7 @@ run;
%mp_lockanytable(LOCK, %mp_lockanytable(LOCK,
lib=%scan(&filter_summary,1,.) lib=%scan(&filter_summary,1,.)
,ds=%scan(&filter_summary,2,.) ,ds=%scan(&filter_summary,2,.)
,ref=MP_FILTERSTORE update - &filter_hash ,ref=MP_FILTERSTORE summary update - &filter_hash
,ctl_ds=&lock_table ,ctl_ds=&lock_table
) )
@@ -190,21 +164,64 @@ run;
%mp_lockanytable(UNLOCK, %mp_lockanytable(UNLOCK,
lib=%scan(&filter_summary,1,.) lib=%scan(&filter_summary,1,.)
,ds=%scan(&filter_summary,2,.) ,ds=%scan(&filter_summary,2,.)
,ref=MP_FILTERSTORE update - &filter_hash ,ref=MP_FILTERSTORE summary update - &filter_hash
,ctl_ds=&lock_table ,ctl_ds=&lock_table
) )
%if &syscc ne 0 %then %do;
data _null_;
set &ds4;
putlog (_all_)(=);
run;
%goto err;
%end;
data &outresult; data &outresult;
set &filter_summary; set &filter_summary;
where filter_hash="&filter_hash"; where filter_hash="&filter_hash";
run; run;
/* Next, update detail table */
%let ds2=%mf_getuniquename(prefix=filterdetail);
data &ds2;
if 0 then set &filter_detail;
set &queryds;
format filter_hash $hex32. filter_line 8.;
filter_hash="&filter_hash";
filter_line=_n_;
PROCESSED_DTTM=%sysfunc(datetime());
run;
%mp_lockanytable(LOCK,
lib=%scan(&filter_detail,1,.)
,ds=%scan(&filter_detail,2,.)
,ref=MP_FILTERSTORE update - &filter_hash
,ctl_ds=&lock_table
)
proc append base=&filter_detail data=&ds2;
run;
%mp_lockanytable(UNLOCK,
lib=%scan(&filter_detail,1,.)
,ds=%scan(&filter_detail,2,.)
,ref=MP_FILTERSTORE detail update &filter_hash
,ctl_ds=&lock_table
)
%if &syscc ne 0 %then %do;
data _null_;
set &ds2;
putlog (_all_)(=);
run;
%goto err;
%end;
%end; %end;
proc sort data=&filter_detail(where=(filter_hash="&filter_hash")) out=&outquery; proc sort data=&filter_detail(where=(filter_hash="&filter_hash")) out=&outquery;
by filter_line; by filter_line;
run; run;
%err:
%mp_abort(iftrue= (&syscc ne 0) %mp_abort(iftrue= (&syscc ne 0)
,mac=mp_filterstore ,mac=mp_filterstore
,msg=%str(syscc=&syscc on macro exit) ,msg=%str(syscc=&syscc on macro exit)