Examples of MongoDBChangeSet


Examples of org.rhq.enterprise.server.plugins.drift.mongodb.entities.MongoDBChangeSet

                expected, actual, ignore);
    }

    @Test(enabled = ENABLED)
    public void findByChangeSetCriteriaWithResourceIdFilter() throws Exception {
        MongoDBChangeSet c1 = new MongoDBChangeSet();
        c1.setCategory(DRIFT);
        c1.setVersion(1);
        c1.setResourceId(1);
        c1.setDriftDefinitionId(1);
        dao.save(c1);

        MongoDBChangeSet c2 = new MongoDBChangeSet();
        c2.setCategory(DRIFT);
        c2.setVersion(2);
        c2.setResourceId(2);
        c2.setDriftDefinitionId(2);
        dao.save(c2);

        GenericDriftChangeSetCriteria criteria = new GenericDriftChangeSetCriteria();
        criteria.addFilterResourceId(1);
       
View Full Code Here

Examples of org.rhq.enterprise.server.plugins.drift.mongodb.entities.MongoDBChangeSet

                "filter", expected, actual, ignore);
    }

    @Test(enabled = ENABLED)
    public void findByChangeSetCriteriaWithVersionFilter() throws Exception {
        MongoDBChangeSet c1 = new MongoDBChangeSet();
        c1.setCategory(DRIFT);
        c1.setVersion(1);
        c1.setResourceId(1);
        c1.setDriftDefinitionId(1);
        dao.save(c1);

        MongoDBChangeSet c2 = new MongoDBChangeSet();
        c2.setCategory(DRIFT);
        c2.setVersion(2);
        c2.setResourceId(1);
        c2.setDriftDefinitionId(1);
        dao.save(c2);
       
        GenericDriftChangeSetCriteria criteria = new GenericDriftChangeSetCriteria();
        criteria.addFilterDriftDefinitionId(1);
        criteria.addFilterVersion("2");
View Full Code Here

Examples of org.rhq.enterprise.server.plugins.drift.mongodb.entities.MongoDBChangeSet

                expected, actual, ignore);
    }

    @Test(enabled = ENABLED)
    public void findByChangeSetCriteriaWithStartVersionFilter() throws Exception {
        MongoDBChangeSet c1 = new MongoDBChangeSet();
        c1.setCategory(DRIFT);
        c1.setVersion(1);
        c1.setResourceId(1);
        c1.setDriftDefinitionId(1);
        dao.save(c1);

        MongoDBChangeSet c2 = new MongoDBChangeSet();
        c2.setCategory(DRIFT);
        c2.setVersion(2);
        c2.setResourceId(1);
        c2.setDriftDefinitionId(1);
        dao.save(c2);

        MongoDBChangeSet c3 = new MongoDBChangeSet();
        c3.setCategory(DRIFT);
        c3.setVersion(3);
        c3.setResourceId(1);
        c3.setDriftDefinitionId(1);
        dao.save(c3);

        GenericDriftChangeSetCriteria criteria = new GenericDriftChangeSetCriteria();
        criteria.addFilterDriftDefinitionId(1);
        criteria.addFilterStartVersion("2");
View Full Code Here

Examples of org.rhq.enterprise.server.plugins.drift.mongodb.entities.MongoDBChangeSet

                expected, actual, ignore);
    }

    @Test(enabled = ENABLED)
    public void findByChangeSetCriteriaWithEndVersionFilter() throws Exception {
        MongoDBChangeSet c1 = new MongoDBChangeSet();
        c1.setCategory(DRIFT);
        c1.setVersion(1);
        c1.setResourceId(1);
        c1.setDriftDefinitionId(1);
        dao.save(c1);

        MongoDBChangeSet c2 = new MongoDBChangeSet();
        c2.setCategory(DRIFT);
        c2.setVersion(2);
        c2.setResourceId(1);
        c2.setDriftDefinitionId(1);
        dao.save(c2);

        MongoDBChangeSet c3 = new MongoDBChangeSet();
        c3.setCategory(DRIFT);
        c3.setVersion(3);
        c3.setResourceId(1);
        c3.setDriftDefinitionId(1);
        dao.save(c3);

        GenericDriftChangeSetCriteria criteria = new GenericDriftChangeSetCriteria();
        criteria.addFilterDriftDefinitionId(1);
        criteria.addFilterEndVersion("2");
View Full Code Here

Examples of org.rhq.enterprise.server.plugins.drift.mongodb.entities.MongoDBChangeSet

                expected, actual, ignore);
    }

    @Test(enabled = ENABLED)
    public void findByChangeSetCriteriaWithDriftDefIdFilter() throws Exception {
        MongoDBChangeSet c1 = new MongoDBChangeSet();
        c1.setCategory(DRIFT);
        c1.setVersion(1);
        c1.setResourceId(1);
        c1.setDriftDefinitionId(1);
        dao.save(c1);
       
        MongoDBChangeSet c11 = new MongoDBChangeSet();
        c11.setCategory(DRIFT);
        c11.setVersion(2);
        c11.setResourceId(1);
        c11.setDriftDefinitionId(1);
        dao.save(c11);

        MongoDBChangeSet c2 = new MongoDBChangeSet();
        c2.setCategory(DRIFT);
        c2.setVersion(1);
        c2.setResourceId(2);
        c2.setDriftDefinitionId(2);
        dao.save(c2);
       
        GenericDriftChangeSetCriteria criteria = new GenericDriftChangeSetCriteria();
        criteria.addFilterDriftDefinitionId(1);
       
View Full Code Here

Examples of org.rhq.enterprise.server.plugins.drift.mongodb.entities.MongoDBChangeSet

    }

    @Test(enabled = ENABLED)
    public void findByChangeSetCriteriaWithCreatedAfterFilter() throws Exception {
        long creationTime = System.currentTimeMillis() - (1000 * 60 * 10)// 10 minutes ago
        MongoDBChangeSet c1 = new MongoDBChangeSet();
        c1.setCategory(DRIFT);
        c1.setVersion(1);
        c1.setResourceId(1);
        c1.setDriftDefinitionId(1);
        c1.setCtime(creationTime);
        dao.save(c1);

        MongoDBChangeSet c2 = new MongoDBChangeSet();
        c2.setCategory(DRIFT);
        c2.setVersion(2);
        c2.setResourceId(1);
        c2.setDriftDefinitionId(1);
        c2.setCtime(c1.getCtime() + (1000 * 60 * 5))// 5 minutes ago
        dao.save(c2);

        GenericDriftChangeSetCriteria criteria = new GenericDriftChangeSetCriteria();
        criteria.addFilterDriftDefinitionId(1);
        criteria.addFilterCreatedAfter(creationTime + 1000);
View Full Code Here

Examples of org.rhq.enterprise.server.plugins.drift.mongodb.entities.MongoDBChangeSet

    }

    @Test(enabled = ENABLED)
    public void findByChangeSetCriteriaWithCreatedBeforeFilter() throws Exception {
        long creationTime = System.currentTimeMillis() - (1000 * 60 * 10)// 10 minutes ago
        MongoDBChangeSet c1 = new MongoDBChangeSet();
        c1.setCategory(DRIFT);
        c1.setVersion(1);
        c1.setResourceId(1);
        c1.setDriftDefinitionId(1);
        c1.setCtime(creationTime);
        dao.save(c1);

        MongoDBChangeSet c2 = new MongoDBChangeSet();
        c2.setCategory(DRIFT);
        c2.setVersion(2);
        c2.setResourceId(1);
        c2.setDriftDefinitionId(1);
        c2.setCtime(c1.getCtime() + (1000 * 60 * 5))// 5 minutes ago
        dao.save(c2);

        GenericDriftChangeSetCriteria criteria = new GenericDriftChangeSetCriteria();
        criteria.addFilterDriftDefinitionId(1);
        criteria.addFilterCreatedBefore(c2.getCtime());

        List<MongoDBChangeSet> actual = dao.findByChangeSetCritiera(criteria);
        List<MongoDBChangeSet> expected = asList(c1);

        String ignore = "drifts";
View Full Code Here

Examples of org.rhq.enterprise.server.plugins.drift.mongodb.entities.MongoDBChangeSet

        if (result == null) {
            return null;
        }

        MongoDBChangeSet changeSet = morphia.fromDBObject(MongoDBChangeSet.class, result);
        if (!changeSet.getDrifts().isEmpty()) {
            return changeSet.getDrifts().iterator().next();
        }
        return null;
    }
