MySQLのクエリ結果の戻り値が返ってこない

Question

エラー内容

今現在、Node.jsにてexpressとMySQLを用いてプログラムを書いています。MySQLのテーブル情報（テーブル名：jobs）を呼び出すには毎回以下のプログラムを書かなくてはなりません。

connection.query(
  'select * from jobs',
  (error, results) => {
    
  }
);

手間もかかり、繰り返し使用するとネストも深くなってしまうということで、以下のように関数を用いて呼び出してみることにしました。

var getJobs = () => {
  connection.query(
    'select * from jobs',
    (error, results) => {
      return results;
    }
  );
}

app.post("/check/:id", (req, res) => {
  connection.query(
    'select * from players where id = ?',
    [req.params.id],
    (error, results) =>  {
      // ここで関数を呼び出し、返り値を出力
      console.log(getJobs());
 
      res.render('check.ejs', {players: results[0]});
    }
  );
});

すると、以下のように未定義と表示されてしまいます。

undefined

また、関数内でコンソール出力すると普通に表示されます。
なぜ返り値としてreturnするとundefinedになるのでしょうか。。。

実際のソースコード

const express = require('express');
const mysql = require('mysql');

const app = express();

app.use(express.static('public'));
app.use(express.urlencoded({ extended: false }));

// 各種変数宣言
var player = [];
var jobList = [];
var doubt = [];
var kill = [];
var divine = [];
var jobsNum;

class Player {
  constructor(i, id, job) {
    this.i = i;
    this.id = id;
    this.job = job;
  }
};

// データベース接続
const connection = mysql.createConnection({
  "host": 'localhost',
  "user": 'root',
  "password": 'muro5866',
  "database": 'werewolf'
});

connection.connect((err) => {
  if (err) {
    console.log('error connecting: ' + err.stack);
    return;
  }
});

// 関数
var getJobs = () => {
  connection.query(
    'select * from jobs',
    (error, results) => {
      return results;
    }
  );
}

var getPlayers = () => {
  connection.query(
    'select * from players',
    (error, results) => {
      return results;
    }
  );
}

var voting = (name, radio, ) => {
  if (name !== undefined) {
    String(radio).split(',');

    // console.log(radio);

    var pId = radio[0];
    var jId = radio[2];

    // console.log(pId);
    // console.log(jId);

    connection.query(
      'select * from jobs',
      (error, results) => {
        switch (results[jId-1].voting) {
          case 'doubt':
            doubt.push(pId);
            break;
          case 'divine':
            divine.push(pId);
            break;
          case 'kill':
            kill.push(pId);
            break;
        }
      }
    );
  }
  return;
}

// レンダリング処理
app.get('/', (req, res) => {
  res.render("top.ejs");
});

app.get("/top", (req, res) => {
  res.render("top.ejs");
});

app.get("/player", (req, res) => {
  connection.query(
    'select * from players',
    (error, results) => {
      res.render('player.ejs', {players: results});
    }
  );
});

app.post("/register", (req, res) => {
  connection.query(
    'insert into players (name, status) values (?, \'alive\')',
    [req.body.pname],
    (error, results) => {
      // res.render('player.ejs', {players: results});
      res.redirect('/player');
    }
  );
});

app.post("/delete/:id", (req, res) => {
  connection.query(
    'delete from players where id = ?',
    [req.params.id],
    (error, results) => {
      // res.redirect('player.ejs', {players: results});
      res.redirect('/player');
    }
  );
});

app.post("/edit/:id", (req, res) => {
  connection.query(
    'update players set name = ? where id = ?',
    [req.body.name, req.params.id],
    (error, results) => {
      // res.redirect('player.ejs', {players: results});
      res.redirect('/player');
    }
  );
});

app.get("/explanation", (req, res) => {
  res.render("explanation.ejs");
});

app.get("/back-top", (req, res) => {
  res.render("top.ejs");
});

app.get("/job", (req, res) => {
  connection.query(
    'select * from jobs',
    (error1, results1) => {
      connection.query(
        // 'select count(*) from players',
        'select * from players',
        (error2, results2) => {
          for (var i = 0; i < results2.length; i++) {
            player[i] = new Player(i, results2[i].id, undefined);
          }
          res.render('job.ejs', {jobs: results1, players:results2});
        }
      );
    }
  );
});

app.get("/settings", (req, res) => {
  res.render("settings.ejs");
});

app.get("/back-job", (req, res) => {
  res.render("job.ejs");
});

