Класс и возрат результата

[diakon]

Только начал изучать Node.js. До этого писал как на php так и на python. Но в ноде все своеобразное. Я хочу сделать класс соединения с БД, и 2мя методами - получения данных и вставики данных (selec и insert) в БД. Я сделал класс

class Db {
    constructor() {
        this.mysql = require('mysql');

        this.sql = this.mysql.createConnection({
            host: "127.0.0.1",
            database: "sql-test-db",
            user: "root",
            password: ""
        });
        this.sql.connect(function(err) {
            if (err) throw err;
        });
    }

    query(sql) {
        this.sql.query(sql, function (err, result) {
            if (err) throw err;

            return result;
        });
    }

    insert(sql, params) {
        this.sql.query(sql + ' ?', params, (err, results, fields) => {
            if (err) throw err;
        })
    }
}
module.exports = Db;

Далее в файле index.js я его получаю и пытаюсь передать в переменную результат SELECT запроса

const Db = require(__dirname + '/models/Db');

let db = new Db();
let result = db.query("SELECT * FROM tbl_chat_room_users");
console.log(result);

Но в итоге получаю undefined Я понимаю, что это связано с тем, что нода асинхронный язык и в момент выполнения console.log(result); в result еще не пришли данные из класса Db, но как тогда реализовывать работу с классами? Я пытался решить проблему через события. Сделать так что бы в db.query вместо return создавалось событие emit('returnSql', result), а потом вне класса (в index.js) пытаться его ловить на on, но ничего не сработало да и выглядит кастыльно. Можете подсказать, в чем я ошибся? Заранее спасибо!

[diakon]

Я так же пробовал переписать класс на async / await

class Db {
    constructor() {
        this.mysql = require('mysql');

        this.sql = this.mysql.createConnection({
            host: "127.0.0.1",
            database: "fastweb-yii2",
            user: "root",
            password: ""
        });
        this.sql.connect(function(err) {
            if (err) throw err;
        });
    }

    async query(sql) {
        return await this.sql.query(sql, function (err, result) {
            let reultsQuery = {};
            if (err) throw err;
            result.forEach(function(rowData, index) {
                reultsQuery[index] = rowData;
            });

            return reultsQuery;
        });
    }

    insert(sql, params) {
        this.sql.query(sql + ' ?', params, (error, results, fields) => {
            if (error) { throw error }
        })
    }
}
module.exports = Db;

но в результате возвращает Promise { <pending> }
Можнете сказать в чем ошибка?

[Aetae]

2. async функция всегда возвращает промис. По сути своей async/await - это синтаксический сахар позволяющий неявно создавать сложные цепочки промисов и не более того.

1. Классическое решение: забыть про построчное написание кода и передавать вторым параметром callback и вызывать оный по завершению запроса.

//...
  query(sql, callback) {
        this.sql.query(sql, function (err, result) {
            if (err) throw err;
 
            callback(result);
        });
}
//...
function nextStep(result) {
   console.log(result);
}
db.query("SELECT * FROM tbl_chat_room_users", nextStep);

Современное решение: использовать async/await и выполнять нужную цепочку в рамках async функции:

(async function(){

  let result = await db.query("SELECT * FROM tbl_chat_room_users");
  console.log(result);
  //...

}())

[diakon]

Но вот в том то и дело, что хочется реализовать CMV модель, где классы выполняли классическую роль - возвращая данные, а не выполняли те функции, которые должен делать контроллер - частная обработка данных. Неужели в node (читай js) это так плохо реализуется?

[Aetae]

Асинхронность, паря, асинхронность. Не сделаешь ты асинхронне операции синхронными. В любых языках. Классы тут не при чём.