Examples of com.mongodb.DBCursor.sort()

com.mongodb.DBCursor.sort()
Sorts this cursor's elements. This method must be called before getting any object from the cursor. @param orderBy the fields by which to sort @return a cursor pointing to the first element of the sorted results

    public List<JobExecution> getJobExecutions(final JobInstance jobInstance) {
        long jobInstanceId = jobInstance == null ? 0 : jobInstance.getInstanceId();
        DBCursor cursor = jobInstance == null ? db.getCollection(TableColumns.JOB_EXECUTION).find() :
                db.getCollection(TableColumns.JOB_EXECUTION).find(
                        new BasicDBObject(TableColumns.JOBINSTANCEID, jobInstance.getInstanceId()));
        cursor = cursor.sort(new BasicDBObject(TableColumns.JOBEXECUTIONID, 1));
        final List<JobExecution> result = new ArrayList<JobExecution>();
        while (cursor.hasNext()) {
            final DBObject next = cursor.next();
            final Long i = (Long) next.get(TableColumns.JOBEXECUTIONID);
            JobExecution jobExecution1 = jobExecutions.get(i);

View Full Code Here

     */
    List<StepExecution> selectStepExecutions(final Long jobExecutionId) {
        final DBCollection collection = db.getCollection(TableColumns.STEP_EXECUTION);
        DBCursor cursor = jobExecutionId == null ? collection.find() :
                collection.find(new BasicDBObject(TableColumns.JOBEXECUTIONID, jobExecutionId));
        cursor = cursor.sort(new BasicDBObject(TableColumns.STEPEXECUTIONID, 1));
        final List<StepExecution> result = new ArrayList<StepExecution>();
        createStepExecutionsFromDBCursor(cursor, result);
        return result;
    }

View Full Code Here

            } else {
                ret = dbCol.find(query, fieldFilter);
            }
            
            if (sortBy != null) {
                ret.sort(sortBy);
            }
            
            if (batchSize != null) {
                ret.batchSize(batchSize.intValue());
            }

View Full Code Here

            } else {
                ret = dbCol.find(query, fieldFilter);
            }


            if (sortBy != null) {
                ret.sort(sortBy);
            }


            if (batchSize != null) {
                ret.batchSize(batchSize.intValue());
            }

View Full Code Here

            } else {
                ret = dbCol.find(query, fieldFilter);
            }


            if (sortBy != null) {
                ret.sort(sortBy);
            }


            if (batchSize != null) {
                ret.batchSize(batchSize.intValue());
            }

View Full Code Here

  private ClosableIterator<Tuple> doFind(MongoDBQueryDescriptor query, QueryParameters queryParameters, DBCollection collection,
      EntityKeyMetadata entityKeyMetadata) {
    DBCursor cursor = collection.find( query.getCriteria(), query.getProjection() );


    if ( query.getOrderBy() != null ) {
      cursor.sort( query.getOrderBy() );
    }


    // apply firstRow/maxRows if present
    if ( queryParameters.getRowSelection().getFirstRow() != null ) {
      cursor.skip( queryParameters.getRowSelection().getFirstRow() );

View Full Code Here

        CommitMongo secondCommit = new CommitMongo();
        secondCommit.setAffectedPaths(Arrays.asList(new String[] { "/a", "/a/d", "/a/b/e" }));
        secondCommit.setRevisionId(2L);


        DBCursor mockDbCursor = EasyMock.createMock(DBCursor.class);
        EasyMock.expect(mockDbCursor.sort(EasyMock.anyObject(DBObject.class))).andReturn(mockDbCursor);
        EasyMock.expect(mockDbCursor.limit(EasyMock.anyInt())).andReturn(mockDbCursor);
        EasyMock.expect(mockDbCursor.hasNext()).andReturn(true).once();
        EasyMock.expect(mockDbCursor.next()).andReturn(firstCommit).once();
        EasyMock.expect(mockDbCursor.hasNext()).andReturn(true).once();
        EasyMock.expect(mockDbCursor.next()).andReturn(secondCommit).once();

View Full Code Here

        CommitMongo secondCommit = new CommitMongo();
        secondCommit.setAffectedPaths(Arrays.asList(new String[] { "/a", "/a/d", "/a/b/e" }));
        secondCommit.setRevisionId(2L);


        DBCursor mockDbCursor = EasyMock.createMock(DBCursor.class);
        EasyMock.expect(mockDbCursor.sort(EasyMock.anyObject(DBObject.class))).andReturn(mockDbCursor);
        EasyMock.expect(mockDbCursor.limit(EasyMock.anyInt())).andReturn(mockDbCursor);
        EasyMock.expect(mockDbCursor.hasNext()).andReturn(true).once();
        EasyMock.expect(mockDbCursor.next()).andReturn(firstCommit).once();
        EasyMock.expect(mockDbCursor.hasNext()).andReturn(true).once();
        EasyMock.expect(mockDbCursor.next()).andReturn(secondCommit).once();

View Full Code Here

        if (high > 0) {
            filter.append("id", new BasicDBObject("$lte", high));
        }


        DBCursor cursor = collection.find(filter);
        cursor.sort(new BasicDBObject("id", 1));


        List<Event> Events = new ArrayList<Event>();
        while (cursor.hasNext()) {
            DBObject event = cursor.next();
            String targetId = (String) event.get("targetId");

View Full Code Here


        BasicDBObject filter = new BasicDBObject().append("targetId", targetID)
            .append("logId", logID);


        DBCursor cursor = collection.find(filter);
        cursor.sort(new BasicDBObject("id", -1));


        long high = 1;
        if (cursor.hasNext()) {
            DBObject row = cursor.next();
            high = (Long) row.get("id");

View Full Code Here

0 1 2 3 4

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.