0

Есть функция для втавки в монго:

function insert_to_mdb (db_data) {
var mdb_url = 'mongodb://localhost:27017/DB';
mongodb.connect(mdb_url, function(err, db) {
  if (err) throw err;
    db.collection('test').insert(db_data, function(err, records) {
        if (err) throw err;    
        db.close();
    });
});
}

Далее пробую

for (var i = 0; i < 500; i++) {
var test_json_str = {'DATA': '123456' };
    insert_to_mdb(test_json_str);
};

И получаю

mongo_client.js:409
      throw err
            ^
Error: connection closed

Причём это только на больших вставках, как я понимаю, просто кончаются пул или свободные соеденения к БД. Как с этим можно бороться?

1
  • Половина вопроса решена, цикл for блокирует nextTick в libuv, но вопрос, как сбросить все подключения всё равно актуален.
    – user26807
    24 мар 2015 в 14:33

1 ответ 1

1

callback - callback function to run after the record is inserted, а это значит, что ты закрыл коннект после первого insert-a.

8
  • но в ф-ции есть новый коннект, к тому же если дело было бы в коннекте, то она бы вообще не вставляла большое кол-во, а она не может вставить, если for больше 100, на 50-ти работает 50/50
    – user26807
    23 мар 2015 в 14:42
  • По хорошему, нужно соединяться с базой лишь однажды, а не внутри цикла. Функция асинхронная, и когда новый коннект открыт, старый вызов может его закрыть. В общем, у вас в коде довольно конфликтная ситуация.
    – zhenyab
    23 мар 2015 в 14:45
  • @vnn198, ты закомментируй close и посмотрим 23 мар 2015 в 14:47
  • ну тогда приложение не закроется, ибо висит открытая связб с монго
    – user26807
    23 мар 2015 в 15:04
  • @vnn198, закроется 23 мар 2015 в 15:19

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge you have read our privacy policy.