|
版本一:
; T e a* C/ B6 c7 ~7 p# [5 K. E5 D' u9 i g3 q& f
1 ) . 大于,小于,大于或等于,小于或等于
6 i! D4 M, u- `7 T9 L+ H; o8 e1 U
. ]( i) R) U9 d9 h4 u$gt:大于
- \6 M$ d: {, a2 b+ p1 D# Y* o$lt:小于3 |4 a: s. v# O" v4 i
$gte:大于或等于
( B9 I# z7 R- ~5 _9 r) F. V$lte:小于或等于
# a8 B# v ~" E( ]. a& y& U) W" Z( \7 |" J$ j$ E
例子: - db.collection.find({ "field" : { $gt: value } } ); // greater than : field > value
4 P+ i* [: D) D% r" X" h+ T - db.collection.find({ "field" : { $lt: value } } ); // less than : field < value6 s% o( H! G6 ?8 w' p
- db.collection.find({ "field" : { $gte: value } } ); // greater than or equal to : field >= value
2 z# y$ H5 c) h4 v - db.collection.find({ "field" : { $lte: value } } ); // less than or equal to : field <= value
复制代码 9 T' e) [+ I" {( M
如查询j大于3,小于4: - db.things.find({j : {$lt: 3}});& ^) p+ l& g" B: V8 O e; k
- db.things.find({j : {$gte: 4}});
复制代码
8 V- V) \- p( V4 A: T7 s也可以合并在一条语句内: - db.collection.find({ "field" : { $gt: value1, $lt: value2 } } ); // value1 < field < value
复制代码
$ Q, V5 c) T1 N' x) N. A" w: E& c: Q) o0 u9 ?
2 ?/ l: j9 ^& K7 q" y2) 不等于 $ne 例子: - db.things.find( { x : { $ne : 3 } } );
复制代码
% r" u2 Y& o5 ]2 d, W# }" ^7 t' B7 G/ W3) in 和 not in ($in $nin)0 C& I0 c* J. ?5 \
5 ?4 q1 q, a3 D" L1 M1 c) v
语法: - db.collection.find( { "field" : { $in : array } } );
复制代码 e5 ^3 N, n* N* I# L5 m
例子: - db.things.find({j:{$in: [2,4,6]}});5 F% [" ]# l* T& N0 u
- db.things.find({j:{$nin: [2,4,6]}});
复制代码 ( }" m3 W& n. D. {7 l; ^5 J. k
& m2 K- j8 ^( T( V: i# b* F
4) 取模运算$mod* U( P6 ^+ L" A8 a0 U5 a
4 \, p( w" m6 g5 ^如下面的运算: - db.things.find( "this.a % 10 == 1")
复制代码 $ J" k" R3 `8 k2 T, X8 G
可用$mod代替: - db.things.find( { a : { $mod : [ 10 , 1 ] } } )
复制代码
& _9 v0 W. L0 V4 \5 `( }6 m/ i ^" ]& w
5) $all
+ f6 r3 D& w7 R. A) o i Y" c+ `. j9 H! n) D" J0 k: G
$all和$in类似,但是他需要匹配条件内所有的值:8 D: x! S& T3 s& R! k9 E% c- `
$ j* ]% P/ G, c+ M# H% Q如有一个对象:
3 D8 A! b2 h8 D; _' G
# Y+ o; ^) q7 [. T/ L0 R4 m下面这个条件是可以匹配的: - db.things.find( { a: { $all: [ 2, 3 ] } } );
复制代码
0 g- x- u9 D: H$ ~但是下面这个条件就不行了: - db.things.find( { a: { $all: [ 2, 3, 4 ] } } );
复制代码
& |9 x' y$ e8 O m) G
7 D1 c, ?% E6 ?0 }6) $size
1 H9 d4 W) y5 t, L" L5 V" i& s
' U6 e7 A8 n! j$size是匹配数组内的元素数量的,如有一个对象:{a:["foo"]},他只有一个元素:! k* e, S% p- t- D) ~
+ t% D3 h0 X8 ~* q( c2 Y5 l% M下面的语句就可以匹配:
- db.things.find( { a : { $size: 1 } } );
复制代码
; k; b; s: A' V2 x; T4 {官网上说不能用来匹配一个范围内的元素,如果想找$size<5之类的,他们建议创建一个字段来保存元素的数量。 You cannot use $size to find a range of sizes (for example: arrays with more than 1 element). If you need to query for a range, create an extra size field that you increment when you add elements.
% v6 d1 A+ Z6 `* B* v4 h7)$exists $exists用来判断一个元素是否存在: 如: - db.things.find( { a : { $exists : true } } ); // 如果存在元素a,就返回5 |& k2 ?4 V6 u
- db.things.find( { a : { $exists : false } } ); // 如果不存在元素a,就返回
复制代码
. f1 n) |: ~' {2 q8) $type $type 基于 bson type来匹配一个元素的类型,像是按照类型ID来匹配,不过我没找到bson类型和id对照表。 - db.things.find( { a : { $type : 2 } } ); // matches if a is a string8 C* H( E% w+ t1 z) c
- db.things.find( { a : { $type : 16 } } ); // matches if a is an int
复制代码 " V. o* [( a/ L5 `$ |6 r' p
9)正则表达式' G; s$ e3 v# u" L
# u8 A u1 M( J1 s; ?% y3 @, h+ h( [. Z
mongo支持正则表达式,如: - db.customers.find( { name : /acme.*corp/i } ); // 后面的i的意思是区分大小写
复制代码
5 F' e1 J- j: w# F9 i' \6 E10) 查询数据内的值
3 h& r. V: j" M4 B3 A( n3 ]! j2 [1 a; S$ L. K( E; U; ~7 \$ s
下面的查询是查询colors内red的记录,如果colors元素是一个数据,数据库将遍历这个数组的元素来查询。 - db.things.find( { colors : "red" } );
复制代码 9 {# R9 Q) k) t$ f8 ~: x: J
11) $elemMatch
& s9 L& \% W( y) S- j9 X. S7 ^
8 G5 T' N3 E# H) `& N: c- Y如果对象有一个元素是数组,那么$elemMatch可以匹配内数组内的元素: - > t.find( { x : { $elemMatch : { a : 1, b : { $gt : 1 } } } } )
' ~) [0 B0 k& a% E9 y7 l - { "_id" : ObjectId("4b5783300334000000000aa9"), " ~* f G* ~# T1 r H* w
- "x" : [ { "a" : 1, "b" : 3 }, 7, { "b" : 99 }, { "a" : 11 } ]
1 g9 f1 ]+ [4 w3 D0 H7 M - }
复制代码
0 X, u( {! `9 n6 Z$elemMatch : { a : 1, b : { $gt : 1 } } 所有的条件都要匹配上才行。注意,上面的语句和下面是不一样的。 > t.find( { "x.a" : 1, "x.b" : { $gt : 1 } } )+ e" K4 _* b2 ^/ q( i4 i
$elemMatch是匹配{ "a" : 1, "b" : 3 },而后面一句是匹配{ "b" : 99 }, { "a" : 11 }
4 g6 S C* Q. W8 R( F
+ x1 |4 T- a4 i0 v1 n( ]12) 查询嵌入对象的值 - db.postings.find( { "author.name" : "joe" } );
复制代码
. J: ~% [7 W% K L) N q举个例子: - > db.blog.save({ title : "My First Post", author: {name : "Jane", id : 1}})
复制代码 ' c: v, m) a2 a* C
如果我们要查询 authors name 是Jane的, 我们可以这样: - > db.blog.findOne({"author.name" : "Jane"})
复制代码 2 |3 a+ E/ Q) I9 w9 @9 G0 w( K
如果不用点,那就需要用下面这句才能匹配: - db.blog.findOne({"author" : {"name" : "Jane", "id" : 1}})
复制代码
7 N, e2 B' k; m" S( y' j下面这句: - db.blog.findOne({"author" : {"name" : "Jane"}})
复制代码 & W8 b% k H8 P( z% [" E
是不能匹配的,因为mongodb对于子对象,他是精确匹配。 # R$ W" k8 Y: ^+ b
13) 元操作符 $not 取反 如: - db.customers.find( { name : { $not : /acme.*corp/i } } );
& x Q- R. M0 v8 t# p2 |% Y - db.things.find( { a : { $not : { $mod : [ 10 , 1 ] } } } );
复制代码
7 A! z5 q- M$ hshell 环境下的操作: 1. 超级用户相关: 1. #进入数据库admin
! ]6 l5 Y1 }+ S
, O2 n/ f% M1 h; i. c/ b2 k 2. #增加或修改用户密码 3. #查看用户列表 4. #用户认证 5. #删除用户
2 A# U9 _! r5 x1 o1 Z6 m, }* {% ~ 6. #查看所有用户 7. #查看所有数据库 : Y2 n8 @: j3 V G/ X! v" Z
8. #查看所有的collection 9. #查看各collection的状态 - db.printCollectionStats()
复制代码 / `8 U; Y& A# J0 B$ u) |% ?$ @
10. #查看主从复制状态 - db.printReplicationInfo()
复制代码
2 n- G2 F' M' Q- N; F& p 11. #修复数据库 12. #设置记录profiling,0=off 1=slow 2=all 13. #查看profiling
4 U8 e5 z0 o" o# B; R. \# b 14. #拷贝数据库 - db.copyDatabase('mail_addr','mail_addr_tmp')
复制代码
' ]7 D7 l- L4 G- y) j l: y3 I+ {) c 15. #删除collection ' G% w# W; m7 n* b# c+ ]% U$ L( @* m# t
16. #删除当前的数据库 2. 增删改 1. #存储嵌套的对象 - db.foo.save({'name':'ysz','address':{'city':'beijing','post':100096},'phone':[138,139]})
复制代码
- x# }, ?' Y( @4 q2 ^: y 2. #存储数组对象 - db.user_addr.save({'Uid':'yushunzhi@sohu.com','Al':['test-1@sohu.com','test-2@sohu.com']})
复制代码
. T. P; m# d+ x& m/ v 3. #根据query条件修改,如果不存在则插入,允许修改多条记录 - db.foo.update({'yy':5},{'$set':{'xx':2}},upsert=true,multi=true)
复制代码
. S, b, I% ^' c) R3 C! g2 S) X 4. #删除yy=5的记录
7 R/ q0 M0 ?* y, c0 @7 v* D 5. #删除所有的记录 3. 索引 1. #增加索引:1(ascending),-1(descending) 2. db.foo.ensureIndex({firstname: 1, lastname: 1}, {unique: true}); 3. #索引子对象 4. db.user_addr.ensureIndex({'Al.Em': 1}) 5. #查看索引信息 6. db.foo.getIndexes() 7. db.foo.getIndexKeys() 8. #根据索引名删除索引 9. db.user_addr.dropIndex('Al.Em_1') 4. 查询 1. #查找所有 2. db.foo.find() 3. #查找一条记录 4. db.foo.findOne() 5. #根据条件检索10条记录 6. db.foo.find({'msg':'Hello 1'}).limit(10) 7. #sort排序 8. db.deliver_status.find({'From':'ixigua@sina.com'}).sort({'Dt',-1}) 9. db.deliver_status.find().sort({'Ct':-1}).limit(1) 10. #count操作 11. db.user_addr.count() 12. #distinct操作,查询指定列,去重复 13. db.foo.distinct('msg') 14. #”>=”操作 15. db.foo.find({"timestamp": {"$gte" : 2}}) 16. #子对象的查找 17. db.foo.find({'address.city':'beijing'}) 5. 管理 1. #查看collection数据的大小 2. db.deliver_status.dataSize() 3. #查看colleciont状态 4. db.deliver_status.stats() 5. #查询所有索引的大小 6. db.deliver_status.totalIndexSize()
. z! L2 J0 k `' K$ J6 N' f6. 高级查询 条件操作符 / y! V G" Y% c' o G6 m3 A2 A! h3 U
- $gt : >
2 E3 h/ @, [+ Q3 h) d. x3 n, h - $lt : <
* ?% }) L) z5 D# Z. w, P - $gte: >= * p8 T, m' n4 }$ |6 ^
- $lte: <=
1 s8 a, B+ N! ?8 a/ P - $ne : !=、<>
$ z' P) x% c3 O- T - $in : in
$ z r0 F' Y( R( r; P* w' A - $nin: not in
3 t) Z5 }9 d6 r6 x - $all: all ' C+ ~0 c& e( T- _0 q
- $not: 反匹配(1.3.3及以上版本)
复制代码 3 B2 | H# o! l8 P1 M5 I# g
4 z) v% z" t$ f8 c- s
查询 name <> "bruce" and age >= 18 的数据
8 A2 t' J' `, w6 G# f- db.users.find({name: {$ne: "bruce"}, age: {$gte: 18}});
复制代码 $ t$ X+ [3 Z) Z$ C
! `5 ~7 e/ \+ t; j
查询 creation_date > '2010-01-01' and creation_date <= '2010-12-31' 的数据
+ y. v! J4 ^7 e. x8 ]- db.users.find({creation_date:{$gt:new Date(2010,0,1), $lte:new Date(2010,11,31)});
复制代码
( H0 G. z. y# w$ [
' n) K; [' r. C; \6 b查询 age in (20,22,24,26) 的数据 ' ^, \" ^0 p4 b1 ~
- db.users.find({age: {$in: [20,22,24,26]}});
复制代码
7 V% O3 Z; U% N3 f9 u7 b
+ U) A. K5 r0 |% a* }0 K: R查询 age取模10等于0 的数据
9 o) [; D o+ G) V- db.users.find('this.age % 10 == 0');
复制代码 z( G/ ^1 {5 i! F
或者
. n" C8 |1 w+ K" j& z6 V- db.users.find({age : {$mod : [10, 0]}});
复制代码 8 C3 l5 v4 d, ?; `
+ M2 e( K2 H, m* g0 T匹配所有
# l. u, l! [$ \- _7 _- H- L- db.users.find({favorite_number : {$all : [6, 8]}});
复制代码
( K+ |5 n9 Y' L1 S可以查询出{name: 'David', age: 26, favorite_number: [ 6, 8, 9 ] } ) N4 q2 b6 L. @; v2 Y8 b1 E6 {
可以不查询出{name: 'David', age: 26, favorite_number: [ 6, 7, 9 ] }
* X4 b# ~; n& U. `8 E; D) a. J5 L" P+ j$ [* Z
查询不匹配name=B*带头的记录 * V9 k+ j0 ^% K2 F
- db.users.find({name: {$not: /^B.*/}});
复制代码 ! q6 O A3 l: d4 }% K4 @
查询 age取模10不等于0 的数据
3 {$ ~$ P% G, ^- db.users.find({age : {$not: {$mod : [10, 0]}}});
复制代码 p8 x% ?. g& [
9 o: v1 t8 }) R' S% j/ }7 n#返回部分字段 7 M+ e! s z0 T0 |) d3 N( U3 v
选择返回age和_id字段(_id字段总是会被返回) % K; o9 m7 r8 O8 d
- db.users.find({}, {age:1}); 2 i: Y1 s+ y; k0 X; ?6 G( K2 T
- db.users.find({}, {age:3}); ; [5 R7 C9 [" S9 d7 K- x* M/ r
- db.users.find({}, {age:true}); . I# y2 y" a( i( K
- db.users.find({ name : "bruce" }, {age:1});
复制代码
% e" Q2 z/ C) i% G0为false, 非0为true
: s |, M. Q9 B+ _; a1 T |4 o9 y8 O6 ~9 t1 H( R5 x
选择返回age、address和_id字段
5 Q7 G$ j- b% D: S+ s( F- db.users.find({ name : "bruce" }, {age:1, address:1});
复制代码
1 w$ ? v% Z6 J" D! Y0 m, r; K' |1 ~( q# H2 r: ~1 v
排除返回age、address和_id字段 % ?% M" z$ _0 z5 F- V9 o2 [
- db.users.find({}, {age:0, address:false});
: S# d; n' t, o/ E- c - db.users.find({ name : "bruce" }, {age:0, address:false});
复制代码
$ o" I7 }2 i$ {- p( Q
6 F7 U @9 Z* D7 ^) y数组元素个数判断 6 I! Y2 E4 O; `- E6 C1 N
对于{name: 'David', age: 26, favorite_number: [ 6, 7, 9 ] }记录 # Z7 B& w$ i7 i4 X% q( A
匹配db.users.find({favorite_number: {$size: 3}});
0 U: y* ^2 j9 u( C& L: c不匹配db.users.find({favorite_number: {$size: 2}}); ; q( ^7 E- p2 G+ _4 ]
6 ?" n( i5 u! T# \2 l5 ]7 }$exists判断字段是否存在
1 a K: c. ^) B9 W) l# j' K查询所有存在name字段的记录 % |& R4 ?1 F: B3 S+ l+ {6 J
- db.users.find({name: {$exists: true}});
复制代码 ) e c' \8 c1 f7 Z& `
查询所有不存在phone字段的记录 9 F2 n! l6 R4 ?. n2 p
- db.users.find({phone: {$exists: false}});
复制代码
! P5 W& Y# M/ ^7 {8 z5 Y; `: p) s. `4 r
$type判断字段类型 ) i4 o6 K' x' ~* S0 k
查询所有name字段是字符类型的 + r, f" _2 c, A/ c4 F
- db.users.find({name: {$type: 2}});
2 o% X7 S6 {& K4 I& r
复制代码
; x; G% b7 G& }9 C2 O查询所有age字段是整型的
$ X6 K: n% ] D8 G7 Q; l! e( ^- db.users.find({age: {$type: 16}});
( f3 c, l, j2 t
复制代码
/ `" t. u9 D1 {$ M对于字符字段,可以使用正则表达式 & `, ^0 O9 _( c4 Y
查询以字母b或者B带头的所有记录
$ [& J8 s" {7 x4 n- db.users.find({name: /^b.*/i});
/ [1 t- I8 d Y @+ i, s
复制代码 ; ~' q- f# {0 m* {9 m$ S* o
$elemMatch(1.3.1及以上版本) ' E2 Y* ~* K A5 W/ O* A3 E I
为数组的字段中匹配其中某个元素
( T; ?/ V6 ?9 g' `
% e; @/ ~* f5 T. p7 V' d4 ~Javascript查询和$where查询 1 ^; J9 c/ g3 b5 W# W! F. |
查询 age > 18 的记录,以下查询都一样
- E8 B% C% W9 v& i( M- db.users.find({age: {$gt: 18}});
2 f& m5 V4 i7 A' {* D T: {0 u' g - db.users.find({$where: "this.age > 18"}); , z/ r9 F) _# X
- db.users.find("this.age > 18");
5 Z3 V' h) D7 N$ t' ^ - f = function() {return this.age > 18} db.users.find(f);
复制代码
/ P- q& f+ f7 a) c' T6 F- Q7 G7 f* }9 ~/ P6 x' m
排序sort() ) s u; R0 O4 G2 a1 W# f) W
以年龄升序asc 4 W6 [- Q2 } L
- db.users.find().sort({age: 1}); ) q6 ?( l; w* Q+ a, g
复制代码
6 Z- {7 l* a4 a7 c以年龄降序desc ; a* q* o$ R4 A$ F
- db.users.find().sort({age: -1});
; |% f) S z/ l' q
复制代码 + o. a$ W' m$ C: @
限制返回记录数量limit()
+ }( }! S' N9 i+ A' i( j返回5条记录 8 e% n8 T: q1 l, I
- db.users.find().limit(5);
' O6 ?, u; g/ e( Q; y+ k# U
复制代码
8 C$ m7 O* L3 Q. R3 I返回3条记录并打印信息 ( H: ~/ `% B% w2 y5 j; I# B7 c* P
- db.users.find().limit(3).forEach(function(user) {print('my age is ' + user.age)}); 0 J( L5 `0 y6 t! @* c
复制代码
! w$ E' Z5 ~! y7 x p结果
/ P3 [ j8 G/ b `$ _; e- my age is 18
+ J- s4 e" c& X& Q) P2 E0 v- \ - my age is 19 3 A& Z; _: z j! a2 R& @9 x* A
- my age is 20
复制代码
' w4 s5 a: ?1 q/ w) F5 L7 k
, S1 b; l' K( J% |2 M w限制返回记录的开始点skip()
) K; z9 `4 m4 Y4 j" @0 }# ?9 W从第3条记录开始,返回5条记录(limit 3, 5)
6 E7 v1 Y' ~5 q! G' K! Y- db.users.find().skip(3).limit(5);
) c! z( L* }+ P+ k* A. a) K- i
复制代码 / x" R5 y- `. M2 J
查询记录条数count()
/ V3 [$ _' y" }) Hdb.users.find().count(); ( x+ v* k9 Z4 k Z. C% {
db.users.find({age:18}).count(); - b- h3 x) t3 _, M5 i: H
以下返回的不是5,而是user表中所有的记录数量 2 S G0 |8 I: Q8 I& P
db.users.find().skip(10).limit(5).count(); ( E/ g$ d' F6 S
如果要返回限制之后的记录数量,要使用count(true)或者count(非0)
# O0 t- F8 G! A6 w- db.users.find().skip(10).limit(5).count(true);
复制代码
0 _1 Z/ K4 Q& X+ M+ ?
4 h# [- E$ X$ u' n分组group()
& Y( a% ~. H5 X( M假设test表只有以下一条数据 ! B: ^4 f" j4 f" P6 B0 @
- { domain: "www.mongodb.org" - X/ @2 H+ L s, Z5 f( ?8 R
- , invoked_at: {d:"2009-11-03", t:"17:14:05"} 9 y; q: k @5 a$ U1 R! P* q
- , response_time: 0.05 0 Z. b$ M+ e2 c& G: w& u
- , http_action: "GET /display/DOCS/Aggregation"
& v: S! n+ v, ` - }
复制代码 + y2 n m0 _2 t6 R- ^
使用group统计test表11月份的数据count:count(*)、total_time:sum(response_time)、avg_time:total_time/count;
2 p6 a2 s; Q( a! W. E- db.test.group(
7 n" R% ^- q8 N# C! o: |# l/ d* l! d } - { cond: {"invoked_at.d": {$gt: "2009-11", $lt: "2009-12"}} * t( C4 P3 Y1 ~; `+ @0 ]3 e: J
- , key: {http_action: true}
9 S% I( X' v' e% e7 K- ` - , initial: {count: 0, total_time:0} - ]5 q0 ~$ L# W6 u9 n
- , reduce: function(doc, out){ out.count++; out.total_time+=doc.response_time } 9 T5 h' W/ A7 [* q' K) X& x6 ^
- , finalize: function(out){ out.avg_time = out.total_time / out.count }
6 V3 m& ]' l+ n - } ); * Z$ `# P5 Q" z( v% V
- : {& J$ K+ M# r2 E" A) c
- [ G: x* i4 `) v
- { 5 x8 j, ?) ~& f+ {! ^2 V/ a" O
- "http_action" : "GET /display/DOCS/Aggregation", 2 v7 `' H1 H2 A& r, y
- "count" : 1,
B' J1 m y; z - "total_time" : 0.05,
v9 b' ]1 D2 J6 b- @1 m - "avg_time" : 0.05
7 N8 e& h3 m5 [. u# u - } ; }- [, G5 s, I- ?& [: O4 @+ }
- ]
复制代码 - t4 d* P8 c. j! V. M0 y; l
/ B* A R" R1 F4 ^& @
2 }( l! @& K) ]1 n/ QMongoDB 高级聚合查询MongoDB版本为:2.0.8 系统为:64位Ubuntu 12.04 先给他家看一下我的表结构[Oh sorry, Mongo叫集合] 如你所见,我尽量的模拟现实生活中的场景。这是一个人的实体,他有基本的manId, manName, 有朋友[myFriends],有喜欢的水果[fruits],而且每种水果都有喜欢的权重。 很不好的是你还看见了有个“_class”字段? 因为我是Java开发者, 我还喜欢用Spring,因此我选用了Spring Data Mongo的类库[也算是框架吧,但是我不这么觉得]。 现在有很多人Spring见的腻了也开始烦了。是的,Spring野心很大,他几乎想要垄断Java方面的任何事情。没办法我从使用Spring后就离不开他,以至于其他框架基本上都不用学。我学了Spring的很多,诸如:Spring Security/Spring Integration/Spring Batch等。。。不发明轮子的他已经提供了编程里的很多场景,我利用那些场景解决了工作中的很多问题,也使我的工作变得很高效。从而我又时间学到它更多。Spring Data Mongo封装了mongodb java driver,提供了和SpringJDBC/Template一致编程风格的MongoTemplate。 不说废话了,我们直接来MongoDB吧。 - Max 和Min7 `7 m) j8 ~) s5 L$ g4 j' }
我和同事在测试Mongo时,索引还写了不到一半,他想查询某个字段的最大值,结果找了半天文档也没找到关于max的函数。我也很纳闷这是常规函数啊怎么不提供? 后来经过翻阅资料确定Mongo确实不提供直接的max和min函数。但是可以通过间接的方式[sort 和 limit]实现这个。 要查询最大值我们只需要把结果集按照降序排列,取第一个值就是了。 如我的例子,我想取得集合中年龄最大的人。 - db.person.find({}).sort({"age" : -1}).limit(1)
复制代码 * S( ~! f0 Z# p6 u; ?8 s) W) Z7 f% H5 V' q
2 z0 w2 O4 s9 f2 i/ K1 K
* U: D1 o5 l" S1 a相反如果想要年龄最小的人,只需要把sort中改为{“age”:1}就可以了。 当然我们使用了sort,对于小数量的文档是没问题的。当对于大量数据需要给age建立索引,否则这个操作很耗时。 - distinct$ n H J2 M" {& \4 n
MongoDB的destinct命令是获取特定字段中不同值列表的最简单工具。该命令适用于普通字段,数组字段[myFriends]和数组内嵌文档[fruits]. 如上面的图片,我认为fruits和myFriends字段是不同的。网上很多资料和例子都没说到这个情景,因为我们也业务是fruits这样的模型,我测试了。对于fruits.fruitId他也是可行的。 如上面的表结构,我想统计所有的喜欢的水果。 - db.person.distinct("fruits.fruitId") // 查找对象里引入对象的值,直接加.
复制代码 * }+ r1 K. |7 ^6 K) o
0 U( K# v) d& R- ~: p 他成功执行了。输出如: - [ "aaa", "bbb", "ccc", "www", "xxx", "yyy", "zzz", "rrr" ]
复制代码 9 g& h# ^/ J5 J- s, S
6 f+ i4 k+ N" c, ` 我想统计集合中共有多少个人[按名字吧] - db.person.distinct("manName")
复制代码
. m k4 p2 i* N" Z7 z3 a6 Z" C" `7 D6 J( d$ W' ?- W
我想统计指定个数的人的共同关注的朋友。 - db.person.distinct("myFriends", {"manName" : {"$in" : ["ZhenQin", "YangYan"]}})
复制代码 1 o* E% _3 b3 J& R5 c# h \
/ Y5 c7 c, G2 h8 Q* @
输出如: - 0 G$ R$ }! K/ Y* p& w3 Z7 |
- [ "234567", "345678", "456789", "987654", "ni", "wo" ]
复制代码 8 x/ ^! ]& y9 g1 {' s
* C0 j! T3 x7 r+ v4 Z- a6 F9 `& `" g: b
那么我使用Java呢? 我只是在演示Mongo的命令,用Spring Data Mongo是怎么操作的? Spring Schema: - <beans xmlns="http://www.springframework.org/schema/beans"
+ W3 l+ Y. g; z( p0 k$ w# J* Q/ O' r; D - xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
6 b4 x$ e: m& _& ]2 X - xmlns:context="http://www.springframework.org/schema/context"
- b" j% D8 D( g7 j8 L5 R0 y - xmlns:mongo="http://www.springframework.org/schema/data/mongo"' o" n4 @3 [. d" r( q
- xsi:schemaLocation="http://www.springframework.org/schema/beans+ W% F( S$ E" p9 W! F3 n
- http://www.springframework.org/schema/beans/spring-beans-3.0.xsd# ?. Q* x# U* {$ c0 ?
- http://www.springframework.org/schema/context4 C5 t% S" V0 E h5 i, |+ E! @
- http://www.springframework.org/schema/context/spring-context-3.1.xsd7 {. c8 F6 Y: B
- http://www.springframework.org/schema/data/mongo7 Q$ L3 |; B4 Y: c2 z
- http://www.springframework.org/schema/data/mongo/spring-mongo-1.0.xsd">
; |+ U- S1 b1 y8 @$ G9 v -
# e& ?8 Y* G0 k - <context:property-placeholder location="classpath:mongo.properties" />+ z' J. `3 g9 @8 I5 W" ]' |1 `3 S; [
- ( g2 H! z. e: J" G; J, U
- <!-- Default bean name is 'mongo' -->
$ p4 p% d7 P/ x8 t - <mongo:mongo id="mongo" host="${mongo.host}" port="${mongo.port}" />. F0 O- ^3 e4 ? g
- 5 A! C) `: a) {' `, f1 u
- <mongo:db-factory id="mongoDbFactory"* p$ O# F% m5 K! C
- mongo-ref="mongo"3 {: W6 ?* L5 ]6 c, f- v, E
- dbname="mongotest" />
4 i& O3 m: e: n1 ]# ?& _ -
# P. \! L- v$ U# S. H - <bean id="mongoTemplate" class="org.springframework.data.mongodb.core.MongoTemplate">
" g1 D( A0 F, A( _! j; H5 ~- v& f - <constructor-arg name="mongoDbFactory" ref="mongoDbFactory"/>9 O- W$ X2 k. M- ^* h' Z
- </bean>+ E* T6 Z( @8 b& O: ]
- </beans>
复制代码
& d/ G4 \0 M4 S2 n4 i
- l+ B8 W3 _, F$ ?8 Z ~6 m3 R5 w max和min的测试: - @Test$ g8 J# l* H1 \5 f: w
- public void testMaxAndMinAge() throws Exception {1 H+ S$ W% `* @' _, h5 C$ P ~
- Query q = new BasicQuery("{}").with(new Sort(new Sort.Order(Sort.Direction.ASC, "age"))).limit(1);6 E% F1 C+ o9 O, {
- Person result = mongoTemplate.findOne(q, Person.class);
! V, g5 X; G7 O3 X( L l: U - log.info(result);
, b! c" P" j4 H2 S; w2 e -
8 U! Y/ x. g- g7 A5 r - q = new BasicQuery("{}").with(new Sort(new Sort.Order(Sort.Direction.DESC, "age"))).limit(1);
- ^7 l0 f9 _! R, [6 }. j8 W } - result = mongoTemplate.findOne(q, Person.class);
) x: h" g# N, k2 K6 K5 N4 w1 \ - log.info(result);
+ C& P, g4 ^, Z2 Z+ ] - }
复制代码 1 v& U! Q9 X5 I' k. B; B M
4 l* m: Z6 p4 S6 I) d# O distinct的测试: - @Test0 i( x. T; j0 w2 W7 q0 m: m0 ~
- public void testDistinct() throws Exception {
& R+ v. s9 U$ _; W4 ` - List result = mongoTemplate.getCollection("person").distinct("myFriends");
( M- ]' c0 H6 f$ z) J# n0 n - for (Object o : result) {; `2 s- g( D" a3 M/ |; Q
- log.info(o);) H. \7 @2 G# R( d% n( H
- }9 W+ k' [) O6 L3 r1 L
- : b- r! N g5 r; I4 M
- log.info("==================================================================");
& ?: ]% _+ N: `1 i. Q3 Z- w - Query query = Query.query(Criteria.where("manId").is("123456"));8 c0 q, s+ d3 }0 _. y
- result = mongoTemplate.getCollection("person").distinct("myFriends", query.getQueryObject());
: M0 j' j3 J1 y1 h# n - for (Object o : result) {- q6 v1 H& ]! X4 h/ Y. D/ c5 u
- log.info(o);
5 n! ?7 @7 @9 w, | W - }
' _7 E5 u0 j1 B5 T( P" b* o - " ^' b$ B: a6 R; j( W: O# ?
- log.info("==================================================================");
# x' S+ _( i/ C3 I3 e - result = mongoTemplate.getCollection("person").distinct("fruits.fruitId");- t5 ?; \' V5 d/ G
- for (Object o : result) {
( [+ p" K" U9 i) l - log.info(o);
6 `' E" _; g" ^9 D% Y - }& S6 n2 x* o* t) F+ ?5 T" D* M
- }
复制代码
, G4 W/ A4 C9 Y$ Z1 V' K% i
+ x- E6 \3 X9 u 输出的结果为: - 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(72)] 2345673 P, N+ s) { K( n2 M( a
- 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(72)] 345678# y, A0 M2 {7 `8 t2 ]
- 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(72)] 456789
6 t2 z+ i! q& U4 c1 @/ O - 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(72)] 987654
2 t5 c- l4 V1 F% @7 s' U; K - 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(72)] ni
# a$ \0 K# ~: c' J/ |7 M - 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(72)] wo. ?9 o$ U, Y$ o' q/ l0 n
- 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(72)] 123456
5 l( @. |; g! `6 j' E - 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(75)] ==================================================================' d5 Y' L. L# ~- N& E! @
- 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(79)] 234567/ {2 V$ @( D( ~1 d7 ?. |3 n
- 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(79)] 345678* ^; a% G, X: a
- 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(79)] 456789, Y. r& ?7 r" {& _; G
- 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(79)] 987654
* }8 Q" U, P4 [. {: E' M - 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(82)] ==================================================================
$ }# R; u' L/ S* D) h2 q! P2 g - 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(85)] aaa3 y# a" ?4 W7 o8 ] e+ N
- 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(85)] bbb
1 M( U5 }# C2 i+ E6 k! i - 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(85)] ccc
9 N: {6 S( M' i' z1 ^- s1 v4 s - 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(85)] www
( x! l7 d/ {! R) E* |8 G - 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(85)] xxx
) s2 e5 d5 X2 g/ s0 |: X - 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(85)] yyy
" E% f5 X8 ^; c F7 P, ~# L - 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(85)] zzz) {+ }) @9 l7 r; A; q
- 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(85)] rrr
$ F J |& Y; U$ l4 l# M9 i; J. n - 12-22 14:13:45 [INFO] [support.GenericApplicationContext(1020)] Closing org.springframework.context.support.GenericApplicationContext@1e0a91ff: startup date [Sat Dec 22 14:13:44 CST 2012]; root of context hierarchy
复制代码 ) D# i/ e/ A, n+ q7 p
# H: y, e* e$ \0 h
这里我要特别说明一下, 当使用了Spring Data Mongo,如上面的findOne(query, Person.class)它就会把查询的结果集转换成Person类的对象。Spring Data Mongo的很多API中都这样,让传入了一个Bean的class对象。因为distinct的测试是输出list<String>的,我 使用的mongo-java-driver的api。他们都很简单,唯一的是Query这个Spring提供的对象,希望读者注意,他几乎封装了所有条件 查询,sort,limit等信息。
; Y7 J9 A6 k9 e5 M# c1 q4 W6 j: V2 P8 y* x$ t0 D
4 K: z/ J: O% }( b |