【MongoDB詳細使用教程】一、Mac安裝MongoDB
【MongoDB詳細使用教程】二、MongoDB基本操作
【MongoDB詳細使用教程】三、高級查詢
【MongoDB詳細使用教程】四、python操作MongoDB
【MongoDB詳細使用教程】五、MongoDB的資料庫管理

1、使用比較運算子查詢
2、使用關鍵字查詢
- 2.1、in/not in 關鍵字
- 2.2、size 關鍵字
- 2.3、exists 關鍵字
- 2.4、or 關鍵字
3、模糊查詢
4、查詢結果排序
5、限定回傳結果數量
6、查詢回傳結果數量
7、聚合函式aggregate()
- 7.1、語法
- 7.2、常用管道
- 7.3、常用聚合函式
- 7.4、實體
  - $group
  - $match
  - $unwind
  - 管道組合應用
8、創建索引

1、使用比較運算子查詢

MongoDB	運算
$gt	大于
$lt	小于
$gte	大于等于
$lte	小于等于歐
$ne	不等于

db.集合名.find({"鍵名": {比較運算子1:值1, 比較運算子2:值2} })

> db.students.find()
{ "_id" : ObjectId("5db642b30f98841018f76965"), "name" : "chen", "age" : 18, "grade" : "一年級" }
{ "_id" : ObjectId("5db642bc0f98841018f76966"), "name" : "wang", "age" : 19, "grade" : "二年級" }
{ "_id" : ObjectId("5db653920f98841018f7696b"), "name" : "xu", "age" : 20, "grade" : "三年級" }
{ "_id" : ObjectId("5db654660f98841018f7696c"), "name" : "ma", "age" : 20, "grade" : "二年級" }

> db.students.find({"age": {$lt:19}})
{ "_id" : ObjectId("5db642b30f98841018f76965"), "name" : "chen", "age" : 18, "grade" : "一年級" }

> db.students.find({"age": {$gte:18,$lt:20}})
{ "_id" : ObjectId("5db642b30f98841018f76965"), "name" : "chen", "age" : 18, "grade" : "一年級" }
{ "_id" : ObjectId("5db642bc0f98841018f76966"), "name" : "wang", "age" : 19, "grade" : "二年級" }

2、使用關鍵字查詢

2.1、in/not in 關鍵字

db.集合名.find({"鍵名": {$in:[值1, 值2, 值3 ...]} })

db.集合名.find({"鍵名": {$nin:[值1, 值2, 值3 ...]} })

> db.students.find({"age":{$in:[19,18,17]}})
{ "_id" : ObjectId("5db642b30f98841018f76965"), "name" : "chen", "age" : 18, "grade" : "一年級" }
{ "_id" : ObjectId("5db642bc0f98841018f76966"), "name" : "wang", "age" : 19, "grade" : "二年級" }

> db.students.find({"age":{$nin:[19,18,17]}})
{ "_id" : ObjectId("5db653920f98841018f7696b"), "name" : "xu", "age" : 20, "grade" : "三年級" }
{ "_id" : ObjectId("5db654660f98841018f7696c"), "name" : "ma", "age" : 20, "grade" : "二年級" }

2.2、size 關鍵字

對于值為list的欄位，可以對list的長度(即list當中值的個數)進行判斷來查詢，

db.集合名.find({"鍵名": {$size:n} })

> db.students.find()
{ "_id" : ObjectId("5db642b30f98841018f76965"), "name" : "chen", "age" : 18, "grade" : "一年級" }
{ "_id" : ObjectId("5db642bc0f98841018f76966"), "name" : "wang", "age" : 19, "grade" : "二年級" }
{ "_id" : ObjectId("5db653920f98841018f7696b"), "name" : "xu", "age" : 20, "grade" : "三年級", "text" : [ "女", "研究員" ] }
{ "_id" : ObjectId("5db654660f98841018f7696c"), "name" : "ma", "age" : 20, "grade" : "二年級", "text" : [ "女", "副教授", "副處長" ] }

# 查找text欄位長度為3的資料
> db.students.find({"text":{$size:3}})
{ "_id" : ObjectId("5db654660f98841018f7696c"), "name" : "ma", "age" : 20, "grade" : "二年級", "text" : [ "女", "副教授", "副處長" ] }

2.3、exists 關鍵字

查詢包含/不包含某個欄位的資料

db.集合名.find({"鍵名": {$exist: true|fase} })   # t、f要小寫

