"""Base class for mysql db connection."""

class Base:
    connection = None
    cursor = None
    db_name = None

    def __init__(self):
        pass

    @classmethod
    def execute_sql_query(cls, sql, params=tuple()):
        """Executes select query and returns records."""
        try:
            cls.cursor.execute(sql, params)
            data = cls.cursor.fetchall()
        except Exception as error:
            print('parameterized query failed {}'.format(error))
        return data

    @classmethod
    def connection_close(cls):
        if  cls.connection and cls.connection.is_connected():
            cls.cursor.close()
            cls.connection.close()
            print(f'{cls.db_name} DB Connection closed')