View Full Code Here

Examples of org.rhq.enterprise.server.plugins.drift.mongodb.entities.MongoDBChangeSet

        List<MongoDBChangeSetEntry> entries = changeSetDAO.findEntries(criteria);
        Map<Integer, Resource> resources = loadResourceMap(subject, criteria.getFilterResourceIds());
        PageList<DriftComposite> results = new PageList<DriftComposite>();

        for (MongoDBChangeSetEntry entry : entries) {
            MongoDBChangeSet changeSet = entry.getChangeSet();
            DriftDTO driftDTO = mapper.toDTO(entry);
            if (criteria.isFetchChangeSet()) {
                DriftChangeSetDTO changeSetDTO = mapper.toDTO(changeSet);
                driftDTO.setChangeSet(changeSetDTO);
            }
            results.add(new DriftComposite(driftDTO, resources.get(changeSet.getResourceId()),
                    changeSet.getDriftDefinitionName()));
        }

        return results;
    }
View Full Code Here

Examples of org.rhq.enterprise.server.plugins.drift.mongodb.entities.MongoDBChangeSet

        // persistDefinitionChangeSet where the definition is passed as an argument to
        // the latter. As it stands right now, each plugin implementation will have
        // duplicate logic for determining whether this is a template or definition change
        // set. That logic could be pulled up into DriftManagerBean.

        MongoDBChangeSet newChangeSet = new MongoDBChangeSet();
        newChangeSet.setResourceId(changeSet.getResourceId());
        newChangeSet.setDriftDefinitionId(changeSet.getDriftDefinitionId());
        newChangeSet.setDriftHandlingMode(changeSet.getDriftHandlingMode());
        newChangeSet.setCategory(changeSet.getCategory());
        newChangeSet.setDriftDefinitionId(changeSet.getDriftDefinitionId());

        if (!isTemplateChangeSet(changeSet)) {
            DriftDefinition driftDef = getDriftDef(subject, changeSet.getDriftDefinitionId());
            if (driftDef == null) {
                throw new IllegalArgumentException("Cannot persist change set. " +
                        DriftDefinition.class.getSimpleName() + " with id " + changeSet.getDriftDefinitionId() +
                        " cannot be found.");
            }
            newChangeSet.setDriftDefinitionName(driftDef.getName());
        }

        for (Drift drift : changeSet.getDrifts()) {
            MongoDBChangeSetEntry entry = new MongoDBChangeSetEntry();
            entry.setPath(drift.getPath());
            entry.setCategory(drift.getCategory());
            // we only need to initialize the newFileHash property here since each drift
            // is going to be a FILE_ADDED entry.
            entry.setNewFileHash(drift.getNewDriftFile().getHashId());
            newChangeSet.add(entry);
        }

        changeSetDAO.save(newChangeSet);

        return newChangeSet.getId();
    }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.