MongoDB 的獲取和安裝
MongoDB的獲取和安裝
1. MongoDB的獲取和安裝
（1）獲取地址 http://www.mongodb.org/downloads 根據自己需要選擇相應的版本，linux下可以使用wget 命令。
（2）解壓 mongodb-win32-i386-1.8.1
（3）創建數據存放文件夾，mongodb默認的數據目錄 /data/db
C:/> mkdir /data
C:/> mkdir /data/db
（4）運行 MongoDB
mongod.exe - 數據庫的服務器端，相當於mysql的 mysqld命令，啟動服務器端
mongo.exe - 數據庫的客戶端,相當於mysql的mysql命令，打開管理控制臺
啟動服務
mongod.exe --dbpath F:/DataBase/MongoDB/db/
--dbpath 數據文件存放路徑
--port 數據服務端口
C:/> cd /my_mongo_dir/bin
C:/my_mongo_dir/bin > mongod //啟動mongod 服務器，默認的數據庫路徑 /data/db，端口27071
啟動客戶端
mongo.exe cclove
cclove 所連接的數據庫名稱
C:/> cd /my_mongo_dir/bin
C:/my_mongo_dir/bin> mongo
2. 熟悉MongoDB的數據操作語句，類sql
數據庫操作語法
mongo --path
db.AddUser(username,password) 添加用戶
db.auth(usrename,password) 設置數據庫連接驗證
db.cloneDataBase(fromhost) 從目標服務器克隆一個數據庫
db.commandHelp(name) returns the help for the command
db.copyDatabase(fromdb,todb,fromhost) 復制數據庫fromdb---源數據庫名稱，todb---目標數據庫名稱，fromhost---源數據庫服務器地址
db.createCollection(name,{size:3333,capped:333,max:88888}) 創建一個數據集，相當於一個表
db.currentOp() 取消當前庫的當前操作
db.dropDataBase() 刪除當前數據庫
db.eval(func,args) run code server-side
db.getCollection(cname) 取得一個數據集合，同用法：db[‘cname‘] or db.cname
db.getCollenctionNames() 取得所有數據集合的名稱列表
db.getLastError() 返回最後一個錯誤的提示消息
db.getLastErrorObj() 返回最後一個錯誤的對象
db.getMongo() 取得當前服務器的連接對象get the server connection object
db.getMondo().setSlaveOk() allow this connection to read from then nonmaster membr of a replica pair
db.getName() 返回當操作數據庫的名稱
db.getPrevError() 返回上一個錯誤對象
db.getProfilingLevel() ?什麽等級
db.getReplicationInfo() ?什麽信息
db.getSisterDB(name) get the db at the same server as this onew
db.killOp() 停止（殺死）在當前庫的當前操作
db.printCollectionStats() 返回當前庫的數據集狀態
db.printReplicationInfo()
db.printSlaveReplicationInfo()
db.printShardingStatus() 返回當前數據庫是否為共享數據庫
db.removeUser(username) 刪除用戶
db.repairDatabase() 修復當前數據庫
db.resetError()
db.runCommand(cmdObj) run a database command. if cmdObj is a string, turns it into {cmdObj:1}
db.setProfilingLevel(level) 0=off,1=slow,2=all
db.shutdownServer() 關閉當前服務程序
db.version() 返回當前程序的版本信息
數據集(表)操作語法
db.linlin.find({id:10}) 返回linlin數據集ID=10的數據集
db.linlin.find({id:10}).count() 返回linlin數據集ID=10的數據總數
db.linlin.find({id:10}).limit(2) 返回linlin數據集ID=10的數據集從第二條開始的數據集
db.linlin.find({id:10}).skip(8) 返回linlin數據集ID=10的數據集從0到第八條的數據集
db.linlin.find({id:10}).limit(2).skip(8) 返回linlin數據集ID=1=的數據集從第二條到第八條的數據
db.linlin.find({id:10}).sort() 返回linlin數據集ID=10的排序數據集
db.linlin.findOne([query]) 返回符合條件的一條數據
db.linlin.getDB() 返回此數據集所屬的數據庫名稱
db.linlin.getIndexes() 返回些數據集的索引信息
db.linlin.group({key:...,initial:...,reduce:...[,cond:...]})
db.linlin.mapReduce(mayFunction,reduceFunction,<optional params>)
db.linlin.remove(query) 在數據集中刪除一條數據
db.linlin.renameCollection(newName) 重命名些數據集名稱
db.linlin.save(obj) 往數據集中插入一條數據
db.linlin.stats() 返回此數據集的狀態
db.linlin.storageSize() 返回此數據集的存儲大小
db.linlin.totalIndexSize() 返回此數據集的索引文件大小
db.linlin.totalSize() 返回些數據集的總大小
db.linlin.update(query,object[,upsert_bool]) 在此數據集中更新一條數據
db.linlin.validate() 驗證此數據集
db.linlin.getShardVersion() 返回數據集共享版本號
db.linlin.find({‘name‘:‘foobar‘}) select * from linlin where name=‘foobar‘
db.linlin.find() select * from linlin
db.linlin.find({‘ID‘:10}).count() select count(*) from linlin where ID=10
db.linlin.find().skip(10).limit(20) 從查詢結果的第十條開始讀20條數據 select * from linlin limit 10,20 ----------mysql
db.linlin.find({‘ID‘:{$in:[25,35,45]}}) select * from linlin where ID in (25,35,45)
db.linlin.find().sort({‘ID‘:-1}) select * from linlin order by ID desc
db.linlin.distinct(‘name‘,{‘ID‘:{$lt:20}}) select distinct(name) from linlin where ID<20
db.linlin.group({key:{‘name‘:true},cond:{‘name‘:‘foo‘},reduce:function(obj,prev){prev.msum+=obj.marks;},initial:{msum:0}})
select name,sum(marks) from linlin group by name
db.linlin.find(‘this.ID<20‘,{name:1}) select name from linlin where ID<20
db.linlin.insert({‘name‘:‘foobar‘,‘age‘:25}) insert into linlin (‘name‘,‘age‘) values(‘foobar‘,25)
db.linlin.insert({‘name‘:‘foobar‘,‘age‘:25,‘email‘:‘[email protected]‘})
db.linlin.remove({}) delete * from linlin
db.linlin.remove({‘age‘:20}) delete linlin where age=20
db.linlin.remove({‘age‘:{$lt:20}}) delete linlin where age<20
db.linlin.remove({‘age‘:{$lte:20}}) delete linlin where age<=20
db.linlin.remove({‘age‘:{$gt:20}}) delete linlin where age>20
db.linlin.remove({‘age‘:{$gte:20}}) delete linlin where age>=20
db.linlin.remove({‘age‘:{$ne:20}}) delete linlin where age!=20
db.linlin.update({‘name‘:‘foobar‘},{$set:{‘age‘:36}}) update linlin set age=36 where name=‘foobar‘
db.linlin.update({‘name‘:‘foobar‘},{$inc:{‘age‘:3}}) update linlin set age=age+3 where name=‘foobar‘
官方提供的操作語句對照表：
上行：SQL 操作語句
下行：Mongo 操作語句
CREATE TABLE USERS (a Number, b Number)
db.createCollection("mycoll")
INSERT INTO USERS VALUES(1,1)
db.users.insert({a:1,b:1})
SELECT a,b FROM users
db.users.find({}, {a:1,b:1})
SELECT * FROM users
db.users.find()
SELECT * FROM users WHERE age=33
db.users.find({age:33})
SELECT a,b FROM users WHERE age=33
db.users.find({age:33}, {a:1,b:1})
SELECT * FROM users WHERE age=33 ORDER BY name
db.users.find({age:33}).sort({name:1})
SELECT * FROM users WHERE age>33
db.users.find({‘age‘:{$gt:33}})})
SELECT * FROM users WHERE age<33
db.users.find({‘age‘:{$lt:33}})})
SELECT * FROM users WHERE name LIKE "%Joe%"
db.users.find({name:/Joe/})
SELECT * FROM users WHERE name LIKE "Joe%"
db.users.find({name:/^Joe/})
SELECT * FROM users WHERE age>33 AND age<=40
db.users.find({‘age‘:{$gt:33,$lte:40}})})
SELECT * FROM users ORDER BY name DESC
db.users.find().sort({name:-1})
SELECT * FROM users WHERE a=1 and b=‘q‘
db.users.find({a:1,b:‘q‘})
SELECT * FROM users LIMIT 10 SKIP 20
db.users.find().limit(10).skip(20)
SELECT * FROM users WHERE a=1 or b=2
db.users.find( { $or : [ { a : 1 } , { b : 2 } ] } )
SELECT * FROM users LIMIT 1
db.users.findOne()
SELECT DISTINCT last_name FROM users
db.users.distinct(‘last_name‘)
SELECT COUNT(*y) FROM users
db.users.count()
SELECT COUNT(*y) FROM users where AGE > 30
db.users.find({age: {‘$gt‘: 30}}).count()
SELECT COUNT(AGE) from users
db.users.find({age: {‘$exists‘: true}}).count()
CREATE INDEX myindexname ON users(name)
db.users.ensureIndex({name:1})
CREATE INDEX myindexname ON users(name,ts DESC)
db.users.ensureIndex({name:1,ts:-1})
EXPLAIN SELECT * FROM users WHERE z=3
db.users.find({z:3}).explain()
UPDATE users SET a=1 WHERE b=‘q‘
db.users.update({b:‘q‘}, {$set:{a:1}}, false, true)
UPDATE users SET a=a+2 WHERE b=‘q‘
db.users.update({b:‘q‘}, {$inc:{a:2}}, false, true)
DELETE FROM users WHERE z="abc"
db.users.remove({z:‘abc‘});
Mongodb啟動命令mongod參數說明
|
--quiet |
# 安靜輸出 |
|
--port arg |
# 指定服務端口號，默認端口27017 |
|
--bind_ip arg |
# 綁定服務IP，若綁定127.0.0.1，則只能本機訪問，不指定默認本地所有IP |
|
--logpath arg |
# 指定MongoDB日誌文件，註意是指定文件不是目錄 |
|
--logappend |
# 使用追加的方式寫日誌 |
|
--pidfilepath arg |
# PID File 的完整路徑，如果沒有設置，則沒有PID文件 |
|
--keyFile arg |
# 集群的私鑰的完整路徑，只對於Replica Set 架構有效 |
|
--unixSocketPrefix arg |
# UNIX域套接字替代目錄,(默認為 /tmp) |
|
--fork |
# 以守護進程的方式運行MongoDB，創建服務器進程 |
|
--auth |
# 啟用驗證 |
|
--cpu |
# 定期顯示CPU的CPU利用率和iowait |
|
--dbpath arg |
# 指定數據庫路徑 |
|
--diaglog arg |
# diaglog選項 0=off 1=W 2=R 3=both 7=W+some reads |
|
--directoryperdb |
# 設置每個數據庫將被保存在一個單獨的目錄 |
|
--journal |
# 啟用日誌選項，MongoDB的數據操作將會寫入到journal文件夾的文件裏 |
|
--journalOptions arg |
# 啟用日誌診斷選項 |
|
--ipv6 |
# 啟用IPv6選項 |
|
--jsonp |
# 允許JSONP形式通過HTTP訪問（有安全影響） |
|
--maxConns arg |
# 最大同時連接數 默認2000 |
|
--noauth |
# 不啟用驗證 |
|
--nohttpinterface |
# 關閉http接口，默認關閉27018端口訪問 |
|
--noprealloc |
# 禁用數據文件預分配(往往影響性能) |
|
--noscripting |
# 禁用腳本引擎 |
|
--notablescan |
# 不允許表掃描 |
|
--nounixsocket |
# 禁用Unix套接字監聽 |
|
--nssize arg (=16) |
# 設置信數據庫.ns文件大小(MB) |
|
--objcheck |
# 在收到客戶數據,檢查的有效性， |
|
--profile arg |
# 檔案參數 0=off 1=slow, 2=all |
|
--quota |
# 限制每個數據庫的文件數，設置默認為8 |
|
--quotaFiles arg |
# number of files allower per db, requires --quota |
|
--rest |
# 開啟簡單的rest API |
|
--repair |
# 修復所有數據庫run repair on all dbs |
|
--repairpath arg |
# 修復庫生成的文件的目錄,默認為目錄名稱dbpath |
|
--slowms arg (=100) |
# value of slow for profile and console log |
|
--smallfiles |
# 使用較小的默認文件 |
|
--syncdelay arg (=60) |
# 數據寫入磁盤的時間秒數(0=never,不推薦) |
|
--sysinfo |
# 打印一些診斷系統信息 |
|
--upgrade |
# 如果需要升級數據庫 |
* Replicaton 參數
|
--fastsync |
# 從一個dbpath裏啟用從庫復制服務，該dbpath的數據庫是主庫的快照，可用於快速啟用同步 |
|
--autoresync |
# 如果從庫與主庫同步數據差得多，自動重新同步， |
|
--oplogSize arg |
# 設置oplog的大小(MB) |
* 主/從參數
|
--master |
# 主庫模式 |
|
--slave |
# 從庫模式 |
|
--source arg |
# 從庫 端口號 |
|
--only arg |
# 指定單一的數據庫復制 |
|
--slavedelay arg |
# 設置從庫同步主庫的延遲時間 |
* Replica set(副本集)選項：
|
--replSet arg |
# 設置副本集名稱 |
* Sharding(分片)選項
|
--configsvr |
# 聲明這是一個集群的config服務,默認端口27019，默認目錄/data/configdb |
|
--shardsvr |
# 聲明這是一個集群的分片,默認端口27018 |
|
--noMoveParanoia |
# 關閉偏執為moveChunk數據保存 |
# 上述參數都可以寫入 mongod.conf 配置文檔裏例如：
dbpath = /data/mongodb
logpath = /data/mongodb/mongodb.log
logappend = true
port = 27017
fork = true
auth = true
e.g：./mongod -shardsvr -replSet shard1 -port 16161 -dbpath /data/mongodb/data/shard1a -oplogSize 100 -logpath /data/mongodb/logs/shard1a.log -logappend -fork -rest
----------------------------------------------------------------------------------
MonoDB shell命令操作語法和JavaScript很類似，其實控制臺底層的查詢語句都是用JavaScript腳本完成操作的。
? 數據庫
1、Help查看命令提示
help
db.help();
db.yourColl.help();
db.youColl.find().help();
rs.help();
2、切換/創建數據庫
>use yourDB;
當創建一個集合(table)的時候會自動創建當前數據庫
3、查詢所有數據庫
show dbs;
4、刪除當前使用數據庫
db.dropDatabase();
5、從指定主機上克隆數據庫
db.cloneDatabase(“127.0.0.1”);
將指定機器上的數據庫的數據克隆到當前數據庫
6、從指定的機器上復制指定數據庫數據到某個數據庫
db.copyDatabase("mydb", "temp", "127.0.0.1");
將本機的mydb的數據復制到temp數據庫中
7、修復當前數據庫
db.repairDatabase();
8、查看當前使用的數據庫
db.getName();
db;
db和getName方法是一樣的效果，都可以查詢當前使用的數據庫
9、顯示當前db狀態
db.stats();
10、當前db版本
db.version();
11、查看當前db的鏈接機器地址
db.getMongo();
? Collection聚集集合
1、創建一個聚集集合（table）
db.createCollection(“collName”, {size: 20, capped: 5, max: 100});
2、得到指定名稱的聚集集合（table）
db.getCollection("account");
3、得到當前db的所有聚集集合
db.getCollectionNames();
4、顯示當前db所有聚集索引的狀態
db.printCollectionStats();
? 用戶相關
1、添加一個用戶
db.addUser("name");
db.addUser("userName", "pwd123", true);
添加用戶、設置密碼、是否只讀
2、數據庫認證、安全模式
db.auth("userName", "123123");
3、顯示當前所有用戶
show users;
4、刪除用戶
db.removeUser("userName");
? 其他
1、查詢之前的錯誤信息
db.getPrevError();
2、清除錯誤記錄
db.resetError();
三、Collection聚集集合操作
? 查看聚集集合基本信息
1、查看幫助
db.yourColl.help();
2、查詢當前集合的數據條數
db.yourColl.count();
3、查看數據空間大小
db.userInfo.dataSize();
4、得到當前聚集集合所在的db
db.userInfo.getDB();
5、得到當前聚集的狀態
db.userInfo.stats();
6、得到聚集集合總大小
db.userInfo.totalSize();
7、聚集集合儲存空間大小
db.userInfo.storageSize();
8、Shard版本信息
db.userInfo.getShardVersion()
9、聚集集合重命名
db.userInfo.renameCollection("users");
將userInfo重命名為users
10、刪除當前聚集集合
db.userInfo.drop();
? 聚集集合查詢
1、查詢所有記錄
db.userInfo.find();
相當於：select * from userInfo;
默認每頁顯示20條記錄，當顯示不下的情況下，可以用it叠代命令查詢下一頁數據。註意：鍵入it命令不能帶“；”
但是你可以設置每頁顯示數據的大小，用DBQuery.shellBatchSize = 50;這樣每頁就顯示50條記錄了。
2、查詢去掉後的當前聚集集合中的某列的重復數據
db.userInfo.distinct("name");
會過濾掉name中的相同數據
相當於：select distict name from userInfo;
3、查詢age = 22的記錄
db.userInfo.find({"age": 22});
相當於： select * from userInfo where age = 22;
4、查詢age > 22的記錄
db.userInfo.find({age: {$gt: 22}});
相當於：select * from userInfo where age > 22;
5、查詢age < 22的記錄
db.userInfo.find({age: {$lt: 22}});
相當於：select * from userInfo where age < 22;
6、查詢age >= 25的記錄
db.userInfo.find({age: {$gte: 25}});
相當於：select * from userInfo where age >= 25;
7、查詢age <= 25的記錄
db.userInfo.find({age: {$lte: 25}});
8、查詢age >= 23 並且 age <= 26
db.userInfo.find({age: {$gte: 23, $lte: 26}});
9、查詢name中包含 mongo的數據
db.userInfo.find({name: /mongo/});
//相當於%%
select * from userInfo where name like ‘%mongo%’;
10、查詢name中以mongo開頭的
db.userInfo.find({name: /^mongo/});
select * from userInfo where name like ‘mongo%’;
11、查詢指定列name、age數據
db.userInfo.find({}, {name: 1, age: 1});
相當於：select name, age from userInfo;
當然name也可以用true或false,當用ture的情況下河name:1效果一樣，如果用false就是排除name，顯示name以外的列信息。
12、查詢指定列name、age數據, age > 25
db.userInfo.find({age: {$gt: 25}}, {name: 1, age: 1});
相當於：select name, age from userInfo where age > 25;
13、按照年齡排序
升序：db.userInfo.find().sort({age: 1});
降序：db.userInfo.find().sort({age: -1});
14、查詢name = zhangsan, age = 22的數據
db.userInfo.find({name: ‘zhangsan‘, age: 22});
相當於：select * from userInfo where name = ‘zhangsan’ and age = ‘22’;
15、查詢前5條數據
db.userInfo.find().limit(5);
相當於：select top 5 * from userInfo;
16、查詢10條以後的數據
db.userInfo.find().skip(10);
相當於：select * from userInfo where id not in (
select top 10 * from userInfo
);
17、查詢在5-10之間的數據
db.userInfo.find().limit(10).skip(5);
可用於分頁，limit是pageSize，skip是第幾頁*pageSize
18、or與 查詢
db.userInfo.find({$or: [{age: 22}, {age: 25}]});
相當於：select * from userInfo where age = 22 or age = 25;
19、查詢第一條數據
db.userInfo.findOne();
相當於：select top 1 * from userInfo;
db.userInfo.find().limit(1);
20、查詢某個結果集的記錄條數
db.userInfo.find({age: {$gte: 25}}).count();
相當於：select count(*) from userInfo where age >= 20;
21、按照某列進行排序
db.userInfo.find({sex: {$exists: true}}).count();
相當於：select count(sex) from userInfo;
? 索引
1、創建索引
db.userInfo.ensureIndex({name: 1});
db.userInfo.ensureIndex({name: 1, ts: -1});
2、查詢當前聚集集合所有索引
db.userInfo.getIndexes();
3、查看總索引記錄大小
db.userInfo.totalIndexSize();
4、讀取當前集合的所有index信息
db.users.reIndex();
5、刪除指定索引
db.users.dropIndex("name_1");
6、刪除所有索引索引
db.users.dropIndexes();
? 修改、添加、刪除集合數據
1、添加
db.users.save({name: ‘zhangsan’, age: 25, sex: true});
添加的數據的數據列，沒有固定，根據添加的數據為準
2、修改
db.users.update({age: 25}, {$set: {name: ‘changeName‘}}, false, true);
相當於：update users set name = ‘changeName’ where age = 25;
db.users.update({name: ‘Lisi‘}, {$inc: {age: 50}}, false, true);
相當於：update users set age = age + 50 where name = ‘Lisi’;
db.users.update({name: ‘Lisi‘}, {$inc: {age: 50}, $set: {name: ‘hoho‘}}, false, true);
相當於：update users set age = age + 50, name = ‘hoho’ where name = ‘Lisi’;
3、刪除
db.users.remove({age: 132});
4、查詢修改刪除
db.users.findAndModify({
query: {age: {$gte: 25}},
sort: {age: -1},
update: {$set: {name: ‘a2‘}, $inc: {age: 2}},
remove: true
});
db.runCommand({ findandmodify : "users",
query: {age: {$gte: 25}},
sort: {age: -1},
update: {$set: {name: ‘a2‘}, $inc: {age: 2}},
remove: true
});
update 或 remove 其中一個是必須的參數; 其他參數可選。
參數
詳解
默認值
query
查詢過濾條件
{}
sort
如果多個文檔符合查詢過濾條件，將以該參數指定的排列方式選擇出排在首位的對象，該對象將被操作
{}
remove
若為true，被選中對象將在返回前被刪除
N/A
update
一個 修改器對象
N/A
new
若為true，將返回修改後的對象而不是原始對象。在刪除操作中，該參數被忽略。
false
fields
參見Retrieving a Subset of Fields (1.5.0+)
All fields
upsert
創建新對象若查詢結果為空。 示例 (1.5.4+)
false
? 語句塊操作
1、簡單Hello World
print("Hello World!");
這種寫法調用了print函數，和直接寫入"Hello World!"的效果是一樣的；
2、將一個對象轉換成json
tojson(new Object());
tojson(new Object(‘a‘));
3、循環添加數據
> for (var i = 0; i < 30; i++) {
... db.users.save({name: "u_" + i, age: 22 + i, sex: i % 2});
... };
這樣就循環添加了30條數據，同樣也可以省略括號的寫法
> for (var i = 0; i < 30; i++) db.users.save({name: "u_" + i, age: 22 + i, sex: i % 2});
也是可以的，當你用db.users.find()查詢的時候，顯示多條數據而無法一頁顯示的情況下，可以用it查看下一頁的信息；
4、find 遊標查詢
>var cursor = db.users.find();
> while (cursor.hasNext()) {
printjson(cursor.next());
}
這樣就查詢所有的users信息，同樣可以這樣寫
var cursor = db.users.find();
while (cursor.hasNext()) { printjson(cursor.next); }
同樣可以省略{}號
5、forEach叠代循環
db.users.find().forEach(printjson);
forEach中必須傳遞一個函數來處理每條叠代的數據信息
6、將find遊標當數組處理
var cursor = db.users.find();
cursor[4];
取得下標索引為4的那條數據
既然可以當做數組處理，那麽就可以獲得它的長度：cursor.length();或者cursor.count();
那樣我們也可以用循環顯示數據
for (var i = 0, len = c.length(); i < len; i++) printjson(c[i]);
7、將find遊標轉換成數組
> var arr = db.users.find().toArray();
> printjson(arr[2]);
用toArray方法將其轉換為數組
8、定制我們自己的查詢結果
只顯示age <= 28的並且只顯示age這列數據
db.users.find({age: {$lte: 28}}, {age: 1}).forEach(printjson);
db.users.find({age: {$lte: 28}}, {age: true}).forEach(printjson);
排除age的列
db.users.find({age: {$lte: 28}}, {age: false}).forEach(printjson);
9、forEach傳遞函數顯示信息
db.things.find({x:4}).forEach(function(x) {print(tojson(x));});
上面介紹過forEach需要傳遞一個函數，函數會接受一個參數，就是當前循環的對象，然後在函數體重處理傳入的參數
MongoDB 的獲取和安裝