查询时常常会用到$in之类的操做符,好比db.collection_0.find("_id":{"$in","0001","0002","0003"})。
可是shell归shell,java里应该怎么写,在这就拿$in做为例子。
PS:我喜欢$in,尤为key是一个array类型的时候。
java
我用的是mongo-java-driver 2.11.0
如今我有个collection叫col_0,而后我在里面存了这么写东西。
假设这是_id为0001的用户有0002和0003两个好友。
如今我想查询一个用户的好友的好友,就像“推荐好友”那样的东西。
Java代码的话,大概能够这样写:
shell
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的构造函数是这样定义的:
ide
/** * 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什么的。
因而:
ui
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()); }