国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 數據庫 > MongoDB > 正文

MongoDB中javascript腳本編程簡介和入門實例

2020-10-29 18:54:30
字體:
來源:轉載
供稿:網友

注:作者使用的mongodb版本為2.4.7。

入門例子

復制代碼 代碼如下:

conn = new Mongo();
db = conn.getDB("db-name");  //選擇數據庫
db.auth("user-name","password");  //用戶驗證

var map = function() {
    split_result = this.sentence.split(" ");
    for (var i in split_result) {
        var word = split_result[i].replace(/(^/s*)|(/s*$)/g,"").toLowerCase(); //去除了單詞兩邊可能的空格,并將單詞轉換為小寫
        if (word.length != 0) {
            emit(word, 1);
        }
    }
}

var reduce = function(key, values) {
    print(key+":"+Array.sum(values));
    return Array.sum(values);
}

db.data.mapReduce(
    map,
    reduce,
    {out:{merge:"mr_result"}}
)

保存為test01.js,在終端中運行:

復制代碼 代碼如下:
$ mongo test01.js

運行結束后可以在集合mr_result中查看mapreduce結果。

值得注意的是,在js腳本中如果直接:

復制代碼 代碼如下:
db.mr_result.find();

是無法輸出結果的。

應該使用下面的方式輸出結果:

復制代碼 代碼如下:
conn = new Mongo();
db = conn.getDB("db-name");  //選擇數據庫
db.auth("user-name","password");  //用戶驗證

var cursor = db.mr_result.find();

while(cursor.hasNext()) {
    r = cursor.next();
    print(r["_id"] + "/t" + r["value"]);
}


保存為test02.js,運行:
復制代碼 代碼如下:
$ mongo test02.js

結果如下:
復制代碼 代碼如下:

a       1
code    1
collection      1
consider        1
contains        1
documents       1
error   1
follow  1
following       3
found   1
get     1
i       2
in      1
link    1
map-reduce      1
of      1
on      1
operations      1
orders  1
prototype       1
that    1
the     4
this    1
when    1

使用load()函數

load()函數用于引入其他文件,這為代碼重用提供了便利。 最簡單的情形是,把數據庫連接操作的代碼放在一個單獨的文件里,在當前目錄建立lib,在lib目錄下創建文件base_operation.js,內容如下:

復制代碼 代碼如下:

function BaseOperation() {

    /*
    連接數據庫,返回連接對象
    */
    this.getDB = function() {
        conn = new Mongo();
        db = conn.getDB("db-name");
        db.auth("user-name","password");
        return db;
    }
}


在當前目錄下建立文件test03.js,內容如下:
復制代碼 代碼如下:

load("lib/base_operation.js");
BO = new BaseOperation();
db = BO.getDB();

var cursor = db.mr_result.find();

while(cursor.hasNext()) {
    r = cursor.next();
    print(r["_id"] + "/t" + r["value"]);
}


運行test03.js的效果和test02.js相同。

發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 安塞县| 巩留县| 连江县| 徐闻县| 冕宁县| 景宁| 洮南市| 太仆寺旗| 内乡县| 翁源县| 大田县| 高邮市| 丹寨县| 三都| 金溪县| 平武县| 汶上县| 葵青区| 宁南县| 比如县| 奉节县| 云龙县| 龙川县| 罗江县| 花莲市| 共和县| 长泰县| 清苑县| 清镇市| 长沙市| 东台市| 和田县| 巴彦淖尔市| 宝坻区| 江源县| 宝鸡市| 西林县| 同德县| 廉江市| 牙克石市| 凉山|