def METHOD_NAME(self) -> Iterable[TableQuery]:
    database = self.config.serviceConnection.__root__.config.database
    if database:
        use_db_query = f"USE DATABASE {database}"
        self.engine.execute(use_db_query)
        self.set_session_query_tag()
        yield from super().METHOD_NAME()
    else:
        query = "SHOW DATABASES"
        results = self.engine.execute(query)
        for res in results:
            row = list(res)
            use_db_query = f"USE DATABASE {row[1]}"
            self.engine.execute(use_db_query)
            logger.info(f"Ingesting from database: {row[1]}")
            self.config.serviceConnection.__root__.config.database = row[1]
            self.engine = get_connection(self.service_connection)
            self.set_session_query_tag()
            yield from super().METHOD_NAME()