使用Express连接到MongoDB

Question

我无法理解需要做什么才能连接到MongoDB，因此我可以将一个对象插入到数据库中。我对使用Express以及MongoDB并不熟悉，但对这两者还没有充分的把握。

我使用标准Express设置创建的app.js如下。

var express = require('express'); 
var path = require('path'); 
var favicon = require('serve-favicon'); 
var logger = require('morgan'); 
var cookieParser = require('cookie-parser'); 
var bodyParser = require('body-parser'); 
var ex_session = require('express-session'); 
var dateformat = require('dateformat'); 

var MongoClient = require('mongodb').MongoClient; 
var ObjectID = require('mongodb').ObjectID; 
var url = 'mongodb://localhost:27017/contacts' 

var index = require('./routes/index'); 

var app = express(); 

// view engine setup 
app.set('views', path.join(__dirname, 'views')); 
app.set('view engine', 'ejs'); 

// uncomment after placing your favicon in /public 
//app.use(favicon(path.join(__dirname, 'public', 'favicon.ico'))); 
app.use(logger('dev')); 
app.use(bodyParser.json()); 
app.use(bodyParser.urlencoded({ extended: false })); 
app.use(cookieParser()); 
app.use(express.static(path.join(__dirname, 'public'))); 

app.use('/', index); 

// catch 404 and forward to error handler 
app.use(function(req, res, next) { 
    var err = new Error('Not Found'); 
    err.status = 404; 
    next(err); 
}); 

// error handler 
app.use(function(err, req, res, next) { 
    // set locals, only providing error in development 
    res.locals.message = err.message; 
    res.locals.error = req.app.get('env') === 'development' ? err : {}; 

    // render the error page 
    res.status(err.status || 500); 
    res.render('error'); 
}); 

module.exports = app; 

我index.js如下：什么我想发生这样的是，当一个POST请求由/发邮件，连接，以便建立一个插入到MongoDB的制造。

var express = require('express'); 
var router = express.Router(); 
var url = 'mongodb://localhost:27017/contacts'; 
var contacts; 

/* GET home page. */ 
var start = function(req, res, next){ 
    console.log("Starting!"); 
    res.render('mailer',{}); 
} 

router.get('/', start); 
router.get('/mailer', start); 

/* Post mailer Page insert into database*/ 
router.post('/mailer', function(req, res, next){ 
    res.render('thanks'); 
    console.log("Welcome to the Thank You Page"); 

    MongoClient.connect(url, function(err, db){ 
    if(err == NULL){ 
     console.log("Connected to database"); 

     // parse the body of the page and set up object to send to the     
     // database 

    } 
    }); 

    }); 



router.get('/contact', function(req, res){ 
    res.render('contact', {}); 
}) 

module.exports = router; 

Answer 1

*快递，

var mongo = require('mongodb'); 
     var MongoClient = mongo.MongoClient;  
     MongoClient.connect('mongodb://'+DB_USERNAME+':'+DB_PASSWORD+'@'+DB_HOST+':'DB_PORT+'/'+DB_NAME,function(err, db){ 
       if(err) 
       console.log(err); 
       else 
       { 
       console.log('Mongo Conn....'); 

       } 
      }); 

//本地服务器快递 //在本地服务器DBPASSWOAD和数据库用户名不需要

MongoClient.connect('mongodb://'+DB_HOST+':'+DB_PORT+'/'+DB_NAME,function(err, db){ 
     if(err) 
     console.log(err); 
     else 
     { 
     console.log('Mongo Conn....'); 

     } 
    }); 

Answer 2

你的代码是超级混乱，我可以显示你的我的配置，你可以参考。

db.js 
import mongoose from 'mongoose'; 

export default function connectDB() { 
    mongoose.Promise = global.Promise; 
    mongoose.connect('mongodb://localhost:27017/contacts'); 
    mongoose.connection.once('open', function() { 
     console.log('mongodb connected.'); 
    }); 
}; 


app.js 
import connectDB from "db.js"; 

connectDB(); 


user.model.js 
import mongoose from 'mongoose'; 

const schema = mongoose.Schema({ 
    email: {type: String, required: true}, 
    mobile: {type: String}, 
    password: {type: String, required: true}, 
}); 

const User = mongoose.model('User', schema, 'user'); 

export default User; 

然后在你的路由器文件ü可以调用User.find（）或User.update或...