src/dirbs/importer/base_delta_importer.py
def _add_change_type_column_with_constraint(self, tblname, cursor):
        """Helper function to add column change type to staging and delta table.

        Change type can be either 'add', 'remove' or 'update'.
        """
        cursor.execute(sql.SQL("""ALTER TABLE {0} ADD COLUMN change_type TEXT""").format(tblname))
        cursor.execute(sql.SQL("""ALTER TABLE {0}
                               ADD CONSTRAINT delta_change_type_check
                                        CHECK (change_type IN ('add',
                                                               'remove',
                                                               'update'))""").format(tblname))
Helper function to add column change type to staging and delta table.

        Change type can be either 'add', 'remove' or 'update'.
        
Helper function to add column change type to staging and delta table.
Helper function to add column change type to staging and delta table .
def _add_change_type_column_with_constraint(self, tblname, cursor):
        cursor.execute(sql.SQL("""ALTER TABLE {0} ADD COLUMN change_type TEXT""").format(tblname))
        cursor.execute(sql.SQL("""ALTER TABLE {0}
                               ADD CONSTRAINT delta_change_type_check
                                        CHECK (change_type IN ('add',
                                                               'remove',
                                                               'update'))""").format(tblname))
def _add_change_type_column_with_constraint ( self , tblname , cursor ) : cursor . execute ( sql . SQL ( """ALTER TABLE {0} ADD COLUMN change_type TEXT""" ) . format ( tblname ) ) cursor . execute ( sql . SQL ( """ALTER TABLE {0}
                               ADD CONSTRAINT delta_change_type_check
                                        CHECK (change_type IN ('add',
                                                               'remove',
                                                               'update'))""" ) . format ( tblname ) )
Helper function to add column change type to staging and delta table.
Helper function to add column change type to staging and delta table .
"""Helper function to add column change type to staging and delta table.

        Change type can be either 'add', 'remove' or 'update'.
        """
self
tblname
cursor