async def METHOD_NAME(
    connection: Connection, admin_structure_id: UUID, structure_id: UUID
) -> UUID | None:
    record = await connection.fetchrow(
        """
        INSERT INTO public.admin_structure_structure(admin_structure_id, structure_id)
        VALUES ($1, $2)
        ON CONFLICT ON CONSTRAINT admin_structure_structure_admin_structure_id_structure_id_key
        DO UPDATE SET deleted_at = NULL
        RETURNING id
        """,  # noqa: E501
        admin_structure_id,
        structure_id,
    )
    if record:
        return record["id"]