ody_migr_transaction Namespace Reference

Classes
class	PgTransaction

Functions
def	pg_crsr_hndlr_decrtr (original_action_handler)

Variables
	LOGGER = logging.getLogger(__name__)
string	PG_ARG_DEFAULT = "arg_default"
string	PGARG_COL_SCHMA = "column_schema"
string	PGARG_COLL = "collection"
string	PGARG_CLN_BFRE_INSRT = "cleanup_before_insert"
string	PGARG_RTRNG_COLMN = "returning_col"
string	PGARG_VRBSE = "verbose"
string	PGARG_WHR_CONDS = "where_conditions"
string	PGARG_RTRN_ONLY_CNT = "return_only_count"
string	PGARG_SLCT_COLS = "select_columns"
string	PGARG_HNDLR_SPECIFIC = "handler_specific_args"
dictionary	PGDEF_ARGS_DICT

Detailed Description

Main module that handles all database operations.

- Each database operation can take relevant optional parameters.
- Safe sql query generation is performed in ody_migr_db_handler.py script.

Specific handler such as `menu_insert_cu_featuremenu` must catch and
raise psycopg2 specific database errors and raise so that execute_migration
sees them and handles appropriately. A decorator `pg_crsr_hndlr_decrtr` is
used for that purpose.

Function Documentation

pg_crsr_hndlr_decrtr()

def ody_migr_transaction.pg_crsr_hndlr_decrtr

(

original_action_handler

)

Common psycopg2 exception handler decorator

Catches and raise psycopg2 related errors and warnings.

Args:
    original_action_handler: function to wrap

Definition at line 68 of file ody_migr_transaction.py.

def pg_crsr_hndlr_decrtr(original_action_handler):
    """Common psycopg2 exception handler decorator

    Catches and raise psycopg2 related errors and warnings.

    Args:
        original_action_handler: function to wrap
    """
    @wraps(original_action_handler)
    def wrapper(*args, **kwargs):
        try:
            return original_action_handler(*args, **kwargs)
        except (psycopg2.Error, psycopg2.Warning):
            raise
    return wrapper

Variable Documentation

PGDEF_ARGS_DICT

dictionary ody_migr_transaction.PGDEF_ARGS_DICT

Initial value:

=  {
    PGARG_COL_SCHMA: None,
    PGARG_COLL: [],
    PGARG_CLN_BFRE_INSRT: False,
    PGARG_RTRNG_COLMN: "",
    PGARG_VRBSE: False,
    PGARG_WHR_CONDS: {},
    PGARG_RTRN_ONLY_CNT: False,
    PGARG_SLCT_COLS: [],
    PGARG_HNDLR_SPECIFIC: {}
}

Definition at line 55 of file ody_migr_transaction.py.