Node.js中使用mongoskin操作mongoDB实例

前端之家收集整理的这篇文章主要介绍了Node.js中使用mongoskin操作mongoDB实例前端之家小编觉得挺不错的,现在分享给大家,也给大家做个参考。

一、废话

@H_502_3@

从13年1月份接触mongodb进行开发,开发了旅游标签服务、微博标签检索系统、地图服务、web APP服务...使用MongoDB的场景从.NET、JAVA环境转到了node.js平台。越发觉Node.js和mongodb结合感觉的很好。感觉mongodb和node.js是天生的一对。的确,mongodb的客户端是JS的解析引擎。因此,选择mongodb和node.js做产品原型也是很nice的选择。网上,遇到网友询问mongodb的开发,选择哪个driver最好,以前一直是使用原生的driver,但是写起来代码有很多需要注意的,比如连接的关闭操作等等...因此,在node.js开发环境下我这里推荐使用mongoskin。 @H_502_3@

二、几个需要说的概念

@H_502_3@

(1)数据库:同关系数据库一样。 (2)集合: 关系数据库中的表。 (3)文档: 类比关系数据库的记录,实则是JSON对象。 (4)数据库设计:建议考虑Nosql设计,抛弃关系数据的设计思想;其实Nosql数据库设计博大精深,需要不断地在项目中实践。 (5)用户体系:每一个数据库都有自己的管理员,可以:

代码如下:
(7)建议更改对外端口 (8)启动服务(这是win下,linux下稍作修改):
代码如下:
@H_502_3@

三、搭建mongodb开发基础设施

@H_502_3@

(0) npm install mongoskin 安装mongoskin@H_502_3@

这里不介绍Node.js安装、package等机制。@H_502_3@

(1)创建配置文件 config.json@H_502_3@

代码如下:
@H_502_3@

(2)创建util相关类mongo.js :导出一个DB对象@H_502_3@

代码如下:
502_3@

/* * @des:导出数据库连接模块 * */ module.exports = (function(){ var host = config.host, port = config.port, dbName = config.dbname, userName = config.username, password = config.password, str = 'mongodb://' + userName + ':' + password + '@' + host +':' + port+ '/' + dbName;@H_502_3@

var option = { native_parser: true };@H_502_3@

return mongoskin.db(str,option); })();

@H_502_3@

(3)构建CRUD的基础类:为了减少重复CURD代码,只需要传入相关的JSON对象即可@H_502_3@

代码如下:
502_3@

var CRUD = function(collection){ this.collection = collection; db.bind(this.collection); };@H_502_3@

CRUD.prototype = { /* * @des: 创建一条记录 * @model: 插入的记录,JSON格式的model * @callback:回调,返回插入成功的记录或者失败信息 * * */ create: function(model,callback){ db[this.collection].save(model,function(err,item){ if(err) { return callback(status.fail); } item.status = status.success.status; item.message = status.success.message; return callback(item); }); },@H_502_3@

/* * @des:读取一条记录 * @query:查询条件,Mongo查询的JSON字面量 * @callback:回调,返回符合要求的记录或者失败信息 * * */ read: function(query,callback){ db[this.collection].find(query).toArray(function(err,items){ if(err){ return callback(status.fail); } var obj = { status: status.success.status, message: status.success.message, items: items };@H_502_3@

return callback(obj); }); }, /* * @des:更新一条记录 * @query:查询条件,Mongo查询的JSON字面量,此处为_id * @updateModel:需要更新的JSON格式的模型 * @callback:返回成功或者失败信息 * * */ update: function(query,updateModel,callback){ var set = {set: updateModel}; db[this.collection].update(query,set,function(err){ if(err){ return callback(status.fail); }else{ return callback(status.success); } }); },@H_502_3@

/* * @des:删除一条记录 * @query:查询条件,Mongo查询的JSON字面量 * @callback:返回失败或者成功的信息 * * */ deleteData: function(query,callback){ db[this.collection].remove(query,function(err){ if(err){ return callback(status.fail); } return callback(status.success); }); } };@H_502_3@

module.exports = CRUD;

@H_502_3@

(4)构建status.json,因为需要一些状态表示成功和失败,后期可以拓展为验证码错误、短信验证错误用户名错误等@H_502_3@

代码如下:
502_3@

/* * 失败状态 * * */ fail: { status: 0, message: 'FAIL' },@H_502_3@

/* * 两次输入的密码不一致 * */ repeatPassword: { status: 0, message: '两次输入的密码不一致' } };

@H_502_3@ 原文链接:https://www.f2er.com/nodejs/57657.html

猜你在找的Node.js相关文章