Как достать данные с модуля который дергает базу, nodejs/express?

Question

[cester]

Добрый день! Очень прошу объяснить!
Что использовать в данном случае, чтобы это был не гавнокод и все работало?
Написал модуль который достает данные из базы. Как получить данные из базы ясно!
не ясно как дальше их передать в другой модуль, как мне получить респонс с этого модуля?
Пожалуйста объясните хотя бы чем это делается, в какую сторону смотреть?
В идеале это был бы какой-то пример.
Спасибо!
Сам модуль

function getDataFromDatabase() {
	var arr = []
	var con = mysql.createConnection(conf.config);
	return con.connect(function (err) {

		if(err) throw err;
		con.query("SELECT DID, DName FROM Device")
		.on('result', function (data) {

			arr.push(data)
		})
		.on('end', function () {
			return JSON.stringify(arr)

		})
	});
}

getDataFromDatabase()
module.exports.getDataFromDatabase = getDataFromDatabase;

Comments

[Abcdefgk]

Вы сначала скажите, зачем их передавать в другой модуль.

[cester]

Abcdefgk, ну мне кажется что это было бы нормально вынести код в другой модуль и в этом модуле уже просто вызвать функцию с какими-то параметрами. и далле передать на клиент.
Буду благодарен за рекомендации по best practice

[de1m]

cester, да это правильно. А то потом получаются скрпипты по тысячи строк.

[Abcdefgk]

Самый (почти) дедовский способ.
this_module

function getDataFromDatabase(callback) {
  var arr = []
  var con = mysql.createConnection(conf.config);
  con.connect(function (err) {

    if(err) throw err;
    con.query("SELECT DID, DName FROM Device")
    .on('result', function (data) {
      arr.push(data)
    })
    .on('end', function () {
      var result = JSON.stringify(arr)
      callback(result);
    });
  });
}

exports.getDataFromDatabase = getDataFromDatabase;

another_module

require('./this_module').getDataFromDatabase(function(result) {
    console.log(result);               // оно тут
});

[cester]

Abcdefgk, Спасибо !

Answer 1

[de1m]

Можено сделать с callback'ом

var getDataFromDatabase = function () {
  var arr = []
  var con = mysql.createConnection(conf.config);
  con.connect(function (err) {

    if(err) throw err;
    con.query("SELECT DID, DName FROM Device")
    .on('result', function (data) {
      arr.push(data)
    })
    .on('end', function () {
      return callback(null, arr);
    })
    .on('error', function(err){
        return callback (err, null);
    });
}

module.exports = {
    getDataFromDatabase
}

Потом вызываете

var fromDB = require(./modulName);
fromDB.getDataFromDatabase(function(err, result){
    if(err){
        console.log(err);
    } else {
        console.log(result);
    }
})

Можно сделать через промис

var getDataFromDatabase = function (callback) {
    return new Promise((resolve, reject) => {
        var arr = []
        var con = mysql.createConnection(conf.config);
        con.connect(function (err) {

            if (err) throw err;
            con.query("SELECT DID, DName FROM Device")
                .on('result', function (data) {
                    arr.push(data)
                })
                .on('end', function () {
                    return resolve(arr);
                })
                .on('error', function (err) {
                    return reject(err);
                })
        });
    })
}

module.exports = {
    getDataFromDatabase
}

Вызов

var fromDB = require("./modulName");
fromDB.getDataFromDatabase()
    .then(result =>{
        console.log(result);
    },(err)=>{
        console.log(err);
    })

Ну и через асинхрнные функции тоже

var getDataFromDatabase = async function (callback) {
    return new Promise((resolve, reject) => {
        var arr = []
        var con = mysql.createConnection(conf.config);
        con.connect(function (err) {

            if (err) throw err;
            con.query("SELECT DID, DName FROM Device")
                .on('result', function (data) {
                    arr.push(data)
                })
                .on('end', function () {
                    return callback(null, arr);
                })
                .on('error', function (err) {
                    return callback(err, null);
                })
        });
    })
}

module.exports = {
    getDataFromDatabase
}

Вызов

var fromDB = require("./modulName");
var test = await fromDB.getDataFromDatabase();

Возможно я где-то ошибся, писал по памяти.
Вот тут я почти всё писал на асинхронных функциях может быть что-то полезное найдёте.

Comments

[cester]

Спасибо !) Но что-то последний пример не работает, матерится на await.
Еще вопрос, какой из этих вариантов рекомендуется использовать (сейчас вроде первый вариант быстрее выполняется)

[de1m]

cester, я так подозреваю, что выбор это на любителя.
Вторые для способа больше смотрятся, как попытка сделать из асинхронного языка снова синхронный, наверное это для тех, кто начинал с чего-то другого. Я как-раз начинал с node.js, поэтому особо проблемы с callback'ами нету.
И вам советую этой всей фигнёй не заморачиваться, делайте как удобнее. Если всётаки надо что-то делать друг за дружкой, то я всётаки советую await/async, это вроде как более современный способ.