版本一:! A( ?3 D# o- J) x: C
5 `- Y. B5 P* p" |1 ) . 大于,小于,大于或等于,小于或等于
* ^/ U( u. [9 m& ]
! w% P3 ]( z/ Y$gt:大于
V6 g: y s5 y/ I1 \# K: t$lt:小于, d5 B; q" m0 O$ Z3 Z! b
$gte:大于或等于: y; L% M' c: r- G' y/ y) i
$lte:小于或等于1 a4 \4 \4 V& @5 ~, u# m
7 k, {7 N& w- ~- M/ p4 ]; c例子: - db.collection.find({ "field" : { $gt: value } } ); // greater than : field > value* Y4 a' @4 o2 d+ F# |
- db.collection.find({ "field" : { $lt: value } } ); // less than : field < value: K% O% Z" j ?
- db.collection.find({ "field" : { $gte: value } } ); // greater than or equal to : field >= value) p9 l7 c: O) o" G5 }! r4 e5 M
- db.collection.find({ "field" : { $lte: value } } ); // less than or equal to : field <= value
复制代码 / q7 A2 T5 D! n: z
如查询j大于3,小于4: - db.things.find({j : {$lt: 3}});
) P$ J+ S# ~( |+ e2 y3 D - db.things.find({j : {$gte: 4}});
复制代码
# j- h. Y+ ~# A: v. H; C+ T5 x$ P也可以合并在一条语句内: - db.collection.find({ "field" : { $gt: value1, $lt: value2 } } ); // value1 < field < value
复制代码 $ g' |: B! v6 O
( M# }/ u4 Z0 J
1 j b2 Q* L, \, `9 |6 M5 Z/ r2) 不等于 $ne 例子: - db.things.find( { x : { $ne : 3 } } );
复制代码
- k+ f% y/ R6 N. k5 E! I/ e7 h3) in 和 not in ($in $nin) t9 C! X/ W3 N" i( C
5 A) Q2 G# x) G+ P: f, O) U* U, Q语法: - db.collection.find( { "field" : { $in : array } } );
复制代码
0 k# y( Z( k' h& p* b例子: - db.things.find({j:{$in: [2,4,6]}});) y( [6 l, x5 ]' I- _
- db.things.find({j:{$nin: [2,4,6]}});
复制代码 $ K+ r$ S1 ~( I z8 E* M( @& Y
/ d2 ~( ^& O/ ?" t
4) 取模运算$mod" Z$ m9 F! n8 @+ r; ?
/ a- z. C9 H6 j! W如下面的运算: - db.things.find( "this.a % 10 == 1")
复制代码
) c. V) G0 b/ D4 s9 `: V& S% Z可用$mod代替: - db.things.find( { a : { $mod : [ 10 , 1 ] } } )
复制代码 * v/ m5 q9 s6 h+ T+ K
/ I9 @& t, K8 T) J5) $all8 v% j8 i8 G8 x* J6 ?1 }+ {5 j3 f
C3 a/ K" E2 [
$all和$in类似,但是他需要匹配条件内所有的值:
4 L9 `& c s; m# |2 m" Z
& Y! y. y5 e& V" G8 w如有一个对象:/ _" |( |# K- M# G7 B4 f
V1 k3 C7 L% E8 i4 t下面这个条件是可以匹配的: - db.things.find( { a: { $all: [ 2, 3 ] } } );
复制代码
. D7 {9 A% C- M但是下面这个条件就不行了: - db.things.find( { a: { $all: [ 2, 3, 4 ] } } );
复制代码 I p. S' H2 K* K
, z' R5 o3 y# z
6) $size
% A* e; y& L+ x d: }4 B0 J" F3 e
$ U5 I# B! h) K0 ~$size是匹配数组内的元素数量的,如有一个对象:{a:["foo"]},他只有一个元素:
% U: V3 O- r1 ?; {. @& F$ @% M
下面的语句就可以匹配: - db.things.find( { a : { $size: 1 } } );
复制代码 5 Z5 P2 f9 f! E7 J& a( d
官网上说不能用来匹配一个范围内的元素,如果想找$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. ' U! B& |: Z/ ^1 R8 B
7)$exists $exists用来判断一个元素是否存在: 如: - db.things.find( { a : { $exists : true } } ); // 如果存在元素a,就返回
! E9 }! P' D8 v - db.things.find( { a : { $exists : false } } ); // 如果不存在元素a,就返回
复制代码
5 e/ d' D( N: W7 _8) $type $type 基于 bson type来匹配一个元素的类型,像是按照类型ID来匹配,不过我没找到bson类型和id对照表。 - db.things.find( { a : { $type : 2 } } ); // matches if a is a string) P8 n4 Y: h! s F4 z& i" A
- db.things.find( { a : { $type : 16 } } ); // matches if a is an int
复制代码
% ~! s+ i' f$ L; f& k3 J/ q( R9)正则表达式
5 m2 p. b' m$ N2 c! \" q% ^+ S3 a1 P2 o3 k( }- w) v
mongo支持正则表达式,如: - db.customers.find( { name : /acme.*corp/i } ); // 后面的i的意思是区分大小写
复制代码
. C/ t* _! l5 h10) 查询数据内的值" P8 [$ S3 T5 L2 Z" I# ]! t
; p6 [8 J+ s; G0 y& y# n
下面的查询是查询colors内red的记录,如果colors元素是一个数据,数据库将遍历这个数组的元素来查询。 - db.things.find( { colors : "red" } );
复制代码
. Z- W! w' w0 u9 ~8 H( H# j; }11) $elemMatch' `3 d" K2 y! g/ y
' j' ~% S5 c0 W. j0 V7 m" u7 i如果对象有一个元素是数组,那么$elemMatch可以匹配内数组内的元素: - > t.find( { x : { $elemMatch : { a : 1, b : { $gt : 1 } } } } ) h8 K3 f0 l# J
- { "_id" : ObjectId("4b5783300334000000000aa9"), 3 b) x) ~; R4 C: H! ~6 S% a& z. h
- "x" : [ { "a" : 1, "b" : 3 }, 7, { "b" : 99 }, { "a" : 11 } ]
9 V7 p8 M P. V: O2 @ h! M - }
复制代码 - f& _6 j. ] j* O- a; D2 _
$elemMatch : { a : 1, b : { $gt : 1 } } 所有的条件都要匹配上才行。注意,上面的语句和下面是不一样的。 > t.find( { "x.a" : 1, "x.b" : { $gt : 1 } } )7 u( e/ l, M! V# P8 G
$elemMatch是匹配{ "a" : 1, "b" : 3 },而后面一句是匹配{ "b" : 99 }, { "a" : 11 } 6 q3 g, @- \2 S( u( f
! X, F$ k/ h5 u5 H3 n12) 查询嵌入对象的值 - db.postings.find( { "author.name" : "joe" } );
复制代码
( j( a f8 |6 }1 O2 s5 N/ X- W举个例子: - > db.blog.save({ title : "My First Post", author: {name : "Jane", id : 1}})
复制代码
* ~1 U* z- K! _7 u5 a& B6 u如果我们要查询 authors name 是Jane的, 我们可以这样: - > db.blog.findOne({"author.name" : "Jane"})
复制代码 ( ~- j( g: j% Q2 f6 U0 _# `
如果不用点,那就需要用下面这句才能匹配: - db.blog.findOne({"author" : {"name" : "Jane", "id" : 1}})
复制代码 / g3 A/ r" Z- m( d3 L
下面这句: - db.blog.findOne({"author" : {"name" : "Jane"}})
复制代码 + r) n9 A8 h2 P: E
是不能匹配的,因为mongodb对于子对象,他是精确匹配。
6 V# l) O f0 u. Y+ u9 s0 |, L13) 元操作符 $not 取反 如: - db.customers.find( { name : { $not : /acme.*corp/i } } );7 i2 c; m/ s% X. k2 k0 p+ M
- db.things.find( { a : { $not : { $mod : [ 10 , 1 ] } } } );
复制代码
" u' @* ^! I& g5 _7 gshell 环境下的操作: 1. 超级用户相关: 1. #进入数据库admin
( d# y. j$ |$ b- h% c$ I* E3 Y$ U$ m+ b" c/ i+ b
2. #增加或修改用户密码 3. #查看用户列表
3 s9 z6 V5 A- ]# x* I/ _; I4 t 4. #用户认证 * C8 a$ i2 t8 p/ C8 A) L: z
5. #删除用户 6. #查看所有用户 7. #查看所有数据库 # v* C4 W" q1 ^, l8 P) y7 s) k7 `
8. #查看所有的collection
! L( `0 u( J! E. s4 L \& ~ J$ e( s 9. #查看各collection的状态 - db.printCollectionStats()
复制代码
" Y1 v* w1 d) ^0 P6 y 10. #查看主从复制状态 - db.printReplicationInfo()
复制代码 # p& }7 _" J0 ~& P0 S" p/ \4 l
11. #修复数据库 / a4 A. d' V# i) ^3 [7 l7 B# p7 t& }
12. #设置记录profiling,0=off 1=slow 2=all $ Y) Y! A8 `% c8 v3 z) ~* Z/ h4 w
13. #查看profiling 14. #拷贝数据库 - db.copyDatabase('mail_addr','mail_addr_tmp')
复制代码
" d/ i$ z. ^$ z 15. #删除collection ( S, n: J' y! x- ^+ b! o# w: [* |9 {$ ?
16. #删除当前的数据库
1 ]/ K2 M) N7 k- p& S* }# |' }) d9 k 2. 增删改 1. #存储嵌套的对象 - db.foo.save({'name':'ysz','address':{'city':'beijing','post':100096},'phone':[138,139]})
复制代码 & \5 q: }% a$ C) l
2. #存储数组对象 - db.user_addr.save({'Uid':'yushunzhi@sohu.com','Al':['test-1@sohu.com','test-2@sohu.com']})
复制代码
! C) Q& f% `/ R/ \7 h1 J' s 3. #根据query条件修改,如果不存在则插入,允许修改多条记录 - db.foo.update({'yy':5},{'$set':{'xx':2}},upsert=true,multi=true)
复制代码
1 \% L5 I: l. @# n! y 4. #删除yy=5的记录 - M4 Y! a3 K1 @$ a2 C, h( U
5. #删除所有的记录
* U7 r2 L k8 V% c; n- G. Z6 n 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() : q1 V; u. g/ e9 M" V: J0 d( h( J
6. 高级查询 条件操作符
) d+ {% b8 q6 N4 U* i5 ~- $gt : > : T1 V* g7 w5 ]4 r' w
- $lt : <
7 Z5 Q- q+ d' \% ]' X* J - $gte: >=
. Z) p$ W3 P- m' z - $lte: <= 7 f6 o+ N+ s* R3 Z$ Y
- $ne : !=、<> , n' P, e/ f B% M4 l
- $in : in
. q8 x i. X9 e- g - $nin: not in 3 d: ^( K0 K1 j$ h; {
- $all: all " x9 F. ~2 T) @3 ]: j, J5 d& m
- $not: 反匹配(1.3.3及以上版本)
复制代码
7 v+ u5 r g9 D2 r& X! Q3 X6 p. u0 `3 {- X( M
查询 name <> "bruce" and age >= 18 的数据 , w' k9 Q* {# P$ N5 c
- db.users.find({name: {$ne: "bruce"}, age: {$gte: 18}});
复制代码 ( M8 Z6 s) z% o" u8 V/ W
- a7 v; Q' G* L
查询 creation_date > '2010-01-01' and creation_date <= '2010-12-31' 的数据 3 t4 \$ b* e1 A6 v3 b; q
- db.users.find({creation_date:{$gt:new Date(2010,0,1), $lte:new Date(2010,11,31)});
复制代码
" Y! ^ r0 P7 X& ]! s( V! o3 t( k0 y) Z1 R0 ^/ M
查询 age in (20,22,24,26) 的数据
9 Z* @6 A) a1 F% }9 F8 k- db.users.find({age: {$in: [20,22,24,26]}});
复制代码
) j- w2 K# C5 e8 u& Y L2 Y. B
/ K/ a3 e: s/ L查询 age取模10等于0 的数据
3 Q; S& p* O' o/ e, A3 j- db.users.find('this.age % 10 == 0');
复制代码
" Y- m8 v) k3 m+ `或者 : v6 }4 k9 E1 X' `7 y
- db.users.find({age : {$mod : [10, 0]}});
复制代码 - [! p- c: t' m/ K$ V. Q! J# t
0 g# M3 H3 h) w# r2 i0 d; ~
匹配所有 ! y- D/ P/ u# T0 t' O" {
- db.users.find({favorite_number : {$all : [6, 8]}});
复制代码
- F: v$ b4 z, ^" i0 C可以查询出{name: 'David', age: 26, favorite_number: [ 6, 8, 9 ] }
4 G8 C) Y+ J e ]1 n0 Z% g可以不查询出{name: 'David', age: 26, favorite_number: [ 6, 7, 9 ] }
. P5 i& X: }! Z- B3 n7 J9 n* _: U; n4 O; I! L2 L/ H
查询不匹配name=B*带头的记录
* Q0 Q/ x- d1 O8 L0 c- db.users.find({name: {$not: /^B.*/}});
复制代码 ) }9 ^. b9 U* q: c! s1 d% [* h% u3 G
查询 age取模10不等于0 的数据 4 z! H3 S, ~% m" N" x; k. h* ~
- db.users.find({age : {$not: {$mod : [10, 0]}}});
复制代码
( p/ B& r* y2 W9 u/ K" X' j6 ?* M* v6 U
#返回部分字段
* Q& |( P: I$ m0 M选择返回age和_id字段(_id字段总是会被返回)
4 O# Y" K% [& n- p( ~$ x- db.users.find({}, {age:1});
. E4 X t; H) S" s4 j9 s - db.users.find({}, {age:3}); * O/ T/ W$ D, j8 y1 E8 D
- db.users.find({}, {age:true});
0 e6 P9 p6 G* K+ E' } - db.users.find({ name : "bruce" }, {age:1});
复制代码
& \, }" H; f, h9 M6 o" D. X9 Z0为false, 非0为true / e: B) g0 R( `1 o7 R O0 J
8 `) K! ^2 e" V选择返回age、address和_id字段
; I( Y) c; o; o; o" ?- db.users.find({ name : "bruce" }, {age:1, address:1});
复制代码
4 j8 Y8 h9 i8 r+ X& {( d! }$ K
: _/ X* X+ j7 r$ j8 O2 ^排除返回age、address和_id字段
- j ^* J H7 j6 c3 s- db.users.find({}, {age:0, address:false});
7 ?( i; t7 \3 @3 l3 Z - db.users.find({ name : "bruce" }, {age:0, address:false});
复制代码 # S3 n5 b! ~3 }. k
9 O5 a5 |& s" ^; P7 r数组元素个数判断 ! C. @5 C/ u. o) {& q
对于{name: 'David', age: 26, favorite_number: [ 6, 7, 9 ] }记录
2 |9 G) ?$ e( [匹配db.users.find({favorite_number: {$size: 3}}); / I4 [( Q; I0 ~2 j
不匹配db.users.find({favorite_number: {$size: 2}}); 2 ?" t( C8 B7 S: t
9 u! y# P; Q3 I9 U; Q9 _- s J$exists判断字段是否存在 ' t% ?- ^0 a6 ~: E- j
查询所有存在name字段的记录 K3 S. L1 C) T8 l3 e, Z
- db.users.find({name: {$exists: true}});
复制代码
( b ~! D" b2 \" u$ @查询所有不存在phone字段的记录
* |) |9 L: J( _8 p& T ~- db.users.find({phone: {$exists: false}});
复制代码
' v- X( z$ M, s4 I/ b, Z0 A* T, A& n; G' u3 e
$type判断字段类型
6 q+ b) m$ c) a5 ?' @8 Z( ]查询所有name字段是字符类型的 ( H8 q$ L/ v5 Q/ f- V
- db.users.find({name: {$type: 2}}); 6 c- [* `# M( ]( \& X
复制代码 ~3 q$ t/ K* a/ q; `" A C+ Z. z
查询所有age字段是整型的
3 g5 s9 z2 C2 ]- db.users.find({age: {$type: 16}});
( Q* l% G1 t) w
复制代码 * I7 w" i7 n) |
对于字符字段,可以使用正则表达式 ; \3 X, U* @1 c( w( c
查询以字母b或者B带头的所有记录
# T n8 }& K2 `3 P- @- db.users.find({name: /^b.*/i}); / N2 S. k+ Y; x, p$ h
复制代码 # y9 \4 E( o0 v! C/ O
$elemMatch(1.3.1及以上版本)
9 I( [1 j8 E5 V; i/ f为数组的字段中匹配其中某个元素 : M' }3 V& F$ _# P% }
7 K7 m3 @* |( P$ {: q7 y
Javascript查询和$where查询
% j- z4 c5 d" ~( [9 F9 v查询 age > 18 的记录,以下查询都一样 5 d0 L$ P: ?2 k/ |: W2 X
- db.users.find({age: {$gt: 18}});
. D6 X& b1 |- z3 w! E( [ - db.users.find({$where: "this.age > 18"});
: `/ l* ?8 ^, }0 J - db.users.find("this.age > 18");
9 S. r% w" ?% `# y# j3 a - f = function() {return this.age > 18} db.users.find(f);
复制代码 $ J: q( M$ q5 w! X4 O
# y( { B j9 _, @- h; _
排序sort() , G9 X# Y4 F3 c1 N3 Q% C1 D6 A# R* W
以年龄升序asc : A6 \0 J. L! B) }: a
- db.users.find().sort({age: 1});
; ?3 p, D+ F) i5 h$ N
复制代码 2 ~0 Z5 g+ i" W+ E$ y. e9 o- P2 C
以年龄降序desc ; v( s. s7 g- d6 q0 p5 @
- db.users.find().sort({age: -1}); ( {7 f( U+ E" h4 p
复制代码
) W! r l' @. W6 @ A/ X6 I7 w, X, s s限制返回记录数量limit() 5 v. Z- _7 G- m b
返回5条记录 # G( P% W% e3 R* i2 i9 l s
- db.users.find().limit(5);
X1 h: ~& t7 Z* E6 P/ J& k' q5 ?
复制代码
4 M/ }# |) ~0 e返回3条记录并打印信息 3 G# l) J: v. \1 a1 A
- db.users.find().limit(3).forEach(function(user) {print('my age is ' + user.age)}); ) x1 Q1 _) O' `" ` U( I7 t% {$ X
复制代码
& p# z, e8 d! H+ G- {, w结果 , l" f2 v* |/ b. D, V- q
- my age is 18
0 K4 j& b5 g# Y3 b - my age is 19
N' Q1 E2 ]4 n0 @# w8 Z Y* H - my age is 20
复制代码
/ ~/ w* Q% J: X# B0 ~/ @4 ?5 [2 C0 `
限制返回记录的开始点skip() ; o+ [6 w6 y3 I1 M* ]
从第3条记录开始,返回5条记录(limit 3, 5) " N4 P3 _6 N/ U k# \5 m
- db.users.find().skip(3).limit(5); + v6 D6 ?2 E8 P9 c
复制代码
2 Z% S0 {' D7 F3 z查询记录条数count()
; |2 U {/ _# bdb.users.find().count();
, a% h. A/ S J$ j. {5 |db.users.find({age:18}).count(); 9 f/ R d! _! m8 ?6 k
以下返回的不是5,而是user表中所有的记录数量
& u1 t! I* O9 H. J# o/ `0 F' P# gdb.users.find().skip(10).limit(5).count(); 4 f7 ]" d3 j5 k8 Y' w$ l1 W
如果要返回限制之后的记录数量,要使用count(true)或者count(非0)
$ Q$ F% @ m6 L- db.users.find().skip(10).limit(5).count(true);
复制代码
0 K1 S" k v4 M+ n3 O
! B, B3 x. ~) ^# E& k- g$ {: T分组group()
; N& n$ `3 t6 \% J* [假设test表只有以下一条数据 " d# Y5 X! n8 y; z% s
- { domain: "www.mongodb.org" 6 E7 o2 b8 a6 l+ U9 T
- , invoked_at: {d:"2009-11-03", t:"17:14:05"} * l& Z9 ^/ y3 X; f( R7 V
- , response_time: 0.05
; s) p' q+ Q' M* y0 j; z: t+ ?8 M: K - , http_action: "GET /display/DOCS/Aggregation" 1 z3 _/ M' k) Q! r1 S# [
- }
复制代码
7 l6 x' g! `/ y( r: g使用group统计test表11月份的数据count:count(*)、total_time:sum(response_time)、avg_time:total_time/count; F; Y( b+ P) t7 N! J
- db.test.group(
! I1 m( H/ K8 }+ @ - { cond: {"invoked_at.d": {$gt: "2009-11", $lt: "2009-12"}} 3 _5 X( M# D: R9 y2 P
- , key: {http_action: true}
+ W! \5 Z/ \* B - , initial: {count: 0, total_time:0} . `+ t2 ^& m8 q1 a6 c0 }
- , reduce: function(doc, out){ out.count++; out.total_time+=doc.response_time } # D2 V. f6 j9 R8 \' f* D
- , finalize: function(out){ out.avg_time = out.total_time / out.count } , s1 e) r" c- ]2 w
- } ); 7 @4 S$ H/ w: S* \
, [; | Q$ k- ^- [ V& D: S# }; G- G( \
- { & o3 V+ |$ |0 _& J
- "http_action" : "GET /display/DOCS/Aggregation",
6 |4 z% n% v. X: e0 u6 i7 t; O - "count" : 1, / m# N. K# W1 X, J8 E8 ~; }4 T
- "total_time" : 0.05, + x5 l) ]0 ]2 L8 V% t; S
- "avg_time" : 0.05 0 `4 p. b( P7 S$ A/ c, ^0 x! s: V
- } ; s; F9 p) g6 I: |( ?+ L; s
- ]
复制代码
J; L0 t& R4 D' k6 ?$ a' v ~0 b. ]: v- u' P: O0 x \, b& P3 n7 ]9 Y
; a" j5 e) L6 m1 e0 F0 lMongoDB 高级聚合查询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 和Min
$ P3 Q; |, a) D. A+ i
我和同事在测试Mongo时,索引还写了不到一半,他想查询某个字段的最大值,结果找了半天文档也没找到关于max的函数。我也很纳闷这是常规函数啊怎么不提供? 后来经过翻阅资料确定Mongo确实不提供直接的max和min函数。但是可以通过间接的方式[sort 和 limit]实现这个。 要查询最大值我们只需要把结果集按照降序排列,取第一个值就是了。 如我的例子,我想取得集合中年龄最大的人。 - db.person.find({}).sort({"age" : -1}).limit(1)
复制代码 : s/ j9 n+ a4 L: [8 m! W+ p. a7 F% {
! H' A# x0 a) [. Z( d5 d& A3 U4 l: y
相反如果想要年龄最小的人,只需要把sort中改为{“age”:1}就可以了。 当然我们使用了sort,对于小数量的文档是没问题的。当对于大量数据需要给age建立索引,否则这个操作很耗时。 - distinct+ U; x9 F, R. u7 a
MongoDB的destinct命令是获取特定字段中不同值列表的最简单工具。该命令适用于普通字段,数组字段[myFriends]和数组内嵌文档[fruits]. 如上面的图片,我认为fruits和myFriends字段是不同的。网上很多资料和例子都没说到这个情景,因为我们也业务是fruits这样的模型,我测试了。对于fruits.fruitId他也是可行的。 如上面的表结构,我想统计所有的喜欢的水果。 - db.person.distinct("fruits.fruitId") // 查找对象里引入对象的值,直接加.
复制代码
+ \& A; V/ g4 |8 u, A" j
! S% s$ _0 h) r) p% M! P1 } 他成功执行了。输出如: - [ "aaa", "bbb", "ccc", "www", "xxx", "yyy", "zzz", "rrr" ]
复制代码 7 A" S$ ?: r- z4 j- N
- u1 \+ d+ w* E5 b+ j5 c" {
我想统计集合中共有多少个人[按名字吧] - db.person.distinct("manName")
复制代码
2 Y5 K! S0 e9 u% ^- A+ c+ X1 `- k3 [ U
我想统计指定个数的人的共同关注的朋友。 - db.person.distinct("myFriends", {"manName" : {"$in" : ["ZhenQin", "YangYan"]}})
复制代码 - W# r; R% _& }
- H( G( m- x! E9 c4 U/ P 输出如: -
+ b% p1 w' F0 u6 g+ Y% Y - [ "234567", "345678", "456789", "987654", "ni", "wo" ]
复制代码 5 Q4 ^1 a7 R1 P% [
* v, V( d) N% G0 I0 s* Z
( I' M9 z; ^' `8 b" f
那么我使用Java呢? 我只是在演示Mongo的命令,用Spring Data Mongo是怎么操作的? Spring Schema: - <beans xmlns="http://www.springframework.org/schema/beans"
+ V5 ]6 `" \/ f. P - xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
z5 a/ Y' s" B5 ^) S" @, d - xmlns:context="http://www.springframework.org/schema/context"
& s0 }9 R6 ^3 E( K. o - xmlns:mongo="http://www.springframework.org/schema/data/mongo"" A4 K8 b/ m$ l6 t1 k" E1 L
- xsi:schemaLocation="http://www.springframework.org/schema/beans! s1 L$ V" }/ b' s1 ?4 b# a
- http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
: {2 u: _0 [" W5 ?% |! L! v - http://www.springframework.org/schema/context
4 a' b9 t+ E( {# _ - http://www.springframework.org/schema/context/spring-context-3.1.xsd
: C' y! O- I) J - http://www.springframework.org/schema/data/mongo0 u) A8 h/ W5 N' r7 D
- http://www.springframework.org/schema/data/mongo/spring-mongo-1.0.xsd">
$ ]2 v2 N! c- k/ P; _3 K - ' X# f' d' W' N- T/ ~
- <context:property-placeholder location="classpath:mongo.properties" />2 i3 l: Z+ n* P; p% h$ n
-
0 U0 {4 N3 _3 a) N) S4 Y+ T G - <!-- Default bean name is 'mongo' -->2 J# z: q- K% x4 r6 n$ O4 p4 ~
- <mongo:mongo id="mongo" host="${mongo.host}" port="${mongo.port}" />
/ M! X; o! O8 V+ k4 X" [( u -
+ e1 Q% v! M/ D( F. ~ - <mongo:db-factory id="mongoDbFactory" H4 c6 ~: w3 Q. j/ b. f/ o; H. Z( W. W; a
- mongo-ref="mongo"
- k, l m& c8 M% B' {0 n+ D) k* E% M - dbname="mongotest" />% |: ?3 V7 A z3 X8 c/ i/ d
-
, Q) P @* v9 h' R7 N) P - <bean id="mongoTemplate" class="org.springframework.data.mongodb.core.MongoTemplate">
2 J" I, v, e, B6 ~, C/ x - <constructor-arg name="mongoDbFactory" ref="mongoDbFactory"/>% F {6 Y1 b1 ?% d
- </bean>
4 y& Q z7 D t# L, Y - </beans>
复制代码
6 f' Q+ l0 r% x- ]$ H
. d. K; A# z* a' d/ ]; p max和min的测试: - @Test
0 Y1 E9 a$ r' }, u: W( G - public void testMaxAndMinAge() throws Exception {& W% X9 Y: F7 {5 l- J# \
- Query q = new BasicQuery("{}").with(new Sort(new Sort.Order(Sort.Direction.ASC, "age"))).limit(1);
\8 h6 p& }. O; t9 O - Person result = mongoTemplate.findOne(q, Person.class);
- x, X6 V2 X- v - log.info(result);: G, t# v4 s' C/ N. q$ @9 ?
- 5 F' Y+ a, j6 Z, D- G) t1 ?% q, k
- q = new BasicQuery("{}").with(new Sort(new Sort.Order(Sort.Direction.DESC, "age"))).limit(1);1 @$ n( i( D8 r" m+ A8 u
- result = mongoTemplate.findOne(q, Person.class);1 L3 d6 o& i% O* v; ?+ g
- log.info(result);, w" z; r% C% K4 |- W
- }
复制代码
: e8 v" b* V# v: ~3 }7 S# a" P% o9 @$ g& A" a( X) R
distinct的测试: - @Test5 k% n, O$ D1 n6 H' J) f
- public void testDistinct() throws Exception {
- e6 L5 L, Z* x* `, x - List result = mongoTemplate.getCollection("person").distinct("myFriends");
& H0 I, Q2 V; M$ Y$ N- z - for (Object o : result) {
( a3 [7 \0 d1 U: L - log.info(o);
9 T0 p$ Q: p! s; | - }
: t) c# d% k3 d& Z$ w - 8 I$ p, Z5 E- k
- log.info("==================================================================");
6 Q1 g2 `! k8 G5 u/ V3 t! l - Query query = Query.query(Criteria.where("manId").is("123456"));
1 `$ ]3 m+ G# C5 k) j - result = mongoTemplate.getCollection("person").distinct("myFriends", query.getQueryObject());1 l: G8 r+ t: V s! y7 ~0 K- x9 v x
- for (Object o : result) {
" N1 w( i s5 e" _) b - log.info(o);) a4 k& ]6 [2 K0 \4 U/ }
- }6 E& ~6 `- X' w( k9 e% n0 x
-
6 `% M Q9 j- g) o* D+ l/ V - log.info("==================================================================");
9 R% |" Z: X! k: {; H! d8 y0 x r' E1 [ - result = mongoTemplate.getCollection("person").distinct("fruits.fruitId");
1 C2 z+ u) x* J. ^7 c) q; o N - for (Object o : result) {7 H( V6 t' |* s+ j' r5 k
- log.info(o);
4 w: l. Q8 J5 T; `( a3 } p8 K - }
4 l7 f x5 ?4 ] w - }
复制代码
# L; R" g( Z+ u" E% T
' a9 q- Z; N' d 输出的结果为: - 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(72)] 234567
2 _. j# Q' m4 B6 u( p1 \0 m - 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(72)] 345678# @* H: v6 U" @( }# A) N
- 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(72)] 456789
9 M1 ^. `1 c7 R5 t - 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(72)] 987654
: q/ U/ ~( ~# T7 o - 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(72)] ni! t/ ], h! T. h8 O! C0 q. v
- 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(72)] wo
2 k! ~: K& f* z6 H& X - 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(72)] 1234569 H ~! g6 ~0 u6 [
- 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(75)] ==================================================================
2 W) g8 _0 {7 Y1 ~0 W) C - 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(79)] 2345674 u* E1 T4 d$ v6 I( W
- 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(79)] 345678
" N8 [" W1 R: Z% p- h# l# \ - 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(79)] 456789, d! j& g* P8 \+ `
- 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(79)] 987654! n; d r# P! p# |8 A7 V; Q' ^
- 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(82)] ==================================================================) i- I. f4 a, J8 K" B/ P: W
- 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(85)] aaa) O" a! q# w$ j# ~ f
- 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(85)] bbb7 ^( ^# G. B+ z& p- R) G
- 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(85)] ccc
! X+ X( T* R4 q& M - 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(85)] www
8 u( G3 q! v, E% S3 A - 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(85)] xxx) n2 B& I( o f) s: G
- 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(85)] yyy( E$ a" T( O7 i% v+ c! J9 r, z6 X/ g
- 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(85)] zzz( w; V7 S" W8 k. e& t
- 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(85)] rrr1 Q: o& ~5 K* `: s
- 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
复制代码
! S4 L+ Z* g0 ^; _% q& T6 ^% _
3 e9 M( t% a9 y# m0 r 这里我要特别说明一下, 当使用了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等信息。
: ^- c: u3 X3 ~9 k9 p: X. M' T4 b# S4 Y3 q8 _
! y8 H) T% i, S( b, l
|