Node.jsでのデータベース接続とリソース解放の正しい方法

Webアプリケーションを開発する際、データベースと接続する処理は不可欠です。
しかし、適切にリソースを管理しないと、接続が解放されずにシステムの負荷が増大する可能性があります。
本記事では、Node.jsを使用したデータベース接続の適切な管理方法について解説します。

データベース接続を適切に管理する重要性

データベースに接続した後、処理が終了しても接続を解放しないと、以下のような問題が発生します。

これらを防ぐため、データベース接続は適切に解放する必要があります。

データベース接続の一般的な流れ

データベースを使用する際、以下のような流れで接続を管理します。

1. 接続の確立：データベースと通信するための接続を取得する
2. 処理の実行：SQLを発行し、データの取得や登録を行う
3. 接続の解放：使用した接続を閉じ、リソースを適切に開放する

この流れの中で、接続を確実に解放しないと、システムの負荷が増し、最悪の場合、データベースにアクセスできなくなることがあります。

適切な接続管理の実装例

以下の例では、データベース接続を適切に取得し、エラー発生時でも確実に接続を解放する方法を紹介します。

適切なデータベース接続の実装例

const express = require('express');
const { check, validationResult } = require('express-validator');
const router = express.Router();

// ルートハンドラー
router.put('/delete',
  [check('id').not().isEmpty()],
  async (req, res) => {
    // バリデーションチェック
    const errors = validationResult(req);
    if (!errors.isEmpty()) {
      return res.status(400).json({ errors: errors.array() });
    }

    let client;
    try {
      // データベース接続
      client = await req.database.connect();
      
      // データ更新処理（例: 削除フラグの更新）
      const result = await someLogicFunction(client, req);
      
      // 正常終了
      return res.status(200).json(result);
    } catch (err) {
      // エラー処理
      console.error('エラー:', err);
      return res.status(500).json({ message: err.message });
    } finally {
      // 接続解放
      client?.release();
    }
  }
);

ポイント解説

1. バリデーションチェック
   • express-validator を使用してリクエストデータの検証を行い、不正なデータの処理を防ぎます。
2. let client; で変数を事前に宣言
   • try ブロックの中で代入するため、関数のスコープ内で定義。
3. 適切なエラーハンドリング
   • try...catch 構文を用いてエラーを適切にキャッチし、res.status(500).json({ message: err.message }) でエラーメッセージを返します。
4. データベース接続を await req.database.connect(); で取得
   • await を使用して、非同期処理が完了するまで待機。
5. 処理が終わった後は finally で client?.release(); を呼び出し
   • try や catch でエラーが発生しても、 finally 内のコードは必ず実行される。
   • ? を入れることで、接続が確立していない場合に release() を実行しないようにしている。

接続解放の確認方法

接続が適切に解放されているかを確認するには、ログ出力を活用します。

client.release();
console.log(client);

この出力結果を確認し、_connected: false などのステータスが表示されていれば、正常に解放されていることが分かります。

よくあるミスとその対策

接続を解放しない

const handleRequest = async (req, res, action) => {
  const client = await req.database.connect(); // 接続取得
  try {
    const results = await action(client, req, res);
    return res.status(200).json(results);
  } catch (err) {
    console.error('エラー発生:', err);
    return res.status(500).json({ message: '内部エラーが発生しました' });
  }
  // client.release() がないため、接続が解放されずリソースが枯渇する
};

client が未定義のまま release() を呼び出す

const handleRequest = async (req, res, action) => {
  let client;
  try {
    const results = await action(client, req, res); // clientが未定義のまま使用される
    return res.status(200).json(results);
  } catch (err) {
    console.error('エラー発生:', err);
    return res.status(500).json({ message: '内部エラーが発生しました' });
  } finally {
    client.release(); // clientが未定義の可能性があり、エラーが発生する
  }
};

まとめ

データベース接続を適切に管理しないと、リソースの枯渇やエラーの原因となります。
本記事で紹介した方法を参考に、適切な接続管理を行い、安全なシステムを構築してください。

重要なポイント

これらのポイントを押さえることで、安全で効率的なデータベース接続管理が可能になります。

• Original:https://minory.org/node-db-connect.html
• Source:minory
• Author:管理者

Amazonベストセラー