From d18ef789eb0981a24e7ec1fe2dae76ef9d8f0ba7 Mon Sep 17 00:00:00 2001 From: Yorick Barbanneau Date: Wed, 4 May 2022 01:10:35 +0200 Subject: [PATCH] Add create_trigger.py script --- create_trigger.py | 176 ++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 176 insertions(+) create mode 100755 create_trigger.py diff --git a/create_trigger.py b/create_trigger.py new file mode 100755 index 0000000..b7e58bb --- /dev/null +++ b/create_trigger.py @@ -0,0 +1,176 @@ +#!/usr/bin/env python +import sys +import os +import re +# import time +import logging +import argparse as arg +import psycopg2 as pg +from psycopg2.extensions import AsIs + +from classes.CustomFormater import CustomFormatter +from classes.Timer import Timer + +import locale +locale.setlocale(locale.LC_ALL, 'fr_FR.UTF-8') + +# Schema name is NAMEDATALEN-1 (PGSQL source code) +# -> src/include/pg_config_manual.h +def check_schema_name(arg_value, pat=re.compile(r"^[a-z0-9A-Z]{1,63}$")): + if not pat.match(arg_value): + raise ValueError + return arg_value + + +def parse_args(): + """ + Parse arguments + """ + parser = arg.ArgumentParser('Process csv files from INSEE') + + parser.add_argument('--source', '-s', + help='csv source directory', + default='exports') + + parser.add_argument('--connection-file', '-f', + help='Postgresql connexion file', + default='.pgconn' + ) + + # As whe use AsIs function to not include '' in our sql queries for schema + # name, me mus ensure that it is not contains SQL special characters + # like comments --, final coma etc and avoid SQL injection + parser.add_argument('--schema-name', + help='Database schema name', + type=check_schema_name, + default='insee' + ) + + parser.add_argument('--test', '-t', + help='test view, get 10 record of each', + action='store_true' + ) + + debug_group = parser.add_mutually_exclusive_group() + debug_group.add_argument('--verbose', '-V', + help='Verbose output', + action='store_true') + debug_group.add_argument('--debug', '-d', + help='Activate debug mode', + action='store_true') + return parser.parse_args() + +if __name__ == '__main__': + args = parse_args() + #logging.basicConfig(level=logging.DEBUG) + logger = logging.getLogger() + tty_handler = logging.StreamHandler() + + # create console handler with a higher log level + tty_handler.setFormatter(CustomFormatter()) + logger.addHandler(tty_handler) + + if args.verbose is True: + logger.setLevel(logging.INFO) + logger.info('VERBOSE mode activated') + + if args.debug is True: + logger.setLevel(logging.DEBUG) + logger.debug('DEBUG mode activated') + + logging.debug('Import pgsql connection file {}'.format(args.connection_file)) + with open(args.connection_file) as cf: + pg_conn = cf.read() + + t = Timer(logger=logger.info) + conn = pg.connect(pg_conn) + with conn.cursor() as curs: + + logger.debug('Create trigger on region and departement') + t.start('dep reg trigger') + try: + curs.execute(""" + + CREATE OR REPLACE FUNCTION %(schema)s.block_maj_reg_dep() + RETURNS TRIGGER AS $bloquage$ + BEGIN + RAISE EXCEPTION + 'Mise à jour non autorisé'; + END; + $bloquage$ language plpgsql; + + CREATE TRIGGER TRG_BLOQ_MAJ_REG + BEFORE INSERT OR UPDATE OR DELETE ON %(schema)s.region + + FOR EACH ROW EXECUTE PROCEDURE %(schema)s.block_maj_reg_dep(); + + CREATE TRIGGER TRG_BLOQ_MAJ_DEP + BEFORE INSERT OR UPDATE OR DELETE ON %(schema)s.departement + + FOR EACH ROW EXECUTE PROCEDURE %(schema)s.block_maj_reg_dep(); + """, + {'schema':AsIs(args.schema_name)}) + conn.commit() + except Exception as e: + logger.error('Something goes wrong on block trigger: {}'.format(e)) + sys.exit(1) + t.stop() + + logger.debug('Add procedure to modify pop. values on region and dep') + t.start('Add fun_maj_pop() procedure') + try: + curs.execute(""" + CREATE OR REPLACE FUNCTION %(schema)s.FUN_MAJ_POP() + RETURNS TRIGGER AS $maj_population$ + BEGIN + + ALTER TABLE %(schema)s.region DISABLE TRIGGER TRG_BLOQ_MAJ_REG; + ALTER TABLE %(schema)s.departement DISABLE TRIGGER TRG_BLOQ_MAJ_DEP; + + IF(TG_OP = 'INSERT' AND NEW.ID_INDICATEUR = 1 + AND (NEW.VALEUR <> 0 OR NEW.VALEUR <> NULL)) THEN + CALL %(schema)s.PRC_POP_REG_DEP(); + END IF; + + IF(TG_OP = 'UPDATE' AND NEW.ID_INDICATEUR = 1 + AND NEW.VALEUR <> OLD.VALEUR) THEN + CALL %(schema)s.PRC_POP_REG_DEP(); + END IF; + + IF(TG_OP = 'DELETE' AND OLD.ID_INDICATEUR = 1 + AND (OLD.VALEUR <> 0 OR OLD.VALEUR <> NULL)) THEN + CALL %(schema)s.PRC_POP_REG_DEP(); + END IF; + + ALTER TABLE %(schema)s.region ENABLE TRIGGER TRG_BLOQ_MAJ_REG; + ALTER TABLE %(schema)s.region ENABLE TRIGGER TRG_BLOQ_MAJ_DEP; + + RETURN NULL; + END; + $maj_population$ language plpgsql; + """, + {'schema':AsIs(args.schema_name)}) + conn.commit() + except Exception as e: + logger.error( + 'Something goes wrong on fun_maj_pop procedure: {}'.format(e) + ) + sys.exit(1) + t.stop() + + logger.debug('Add trigger on statistique tto update pop. values') + t.start('Add fun_maj_pop() procedure') + try: + curs.execute(""" + CREATE TRIGGER TRG_MAJ_POP + AFTER INSERT OR UPDATE OR DELETE ON %(schema)s.statistique + FOR EACH ROW EXECUTE PROCEDURE %(schema)s.FUN_MAJ_POP(); + """, + {'schema':AsIs(args.schema_name)}) + conn.commit() + except Exception as e: + logger.error( + 'Something goes wrong on statistique trigger: {}'.format(e) + ) + sys.exit(1) + t.stop()