您好,登錄后才能下訂單哦!
查詢時經常會用到$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,然后我在里面存了這么寫東西。
假設這是_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的構造函數是這樣定義的:
/** * 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); }
也就是說我把$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()); }
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。