您尚未登录,请登录后浏览更多内容! 登录 | 立即注册

QQ登录

只需一步,快速开始

 找回密码
 立即注册

QQ登录

只需一步,快速开始

查看: 3496|回复: 0

[php学习资料] MongoDB高级查询用法大全

[复制链接]
发表于 2019-7-4 17:21:36 | 显示全部楼层 |阅读模式
版本一:6 |- T& X8 c: b4 @+ e/ Y

% X+ B/ P7 w3 O/ z6 q" M1 ) . 大于,小于,大于或等于,小于或等于& I% ?  @1 R! \3 I

- K: k6 z- P7 ]3 I8 ?$gt:大于7 w6 _- O# C% y  L; H" w
$lt:小于1 C/ z2 }* v9 K1 q& J, r
$gte:大于或等于; [7 r4 W1 D$ Z& r! l1 ^% a6 v
$lte:小于或等于% }* x8 w. R, I$ J/ ~- F

0 [! @2 q; {8 r3 C7 R" H6 }例子:
  1. db.collection.find({ "field" : { $gt: value } } );   // greater than  : field > value; B4 U# @$ K0 j' R
  2. db.collection.find({ "field" : { $lt: value } } );   // less than  :  field < value
    " S/ I  S( d/ R8 I0 N( \
  3. db.collection.find({ "field" : { $gte: value } } );  // greater than or equal to : field >= value
    3 l8 \9 h" A6 i4 `$ O
  4. db.collection.find({ "field" : { $lte: value } } );  // less than or equal to : field <= value
复制代码

0 M% t4 m3 K. J  Y
如查询j大于3,小于4:
  1. db.things.find({j : {$lt: 3}});1 j! o( J- `- H+ h; r/ S) r) l) x
  2. db.things.find({j : {$gte: 4}});
复制代码

3 Q; f$ Y' v# H  M
也可以合并在一条语句内:
  1. db.collection.find({ "field" : { $gt: value1, $lt: value2 } } );    // value1 < field < value
复制代码
: }' {; `9 d: E! b

. B+ F5 p6 t/ d: H
% h9 s0 S  P, f9 D4 R2 x% [8 r. Q
2) 不等于 $ne
例子:
  1. db.things.find( { x : { $ne : 3 } } );
复制代码

3 W. P* K  Y0 H( E3 d
3) in 和 not in ($in $nin)
) o" p* ?- f( v" n( Y0 m% a) Z$ q7 z' j
4 T6 E$ Q% i8 ~6 C' u/ D( |4 u  U9 T语法:
  1. db.collection.find( { "field" : { $in : array } } );
复制代码

" M1 N$ [; y5 W6 C1 ?
例子:
  1. db.things.find({j:{$in: [2,4,6]}});' y7 B7 ~+ R. d
  2. db.things.find({j:{$nin: [2,4,6]}});
复制代码

+ W' S- h' G  l: n% e

- ^4 s# ^/ U' A# o1 s9 q. C: ]: s4) 取模运算$mod
; n5 P& D5 }* X& Y! `3 o
3 D* a2 s$ a& v" |如下面的运算:
  1. db.things.find( "this.a % 10 == 1")
复制代码
/ k) B5 x* i4 C, ^- b
可用$mod代替:
  1. db.things.find( { a : { $mod : [ 10 , 1 ] } } )
复制代码

1 J" s$ U$ n8 f8 ]3 _# l) g  J0 [
! ?: F$ W1 h8 D
5)  $all
6 \9 m  d! W1 n. r4 e2 r1 W" D& ?, {5 l6 s* Y) t
$all和$in类似,但是他需要匹配条件内所有的值:. [  q+ w6 Y2 K+ n( o

- H, u1 T/ o: V; b+ i9 j如有一个对象:4 K5 Q' E1 B: Z2 [' L) p1 Q
  1. { a: [ 1, 2, 3 ] }
复制代码

2 A1 C: j; g. H2 t: s2 z% t1 L% f
下面这个条件是可以匹配的:
  1. db.things.find( { a: { $all: [ 2, 3 ] } } );
复制代码
* Z6 `3 j6 r! o8 ?1 V7 ~
但是下面这个条件就不行了:
  1. db.things.find( { a: { $all: [ 2, 3, 4 ] } } );
复制代码
7 V0 C2 P' O, x; U. l/ a, d& w  p

% v- S7 r& d) ]" U" j# ?+ m' O$ T6)  $size# {, A! W/ M2 K
* X' i! _/ {4 l
$size是匹配数组内的元素数量的,如有一个对象:{a:["foo"]},他只有一个元素:
$ e2 j8 _0 C) p' M. ?  u/ s4 w; F' A7 E* c
下面的语句就可以匹配:
  1. db.things.find( { a : { $size: 1 } } );
