diff --git a/DHIS2/sql_queries_generator/README.md b/DHIS2/sql_queries_generator/README.md new file mode 100644 index 0000000..b8510be --- /dev/null +++ b/DHIS2/sql_queries_generator/README.md @@ -0,0 +1,40 @@ +## Queries generator script + +The script can: + +- Generate queries for datavalues. +- Generate queries for datavalueaudit. +- Generate queries for trackedentitydatavalue. +- Generate queries for trackedentitydatavalueaudit. + +#Type of queries in separated files +- Update of value (name of input file +_update.sql). +- Count of values (name of input file +_count.sql). +- Select of values with human readable output (name of input file +_show_values.sql). + +#Ignore queries flags as params + --ignore-show-values Ignore the show values queries + --ignore-count-values + Ignore the count values queries + --ignore-updates Ignore the updates queries + --ignore-datavalues Ignore the datavalues queries + --ignore-trackedentitydatavalues + Ignore the trackedentitydatavalues queries + --ignore-datavaluesaudit + Ignore the datavaluesaudit queries + --ignore-trackedentitydatavaluesaudit + Ignore the trackedentitydatavaluesaudit queries + --ignore-new-codes Ignore the new code queries + --ignore-old-codes Ignore the old code queries + --ignore-relation-check Ignore the relation in the old metadata + to generate the update queries (for example: + ignore the dataelement relation of a dataelement + with the optionset parent of the old option in the datavalues) + + + +#Supported metadata +- Only options for now. + +#Input requirements +A csv file with the old_code;old_id;new_code;new_id for each line with a header (the first line will be ignored) diff --git a/DHIS2/sql_queries_generator/input/.gitignore b/DHIS2/sql_queries_generator/input/.gitignore new file mode 100644 index 0000000..16f2dc5 --- /dev/null +++ b/DHIS2/sql_queries_generator/input/.gitignore @@ -0,0 +1 @@ +*.csv \ No newline at end of file diff --git a/DHIS2/sql_queries_generator/input/example_options.csv b/DHIS2/sql_queries_generator/input/example_options.csv new file mode 100644 index 0000000..d9bd589 --- /dev/null +++ b/DHIS2/sql_queries_generator/input/example_options.csv @@ -0,0 +1,2 @@ +code (old country),id (old country),code (new countries),id (new countries) +Op_Country_ABW,YINMRPJJN5V,ABW,gVd3RYvdHvq \ No newline at end of file diff --git a/DHIS2/sql_queries_generator/queries/.gitignore b/DHIS2/sql_queries_generator/queries/.gitignore new file mode 100644 index 0000000..48e029b --- /dev/null +++ b/DHIS2/sql_queries_generator/queries/.gitignore @@ -0,0 +1 @@ +*.sql \ No newline at end of file diff --git a/DHIS2/sql_queries_generator/sql_queries_generator.py b/DHIS2/sql_queries_generator/sql_queries_generator.py new file mode 100644 index 0000000..acb8400 --- /dev/null +++ b/DHIS2/sql_queries_generator/sql_queries_generator.py @@ -0,0 +1,256 @@ +import argparse +import csv +import os +from os import listdir +from os.path import isfile, join + +NEW_ID = "new_id" + +NEW_CODE = "new_code" + +OLD_ID = "old_id" + +OLD_CODE = "old_code" + +input = "input" +output = "queries" + +update_data_value_codes_by_code_in_metadata_related = "update datavalue set value = '%s' where value like '%s' and " \ + "dataelementid in (select de.dataelementid from dataelement de " \ + "inner join optionset os on de.optionsetid=os.optionsetid " \ + "inner join optionvalue op on op.optionsetid=os.optionsetid " \ + "where op.uid like '%s');\n" +update_audit_data_values_codes_by_code_in_metadata_related = "update datavalueaudit set value = '%s' " \ + "where value like '%s' and dataelementid in " \ + "(select de.dataelementid from dataelement de inner join optionset os " \ + "on de.optionsetid=os.optionsetid inner join optionvalue op " \ + "on op.optionsetid=os.optionsetid where op.uid like '%s');\n" +update_tracked_entity_data_values_codes_by_code_in_metadata_related = "update trackedentitydatavalue set value = '%s' " \ + "where value like '%s' and dataelementid in " \ + "(select de.dataelementid from dataelement de inner join optionset os " \ + "on de.optionsetid=os.optionsetid inner join optionvalue op " \ + "on op.optionsetid=os.optionsetid where op.uid like '%s');\n" +update_audit_tracked_entity_data_values_codes_by_code_in_metadata_related = "update trackedentitydatavalueaudit " \ + "set value = '%s' where value like '%s' and dataelementid in " \ + "(select de.dataelementid from dataelement de inner join optionset os " \ + "on de.optionsetid=os.optionsetid inner join optionvalue op " \ + "on op.optionsetid=os.optionsetid where op.uid like '%s');\n" + +update_data_value_codes_by_code = "update datavalue set value = '%s' where value like '%s';\n" +update_audit_data_values_codes_by_code = "update datavalueaudit set value = '%s' where value like '%s';\n" +update_tracked_entity_data_values_codes_by_code = "update trackedentitydatavalue set value = '%s' " \ + "where value like '%s';\n" +update_audit_tracked_entity_data_values_codes_by_code = "update trackedentitydatavalueaudit set value = '%s' " \ + "where value like '%s';\n" + +show_count_of_data_values_by_code = "select count(*) from datavalue dv where dv.value like '%s';\n" +show_count_of_audit_data_values_by_code = "select count(*) from datavalueaudit dv where dv.value like '%s';\n" +show_count_of_tracked_entity_data_values_by_code = "select count(*) from trackedentitydatavalue dv where dv.value " \ + "like '%s';\n" +show_count_of_audit_tracked_entity_data_values_by_code = "select count(*) from trackedentitydatavalueaudit dv where " \ + "dv.value like '%s';\n" + +show_data_values_by_code = "select de.uid as dataelement_uid, de.name as dataelement_name, ou.name as orgunit_name, " \ + "ou.uid as orgunit_uid, pe.startdate, pe.enddate, coc.uid as coc_uid, coc.name as coc_name, " \ + "value, storedby, dv.created, dv.lastupdated, dv.deleted from datavalue dv " \ + "inner join dataelement de on de.dataelementid=dv.dataelementid " \ + "inner join period pe on pe.periodid=dv.periodid " \ + "inner join categoryoptioncombo coc on coc.categoryoptioncomboid=dv.categoryoptioncomboid " \ + "inner join organisationunit ou on ou.organisationunitid=dv.sourceid where dv.value like '%s';\n" + +show_audit_data_values_by_code = "select de.uid as dataelement_uid, de.name as dataelement_name, ou.name as orgunit_name, " \ + "ou.uid as orgunit_uid, pe.startdate, pe.enddate, coc.uid as coc_uid, coc.name as coc_name, " \ + "value,dv.created, dv.modifiedby, dv.audittype from datavalueaudit dv " \ + "inner join dataelement de on de.dataelementid=dv.dataelementid " \ + "inner join period pe on pe.periodid=dv.periodid " \ + "inner join categoryoptioncombo coc on coc.categoryoptioncomboid=dv.categoryoptioncomboid " \ + "inner join organisationunit ou on ou.organisationunitid=dv.organisationunitid where dv.value like '%s';\n" + +show_tracked_entity_data_values_by_code = "select p.uid as program_uid, p.name as program_name, " \ + "ou.uid as orgunit_uid, ou.name as orgunit_name, de.uid as dataelement_uid, de.name as dataelement_name, " \ + "dv.value, dv.storedby, dv.created, dv.lastupdated " \ + "from trackedentitydatavalue dv inner join dataelement de on de.dataelementid = dv.dataelementid " \ + "inner join programstageinstance psi on psi.programstageinstanceid=dv.programstageinstanceid " \ + "inner join programstage ps on ps.programstageid=psi.programstageid " \ + "inner join program p on p.programid = ps.programid inner join organisationunit ou on " \ + "psi.organisationunitid=ou.organisationunitid " \ + "where dv.value like '%s' order by p.name;\n" + +show_audit_tracked_entity_data_values_by_code = "select p.uid as program_uid, p.name as program_name, " \ + "ou.uid as orgunit_uid, ou.name as orgunit_name, de.uid as dataelement_uid, de.name as dataelement_name," \ + "dv.value, dv.modifiedby, dv.audittype " \ + "from trackedentitydatavalueaudit dv inner join " \ + "dataelement de on de.dataelementid = dv.dataelementid inner join programstageinstance psi on " \ + "psi.programstageinstanceid=dv.programstageinstanceid " \ + "inner join programstage ps on ps.programstageid=psi.programstageid " \ + "inner join program p on p.programid = ps.programid " \ + "inner join organisationunit ou on psi.organisationunitid=ou.organisationunitid " \ + "where dv.value like '%s' order by p.name;\n" + + +def assign_csv_data(row): + if row[0] != "" and row[2] != "" and row[1] != "" and row[3] != "": + output_data.append({OLD_CODE: row[0], OLD_ID: row[1], + NEW_CODE: row[2], NEW_ID: row[3]}) + + +def main(): + global output_data + output_data = dict() + args = get_args() + is_csv = lambda fname: os.path.splitext(fname)[-1] in ['.csv'] + is_not_csv = lambda fname: not os.path.splitext(fname)[-1] in ['.csv'] + is_not_git = lambda fname: not fname.startswith(".git") + applied_filter = is_not_git if is_csv else is_not_csv + + files = [f for f in filter(applied_filter, listdir(input)) if isfile(join(input, f))] + for path_file in files: + output_data = list() + with open(os.path.join("input", path_file)) as csv_file: + csv_reader = csv.reader(csv_file, delimiter=',') + line_count = 0 + for row in csv_reader: + if line_count == 0: + print(f'Column names are {", ".join(row)}') + line_count += 1 + else: + assign_csv_data(row) + + line_count += 1 + if args.updates: + generate_updates(path_file, args) + + if args.count: + generate_count_values(path_file, args) + + if args.values: + generate_show_values(path_file, args) + + +def generate_updates(path_file, args): + print("Processing updates") + with open(join(output, path_file + "_update.sql"), 'w', encoding='utf-8') as file: + file.write('/* ~~~~~~~~~~~~~~~~~~~~~~UPDATES~~~~~~~~~~~~~~~~ */\n') + for item in output_data: + queries = list() + + if args.datavalues: + if args.relation: + queries.append(update_data_value_codes_by_code_in_metadata_related) + else: + queries.append(update_data_value_codes_by_code) + if args.datavaluesaudit: + if args.relation: + queries.append(update_audit_data_values_codes_by_code_in_metadata_related) + else: + queries.append(update_audit_data_values_codes_by_code) + if args.trackedentitydatavalues: + if args.relation: + queries.append(update_tracked_entity_data_values_codes_by_code_in_metadata_related) + else: + queries.append(update_tracked_entity_data_values_codes_by_code) + if args.trackedentitydatavaluesaudit: + if args.relation: + queries.append(update_audit_tracked_entity_data_values_codes_by_code_in_metadata_related) + else: + queries.append(update_audit_tracked_entity_data_values_codes_by_code) + + for query in queries: + if args.relation: + file.write(query % (item[NEW_CODE], item[OLD_CODE], item[OLD_ID])) + else: + file.write(query % (item[NEW_CODE], item[OLD_CODE])) + + print("Done") + + +def generate_count_values(path_file, args): + print("Processing counts") + with open(join(output, path_file + "_count.sql"), 'w', encoding='utf-8') as file: + file.write('/* ~~~~~~~~~~~~~~~~~~~~~~COUNT~~~~~~~~~~~~~~~~ */\n') + for item in output_data: + codes = list() + queries = list() + if args.new: + codes.append(NEW_CODE) + if args.old: + codes.append(OLD_CODE) + + if args.datavalues: + queries.append(show_count_of_data_values_by_code) + if args.datavaluesaudit: + queries.append(show_count_of_audit_data_values_by_code) + if args.trackedentitydatavalues: + queries.append(show_count_of_tracked_entity_data_values_by_code) + if args.trackedentitydatavaluesaudit: + queries.append(show_count_of_audit_tracked_entity_data_values_by_code) + + for query in queries: + for code in codes: + file.write(query % item[code]) + print("Done") + + +def generate_show_values(path_file, args): + print("Processing Show values") + with open(join(output, path_file + "_show_values.sql"), 'w', encoding='utf-8') as file: + file.write('/* ~~~~~~~~~~~~~~~~~~~~~~SHOW_VALUES~~~~~~~~~~~~~~~~ */\n') + for item in output_data: + codes = list() + queries = list() + if args.new: + codes.append(NEW_CODE) + if args.old: + codes.append(OLD_CODE) + + if args.datavalues: + queries.append(show_data_values_by_code) + if args.datavaluesaudit: + queries.append(show_audit_data_values_by_code) + if args.trackedentitydatavalues: + queries.append(show_tracked_entity_data_values_by_code) + if args.trackedentitydatavaluesaudit: + queries.append(show_audit_tracked_entity_data_values_by_code) + + for query in queries: + for code in codes: + file.write(query % item[code]) + print("Done") + + +def get_args(): + "Return arguments" + parser = argparse.ArgumentParser(description=__doc__) + print(argparse) + add = parser.add_argument # shortcut + add('--ignore-show-values', dest='values', help='Ignore the show values queries', + action='store_false') + parser.set_defaults(values=True) + add('--ignore-count-values', dest='count', help='Ignore the count values queries', + action='store_false') + parser.set_defaults(count=True) + add('--ignore-updates', dest='updates', help='Ignore the updates queries', action='store_false') + parser.set_defaults(updates=True) + add('--ignore-datavalues', dest='datavalues', help='Ignore the datavalues queries' + , action='store_false') + parser.set_defaults(datavalues=True) + add('--ignore-trackedentitydatavalues', help='Ignore the trackedentitydatavalues queries' + , dest='trackedentitydatavalues', action='store_false') + parser.set_defaults(trackedentitydatavalues=True) + add('--ignore-datavaluesaudit', dest='datavaluesaudit', help='Ignore the datavaluesaudit queries' + , action='store_false') + parser.set_defaults(datavaluesaudit=True) + add('--ignore-trackedentitydatavaluesaudit', help='Ignore the trackedentitydatavaluesaudit queries', + dest='trackedentitydatavaluesaudit', action='store_false') + parser.set_defaults(trackedentitydatavaluesaudit=True) + add('--ignore-new-codes', dest='new', help='Ignore the new code queries', + action='store_false') + parser.set_defaults(new=True) + add('--ignore-old-codes', dest='old', help='Ignore the old code queries', action='store_false') + add('--ignore-relation-check', dest='relation', help='Ignore the relation check', action='store_false') + parser.set_defaults(relation=True) + return parser.parse_args() + + +if __name__ == '__main__': + main()