MongoDB 基本操做與MongoDB for JAVA

時間 2019-11-07

標籤 mongodb 基本 java 欄目 MongoDB 简体版

原文原文鏈接

1、準備工做

一、下載mongoDB html

下載地址：http://www.mongodb.org/downloads java

選擇合適你的版本 git

相關文檔：http://www.mongodb.org/display/DOCS/Tutorial github

二、安裝mongoDB mongodb

A、不解壓模式： shell

將下載下來的mongoDB-xxx.zip打開，找到bin目錄，運行mongod.exe就能夠啓動服務，默認端口27017，db保存的路徑是系統C硬盤目錄的根目錄的/data/db目錄。也就是說，若是你的mongoDB-xxx.zip在E盤，那麼你須要在C盤下創建data/db目錄。mongoDB不會幫你創建這個目錄的。數據庫

而後運行mongo便可鏈接到test數據庫，你就能夠進行數據操做。運行help顯示幫助命令行。 json

B、解壓模式數組

將下載下來的mongoDB-xxx.zip解壓到任意目錄，找到bin目錄，運行mongod.exe就能夠啓動mongoDB，默認端口27017，db保存的路徑是當前zip所在硬盤目錄的根目錄的/data/db目錄。也就是說，若是你的mongoDB-xxx.zip在E盤，那麼你須要在E盤下創建data/db目錄。mongoDB不會幫你創建這個目錄的。安全

而後運行mongo便可鏈接到test數據庫，你就能夠進行數據操做。運行help顯示幫助命令行。

三、簡單測試

> 2+4

> db

test

> //第一次插入數據會建立數據庫

Fri May 20 16:47:39 malformed UTF-8 character sequence at offset 27

error2:(shellhelp1) exec failed: malformed UTF-8 character sequence at offset 27

> db.foo.insert({id: 2011, userName: 'hoojo', age: 24, email: "hoojo_@126.com"});

> db.foo.find();

{ "_id" : ObjectId("4dd62b0352a70cbe79e04f81"), "id" : 2011, "userName" : "hoojo",

"age" : 24, "email" : "hoojo_@126.com" }

上面完成了簡單運算，顯示當前使用的數據庫，以及添加數據、查詢數據操做

2、DB shell數據操做

shell命令操做語法和JavaScript很相似，其實控制檯底層的查詢語句都是用JavaScript腳本完成操做的。

Ø 數據庫

一、Help查看命令提示

help

db.help();

db.yourColl.help();

db.youColl.find().help();

rs.help();

二、切換/建立數據庫

>use yourDB;

當建立一個集合(table)的時候會自動建立當前數據庫

3、查詢全部數據庫

show dbs;

四、刪除當前使用數據庫

db.dropDatabase();

五、從指定主機上克隆數據庫

db.cloneDatabase(「127.0.0.1」);

將指定機器上的數據庫的數據克隆到當前數據庫

六、從指定的機器上覆制指定數據庫數據到某個數據庫

db.copyDatabase("mydb", "temp", "127.0.0.1");

將本機的mydb的數據複製到temp數據庫中

七、修復當前數據庫

db.repairDatabase();

八、查看當前使用的數據庫

db.getName();

db;

db和getName方法是同樣的效果，均可以查詢當前使用的數據庫

九、顯示當前db狀態

db.stats();

十、當前db版本

db.version();

十一、查看當前db的連接機器地址

db.getMongo();

Ø Collection彙集集合

一、建立一個彙集集合（table）

db.createCollection(「collName」, {size: 20, capped: 5, max: 100});

二、獲得指定名稱的彙集集合（table）

db.getCollection("account");

三、獲得當前db的全部彙集集合

db.getCollectionNames();

四、顯示當前db全部彙集索引的狀態

db.printCollectionStats();

Ø 用戶相關

一、添加一個用戶

db.addUser("name");

db.addUser("userName", "pwd123", true);

添加用戶、設置密碼、是否只讀

二、數據庫認證、安全模式

db.auth("userName", "123123");

3、顯示當前全部用戶

show users;

四、刪除用戶

db.removeUser("userName");

Ø 其餘

一、查詢以前的錯誤信息

db.getPrevError();

二、清除錯誤記錄

db.resetError();

3、Collection彙集集合操做

Ø 查看彙集集合基本信息

一、查看幫助

db.yourColl.help();

二、查詢當前集合的數據條數

db.yourColl.count();

三、查看數據空間大小

db.userInfo.dataSize();

四、獲得當前彙集集合所在的db

db.userInfo.getDB();

五、獲得當前彙集的狀態

db.userInfo.stats();

六、獲得彙集集合總大小

db.userInfo.totalSize();

七、彙集集合儲存空間大小

db.userInfo.storageSize();

八、Shard版本信息

db.userInfo.getShardVersion()

九、彙集集合重命名

db.userInfo.renameCollection("users");

將userInfo重命名爲users

十、刪除當前彙集集合

db.userInfo.drop();

Ø 彙集集合查詢

一、查詢全部記錄

db.userInfo.find();

至關於：select * from userInfo;

默認每頁顯示20條記錄，當顯示不下的狀況下，能夠用it迭代命令查詢下一頁數據。注意：鍵入it命令不能帶「；」

可是你能夠設置每頁顯示數據的大小，用DBQuery.shellBatchSize = 50;這樣每頁就顯示50條記錄了。

二、查詢去掉後的當前彙集集合中的某列的重複數據

db.userInfo.distinct("name");

會過濾掉name中的相同數據

至關於：select distict name from userInfo;

三、查詢age = 22的記錄

db.userInfo.find({"age": 22});

至關於： select * from userInfo where age = 22;

四、查詢age > 22的記錄

db.userInfo.find({age: {$gt: 22}});

至關於：select * from userInfo where age > 22;

五、查詢age < 22的記錄

db.userInfo.find({age: {$lt: 22}});

至關於：select * from userInfo where age < 22;

六、查詢age >= 25的記錄

db.userInfo.find({age: {$gte: 25}});

至關於：select * from userInfo where age >= 25;

七、查詢age <= 25的記錄

db.userInfo.find({age: {$lte: 25}});

八、查詢age >= 23 而且 age <= 26

db.userInfo.find({age: {$gte: 23, $lte: 26}});

九、查詢name中包含 mongo的數據

db.userInfo.find({name: /mongo/});

//至關於%%

select * from userInfo where name like ‘%mongo%’;

十、查詢name中以mongo開頭的

db.userInfo.find({name: /^mongo/});

select * from userInfo where name like ‘mongo%’;

十一、查詢指定列name、age數據

db.userInfo.find({}, {name: 1, age: 1});

至關於：select name, age from userInfo;

固然name也能夠用true或false,當用ture的狀況下河name:1效果同樣，若是用false就是排除name，顯示name之外的列信息。

十二、查詢指定列name、age數據, age > 25

db.userInfo.find({age: {$gt: 25}}, {name: 1, age: 1});

至關於：select name, age from userInfo where age > 25;

1三、按照年齡排序

升序：db.userInfo.find().sort({age: 1});

降序：db.userInfo.find().sort({age: -1});

1四、查詢name = zhangsan, age = 22的數據

db.userInfo.find({name: 'zhangsan', age: 22});

至關於：select * from userInfo where name = ‘zhangsan’ and age = ‘22’;

1五、查詢前5條數據

db.userInfo.find().limit(5);

至關於：select top 5 * from userInfo;

1六、查詢10條之後的數據

db.userInfo.find().skip(10);

至關於：select * from userInfo where id not in (

select top 10 * from userInfo

);

1七、查詢在5-10之間的數據

db.userInfo.find().limit(10).skip(5);

可用於分頁，limit是pageSize，skip是第幾頁*pageSize

1八、or與 查詢

db.userInfo.find({$or: [{age: 22}, {age: 25}]});

至關於：select * from userInfo where age = 22 or age = 25;

1九、查詢第一條數據

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;

2一、按照某列進行排序

db.userInfo.find({sex: {$exists: true}}).count();

至關於：select count(sex) from userInfo;

Ø 索引

一、建立索引

db.userInfo.ensureIndex({name: 1});

db.userInfo.ensureIndex({name: 1, ts: -1});

二、查詢當前彙集集合全部索引

db.userInfo.getIndexes();

三、查看總索引記錄大小

db.userInfo.totalIndexSize();

四、讀取當前集合的全部index信息

db.users.reIndex();

五、刪除指定索引

db.users.dropIndex("name_1");

六、刪除全部索引索引

db.users.dropIndexes();

Ø 修改、添加、刪除集合數據

一、添加

db.users.save({name: ‘zhangsan’, age: 25, sex: true});

添加的數據的數據列，沒有固定，根據添加的數據爲準

二、修改

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’;

三、刪除

db.users.remove({age: 132});

