使用 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 如下，我希望在 /mailer 发出 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 和 DBusername 不需要

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 或 ...