MongoDB Java驱动程序 - 在查找查询中使用exists投影

3

我想获取所有没有下载字段的文档

find{ "download" : {$exists: false}}

对于Java,我找到了一个示例:

  BasicDBObject neQuery = new BasicDBObject();
  neQuery.put("number", new BasicDBObject("$ne", 4));
  DBCursor cursor = collection.find(neQuery);

  while(cursor.hasNext()) {
    System.out.println(cursor.next());
  }

我的适应性是:
      BasicDBObject field = new BasicDBObject();
      field.put("entities.media", 1);
  field.put("download", new BasicDBObject("$exists",false));
  System.out.println("Start Find");
  DBCursor  cursor = collection.find(query,field);      
      System.out.println("End Find Start Loop ALL 100k");
   int i = 1;
                while(cursor.hasNext())

Exists命令行无法正常工作:

Exception in thread "main" java.lang.reflect.InvocationTargetException
        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
        at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
        at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
        at java.lang.reflect.Method.invoke(Method.java:616)
        at org.eclipse.jdt.internal.jarinjarloader.JarRsrcLoader.main(JarRsrcLoader.java:58)
Caused by: com.mongodb.MongoException: Unsupported projection option: $exists
        at com.mongodb.MongoException.parse(MongoException.java:82)
        at com.mongodb.DBApiLayer$MyCollection.__find(DBApiLayer.java:314)
        at com.mongodb.DBApiLayer$MyCollection.__find(DBApiLayer.java:295)
        at com.mongodb.DBCursor._check(DBCursor.java:368)
        at com.mongodb.DBCursor._hasNext(DBCursor.java:459)
        at com.mongodb.DBCursor.hasNext(DBCursor.java:484)
        at ImgToDisk.main(ImgToDisk.java:61)
        ... 5 more

目前我不知道正确的适应方式,因为在shell和UMongo中已经使我的查询工作正常,但是转移到Java中似乎并不那么容易。


在您的find()调用中,您可以引用一个查询对象。在示例中包含这一点可能会有所帮助。 - rompetroll
3个回答

7
您使用的是:
collection.find(query,field);

find方法的第二个参数是指示您要返回哪些文档属性的DBObject。它有助于减少网络负载。

在您的示例中,您尝试将$exists子句放入名为“field”的DBObject中,但这样做是行不通的。 第二个参数对象只能具有1(包括此属性)或0(排除此属性)的属性值。

请将其放入名为“query”的第一个DBObject中。

还可以参见此处此处


2
你可以使用JAVA API中的DBCollection来完成这个任务。
public List<BasicDBObject> Query(String collection, Map<String, String> query, String... excludes) {
BasicDBObject bquery = new BasicDBObject(query);
BasicDBObject bexcludes = new BasicDBObject(excludes.length);
for (String ex : excludes) {
  bexcludes.append(ex, false);
}
return db.getCollection(collection, BasicDBObject.class).find(bquery).projection(bexcludes)
    .into(new ArrayList<BasicDBObject>());

}

数据库是MongoDataBase


2
我们需要指定两件事情。
第一:
collection.find(query,field);

以上命令不来自MongoDB Java驱动程序。 这意味着我们只能在mongo shell(或mongo Compass)中运行,而不能在Java中运行。

第二: 要在Java中限制字段,可以使用projection(),如以下代码所示

find(queryFilter)
.projection(fields(include("title", "year"),exclude("_id")))

完整示例:

Bson queryFilter = eq("cast", "Salma Hayek");
//or Document queryFilter = new Document("cast", "Salma Hayek");

Document result =
        collection
            .find(queryFilter)
            //.limit(1)  if you want to limit the result 

            .projection(fields(include("title", "year"),exclude("_id")))
       //or .projection(fields(include("title", "year"), excludeId()))
       //or .projection(new Document("title", 1).append("year", 1))
            .iterator()
            .tryNext();

网页内容由stack overflow 提供, 点击上面的
可以查看英文原文,
原文链接