> db.students.find()
{ "_id" : ObjectId("5db642b30f98841018f76965"), "name" : "chen", "age" : 18, "grade" : "一年級" }
{ "_id" : ObjectId("5db642bc0f98841018f76966"), "name" : "wang", "age" : 19, "grade" : "二年級" }
{ "_id" : ObjectId("5db653920f98841018f7696b"), "name" : "xu", "age" : 20, "grade" : "三年級", "text" : [ "女", "研究員" ] }
{ "_id" : ObjectId("5db654660f98841018f7696c"), "name" : "ma", "age" : 20, "grade" : "二年級", "text" : [ "女", "副教授", "副處長" ] }

# 查詢包含text欄位的資料
> db.students.find({"text":{$exists:true}})
{ "_id" : ObjectId("5db653920f98841018f7696b"), "name" : "xu", "age" : 20, "grade" : "三年級", "text" : [ "女", "研究員" ] }
{ "_id" : ObjectId("5db654660f98841018f7696c"), "name" : "ma", "age" : 20, "grade" : "二年級", "text" : [ "女", "副教授", "副處長" ] }
# 查詢不含text欄位的資料
> db.students.find({"text":{$exists:false}})
{ "_id" : ObjectId("5db642b30f98841018f76965"), "name" : "chen", "age" : 18, "grade" : "一年級" }
{ "_id" : ObjectId("5db642bc0f98841018f76966"), "name" : "wang", "age" : 19, "grade" : "二年級" }

2.4、or 關鍵字

db.集合名.find({$or:[{條件1}, {條件2}, {條件3}...]})

> db.students.find()
{ "_id" : ObjectId("5db642b30f98841018f76965"), "name" : "chen", "age" : 18, "grade" : "一年級" }
{ "_id" : ObjectId("5db642bc0f98841018f76966"), "name" : "wang", "age" : 19, "grade" : "二年級" }
{ "_id" : ObjectId("5db653920f98841018f7696b"), "name" : "xu", "age" : 20, "grade" : "三年級", "text" : [ "女", "研究員" ] }
{ "_id" : ObjectId("5db654660f98841018f7696c"), "name" : "ma", "age" : 20, "grade" : "二年級", "text" : [ "女", "副教授", "副處長" ] }

# 查詢包含text欄位或者name=chen的資料
> db.students.find({$or:[{"text":{$exists:true}},{"name":"chen"}]})
{ "_id" : ObjectId("5db642b30f98841018f76965"), "name" : "chen", "age" : 18, "grade" : "一年級" }
{ "_id" : ObjectId("5db653920f98841018f7696b"), "name" : "xu", "age" : 20, "grade" : "三年級", "text" : [ "女", "研究員" ] }
{ "_id" : ObjectId("5db654660f98841018f7696c"), "name" : "ma", "age" : 20, "grade" : "二年級", "text" : [ "女", "副教授", "副處長" ] }

3、模糊查詢

