【mongoDB】Java中使用條件操作符進(jìn)行查詢

查詢時(shí)經(jīng)常會(huì)用到$in之類(lèi)的操作符，比如db.collection_0.find("_id":{"$in","0001","0002","0003"})。
但是shell歸shell，java里應(yīng)該怎么寫(xiě)，在這就拿$in作為例子。
PS:我喜歡$in，尤其key是一個(gè)array類(lèi)型的時(shí)候。

我用的是mongo-java-driver 2.11.0

現(xiàn)在我有個(gè)collection叫col_0，然后我在里面存了這么寫(xiě)東西。

假設(shè)這是_id為0001的用戶有0002和0003兩個(gè)好友。
現(xiàn)在我想查詢一個(gè)用戶的好友的好友，就像“推薦好友”那樣的東西。

Java代碼的話，大概可以這樣寫(xiě)：

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的構(gòu)造函數(shù)是這樣定義的:

/**
 * creates an object with the given key/value
 * @param key  key under which to store
 * @param value value to stor
 */
public BasicDBObject(String key, Object value){
    super(key, value);
}

也就是說(shuō)我把$in當(dāng)作key來(lái)使用了。
按shell的語(yǔ)法來(lái)說(shuō)貌似是那么回事，但我總覺(jué)得這種寫(xiě)法不夠OO。
于是我用QueryBuilder這樣寫(xiě):

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"));
            }
        }

有時(shí)候感覺(jué)OO真是自尋煩惱。
無(wú)論如何，條件操作符了這樣就可以用了。

但我可能對(duì)對(duì)象關(guān)系映射之類(lèi)的東西習(xí)慣了，所以我決定用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());
            }