四、查詢修改刪除

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

Ø 語句塊操做

一、簡單Hello World

print("Hello World!");

這種寫法調用了print函數，和直接寫入"Hello World!"的效果是同樣的；

二、將一個對象轉換成json

tojson(new Object());

tojson(new Object('a'));

三、循環添加數據

> 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查看下一頁的信息；

四、find 遊標查詢

>var cursor = db.users.find();

> while (cursor.hasNext()) {

printjson(cursor.next());

這樣就查詢全部的users信息，一樣能夠這樣寫

var cursor = db.users.find();

while (cursor.hasNext()) { printjson(cursor.next); }

一樣能夠省略{}號

五、forEach迭代循環

db.users.find().forEach(printjson);

forEach中必須傳遞一個函數來處理每條迭代的數據信息

六、將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]);

七、將find遊標轉換成數組

> var arr = db.users.find().toArray();

> printjson(arr[2]);

用toArray方法將其轉換爲數組

八、定製咱們本身的查詢結果

只顯示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);

九、forEach傳遞函數顯示信息

db.things.find({x:4}).forEach(function(x) {print(tojson(x));});

上面介紹過forEach須要傳遞一個函數，函數會接受一個參數，就是當前循環的對象，而後在函數體重處理傳入的參數信息。

【MongoDB for Java】Java操做MongoDB

開發環境：

System：Windows

IDE：eclipse、MyEclipse 8

Database：mongoDB

開發依賴庫：

JavaEE五、mongo-2.5.3.jar、junit-4.8.2.jar

Email：hoojo_@126.com

Blog：http://blog.csdn.net/IBM_hoojo

http://hoojo.cnblogs.com/

1、準備工做

一、首先，下載mongoDB對Java支持的驅動包

驅動包下載地址：https://github.com/mongodb/mongo-java-driver/downloads

mongoDB對Java的相關支持、技術：http://www.mongodb.org/display/DOCS/Java+Language+Center

驅動源碼下載：https://download.github.com/mongodb-mongo-java-driver-r2.6.1-7-g6037357.zip

在線查看源碼：https://github.com/mongodb/mongo-java-driver

二、下面創建一個JavaProject工程，導入下載下來的驅動包。便可在Java中使用mongoDB，目錄以下：

2、Java操做MongoDB示例

在本示例以前你須要啓動mongod.exe的服務，啓動後，下面的程序才能順利執行；

一、創建SimpleTest.java，完成簡單的mongoDB數據庫操做

Mongo mongo = new Mongo();

這樣就建立了一個MongoDB的數據庫鏈接對象，它默認鏈接到當前機器的localhost地址，端口是27017。

DB db = mongo.getDB(「test」);

這樣就得到了一個test的數據庫，若是mongoDB中沒有建立這個數據庫也是能夠正常運行的。若是你讀過上一篇文章就知道，mongoDB能夠在沒有建立這個數據庫的狀況下，完成數據的添加操做。當添加的時候，沒有這個庫，mongoDB會自動建立當前數據庫。

獲得了db，下一步咱們要獲取一個「彙集集合DBCollection」，經過db對象的getCollection方法來完成。

DBCollection users = db.getCollection("users");

這樣就得到了一個DBCollection，它至關於咱們數據庫的「表」。

查詢全部數據

DBCursor cur = users.find();

while (cur.hasNext()) {

System.out.println(cur.next());

}

完整源碼

package com.hoo.test;
 
import java.net.UnknownHostException;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.DBCursor;
import com.mongodb.Mongo;
import com.mongodb.MongoException;
import com.mongodb.util.JSON;
 
/**
 * <b>function:</b>MongoDB 簡單示例
 * @author hoojo
 * @createDate 2011-5-24 下午02:42:29
 * @file SimpleTest.java
 * @package com.hoo.test
 * @project MongoDB
 * @blog http://blog.csdn.net/IBM_hoojo
 * @email hoojo_@126.com
 * @version 1.0
 */
public class SimpleTest {
 
    public static void main(String[] args) throws UnknownHostException, MongoException {
        Mongo mg = new Mongo();
        //查詢全部的Database
        for (String name : mg.getDatabaseNames()) {
            System.out.println("dbName: " + name);
        }
        
        DB db = mg.getDB("test");
        //查詢全部的彙集集合
        for (String name : db.getCollectionNames()) {
            System.out.println("collectionName: " + name);
        }
        
        DBCollection users = db.getCollection("users");
        
        //查詢全部的數據
        DBCursor cur = users.find();
        while (cur.hasNext()) {
            System.out.println(cur.next());
        }
        System.out.println(cur.count());
        System.out.println(cur.getCursorId());
        System.out.println(JSON.serialize(cur));
    }
}

