Node.js(Express) + MongoDBで全件検索したときのクライアントの閉じ方がわからない。

Question

Node.js(Express)とMongoDBで全件検索をしたときのクライアントの閉じ方がわかりません。

router.get("/*", (req,res)=>{
    MongoClient.connect(CONNECTION_URL, OPTIONS, (error, client)=>{
        var db = client.db(DATABASE);
        db.collection("cars").find({})
        .toArray((error, docs)=>{
            if(error){
                res.status(500);
                client.close(); 
            }else{
                console.log(docs);
                res.render("./show/index.ejs", {docs});
                client.close();
        }});
    });
});

本当はif(error){client.close()}else{client.close()}と別々に記述するのではなく、最後に.then(()=>{client.close()})と記述したいのですが、エラーが発生します。

当方初学者のため、とんちんかんなことをしてしまっているかもしれませんが、よろしければ有識者の皆様からお知恵を貸していただけると大変助かります。

Answer 1

そもそもの所でNode.jsの強みが消えますので
コネクションは基本的に閉じずに運用してください。

というわけでコネクションを閉じない運用の提案をしていきます。
MongoDBにはコネクションプールという機能が存在します
参考サイト: 公式サイトドキュメント#コネクションプール

MongoClient connection pooling

A Connection Pool is a cache of database connections maintained by the driver so that connections can be re-used when new connections to the database are required. To reduce the number of connection pools created by your application, we recommend calling MongoClient.connect once and reusing the database variable returned by the callback:

和訳

MongoClient コネクションプール
コネクションプールとは、ドライバが管理するデータベース接続のキャッシュのことで、 データベースへの新しい接続が必要になったときに接続を再利用できるようにします。アプリケーションが作成するコネクションプールの数を減らすには、 MongoClient.connect を一度コールしてコールバックで返されたデータベース変数を再利用することをお勧めします。

解説しますと、Webサーバは同時に何百人というユーザがWebサービスを利用しようと訪れる可能性があります。
その何百人が一斉にrouter.get("/*", fn)に押し寄せたとすると、
MongooDBサーバにその何百人分のコネクションよこせが来るので最初の3人だけ受け付けて、残り数百人はエラーという結果になりかねません。
(MongoDBというアプリもそこまでヤワな作りでは無いでしょうし、実際にはそれなりに上手くやるでしょうけどね)

その対策としてコネクションプールという機能が存在します。
プールは学校とかにある水が張っていて泳げるプールを指します。
水面にビート板のように接続状態のコネクションを投げ入れておき、利用者が取れるような仕組みになっています。
(MySQL等の他のデータベースにもある、わりとよくある作戦です)

コネクションプールを使いNode.jsとMongoDBを接続させますと、
予め3本の接続を予約しておいてすぐ使える状態にします。
(この時の接続本数は設定により自由に変更が可能です)

100人のユーザーが訪れた場合、最初の3人に接続を使わせておき
残り97人には「ちょっと待ってろ」と待たせます。
3本の問い合わせは、問い合わせ完了後、コネクションプールに接続を返しに来ます。

接続がコネクションプールに帰ってきたら4人目、5人目という風に
順番待ちしている人たちに接続を使わせるという仕組みになります。

コードに関してはドキュメントの下にあります
軽くコメントで注釈入れつつ、一緒に見ていきましょう。

var express = require('express');
var mongodb = require('mongodb');
var app = express();

var MongoClient = require('mongodb').MongoClient;
// 予めコネクションプール用の変数を宣言しておく
var db;

// 初期処理としてMongoDBのコネクションを確保する
MongoClient.connect("mongodb://localhost:27017/integration_test", function(err, database) {
  if(err) throw err;

  // MongoDBとの接続が完了したらコネクションプール用の変数へ代入
  db = database;

  // MongoDBとの接続が完了してからExpress.jsを立ち上げるのだ
  app.listen(3000);
  console.log("Listening on port 3000");
});

// 改めてExpress.jsの設定を記述していく
app.get("/", function(req, res) {
  // コネクションプール利用時の書き方は特に変わらない
  // こうするだけで勝手に順番待ちを作って解決してくれる
  db.collection("replicaset_mongo_client_collection").find({}, function(err, docs) {
    docs.each(function(err, doc) {
      if(doc) {
        console.log(doc);
      }
      else {
        // コネクションを閉じる記述の必要無し
        res.end();
      }
    });
  });
});

Answer 2

私の場合、こんな感じでコーディングしたりします。
よろしかったら参考にしてください。

router.get("/*", (req, res) => {

    let query = {..........};

    MongoClient.connect(CONNECTION_URL, OPTIONS, (error, client) => {
        let db = client.db(DATABSE);

        Promise.all([
            db.collection(..........)
                .find(query)
                ..........
                .toArray()
        ]).then((results) => {
            let data = {
                ..........
                }
            };
            res.render("index.ejs", data);
        }).catch((error) => {
            throw error;
        }).then(() => {
            client.close();
        });
    });
});

module.exports = router;