用nodejs插入mongodb

我试图插入一些数据在我的mongodb与nodejs每当套接字发射。 这里是代码:

io.sockets.on( "connection",function( socket ){ socket.on( "send", function( data ) { console.log(data.name + " and the content is: " + data.content); mongodb.connect( "mongodb://127.0.0.1", function( err, db ) { if(err) throw err; var to_be_inserted = {name: data.name,content: data.content}; db.collection("chat").insert(to_be_inserted,function(err,objects){ if(err) throw err; }); }) }) }) 

但是每当我去我的mongo控制台并input

 db.chat.find() 

我无法find插入的logging。 我敢肯定,我有mongod打开,我敢肯定,套接字发射。 而且插入之前的consoloe.log确实有效。

这是我的mongo客户端

 var mongodb = require("mongodb").MongoClient; 

我的控制台运行nodejs服务器不会logging任何错误。

您应该指定一个数据库名称(这里是: myDatabase )和一个端口号(为了安全)。

 mongodb.connect("mongodb://127.0.0.1:27017/myDatabase", function( err, db ) { 

在mongo shell中searchlogging的时候试试:

 use myDatabase db.chat.find() 

你忘了包含MongoDB的端口号和数据库,

 MongoClient.connect('mongodb://127.0.0.1:27017/test', function(err, db) { if (err) throw err; console.log("Connected to Database"); } 

试试这个代码

  var MongoClient=require('mongodb').MongoClient; var Server=require('mongodb').Server; var mongoc=new MongoClient(new Server("localhost",27017)); mongoc.open(function(err) { db.collection(<collection_name>).insert(<query>,function(err,result) { 

});

 const http = require('http'); const hostname = '127.0.0.1'; const port = 8081; var express = require("express"); var bodyParser = require('body-parser'); var app = express(); var MongoClient = require('mongodb').MongoClient; var url = "mongodb://localhost:27017"; app.use(bodyParser.json()); app.get('/get', function (req, res) { res.send('Hello World') }) var data = { title: 'my title', content: 'my content' }; // This responds a POST request for the homepage app.post('/say/:userid', function (req, res) { var queryParameter=JSON.stringify(req.query); res.send('Hello POST'+req.params.userid+""+queryParameter); }) app.post('/insert', function (req, res) { console.log(req.body); res.send('Hello POST'+JSON.stringify(req.body)); /* var MongoClient = require('mongodb').MongoClient; var url = "mongodb://localhost:27017"; */ MongoClient.connect(url, function(err, db) { if (err) throw err; var dbase = db.db("mydb"); var myobj = { name: JSON.stringify(req.body.name), address:JSON.stringify(req.body.address) }; dbase.collection("student").insertOne(myobj, function(err, res) { if (err) throw err; console.log("1 document inserted");