Nodejs + MongoDB

基于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/,可以看到

 

郑重声明:本站内容如果来自互联网及其他传播媒体,其版权均属原媒体及文章作者所有。转载目的在于传递更多信息及用于网络分享,并不代表本站赞同其观点和对其真实性负责,也不构成任何其他建议。