在Node.JS中寻找从MongoDB读取的帮助

我有一些存储在MongoDB中的记录我试图通过Node.JS http服务器将它们输出到浏览器窗口.我认为我是一个很好的部分,但我错过了一些小东西,使它不能实际工作.

下面的代码使用Node-mongo-native连接到数据库.

如果周围有人可以帮助我在节点中进行最后几次连接,我真的很感激.公平地说,我确信这只是一个开始.

var sys  = require("sys");
var test = require("assert");
var http = require('http');

var     Db              = require('../lib/mongodb').Db,Connection      = require('../lib/mongodb').Connection,Server          = require('../lib/mongodb').Server,//BSON          = require('../lib/mongodb').bSONPure;
        BSON            = require('../lib/mongodb').bSONNative;

var     host = process.env['MONGO_NODE_DRIVER_HOST'] != null ? process.env['MONGO_NODE_DRIVER_HOST'] : 'localhost';
var     port = process.env['MONGO_NODE_DRIVER_PORT'] != null ? process.env['MONGO_NODE_DRIVER_PORT'] : Connection.DEFAULT_PORT;

sys.puts("ConnecTing to " + host + ":" + port);

function PutItem(err,item){
    var result = "";
    if(item != null) {
            for (key in item) {
                    result += key + '=' + item[key];
            }
    }
    // sys.puts(sys.inspect(item))  // debug output
    return result;
}

function Readtest(){
    var db = new Db('mydb',new Server(host,port,{}),{native_parser:truE});
    var result = "";
    db.open(function (err,db) {
            db.collection('test',function(err,collection) {
                    collection.find(function (err,cursor){
                            cursor.each( function (err,item) {
                                    result += PutItem(err,item);
                            });
                    });
            });
    });
    return result;
}

http.createServer(function (req,res) {
  res.writeHead(200,{'Content-Type': 'text/plain'});
  res.end("foo"+Readtest());
}).listen(8124);
console.log('Server running on 8124');

资料来源：
– mongo连接代码：
https://github.com/christkv/node-mongodb-native/blob/master/examples/simple.js
– 节点. http代码：nodejs.org

编辑正确的代码

感谢下面的Mic让我朝着正确的方向前进.对于任何感兴趣的人,更正的解决方案是：

function ReadTest(res){
    var db = new Db('mydb',{native_parser:truE});
    var result = "";
    res.write("in readtest\n");
    db.open(function (err,db) {
            res.write("@L_772_13@ open\n");
            db.collection('test',collection) {
                    res.write("in collection\n");
                    collection.find(function (err,cursor){
                            res.write("found\n");
                            cursor.each( function (err,item) {
                                    res.write("@L_772_13@ open\n");
                                    var x = PutItem(err,item);
                                    sys.puts(X);
                                    res.write(X);
                                    if (item == null) {
                                            res.end('foo');
                                    }
                            });
                    });
            });
    });
}

http.createServer(function (req,res) {
    res.writeHead(200,{'Content-Type': 'text/plain'});
    res.write("start\n");
    ReadTest(res);
}).listen(8124);
console.log('Server running on 8124');

function readTest(res) {
    db.open(function (err,db) {
        db.collection('test',collection) {
            collection.find(function (err,cursor) {
                res.writeHead(200,{'Content-type' : 'text/plain'});
                cursor.each( function (err,item) { res.write(item); });
                res.end();
     ...