使用 Node.js、Express、AngularJS 和 MongoDB 构建-3
|
- UID
- 1066743
|
使用 Node.js、Express、AngularJS 和 MongoDB 构建-3
第 3 步. 使用 Mongoose 在 MongoDB 中存储数据为了存储数据，该应用程序使用了 MongoDB 驱动程序和 Mongoose npm 模块。它们允许应用程序与 MongoDB 数据库进行通信。要获得这些模块，请打该应用程序根目录中的 package.json 文件，并在依赖关系部分中添加以下这些代码行：。
清单 10. 向依赖关系添加下列代码1
2
| "mongodb": ">= 1.3.19",
"mongoose": ">= 3.8.0",
|
保存文件，在 Project Explorer 中右键单击并选择 Run As > npm install。这将安装 npm 模块和其他所有依赖关系。
创建一个 Mongoose 模型在您应用程序的名为 models 的根目录中创建一个新的子目录，并在这个子目录中创建一个名为 Poll.js 的新文件。在这个文件中，我们定义了我们的 Mongoose 模型，该模型将用于查询数据，并以结构化数据的形式将这些数据保存到 MongoDB 。
清单 11. models/Poll.js 1
2
3
4
5
6
7
8
9
10
| var mongoose = require('mongoose');
var voteSchema = new mongoose.Schema({ ip: 'String' });
var choiceSchema = new mongoose.Schema({
text: String,
votes: [voteSchema]
});
exports.PollSchema = new mongoose.Schema({
question: { type: String, required: true },
choices: [choiceSchema]
});
|
定义数据存储的 API 路由接下来，在您应用程序的根目录下的 app.js 文件中设置一些路由，以便创建一些 JSON 端点，这些端点可用于根据 Angular 客户端代码来查询和更新 MongoDB。找到 app.get('/', routes.index) 行，并将下列代码添加到这一行的后面：：
清单 12. 创建 JSON 端点1
2
3
| app.get('/polls/polls', routes.list);
app.get('/polls/:id', routes.poll);
app.post('/polls', routes.create);
|
现在，您需要实现这些功能。将 routes/index.js 文件的内容替换为下列代码：
清单 13. routes/index.js1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
| var mongoose = require('mongoose');
var db = mongoose.createConnection('localhost', 'pollsapp');
var PollSchema = require('../models/Poll.js').PollSchema;
var Poll = db.model('polls', PollSchema);
exports.index = function(req, res) {
res.render('index', {title: 'Polls'});
};
// JSON API for list of polls
exports.list = function(req, res) {
Poll.find({}, 'question', function(error, polls) {
res.json(polls);
});
};
// JSON API for getting a single poll
exports.poll = function(req, res) {
var pollId = req.params.id;
Poll.findById(pollId, '', { lean: true }, function(err, poll) {
if(poll) {
var userVoted = false,
userChoice,
totalVotes = 0;
for(c in poll.choices) {
var choice = poll.choices[c];
for(v in choice.votes) {
var vote = choice.votes[v];
totalVotes++;
if(vote.ip === (req.header('x-forwarded-for') || req.ip)) {
userVoted = true;
userChoice = { _id: choice._id, text: choice.text };
}
}
}
poll.userVoted = userVoted;
poll.userChoice = userChoice;
poll.totalVotes = totalVotes;
res.json(poll);
} else {
res.json({error:true});
}
});
};
// JSON API for creating a new poll
exports.create = function(req, res) {
var reqBody = req.body,
choices = reqBody.choices.filter(function(v) { return v.text != ''; }),
pollObj = {question: reqBody.question, choices: choices};
var poll = new Poll(pollObj);
poll.save(function(err, doc) {
if(err || !doc) {
throw 'Error';
} else {
res.json(doc);
}
});
};
|
使用 Angular 服务将数据绑定到前端此时，设置后台，以便启用查询，并将问卷调查数据保存到数据库，但我们需要在 Angular 中做一些更改，以便让它知道如何与数据库进行通信。使用 Angular 服务很容易完成这项任务，它将与服务器端进行通信的过程包装到了简单的函数调用中：
清单 14. public/javascripts/services.js1
2
3
4
5
6
| angular.module('pollServices', ['ngResource']).
factory('Poll', function($resource) {
return $resource('polls/:pollId', {}, {
query: { method: 'GET', params: { pollId: 'polls' }, isArray: true }
})
});
|
在创建的这一文件之后，您需要将它包括在您的 index.jade 模板中。在文件标头部分的最后一个脚本元素的下面添加以下这行代码：
script(src='/javascripts/services.js')。
您还需要告诉您的 Angular 应用程序使用这个服务模块。要实现这一点，请打开 public/javascripts/app.js 并将第一行更改为可读，如下所示：
angular.module('polls', ['pollServices'])。
最后，更改 Angular 控制器，以便使用该服务在数据库中进行查询和存储问卷调查数据。在 public/javascripts/controllers.js 文件中，将 PollListCtrl 更改如下：。
清单 15. public/javascripts/controller.js1
2
3
4
| function PollListCtrl($scope, Poll) {
$scope.polls = Poll.query();
}
...
|
更新 PollItemCtrl 函数，以便根据问卷调查的 ID 来查询某个问卷调查：
清单 16. public/javascripts/controller.js (continued)1
2
3
4
5
6
| ...
function PollItemCtrl($scope, $routeParams, Poll) {
$scope.poll = Poll.get({pollId: $routeParams.pollId});
$scope.vote = function() {};
}
...
|
类似地，更改 PollNewCtrl 函数，以便在提交表单时将新调查数据发送到服务器。 |
|
|
|
|
|
