查询时经常会用到$in之类的操作符，比如db.collection_0.find("_id":{"$in","0001","0002","0003"})。

但是shell归shell，java里应该怎么写，在这就拿$in作为例子。

PS:我喜欢$in，尤其key是一个array类型的时候。

我用的是mongo-java-driver 2.11.0

现在我有个collection叫col_0，然后我在里面存了这么写东西。

170600366.jpg

假设这是_id为0001的用户有0002和0003两个好友。

现在我想查询一个用户的好友的好友，就像“推荐好友”那样的东西。

Java代码的话，大概可以这样写：

DB db = MonFactory.getInstance().getMongo().getDB("test");

        DBCollection dbCollection = db.getCollection("col_0");

        BasicDBObject term = new BasicDBObject();

        term.put("_id", uid);

        DBObject curUserData = dbCollection.findOne(term);

        List<String> p4pList = new ArrayList<String>();

        p4pList.addAll((Collection<? extends String>) curUserData.get("pals"));

        DBObject result;

        term = new BasicDBObject("_id", new BasicDBObject("$in", p4pList));

        DBCursor cursor = dbCollection.find(term);

        while (cursor.hasNext()) {

            if ((result = cursor.next()) != null) {

                System.out.println(result.get("pals"));

            }

        }

使用的BasicDBObject的构造函数是这样定义的:

public BasicDBObject(String key, Object value){

    super(key, value);

}

也就是说我把$in当作key来使用了。

按shell的语法来说貌似是那么回事，但我总觉得这种写法不够OO。

于是我用QueryBuilder这样写:

DB db = MonFactory.getInstance().getMongo().getDB("test");

        DBCollection dbCollection = db.getCollection("col_0");

        DBObject term = new BasicDBObject();

        term.put("_id", uid);

        DBObject curUserData = dbCollection.findOne(term);

        List<String> p4pList = new ArrayList<String>();

        p4pList.addAll((Collection<? extends String>) curUserData.get("pals"));

        DBObject result;

//      term = new BasicDBObject("_id", new BasicDBObject("$in", p4pList));

        term = QueryBuilder.start().and("id").in(p4pList).get();

        DBCursor cursor = dbCollection.find(term);

        while (cursor.hasNext()) {

            if ((result = cursor.next()) != null) {

                System.out.println(result.get("pals"));

            }

        }

有时候感觉OO真是自寻烦恼。

无论如何，条件操作符了这样就可以用了。

但我可能对对象关系映射之类的东西习惯了，所以我决定用Morphia什么的。

于是：

Mongo mongo = new MongoClient("localhost", 27017);

            DataStore store = new DataStore(mongo, "test");

            Query<Person> query = store.createQuery(Person.class);

            query.criteria("_id").equals(uid);

            query = store.createQuery(Person.class);

            query.criteria("_id").in(Arrays.asList(query.get().getPals()));

            for (Iterator<Person> itr = store.createQuery(Person.class)

                    .iterator(); itr.hasNext();) {

                System.out.println(itr.next().getPals());

            }

©著作权归作者所有：来自51CTO博客作者runtimeErr的原创作品，如需转载，请注明出处，否则将追究法律责任

javamongodb条件操作符进行查询Not Only SQL

3