Nodejs结合MongoDB

neversoft

　　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('');
　　html.push('');
　　html.push('');
　　html.push('Nodejs');
　　html.push('');
　　html.push('');
　　if(len > 0) {
　　html.push('');
　　for(var i = 0; i < len; i++) {
　　html.push('' + products.name + '');
　　}
　　html.push('');
　　}
　　html.push('');
　　html.push('');
　　res.writeHead(200, &quot;Content-Type: text/html&quot;);
　　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(&quot;products&quot;, 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(&quot;Started&quot;);