二、完成CRUD操做，首先創建一個MongoDB4CRUDTest.java，基本測試代碼以下：

package com.hoo.test;
 
import java.net.UnknownHostException;
import java.util.ArrayList;
import java.util.List;
import org.bson.types.ObjectId;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import com.mongodb.BasicDBObject;
import com.mongodb.Bytes;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.DBCursor;
import com.mongodb.DBObject;
import com.mongodb.Mongo;
import com.mongodb.MongoException;
import com.mongodb.QueryOperators;
import com.mongodb.util.JSON;
 
/**
 * <b>function:</b>實現MongoDB的CRUD操做
 * @author hoojo
 * @createDate 2011-6-2 下午03:21:23
 * @file MongoDB4CRUDTest.java
 * @package com.hoo.test
 * @project MongoDB
 * @blog http://blog.csdn.net/IBM_hoojo
 * @email hoojo_@126.com
 * @version 1.0
 */
public class MongoDB4CRUDTest {
    
    private Mongo mg = null;
    private DB db;
    private DBCollection users;
    
    @Before
    public void init() {
        try {
            mg = new Mongo();
            //mg = new Mongo("localhost", 27017);
        } catch (UnknownHostException e) {
            e.printStackTrace();
        } catch (MongoException e) {
            e.printStackTrace();
        }
        //獲取temp DB；若是默認沒有建立，mongodb會自動建立
        db = mg.getDB("temp");
        //獲取users DBCollection；若是默認沒有建立，mongodb會自動建立
        users = db.getCollection("users");
    }
    
    @After
    public void destory() {
        if (mg != null)
            mg.close();
        mg = null;
        db = null;
        users = null;
        System.gc();
    }
    
    public void print(Object o) {
        System.out.println(o);
    }
}

三、添加操做

在添加操做以前，咱們須要寫個查詢方法，來查詢全部的數據。代碼以下：

/**
 * <b>function:</b> 查詢全部數據
 * @author hoojo
 * @createDate 2011-6-2 下午03:22:40
 */
private void queryAll() {
    print("查詢users的全部數據：");
    //db遊標
    DBCursor cur = users.find();
    while (cur.hasNext()) {
        print(cur.next());
    }
}
 
@Test
public void add() {
    //先查詢全部數據
    queryAll();
    print("count: " + users.count());
    
    DBObject user = new BasicDBObject();
    user.put("name", "hoojo");
    user.put("age", 24);
    //users.save(user)保存，getN()獲取影響行數
    //print(users.save(user).getN());
    
    //擴展字段，隨意添加字段，不影響現有數據
    user.put("sex", "男");
    print(users.save(user).getN());
    
    //添加多條數據，傳遞Array對象
    print(users.insert(user, new BasicDBObject("name", "tom")).getN());
    
    //添加List集合
    List<DBObject> list = new ArrayList<DBObject>();
    list.add(user);
    DBObject user2 = new BasicDBObject("name", "lucy");
    user.put("age", 22);
    list.add(user2);
    //添加List集合
    print(users.insert(list).getN());
    
    //查詢下數據，看看是否添加成功
    print("count: " + users.count());
    queryAll();
}

四、刪除數據

@Test
public void remove() {
    queryAll();
    print("刪除id = 4de73f7acd812d61b4626a77：" + users.remove(new BasicDBObject("_id", new ObjectId("4de73f7acd812d61b4626a77"))).getN());
    print("remove age >= 24: " + users.remove(new BasicDBObject("age", new BasicDBObject("$gte", 24))).getN());
}

五、修改數據

@Test
public void modify() {
    print("修改：" + users.update(new BasicDBObject("_id", new ObjectId("4dde25d06be7c53ffbd70906")), new BasicDBObject("age", 99)).getN());
    print("修改：" + users.update(
            new BasicDBObject("_id", new ObjectId("4dde2b06feb038463ff09042")), 
            new BasicDBObject("age", 121),
            true,//若是數據庫不存在，是否添加
            false//多條修改
            ).getN());
    print("修改：" + users.update(
            new BasicDBObject("name", "haha"), 
            new BasicDBObject("name", "dingding"),
            true,//若是數據庫不存在，是否添加
            true//false只修改第一天，true若是有多條就不修改
            ).getN());
    
    //當數據庫不存在就不修改、不添加數據，當多條數據就不修改
    //print("修改多條：" + coll.updateMulti(new BasicDBObject("_id", new ObjectId("4dde23616be7c19df07db42c")), new BasicDBObject("name", "199")));
}

