You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
773 lines
43 KiB
773 lines
43 KiB
--Freemarker Template |
|
<#include "SQL_lingua_franca"/> |
|
<#include "SuperX_general"/> |
|
|
|
|
|
<#assign etl_jobs = [ |
|
{"uniquename":"sx_select_mask", "name":"Maske entladen", "systeminfo_id":270 ,"logfile":""}, |
|
{"uniquename":"sx_insert_mask", "name":"Maske hochladen", "systeminfo_id":270 ,"logfile":""}, |
|
{"uniquename":"kern_konstanten_update", "name":"Konstanten aktualisieren", "systeminfo_id":270 ,"logfile":""}, |
|
{"uniquename":"sichten_unload", "name":"Sichten entladen", "systeminfo_id":270 ,"logfile":""}, |
|
{"uniquename":"sichten_upload", "name":"Sichten hochladen", "systeminfo_id":270 ,"logfile":""}, |
|
{"uniquename":"sos_gewichtung_unload", "name":"Gewichtungen entladen", "systeminfo_id":270 ,"logfile":""}, |
|
{"uniquename":"qa_project_unload", "name":"Testfallprojekte entladen", "systeminfo_id":260 ,"logfile":""}, |
|
{"uniquename":"rpta_column_layout_unload", "name":"Spaltenlayout entladen", "systeminfo_id":330 ,"logfile":""}, |
|
{"uniquename":"rpta_column_layout_upload", "name":"Spaltenlayout hochladen", "systeminfo_id":330 ,"logfile":""}, |
|
{"uniquename":"sxc_stud_zugang_abgang_aggr_unload", "name":"Studierendenströme für SXC entladen", "systeminfo_id":360 ,"logfile":""}, |
|
{"uniquename":"sxc_stud_zugang_abgang_aggr_upload", "name":"Studierendenströme für SXC hochladen", "systeminfo_id":360 ,"logfile":""} |
|
|
|
|
|
] /> |
|
|
|
<#assign etl_job_params = [ |
|
{"etl_job":"sx_select_mask","param_name":"TID", "name":"Maskennr.", "param_default":""}, |
|
{"etl_job":"sx_select_mask","param_name":"PATH_TO_OUTPUTFILE", "name":"Ausgabedatei", "param_default":"$SUPERX_DIR/db/masken/$TID.xml"}, |
|
{"etl_job":"sx_select_mask","param_name":"FORMAT", "name":"Ausgabeformat", "param_default":"XML"}, |
|
|
|
{"etl_job":"sx_insert_mask","param_name":"TID", "name":"Maskennr.", "param_default":""}, |
|
{"etl_job":"sx_insert_mask","param_name":"PATH_TO_INPUTFILE", "name":"Eingabepfad", "param_default":"$SUPERX_DIR/db/masken/$TID.xml"}, |
|
{"etl_job":"sx_insert_mask","param_name":"FORMAT", "name":"Format", "param_default":"XML"}, |
|
|
|
{"etl_job":"kern_konstanten_update","param_name":"SUPERX_DIR", "name":"Superx-Pfad zu WEB-INF/conf/edustore", "param_default":"$WEBAPP/WEB-INF/conf/edustore"}, |
|
{"etl_job":"kern_konstanten_update","param_name":"PATH_TO_INPUTFILE", "name":"Eingabepfad", "param_default":"$SUPERX_DIR/db/install/schluesseltabellen/kern_feste_konstanten_fuellen.sql"}, |
|
|
|
{"etl_job":"sichten_unload","param_name":"SICHTEN_TID", "name":"Sicht", "param_default":""}, |
|
{"etl_job":"sichten_unload","param_name":"NAME_INTERN", "name":"ID", "param_default":""}, |
|
{"etl_job":"sichten_unload","param_name":"PATH_TO_OUTPUTFILE", "name":"Ausgabedatei", "param_default":"$SUPERX_DIR/db/masken/sichten.xml"}, |
|
{"etl_job":"sichten_unload","param_name":"FORMAT", "name":"Ausgabeformat", "param_default":"XML"}, |
|
|
|
{"etl_job":"sichten_upload","param_name":"SICHTEN_TID", "name":"Sicht", "param_default":""}, |
|
{"etl_job":"sichten_upload","param_name":"NAME_INTERN", "name":"ID", "param_default":""}, |
|
{"etl_job":"sichten_upload","param_name":"PATH_TO_INPUTFILE", "name":"Eingabedatei", "param_default":""}, |
|
{"etl_job":"sichten_upload","param_name":"FORMAT", "name":"Format", "param_default":"XML"}, |
|
|
|
{"etl_job":"qa_project_unload","param_name":"QA_PROJECT_ID", "name":"Testfall-Projekt", "param_default":""}, |
|
{"etl_job":"qa_project_unload","param_name":"PATH_TO_OUTPUTFILE", "name":"Ausgabedatei", "param_default":"$SUPERX_DIR/db/masken/qa_project_$QA_PROJECT_ID.xml"}, |
|
{"etl_job":"qa_project_unload","param_name":"FORMAT", "name":"Ausgabeformat", "param_default":"XML"}, |
|
|
|
{"etl_job":"rpta_column_layout_unload","param_name":"RPTA_COLUMN_LAYOUT_TID", "name":"Spaltenlayout", "param_default":""}, |
|
{"etl_job":"rpta_column_layout_unload","param_name":"PATH_TO_OUTPUTFILE", "name":"Ausgabedatei", "param_default":"$SUPERX_DIR/db/masken/rpta_column_layout_$RPTA_COLUMN_LAYOUT_UNIQUENAME.xml"}, |
|
{"etl_job":"rpta_column_layout_unload","param_name":"FORMAT", "name":"Ausgabeformat", "param_default":"XML"}, |
|
|
|
{"etl_job":"rpta_column_layout_upload","param_name":"SYSTEMINFO_ID", "name":"Komponente", "param_default":""}, |
|
{"etl_job":"rpta_column_layout_upload","param_name":"RPTA_COLUMN_LAYOUT_TID", "name":"ID", "param_default":""}, |
|
{"etl_job":"rpta_column_layout_upload","param_name":"PATH_TO_INPUTFILE", "name":"Eingabedatei", "param_default":""}, |
|
{"etl_job":"rpta_column_layout_upload","param_name":"FORMAT", "name":"Format", "param_default":"XML"}, |
|
|
|
{"etl_job":"sxc_stud_zugang_abgang_aggr_unload","param_name":"HS_NR", "name":"Hochschule", "param_default":""}, |
|
{"etl_job":"sxc_stud_zugang_abgang_aggr_unload","param_name":"PATH_TO_OUTPUTFILE", "name":"Ausgabedatei", "param_default":"$SUPERX_DIR/db/masken/rpta_column_layout_$RPTA_COLUMN_LAYOUT_UNIQUENAME.xml"}, |
|
{"etl_job":"sxc_stud_zugang_abgang_aggr_unload","param_name":"FORMAT", "name":"Ausgabeformat", "param_default":"XML"}, |
|
|
|
{"etl_job":"sxc_stud_zugang_abgang_aggr_upload","param_name":"SYSTEMINFO_ID", "name":"Komponente", "param_default":""}, |
|
{"etl_job":"sxc_stud_zugang_abgang_aggr_upload","param_name":"HS_NR", "name":"ID", "param_default":""}, |
|
{"etl_job":"sxc_stud_zugang_abgang_aggr_upload","param_name":"PATH_TO_INPUTFILE", "name":"Eingabedatei", "param_default":""}, |
|
{"etl_job":"sxc_stud_zugang_abgang_aggr_upload","param_name":"FORMAT", "name":"Format", "param_default":"XML"}, |
|
|
|
|
|
{"etl_job":"sos_gewichtung_unload","param_name":"SYSTEMINFO_ID", "name":"Komponente", "param_default":""}, |
|
{"etl_job":"sos_gewichtung_unload","param_name":"PATH_TO_OUTPUTFILE", "name":"Ausgabedatei", "param_default":"$SUPERX_DIR/db/db/module/sos/schluesseltabellen/sichten_$SYSTEMINFO_ID.xml"}, |
|
{"etl_job":"sos_gewichtung_unload","param_name":"FORMAT", "name":"Ausgabeformat", "param_default":"XML"} |
|
|
|
] /> |
|
|
|
<#assign etl_steps = [ |
|
{"etl_job":"sx_select_mask", "uniquename":"unload_masken_stammdaten", "name":"Masken-Daten entladen", "type":"MSG"}, |
|
{"etl_job":"sx_select_mask", "uniquename":"unload_maskeninfo", "name":"Maskeninfo entladen", "type":"UNLOAD", "parent":"unload_masken_stammdaten"}, |
|
{"etl_job":"sx_select_mask", "uniquename":"unload_felderinfo", "name":"felderinfo entladen", "type":"UNLOAD", "parent":"unload_masken_stammdaten"}, |
|
{"etl_job":"sx_select_mask", "uniquename":"unload_masken_felder_bez", "name":"masken_felder_bez entladen", "type":"UNLOAD", "parent":"unload_masken_stammdaten"}, |
|
{"etl_job":"sx_select_mask", "uniquename":"unload_sachgeb_maske_bez", "name":"sachgeb_maske_bez entladen", "type":"UNLOAD", "parent":"unload_masken_stammdaten"}, |
|
{"etl_job":"sx_select_mask", "uniquename":"unload_maske_system_bez", "name":"maske_system_bez entladen", "type":"UNLOAD", "parent":"unload_masken_stammdaten"}, |
|
{"etl_job":"sx_select_mask", "uniquename":"unload_themenbaum", "name":"themenbaum entladen", "type":"UNLOAD"}, |
|
{"etl_job":"sx_select_mask", "uniquename":"unload_sx_mask_style", "name":"sx_mask_style entladen", "type":"UNLOAD"}, |
|
{"etl_job":"sx_select_mask", "uniquename":"unload_sx_stylesheets", "name":"sx_stylesheets entladen", "type":"UNLOAD"}, |
|
{"etl_job":"sx_select_mask", "uniquename":"unload_stylesheet_field", "name":"stylesheet_field entladen", "type":"UNLOAD"}, |
|
{"etl_job":"sx_select_mask", "uniquename":"unload_captions", "name":"captions entladen", "type":"UNLOAD"}, |
|
|
|
{"etl_job":"sx_insert_mask", "uniquename":"create_tmp_etl_masken", "name":"Tabellen tmp_etl_masken erzeugen", "type":"DOSQL" }, |
|
|
|
{"etl_job":"sx_insert_mask", "uniquename":"upload_maskeninfo", "name":"Maskeninfo hochladen", "type":"LOAD" }, |
|
|
|
{"etl_job":"sx_insert_mask", "uniquename":"upload_felderinfo", "name":"felderinfo hochladen", "type":"LOAD" }, |
|
|
|
{"etl_job":"sx_insert_mask", "uniquename":"upload_masken_felder_bez", "name":"masken_felder_bez hochladen", "type":"LOAD" }, |
|
|
|
{"etl_job":"sx_insert_mask", "uniquename":"upload_sachgeb_maske_bez", "name":"sachgeb_maske_bez hochladen", "type":"LOAD" }, |
|
|
|
{"etl_job":"sx_insert_mask", "uniquename":"upload_maske_system_bez", "name":"maske_system_bez hochladen", "type":"LOAD" }, |
|
{"etl_job":"sx_insert_mask", "uniquename":"create_tmp_etl_themenbaum", "name":"Tabelle tmp_etl_themenbaum erzeugen", "type":"DOSQL" }, |
|
{"etl_job":"sx_insert_mask", "uniquename":"create_tmp_etl_stylesheets", "name":"Tabelle tmp_etl_stylesheets erzeugen", "type":"DOSQL" }, |
|
{"etl_job":"sx_insert_mask", "uniquename":"create_tmp_etl_sx_captions", "name":"Tabelle tmp_etl_sx_captions erzeugen", "type":"DOSQL" }, |
|
|
|
{"etl_job":"sx_insert_mask", "uniquename":"upload_tmp_etl_themenbaum", "name":"tmp_etl_themenbaum hochladen", "type":"LOAD" }, |
|
{"etl_job":"sx_insert_mask", "uniquename":"upload_tmp_etl_stylesheets", "name":"tmp_etl_stylesheets hochladen", "type":"LOAD" }, |
|
{"etl_job":"sx_insert_mask", "uniquename":"upload_tmp_etl_mask_style", "name":"tmp_etl_mask_style hochladen", "type":"LOAD" }, |
|
{"etl_job":"sx_insert_mask", "uniquename":"upload_tmp_etl_stylesheet_field", "name":"tmp_etl_stylesheet_field hochladen", "type":"LOAD" }, |
|
{"etl_job":"sx_insert_mask", "uniquename":"upload_tmp_sx_captions", "name":"tmp_sx_captions hochladen", "type":"LOAD" }, |
|
|
|
{"etl_job":"sx_insert_mask", "uniquename":"masken_fuellen", "name":"masken_fuellen", "type":"DOSQL" }, |
|
{"etl_job":"sx_insert_mask", "uniquename":"themenbaum_fuellen", "name":"themenbaum_fuellen", "type":"DOSQL" }, |
|
{"etl_job":"sx_insert_mask", "uniquename":"sx_stylesheets_fuellen", "name":"sx_stylesheets_fuellen", "type":"DOSQL" }, |
|
{"etl_job":"sx_insert_mask", "uniquename":"sx_captions_fuellen", "name":"sx_captions_fuellen", "type":"DOSQL" }, |
|
|
|
{"etl_job":"kern_konstanten_update", "uniquename":"kern_konstanten_update", "name":"Kern Konstanten aktualisieren", "type":"DOSQL" }, |
|
|
|
{"etl_job":"sichten_unload", "uniquename":"unload_sichten_ges", "name":"Sichten entladen", "type":"MSG"}, |
|
{"etl_job":"sichten_unload", "uniquename":"unload_sichtentab", "name":"Sichten entladen", "type":"UNLOAD", "parent":"unload_sichten_ges"}, |
|
{"etl_job":"sichten_unload", "uniquename":"unload_sichten_sachgeb", "name":"Sachgebiete von Sichten entladen", "type":"UNLOAD", "parent":"unload_sichten_ges"}, |
|
|
|
{"etl_job":"sichten_upload", "uniquename":"create_tmp_etl_sichten", "name":"Tabelle tmp_etl_sichten erzeugen", "type":"DOSQL" }, |
|
{"etl_job":"sichten_upload", "uniquename":"upload_tmp_etl_sichten", "name":"tmp_etl_sichten hochladen", "type":"LOAD" }, |
|
{"etl_job":"sichten_upload", "uniquename":"upload_tmp_etl_sachgeb_sichtarten", "name":"upload_tmp_etl_sachgeb_sichtarten hochladen", "type":"LOAD" }, |
|
{"etl_job":"sichten_upload", "uniquename":"trans_etl_sichten", "name":"etl_sichten füllen", "type":"DOSQL" }, |
|
|
|
{"etl_job":"sos_gewichtung_unload", "uniquename":"unload_sos_gewichtung_ges", "name":"Gewichtungen entladen", "type":"MSG"}, |
|
{"etl_job":"sos_gewichtung_unload", "uniquename":"unload_sos_gewichtung", "name":"Gewichtungen entladen", "type":"UNLOAD", "parent":"unload_sos_gewichtung_ges"}, |
|
|
|
{"etl_job":"qa_project_unload", "uniquename":"qa_project_unload_ges", "name":"Testfall-Projekt entladen", "type":"MSG"}, |
|
{"etl_job":"qa_project_unload", "uniquename":"unload_qa_project_tab", "name":"Projekte entladen", "type":"UNLOAD", "parent":"qa_project_unload_ges"}, |
|
{"etl_job":"qa_project_unload", "uniquename":"unload_qa_resultset_tab", "name":"Resultsets entladen", "type":"UNLOAD", "parent":"qa_project_unload_ges"}, |
|
{"etl_job":"qa_project_unload", "uniquename":"unload_qa_dbtest_tab", "name":"DB-Tests entladen", "type":"UNLOAD", "parent":"qa_project_unload_ges"}, |
|
{"etl_job":"qa_project_unload", "uniquename":"unload_qa_dbtest_assertion_tab", "name":"DB-Test Erwartungen entladen", "type":"UNLOAD", "parent":"qa_project_unload_ges"}, |
|
{"etl_job":"qa_project_unload", "uniquename":"unload_qa_dbtest2project_tab", "name":"DB-Test zu Projekt entladen", "type":"UNLOAD", "parent":"qa_project_unload_ges"}, |
|
{"etl_job":"qa_project_unload", "uniquename":"unload_qa_mask_execution_tab", "name":"Masken-Tests entladen", "type":"UNLOAD", "parent":"qa_project_unload_ges"}, |
|
{"etl_job":"qa_project_unload", "uniquename":"unload_qa_mask_execution_assert_tab", "name":"Masken-Test Erwartungen entladen", "type":"UNLOAD", "parent":"qa_project_unload_ges"}, |
|
{"etl_job":"qa_project_unload", "uniquename":"unload_qa_mask_execution2project_tab", "name":"Masken-Test zu Projekt entladen", "type":"UNLOAD", "parent":"qa_project_unload_ges"}, |
|
|
|
{"etl_job":"rpta_column_layout_unload", "uniquename":"rpta_column_layout_unload_ges", "name":"Spaltenlayout-Projekt entladen", "type":"MSG"}, |
|
{"etl_job":"rpta_column_layout_unload", "uniquename":"unload_rpta_resultset_tab", "name":"Resultset entladen", "type":"UNLOAD", "parent":"rpta_column_layout_unload_ges"}, |
|
{"etl_job":"rpta_column_layout_unload", "uniquename":"unload_rpta_column_layout_tab", "name":"Spaltenlayout entladen", "type":"UNLOAD", "parent":"rpta_column_layout_unload_ges"}, |
|
{"etl_job":"rpta_column_layout_unload", "uniquename":"unload_rpta_column_tab", "name":"Spalten entladen", "type":"UNLOAD", "parent":"rpta_column_layout_unload_ges"}, |
|
{"etl_job":"rpta_column_layout_unload", "uniquename":"unload_rpta_column2layout_tab", "name":"Spalten zu Layout entladen", "type":"UNLOAD", "parent":"rpta_column_layout_unload_ges"}, |
|
|
|
{"etl_job":"rpta_column_layout_upload", "uniquename":"create_tmp_rpta_column_layout", "name":"Tabelle tmp_rpta_column_layout erzeugen", "type":"DOSQL" }, |
|
{"etl_job":"rpta_column_layout_upload", "uniquename":"upload_rpta_resultset_tab", "name":"tmp_rpta_resultset hochladen", "type":"LOAD" }, |
|
{"etl_job":"rpta_column_layout_upload", "uniquename":"upload_rpta_column_layout_tab", "name":"tmp_rpta_column_layout hochladen", "type":"LOAD" }, |
|
{"etl_job":"rpta_column_layout_upload", "uniquename":"upload_rpta_column_tab", "name":"tmp_rpta_column hochladen", "type":"LOAD" }, |
|
{"etl_job":"rpta_column_layout_upload", "uniquename":"upload_rpta_column2layout_tab", "name":"tmp_rpta_column2layout hochladen", "type":"LOAD" }, |
|
{"etl_job":"rpta_column_layout_upload", "uniquename":"trans_rpta_column_layout", "name":"rpta_column_layout füllen", "type":"DOSQL" }, |
|
|
|
{"etl_job":"sxc_stud_zugang_abgang_aggr_unload", "uniquename":"sxc_stud_zugang_abgang_aggr_unload_ges", "name":"Studierendenströme für SXC entladen", "type":"MSG"}, |
|
{"etl_job":"sxc_stud_zugang_abgang_aggr_unload", "uniquename":"unload_sxc_stud_zugang_abgang_aggr_tab", "name":"sxc_stud_zugang_abgang_aggr entladen", "type":"UNLOAD", "parent":"sxc_stud_zugang_abgang_aggr_unload_ges"}, |
|
|
|
{"etl_job":"sxc_stud_zugang_abgang_aggr_upload", "uniquename":"create_tmp_sxc_stud_zugang_abgang_aggr", "name":"Tabelle tmp_sxc_stud_zugang_abgang_aggr erzeugen", "type":"DOSQL" }, |
|
{"etl_job":"sxc_stud_zugang_abgang_aggr_upload", "uniquename":"upload_sxc_stud_zugang_abgang_aggr_tab", "name":"tmp_sxc_stud_zugang_abgang_aggr hochladen", "type":"LOAD" }, |
|
{"etl_job":"sxc_stud_zugang_abgang_aggr_upload", "uniquename":"trans_sxc_stud_zugang_abgang_aggr", "name":"sxc_stud_zugang_abgang_aggr füllen", "type":"DOSQL" } |
|
|
|
] /> |
|
|
|
<#assign etl_step_properties = [ |
|
{"etl_step":"unload_masken_stammdaten","prop_name":"msg", "prop_value":"Entlade Stammdaten Maske/n $TID" }, |
|
{"etl_step":"unload_maskeninfo","prop_name":"select_stmt", "prop_value":"select tid,name,select_stmt,xil_proplist,chart_xtitel,chart_ytitel,erlaeuterung,cleanup_stmt,default_file,frontend,breite,hoehe,ampel,hilfe,hinweis from maskeninfo where tid in ($TID)" }, |
|
{"etl_step":"unload_felderinfo","prop_name":"select_stmt", "prop_value":"select tid ,name,nummer,x,y,buttonbreite,feldbreite,zeilenanzahl,typ,laenge,obligatorisch,art,relation,attribut,defaultwert from felderinfo where tid in (select felderinfo_id from masken_felder_bez where maskeninfo_id in ( $TID )) order by tid" }, |
|
{"etl_step":"unload_masken_felder_bez","prop_name":"select_stmt", "prop_value":"select maskeninfo_id,felderinfo_id from masken_felder_bez where maskeninfo_id in ( $TID ) order by 1,2" }, |
|
{"etl_step":"unload_sachgeb_maske_bez","prop_name":"select_stmt", "prop_value":"select sachgebiete_id,maskeninfo_id from sachgeb_maske_bez where maskeninfo_id in ( $TID ) order by 1,2" }, |
|
{"etl_step":"unload_maske_system_bez","prop_name":"select_stmt", "prop_value":"select maskeninfo_id,systeminfo_id from maske_system_bez where maskeninfo_id in ( $TID ) order by 1,2" }, |
|
{"etl_step":"unload_themenbaum","prop_name":"select_stmt", "prop_value":"select name,maskeninfo_id,parent,(select name from themenbaum where tid=T.parent) as parent_name,gueltig_seit,gueltig_bis,erlaeuterung,sort,css_class from themenbaum T where maskeninfo_id in ( $TID ) union select name,maskeninfo_id,parent,(select name from themenbaum where tid=T.parent) as parent_name, gueltig_seit,gueltig_bis,erlaeuterung,sort,css_class from themenbaum T where T.tid=(select T2.parent from themenbaum T2 where T2.maskeninfo_id in ( $TID )) order by 2,1" }, |
|
{"etl_step":"unload_sx_mask_style","prop_name":"select_stmt", "prop_value":"select maskeninfo_id,stylesheet_id,ord,(select filename from sx_stylesheets where tid=S.stylesheet_id) as stylesheet_filename from sx_mask_style S where maskeninfo_id in ( $TID ) order by 1,2,3" }, |
|
{"etl_step":"unload_sx_stylesheets","prop_name":"select_stmt", "prop_value":"select S.tid,S.filename,S.caption,S.description,S.relation,S.useragent,S.contenttype,S.is_generic,S.toolbar_icon_filepath,S.usage_resultset_data,S.stylesheet_type,S.jr_datasource from sx_stylesheets S, sx_mask_style M where S.tid=M.stylesheet_id and M.maskeninfo_id in ( $TID ) order by 1,2,3" }, |
|
{"etl_step":"unload_stylesheet_field","prop_name":"select_stmt", "prop_value":"select F.tid,F.stylesheet_id,S.filename as stylesheet_filename,F.tablename,F.fieldname FROM stylesheet_field F, sx_stylesheets S, sx_mask_style M where F.stylesheet_id=S.tid and S.tid=M.stylesheet_id and M.maskeninfo_id in ( $TID ) order by 1,2,3,4,5" }, |
|
{"etl_step":"unload_captions","prop_name":"select_stmt", "prop_value":"select id, table_name, field_name, record_no, locale, contents_short, contents_long, equalitystatus, sachgebiete_id, doku_link, export_to_glossar from sx_captions where table_name=''felderinfo'' and record_no in (select B.felderinfo_id from masken_felder_bez B where B.maskeninfo_id in ( $TID )) order by 1,2,3,4,5" }, |
|
|
|
{"etl_step":"create_tmp_etl_masken","prop_name":"PATH_TO_INPUTFILE", "prop_value":"$SUPERX_DIR/db/module/etl/schluesseltabellen/create_load_etl_masken.sql" }, |
|
|
|
{"etl_step":"upload_maskeninfo","prop_name":"target_table", "prop_value":"tmp_maskeninfo" }, |
|
{"etl_step":"upload_maskeninfo","prop_name":"format", "prop_value":"xml" }, |
|
{"etl_step":"upload_maskeninfo","prop_name":"search_path", "prop_value":"/etlAction/unload [@name=\"unload_maskeninfo\"]/rs/row" }, |
|
{"etl_step":"upload_maskeninfo","prop_name":"path_to_inputfile", "prop_value":"$PATH_TO_INPUTFILE" }, |
|
|
|
{"etl_step":"upload_felderinfo","prop_name":"target_table", "prop_value":"tmp_felderinfo" }, |
|
{"etl_step":"upload_felderinfo","prop_name":"format", "prop_value":"xml" }, |
|
{"etl_step":"upload_felderinfo","prop_name":"search_path", "prop_value":"/etlAction/unload [@name=\"unload_felderinfo\"]/rs/row" }, |
|
{"etl_step":"upload_felderinfo","prop_name":"path_to_inputfile", "prop_value":"$PATH_TO_INPUTFILE" }, |
|
|
|
{"etl_step":"upload_masken_felder_bez","prop_name":"target_table", "prop_value":"tmp_masken_felder_bez" }, |
|
{"etl_step":"upload_masken_felder_bez","prop_name":"format", "prop_value":"xml" }, |
|
{"etl_step":"upload_masken_felder_bez","prop_name":"search_path", "prop_value":"/etlAction/unload [@name=\"unload_masken_felder_bez\"]/rs/row" }, |
|
{"etl_step":"upload_masken_felder_bez","prop_name":"path_to_inputfile", "prop_value":"$PATH_TO_INPUTFILE" }, |
|
|
|
{"etl_step":"upload_sachgeb_maske_bez","prop_name":"target_table", "prop_value":"tmp_sachgeb_maske_bez" }, |
|
{"etl_step":"upload_sachgeb_maske_bez","prop_name":"format", "prop_value":"xml" }, |
|
{"etl_step":"upload_sachgeb_maske_bez","prop_name":"search_path", "prop_value":"/etlAction/unload [@name=\"unload_sachgeb_maske_bez\"]/rs/row" }, |
|
{"etl_step":"upload_sachgeb_maske_bez","prop_name":"path_to_inputfile", "prop_value":"$PATH_TO_INPUTFILE" }, |
|
|
|
{"etl_step":"upload_maske_system_bez","prop_name":"target_table", "prop_value":"tmp_maske_system_bez" }, |
|
{"etl_step":"upload_maske_system_bez","prop_name":"format", "prop_value":"xml" }, |
|
{"etl_step":"upload_maske_system_bez","prop_name":"search_path", "prop_value":"/etlAction/unload [@name=\"unload_maske_system_bez\"]/rs/row" }, |
|
{"etl_step":"upload_maske_system_bez","prop_name":"path_to_inputfile", "prop_value":"$PATH_TO_INPUTFILE" }, |
|
{"etl_step":"create_tmp_etl_themenbaum","prop_name":"PATH_TO_INPUTFILE", "prop_value":"$SUPERX_DIR/db/module/etl/schluesseltabellen/create_load_etl_themenbaum.sql" }, |
|
{"etl_step":"create_tmp_etl_stylesheets","prop_name":"PATH_TO_INPUTFILE", "prop_value":"$SUPERX_DIR/db/module/etl/schluesseltabellen/create_load_etl_stylesheets.sql" }, |
|
{"etl_step":"create_tmp_etl_sx_captions","prop_name":"PATH_TO_INPUTFILE", "prop_value":"$SUPERX_DIR/db/module/etl/schluesseltabellen/create_load_etl_sx_captions.sql" }, |
|
|
|
{"etl_step":"upload_tmp_etl_themenbaum","prop_name":"target_table", "prop_value":"tmp_etl_themenbaum" }, |
|
{"etl_step":"upload_tmp_etl_themenbaum","prop_name":"format", "prop_value":"xml" }, |
|
{"etl_step":"upload_tmp_etl_themenbaum","prop_name":"search_path", "prop_value":"/etlAction/unload [@name=\"unload_themenbaum\"]/rs/row" }, |
|
{"etl_step":"upload_tmp_etl_themenbaum","prop_name":"path_to_inputfile", "prop_value":"$PATH_TO_INPUTFILE" }, |
|
|
|
{"etl_step":"upload_tmp_etl_stylesheets","prop_name":"target_table", "prop_value":"tmp_etl_stylesheets" }, |
|
{"etl_step":"upload_tmp_etl_stylesheets","prop_name":"format", "prop_value":"xml" }, |
|
{"etl_step":"upload_tmp_etl_stylesheets","prop_name":"search_path", "prop_value":"/etlAction/unload [@name=\"unload_sx_stylesheets\"]/rs/row" }, |
|
{"etl_step":"upload_tmp_etl_stylesheets","prop_name":"path_to_inputfile", "prop_value":"$PATH_TO_INPUTFILE" }, |
|
|
|
{"etl_step":"upload_tmp_etl_mask_style","prop_name":"target_table", "prop_value":"tmp_etl_mask_style" }, |
|
{"etl_step":"upload_tmp_etl_mask_style","prop_name":"format", "prop_value":"xml" }, |
|
{"etl_step":"upload_tmp_etl_mask_style","prop_name":"search_path", "prop_value":"/etlAction/unload [@name=\"unload_sx_mask_style\"]/rs/row" }, |
|
{"etl_step":"upload_tmp_etl_mask_style","prop_name":"path_to_inputfile", "prop_value":"$PATH_TO_INPUTFILE" }, |
|
|
|
{"etl_step":"upload_tmp_etl_stylesheet_field","prop_name":"target_table", "prop_value":"tmp_etl_stylesheet_field" }, |
|
{"etl_step":"upload_tmp_etl_stylesheet_field","prop_name":"format", "prop_value":"xml" }, |
|
{"etl_step":"upload_tmp_etl_stylesheet_field","prop_name":"search_path", "prop_value":"/etlAction/unload [@name=\"unload_stylesheet_field\"]/rs/row" }, |
|
{"etl_step":"upload_tmp_etl_stylesheet_field","prop_name":"path_to_inputfile", "prop_value":"$PATH_TO_INPUTFILE" }, |
|
|
|
{"etl_step":"upload_tmp_sx_captions","prop_name":"target_table", "prop_value":"tmp_etl_sx_captions" }, |
|
{"etl_step":"upload_tmp_sx_captions","prop_name":"format", "prop_value":"xml" }, |
|
{"etl_step":"upload_tmp_sx_captions","prop_name":"search_path", "prop_value":"/etlAction/unload [@name=\"unload_captions\"]/rs/row" }, |
|
{"etl_step":"upload_tmp_sx_captions","prop_name":"path_to_inputfile", "prop_value":"$PATH_TO_INPUTFILE" }, |
|
|
|
|
|
{"etl_step":"create_tmp_etl_sichten","prop_name":"PATH_TO_INPUTFILE", "prop_value":"$SUPERX_DIR/db/module/etl/schluesseltabellen/create_load_etl_sichten.sql" }, |
|
{"etl_step":"upload_tmp_etl_sichten","prop_name":"target_table", "prop_value":"tmp_etl_sichten" }, |
|
{"etl_step":"upload_tmp_etl_sichten","prop_name":"format", "prop_value":"xml" }, |
|
{"etl_step":"upload_tmp_etl_sichten","prop_name":"search_path", "prop_value":"/etlAction/unload [@name=\"unload_sichtentab\"]/rs/row" }, |
|
{"etl_step":"upload_tmp_etl_sichten","prop_name":"path_to_inputfile", "prop_value":"$PATH_TO_INPUTFILE" }, |
|
|
|
{"etl_step":"upload_tmp_etl_sachgeb_sichtarten","prop_name":"target_table", "prop_value":"tmp_etl_sachgeb_sichtarten" }, |
|
{"etl_step":"upload_tmp_etl_sachgeb_sichtarten","prop_name":"format", "prop_value":"xml" }, |
|
{"etl_step":"upload_tmp_etl_sachgeb_sichtarten","prop_name":"search_path", "prop_value":"/etlAction/unload [@name=\"unload_sichten_sachgeb\"]/rs/row" }, |
|
{"etl_step":"upload_tmp_etl_sachgeb_sichtarten","prop_name":"path_to_inputfile", "prop_value":"$PATH_TO_INPUTFILE" }, |
|
|
|
|
|
{"etl_step":"trans_etl_sichten","prop_name":"PATH_TO_INPUTFILE", "prop_value":"$SUPERX_DIR/db/module/etl/schluesseltabellen/trans_etl_sichten.sql" }, |
|
|
|
{"etl_step":"masken_fuellen","prop_name":"PATH_TO_INPUTFILE", "prop_value":"$SUPERX_DIR/db/module/etl/schluesseltabellen/masken_fuellen.sql" }, |
|
{"etl_step":"themenbaum_fuellen","prop_name":"PATH_TO_INPUTFILE", "prop_value":"$SUPERX_DIR/db/module/etl/schluesseltabellen/themenbaum_fuellen.sql" }, |
|
{"etl_step":"sx_stylesheets_fuellen","prop_name":"PATH_TO_INPUTFILE", "prop_value":"$SUPERX_DIR/db/module/etl/schluesseltabellen/sx_stylesheets_fuellen.sql" }, |
|
{"etl_step":"sx_captions_fuellen","prop_name":"PATH_TO_INPUTFILE", "prop_value":"$SUPERX_DIR/db/module/etl/schluesseltabellen/sx_captions_fuellen.sql" }, |
|
|
|
{"etl_step":"kern_konstanten_update","prop_name":"path_to_inputfile", "prop_value":"$PATH_TO_INPUTFILE" }, |
|
|
|
{"etl_step":"unload_sichten_ges","prop_name":"msg", "prop_value":"Entlade Sichten" }, |
|
{"etl_step":"unload_sichtentab","prop_name":"select_stmt", "prop_value":"SELECT S.systeminfoid,S.art,S.type,S.name_intern,S.name,S.sortnr,S.quelle,S.standbutton,S.aktiv FROM sichten S where S.tid in ( $SICHTEN_TID ) order by art,sortnr ,name;" }, |
|
{"etl_step":"unload_sichten_sachgeb","prop_name":"select_stmt", "prop_value":"SELECT A.sichtart,A.sachgebiete_id FROM sachgeb_sichtarten A where A.sichtart in (select distinct S.art from sichten S where S.tid in ( $SICHTEN_TID )) order by 1,2;" }, |
|
|
|
{"etl_step":"unload_sos_gewichtung_ges","prop_name":"msg", "prop_value":"Entlade Gewichtungen Komponente $SYSTEMINFO_ID" }, |
|
{"etl_step":"unload_sos_gewichtung","prop_name":"select_stmt", "prop_value":" SELECT art, ch35_ang_abschluss, fach_nr, kz_fach, text, faktor FROM sos_gewichtung where ch35_ang_abschluss in (''B5'',''B6'',''B7'',''B8'',''M3'',''M4'',''M7'',''M8'') and art=''vzae'' order by 1,2,3,4,5 ;" }, |
|
|
|
{"etl_step":"qa_project_unload_ges","prop_name":"msg", "prop_value":"Entlade Testfall-Projekt $QA_PROJECT_ID Stammdaten" }, |
|
{"etl_step":"unload_qa_project_tab","prop_name":"select_stmt", "prop_value":"SELECT uniquename, name, systeminfo_id, sachgebiete_id, active, created_from, issue_link FROM qa_project where tid= $QA_PROJECT_ID order by 1;" }, |
|
{"etl_step":"unload_qa_resultset_tab","prop_name":"select_stmt", "prop_value":"SELECT R.uniquename, R.name, R.systeminfo_id, R.fromclause, R.fieldclause, R.groupbyclause, R.orderbyclause FROM qa_resultset R where R.tid in (select distinct T.resultset_id from qa_dbtest T, qa_dbtest2project P where P.dbtest_id=T.tid and P.project_id= $QA_PROJECT_ID ) order by 1;" }, |
|
{"etl_step":"unload_qa_dbtest_tab","prop_name":"select_stmt", "prop_value":"SELECT T.uniquename,T.name,T.systeminfo_id,R.uniquename as resultset_uniquename,T.whereclause,T.description,T.active from qa_dbtest T,qa_resultset R where R.tid=T.resultset_id and T.tid in (select P.dbtest_id from qa_dbtest2project P where P.project_id= $QA_PROJECT_ID ) order by 1;" }, |
|
{"etl_step":"unload_qa_dbtest_assertion_tab","prop_name":"select_stmt", "prop_value":"SELECT T.uniquename as dbtest_uniquename,A.rownr,A.def_col_caption,A.def_col_name,A.def_col_value,A.def_col_function from qa_dbtest T, qa_dbtest_assertion A where A.dbtest_id=T.tid and T.tid in (select P.dbtest_id from qa_dbtest2project P where P.project_id= $QA_PROJECT_ID ) order by 1;" }, |
|
{"etl_step":"unload_qa_dbtest2project_tab","prop_name":"select_stmt", "prop_value":"SELECT T.uniquename as dbtest_uniquename,P.uniquename as project_uniquename,DP.issue_id FROM qa_dbtest2project DP, qa_dbtest T, qa_project P where DP.dbtest_id=T.tid and DP.project_id=P.tid and DP.project_id= $QA_PROJECT_ID order by 1;" }, |
|
|
|
{"etl_step":"unload_rpta_column_layout_ges","prop_name":"msg", "prop_value":"Entlade Spaltenlayout $RPTA_COLUMN_LAYOUT_TID Stammdaten" }, |
|
{"etl_step":"unload_rpta_resultset_tab","prop_name":"select_stmt", "prop_value":"SELECT R.* from rpta_resultset R where R.tid in (select L.resultset_id from rpta_column_layout L where L.tid in ( $RPTA_COLUMN_LAYOUT_TID )) order by 1;" }, |
|
{"etl_step":"unload_rpta_column_layout_tab","prop_name":"select_stmt", "prop_value":"SELECT L.*,R.uniquename as resultset_uniquename from rpta_column_layout L, rpta_resultset R where R.tid=L.resultset_id and L.tid in ( $RPTA_COLUMN_LAYOUT_TID ) order by 1;" }, |
|
{"etl_step":"unload_rpta_column_tab","prop_name":"select_stmt", "prop_value":"select * from rpta_column where tid in (select column_id from rpta_column2layout L where L.layout_id in ( $RPTA_COLUMN_LAYOUT_TID ) ) order by 1;" }, |
|
{"etl_step":"unload_rpta_column2layout_tab","prop_name":"select_stmt", "prop_value":"select L.tid, |
|
L.column_id, |
|
L.layout_id, |
|
L.sortnr, |
|
L.is_visible, |
|
L.visible_size, |
|
F.uniquename as format_code, |
|
L.targetfieldname, |
|
L.caption, |
|
L.description from rpta_column2layout L left outer join rpta_format_code F on (F.tid=L.format_code_id) where L.layout_id in ( $RPTA_COLUMN_LAYOUT_TID ) order by 1;" }, |
|
|
|
{"etl_step":"create_tmp_rpta_column_layout","prop_name":"PATH_TO_INPUTFILE", "prop_value":"$SUPERX_DIR/db/module/etl/schluesseltabellen/create_load_etl_rpta_column_layout.sql" }, |
|
|
|
{"etl_step":"upload_rpta_resultset_tab","prop_name":"target_table", "prop_value":"tmp_rpta_resultset" }, |
|
{"etl_step":"upload_rpta_resultset_tab","prop_name":"format", "prop_value":"xml" }, |
|
{"etl_step":"upload_rpta_resultset_tab","prop_name":"search_path", "prop_value":"/etlAction/unload [@name=\"unload_rpta_resultset_tab\"]/rs/row" }, |
|
{"etl_step":"upload_rpta_resultset_tab","prop_name":"path_to_inputfile", "prop_value":"$PATH_TO_INPUTFILE" }, |
|
|
|
{"etl_step":"upload_rpta_column_layout_tab","prop_name":"target_table", "prop_value":"tmp_etl_rpta_column_layout" }, |
|
{"etl_step":"upload_rpta_column_layout_tab","prop_name":"format", "prop_value":"xml" }, |
|
{"etl_step":"upload_rpta_column_layout_tab","prop_name":"search_path", "prop_value":"/etlAction/unload [@name=\"unload_rpta_column_layout_tab\"]/rs/row" }, |
|
{"etl_step":"upload_rpta_column_layout_tab","prop_name":"path_to_inputfile", "prop_value":"$PATH_TO_INPUTFILE" }, |
|
|
|
{"etl_step":"upload_rpta_column_tab","prop_name":"target_table", "prop_value":"tmp_rpta_column" }, |
|
{"etl_step":"upload_rpta_column_tab","prop_name":"format", "prop_value":"xml" }, |
|
{"etl_step":"upload_rpta_column_tab","prop_name":"search_path", "prop_value":"/etlAction/unload [@name=\"unload_rpta_column_tab\"]/rs/row" }, |
|
{"etl_step":"upload_rpta_column_tab","prop_name":"path_to_inputfile", "prop_value":"$PATH_TO_INPUTFILE" }, |
|
|
|
{"etl_step":"upload_rpta_column2layout_tab","prop_name":"target_table", "prop_value":"tmp_rpta_column2layout" }, |
|
{"etl_step":"upload_rpta_column2layout_tab","prop_name":"format", "prop_value":"xml" }, |
|
{"etl_step":"upload_rpta_column2layout_tab","prop_name":"search_path", "prop_value":"/etlAction/unload [@name=\"unload_rpta_column2layout_tab\"]/rs/row" }, |
|
{"etl_step":"upload_rpta_column2layout_tab","prop_name":"path_to_inputfile", "prop_value":"$PATH_TO_INPUTFILE" }, |
|
{"etl_step":"trans_rpta_column_layout","prop_name":"PATH_TO_INPUTFILE", "prop_value":"$SUPERX_DIR/db/module/etl/schluesseltabellen/trans_rpta_column_layout.sql" }, |
|
|
|
{"etl_step":"unload_qa_mask_execution_tab","prop_name":"select_stmt", "prop_value":"SELECT E.name,E.userinfo_id,E.maskeninfo_id,E.is_active,E.stylesheet_id,E.contenttype,E.output_filename,E.systeminfo_id,E.uniquename FROM qa_mask_execution E where E.tid in (select P.mask_execution_id from qa_mask_execution2project P where P.project_id= $QA_PROJECT_ID ) order by 1;" }, |
|
{"etl_step":"unload_qa_mask_execution_assert_tab","prop_name":"select_stmt", "prop_value":"SELECT E.uniquename,A.rownr,A.colnr,A.result_value_min,A.result_value_max,A.is_active,A.caption FROM qa_mask_execution E, qa_mask_execution_assert A where E.tid=A.mask_execution_id and E.tid in (select P.mask_execution_id from qa_mask_execution2project P where P.project_id= $QA_PROJECT_ID ) order by 1;" }, |
|
{"etl_step":"unload_qa_mask_execution2project_tab","prop_name":"select_stmt", "prop_value":"SELECT E.uniquename as mask_execution_uniquename,P.uniquename as project_uniquename,DP.issue_id FROM qa_mask_execution2project DP, qa_mask_execution E, qa_project P where DP.mask_execution_id=E.tid and DP.project_id=P.tid and DP.project_id= $QA_PROJECT_ID order by 1;" }, |
|
|
|
{"etl_step":"unload_sxc_stud_zugang_abgang_aggr_ges","prop_name":"msg", "prop_value":"Entlade Studierendenströme für SXC $HS_NR" }, |
|
{"etl_step":"unload_sxc_stud_zugang_abgang_aggr_tab","prop_name":"select_stmt", "prop_value":"SELECT A.* from sxc_stud_zugang_abgang_aggr A where val(A.hs_nr) in ( $HS_NR ) order by 1;" }, |
|
|
|
{"etl_step":"create_tmp_sxc_stud_zugang_abgang_aggr","prop_name":"PATH_TO_INPUTFILE", "prop_value":"$SUPERX_DIR/db/module/etl/schluesseltabellen/create_load_etl_sxc_stud_zugang_abgang_aggr.sql" }, |
|
|
|
{"etl_step":"upload_sxc_stud_zugang_abgang_aggr_tab","prop_name":"target_table", "prop_value":"tmp_sxc_stud_zugang_abgang_aggr" }, |
|
{"etl_step":"upload_sxc_stud_zugang_abgang_aggr_tab","prop_name":"format", "prop_value":"xml" }, |
|
{"etl_step":"upload_sxc_stud_zugang_abgang_aggr_tab","prop_name":"search_path", "prop_value":"/etlAction/unload [@name=\"unload_sxc_stud_zugang_abgang_aggr_tab\"]/rs/row" }, |
|
{"etl_step":"upload_sxc_stud_zugang_abgang_aggr_tab","prop_name":"path_to_inputfile", "prop_value":"$PATH_TO_INPUTFILE" }, |
|
|
|
{"etl_step":"trans_sxc_stud_zugang_abgang_aggr","prop_name":"PATH_TO_INPUTFILE", "prop_value":"$SUPERX_DIR/db/module/etl/schluesseltabellen/trans_sxc_stud_zugang_abgang_aggr.sql" } |
|
|
|
|
|
|
|
|
|
] /> |
|
<#assign testfaelle = [ |
|
{"testcase":"test_sx_select_mask","assertion":1, "sql":"select count(*) from etl_job where uniquename='sx_select_mask'" }, |
|
{"testcase":"test_sx_insert_mask","assertion":1, "sql":"select count(*) from etl_job where uniquename='sx_insert_mask'" }, |
|
{"testcase":"test_sx_insert_mask_params","assertion":3, "sql":"select count(*) from etl_job_param P, etl_job J where J.tid=P.etl_job_id and J.uniquename='sx_insert_mask'" } |
|
|
|
] /> |
|
|
|
create temp table tmp_etl_step( |
|
tid INTEGER, |
|
uniquename VARCHAR(255) , |
|
caption VARCHAR(255) , |
|
systeminfo_id INTEGER not null, |
|
step_type INTEGER, |
|
step_type_uniquename VARCHAR(255), |
|
sortnr SMALLINT not null, |
|
force_continue SMALLINT, |
|
etl_job_id INTEGER , |
|
parent_step_id INTEGER , |
|
parent_step_uniquename varchar(255), |
|
parent_job_uniquename varchar(255), |
|
logfile varchar(255), |
|
custom_step smallint, |
|
already_exists smallint |
|
) |
|
; |
|
|
|
create temp table tmp_etl_job( |
|
tid INTEGER, |
|
uniquename VARCHAR(255) , |
|
caption VARCHAR(255) , |
|
systeminfo_id INTEGER not null, |
|
logfile varchar(255), |
|
already_exists smallint, |
|
custom_job smallint |
|
) |
|
; |
|
|
|
create temp table tmp_etl_job_param( |
|
tid SERIAL not null, |
|
etl_job_id INTEGER , |
|
uniquename VARCHAR(255) not null, |
|
name VARCHAR(255) , |
|
param_default VARCHAR(255) |
|
) |
|
; |
|
|
|
|
|
create temp table tmp_etl_step_property( |
|
tid SERIAL not null, |
|
etl_step_id INTEGER not null, |
|
prop_name VARCHAR(255) , |
|
prop_value text |
|
|
|
) |
|
; |
|
|
|
create temp table tmp_etl_step_relation( |
|
tid SERIAL not null, |
|
step_id INTEGER not null, |
|
parent_step_id INTEGER , |
|
job_id INTEGER not null, |
|
force_continue SMALLINT default 1 , |
|
step_active SMALLINT default 1, |
|
sortnr SMALLINT default 1, |
|
custom_step SMALLINT default 1 |
|
|
|
) |
|
; |
|
|
|
--jobs with custom_job=0 get deleted in HISinOne-BI |
|
--therefore set to 2: |
|
update etl_job set custom_job=2 |
|
where custom_job=0 |
|
and uniquename in ('sx_select_mask','sx_insert_mask', |
|
'kern_konstanten_update', |
|
'sichten_unload', |
|
'sos_gewichtung_unload'); |
|
|
|
|
|
update etl_step set custom_step=2 |
|
where custom_step=0 |
|
and tid in (select R.step_id from etl_step_relation R, etl_job J |
|
where R.job_id=J.tid |
|
and J.uniquename in ('sx_select_mask','sx_insert_mask', |
|
'kern_konstanten_update', |
|
'sichten_unload', |
|
'sos_gewichtung_unload')); |
|
|
|
update etl_step_relation set custom_step=2 |
|
where custom_step=0 |
|
and job_id in (select J.tid |
|
from etl_job J |
|
where J.uniquename in ('sx_select_mask','sx_insert_mask', |
|
'kern_konstanten_update', |
|
'sichten_unload', |
|
'sos_gewichtung_unload')); |
|
|
|
<#foreach etl_job in etl_jobs> |
|
|
|
truncate table tmp_etl_job; |
|
truncate table tmp_etl_step; |
|
truncate table tmp_etl_job_param; |
|
truncate table tmp_etl_step_property; |
|
truncate table tmp_etl_step_relation; |
|
|
|
--tids der jobs dürfen sich nicht ändern, daher |
|
-- |
|
-- 1. vorh. Jobs updaten |
|
-- 2. neue Jobs einfügen |
|
-- 3. alte Jobs löschen |
|
|
|
insert into tmp_etl_job(uniquename,caption,systeminfo_id,logfile,already_exists,custom_job) |
|
values ('${etl_job.uniquename}', |
|
'${etl_job.name}', |
|
${etl_job.systeminfo_id}, |
|
'${etl_job.logfile}',0,2); |
|
|
|
<#if SQLdialect='Postgres'> |
|
--Postgres Dialekt: |
|
|
|
update tmp_etl_job set tid=J.tid, |
|
already_exists=1, |
|
caption=J.caption, |
|
logfile=J.logfile, |
|
custom_job=J.custom_job |
|
from etl_job J where J.uniquename=tmp_etl_job.uniquename |
|
and J.systeminfo_id=tmp_etl_job.systeminfo_id |
|
; |
|
|
|
<#else> |
|
|
|
--Informix Dialekt: |
|
update tmp_etl_job set (tid, |
|
already_exists, |
|
caption, |
|
logfile, |
|
custom_job) |
|
= ((select |
|
tid, |
|
1 as already_exists, |
|
caption, |
|
logfile, |
|
custom_job |
|
from etl_job J where J.uniquename=tmp_etl_job.uniquename |
|
and J.systeminfo_id=tmp_etl_job.systeminfo_id)) |
|
where 0 <(select count(*) |
|
from etl_job J where J.uniquename=tmp_etl_job.uniquename |
|
and J.systeminfo_id=tmp_etl_job.systeminfo_id) |
|
|
|
; |
|
|
|
</#if> |
|
|
|
|
|
|
|
--TODO Informix |
|
|
|
--neue jobs: |
|
insert into etl_job(uniquename,caption,systeminfo_id,custom_job) |
|
select uniquename,caption,systeminfo_id,custom_job |
|
from tmp_etl_job |
|
where already_exists=0; |
|
--tid von neuen Jobs ermitteln: |
|
update tmp_etl_job set tid=(select J.tid |
|
from etl_job J where J.uniquename=tmp_etl_job.uniquename |
|
and J.systeminfo_id=tmp_etl_job.systeminfo_id) |
|
where already_exists=0 |
|
; |
|
|
|
--TODO |
|
--obsolete Jobs: sollen bei Deinstallation des Moduls entfernt werden |
|
|
|
|
|
--Parameter: |
|
<#foreach etl_job_param in etl_job_params> |
|
<#if etl_job_param.etl_job==etl_job.uniquename> |
|
|
|
insert into tmp_etl_job_param( |
|
etl_job_id , |
|
uniquename, |
|
name , |
|
param_default) |
|
select J.tid, |
|
'${etl_job_param.param_name}', |
|
'${etl_job_param.name}', |
|
'${etl_job_param.param_default}' |
|
from tmp_etl_job J |
|
; |
|
</#if> |
|
</#foreach> |
|
|
|
|
|
|
|
--ETL-Schritte |
|
<#assign sortnr=0 /> |
|
<#foreach etl_step in etl_steps> |
|
<#if etl_step.etl_job==etl_job.uniquename> |
|
|
|
<#assign sortnr=sortnr+1 /> |
|
|
|
insert into tmp_etl_step( |
|
uniquename , |
|
caption , |
|
systeminfo_id , |
|
step_type_uniquename, |
|
sortnr, |
|
force_continue, |
|
etl_job_id , |
|
parent_step_uniquename, |
|
parent_job_uniquename, |
|
logfile, |
|
custom_step, |
|
already_exists |
|
) |
|
select '${etl_step.uniquename}', |
|
'${etl_step.name}', |
|
${etl_job.systeminfo_id}, |
|
'${etl_step.type}' as step_type_uniquename, |
|
${sortnr}*10 as sortnr, |
|
0 as force_continue, |
|
J.tid as etl_job_id, |
|
<#if etl_step.parent?exists && etl_step.parent !="" > |
|
'${etl_step.parent}', |
|
<#else> |
|
'' as parent_step_uniquename, |
|
</#if> |
|
J.uniquename, |
|
'${etl_job.logfile}' as logfile, |
|
2, |
|
0 |
|
from etl_job J |
|
where J.uniquename='${etl_job.uniquename}' |
|
and J.systeminfo_id=${etl_job.systeminfo_id}; |
|
|
|
|
|
|
|
|
|
</#if> --Ende steps eines job |
|
</#foreach> |
|
|
|
--erst job-params einfügen: |
|
|
|
delete from etl_job_param |
|
where etl_job_id in ( |
|
SELECT distinct |
|
etl_job_id |
|
FROM tmp_etl_job_param ) |
|
; |
|
|
|
insert into etl_job_param |
|
( |
|
etl_job_id, |
|
uniquename, |
|
name, |
|
param_default |
|
) |
|
SELECT |
|
etl_job_id, |
|
uniquename, |
|
name, |
|
param_default |
|
FROM tmp_etl_job_param |
|
; |
|
|
|
--nun steps einfügen: |
|
|
|
|
|
update tmp_etl_step set step_type=(select T.tid from etl_step_type T |
|
where T.uniquename=tmp_etl_step.step_type_uniquename); |
|
|
|
--select * from tmp_etl_step |
|
--where step_type is null;--_uniquename from tmp_etl_step; |
|
|
|
|
|
--vorhandene Steps erkennen: |
|
<#if SQLdialect='Postgres'> |
|
--Postgres Dialekt: |
|
|
|
update tmp_etl_step set tid=S.tid, |
|
already_exists=1, |
|
caption=S.caption, |
|
logfile=S.logfile, |
|
custom_step=S.custom_step |
|
from etl_step S where S.uniquename=tmp_etl_step.uniquename |
|
and S.systeminfo_id=tmp_etl_step.systeminfo_id |
|
; |
|
<#else> |
|
|
|
--Informix Dialekt: |
|
update tmp_etl_step set (tid, |
|
already_exists, |
|
caption, |
|
logfile, |
|
custom_step) |
|
= ((select |
|
tid, |
|
1 as already_exists, |
|
caption, |
|
logfile, |
|
custom_step |
|
from etl_step S where S.uniquename=tmp_etl_step.uniquename |
|
and S.systeminfo_id=tmp_etl_step.systeminfo_id)) |
|
where 0 <(select count(*) |
|
from etl_step S where S.uniquename=tmp_etl_step.uniquename |
|
and S.systeminfo_id=tmp_etl_step.systeminfo_id) |
|
; |
|
|
|
|
|
|
|
</#if> |
|
|
|
|
|
--neue Steps einfügen: |
|
insert into etl_step( |
|
uniquename, |
|
caption, |
|
systeminfo_id, |
|
step_type_id, |
|
logfile, |
|
custom_step) |
|
select |
|
uniquename, |
|
caption, |
|
systeminfo_id, |
|
step_type, |
|
logfile, |
|
custom_step |
|
FROM tmp_etl_step |
|
where already_exists=0 |
|
; |
|
|
|
--tid von neuen steps ermitteln: |
|
update tmp_etl_step set tid=(select S.tid |
|
from etl_step S where S.uniquename=tmp_etl_step.uniquename |
|
and S.systeminfo_id=tmp_etl_step.systeminfo_id) |
|
where already_exists=0 |
|
; |
|
|
|
--parent ermitteln: |
|
update tmp_etl_step set parent_step_id=(select S.tid |
|
from etl_step S where S.uniquename=tmp_etl_step.parent_step_uniquename |
|
and S.systeminfo_id=tmp_etl_step.systeminfo_id) |
|
; |
|
|
|
|
|
delete from etl_step_property |
|
where etl_step_id in (select T.tid |
|
FROM tmp_etl_step T ) |
|
; |
|
delete from etl_step_relation |
|
where job_id in (select J.tid |
|
FROM tmp_etl_job J) |
|
and custom_step=2 |
|
; |
|
|
|
|
|
--jetzt step-params: |
|
|
|
<#foreach etl_step_property in etl_step_properties> |
|
insert into tmp_etl_step_property( |
|
etl_step_id, |
|
prop_name) |
|
select |
|
T.tid as etl_step_id, |
|
'${etl_step_property.prop_name}' |
|
|
|
FROM tmp_etl_step T |
|
where uniquename ='${etl_step_property.etl_step}' |
|
; |
|
|
|
</#foreach> |
|
|
|
--einfügen in echte Tabelle: |
|
insert into etl_step_property( |
|
etl_step_id, |
|
prop_name) |
|
select |
|
T.etl_step_id, |
|
T.prop_name |
|
FROM tmp_etl_step_property T |
|
; |
|
|
|
--jetzt step-relation: |
|
insert into tmp_etl_step_relation( |
|
step_id, |
|
parent_step_id, |
|
job_id, |
|
force_continue, |
|
step_active, |
|
sortnr, |
|
custom_step |
|
) |
|
select |
|
tid, |
|
parent_step_id, |
|
etl_job_id, |
|
0 as force_continue, |
|
1 as step_active, |
|
sortnr, |
|
2 |
|
FROM tmp_etl_step |
|
; |
|
|
|
insert into etl_step_relation( |
|
step_id, |
|
parent_step_id, |
|
job_id, |
|
force_continue, |
|
step_active, |
|
sortnr, |
|
custom_step |
|
) |
|
select |
|
step_id, |
|
parent_step_id, |
|
job_id, |
|
force_continue, |
|
step_active, |
|
sortnr, |
|
custom_step |
|
FROM tmp_etl_step_relation |
|
; |
|
</#foreach> --Ende job |
|
|
|
|
|
drop table tmp_etl_step; |
|
drop table tmp_etl_job; |
|
drop table tmp_etl_job_param; |
|
drop table tmp_etl_step_property; |
|
drop table tmp_etl_step_relation; |
|
|
|
|
|
<#foreach testfall in testfaelle> |
|
select 'testfall ${testfall.testcase}: ERFOLG' |
|
from xdummy |
|
where ${testfall.assertion}=(${testfall.sql}) |
|
; |
|
select 'testfall ${testfall.testcase}: FEHLER bei ${testfall.testcase}' |
|
from xdummy |
|
where ${testfall.assertion}!=(${testfall.sql}) |
|
; |
|
|
|
|
|
</#foreach> --Ende Testfälle |
|
|
|
|
|
<#foreach etl_step_property in etl_step_properties> |
|
|
|
update etl_step_property set prop_value='${etl_step_property.prop_value}' where prop_name='${etl_step_property.prop_name}' and etl_step_id=(select S.tid from etl_step S where S.uniquename='${etl_step_property.etl_step}'); |
|
|
|
</#foreach> |
|
|
|
|
|
|
|
|