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