您的位置：首页 > 数据库 > Mongodb

Nodejs 邂逅 Mongodb

2013-08-25 20:42 204 查看

基于Nodejs和MongoDB，读取数据库中产品的列表

var http = require("http"),
mongo = require("mongodb"),
events = require("events");

http.createServer(function(req, res) {

var products_emitter = new events.EventEmitter(),
// 创建到northwind数据库的链接。相当于use northwind
db = new mongo.Db("northwind", new mongo.Server('localhost', 27017, {}), {});

var listener = function(products) {
var html = [], len = products.length;
html.push('<!DOCTYPE html>');
html.push('<html>');
html.push('<head>');
html.push('<title>Nodejs</title>');
html.push('</head>');
html.push('<body>');
if(len > 0) {
html.push('<ul>');
for(var i = 0; i < len; i++) {
html.push('<li>' + products[i].name + '</li>');
}
html.push('</ul>');
}
html.push('</body>');
html.push('</html>');

res.writeHead(200, "Content-Type: text/html");
res.write(html.join(''));
res.end();

clearTimeout(timeout);
}
products_emitter.on('products', listener);

var timeout = setTimeout(function() {
products_emitter.emit('products', []);
products_emitter.removeListener('products', listener);
}, 10000);

db.open(function() {
// 打开名为products的表
db.collection("products", function(err, collection) {
// select * from products 相当于db.products.find()
collection.find(function(err, cursor) {
cursor.toArray(function(err, items) {
products_emitter.emit('products', items);
});
});
});
});

}).listen(8000);

console.log("Started");

网上找了上面这段代码［原文］，执行了下，访问http://127.0.0.1:8000/当然一开始什么也没有。

于是往数据库norhwind 的集合products(collection)插入了两条数据，shell 命令如下

> use northwind
switched to db northwind
> db.products.insert({'name':'shanshan'})
> db.products.insert({'name':'sandy'})

注意不需要预先创建一个集合，在第一次插入数据时候会自动创建。

再次刷新页面http://127.0.0.1:8000/，可以看到

内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理

标签：

相关文章推荐

新的分享

章节导航