def map_column_names()

in connectors/sources/generic_database.py [0:0]


def map_column_names(column_names, schema=None, tables=None):
    prefix = ""
    if schema and len(schema.strip()) > 0:
        prefix += schema.strip() + "_"
    if tables and len(tables) > 0:
        prefix += f"{'_'.join(sorted(tables))}_"
    return [f"{prefix}{column}".lower() for column in column_names]