db.集合名.find({"鍵名": js正則表達)

> db.students.find()
{ "_id" : ObjectId("5db642b30f98841018f76965"), "name" : "chen", "age" : 18, "grade" : "一年級" }
{ "_id" : ObjectId("5db642bc0f98841018f76966"), "name" : "wang", "age" : 19, "grade" : "二年級" }
{ "_id" : ObjectId("5db653920f98841018f7696b"), "name" : "xu", "age" : 20, "grade" : "三年級", "text" : [ "女", "研究員" ] }
{ "_id" : ObjectId("5db654660f98841018f7696c"), "name" : "ma", "age" : 20, "grade" : "二年級", "text" : [ "女", "副教授", "副處長" ] }
{ "_id" : ObjectId("5db68d190f98841018f76970"), "name" : "cheng", "age" : 21, "grade" : "四年級" }

# 查詢name以che開頭的資料
> db.students.find({"name":/che/})
{ "_id" : ObjectId("5db642b30f98841018f76965"), "name" : "chen", "age" : 18, "grade" : "一年級" }
{ "_id" : ObjectId("5db68d190f98841018f76970"), "name" : "cheng", "age" : 21, "grade" : "四年級" }

4、查詢結果排序

db.集合名.find().sort({"鍵名": 1｜-1, "鍵名": 1｜-1...})

 1 為升序  
-1 為降序

> db.students.find().sort({"name":1, "age":-1})
{ "_id" : ObjectId("5db642b30f98841018f76965"), "name" : "chen", "age" : 18, "grade" : "一年級" }
{ "_id" : ObjectId("5db68f6c0f98841018f76971"), "name" : "cheng", "age" : 22, "grade" : "五年級" }
{ "_id" : ObjectId("5db68d190f98841018f76970"), "name" : "cheng", "age" : 21, "grade" : "四年級" }
{ "_id" : ObjectId("5db654660f98841018f7696c"), "name" : "ma", "age" : 20, "grade" : "二年級", "text" : [ "女", "副教授", "副處長" ] }
{ "_id" : ObjectId("5db642bc0f98841018f76966"), "name" : "wang", "age" : 19, "grade" : "二年級" }
{ "_id" : ObjectId("5db653920f98841018f7696b"), "name" : "xu", "age" : 20, "grade" : "三年級", "text" : [ "女", "研究員" ] }

5、限定回傳結果數量

db.集合名.find().limit(n)

db.集合名.find().skip(n)  # 跳過n條，回傳從n+1k開始的資料

db.集合名.find().skip(n).limit(m)  # 跳過n條，回傳后面的m條

.limit() 與 .sort()無先后順序

# 按age正序排列，并回傳前兩行資料
> db.students.find().limit(2).sort({"age":1})
{ "_id" : ObjectId("5db642b30f98841018f76965"), "name" : "chen", "age" : 18, "grade" : "一年級" }
{ "_id" : ObjectId("5db642bc0f98841018f76966"), "name" : "wang", "age" : 19, "grade" : "二年級" }
> db.students.find().sort({"age":1}).limit(2)
{ "_id" : ObjectId("5db642b30f98841018f76965"), "name" : "chen", "age" : 18, "grade" : "一年級" }
{ "_id" : ObjectId("5db642bc0f98841018f76966"), "name" : "wang", "age" : 19, "grade" : "二年級" }

# 查詢age第二小和第三小的資料
> db.students.find().skip(1).limit(2).sort({"age":1})
{ "_id" : ObjectId("5db642bc0f98841018f76966"), "name" : "wang", "age" : 19, "grade" : "二年級" }
{ "_id" : ObjectId("5db653920f98841018f7696b"), "name" : "xu", "age" : 20, "grade" : "三年級", "text" : [ "女", "研究員" ] }

6、查詢回傳結果數量

db.集合名.find().count()

db.集合名.find().skip(n).count(true)  # 與skip結合使用時，要加true

> db.students.find({"name":"cheng"}).count()
2

> db.students.find().count()
6

# 不加true就會統計全部資料條目
> db.students.find().skip(2).count()    
6
> db.students.find().skip(2).count(true)
4

7、聚合函式aggregate()

7.1、語法

db.集合名.aggregate([
                    { 管道1: {運算式1} },
                    { 管道1: {運算式1} },
                    { 管道1: {運算式1} },
                    ...
                    ])
                
                # 如果只有一個管道則去掉"[]"

在aggregate()函式中，資料會依次通過每個管道進行篩選過濾，因此稱其為管道，

7.2、常用管道

管道	說明
$group	將集合中的檔案分組，可用于統計結果
$match	過濾資料，只輸出符合條件的檔案
$project	修改輸入檔案的結構，如重命名、增加、洗掉欄位、創建計算結果
$sort	將輸入檔案排序后輸出
$limit	限制聚合管道回傳的檔案數
$skip	跳過指定數量的檔案，并回傳余下的檔案
$unwind	將陣列型別的欄位進行拆分

7.3、常用聚合函式

只能在$group管道中使用，

分組函式	說明
$sum	計算總和，$sum:1同count表示計數
$avg	計算平均值
$min	獲取最小值
$max	獲取最大值
$push	在結果檔案中插入值到一個陣列中，相當于拼接欄位
$first	根據資源檔案的排序獲取第一個檔案資料
$last	根據資源檔案的排序獲取最后一個檔案資料

7.4、實體

$group

db.集合名.aggregate(
    {$group:
        {
        _id:'$欄位名', 別名:{$聚合函式:'$欄位名'}
        }
    }

根據_id后的欄位名進行分組，對聚合函式后的欄位名進行聚合運算，

如果分組后，要對全部資料進行聚合運算，則 $聚合函式:1，相當于sql中的 count(1)

# 統計男女生人數
db.singer.aggregate(
    {$group:
        {
            _id:'$sex',
            count_sex:{$sum:1}
        }
    }
);
___________________________________
{ "_id" : "女", "count_sex" : 4 }
{ "_id" : "男", "count_sex" : 11 }

$sum:1 的作用是統計數量
$sum:'$欄位名' 則是欄位值進行累加

因為聚合函式只能在group管道中使用，如果要對全部資料進行聚合運算（即不分組），則 _id:null .

# 統計所有人平均年齡
db.singer.aggregate(
    {$group:
        {
            _id:null,
            總人數:{$sum:1},
            avg_age:{$avg:"$age"},
            min_age:{$min:"$age"},
            max_age:{$max:"$age"}
        }
    }
);
_______________________________________________________
{ "_id" : null, "總人數" : 15, "avg_age" : 42.666666666666664, "min_age" : 29, "max_age" : 55 }

這里直接使用中文進行重命名

用$push輸出分組后的全部值

# 統計男女生人數及男女生名單
db.singer.aggregate(
    {$group:
        {
            _id:"$sex",
            人數:{$sum:1},
            名單:{$push:"$name"}
        }
    }
);
________________________________________________________________________________
{ "_id" : "女", "人數" : 4, "名單" : [ "李宇春", "趙麗穎", "黃齡", "王菲" ] }
{ "_id" : "男", "人數" : 11, "名單" : [ "劉德華", "張學友", "黎明", "郭富城", "薛之謙", "周杰倫", "PSY", "杰克遜", "楊坤", "煉訓", "林志炫" ] }

++$push:"$欄位名"++ 相當于mysql中的 ++group_concat(欄位名)++ 和 oracle中的 ++wmsys.wm_concat(欄位名)++

$match

db.集合名.aggregate(
    {$match:{"鍵名":{運算式}}},
);

# 查找age大于40的資料
db.singer.aggregate(
    {$match:
        {"age":{$gt:40}}
    }
);

$unwind

db.集合名.aggregate(
    {$unwind:"鍵名"}
);

$unwind會將值為陣列（串列）的欄位進行拆分，陣列中的每個值都與該行資料的其他欄位組成一行新的資料，

> db.singer.find({"name":"劉德華"})
————————————————————————————————
{ "_id" : ObjectId("5db78dcb25fcb93e108d6dcb"), "num" : "1", "name" : "劉德華", "country" : "中國", "sex" : "男", "age" : 55, "score" : 100, "works" : [ "愛你一萬年", "忘情水", "來生緣", "我不夠愛你" ], "description" : "1961年9月27日出生于中國香港，演員、歌手、作詞人、制片人，影視歌多棲發展的代表藝人之一，" }


# 將劉德華的works欄位拆分
db.singer.aggregate([
    {$match:{"name":"劉德華"}},
    {$unwind:"$works"}
]);
——————————————————————————————
{ "_id" : ObjectId("5db78dcb25fcb93e108d6dcb"), "num" : "1", "name" : "劉德華", "country" : "中國", "sex" : "男", "age" : 55, "score" : 100, "works" : "愛你一萬年", "description" : "1961年9月27日出生于中國香港，演員、歌手、作詞人、制片人，影視歌多棲發展的代表藝人之一，" }
{ "_id" : ObjectId("5db78dcb25fcb93e108d6dcb"), "num" : "1", "name" : "劉德華", "country" : "中國", "sex" : "男", "age" : 55, "score" : 100, "works" : "忘情水", "description" : "1961年9月27日出生于中國香港，演員、歌手、作詞人、制片人，影視歌多棲發展的代表藝人之一，" }
{ "_id" : ObjectId("5db78dcb25fcb93e108d6dcb"), "num" : "1", "name" : "劉德華", "country" : "中國", "sex" : "男", "age" : 55, "score" : 100, "works" : "來生緣", "description" : "1961年9月27日出生于中國香港，演員、歌手、作詞人、制片人，影視歌多棲發展的代表藝人之一，" }
{ "_id" : ObjectId("5db78dcb25fcb93e108d6dcb"), "num" : "1", "name" : "劉德華", "country" : "中國", "sex" : "男", "age" : 55, "score" : 100, "works" : "我不夠愛你", "description" : "1961年9月27日出生于中國香港，演員、歌手、作詞人、制片人，影視歌多棲發展的代表藝人之一，" }

管道組合應用

# 查詢年齡大于30的男女生人數
db.singer.aggregate([
    {$match:{"age":{$gt:30}}},
    {$group:{_id:"$sex",人數:{$sum:1}}}
]);
————————————————————————————————
{ "_id" : "女", "人數" : 2 }
{ "_id" : "男", "人數" : 11 }

# 查詢年齡在30歲以上，年齡第二小和第三小的人
db.singer.aggregate([
    {$match:{"age":{$gt:30}}},
    {$project:{_id:0,name:1,age:1}},
    {$sort:{"age":1}},
    {$skip:1},
    {$limit:2}
]);
——————————————————————
{ "name" : "薛之謙", "age" : 33 }
{ "name" : "周杰倫", "age" : 37 }

$project用來設定哪些欄位顯示，哪些不顯示，并可以設定欄位顯示順序，1為顯示，0為不顯示，
這里要注意，在$project后面_id欄位默認顯示，其他欄位默認不顯示，

8、創建索引

db.集合名.ensureIndex({"鍵名1":1|-1, "鍵名2":1|-1})

> db.students.ensureIndex({"name":1})
{
	"createdCollectionAutomatically" : false,
	"numIndexesBefore" : 1,
	"numIndexesAfter" : 2,
	"ok" : 1
}

轉載請註明出處，本文鏈接：https://www.uj5u.com/shujuku/46504.html

標籤：大數據

上一篇：阿里蔣曉偉談計算引擎Flink和Spark的對比

下一篇：HBase常用的JAVA API操作