def METHOD_NAME(txn: LoggingTransaction) -> None:
    self.db_pool.simple_insert_txn(
        txn,
        "room_aliases",
        {
            "room_alias": room_alias.to_string(),
            "room_id": room_id,
            "creator": creator,
        },
    )
    self.db_pool.simple_insert_many_txn(
        txn,
        table="room_alias_servers",
        keys=("room_alias", "server"),
        values=[(room_alias.to_string(), server) for server in servers],
    )
    self._invalidate_cache_and_stream(
        txn, self.get_aliases_for_room, (room_id,)
    )