版本一:
1 m; {- K$ W+ W6 ~8 ~( h/ p$ W- {* D2 ]3 |4 y+ r
1 ) . 大于,小于,大于或等于,小于或等于
0 ` W- h0 \3 c- F# o1 o2 `
: d. j) L# {5 y3 r$gt:大于
) b0 b, a2 U$ ?5 j+ c$lt:小于
3 v$ i: v. Q6 e2 t$gte:大于或等于6 X. K& v& ?# j3 u& B) P
$lte:小于或等于
2 ?, n% G8 o: I0 G6 _: U. o! K! L2 H! T, k6 G9 {
例子: - db.collection.find({ "field" : { $gt: value } } ); // greater than : field > value
2 x+ t) p; w7 i0 v: r - db.collection.find({ "field" : { $lt: value } } ); // less than : field < value
, n7 I( v% |. \4 j: G2 c - db.collection.find({ "field" : { $gte: value } } ); // greater than or equal to : field >= value
0 A) M# P: U9 b, w* z0 C - db.collection.find({ "field" : { $lte: value } } ); // less than or equal to : field <= value
复制代码 ( l" S) h) f- q9 h
如查询j大于3,小于4: - db.things.find({j : {$lt: 3}});
- i: a3 N9 \7 H; \' @' @1 z - db.things.find({j : {$gte: 4}});
复制代码 ! Y: t! s/ u( `5 K! X3 p+ u
也可以合并在一条语句内: - db.collection.find({ "field" : { $gt: value1, $lt: value2 } } ); // value1 < field < value
复制代码
/ T5 X6 J$ G6 H2 C! j/ x9 m
) J/ K) @' k9 h7 d. K7 {- z; Y: D) q
2) 不等于 $ne 例子: - db.things.find( { x : { $ne : 3 } } );
复制代码
# u# k# L0 q% c d3) in 和 not in ($in $nin)8 I5 p9 D) w1 D9 z/ `- j6 _
2 z8 K, p; W, ?. `* f' N
语法: - db.collection.find( { "field" : { $in : array } } );
复制代码 ; m3 E9 E( u6 r( w' l
例子: - db.things.find({j:{$in: [2,4,6]}});
2 q2 @/ k) W2 G0 j - db.things.find({j:{$nin: [2,4,6]}});
复制代码 6 c% M; D4 T) }% M1 q7 T" @
( U" }7 ?4 G5 W6 c4) 取模运算$mod0 ?+ C' y9 M+ ~5 c% y; `
- l5 K3 |0 |/ t* o1 r1 x
如下面的运算:
- db.things.find( "this.a % 10 == 1")
复制代码 - O7 _5 y, \, b7 |6 x# C
可用$mod代替: - db.things.find( { a : { $mod : [ 10 , 1 ] } } )
复制代码
% U9 ?2 I8 L1 n' U6 t, Y$ I; x; p. \# P9 Y, e7 d/ s
5) $all' |$ ^% Z4 H2 i( o$ u: W& k
7 s$ C' [) ~0 u, ]* I+ s
$all和$in类似,但是他需要匹配条件内所有的值:
g( D% @7 Y0 E, M! ?- C2 W" ~, @ s0 E: O$ H0 \2 g
如有一个对象:3 b K9 d4 E: i3 c3 C o8 O* a
6 m1 n0 q5 c+ x5 Q; U% k下面这个条件是可以匹配的: - db.things.find( { a: { $all: [ 2, 3 ] } } );
复制代码
: o5 \/ b0 N% x5 i5 h但是下面这个条件就不行了: - db.things.find( { a: { $all: [ 2, 3, 4 ] } } );
复制代码 4 _9 F4 [: m7 U, s$ h
q9 S% M7 P% V8 n9 c
6) $size, m7 V( m: P2 B5 O9 O' h% q ]
1 G/ I; d, S6 x3 s! z
$size是匹配数组内的元素数量的,如有一个对象:{a:["foo"]},他只有一个元素:0 B* {# n' |$ Y/ z! d% @! W
4 N6 Z' M# H C6 ]下面的语句就可以匹配: - db.things.find( { a : { $size: 1 } } );
复制代码 / v: ?8 w$ O* ?- M: h* b! N1 U
官网上说不能用来匹配一个范围内的元素,如果想找$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.
9 i; V1 v( S+ ^! y/ w( D- e# f7)$exists $exists用来判断一个元素是否存在: 如: - db.things.find( { a : { $exists : true } } ); // 如果存在元素a,就返回
/ m6 I) H; ~+ _ - db.things.find( { a : { $exists : false } } ); // 如果不存在元素a,就返回
复制代码 % C* H# \' Y: `
8) $type $type 基于 bson type来匹配一个元素的类型,像是按照类型ID来匹配,不过我没找到bson类型和id对照表。 - db.things.find( { a : { $type : 2 } } ); // matches if a is a string+ Z$ ?! _0 c5 z( {2 x$ c
- db.things.find( { a : { $type : 16 } } ); // matches if a is an int
复制代码
8 ~! T; Z& ~; P6 {: D. Q; l9)正则表达式
6 a) u9 c, L; Z
. w$ }% Q s4 R! J1 vmongo支持正则表达式,如: - db.customers.find( { name : /acme.*corp/i } ); // 后面的i的意思是区分大小写
复制代码
( H" L5 C8 L1 w2 l: b6 c10) 查询数据内的值, q0 U3 K: S z$ S$ X3 f- [" S
4 u, y8 t/ F& J8 O! C+ R$ h- J
下面的查询是查询colors内red的记录,如果colors元素是一个数据,数据库将遍历这个数组的元素来查询。 - db.things.find( { colors : "red" } );
复制代码 $ Q+ o5 L7 j: ^1 U; T! {+ K
11) $elemMatch
; E% z" x5 P& z A: @; Z
7 K t: b& g4 J: f) Y如果对象有一个元素是数组,那么$elemMatch可以匹配内数组内的元素: - > t.find( { x : { $elemMatch : { a : 1, b : { $gt : 1 } } } } )
2 i3 k2 l5 b3 R0 R$ F, B - { "_id" : ObjectId("4b5783300334000000000aa9"),
9 r- \2 e+ y9 t& V - "x" : [ { "a" : 1, "b" : 3 }, 7, { "b" : 99 }, { "a" : 11 } ]
# \3 `& \, G$ U - }
复制代码 + x8 q" r8 `' ?1 x
$elemMatch : { a : 1, b : { $gt : 1 } } 所有的条件都要匹配上才行。注意,上面的语句和下面是不一样的。 > t.find( { "x.a" : 1, "x.b" : { $gt : 1 } } )
2 E0 @& _* ~+ Q' R1 Q$elemMatch是匹配{ "a" : 1, "b" : 3 },而后面一句是匹配{ "b" : 99 }, { "a" : 11 }
% G3 R/ b/ \% [/ [& ^9 o& I/ x6 G& A7 X8 G
12) 查询嵌入对象的值 - db.postings.find( { "author.name" : "joe" } );
复制代码 6 ~8 s; L+ t4 L5 U1 I: O/ b
举个例子: - > db.blog.save({ title : "My First Post", author: {name : "Jane", id : 1}})
复制代码
" c+ u1 {- P% K' K. P: }如果我们要查询 authors name 是Jane的, 我们可以这样: - > db.blog.findOne({"author.name" : "Jane"})
复制代码 7 ?4 F5 P3 I3 K1 C
如果不用点,那就需要用下面这句才能匹配: - db.blog.findOne({"author" : {"name" : "Jane", "id" : 1}})
复制代码
* ~9 d1 I2 V r下面这句: - db.blog.findOne({"author" : {"name" : "Jane"}})
复制代码 ' t, ?) ?* R$ ]# e! q
是不能匹配的,因为mongodb对于子对象,他是精确匹配。
2 y1 A. e/ M& Y/ U/ V& H13) 元操作符 $not 取反 如: - db.customers.find( { name : { $not : /acme.*corp/i } } );
. |) j) q7 \2 E: x( ^ K - db.things.find( { a : { $not : { $mod : [ 10 , 1 ] } } } );
复制代码 % B% L" E: o. l
shell 环境下的操作: 1. 超级用户相关: 1. #进入数据库admin
1 H1 [. \9 h2 K$ x8 @
. v8 m. f% G. ]6 j* G$ b1 d* w' Z 2. #增加或修改用户密码 3 I' W3 ]9 T2 e7 U& V6 L5 E
3. #查看用户列表
+ |/ I; q- G$ @+ G9 k! m2 [9 `* Q 4. #用户认证 5. #删除用户 6. #查看所有用户 / Q$ W9 Y$ F, K5 J' c' i; z1 b- Y
7. #查看所有数据库 8. #查看所有的collection
+ Q x. D5 Z: Q2 [# b9 q8 I 9. #查看各collection的状态 - db.printCollectionStats()
复制代码 5 F& r5 D% {( P/ [3 V2 }
10. #查看主从复制状态 - db.printReplicationInfo()
复制代码
# x% s! {2 j( |" O" s' a 11. #修复数据库 12. #设置记录profiling,0=off 1=slow 2=all 13. #查看profiling
. C" G$ b. G( k) C& r, [ w 14. #拷贝数据库 - db.copyDatabase('mail_addr','mail_addr_tmp')
复制代码 8 r O( m3 i" r0 i% A- @
15. #删除collection 16. #删除当前的数据库 2. 增删改 1. #存储嵌套的对象 - db.foo.save({'name':'ysz','address':{'city':'beijing','post':100096},'phone':[138,139]})
复制代码
4 N5 o0 p# \1 v+ ^- M, O8 i 2. #存储数组对象 - db.user_addr.save({'Uid':'yushunzhi@sohu.com','Al':['test-1@sohu.com','test-2@sohu.com']})
复制代码 8 l4 f2 E- ~7 J k- r
3. #根据query条件修改,如果不存在则插入,允许修改多条记录 - db.foo.update({'yy':5},{'$set':{'xx':2}},upsert=true,multi=true)
复制代码 : _2 n, ]& G j9 G- w6 ?/ ?
4. #删除yy=5的记录 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()
3 M3 B- T% o; }8 ]6. 高级查询 条件操作符 ( b3 i, x; C, B( i v- p1 V- n
- $gt : >
2 m& D, E1 \( q. ?$ B: T - $lt : <
* Y3 K) x- M9 [ - $gte: >=
1 B3 K& H: [2 F% O3 y: S: ~ - $lte: <=
, w4 \+ y1 K* M2 } - $ne : !=、<>
" M$ p9 M4 w9 B/ Z& r) A - $in : in , ?- i. i; q5 C3 Q: {: w9 F
- $nin: not in
3 R0 K+ A5 Q3 @! ~; w& \* U- z - $all: all ; J& \5 T; ]. y" u% N. P
- $not: 反匹配(1.3.3及以上版本)
复制代码 - B7 W% E R; _
, V9 {0 ] q6 u$ A! K, Y6 S1 D
查询 name <> "bruce" and age >= 18 的数据
" j% f+ _, r. @! b7 ^* k" D3 X- db.users.find({name: {$ne: "bruce"}, age: {$gte: 18}});
复制代码
; ~) b2 {5 T3 D
; x; t6 r6 I: g; m( p6 j1 m查询 creation_date > '2010-01-01' and creation_date <= '2010-12-31' 的数据
2 s9 ~ R0 b5 P- db.users.find({creation_date:{$gt:new Date(2010,0,1), $lte:new Date(2010,11,31)});
复制代码
D a9 k* Z( ~1 h% r
1 L, g8 J6 d7 A2 D4 }' S! @6 U/ Y查询 age in (20,22,24,26) 的数据
! C6 e$ p# F" L3 P- db.users.find({age: {$in: [20,22,24,26]}});
复制代码
" {; l/ p$ D% _3 X5 {4 Q5 j3 I; {$ h! y# R8 x; O* O' [$ z$ a
查询 age取模10等于0 的数据 7 ?: c) \3 y7 |, b& f
- db.users.find('this.age % 10 == 0');
复制代码 ' L; w7 E. D/ D7 I2 M* R
或者
) x1 t. r/ a" K/ }# r8 \- db.users.find({age : {$mod : [10, 0]}});
复制代码
- K+ h# P7 ]/ \3 D2 T7 z# D: s2 K5 v4 B
匹配所有 9 Z/ t. R7 Q1 h% S% E! @& M
- db.users.find({favorite_number : {$all : [6, 8]}});
复制代码 2 N% h& u# F4 s) b
可以查询出{name: 'David', age: 26, favorite_number: [ 6, 8, 9 ] } / j& G4 t6 |! c7 f
可以不查询出{name: 'David', age: 26, favorite_number: [ 6, 7, 9 ] }
7 S2 x/ }- l7 A! \" a7 U7 y8 ]) U
5 A, Z4 _( U! a l, k, h, \查询不匹配name=B*带头的记录
' G! {3 z% j8 @" S( l. ]: s- db.users.find({name: {$not: /^B.*/}});
复制代码 4 t' L# _1 F& @* [8 G
查询 age取模10不等于0 的数据 4 ]# z7 q" A0 g2 Z0 D4 _8 R8 G
- db.users.find({age : {$not: {$mod : [10, 0]}}});
复制代码 6 i m5 a8 c8 g4 r. v9 r
' j+ R, m% r F: H
#返回部分字段
p7 C, x. g7 q6 x1 q: r. G选择返回age和_id字段(_id字段总是会被返回)
( g4 \* ^9 a- K/ s. o" K" c- db.users.find({}, {age:1}); 6 m2 h4 ^4 A" d0 `. T- q
- db.users.find({}, {age:3});
& o4 ?; E6 T" k- |# I" u# T" Z1 m; N9 k - db.users.find({}, {age:true});
( c" `0 q* X$ n" t7 o - db.users.find({ name : "bruce" }, {age:1});
复制代码 8 s; V. d1 P9 P7 \* G0 E3 h
0为false, 非0为true : j, I' z( f2 A
U" J8 B' F& n! E+ q
选择返回age、address和_id字段
* @+ m/ j9 B, q- r; u$ |- db.users.find({ name : "bruce" }, {age:1, address:1});
复制代码 ' Q) K/ e7 l- ?2 o/ N& N! q0 m
! m3 F. s& a" c: v: J% i
排除返回age、address和_id字段
6 K7 C$ a3 b3 H. P- db.users.find({}, {age:0, address:false}); % _; i: T! `. {4 o Z- |( p! S
- db.users.find({ name : "bruce" }, {age:0, address:false});
复制代码 : H4 X4 r4 K% x K
. O/ W2 h* G6 G" u" ^& s
数组元素个数判断 * r) h! ^9 K6 e- R0 K! O
对于{name: 'David', age: 26, favorite_number: [ 6, 7, 9 ] }记录
- ^' @- F! E8 ~9 `匹配db.users.find({favorite_number: {$size: 3}}); 1 Q ]1 F* N4 b
不匹配db.users.find({favorite_number: {$size: 2}});
/ \9 i0 }( Q b8 O1 T7 X% A4 K
3 \0 p7 q4 f' d) j7 w8 I$exists判断字段是否存在
( ]7 T1 b, o3 Z* N/ M查询所有存在name字段的记录
/ ~( W! F0 f0 h4 d+ X$ @+ p- db.users.find({name: {$exists: true}});
复制代码 , c7 w/ U( K0 V; f
查询所有不存在phone字段的记录 - S" Q. r% I, Y/ W# M7 W* v8 z F1 r
- db.users.find({phone: {$exists: false}});
复制代码
, F7 K, q0 F' z$ A# ~, t) E( H" O8 U! F7 a
$type判断字段类型 ! L, U- X4 n' `; u
查询所有name字段是字符类型的
" \$ {. T9 F% P8 b- db.users.find({name: {$type: 2}});
# J) O4 m* _" R
复制代码
' k( r9 b$ F# o% S查询所有age字段是整型的 % R" p8 c( D: S! m& A3 h/ s
- db.users.find({age: {$type: 16}});
% t/ G5 [% u/ R6 M
复制代码 $ x U% c) T' F$ \: L
对于字符字段,可以使用正则表达式 , X h- k# Z* U6 ?
查询以字母b或者B带头的所有记录 / G8 c% P( @, a5 |/ {3 W
- db.users.find({name: /^b.*/i}); " A7 t; R+ g8 E0 [/ c% X& [1 r
复制代码
# Y! x. }, [9 c2 Z2 s; g+ `: R& p7 |+ P$elemMatch(1.3.1及以上版本)
% H1 C5 T: C! r$ h) d为数组的字段中匹配其中某个元素 ( _7 B/ c7 M! L8 s
) q6 N9 E$ H1 Z
Javascript查询和$where查询
! ?/ B) h8 W2 F& v5 N, _查询 age > 18 的记录,以下查询都一样
+ q: I& h Q; n9 e- db.users.find({age: {$gt: 18}}); ( v( d7 {6 v, \+ E
- db.users.find({$where: "this.age > 18"}); 6 J' J0 N O1 I8 G9 Y- |
- db.users.find("this.age > 18"); ) t6 K# C! K( U4 v5 }; L0 o' c" n8 C
- f = function() {return this.age > 18} db.users.find(f);
复制代码 : {! D3 T* M* F$ N% W* y
4 W8 U6 l2 y4 h* O8 v0 Y
排序sort() x: m2 O4 `0 `5 N1 \+ j; x/ s
以年龄升序asc
5 [: k" G; G8 r- c2 B' l- db.users.find().sort({age: 1}); : F8 h/ |) H4 W. z" F
复制代码
. ?2 _- {$ }- T以年龄降序desc / }9 Z- P; ^, B3 v0 y6 V6 b
- db.users.find().sort({age: -1}); ; f" e% J+ K" `& l ?3 m
复制代码 : m* C9 W8 f/ f( T, e$ x
限制返回记录数量limit()
6 M, v% W% E9 ~- |9 m* q+ Z) p返回5条记录
! C9 i. D/ k v- Y; l7 S. K- db.users.find().limit(5); " G' Y! G! Q9 E$ c# V* e9 C( ?
复制代码
. j( B/ I1 L5 T( r1 B返回3条记录并打印信息
+ V9 d0 { ^4 X9 n y7 M; _" B- db.users.find().limit(3).forEach(function(user) {print('my age is ' + user.age)});
* p% X7 q7 c2 }0 D0 d3 `3 f
复制代码 ! c4 S- I5 b! \8 a6 m' A% I) N1 l
结果 : U3 F" M' [/ E& ]# n
- my age is 18 8 U6 P- j) j) D' ?5 o- N6 z, \( X
- my age is 19
, f( Y; d; R0 \6 Z0 @ - my age is 20
复制代码
. I' n0 R2 @ F6 a* l- I8 z6 p9 p' L% ] K3 g! K4 l" n% K
限制返回记录的开始点skip()
6 ]" R" Z" ]% l5 I A从第3条记录开始,返回5条记录(limit 3, 5) 4 e: p |% M% k1 r3 b6 e
- db.users.find().skip(3).limit(5); & i( x) r3 a5 R4 K9 L6 X* p; T* N# |
复制代码
/ S0 M* p2 ]# V/ ^# A! o* \查询记录条数count() d: | B2 K# Q8 H
db.users.find().count();
+ W( P/ |* l2 w( c! ?. c- u9 @db.users.find({age:18}).count(); ) _) j& U8 w% i( Q3 I5 Z7 t4 H
以下返回的不是5,而是user表中所有的记录数量 # v2 }8 G- s2 ]9 f
db.users.find().skip(10).limit(5).count(); 5 K% u x2 b7 g7 j
如果要返回限制之后的记录数量,要使用count(true)或者count(非0)
& b2 D9 E0 X9 E+ L- db.users.find().skip(10).limit(5).count(true);
复制代码 / v4 r/ M$ X4 E; _/ x
0 p; p" ]: h y2 ^
分组group() . B$ I9 h5 G6 w4 u
假设test表只有以下一条数据
* c: |9 a/ _3 E, m% E0 q, B& w- L3 W- { domain: "www.mongodb.org"
6 k; y$ X$ Q1 P4 g, a - , invoked_at: {d:"2009-11-03", t:"17:14:05"}
2 c" F! _! z3 j) c9 d - , response_time: 0.05 % l( P/ Y3 @& q' P5 \
- , http_action: "GET /display/DOCS/Aggregation" ( K% e7 H! Q) R% D8 P
- }
复制代码 + U* \% k+ x2 `1 c( @9 R( t4 }3 ^
使用group统计test表11月份的数据count:count(*)、total_time:sum(response_time)、avg_time:total_time/count;
8 [: t( R" S' z! M, I I- db.test.group(
4 _! Y* L5 B4 N) g8 M' s+ | q - { cond: {"invoked_at.d": {$gt: "2009-11", $lt: "2009-12"}} 3 F P9 F/ B% p7 z" \
- , key: {http_action: true}
' j5 T* T' R- y/ O a. d* S$ n - , initial: {count: 0, total_time:0} . H: M: d( o0 W% U
- , reduce: function(doc, out){ out.count++; out.total_time+=doc.response_time } 0 ^! z5 \& L$ b
- , finalize: function(out){ out.avg_time = out.total_time / out.count }
' h( T, K: a6 A( x9 y Y! p: Y - } ); ' u+ C# R2 q7 G& B
- 0 r5 }) I3 _9 P; H" s/ b
- [
( G+ A, @. H7 O& b. m; X, n5 p - {
( W6 c* w! r' q1 u; i - "http_action" : "GET /display/DOCS/Aggregation", + L9 @2 v' C9 \( s( g
- "count" : 1,
5 n( L3 o6 u! r2 s) h - "total_time" : 0.05,
8 r8 U5 r/ {/ Y2 G, { - "avg_time" : 0.05 % a# I7 I$ v; l& j ?+ l
- } 0 z9 u/ [: Q8 L
- ]
复制代码
! o* Z- ]5 e d* I
& X' V, ~9 M+ u; t. G& R! `' ?7 I) l0 S+ y* b7 k: m3 x! ^0 v
MongoDB 高级聚合查询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 和Min1 M% N" r& y9 W" U+ v% E" H
我和同事在测试Mongo时,索引还写了不到一半,他想查询某个字段的最大值,结果找了半天文档也没找到关于max的函数。我也很纳闷这是常规函数啊怎么不提供? 后来经过翻阅资料确定Mongo确实不提供直接的max和min函数。但是可以通过间接的方式[sort 和 limit]实现这个。 要查询最大值我们只需要把结果集按照降序排列,取第一个值就是了。 如我的例子,我想取得集合中年龄最大的人。 - db.person.find({}).sort({"age" : -1}).limit(1)
复制代码
" y p0 F% B3 {+ E; n0 R; d) r
- h- p% b0 ?6 r( B8 e
相反如果想要年龄最小的人,只需要把sort中改为{“age”:1}就可以了。 当然我们使用了sort,对于小数量的文档是没问题的。当对于大量数据需要给age建立索引,否则这个操作很耗时。 - distinct
9 p5 }$ r. z7 v2 a: ?$ [& e
MongoDB的destinct命令是获取特定字段中不同值列表的最简单工具。该命令适用于普通字段,数组字段[myFriends]和数组内嵌文档[fruits]. 如上面的图片,我认为fruits和myFriends字段是不同的。网上很多资料和例子都没说到这个情景,因为我们也业务是fruits这样的模型,我测试了。对于fruits.fruitId他也是可行的。 如上面的表结构,我想统计所有的喜欢的水果。 - db.person.distinct("fruits.fruitId") // 查找对象里引入对象的值,直接加.
复制代码
; K* ^* N9 Y c o' ?) }& W- O$ R! t2 y: ~
他成功执行了。输出如: - [ "aaa", "bbb", "ccc", "www", "xxx", "yyy", "zzz", "rrr" ]
复制代码 7 D7 W1 \ }1 ~2 f
4 U9 z2 g1 N( l
我想统计集合中共有多少个人[按名字吧] - db.person.distinct("manName")
复制代码
5 g# W! L; f" r+ M. j, R& [8 m0 K9 S+ W) u+ F& x
我想统计指定个数的人的共同关注的朋友。 - db.person.distinct("myFriends", {"manName" : {"$in" : ["ZhenQin", "YangYan"]}})
复制代码 w9 ]. a! r. d8 Z# _3 {9 q
1 `! e! W, r) N- M. q! y 输出如: - 8 k' d) E U' x+ Y, F$ ?0 }6 g+ Y9 G
- [ "234567", "345678", "456789", "987654", "ni", "wo" ]
复制代码 . ^3 l" K; o. i2 l$ C1 g# W) ?" h
. {& G, ]( x+ ~& Z) K3 s) j
/ K6 S* A: W8 F! `$ N0 J$ f6 J1 D那么我使用Java呢? 我只是在演示Mongo的命令,用Spring Data Mongo是怎么操作的? Spring Schema: - <beans xmlns="http://www.springframework.org/schema/beans" E- p/ J1 S2 y0 T$ z! R
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"2 A4 j2 U1 |* w5 a9 @" i
- xmlns:context="http://www.springframework.org/schema/context"( h# n m/ M& ?7 C* o4 [3 S- z+ l8 e
- xmlns:mongo="http://www.springframework.org/schema/data/mongo"
3 O: c( L9 Y& \. F+ S. `1 H8 H. \4 m - xsi:schemaLocation="http://www.springframework.org/schema/beans1 _7 f& m0 p& _0 s. O
- http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
+ \6 s- S% W3 } - http://www.springframework.org/schema/context1 K; }) }; d2 _' h8 y
- http://www.springframework.org/schema/context/spring-context-3.1.xsd' X$ V/ ?# i" ? @* O% [/ d% X
- http://www.springframework.org/schema/data/mongo8 f" a* }# C5 K& s: E& W3 W
- http://www.springframework.org/schema/data/mongo/spring-mongo-1.0.xsd">
4 X* @! C1 C8 O6 M) ]9 J6 U -
* S- U9 h9 Q" Z, B - <context:property-placeholder location="classpath:mongo.properties" />
9 N* d/ ^ C( b* ] V5 j - ( T( F8 v8 H b, \0 ?
- <!-- Default bean name is 'mongo' -->
/ m7 O" t Q' x/ h3 @* |* B - <mongo:mongo id="mongo" host="${mongo.host}" port="${mongo.port}" />0 b8 O8 u# U7 G- t7 w
-
" z K" i+ [! y. z: k. P9 N# B' L - <mongo:db-factory id="mongoDbFactory"2 W: a% b5 B* e3 b
- mongo-ref="mongo"
- [, m4 I) n6 V8 h$ ?5 @ - dbname="mongotest" />
. i7 `+ \: ?0 a( O$ _ -
+ h/ S% H0 }) _' V: B - <bean id="mongoTemplate" class="org.springframework.data.mongodb.core.MongoTemplate">
' Y4 s9 T! r' A$ D$ _ - <constructor-arg name="mongoDbFactory" ref="mongoDbFactory"/>
' P4 b$ H' B/ ~! X/ z# I# y6 X - </bean>5 L9 D" l! v$ k! J' V) }
- </beans>
复制代码
6 P4 ~2 i! C0 B' F/ v* L
1 c* F, A% K1 z9 ?4 ?/ g max和min的测试: - @Test! }, \3 I4 b% Y+ X) W* _
- public void testMaxAndMinAge() throws Exception {
2 m$ q u; j1 Z7 [ - Query q = new BasicQuery("{}").with(new Sort(new Sort.Order(Sort.Direction.ASC, "age"))).limit(1);
8 K$ \( z9 L! S: R - Person result = mongoTemplate.findOne(q, Person.class);
: L1 r. b7 d* M0 F0 G - log.info(result);7 H1 ]6 w1 e+ e2 {/ r
- 8 W0 A+ W1 z# J }, k8 ], p
- q = new BasicQuery("{}").with(new Sort(new Sort.Order(Sort.Direction.DESC, "age"))).limit(1);- |8 |* i8 g% ~8 d3 U1 g
- result = mongoTemplate.findOne(q, Person.class);
# p1 H7 v4 N1 r1 a6 T - log.info(result);2 H0 h) C- C/ F% J9 D
- }
复制代码 ( ?! h' G3 M! U6 M% \3 O$ A+ F, C
0 ^3 a7 N5 o2 c1 A, ^" M
distinct的测试: - @Test( ?2 V5 o7 Y- d D
- public void testDistinct() throws Exception {. o# J* w+ m8 v b. E. ^, _
- List result = mongoTemplate.getCollection("person").distinct("myFriends");
" \5 k% f. ~. u& C. | - for (Object o : result) {
. m. t% \; q* E+ v0 D2 m - log.info(o);
- Q) u# X. D0 w% \- v( w; M( `) `' ^ - }3 e7 Z0 \8 E7 n& d1 }$ G
- 1 Q$ Z F5 R) p9 v
- log.info("==================================================================");
9 s# \ l# i; l/ v - Query query = Query.query(Criteria.where("manId").is("123456"));" I6 l% J# o: y# W) h# x
- result = mongoTemplate.getCollection("person").distinct("myFriends", query.getQueryObject());: s8 M: H' Z$ `; M8 ?# x( N
- for (Object o : result) {
$ u/ ~5 h+ Z( E9 s$ T - log.info(o);
5 p; k6 N; j8 U! ^" l# u - }6 Z- r! a( H6 H, q. B7 Y+ H+ k
-
# B2 J, i- C, t- A# e - log.info("==================================================================");, c, c) ?$ A) U, ^7 J5 c
- result = mongoTemplate.getCollection("person").distinct("fruits.fruitId");
3 a$ ~+ @8 B7 k: d - for (Object o : result) {
/ i4 Y; j z( K - log.info(o);
# d* u! Q6 m! k9 v# p3 Y - }
+ T4 H' \3 q0 k1 [* l E$ ~ - }
复制代码
- H& e* J2 W4 f/ j# W$ e
0 E, F7 w7 `& t1 H( P 输出的结果为: - 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(72)] 234567
( a6 d. M$ X/ F- A0 V - 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(72)] 345678- b' X, f6 C: E- U. E
- 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(72)] 456789
5 R h K( m& o, z3 j - 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(72)] 9876542 F5 r0 M+ l) U# b7 l; V, d
- 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(72)] ni
0 I" q- y3 e5 r; W0 C; H6 r - 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(72)] wo U- l1 x1 a% b
- 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(72)] 123456
1 `' x* D# c- j - 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(75)] ==================================================================
% `% w. M* |# s! \ - 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(79)] 234567* {% [. P5 b! j' u
- 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(79)] 3456787 L, Q$ r% W* h: A: B
- 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(79)] 456789% j3 q! j. \ T- v. O6 A
- 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(79)] 987654
8 Q H6 ]3 w! I2 D. ^ - 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(82)] ==================================================================) \: ?" k# f! S, E7 P
- 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(85)] aaa) _; T+ b+ l$ P `3 q9 l. |
- 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(85)] bbb6 w6 P' K, N' `2 B/ \9 q
- 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(85)] ccc6 s6 a7 H9 V* [* w
- 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(85)] www
/ D; K1 ]1 i, L7 m - 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(85)] xxx: Y0 B1 B' \: d" _
- 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(85)] yyy
" V5 Z; ~( s0 s& @, a# u - 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(85)] zzz
8 V8 @( ^* |7 Z - 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(85)] rrr4 ~# M7 T6 N7 b& I
- 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
复制代码
% U! J2 }& V S- E
. P' u, W8 E c 这里我要特别说明一下, 当使用了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等信息。 3 D. i* ]2 \" O& y; _
5 `; U/ b3 M! @6 S
8 x! P" n* |" y4 a7 u |