Examples of com.mongodb.DBCollection.find()

com.mongodb.DBCollection.find()
Calls {@link DBCollection#find(com.mongodb.DBObject,com.mongodb.DBObject,int,int)} and applies the query options @param query query used to search @param fields the fields of matching objects to return @param numToSkip number of objects to skip @param batchSize the batch size. This option has a complex behavior, see {@link DBCursor#batchSize(int) } @param options - see Bytes QUERYOPTION_ @return the cursor @throws MongoException @dochub find

        list.beforeFetchingNextBatch();
      BasicDBObject query = new BasicDBObject();
      query.put("_id", new BasicDBObject("$in", keysToLookup));
      BasicDBObject orderBy = new BasicDBObject();
      orderBy.put("_id", 1);
      cursor = dbCollection.find(query).sort(orderBy).batchSize(batchSize);
      if (list != null)
        list.afterFetchingNextBatch(cursor.count());
    } else {
      cursor = new DBCursor(dbCollection, null, null, null);
    }

View Full Code Here


      BasicDBObject query = new BasicDBObject();
      query.put("_id", new BasicDBObject("$in", keysToLookup));
      BasicDBObject orderBy = new BasicDBObject();
      orderBy.put("_id", 1);
      cursor = dbCollection.find(query).sort(orderBy)
          .batchSize(batchSize);


      if (list != null)
        list.afterFetchingNextBatch(cursor.size());
    } else {

View Full Code Here

      BasicDBObject fields = new BasicDBObject();
      fields.put("_id", -1);
      fields.append("k", 1);
      fields.append("v", 1);


      cursor = dbCollection.find(query, fields);


      if (batchListener != null)
        batchListener.afterFetchingNextBatch(cursor.count());


      List<IndexColumn> finalRes = new ArrayList<IndexColumn>();

View Full Code Here

        Integer limit = exchange.getIn().getHeader(MongoDbConstants.LIMIT, Integer.class);
        DBObject sortBy = exchange.getIn().getHeader(MongoDbConstants.SORT_BY, DBObject.class);
        DBCursor ret = null;
        try {  
            if (query == null && fieldFilter == null) {
                ret = dbCol.find(new BasicDBObject());
            } else if (fieldFilter == null) {
                ret = dbCol.find(query);
            } else {
                ret = dbCol.find(query, fieldFilter);
            }

View Full Code Here

        DBCursor ret = null;
        try {  
            if (query == null && fieldFilter == null) {
                ret = dbCol.find(new BasicDBObject());
            } else if (fieldFilter == null) {
                ret = dbCol.find(query);
            } else {
                ret = dbCol.find(query, fieldFilter);
            }
            
            if (sortBy != null) {

View Full Code Here

            if (query == null && fieldFilter == null) {
                ret = dbCol.find(new BasicDBObject());
            } else if (fieldFilter == null) {
                ret = dbCol.find(query);
            } else {
                ret = dbCol.find(query, fieldFilter);
            }
            
            if (sortBy != null) {
                ret.sort(sortBy);
            }

View Full Code Here

        Integer limit = exchange.getIn().getHeader(MongoDbConstants.LIMIT, Integer.class);
        DBObject sortBy = exchange.getIn().getHeader(MongoDbConstants.SORT_BY, DBObject.class);
        DBCursor ret = null;
        try {
            if (query == null && fieldFilter == null) {
                ret = dbCol.find(new BasicDBObject());
            } else if (fieldFilter == null) {
                ret = dbCol.find(query);
            } else {
                ret = dbCol.find(query, fieldFilter);
            }

View Full Code Here

        DBCursor ret = null;
        try {
            if (query == null && fieldFilter == null) {
                ret = dbCol.find(new BasicDBObject());
            } else if (fieldFilter == null) {
                ret = dbCol.find(query);
            } else {
                ret = dbCol.find(query, fieldFilter);
            }


            if (sortBy != null) {

View Full Code Here

            if (query == null && fieldFilter == null) {
                ret = dbCol.find(new BasicDBObject());
            } else if (fieldFilter == null) {
                ret = dbCol.find(query);
            } else {
                ret = dbCol.find(query, fieldFilter);
            }


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

View Full Code Here

            queryBuilder.greaterThanEquals(startValue);
        }
        DBObject query = queryBuilder.get();
        long start = start();
        try {
            DBCursor cursor = dbCollection.find(query).sort(BY_ID_ASC);
            List<T> list = new ArrayList<T>();
            for (int i = 0; i < limit && cursor.hasNext(); i++) {
                DBObject o = cursor.next();
                T doc = convertFromDBObject(collection, o);
                if (collection == Collection.NODES && doc != null) {

View Full Code Here

0 1 2 3 4 5 6 7 8 9

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.