Examples of org.openengsb.core.ekb.api.EKBCommit.addDelete()

Class org.openengsb.core.ekb.api.EKBCommit

Examples of org.openengsb.core.ekb.api.EKBCommit.addDelete()

org.openengsb.core.ekb.api.EKBCommit.addDelete()
Adds an model to the list of models which shall be deleted from the EDB. If the given object is not a model, an IllegalArgumentException is thrown.

            List<Project> result = queryService.queryByString(Project.class, "name:\"" + project.getName() + "\"");


            if (result.size() == 0) {
                LOGGER.warn("Project {1} does not exist.", project.getName());
            } else {
                commit.addDelete(project);
            }
            deleteAllAssignmentsForProject(project);
        }
        persistService.commit(commit);
        revokePersistenceAccess();

View Full Code Here

            List<User> result = queryService.queryByString(User.class, "username:\"" + user.getUsername() + "\"");


            if (result.size() == 0) {
                LOGGER.warn("User {1} does not exist.", user.getUsername());
            } else {
                commit.addDelete(user);
            }
        }


        persistService.commit(commit);
        revokePersistenceAccess();

View Full Code Here

            List<Role> result = queryService.queryByString(Role.class, "name:\"" + role.getName() + "\"");


            if (result.size() == 0) {
                LOGGER.warn("User {1} does not exist.", role.getName());
            } else {
                commit.addDelete(role);
            }
        }


        persistService.commit(commit);
        revokePersistenceAccess();

View Full Code Here

            List<Role> result = queryService.queryByString(Role.class, "uuid:\"" + assignment.getUuid() + "\"");


            if (result.size() == 0) {
                LOGGER.warn("User {1} does not exist.", assignment.getUuid());
            } else {
                commit.addDelete(assignment);
            }
        }


        persistService.commit(commit);
        revokePersistenceAccess();

View Full Code Here


        UUID preCommit2Revision = query.getLastRevisionNumberOfContext(CONTEXT);
        TestModelDecorator model2 = getTestModelDecorator();
        model2.setEdbId("deleteCommitTest/2");
        commit = getTestEKBCommit().addInsert(model2.getModel());
        commit.addDelete(model1.getModel());
        persist.commit(commit);


        UUID postCommit2Revision = query.getLastRevisionNumberOfContext(CONTEXT);
        persist.deleteCommit(postCommit2Revision, CONTEXT);

View Full Code Here

        OpenEngSBModel delete1 = new TestModelA();
        OpenEngSBModel delete2 = new TestModelB();


        commit.addInsert(insert1).addInsert(insert2).addInsert(insert3);
        commit.addUpdate(update1).addUpdate(update2);
        commit.addDelete(delete1).addDelete(delete2);


        // test
        IndexCommit convertedCommit = converter.convert(commit);


        // assert

View Full Code Here

        for (EDBObject update : commit.getUpdates()) {
            result.addUpdate(createModelOfEDBObject(update, cache));
        }
        for (String delete : commit.getDeletions()) {
            EDBObject object = edbService.getObject(delete, commit.getTimestamp());
            result.addDelete(createModelOfEDBObject(object, cache));
        }
        return result;
    }


    /**

View Full Code Here

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.