protected void executeUpdate()

in common/src/main/java/com/youtrackdb/ldbc/common/queries/Update7AddComment.java [18:45]


    protected void executeUpdate(LdbcUpdate7AddComment operation, GraphTraversalSource g) {
        var traversal = g.addV(COMMENT)
                        .property(ID, operation.getCommentId())
                        .property(CREATION_DATE, operation.getCreationDate())
                        .property(LOCATION_IP, operation.getLocationIp())
                        .property(BROWSER_USED, operation.getBrowserUsed())
                        .property(CONTENT, operation.getContent())
                        .property(LENGTH, operation.getLength())
                        .as("comment")
                        .addE(HAS_CREATOR)
                            .from("comment")
                            .to(V().has(PERSON, ID, operation.getAuthorPersonId()))
                        .addE(IS_LOCATED_IN)
                            .from("comment")
                            .to(V().has(PLACE, ID, operation.getCountryId()));

                if (operation.getReplyToPostId() != -1) {
                    traversal.addE(REPLY_OF).from("comment").to(V().has(POST, ID, operation.getReplyToPostId()));
                } else if (operation.getReplyToCommentId() != -1) {
                    traversal.addE(REPLY_OF).from("comment").to(V().has(COMMENT, ID, operation.getReplyToCommentId()));
                }

                for (Long tagId : operation.getTagIds()) {
                    traversal.addE(HAS_TAG).from("comment").to(V().has(TAG, ID, tagId));
                }

        traversal.iterate();
    }