NodeJS MySQL 和 Promises - 无法读取未定义的属性“查询”？

Question

我只是在学习使用 Promise，但不确定我遇到的这个错误；

  Cannot read property 'query' of undefined

我已经简化了我的查询，但仍然出现错误。所以我猜这可能与我用于 MySQL 数据库的类有关。这是我进行查询的地方；

var createAudiopost = async function(req, res, next){     
let row_a, row_b, row_c, row_d, row_e, row_f;    
try {    
    row_a = await mydb.query( 'SELECT * FROM audioposts'); 
     
     console.log("success");  
     res.json({     "title" : title, 
                    "userid" : userid,
                    "opid" : opid, 
                    "insert
            });     
}                           
catch(err) {
    console.log(err.message);
}
finally {
    mydb.close();
        }
}

 module.exports = createAudiopost;

我在这里为 MySQL 数据库创建了一个类；

const mysql = require( 'mysql' );

let config = {
    host     : 'localhost',
    user     : 'user',
    password : 'password',
    database: 'database'
};

class DataBase {
    constructor( config ) {
        this.connection = mysql.createConnection( config );
    }
    query( sql, args ) {
        return new Promise( ( resolve, reject ) => {
            this.database.query( sql, args, ( err, rows ) => {
                if ( err )
                    return reject( err );
                resolve( rows );
            } );
        } );
    }
    close() {
        return new Promise( ( resolve, reject ) => {
            this.connection.end( err => {
                if ( err )
                    return reject( err );
                resolve();
            } );
        } );
    }
}

const mydb = new DataBase(config); 

为什么我的控制台告诉我查询未定义？

Answer 1

你需要绑定你的promise函数：

    query( sql, args ) {
        return new Promise( function ( resolve, reject ) {
            this.connection.query( sql, args, ( err, rows ) => {
                if ( err )
                    return reject( err );
                resolve( rows );
            } );
        }.bind(this) );
    }

或者你可以使用别名

    query( sql, args ) {
        let that = this;
        return new Promise( function ( resolve, reject ) {
            that.connection.query( sql, args, ( err, rows ) => {
                if ( err )
                    return reject( err );
                resolve( rows );
            } );
        });
    }