コールバック関数内から値を返す方法

Question

前提・実現したいこと

Node.js + MySQLで開発を行ています。
DBに特定のIDが登録されているかどうかの値(bool型)を返す関数を作成したいと思っております。
(Node.js（JavaScript）での開発はこれが初めてとなります。)

発生している問題・エラーメッセージ

下記のコードでtrueになるような引数を与えてもfalseしか返ってきません。

該当のソースコード

修正1

var http = require('http');
const mysql = require('mysql');
const connection = mysql.createConnection({
    host: '',
    user: 'aaa',
    password: 'bbb',
    port: '3306'
});

async function isRegistered(id) {
    var result = false;

    var query = `SELECT EXISTS (SELECT * FROM hoges WHERE id = '${id}') as result;`;  
    await connection.query(query, (err, rows, fields) => {
        result = Boolean(rows[0].result); // ★3番目に呼ばれる
    });

    return result; // ★1番目に呼ばれる
}

// 呼び出し元
http.createServer(async function (req, res) {
    if (req.method == 'POST') {
        var result = awit isRegistered('hogehoge');   
        console.log(result.resolve);// ★2番目に呼ばれる
    }
}).listen(8080);

試したこと

Node.jsの経験が浅いので断定できませんが、
非同期処理のため想定している値と別の値が返ってきてしまうのだと考えています。
(err, rows, fields) => {}の前にasyncなどを付けて試してみましたが、解決には至りませんでした。
解決策をご存知であれば、ご教授よろしくお願いいたします。

補足情報（FW/ツールのバージョンなど）

VisualStudio 2019
Node.js v12.18.3

Answer 1

素のmysqlパッケージはPromiseを使えないようなのでコールバックで延々繋いでいくしかないと思います。Promiseを使えればawaitも使えると思うので良かったら、

https://www.npmjs.com/package/promise-mysql

あたりを試してみるのもいいかもしれません。(試してません)

const mysql = require('mysql');
const connection = mysql.createConnection({
    host: '',
    user: 'aaa',
    password: 'bbb',
    port: '3306'
});

function isRegistered(id, resolve) {
    var result = false;

    var query = `SELECT EXISTS (SELECT * FROM hoges WHERE id = '${id}') as result;`;
    connection.query(query, (err, rows, fields) => {
        result = Boolean(rows[0].result);
        resolve(result);
    });
}

isRegistered('hogehoge', (result)=>{
    console.log(result);
});

一応promise-mysqlのサンプルも書いときました。

const mysql = require('promise-mysql');

(async () => {
    const connection = await mysql.createConnection({
        host: 'localhost',
        user: 'homestead',
        database: 'homestead',
        password: 'secret',
        port: '13306'
    });

    const rows = await connection.query(`SELECT * FROM item;`);
    console.log(rows);
    connection.end();
})();

最後に上のサンプルをmysqlを使って自前のPromiseで処理するとすると...

const mysql = require('mysql');

async function mysql_createConnection(option) {
    return Promise.resolve(mysql.createConnection(option));
}

async function connection_query(connection, query) {
    return new Promise((resolve, reject) => {
        connection.query(query, (error, results, fields) => {
            if (error) {
                reject(error);
            } else {
                resolve(results);
            }
        });
    })
}

(async () => {
    const connection = await mysql_createConnection({
        host: 'localhost',
        user: 'homestead',
        database: 'homestead',
        password: 'secret',
        port: '13306'
    });

    const rows = await connection_query(connection, `SELECT * FROM item;`);
    console.log(rows);
    connection.end();
})();

Comments

[kawauso]

ご回答ありがとうございます。
promise-mysqlはまだ試せていませんが、その他2点の方法で動作が確認できました。
助かりました。ありがとうございました！

Answer 2

async await は、普通は、こういう風に付けるかと思いますが、

async function isRegistered(id) {
:
    await connection.query(query, (err, rows, fields) => {
        result = Boolean(rows[0].result);
    });

mysql.createConnection
の動作がわからないので、なんともです。

戻り値、ではなくて、グローバル的な値をコールバック側で書き換えたほうがわかりやすいかもしれないです。

非同期処理はややこしいもんです。

Comments

[kawauso]

ご回答ありがとうございます。
mysqlに関する記述、関数呼び出し元を追記しました。

（質問文 修正1）async/awaitを回答のように付け加えてみました。そうすると次はtrueしか返ってこなくなりました。デバッグで追いかけましたが、isRegisteredのresultにはきちんとfalseが代入されていましたが、なぜか呼び出し元ではtrueが返ってきてしまいます。

（質問文 修正2）グローバル変数で試してみましたが、今度はresultがundefinedのままでした。

[kawauso]

申し訳ございません。修正1ですが.resolveをつけていませんでした。
result.resolveの結果はundefinedとなってしまいます。
デバッグしているとisRegisteredのreturn resultまでいかないのですが、何か原因をご存知でしょうか。

[standard-soft]

```
http.createServer(async function (req, res) {
if (req.method == 'POST') {
var result = await isRegistered('hogehoge');
console.log(result);
}
}).listen(8080);
```

追加部分のところ、こうではないかと思うのです。
実行環境が用意できないので、あてずっぽうで申し訳ないところですが。

[kawauso]

ご回答ありがとうございます。
ご回答のように試してみましたが、実行と同時にプログラムが終了してしまいます。
エラー文等も出力されませんでした。

[kawauso]

何度も申し訳ございません。落ちるのはこちらのミスでした。
質問文のコードの★印のところにブレークポイントを打って検証してみるとコールバック内の値が最後に呼び出されていることが分かりました。
なので、デフォルト値として代入しているfalseが返ってきしまっているようです。

[standard-soft]

connection.query
が、async関数ではないようですね。
connection.query( に渡しているコールバック関数で行いたいことを実装するしか、
ないような気がします。

mysql.createConnection
などのサンプルに非同期処理のところで、何かサンプルを検索して真似してみるとかでしょうか。

このくらいのことしかわかりませんでした。
すいません、大してお力になれずです。

[kawauso]

回答ありがとうございます。
いろいろ調べてみたいと思います。解決できれば追記します。
お付き合い頂きありがとうございました。