expressでMySQLからデータ取得時に500エラー("Can't add new command when connection is in closed state)が発生

Question

###前提・実現したいこと
同じリクエストを何回行ってもMySQLから必要なデータを取得できるようにしたい。
(後の実装でブラウザからDBへ検索をかけたときに、データを取得してブラウザで表示できるようにしたいため)

###発生している問題・エラーメッセージ
MySQLからデータを取得するリクエスト(http://localhost:3001/api)を出した際、初回はデータを取得できるのですが2回目以降は下記エラーが発生してしまい取得できません。

Error: Can't add new command when connection is in closed state
    at Connection._addCommandClosedState (/mnt/c/temp/comic_20211026/node_modules/mysql2/lib/connection.js:148:17)
    at Connection.end (/mnt/c/temp/comic_20211026/node_modules/mysql2/lib/connection.js:855:26)
    at Query.onResult (/mnt/c/temp/comic_20211026/backend/index.js:38:20)
    at Connection._addCommandClosedState (/mnt/c/temp/comic_20211026/node_modules/mysql2/lib/connection.js:153:11)
    at Connection.query (/mnt/c/temp/comic_20211026/node_modules/mysql2/lib/connection.js:546:17)
    at /mnt/c/temp/comic_20211026/backend/index.js:34:14
    at Layer.handle [as handle_request] (/mnt/c/temp/comic_20211026/node_modules/express/lib/router/layer.js:95:5)
    at next (/mnt/c/temp/comic_20211026/node_modules/express/lib/router/route.js:137:13)
    at Route.dispatch (/mnt/c/temp/comic_20211026/node_modules/express/lib/router/route.js:112:3)
    at Layer.handle [as handle_request] (/mnt/c/temp/comic_20211026/node_modules/express/lib/router/layer.js:95:5)

該当ソースは以下になります。

const express = require('express')
const mysql = require('mysql2')
const app = express()
const port = process.env.PORT || 3001

app.get('/', (req, res) => {
  res.send('Hello World!')
})

console.log("connection定義開始");
const connection = mysql.createConnection({
  host: 'localhost',
  user: 'testuser001',
  password: 'Testuser001&',
  database: 'comic'
});
console.log("connection定義終了");

app.get("/api", (req, res) => {
  connection.query(
    'SELECT * FROM `list`',
    function(err, results, fields) {
      if(err) {
        connection.end();
        console.log("接続終了(異常)");
        throw err;
      }
      res.json({message: results[0].title});
    }
  )
  connection.end();
  console.log("接続終了(正常)");
});

app.listen(port, () => {
  console.log(`listening on *:${port}`);
})

###試したこと
最後に「connection.end()」とやっていることが原因で2回目以降のリクエストに失敗していると考え、connection.query()を実行する前にconnectメソッドを呼び出すようにしてみました。

connection.connect((err) => {
  if (err) {
    throw new err("接続失敗");
  }
  console.log("接続成功");
})

しかし、その方法を取り入れても同様のエラーが出てしまいます。。。

###考えられること
初回はデータが取れて2回目以降が取れなくなっているということで、おそらくMySQL関連の実装に
問題がありそうというところまでは想像できます。ただ、対処法が思いつかずこちらに質問を出している次第です。

###補足情報（FW/ツールのバージョンなど）
Node.js:14.16.1
npm:6.14.12
mysql2:2.3.3
express:4.17.1

Answer 1

古い質問に回答するのもなんですが...

結論から言うと、解決策は

• query()の第二引数に渡すコールバック内でend()を実行する

ということになりますね。
理由はベストアンサーの方が書かれているように、JSの非同期処理の仕様に依っています。
もしもっと楽にやるなら、Promiseでラップすべきでしょう(mysql2のPromise版がこれをやっています)。

ここで補足すべきだと思ってこの回答を書いていますが、「コネクションを切断すべきではない」はさすがに語弊があるかと。
おそらくベストアンサーの方が言いたいのは、コネクションをプーリングして使い回すべきだ、という事ではないでしょうか。
少なくともそれをやらない限り、一連の処理(例えば1リクエスト)の最後で切断はマストになります。

Answer 2

Node.jsのサンプルでコネクションを勝手に閉じ始めるサンプルコードが多いですが
そもそもコネクションは閉じない方が良いです。
コネクションを閉じるのはCtrl+CによるSIGINT等の停止命令が出た時だけです。

なので今回の問題を解消するのに必要な事は、
コード内のconnection.end()を全て捨てる事です。

---

もっと正確にお行儀よくやりたいなら
Node.js API (process) - シグナルイベント
この記事の「シグナル受信イベント」の項目を確認してください。

process.on('SIGINT', () => {
  connection.end();
});

終了時に非同期操作を実行する方法
余談ですがbeforeExitはイベントループを全てこなすまで待つので無意味ですね。
Webサーバは稼働中一生イベントループが途切れる事がないので。
まぁ、ここまでお行儀よくやる必要はないかと思いますが。

---

app.get("/api", (req, res) => {
  connection.query(
    'SELECT * FROM `list`',
    function(err, results, fields) {
      if(err) {
        connection.end();
        console.log("接続終了(異常)");
        throw err;
      }
      res.json({message: results[0].title});
    }
  )
  connection.end();
  console.log("接続終了(正常)");
});

JavaScriptのルールにより、
非同期処理はイベントループの向こう側に飛ばす事になります。

console.log(1);
setTimeout(
  () => console.log(2),
  0
);
console.log(3);
// 1 => 3 => 2の順番で表示される

上記のコードは0ミリ秒を待つという処理で実行した瞬間に動作は達成しています、
じゃあなんで「1, 3, 2」の順番になるんだよ。「1, 2, 3」になるだろ？という話ですが、
setTimeoutの実現順番が既存の処理を上から全て実行した後、
イベントループの仕組みで巡回してきて「おっ、達成条件である0ミリ秒をクリアしているな？では実行しよう」という風に後から実行するからです。

なのでfunction (err, results,fields) {}の関数の中身は、
少なくとも下のconnection.end()が実行された後になります。
順番が制御出来てないのでそこに書くべきではありません。

Comments

[yuki_20211108]

ご回答いただきありがとうございます。
「connection.end()」は必要ないんですね・・・。
参考にしていたサイトのほとんどが「connection.end()」を入れていたのですが、
あまり深く理解しないまま使ってしまっていました(汗)

とても丁寧な回答ありがとうございました！