复制代码

+ r: g- l! J% S. L! r
官网上说不能用来匹配一个范围内的元素,如果想找$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.
+ A: V: [6 ?0 e) c, K4 i9 V7 D
7)$exists
$exists用来判断一个元素是否存在:
如:
  1. db.things.find( { a : { $exists : true } } ); // 如果存在元素a,就返回$ G  K/ I( f* w- Q0 I/ S
  2. db.things.find( { a : { $exists : false } } ); // 如果不存在元素a,就返回
复制代码

' s9 r; g" A6 x2 ?  B5 g
8)  $type
$type 基于 bson type来匹配一个元素的类型,像是按照类型ID来匹配,不过我没找到bson类型和id对照表。
  1. db.things.find( { a : { $type : 2 } } ); // matches if a is a string
    , |; {. C5 |& b9 a& ?" L
  2. db.things.find( { a : { $type : 16 } } ); // matches if a is an int
复制代码

. {% U6 e( r, {$ B( @% c
9)正则表达式4 D7 N1 P& ]1 {0 X, ]2 m6 b1 x" K
$ i) a, D' k3 n4 ^0 d
mongo支持正则表达式,如:
  1. db.customers.find( { name : /acme.*corp/i } ); // 后面的i的意思是区分大小写
复制代码

5 ]* P& T( D5 n) E
10)  查询数据内的值0 i" R9 n$ L( I* t
: u7 g( f: _5 ]" n0 Z; t: L
下面的查询是查询colors内red的记录,如果colors元素是一个数据,数据库将遍历这个数组的元素来查询。
  1. db.things.find( { colors : "red" } );
复制代码
, [2 D- U; m" r! I
11) $elemMatch
" {/ l6 S" w9 h- m( a9 p
8 s% L2 s6 o+ I' Z+ `- {如果对象有一个元素是数组,那么$elemMatch可以匹配内数组内的元素:
  1. > t.find( { x : { $elemMatch : { a : 1, b : { $gt : 1 } } } } )
    ( @! x3 L; d6 N6 ^
  2. { "_id" : ObjectId("4b5783300334000000000aa9"),  
    , H2 d3 U+ ?* b
  3. "x" : [ { "a" : 1, "b" : 3 }, 7, { "b" : 99 }, { "a" : 11 } ]
    ; A* N$ O/ r$ I3 w
  4. }
复制代码

% h( Q& r4 H' a. d0 m$elemMatch : { a : 1, b : { $gt : 1 } } 所有的条件都要匹配上才行。
注意,上面的语句和下面是不一样的。
> t.find( { "x.a" : 1, "x.b" : { $gt : 1 } } )- V. \  E: d, a9 d" F7 ?% q
$elemMatch是匹配{ "a" : 1, "b" : 3 },而后面一句是匹配{ "b" : 99 }, { "a" : 11 } ( {* U- q9 A; [9 ~) W; u( O: o$ g
7 H' n7 H! b  C* t" n
12)  查询嵌入对象的值
  1. db.postings.find( { "author.name" : "joe" } );
复制代码
; a- M1 D; @( k3 w. T8 \3 z: Z( e) O
注意用法是author.name,用一个点就行了。更详细的可以看这个链接: dot notation
举个例子:
  1. > db.blog.save({ title : "My First Post", author: {name : "Jane", id : 1}})
复制代码

% ]" E9 D; n1 R( k7 r
如果我们要查询 authors name 是Jane的, 我们可以这样:
  1. > db.blog.findOne({"author.name" : "Jane"})
复制代码

. O4 A* C# ^! X
如果不用点,那就需要用下面这句才能匹配:
  1. db.blog.findOne({"author" : {"name" : "Jane", "id" : 1}})
复制代码
" T: P# V1 s! W4 |3 ?7 a. ^4 ^0 t
下面这句:
  1. db.blog.findOne({"author" : {"name" : "Jane"}})
复制代码

* ], S) t" V4 M) O& @
是不能匹配的,因为mongodb对于子对象,他是精确匹配。

/ S5 Z5 D" D! a
13) 元操作符 $not 取反
如:
  1. db.customers.find( { name : { $not : /acme.*corp/i } } );
    5 S! j4 L  O; R- t# j
  2. db.things.find( { a : { $not : { $mod : [ 10 , 1 ] } } } );
复制代码

. p: a) M! c2 d* f* K
mongodb还有很多函数可以用,如排序,统计等,请参考原文。) M$ E" L! s( I: ^