六、查詢數據

@Test
public void query() {
    //查詢全部
    //queryAll();
    
    //查詢id = 4de73f7acd812d61b4626a77
    print("find id = 4de73f7acd812d61b4626a77: " + users.find(new BasicDBObject("_id", new ObjectId("4de73f7acd812d61b4626a77"))).toArray());
    
    //查詢age = 24
    print("find age = 24: " + users.find(new BasicDBObject("age", 24)).toArray());
    
    //查詢age >= 24
    print("find age >= 24: " + users.find(new BasicDBObject("age", new BasicDBObject("$gte", 24))).toArray());
    print("find age <= 24: " + users.find(new BasicDBObject("age", new BasicDBObject("$lte", 24))).toArray());
    
    print("查詢age!=25：" + users.find(new BasicDBObject("age", new BasicDBObject("$ne", 25))).toArray());
    print("查詢age in 25/26/27：" + users.find(new BasicDBObject("age", new BasicDBObject(QueryOperators.IN, new int[] { 25, 26, 27 }))).toArray());
    print("查詢age not in 25/26/27：" + users.find(new BasicDBObject("age", new BasicDBObject(QueryOperators.NIN, new int[] { 25, 26, 27 }))).toArray());
    print("查詢age exists 排序：" + users.find(new BasicDBObject("age", new BasicDBObject(QueryOperators.EXISTS, true))).toArray());
    
    print("只查詢age屬性：" + users.find(null, new BasicDBObject("age", true)).toArray());
    print("只查屬性：" + users.find(null, new BasicDBObject("age", true), 0, 2).toArray());
    print("只查屬性：" + users.find(null, new BasicDBObject("age", true), 0, 2, Bytes.QUERYOPTION_NOTIMEOUT).toArray());
    
    //只查詢一條數據，多條去第一條
    print("findOne: " + users.findOne());
    print("findOne: " + users.findOne(new BasicDBObject("age", 26)));
    print("findOne: " + users.findOne(new BasicDBObject("age", 26), new BasicDBObject("name", true)));
    
    //查詢修改、刪除
    print("findAndRemove 查詢age=25的數據，而且刪除: " + users.findAndRemove(new BasicDBObject("age", 25)));
    
    //查詢age=26的數據，而且修改name的值爲Abc
    print("findAndModify: " + users.findAndModify(new BasicDBObject("age", 26), new BasicDBObject("name", "Abc")));
    print("findAndModify: " + users.findAndModify(
        new BasicDBObject("age", 28), //查詢age=28的數據
        new BasicDBObject("name", true), //查詢name屬性
        new BasicDBObject("age", true), //按照age排序
        false, //是否刪除，true表示刪除
        new BasicDBObject("name", "Abc"), //修改的值，將name修改爲Abc
        true, 
        true));
    
    queryAll();
}

mongoDB不支持聯合查詢、子查詢，這須要咱們本身在程序中完成。將查詢的結果集在Java查詢中進行須要的過濾便可。

七、其餘操做

public void testOthers() {
    DBObject user = new BasicDBObject();
    user.put("name", "hoojo");
    user.put("age", 24);
    
    //JSON 對象轉換 
    print("serialize: " + JSON.serialize(user));
    //反序列化
    print("parse: " + JSON.parse("{ \"name\" : \"hoojo\" , \"age\" : 24}"));
    
    print("判斷temp Collection是否存在: " + db.collectionExists("temp"));
    
    //若是不存在就建立
    if (!db.collectionExists("temp")) {
        DBObject options = new BasicDBObject();
        options.put("size", 20);
        options.put("capped", 20);
        options.put("max", 20);
        print(db.createCollection("account", options));
    }
    
    //設置db爲只讀
    db.setReadOnly(true);
    
    //只讀不能寫入數據
    db.getCollection("test").save(user);

window下自動啓動MONGODB：

mongod.exe -dbpath d:\data\db -logpath d:\log\log.txt -install

Linux下啓動MONGODB

/usr/local/mongodb/bin/mongod --dbpath=/usr/local/mongodb/data --logpath=/usr/local/mongodb/logs -logappend --auth -port=27017