app.post("/start", (req, res) => {
  connection.query(
    'select * from players',
    (error1, results1) => {
      // 各役職の人数を配列に格納
      jobsNum = req.body.jobs;

      // 更新してしまった場合のためにPlayerの値入れ直し
      for (var i = 0; i < results1.length; i++) {
        player[i] = new Player(i, results1[i].id, undefined);
      }

      // 各プレイヤーの役職決定
      // jobListに役職idを格納
      for (var i = 0; i < Number(req.body.sum); i += j) {
        for (var j = 0; j < jobsNum[i]; j++) {
          jobList[i+j] = i + 1;
          // console.log(jobList)
        }
      }

      var len = jobList.length;

      while (len) {
        var j = Math.floor( Math.random() * len );
        var t = jobList[--len];
        jobList[len] = jobList[j];
        jobList[j] = t;
      }

      for (var i = 0; i < Number(req.body.sum); i++) {
        player[i].job = jobList[i];
        connection.query(
          'update players set jobid = ? where id = ?',
          [jobList[i], player[i].id],
          (error2, results2) => {

          }
        );
      }
      res.render("start.ejs", {players: results1[0]});
    }
  );
});

app.post("/check/:id", (req, res) => {
  connection.query(
    'select * from players where id = ?',
    [req.params.id],
    (error, results) =>  {
      // morningでも同様にラジオ取得する
      // ラジオによって投票処理
      voting(req.body.name, req.body.radioGroup);
      // var abc = [];
      // abc = getJobs();
      console.log(getJobs());
 
      res.render('check.ejs', {players: results[0]});
    }
  );
});

app.post("/night-action/:id", (req, res) => {
  connection.query(
    // このidの次のデータを合わせて取得
    'select * from players where id >= ? order by id limit 2',
    // 'select * from players where id = ?',
    [req.params.id],
    (error1, results1) =>  {
      connection.query(
        'select * from players',
        (error2, results2) => {
          connection.query(
            'select * from jobs',
            (error3, results3) => {
              var job;
              var pId;
              
              // 更新してしまった場合のためにPlayerの値入れ直し
              for (var i = 0; i < results2.length; i++) {
                player[i] = new Player(i, results2[i].id, results2[i].jobid);
              }
              // console.log(player);

              for (var i = 0; i < results2.length; i++) {
                if (player[i].id === results1[0].id) {
                  // プレイヤーのjobId
                  var id = player[i].job;
                  job = results3[id-1];
                  pId = player[i].id;
                }
              }
              // console.log('job : ' + job);

              connection.query(
                // 'update players set job = ? where id = ?',
                // [job.name, pId],
                'update players set jobid = ? where id = ?',
                [job.id, pId],
                (error4, results4) => {
                  res.render('night-action.ejs', {mplayer: results1[0], nplayer: results1[1], players: results2, job: job});
                  // res.render('check.ejs', {players: results1[0]});
                }
              );
            }
          );
        }
      )
      // console.log(results);
      // res.render('night-action.ejs', {players: results[0]});
      // res.render('check.ejs', {players: results});
    }
  );
});

app.get("/morning", (req, res) => {
  connection.query(
    'select * from players',
    (error, results) => {
      res.render("morning.ejs");
    }
  );
});

app.listen(3000);
console.log("server listening...");

試してみたこと

関数内のreturnの位置をconnection.queryの外に出してみましたが、だめでした。
どなたか、回答の方よろしくお願いします。

Answer 1

なぜ返り値としてreturnするとundefinedになるのでしょうか。。。

queryは非同期実行されますので、getJobs関数からは、クエリの実行を待たずに戻ります。つまり、通常の返り値としてクエリの結果を受け渡しすることはできません。

Comments

[vamrat]

お礼が遅くなり申し訳ございません。非同期実行が原因だったのですね、ありがとうございます。

Answer 2

原因は

var getJobs = () => {
  connection.query(
    'select * from jobs',
    (error, results) => {
      return results;
    }
  );
  // connection.queryは非同期関数なので
  // すぐにここに来る
  // 何も返してないのでundefinedになる
}

です。

解決策として

• コールバック関数を使う
• Promiseを利用する
• MySQL2 Using Promise Wrapperを利用する

Comments

[vamrat]

お礼が遅くなり申し訳ございません。なるほど、connection.query処理は非同期で処理されずに何も行われてなかったのですね。解決策の内の3つ、難しいですがなんとか理解して実装してみようと思います。ありがとうございます。