//存储用户信息
User.prototype.save = function (callback) {
//要存入数据库的用户文档
var user = {
name: this.name,
password: this.password
};
//打开数据库
mongodb.open(function (err, db) {
if (err) {
return callback(err); //错误，返回 err 信息
}
//读取 users 集合
db.collection('users', function (err, collection) {
if (err) {
mongodb.close();
return callback(err); //错误，返回 err 信息
}
//将用户数据插入 users 集合
collection.insert(user, {
safe: true
}, function (err, user) {
mongodb.close();
if (err) {
return callback(err); //错误，返回 err 信息
}
callback(null, user[0]); //成功！err 为 null，并返回存储后的用户文档
});
});
});
};
复制代码 代码如下:
//读取用户信息
User.get = function(name, callback) {
//打开数据库
mongodb.open(function (err, db) {
if (err) {
return callback(err);//错误，返回 err 信息
}
//读取 users 集合
db.collection('users', function (err, collection) {
if (err) {
mongodb.close();
return callback(err);//错误，返回 err 信息
}
//查找用户名（name键）值为 name 一个文档
collection.findOne({
name: name
}, function (err, user) {
mongodb.close();
if (err) {
return callback(err);//失败！返回 err 信息
}
callback(null, user);//成功！返回查询的用户信息
});
});
});
};
这里一个写数据，一个读数据，处理程序有了，现在需要在index.js前面加上如下程序
复制代码 代码如下:
var User = require('../models/user.js');
再修改其中的app.post('/register')
复制代码 代码如下:
app.post('/register', function (req, res) {
var name = req.body.name;
var pwd = req.body.password;
var newUser = new User({
name: name,
password: pwd
});
newUser.save(function (err, user) {
//相关操作，写入session
res.send(user);
});
});
然后点击注册后便会有反应了
如果此时不能确定是否写入数据库，便可进入数据库查询一番，首先切换至数据库目录
复制代码 代码如下:
D:\mongodb\bin>
输入：
复制代码 代码如下:
mongo
然后切换其数据库连接至blog
复制代码 代码如下:
use blog
最后输入
复制代码 代码如下:
db.users.find()
我们大家就开心的看到数据写入了，于是今天的学习暂时告一段落
结语
今天我们跟着一篇博客完成了从安装到写入数据库的操作，明天让我们来将其它方面加入，逐步深化nodeJS的学习
您可能感兴趣的文章: