知識點:
美化輸出:
db.stu.find().pretty()
$project:修改輸入文檔的結(jié)構(gòu)≌眨可以用來重命名劫映、增加或刪除域,也可以用于創(chuàng)建計算結(jié)果以及嵌套文檔府蛇。
$match:用于過濾數(shù)據(jù)集索,只輸出符合條件的文檔。$match使用MongoDB的標(biāo)準(zhǔn)查詢操作汇跨。
$limit:用來限制MongoDB聚合管道返回的文檔數(shù)务荆。
$skip:在聚合管道中跳過指定數(shù)量的文檔,并返回余下的文檔穷遂。
$unwind:將文檔中的某一個數(shù)組類型字段拆分成多條函匕,每條包含數(shù)組中的一個值。
$group:將集合中的文檔分組蚪黑,可用于統(tǒng)計結(jié)果盅惜。
$sort:將輸入文檔排序后輸出中剩。
$geoNear:輸出接近某一地理位置的有序文檔。
安裝mongodb:
sudo apt-get install mongodb
配置文件:
/etc/mongodb.conf
查看版本號:
mongo -version
啟動:
service mongodb start
關(guān)閉:
service mongodb stop
配置文件啟動mongdb:
sudo mongod --config /etc/mastermongodb.conf
sudo mongod -f /etc/mastermongodb.conf (簡寫)
通常這種方法啟動是阻塞終端的,可以通過更改配置文件來讓其后臺啟動:
vi /etc/mongodb.conf
加上 fork=true
允許創(chuàng)建子線程,也就是在后臺子線程運行
有開啟就有關(guān)閉抒寂,上面方法會永久開啟mongodb结啼,那么如何關(guān)閉其運行呢?
1屈芜、普通命令
use admin
db.shutdownServer()
2郊愧、如果沒有up-to-date 從Mongodb且你想強制關(guān)閉服務(wù),可以通過添加force:true;命令如下
db.shutdownServer({force : true})
3井佑、指定特定超時時間的關(guān)閉服務(wù)器属铁,命令同上,另外加上一個timeoutsec:參數(shù)
db.shutdownServer({force : true, timeoutsec : 5})
啟動客戶端:
mongo -port 27018
默認(rèn)設(shè)置MongoDB是隨Ubuntu啟動自動啟動的躬翁。
輸入以下命令查看是否啟動成功:
pgrep mongo -l #注意:-l是英文字母l焦蘑,不是阿拉伯?dāng)?shù)字1
卸載MongoDB
sudo apt-get --purge remove mongodb mongodb-clients mongodb-server
打開mongodb客戶端:
mongo
常用操作命令:
db 查看當(dāng)前所用數(shù)據(jù)庫
show dbs:顯示數(shù)據(jù)庫列表
show collections:顯示當(dāng)前數(shù)據(jù)庫中的集合(類似關(guān)系數(shù)據(jù)庫中的表table)
show users:顯示所有用戶
db.dropDatabase() 刪除當(dāng)前所用數(shù)據(jù)庫 D要大寫
db.createCollection('test') 創(chuàng)建一個集合(相當(dāng)于表) C要大寫
use yourDB:切換當(dāng)前數(shù)據(jù)庫至yourDB
db.help() :顯示數(shù)據(jù)庫操作命令
db.yourCollection.help() :顯示集合操作命令,yourCollection是集合名
注:
MongoDB沒有創(chuàng)建數(shù)據(jù)庫的命令盒发,如果你想創(chuàng)建一個“School”的數(shù)據(jù)庫例嘱,先運行use School命令,之后做一些操作(如:創(chuàng)建聚集集合db.createCollection('teacher')),這樣就可以創(chuàng)建一個名叫“School”的數(shù)據(jù)庫
舉例:
切換到school數(shù)據(jù)庫(如果沒有他自己會創(chuàng)建并且切換到school):
use school
創(chuàng)建collection(相當(dāng)于關(guān)系數(shù)據(jù)庫中的表)
db.createCollection('teacher')
插入數(shù)據(jù)有兩種方式:insert和save迹辐。
db.student.insert({_id:1, sname: 'zhangsan', sage: 20}) #_id可選
db.student.save({_id:1, sname: 'zhangsan', sage: 22}) #_id可選
這兩種方式蝶防,其插入的數(shù)據(jù)中_id字段均可不寫,會自動生成一個唯一的_id來標(biāo)識本條數(shù)據(jù)明吩。而insert和save不同之處在于:在手動插入_id字段時间学,如果_id已經(jīng)存在,insert不做操作印荔,save做更新操作低葫;如果不加_id字段,兩者作用相同都是插入數(shù)據(jù)
注:
插入數(shù)據(jù)時 鍵可以不用加引號,但是值必須根據(jù)數(shù)據(jù)類型適當(dāng)加引號!
添加的數(shù)據(jù)其結(jié)構(gòu)是松散的仍律,只要是bson格式均可嘿悬,列屬性均不固定,根據(jù)添加的數(shù)據(jù)為準(zhǔn)水泉。先定義數(shù)據(jù)再插入善涨,就可以一次性插入多條數(shù)據(jù)
s = [{sname:'zhaoliu',_id:1,sage:12},{_id:2,sname:'daqiao',sage:13}]
db.stu.insert(s) #stu為collection的名字
查找數(shù)據(jù):
db.student.find() #查詢所有記錄。相當(dāng)于:select * from student
db.student.find({sname: 'lisi'}) #查詢sname='lisi'的記錄草则。相當(dāng)于: select * from student where sname='lisi'
db.student.find({},{sname:1, sage:1}) #查詢指定列sname钢拧、sage數(shù)據(jù)。相當(dāng)于:select sname,sage from student炕横。sname:1表示返回sname列源内,默認(rèn)_id字段也是返回的,可以添加_id:0(意為不返回_id)寫成{sname: 1, sage: 1,_id:0}份殿,就不會返回默認(rèn)的_id字段了
db.student.find({sname: 'zhangsan', sage: 22}) #and 與條件查詢膜钓。相當(dāng)于:select * from student where sname = 'zhangsan' and sage = 22
db.student.find({$or: [{sage: 22}, {sage: 25}]}) #or 條件查詢嗽交。相當(dāng)于:select * from student where sage = 22 or sage = 25
更新數(shù)據(jù):
db.youCollection.update(criteria, objNew, upsert, multi )
criteria: update的查詢條件,類似sql update查詢內(nèi)where后面的
objNew : update的對象和一些更新的操作符(如$set)等颂斜,也可以理解為sql update查詢內(nèi)set后面的夫壁。
upsert : 如果不存在update的記錄,是否插入objNew焚鲜,true為插入掌唾,默認(rèn)是false放前,不插入忿磅。
multi: mongodb默認(rèn)是false,只更新找到的第一條記錄,如果這個參數(shù)為true,就把按條件查出來多條記錄全部更新凭语。默認(rèn)false葱她,只修改匹配到的第一條數(shù)據(jù)。
其中criteria和objNew是必選參數(shù)似扔,upsert和multi可選參數(shù)
例如:
db.stu.find()
{ "_id" : ObjectId("5aa4e02f8bc6ad195143a5f7"), "sname" : "lisi", "sage" : 12 }
{ "_id" : ObjectId("5aa4e02f8bc6ad195143a5f8"), "sname" : "wangwu", "sage" : 13 }
{ "_id" : 1, "sname" : "zhaoliu", "sage" : 12 }
{ "_id" : 2, "sname" : "daqiao", "sage" : 13 }
db.stu.update({sname:'lisi'},{$set:{sage:30}},false,true) 第三個參數(shù)為false 若查找不存在不用添加
WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 })
db.stu.find()
{ "_id" : ObjectId("5aa4e02f8bc6ad195143a5f7"), "sname" : "lisi", "sage" : 30 }
{ "_id" : ObjectId("5aa4e02f8bc6ad195143a5f8"), "sname" : "wangwu", "sage" : 13 }
{ "_id" : 1, "sname" : "zhaoliu", "sage" : 12 }
{ "_id" : 2, "sname" : "daqiao", "sage" : 13 }
db.stu.update({sname:'lisii'},{$set:{sage:30}},true,true) 第三個參數(shù)為true,若不存在需要添加此新項
db.stu.find()
{ "_id" : ObjectId("5aa4e02f8bc6ad195143a5f7"), "sname" : "lisi", "sage" : 30 }
{ "_id" : ObjectId("5aa4e02f8bc6ad195143a5f8"), "sname" : "wangwu", "sage" : 13 }
{ "_id" : 1, "sname" : "zhaoliu", "sage" : 12 }
{ "_id" : 2, "sname" : "daqiao", "sage" : 13 }
{ "_id" : ObjectId("5aa4e3d5b2fc99b176fbf052"), "sname" : "lisii", "sage" : 30 }
刪除操作:
刪除數(shù)據(jù):
db.student.remove({sname: 'chenliu'}) #相當(dāng)于:delete from student where sname='chenliu'
注:
把符合條件的全部刪除
刪除當(dāng)前數(shù)據(jù)庫:
db.dropDatabase()
注:
- 先use到要刪除的數(shù)據(jù)庫
- 在執(zhí)行db.dropDatabase()
刪除集合:
db.collection_name.drop()
例如:
db.student.drop() 刪除student集合
聚合:
語法:
db.collection_name.aggregate(aggregate_operation)
db.mycol.aggregate([{$group : {_id : "$by_user", total : {$sum : 1}}}])
解:
_id:"$by_user"
根據(jù)by_user這個字段得值分組 $不能忘
total : {$sum : 1}
計算每個分組的數(shù)量 1表示數(shù)量的一倍也就是原數(shù)量,若為2就是每組的數(shù)量是原來的兩倍 $不能忘
$sum 計算總和吨些。 db.mycol.aggregate([{$group : {_id : "$by_user", num_tutorial : {$sum : "$likes"}}}])
將集合中所有文檔分為一組:
db.stu.aggregate({$group:{_id:null,count:{'$sum':1},avgAge:{'$avg':'$age'}}})
$avg 計算平均值 db.mycol.aggregate([{$group : {_id : "$by_user", num_tutorial : {$avg : "$likes"}}}])
$min 獲取集合中所有文檔對應(yīng)值得最小值。 db.mycol.aggregate([{$group : {_id : "$by_user", num_tutorial : {$min : "$likes"}}}])
$max 獲取集合中所有文檔對應(yīng)值得最大值炒辉。 db.mycol.aggregate([{$group : {_id : "$by_user", num_tutorial : {$max : "$likes"}}}])
$push 在結(jié)果文檔中插入值到一個數(shù)組中。 db.mycol.aggregate([{$group : {_id : "$by_user", url : {$push: "$url"}}}])
$addToSet 在結(jié)果文檔中插入值到一個數(shù)組中缝裤,但不創(chuàng)建副本。 db.mycol.aggregate([{$group : {_id : "$by_user", url : {$addToSet : "$url"}}}])
$first 根據(jù)資源文檔的排序獲取第一個文檔數(shù)據(jù)。 db.mycol.aggregate([{$group : {_id : "$by_user", first_url : {$first : "$url"}}}])
$last 根據(jù)資源文檔的排序獲取最后一個文檔數(shù)據(jù) db.mycol.aggregate([{$group : {_id : "$by_user", last_url : {$last : "$url"}}}])
透視數(shù)據(jù):
把分組的數(shù)據(jù)信息放入列表中:
db.stu.aggregate({$group:{_id:'$gender',name:{$push:'$name'}}})
使用$$ROOT可以將內(nèi)容加入到結(jié)果集的數(shù)組中:
db.stu.aggregate({$group:{_id:'$gender',name:{$push:'$$ROOT'}}})
例如:
{ "country" : "china", "province" : "sh", "userid" : "a" }
{ "country" : "china", "province" : "sh", "userid" : "b" }
{ "country" : "china", "province" : "sh", "userid" : "a" }
{ "country" : "china", "province" : "sh", "userid" : "c" }
{ "country" : "china", "province" : "bj", "userid" : "da" }
{ "country" : "china", "province" : "bj", "userid" : "fa" }
需求:統(tǒng)計出每個country/province下的userid的數(shù)量(同一個userid只統(tǒng)計一次)
解答:
db.tv3.aggregate(
{$group:{_id:{'country':'$country','province':'$province','userid':'$userid'}}}, #把所有字段分組就是去重
{$group:{_id:{'country':'$_id.country','province':'$_id.province'},count:{'$sum':1}}}
)
match是管道命令厘擂,能將結(jié)果交給后一個管道获茬,但是find不可以
查詢年齡大于20的所有數(shù)據(jù)
db.stu.aggregate({$match:{age:{'$gt':20}}})
查詢來自桃花島人的數(shù)量
db.stu.aggregate({$match:{hometown:'桃花島'}},
{$group:{_id:null,count:{'$sum':1}}}
)
查詢年齡大于20的男生.女生的人數(shù):
db.stu.aggregate(
{$match:{age:{'$gt':20}}},
{$group:{_id:'$gender',count:{'$sum':1}}}
)
大于:gt
小于:lt
等于:e
大于等于:gte
$project -->:用于修改文檔的結(jié)構(gòu),重命名,增加,刪除字段,創(chuàng)建計算結(jié)構(gòu)
例如:
只需查詢學(xué)生的姓名,年齡
db.stu.aggregate({$project:{_id:0,name:1,age:1}})
注:0表示不顯示 1表示顯示 _id默認(rèn)是顯示的,需要手動關(guān)閉
查詢男女生人數(shù):
db.stu.aggregate(
{$group:{_id:'$gender',count:{'$sum':1}}},
{$project:{_id:0,count:1}}
)
例如:
{ "country" : "china", "province" : "sh", "userid" : "a" }
{ "country" : "china", "province" : "sh", "userid" : "b" }
{ "country" : "china", "province" : "sh", "userid" : "a" }
{ "country" : "china", "province" : "sh", "userid" : "c" }
{ "country" : "china", "province" : "bj", "userid" : "da" }
{ "country" : "china", "province" : "bj", "userid" : "fa" }
需求:統(tǒng)計出每個country/province下的userid的數(shù)量(同一個userid只統(tǒng)計一次)把还,結(jié)果中的字段為{country:"",province:""酌伊,counter:"*"},并且結(jié)果按照counter的倒敘輸出
解答:
db.tv3.aggregate(
{$group:{_id:{country:'$country',province:'$province',userid:'$userid'}}},
{$group:{_id:{'country':'$_id.country',province:'$_id.province'},count:{'$sum':1}}},
{$project:{country:'$_id.country',province:'$_id.province',counter:'$count',_id:0}},
{$sort:{counter:-1}}
)
$limit:
限制聚合管道返回的文檔數(shù)
$skip:
跳過指定文檔數(shù),并返回余下文檔
一般格式:
db.stu.aggregate({$limit:1})
$limit和$skip連用時一般 skip在前,limit在后
需求:統(tǒng)計出每個country/province下的userid的數(shù)量(同一個userid只統(tǒng)計一次)奏候,結(jié)果中的字段為{country:""厚棵,province:"",counter:"*"},并且結(jié)果按照counter的倒敘輸出,結(jié)果文檔跳過一個,輸出一個
db.tv3.aggregate(
{$group:{_id:{country:'$country',province:'$province',userid:'$userid'}}},
{$group:{_id:{'country':'$_id.country',province:'$_id.province'},count:{'$sum':1}}},
{$project:{country:'$_id.country',province:'$_id.province',counter:'$count',_id:0}},
{$sort:{counter:-1}},
{$skip:1},
{$limit:1}
)
$unwind:
將?檔中的某?個數(shù)組類型字段拆分成多條谐区, 每條包含數(shù)組中的?個值
語法:db.集合名稱.aggregate({$unwind:'$字段名稱'})
db.t2.insert({_id:1,item:'t-shirt',size:['S','M','L']})
db.t2.aggregate({$unwind:'$size'})
結(jié)果如下:
{ "_id" : 1, "item" : "t-shirt", "size" : "S" }
{ "_id" : 1, "item" : "t-shirt", "size" : "M" }
{ "_id" : 1, "item" : "t-shirt", "size" : "L" }
屬性值為false表示丟棄屬性值為空的?檔
屬性preserveNullAndEmptyArrays值為true表示保留屬性值為空的?檔
用法:
db.stu.aggregate(
{$unwind:{size:'$size',priserveNullAndEmptyArrays:true}} #防止數(shù)據(jù)丟失
)
數(shù)據(jù)庫中有一條數(shù)據(jù):{"username":"Alex","tags": ['C#','Java','C++']}灭返,如何獲取該tag列表的長度?
db.t2.aggregate(
{$unwind:'$tags'},
{$group:{_id:{username:'$username'},count:{'$sum':1}}},
{$project:{count:'$count',_id:0}}
)
數(shù)據(jù)庫的備份與恢復(fù):
備份:
備份的語法:
mongodump -h dbhost -d dbname -o dbdirectory
-h: 服務(wù)器地址蚓聘, 也可以指定端?號
-d: 需要備份的數(shù)據(jù)庫名稱
-o: 備份的數(shù)據(jù)存放位置捞高, 此?錄中存放著備份出來的數(shù)據(jù)
mongodump -h 192.168.196.128:27017 -d test1 -o ~/Desktop/test1bak
恢復(fù):
恢復(fù)語法:
mongorestore -h dbhost -d dbname --dir dbdirectory
-h: 服務(wù)器地址
-d: 需要恢復(fù)的數(shù)據(jù)庫實例
--dir: 備份數(shù)據(jù)所在位置
mongorestore -h 192.168.196.128:27017 -d test2 --dir ~/Desktop/test1bak/test1
循環(huán)加入數(shù)據(jù):
for(i=0;i<100000;i++){db.t255.insert({name:'test'+i,age:i})}
查看找到數(shù)據(jù)時的狀態(tài):
db.t1.find({name:'test10000'}).explain('executionStats')
建立索引:
語法:db.集合.ensureIndex({屬性:1})冗尤,1表示升序胀溺, -1表示降序
具體操作:db.t255.ensureIndex({name:1})
在默認(rèn)情況下索引字段的值可以相同
創(chuàng)建唯一索引(索引的值是唯一的):
db.t1.ensureIndex({"name":1},{"unique":true}) #如果要插入的值庫里面已經(jīng)有了就拒絕插入
建立聯(lián)合索引(什么時候需要聯(lián)合索引):
db.t1.ensureIndex({name:1,age:1}) #根據(jù)name和age的字段設(shè)置聯(lián)合索引
查看當(dāng)前集合的所有索引:
db.t1.getIndexes()
刪除索引:
db.t1.dropIndex({'索引名稱':1})
主從設(shè)置:
主的配置文件:/etc/mastermongodb.conf
從的配置文件:/etc/slavemongodb.conf
配置文件啟動mongdb:
sudo mongod --config /etc/mastermongodb.conf
sudo mongod -f /etc/mastermongodb.conf (簡寫)
通常這種方法啟動是阻塞終端的,可以通過更改配置文件來讓其后臺啟動:
vi /etc/mongodb.conf
加上 fork=true
允許創(chuàng)建子線程,也就是在后臺子線程運行
啟動客戶端:
mongo -port 27018 #主的端口