async.series с мангустой

Question

var mongoose = require('mongoose');
var mongoDB = "mongodb://jananton:password1@ds020168.mlab.com:20168/test_database";
var User = require('./models/User.js');
var async = require('async');

function establishConnection() {
  mongoose.connect(mongoDB, {
    useNewUrlParser: true
  }).then(
    () => {
      console.log("Connection successful")
    },
    (err) => {
      console.log("Warning!" + err)
    }
  );
  mongoose.Promise = global.Promise;
  var db = mongoose.connection;
  db.on('error', console.error.bind(console, 'MongoDB connection error:'));
}

let users = [];

function createUser(user_name, user_status, user_position) {
  var newUser = new User({
    Name: user_name,
    _id: new mongoose.Types.ObjectId(),
    Status: user_status,
    Position: user_position
  });
  newUser.save((err) => {
    if (err) {
      console.log(err);
    }
  });
  console.log(newUser.Name);
  users.push(newUser);
};

//Call both functions, starting with establishConnection
async.series([
    establishConnection,
    createUser("Andy", "Administrator", "Whatever"),
  ],
  function(err, res) {
    mongoose.connection.close();
  })

В приведенном выше коде я просто подключаюсь к базе данных MongoDB, размещенной на mLab, с помощью метода EstabConnection (). Вторая функция, createUser, создает документ и сохраняет его в базе данных. Затем обе функции вызываются из функции async.series () с выводом на консоль

Andy
Connection successful

Я не понимаю, почему Andy выводится первым, только затем Соединение успешно регистрируется, так как createConnection () предшествует createUser (). Кроме того, mongoose не закрывает соединение (см. Функцию обратного вызова функции async.series). Может кто-нибудь объяснить мне, почему?

Answer 1

Так что вам нужно исправить использование async.series. async.series требует, чтобы каждая функция вызывала функцию обратного вызова, когда ее выполнение завершено, поэтому ряд работает правильно.

async.series([
    function(callback) {
        // do some stuff ...
        callback(null, 'one');
    },
    function(callback) {
        // do some more stuff ...
        callback(null, 'two');
    }
],
// optional callback
function(err, results) {
    // results is now equal to ['one', 'two']
});

так что в вашем случае вам нужно сделать это так,

var mongoose = require('mongoose');
var mongoDB = 
 "mongodb://jananton:password1@ds020168.mlab.com:20168/test_database";
var User = require('./models/User.js');
var async = require('async');

function establishConnection(callback) {
  mongoose.connect(mongoDB, {
    useNewUrlParser: true
  }).then(
    () => {
      console.log("Connection successful")
      callback(null, "Connection successful");
    },
    (err) => {
      console.log("Warning!" + err)
      callback(err);
    }
  );
  mongoose.Promise = global.Promise;
  var db = mongoose.connection;
  db.on('error', console.error.bind(console, 'MongoDB connection error:'));
}

let users = [];

function createUser(user_name, user_status, user_position, callback) {
  var newUser = new User({
    Name: user_name,
    _id: new mongoose.Types.ObjectId(),
    Status: user_status,
    Position: user_position
  });
  newUser.save((err) => {
    if (err) {
      console.log(err);
      return callback(err);
    }
  });
  console.log(newUser.Name);
  users.push(newUser);
  return callback(null, newUser);
};

//Call both functions, starting with establishConnection
async.series([
    establishConnection,
    createUser("Andy", "Administrator", "Whatever", callback),
  ],
  function(err, res) {
    mongoose.connection.close();
  })

Надеюсь, это поможет вам.