& ~! [  P- R3 rmongodb目前没有或(or)操作符,只能用变通的办法代替,可以参考下面的链接:
8 k& t' ~( {# n/ _! ]8 |& h
6 U9 n0 }+ d; I' O8 E% Dhttp://www.mongodb.org/display/DOCS/OR+operations+in+query+expressions
. f$ i. u! G! E# O
+ @1 y' \! q7 N, z1 ~: B( w版本二:, r6 u2 o6 @3 R8 {" ?; n9 ^
shell 环境下的操作:
   1.  超级用户相关:
         1. #进入数据库admin

6 p: [( p3 s( y/ ^/ \9 G
  1. use admin
复制代码
( ?3 ]; T" c; [; D
         2. #增加或修改用户密码
  1.           db.addUser('name','pwd')
复制代码

  R9 ]1 d, E( m) F* n
         3. #查看用户列表
  1.           db.system.users.find()
复制代码

! x  i( S9 Y2 K% w' m
         4. #用户认证
  1.           db.auth('name','pwd')
复制代码
0 K" T, J/ I- c& m
         5. #删除用户
  1.           db.removeUser('name')
复制代码

- Q6 i  x) a2 [5 O! |1 j
         6. #查看所有用户
  1.           show users
复制代码
! F0 \3 _8 j2 x! Y/ M4 c
         7. #查看所有数据库
  1.           show dbs
复制代码

4 P/ g' i" G; K" F& [, V  l
         8. #查看所有的collection
  1.           show collections
复制代码
4 L( ], A, g9 c0 C/ P) ]4 h& q
         9. #查看各collection的状态
  1.           db.printCollectionStats()
复制代码
/ \/ v. _6 w& u: ~" U* J% R
        10. #查看主从复制状态
  1.           db.printReplicationInfo()
复制代码
0 E& x% B7 g5 G
        11. #修复数据库
  1.           db.repairDatabase()
复制代码

5 m  m5 Z! a9 u, X' ^. j8 B6 u
        12. #设置记录profiling,0=off 1=slow 2=all
  1.           db.setProfilingLevel(1)
复制代码

, |, G4 T- ?3 I! D
        13. #查看profiling
  1.           show profile
复制代码

) O. C  h5 x- ~3 S: L" p
        14. #拷贝数据库
  1.           db.copyDatabase('mail_addr','mail_addr_tmp')
复制代码

$ e8 W- s) j$ Z" N
        15. #删除collection
  1.           db.mail_addr.drop()
复制代码

$ T* o! M! N" v8 Y* j- ?1 |# d
        16. #删除当前的数据库
  1.           db.dropDatabase()
复制代码
+ S/ {) D6 i' d' H5 k
   2. 增删改
         1. #存储嵌套的对象
  1.              db.foo.save({'name':'ysz','address':{'city':'beijing','post':100096},'phone':[138,139]})
复制代码
4 g$ _+ d9 o* n# u$ ~
         2. #存储数组对象
  1.              db.user_addr.save({'Uid':'yushunzhi@sohu.com','Al':['test-1@sohu.com','test-2@sohu.com']})
