09

1.安装mongodb nodejs driver

要安装mongodb nodejs的原生driver,可以通过npm,也可以通过github下载:

npm install mongodb

2连接到数据库

var mongo = require('mongodb'),

Server = mongo.Server,

Db = mongo.Db;

var server = new Server('localhost', 27017, {auto_reconnect: true});

var db = new Db('foo', server);

db.open(function(err, db) {

if(!err) {

console.log("We are connected");

}

});

查询Get

db.open(function(err, db) {

if(!err) {

console.log("We are connected");

db.collection('bar', function(err, collection){

collection.find().toArray(function(error, bars){console.log(bars);});

collection.find({a:1}).toArray(function(error, bars){console.log(bars);});

collection.findOne({a: 1}, function(error, bar){console.log(bar)});

});

}

});

这里一旦用find获取到结果集之后,需要调用toArray方法,并传递回调函数,这个时候才能拿到真正的数据。第二个find语句则是查找所有a=1的文档。第三个find语句则是只找第一个满足条件的文档。具体更多的过滤条件可以参考官方的Query语句。这里有个有趣的事情需要注意,find本身并不执行查询,它只是返回一个Cursor实例,你可以遍历这个Cursor来查询数据。如下面的例子:

// Cursors don't run their queries until you actually attempt to retrieve data

// from them.

// Find returns a Cursor, which is Enumerable. You can iterate:

collection.find(function(err, cursor) {

cursor.each(function(err, item) {

if(item != null) console.dir(item);

});

});

// You can turn it into an array

collection.find(function(err, cursor) {

cursor.toArray(function(err, items) {

console.log("count: " + items.length);

});

});

插入Insert

db.open(function(err, db) {

if(!err) {

db.collection('bar', function(err, collection) {

var doc1 = {a: 1};

var doc2 = {a: 2, b: 'b2'};

var docs = [{a:3}, {a:4}];

collection.insert(doc1);

collection.insert(doc2, {safe:true}, function(err, result) {});

collection.insert(docs, {safe:true}, function(err, result) {});

});

}

});

第一个insert和第二个insert的区别在于,增加了一个option对象参数({safe:true})以及一个回调函数。MongoDB的

insert/update/remove都是异步的,也就是说发出insert命令之后,就不管数据库是否执行成功了。要想知道数据库是否执行成功,需

要再发出一个查询请求来获取连接(Connection)的最后一个错误状态。为了简化这个过程,也就支持{safe:true}这个参数,使得

insert和错误状态查询能够一起执行,一旦设置这个参数,一定要增加回调函数作为第三个参数。具体地,我们可以看下面地例子来理解这个

{safe:true}的意义:

db.collection('bar', function(err, collection){

collection.insert({a:996, _id:'1'}, function(error, bars){

console.log('insert success without safe');

console.log(error);

console.log(bars);

collection.insert({a:996, _id:'1'}, {safe:true}, function(error, bars){

console.log('insert fail with safe and get error');

console.log(error);

console.log(bars);

collection.insert({a:996, _id:'1'}, function(error, bars){

console.log('insert fail without safe but no error');

console.log(error);

console.log(bars);

});

});

});

});

# output result

[app.js] insert success without safe

[app.js] null

[app.js] [ { a: 996, _id: '1' } ]

[app.js] insert fail with safe and get error

[app.js] { [MongoError: E11000 duplicate key error index: foo.bar.$_id_  dup key: { : "1" }]

name: 'MongoError',

err: 'E11000 duplicate key error index: foo.bar.$_id_  dup key: { : "1" }',

code: 11000,

n: 0,

connectionId: 38,

ok: 1 }

[app.js] undefined

[app.js] insert fail without safe but no error

[app.js] null

[app.js] [ { a: 996, _id: '1' } ]

这里的_id是mongodb默认的主键,是不允许重复的。如果你传入了_id则以传入的值作为主键,如果没有传入则会自动生成。你可以看到,第一次insert,我们也不关心是不是真的插入了,幸运的是真的成功了,因为不存在_id为1的数据。第二次插入的时候,我们设置{safe:true}以确保一定插入成功,这是会报主键重复的错误。第三次同样的插入,但是不设置{safe:true},这个时候发现并没有报错,而且回调函数还拿到了要插入的数据。是不是第三次插入成功了呢?不是的,其实正像第二次插入的一样,肯定是主键重复了,但是由于我们并没有要求返回最后的错误状态,所以mongodb drvier直接回调了我们传入的回调函数,并且设置error为null,bars为要插入的数据。总结一下,如果你要确保数据是否更新(insert/update/remove)成功必须要设置{safe:true}选项。

更新Update

collection.update({a:996}, {$push: {b:'b'}}, function(error, bars){});

collection.update({a:996}, {$set: {a:997}}, function(error, bars){});

注意,这里为了代码简单,我们没有设置{safe:true}。你可以看到update的第一个参数是条件,即对a=996的文档进行更新。第二个参数则

是表示要如何更新文档,譬如第一个update是增加一个属性b,且设置其值为字符串'b';第二个update是修改a的值为997。可以看出,第二个

参数是一个对象,其属性名是一个操作符,以$开头,值为一个对象。这些操作符除了这里的$push和$set,还有其它的$inc, $unset,

$pushAll等等,具体可以参考这里。

删除Delete

collection.remove({a:997}, {safe:true}, function(error, count){

console.log(error);

console.log(count);

collection.remove();

});

这里第一个remove是删除a=997的所有文档。回调函数的第二个参数是表示相应删除的文档数量。第二个remove则是删除该collection中的所有文档。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 203,456评论 5 477
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 85,370评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 150,337评论 0 337
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,583评论 1 273
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,596评论 5 365
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,572评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 37,936评论 3 395
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,595评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,850评论 1 297
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,601评论 2 321
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,685评论 1 329
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,371评论 4 318
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,951评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,934评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,167评论 1 259
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 43,636评论 2 349
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,411评论 2 342

推荐阅读更多精彩内容