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

QQ登录

只需一步,快速开始

 找回密码
 立即注册

QQ登录

只需一步,快速开始

查看: 10392|回复: 0
打印 上一主题 下一主题

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

[复制链接]
跳转到指定楼层
楼主
发表于 2019-7-4 17:21:36 | 只看该作者 |只看大图 回帖奖励 |倒序浏览 |阅读模式
版本一:
" 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
例子:
  1. db.collection.find({ "field" : { $gt: value } } );   // greater than  : field > value* |% E6 B! v9 i( Y4 {
  2. db.collection.find({ "field" : { $lt: value } } );   // less than  :  field < value
    ' {1 o" A" h( p9 K1 n) E2 S' y
  3. db.collection.find({ "field" : { $gte: value } } );  // greater than or equal to : field >= value
    + |' q) z: l4 C* |2 m0 j
  4. 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:
  1. db.things.find({j : {$lt: 3}});
    ' t' W4 w/ E6 v8 c9 @- G% s( x: k
  2. db.things.find({j : {$gte: 4}});
复制代码

1 B% y6 v4 l+ o% |" m  X- x
也可以合并在一条语句内:
  1. 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
例子:
  1. 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语法:
  1. db.collection.find( { "field" : { $in : array } } );
复制代码
' K. `7 Y# l0 S1 S2 }
例子:
  1. db.things.find({j:{$in: [2,4,6]}});
    ' S. t/ C# ^: W* s
  2. 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
如下面的运算:
  1. db.things.find( "this.a % 10 == 1")
复制代码

, K  z' z7 O% A" U  U
可用$mod代替:
  1. 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
  1. { a: [ 1, 2, 3 ] }
复制代码

* ~& i/ o0 t8 b( {( o( `( Y5 N
下面这个条件是可以匹配的:
  1. db.things.find( { a: { $all: [ 2, 3 ] } } );
复制代码

% ]0 y* _" ?& u  v
但是下面这个条件就不行了:
  1. 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
下面的语句就可以匹配:
  1. 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用来判断一个元素是否存在:
如:
  1. db.things.find( { a : { $exists : true } } ); // 如果存在元素a,就返回
    ) s+ j3 L  g" ]/ I( _6 W9 r( d! j
  2. db.things.find( { a : { $exists : false } } ); // 如果不存在元素a,就返回
复制代码
8 r4 b9 E& T# O
8)  $type
$type 基于 bson type来匹配一个元素的类型,像是按照类型ID来匹配,不过我没找到bson类型和id对照表。
  1. db.things.find( { a : { $type : 2 } } ); // matches if a is a string1 Q; Z2 Z+ t: |2 [
  2. db.things.find( { a : { $type : 16 } } ); // matches if a is an int
复制代码

- g9 [9 j% W" n* `( a
9)正则表达式8 Z* k1 a: E) \6 Q4 E) L- }/ G: H- K
/ l8 z# U$ s! G: b
mongo支持正则表达式,如:
  1. 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元素是一个数据,数据库将遍历这个数组的元素来查询。
  1. 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可以匹配内数组内的元素:
  1. > t.find( { x : { $elemMatch : { a : 1, b : { $gt : 1 } } } } )
    , D" B: K  p" @" f2 S5 t
  2. { "_id" : ObjectId("4b5783300334000000000aa9"),  3 I! k6 n6 @% u- |# H$ Y
  3. "x" : [ { "a" : 1, "b" : 3 }, 7, { "b" : 99 }, { "a" : 11 } ]6 m3 O' ]$ `* ^
  4. }
复制代码

. ^; 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)  查询嵌入对象的值
  1. db.postings.find( { "author.name" : "joe" } );
复制代码

/ `* |* t/ |8 ^2 j
注意用法是author.name,用一个点就行了。更详细的可以看这个链接: dot notation
举个例子:
  1. > db.blog.save({ title : "My First Post", author: {name : "Jane", id : 1}})
复制代码
; B3 `0 q6 l3 r. `; P
如果我们要查询 authors name 是Jane的, 我们可以这样:
  1. > db.blog.findOne({"author.name" : "Jane"})
复制代码

; U2 H2 k9 ^: r( c+ M0 D. F
如果不用点,那就需要用下面这句才能匹配:
  1. db.blog.findOne({"author" : {"name" : "Jane", "id" : 1}})
复制代码
1 \3 o7 r+ q, ?# o
下面这句:
  1. db.blog.findOne({"author" : {"name" : "Jane"}})
复制代码

- [+ J1 @3 V; T" w
是不能匹配的,因为mongodb对于子对象,他是精确匹配。

$ z  T( Y# n+ E5 O) @
13) 元操作符 $not 取反
如:
  1. db.customers.find( { name : { $not : /acme.*corp/i } } );0 l0 {2 u$ e2 q% o
  2. db.things.find( { a : { $not : { $mod : [ 10 , 1 ] } } } );
复制代码
$ q, V, Z3 V9 X7 L1 \
mongodb还有很多函数可以用,如排序,统计等,请参考原文。0 J5 s6 m2 e8 P* S+ a( r. ?( u! X, L

7 F0 D. L: B8 dmongodb目前没有或(or)操作符,只能用变通的办法代替,可以参考下面的链接:" D- J, G+ p6 _' v# k: i

  [; p4 Z+ v8 U1 e1 vhttp://www.mongodb.org/display/DOCS/OR+operations+in+query+expressions4 _0 @6 v& `8 f( ~+ V0 x7 U

$ W+ X) e! W1 m9 e: U* m版本二:) x; a3 F1 M6 J, V
shell 环境下的操作:
   1.  超级用户相关:
         1. #进入数据库admin
' N4 z5 ?5 @. g' |
  1. use admin
复制代码

7 N8 p) t4 B/ k9 k# q; ?! d3 w# M0 J
         2. #增加或修改用户密码
  1.           db.addUser('name','pwd')
复制代码

% ?% U' l4 Q; M
         3. #查看用户列表
  1.           db.system.users.find()
复制代码

: w  y$ `% d# R. M
         4. #用户认证
  1.           db.auth('name','pwd')
复制代码

6 ^" S/ z  H& a: R
         5. #删除用户
  1.           db.removeUser('name')
复制代码
* o/ J! K' j0 a
         6. #查看所有用户
  1.           show users
复制代码
2 p2 [" Y- V/ N
         7. #查看所有数据库
  1.           show dbs
复制代码

# j. A, R( I3 K  X) ^6 Y; m; Q
         8. #查看所有的collection
  1.           show collections
复制代码

  W9 r; Q2 A9 s8 k8 C
         9. #查看各collection的状态
  1.           db.printCollectionStats()
复制代码
4 S) L; a( M' S* X, Y5 G  W! y( _& x
        10. #查看主从复制状态
  1.           db.printReplicationInfo()
复制代码
/ I5 U3 i2 D3 W
        11. #修复数据库
  1.           db.repairDatabase()
复制代码
' {3 A; f: W% n* A! x' a, Q# y
        12. #设置记录profiling,0=off 1=slow 2=all
  1.           db.setProfilingLevel(1)
复制代码
5 b( O3 q. o' p; H
        13. #查看profiling
  1.           show profile
复制代码
7 {3 v: _5 E, n, f8 [8 V- a
        14. #拷贝数据库
  1.           db.copyDatabase('mail_addr','mail_addr_tmp')
复制代码

# M1 K) D: C% @- l9 i3 _5 n
        15. #删除collection
  1.           db.mail_addr.drop()
复制代码
$ W- @, Y& k# K
        16. #删除当前的数据库
  1.           db.dropDatabase()
复制代码
, U4 H& G1 J  H
   2. 增删改
         1. #存储嵌套的对象
  1.              db.foo.save({'name':'ysz','address':{'city':'beijing','post':100096},'phone':[138,139]})
复制代码
# k& C  O/ E. l  F$ [. G
         2. #存储数组对象
  1.              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条件修改,如果不存在则插入,允许修改多条记录
  1.             db.foo.update({'yy':5},{'$set':{'xx':2}},upsert=true,multi=true)
复制代码

3 [8 d8 s9 H% h" k  B5 i
         4. #删除yy=5的记录
  1.             db.foo.remove({'yy':5})
复制代码
0 ?9 ^( d. g% {5 s$ C" ?4 u& D& I
         5. #删除所有的记录
  1.             db.foo.remove()
复制代码

( F0 m' k  O6 M$ A) F' E
   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& d
6.  高级查询
条件操作符 ' S- ?7 s1 [8 r2 c) l$ ?, n
  1. $gt : > $ ]8 A1 O1 i8 Q# G% `4 }/ o, _: Q6 {
  2. $lt : <
    & {* f% \" f; i- F1 i0 r
  3. $gte: >= 6 \5 H4 {; x- I2 w
  4. $lte: <= 3 K3 C) }8 S# O; O+ P$ U+ w, o1 e
  5. $ne : !=、<> $ ~  s' |: b3 R% a1 c
  6. $in : in
    # d* M6 s# U* K4 E& [
  7. $nin: not in & [/ H; t, Y- S0 \$ ]& S
  8. $all: all * i1 U  ~1 t0 o1 i9 \1 ^# s" G9 c7 F
  9. $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
  1. 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
  1. 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 |
  1. 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
  1. db.users.find('this.age % 10 == 0');
复制代码
2 w& i& K. y. j6 C6 E
或者 ' t& E9 I9 t$ G2 _/ S
  1. 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
  1. 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
  1. db.users.find({name: {$not: /^B.*/}});
复制代码

+ b! L. [* d" B" a# ]查询 age取模10不等于0 的数据 - M! U" K1 n1 e' `, I9 o
  1. 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
  1. db.users.find({}, {age:1});
    2 C) ]  R/ B: H( ~- P' h' X( \
  2. db.users.find({}, {age:3});
    4 C' L) K; s) _/ Z, u
  3. db.users.find({}, {age:true}); ! J9 |3 y$ R! @7 C8 h/ R
  4. 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
  1. 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( \
  1. db.users.find({}, {age:0, address:false}); " U6 p" c8 L/ @" T$ O
  2. 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
  1. db.users.find({name: {$exists: true}});
复制代码
! @+ L& q. G9 d) Q. O4 `
查询所有不存在phone字段的记录 $ w4 b4 j  j, m8 U
  1. 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
  1. 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
  1. 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
  1. 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
  1. db.users.find({age: {$gt: 18}});
    4 p: I. N# w! m
  2. db.users.find({$where: "this.age > 18"});
    # q7 T- h! E. c+ D- h
  3. db.users.find("this.age > 18"); * T- I: }) O0 ~4 ^( o
  4. 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
  1. 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
  1. 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
  1. 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
  1. 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+ \/ ]
  1. my age is 18 / A' Y7 Z" e9 n" L/ }1 }
  2. my age is 19
    - E2 F2 `' X& V2 i
  3. 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
  1. 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" ]
  1. 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
  1. { domain: "www.mongodb.org"
    , z# `4 r1 n+ P& s  _. ^
  2. , invoked_at: {d:"2009-11-03", t:"17:14:05"} ( k4 D9 }/ c3 W7 T1 ~3 L7 D
  3. , response_time: 0.05 9 u/ i: o2 {+ _* H" u
  4. , http_action: "GET /display/DOCS/Aggregation"
    7 I6 H4 e" _6 o* u9 R9 s! Z$ t
  5. }
复制代码
+ 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
  1. db.test.group( % w: @0 f+ h* T9 B& l5 _
  2. { cond: {"invoked_at.d": {$gt: "2009-11", $lt: "2009-12"}}
    + K0 N4 d$ Y* l: G6 i
  3. , key: {http_action: true}
    , ~0 G9 i9 ^5 x, f; `4 P
  4. , initial: {count: 0, total_time:0}
    ) ?" I  z% r* U( J7 X, p/ D7 p; t
  5. , reduce: function(doc, out){ out.count++; out.total_time+=doc.response_time }
    ' q4 g* T* |! p! \) P$ C. d7 ~  ^
  6. , finalize: function(out){ out.avg_time = out.total_time / out.count } + i1 Z* W% N( Z; g
  7. } );
    - A0 H/ j9 T7 s6 }9 Q! g

  8. : D1 W5 `, N# y9 `: L
  9. [
      @! u, b/ h& d" y
  10. { # Q* h! Q& z+ F7 q# V6 m! z
  11. "http_action" : "GET /display/DOCS/Aggregation",
      y% y. f9 @: M7 n( x- X6 D
  12. "count" : 1,
    6 `! {4 g. Q" @6 ?
  13. "total_time" : 0.05, $ Z6 {: d- y6 Q( f3 m2 {
  14. "avg_time" : 0.05 - y/ R( \1 X! F2 }  J
  15. }
    + _2 Q3 Q0 L  ^
  16. ]
复制代码

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]实现这个。
要查询最大值我们只需要把结果集按照降序排列,取第一个值就是了。
如我的例子,我想取得集合中年龄最大的人。
  1. 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他也是可行的。
如上面的表结构,我想统计所有的喜欢的水果。
  1. db.person.distinct("fruits.fruitId") // 查找对象里引入对象的值,直接加.
复制代码
# ]/ x+ o8 s4 s( `
% w+ u1 e3 I! K+ F" E, H6 i. \
他成功执行了。输出如:
  1. [ "aaa", "bbb", "ccc", "www", "xxx", "yyy", "zzz", "rrr" ]
复制代码

6 r5 l2 x7 X* J2 i; H8 m3 ]" \6 F  `. J7 A% @5 E; w
我想统计集合中共有多少个人[按名字吧]
  1. db.person.distinct("manName")
复制代码

; p1 O/ `% y6 B9 ^
" N$ d7 @" w9 @, `) s* t
我想统计指定个数的人的共同关注的朋友。
  1. db.person.distinct("myFriends", {"manName" : {"$in" : ["ZhenQin", "YangYan"]}})
复制代码

" r: `3 \; S4 X3 u7 s, K
* Y) s" ?  ~; _
输出如:
  1.         
    * F: _' ?; E% {0 V
  2. [ "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:
  1. <beans xmlns="http://www.springframework.org/schema/beans"" C" c8 ]1 S  q5 v0 X
  2.        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    % }) x: {( v+ X
  3.        xmlns:context="http://www.springframework.org/schema/context"
    / \; ?& v" y% b2 s3 L2 U
  4.        xmlns:mongo="http://www.springframework.org/schema/data/mongo"
    3 B/ y# z( h9 z  J; o
  5.        xsi:schemaLocation="http://www.springframework.org/schema/beans7 W, a; H& Z/ F/ Q: Q
  6.           http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
    $ F2 Z/ V, V% }# Q* O3 y* M
  7.           http://www.springframework.org/schema/context; Y' [7 |5 U; \$ m: a% b( x
  8.           http://www.springframework.org/schema/context/spring-context-3.1.xsd
    ) Q+ B3 Q7 m# x! m  f
  9.           http://www.springframework.org/schema/data/mongo
    3 {# ]/ X$ p. a3 m7 g
  10.           http://www.springframework.org/schema/data/mongo/spring-mongo-1.0.xsd">5 F" S6 f# w2 P
  11. 7 Q+ `9 z& y4 ^
  12.     <context:property-placeholder location="classpath:mongo.properties" />( K8 ]* \& h. q0 ?

  13. 5 d6 O2 U" m. r4 C
  14.     <!-- Default bean name is 'mongo' -->6 D4 t2 |4 u% c, V+ @/ N) U  `
  15.     <mongo:mongo id="mongo" host="${mongo.host}" port="${mongo.port}" />
    6 ]" k7 H% a+ R0 i: n! y9 C9 E
  16. 6 |( B  B+ k7 ]3 L5 ]+ ]9 X- x
  17.     <mongo:db-factory id="mongoDbFactory"6 ]& _" p. I" V- o( S( h0 z6 _
  18.                   mongo-ref="mongo"  P! ~/ {9 }( D) [$ k5 T( n+ z2 ?1 ^$ c3 Z
  19.                   dbname="mongotest" />
    + L% @& ~! @9 W3 d
  20. ! I; q, I2 X- V6 B2 ]
  21.     <bean id="mongoTemplate" class="org.springframework.data.mongodb.core.MongoTemplate">3 d: e5 x5 L6 z5 `4 W6 L( k9 j$ W
  22.         <constructor-arg name="mongoDbFactory" ref="mongoDbFactory"/>
    $ e' m. D5 M+ ^6 A( X! q
  23.     </bean>
    4 i, T" t1 N: J3 X2 c
  24. </beans>
复制代码
5 d, S  y' b7 G# O9 }+ }( T
/ }. c. m6 `/ m( o! y: E. O: m
maxmin的测试
  1. @Test* K- b3 j4 y# P# I
  2.     public void testMaxAndMinAge() throws Exception {
    9 n" M& x; H+ j9 w" {
  3.         Query q = new BasicQuery("{}").with(new Sort(new Sort.Order(Sort.Direction.ASC, "age"))).limit(1);
    , @0 r& o) _- c6 m  M
  4.         Person result = mongoTemplate.findOne(q, Person.class);
    # i  l" f* q  X" P1 i% I4 [* E
  5.         log.info(result);) a+ q/ T- r" ^/ P

  6. ! ^% z( F6 O6 b" m* P& b6 V
  7.         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
  8.         result = mongoTemplate.findOne(q, Person.class);
    ! O4 d( m7 M' Y  H1 l9 {
  9.         log.info(result);
    ; h" W4 ]- d8 x4 ~& X5 `. u7 q
  10.     }
复制代码
4 `" g! o+ o, `, S

/ o6 |& S: g* F( Y# W0 m
distinct的测试:
  1. @Test
    : ?8 Z/ \* u* W% y( ^3 t2 }
  2.     public void testDistinct() throws Exception {" X! b* @# m5 ^9 ?0 `7 l
  3.         List result = mongoTemplate.getCollection("person").distinct("myFriends");: p6 [2 V6 {8 Z% t
  4.         for (Object o : result) {
      J4 s. y! B* g% v" s( A
  5.             log.info(o);
    $ C1 W9 t2 j) Y, n2 G/ R+ X3 e
  6.         }0 x/ h) E: Q2 Z+ x- ~

  7. 3 L8 A) q; }& J1 Q9 G7 ^) g% e- d
  8.         log.info("==================================================================");
    5 ?- P. J% }" N! @4 A) M1 q
  9.         Query query = Query.query(Criteria.where("manId").is("123456"));7 t! ?5 U( `! W6 Q5 P; _, @. P
  10.         result = mongoTemplate.getCollection("person").distinct("myFriends", query.getQueryObject());! x% _0 i0 A2 v  b; O; F9 W! A
  11.         for (Object o : result) {3 v. b/ M; }  m8 f! Q
  12.             log.info(o);
    - G& T$ v! K" ?6 Q2 L% T& _. K; @
  13.         }. F3 g4 A3 }8 U, }% X; f6 C

  14.   H6 b! Y7 [& |6 G4 Y
  15.         log.info("==================================================================");6 E1 Z# c4 W( H8 R
  16.         result = mongoTemplate.getCollection("person").distinct("fruits.fruitId");0 O! H9 W3 g8 A& e7 ~8 z0 W$ |
  17.         for (Object o : result) {
    ; \3 L- X9 K: r3 o6 T9 ~
  18.             log.info(o);( {2 E4 I0 E- K2 u$ D
  19.         }) z* M: g! M+ B% k' E, C
  20.     }
复制代码

8 g4 j& d. M; M) {2 f8 C+ j1 h* @2 n/ p( i0 n2 D
输出的结果为:
  1. 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(72)] 234567# d; v9 x0 N8 ]) z8 N; x6 ?
  2. 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(72)] 345678) c8 v8 C% f# s2 d7 B" A
  3. 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(72)] 456789; S( X' N: f( M
  4. 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(72)] 987654! Y! [* i' ~9 E3 e4 a- u
  5. 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(72)] ni. r( b1 A& [5 H) e2 |; T7 Q0 K: b
  6. 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(72)] wo4 ]7 q# W% {6 S9 I! O' M
  7. 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(72)] 123456
    ! l& l9 D4 k, z& `4 O$ Z" G
  8. 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(75)] ==================================================================$ B- n1 F# r) r1 }/ I* Y4 m; S
  9. 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(79)] 2345671 }  r9 ]; X7 ?  M$ b
  10. 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(79)] 345678
    6 P8 V. o4 F9 r' k5 N9 R
  11. 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(79)] 456789& s( s$ j& f( S) u. V3 C9 u
  12. 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(79)] 987654! u: U# a' N+ {* i8 P
  13. 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(82)] ==================================================================
    6 W9 j1 t3 T) n3 u. E
  14. 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(85)] aaa
    9 f7 V( b4 ^- D5 q: ^7 g' _3 O
  15. 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(85)] bbb; M8 m, o( m: r; G4 J( b+ U/ k: v6 d0 u
  16. 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(85)] ccc
    2 M! {3 |, u1 G+ D
  17. 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(85)] www. ~+ }% \. A, y8 D
  18. 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(85)] xxx2 D' R6 e; h, w, w7 O; R  q
  19. 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(85)] yyy
    2 |( `- C7 J8 b" f% V% R
  20. 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(85)] zzz
    / y; i9 Q2 O! T! H/ P
  21. 12-22 14:13:45 [INFO] [t.MongoAdvaceQueryTest(85)] rrr
    + |* ?" G) ~# D/ {0 t" T0 O
  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
复制代码
% 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
分享到:  QQ好友和群QQ好友和群 QQ空间QQ空间 腾讯微博腾讯微博 腾讯朋友腾讯朋友
收藏收藏 分享分享 支持支持 反对反对
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

GMT+8, 2024-5-8 23:34 , Processed in 0.172789 second(s), 24 queries .

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