复制代码
( w" B6 _) n' n# U$ r
         3. #根据query条件修改,如果不存在则插入,允许修改多条记录
  1.             db.foo.update({'yy':5},{'$set':{'xx':2}},upsert=true,multi=true)
复制代码
1 F% L/ N9 C5 i& j2 E
         4. #删除yy=5的记录
  1.             db.foo.remove({'yy':5})
复制代码
" p/ a- O% ]! b' L
         5. #删除所有的记录
  1.             db.foo.remove()
复制代码

8 h$ `, I3 P$ C3 H4 @
   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()

! t/ u3 _/ `) X, u  N
6.  高级查询
条件操作符
$ ~# L& q/ \- Q8 P9 G0 R
  1. $gt : >
    4 r% t' o# P! _: W
  2. $lt : < 3 B6 e0 T  b" Q: h/ w3 ?# Q
  3. $gte: >= & @, ^+ U8 J  k" w
  4. $lte: <=
    1 q% R3 {+ ^0 Z3 Y7 o4 z
  5. $ne : !=、<>   D9 ^. G7 W$ w* p5 k
  6. $in : in - D$ B( i0 j3 r: U% f
  7. $nin: not in ! L& g! g$ w4 P+ h: j: u
  8. $all: all
    / \1 k/ |2 g% s" k. C: L  X/ }
  9. $not: 反匹配(1.3.3及以上版本)
复制代码
5 r3 |# C) x% m0 E7 @- z
; {8 w, n# o0 c  \
查询 name <> "bruce" and age >= 18 的数据
0 t' C6 {0 c' X* g% Y4 [2 N* n
  1. db.users.find({name: {$ne: "bruce"}, age: {$gte: 18}});
复制代码
7 M$ H0 m! _: ~( j; f% i# K

/ H: \2 _+ |& W* V) J查询 creation_date > '2010-01-01' and creation_date <= '2010-12-31' 的数据 , W, @% {, W. [4 e& G
  1. db.users.find({creation_date:{$gt:new Date(2010,0,1), $lte:new Date(2010,11,31)});
复制代码

: }% Z  {0 L/ Y: ]) @% A
1 v- a- e6 w: O" [: Q查询 age in (20,22,24,26) 的数据 ; P7 E* }7 q" |. L" ^
  1. db.users.find({age: {$in: [20,22,24,26]}});
复制代码
4 p) u  _8 r3 U9 u; H

' W% B. K4 z9 i0 M- Q查询 age取模10等于0 的数据
, O" U. v" e6 o- {% p3 f. A* A
  1. db.users.find('this.age % 10 == 0');
复制代码
7 X  {$ Y9 \% N: ~8 l
或者
9 ~" J/ t+ j6 |6 n7 Z; c
  1. db.users.find({age : {$mod : [10, 0]}});
复制代码

  |3 P9 Z# k8 `8 V' w3 J1 U
  C8 K4 `* G8 d' l  @  O, D6 Y1 f匹配所有
$ m0 K* H0 A4 j8 b8 H. C8 O+ M! q
  1. db.users.find({favorite_number : {$all : [6, 8]}});
复制代码
+ e7 o/ b% x3 \( C! B7 t7 e7 v
可以查询出{name: 'David', age: 26, favorite_number: [ 6, 8, 9 ] } 2 n" e" g3 H: s. m
可以不查询出{name: 'David', age: 26, favorite_number: [ 6, 7, 9 ] } / X6 _' e& f; h, X' C
+ |0 Y8 I  Y5 T9 g' t# h7 F3 z8 B5 c
查询不匹配name=B*带头的记录 6 ]0 S' ]% f+ X( B3 \
  1. db.users.find({name: {$not: /^B.*/}});
复制代码

) m" j* H! n7 B$ \' `% g查询 age取模10不等于0 的数据 5 }; W- f; A3 d' @
  1. db.users.find({age : {$not: {$mod : [10, 0]}}});
复制代码

. F; E* s! e) ~  L7 q' N
/ r9 T. P9 _4 _; G4 U#返回部分字段
/ T0 g; x: N; x% G  y  P选择返回age和_id字段(_id字段总是会被返回) 7 b. Q4 S: l/ q$ m0 `7 X- y
  1. db.users.find({}, {age:1});
    3 }, G( q1 `- k* O1 k& k  W* z& I
  2. db.users.find({}, {age:3}); " |$ i1 L& |' m, ~9 n
  3. db.users.find({}, {age:true}); / Q4 Q9 b4 ]/ y- ~6 n
  4. db.users.find({ name : "bruce" }, {age:1});
复制代码
: T% [$ o$ h4 x
0为false, 非0为true
  f  \0 {* k, N, r! o
& F/ ?5 H6 |: U8 X* `7 M. S选择返回age、address和_id字段
% S9 Y( F) K4 Y# k/ c
  1. db.users.find({ name : "bruce" }, {age:1, address:1});
复制代码

2 w; z6 k+ u% R/ B1 n' m% U
8 w7 W4 b) g1 f$ ?7 d  _排除返回age、address和_id字段
$ B2 K6 a  t; _' K( H: Z6 `
  1. db.users.find({}, {age:0, address:false});
    , c1 \# S% K6 r9 e2 C5 g- s- _
  2. db.users.find({ name : "bruce" }, {age:0, address:false});
复制代码
4 E; I9 O9 n4 C, @9 z. @' d

3 f; R$ h! W1 T' o' M" M数组元素个数判断 5 i" Y* y4 ?* j6 Y2 i9 _
对于{name: 'David', age: 26, favorite_number: [ 6, 7, 9 ] }记录
" Y4 |4 E2 q- C/ R' p, |  S匹配db.users.find({favorite_number: {$size: 3}}); 1 m* k  ^0 s" @4 N5 F7 _* B9 A
不匹配db.users.find({favorite_number: {$size: 2}});
; h) j6 j" ^: X0 o+ C! b. U4 @
! p2 j/ k& q; m- Y& h+ h$exists判断字段是否存在
1 [- i- X/ Y* x& z查询所有存在name字段的记录 , y' M+ S3 X" m/ p
  1. db.users.find({name: {$exists: true}});
复制代码

4 ?. s9 S6 M+ n2 c6 j- F查询所有不存在phone字段的记录 9 m+ r) m# m' ^) h
  1. db.users.find({phone: {$exists: false}});
复制代码
! }) ?/ W5 E4 N& O, V% r

7 v, _3 m3 d7 G% c  S8 R: ?2 j! f$type判断字段类型
3 B$ p8 x$ i1 j# m, c; u# i查询所有name字段是字符类型的 6 j4 I% j2 c* q' \9 E  V8 @1 f
  1. db.users.find({name: {$type: 2}}); 5 r! k2 X6 |4 Q4 r
复制代码
  ~* g( _. W" O) o% _5 Z
查询所有age字段是整型的 " I/ P$ ?. w, `6 t7 b9 g  W) p3 E! V' N
  1. db.users.find({age: {$type: 16}}); ! r2 c( l" N/ t( ~9 y6 ?& i
复制代码
/ j8 f/ g9 k+ ?* x
对于字符字段,可以使用正则表达式 , z) u8 \7 y9 u$ W4 Z+ ~1 m7 W" S/ j3 A
查询以字母b或者B带头的所有记录 ' ]1 @3 D. z- m( \# k5 ~
  1. db.users.find({name: /^b.*/i});
    9 {) j; i% e, z0 m, T0 @+ d
复制代码

8 l7 }) @& t. X8 N: G4 U$ t$elemMatch(1.3.1及以上版本)
9 M: U$ _! n% M5 s( ?0 [为数组的字段中匹配其中某个元素 6 }5 I6 ^+ L" \' V

3 E. p. Z5 |' v( a( KJavascript查询和$where查询
$ `7 Q4 z& p9 F: m查询 age > 18 的记录,以下查询都一样
8 I' s' R# n) K, B- ?
  1. db.users.find({age: {$gt: 18}});
    # e, e' P2 i* E, @% B! L
  2. db.users.find({$where: "this.age > 18"});
    5 e1 b& `& `$ u& d: W2 _
  3. db.users.find("this.age > 18");
    " d5 ~0 |% ?6 L0 r* W6 n
  4. f = function() {return this.age > 18} db.users.find(f);
复制代码

+ u. }3 T' Y; s% K- w
" N7 `: f+ c2 n. c, L6 B排序sort()
& k5 Z+ J' [$ Z8 c+ j7 Q以年龄升序asc
6 X9 j, M) f8 i8 G9 r. v
  1. db.users.find().sort({age: 1});
    1 W* K6 h1 d# @: u9 A$ J7 `3 j/ U5 a
复制代码

  f4 A( B1 a4 C/ {: u8 @以年龄降序desc
9 C; V. r. Z- m& ?8 K
  1. db.users.find().sort({age: -1}); ( B8 u' W: p& g5 S
复制代码
; V' R# f9 f2 i6 c+ E
限制返回记录数量limit()
4 z$ v# f* A% A返回5条记录 & {# u' f" b& R* F' Q, J
  1. db.users.find().limit(5); 9 l6 I: N( m; x7 n1 C: {: p) x
复制代码
( X8 @5 ]1 J, Z! ~
返回3条记录并打印信息 & ?- h3 e% v% `& U
  1. db.users.find().limit(3).forEach(function(user) {print('my age is ' + user.age)});
    / A' w7 Y. L9 h! K( M
复制代码
8 h/ p  _6 \7 z* w9 F
结果 2 x7 M+ z! g. R: |! g2 [3 N0 h) {
  1. my age is 18 + u# H! f" Q3 l! ?; |9 k( q
  2. my age is 19 0 n8 H5 g5 C# a3 {# I& q& x% R
  3. my age is 20
复制代码

) f2 q! s' s7 w, P) V- |# g/ c, a, i3 v  x0 h- F
限制返回记录的开始点skip() % @3 {0 t3 R1 n& `
从第3条记录开始,返回5条记录(limit 3, 5)   m6 R7 |7 c5 S$ z1 N8 A- y
  1. db.users.find().skip(3).limit(5);
      [7 o, ?" @, |( z! |1 Z
复制代码
6 C  T* K$ z- S, {2 B: w/ i
查询记录条数count() / x9 V' t& G: E3 I3 y0 Y
db.users.find().count(); 3 R, h1 S- x! A, V$ U! z
db.users.find({age:18}).count();
4 j8 Q3 Q+ i& o. v. Q% h) O5 h以下返回的不是5,而是user表中所有的记录数量 8 f" u7 u- E' ^' J1 v+ v9 y
db.users.find().skip(10).limit(5).count();
3 L! P+ F% q( r! R% W- Z0 w如果要返回限制之后的记录数量,要使用count(true)或者count(非0) 0 c! L5 M8 d* e/ u: W8 z
  1. db.users.find().skip(10).limit(5).count(true);
复制代码

4 }0 c' ?! ^, m, \5 g, ?- G
$ g. M# ~% F* K7 |- d分组group() # B/ x( X) k, G. }* {+ w
假设test表只有以下一条数据
% n! G' d( D; ?
  1. { domain: "www.mongodb.org" ; o9 k, C+ E& u' o- w
  2. , invoked_at: {d:"2009-11-03", t:"17:14:05"}
    . J8 f2 {  c' j- k" A1 L* \+ [$ L
  3. , response_time: 0.05 3 g; I9 ?- D; P( n
  4. , http_action: "GET /display/DOCS/Aggregation" 3 b  K7 p$ V" R5 P% Q( {
  5. }
复制代码

. X6 n- s- e. p& }- B9 [使用group统计test表11月份的数据count:count(*)、total_time:sum(response_time)、avg_time:total_time/count; 0 S  a; r3 E! @& `
  1. db.test.group(
    # V# g& L- \+ o5 y
  2. { cond: {"invoked_at.d": {$gt: "2009-11", $lt: "2009-12"}} : B: R$ B- B% P& {
  3. , key: {http_action: true} * c) R- I  B+ M( i" Y; r
  4. , initial: {count: 0, total_time:0} % N7 {' Q9 {  o; B  `
  5. , reduce: function(doc, out){ out.count++; out.total_time+=doc.response_time } + m( i* ]% E/ d  o/ |0 Y
  6. , finalize: function(out){ out.avg_time = out.total_time / out.count } + _2 Q% n3 u7 F1 J6 c
  7. } ); 3 D: t& l6 g2 g8 s

  8. , J8 [" `- _6 g) e" C
  9. [
    7 P& ^0 F! @1 F  C1 t5 q
  10. { 2 g  o/ J& m0 I6 V6 B: b) [
  11. "http_action" : "GET /display/DOCS/Aggregation", # }" i2 k5 Q5 j! |# j
  12. "count" : 1, 8 f* n% I+ n# N4 w
  13. "total_time" : 0.05, $ B; f% U  k  }/ R4 Y. A
  14. "avg_time" : 0.05 & W7 q* {. z+ u/ ~
  15. } ) g! D2 Q- L  C- E
  16. ]
复制代码

- S( C4 \2 n; C* F  e' p5 O3 \$ f) L5 i5 m

+ |( q: s% O! D( Z# QMongoDB 高级聚合查询
MongoDB版本为:2.0.8
系统为:64位Ubuntu 12.04
先给他家看一下我的表结构[Oh sorry, Mongo叫集合]
20121225152152_182.png
如你所见,我尽量的模拟现实生活中的场景。这是一个人的实体,他有基本的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
    4 `) w! [+ Z# I. d: q2 ]
我和同事在测试Mongo时,索引还写了不到一半,他想查询某个字段的最大值,结果找了半天文档也没找到关于max的函数。我也很纳闷这是常规函数啊怎么不提供? 后来经过翻阅资料确定Mongo确实不提供直接的max和min函数。但是可以通过间接的方式[sort 和 limit]实现这个。
要查询最大值我们只需要把结果集按照降序排列,取第一个值就是了。
如我的例子,我想取得集合中年龄最大的人。
  1. db.person.find({}).sort({"age" : -1}).limit(1)
复制代码
2 c$ Q5 ~$ z6 c
2 V- q' P, S2 @3 M5 T
. Y' K0 q7 o; h' W! G- P
相反如果想要年龄最小的人,只需要把sort中改为{“age”:1}就可以了。
当然我们使用了sort,对于小数量的文档是没问题的。当对于大量数据需要给age建立索引,否则这个操作很耗时。
  • distinct
    9 H6 [" B; M- o& U; H/ A! O0 J
MongoDB的destinct命令是获取特定字段中不同值列表的最简单工具。该命令适用于普通字段,数组字段[myFriends]和数组内嵌文档[fruits].
如上面的图片,我认为fruits和myFriends字段是不同的。网上很多资料和例子都没说到这个情景,因为我们也业务是fruits这样的模型,我测试了。对于fruits.fruitId他也是可行的。
如上面的表结构,我想统计所有的喜欢的水果。
  1. db.person.distinct("fruits.fruitId") // 查找对象里引入对象的值,直接加.
复制代码
. M* y$ M9 F" n8 m7 t9 o5 v

. O) O2 n* d& S
他成功执行了。输出如:
  1. [ "aaa", "bbb", "ccc", "www", "xxx", "yyy", "zzz", "rrr" ]
复制代码

- E( a( P; i: M7 e! v$ o8 T' f) W4 g) Z9 A8 o6 l+ }+ e) }' F
我想统计集合中共有多少个人[按名字吧]
  1. db.person.distinct("manName")
复制代码

# V* ~! d5 k( g5 ^8 U. m; h
; x1 l! l8 h4 E/ g6 Q
我想统计指定个数的人的共同关注的朋友。
  1. db.person.distinct("myFriends", {"manName" : {"$in" : ["ZhenQin", "YangYan"]}})
复制代码
+ ?% S1 p( I9 R

0 p" ]4 m6 T. [: V* x6 ]% g! H6 l
输出如:
  1.         
    4 z7 ?! ^! i; v( T; `) Y+ q
  2. [ "234567", "345678", "456789", "987654", "ni", "wo" ]
复制代码

- J0 u/ J$ n. K- j8 b5 [* }6 H* B) H
, W/ \5 u% _  ?# N. l+ c) g
那么我使用Java呢? 我只是在演示Mongo的命令,用Spring Data Mongo是怎么操作的?
Spring Schema:
  1. <beans xmlns="http://www.springframework.org/schema/beans"- h1 o7 c& q  r- r! @
  2.        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    8 F& b- D" v- S$ l. F
  3.        xmlns:context="http://www.springframework.org/schema/context"( E# s; ]! t8 {1 t: k* L. e
  4.        xmlns:mongo="http://www.springframework.org/schema/data/mongo"9 A! U/ ]: w: H$ S6 I! [. ]
  5.        xsi:schemaLocation="http://www.springframework.org/schema/beans
    3 ~% `9 D- s; Z, B& h1 h3 f7 Q
  6.           http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
    1 D$ K6 W$ |# C: u
  7.           http://www.springframework.org/schema/context
    / V. G- C1 s" o2 Z# d
  8.           http://www.springframework.org/schema/context/spring-context-3.1.xsd# z  `5 M3 z' Y- }
  9.           http://www.springframework.org/schema/data/mongo
    0 C! j- p& _2 r# b
  10.           http://www.springframework.org/schema/data/mongo/spring-mongo-1.0.xsd">$ }: u) C  u* A5 Z
  11. ) ^! q7 f9 C; M$ f. C4 n: t$ D
  12.     <context:property-placeholder location="classpath:mongo.properties" />
    $ Y5 L& T. I$ @! l. w5 |

  13. 1 [  t: t# N) I8 m1 G7 c: S) y
  14.     <!-- Default bean name is 'mongo' -->
    ( r5 c# ~  \) A1 D8 i! J
  15.     <mongo:mongo id="mongo" host="${mongo.host}" port="${mongo.port}" />( ]: {# m& _4 f- ~9 g
  16. : d3 k4 ^( Q9 G3 ]* `7 ^
  17.     <mongo:db-factory id="mongoDbFactory"2 m0 }6 s/ K7 I
  18.                   mongo-ref="mongo"% Y/ a) m* V# I& G
  19.                   dbname="mongotest" />2 _7 p8 f7 M0 X  n# d0 T# \# Y9 I

  20. " _- N) W, M7 D1 p% y2 l! T
  21.     <bean id="mongoTemplate" class="org.springframework.data.mongodb.core.MongoTemplate">
    8 \/ |$ G) ?) m
  22.         <constructor-arg name="mongoDbFactory" ref="mongoDbFactory"/>
    $ d/ s: b+ J5 P( N) C/ E# w9 o
  23.     </bean>
    . E( z9 u+ ^  h& N
  24. </beans>
复制代码
, ], ~7 A0 m# ]. C9 h
! z6 U/ _7 \. X) X- h: l
maxmin的测试
  1. @Test
    5 S) w3 R/ W1 Q! X$ T, h9 z
  2.     public void testMaxAndMinAge() throws Exception {
      |& F5 {3 M( W; T4 n
  3.         Query q = new BasicQuery("{}").with(new Sort(new Sort.Order(Sort.Direction.ASC, "age"))).limit(1);. E) q+ a- v; ?4 Z( B" |
  4.         Person result = mongoTemplate.findOne(q, Person.class);
    ! Y0 z$ q7 S+ f8 G, l  P9 w
  5.         log.info(result);: D1 M0 R  o" ?1 H2 m) C
  6. % v- @8 b& \1 H7 N
  7.         q = new BasicQuery("{}").with(new Sort(new Sort.Order(Sort.Direction.DESC, "age"))).limit(1);# l9 E  a9 k( X7 n& d* k
  8.         result = mongoTemplate.findOne(q, Person.class);
    / l3 g" F6 Z% N* ?! ^4 U
  9.         log.info(result);
    - f+ N6 x! p. S9 B, p6 F/ e; t
  10.     }
复制代码
+ D# T9 F' _& A# S  R0 }
- M3 {' K" g: h$ q; e, m
distinct的测试:
  1. @Test
    - A% O. `. x1 ]) X; b
  2.     public void testDistinct() throws Exception {
    3 `8 B6 R. i+ E
  3.         List result = mongoTemplate.getCollection("person").distinct("myFriends");1 T* l1 z) j" p
  4.         for (Object o : result) {1 \  L6 j: W/ q2 f
  5.             log.info(o);
    ' f+ ^8 o7 K: d
  6.         }
    3 D+ c9 k" x2 Z# C$ p1 x9 L

  7. 9 n- Q0 {& S2 e) ]1 L8 D- {- n
  8.         log.info("==================================================================");
    + g  R, F* g2 i3 P# v" o; D' l. h: a
  9.         Query query = Query.query(Criteria.where("manId").is("123456"));) I: G# ^4 O, G  E6 r' E2 y8 J
  10.         result = mongoTemplate.getCollection("person").distinct("myFriends", query.getQueryObject());
    ; l4 I3 M; z* G' N! O
  11.         for (Object o : result) {
    3 e- Y% i, v/ d# Z% g) t8 d# M6 r
  12.             log.info(o);2 x+ `3 q' ]  V, M- Y0 G
  13.         }
    ( {8 h% T9 n. u1 [  ^; t$ r9 x( w
  14. + s, x$ s8 q7 M
  15.         log.info("==================================================================");0 p" G' k2 q2 M2 \; c+ _& m
  16.         result = mongoTemplate.getCollection("person").distinct("fruits.fruitId");
    # |/ e3 V% _2 s- E; B7 X" G9 f
  17.         for (Object o : result) {
    : _; H0 S: ^7 E% N5 X+ e0 u- V
  18.             log.info(o);
    ( x/ G$ X* u, J4 Y
  19.         }
    ' p/ K( P8 w  T" |
  20.     }
复制代码

/ _4 m/ v6 |$ b5 S6 o7 @# t/ d# x9 `
2 v3 P0 f/ p6 A
输出的结果为:
  1. 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(72)] 234567& O5 N" ^, O8 y8 h
  2. 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(72)] 3456784 ~) G+ O5 s, o( M
  3. 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(72)] 456789: m6 _' F* b$ p1 Q1 i* t9 R0 |
  4. 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(72)] 987654( J+ `7 J5 j. w: ~* L
  5. 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(72)] ni! c; l0 F0 g: c# b6 ?
  6. 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(72)] wo7 W! _2 A1 C$ P# f0 |, ]4 I
  7. 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(72)] 1234563 _2 H6 Z9 q) n# s: _
  8. 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(75)] ==================================================================; j# H9 V8 R- O. c  B1 ~
  9. 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(79)] 234567
    + h& ?' e6 o0 \6 O- [- W
  10. 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(79)] 345678# X9 e4 I4 o5 x( I0 L/ B9 Z
  11. 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(79)] 456789
    ; `% G8 u& R* P) }
  12. 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(79)] 987654
    + V2 w$ t7 E9 m8 o9 b2 f0 C7 S
  13. 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(82)] ==================================================================
    & j+ k7 K* @1 c- X1 ~: r( `
  14. 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(85)] aaa9 }! {' }% ~2 l, u+ T( q" c& {
  15. 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(85)] bbb+ p7 ]2 h) o% t
  16. 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(85)] ccc% T& F- A1 a8 _' i/ k
  17. 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(85)] www* R4 X- c/ Z' O8 J6 K
  18. 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(85)] xxx1 d* y1 v( K# B3 z7 X$ a0 P' N
  19. 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(85)] yyy
    ; f& B( i& N/ ?4 P4 Z( z; U/ y
  20. 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(85)] zzz
    . o2 ?0 B" C1 F1 v9 ^
  21. 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(85)] rrr
    ) N. Q3 y5 q# Y' b/ Z$ K5 E/ x* ?
  22. 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
复制代码

, S6 J. S" \( [+ f( ]% s+ ^, `5 o& ^1 c3 d
这里我要特别说明一下, 当使用了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等信息。

" P& X  s, Z: V* P: W& l3 N" X
& u# e& e$ H- L/ N% |0 E4 `) \: N1 i7 t) E! ^' D9 C1 Z
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

GMT+8, 2021-6-13 21:18 , Processed in 0.202751 second(s), 25 queries .

Copyright © 2001-2021 Powered by cncml! X3.2. Theme By cncml!