mysqlに接続する処理を書いているがawait/asyncが機能しない。

Question

typescript+node.jsを用いてMysqlに接続する処理を書いています。接続が失敗した時には間隔を置いて最大5回までリトライするようにしたいと考えているのですが、リトライ処理が完了する前に結果が返ってきてしまいます。接続処理が成功した時にはtrueを、失敗したときにはfalseを返す仕組みにするにはどうすればよいでしょうか。お知恵を拝借したく思います。よろしくお願いいたします。

接続処理側のコード

const mysql = require('mysql');
let connection;
let cnt = 0;


export const cm_dbconnect =  async() => {

    var dbInfo = {
      host     : '127.0.0.1',
      user     : '****',
      password : '**********'
    }

    let db =  mysql.createConnection(dbInfo);
    
    const attemptConnection = async() => {
    console.log('Attempting to connect to db')
   
    
    
    db.connect(async function (err) {
      if (err) {
        
        cnt += 1;
        console.log('Error connecting to database, try again in 1 sec...')
        db.destroy() 
        if (cnt<5) {
        console.log(cnt);
        
        function settimeoutpromise() {
            return new Promise((resolve, reject) => {
                setTimeout(() => {
                cm_dbconnect();
                resolve("end")
            }, 1000);
        })}
        await settimeoutpromise();
    
        } 
      } 
    })
    
    
  }
  await attemptConnection()

            
  
  module.exports  = db;
  if(cnt<5) {
  return  {result: true, errCode: "", errDetail: ""};
  } else {
  return  {result: false, errCode: "", errDetail: ""};
  }

}

コントローラー側のコード

export const Controller = async () => {
   

    let connect = await cm_dbconnect();
          
    let db = require('');
    let sql = 'select *** from ***;';
    db.query(sql, function (error, results, fields) {
    console.log(results);
      
    })
    
    console.log("aaaa");
    console.log(connect);


       }
let test = Controller();

結果

Attempting to connect to db
aaaa
{ result: true, errCode: '', errDetail: '' }
Error connecting to database, try again in 1 sec...
1
undefined
Attempting to connect to db
Error connecting to database, try again in 1 sec...
2
Attempting to connect to db
Error connecting to database, try again in 1 sec...
3
Attempting to connect to db
Error connecting to database, try again in 1 sec...
4
Attempting to connect to db
Error connecting to database, try again in 1 sec...

Answer 1

残念ながら、mysqlライブラリはasync-awaitに対応していません（コールバックにasync関数を渡しても、返り値のPromiseを活かす場がないので無意味です）。

async-awaitに持ち込みたければ、自分でnew Promiseしてコールバックでresolveやrejectを行う必要があります。

（なお、それを行ったmysql-awaitというパッケージも存在するようです）

Comments

[coldr]

ご回答ありがとうございます。私としてはリトライ接続のあとに結果が返って来るのであれば、コールバック、await/asyncどちらを用いても構わないのですが、どのような構成になるかもう少し具体的にご教授いただくことは可能でしょうか。

[maisumakun]

ループで何度も繰り返すような場合は、async-awaitを使うほうが圧倒的に楽です。

[coldr]

ご回答ありがとうございます。今回の構成でasync/awaitを用いるとなると、今までコールバックを用いてエラーハンドリングしていた箇所を何か別の指標を用いてDBに接続できたか否か判別しなければならないと思うのですが、何を用いればよいか分かりかねています。何かテスト用のSELECT文を打って疎通確認してもよいのですが、もう少しエレガントな手法があればご教授いただきたいです。

[maisumakun]

awaitで受けたPromiseがrejectとなった場合、awaitが例外を投げますので、例外処理として対応が可能です。

[coldr]

ご回答ありがとうございます。例えば
msql.createConnection({
host: '127.0.0.1',
user: '***',
password: '****',
}).then(()=>{console.log("aaa")})
.catch(()=>{console.log("bbb")})
とすることでハンドリングすることは可能だと思いますが、msql.createConnectionから返却されたpromiseを変数に格納し、rejectかresolveかを判別するということは可能なのでしょうか。初歩的な質問で恐縮ですが、ご教授よろしくお願いいたします。

[maisumakun]

> msql.createConnectionから返却されたpromiseを変数に格納し、rejectかresolveかを判別するということは可能なのでしょうか。

すでに書いたように、Promiseをawaitで受ければ、rejectの場合例外となるのでtry-catchで処理できます（awaitなしでPromiseのまま受け取った場合、同期的に状態は変化しませんので、そもそも何もできません）。

[maisumakun]

> 接続処理が成功した時にはtrueを、失敗したときにはfalseを返す仕組みにするにはどうすればよいでしょうか。

同期的に結果を返すことは不可能です。その関数自体がPromiseを返すような形を取る（async-awaitで書いてもそうなる）しかありません。

[coldr]

ご助言頂いた通り実装したところ、意図していたように動作しました。誠にありがとうございました。