Функция возвращающая данные полученные из БД, как правильно написать?

Question

[Антон]

Нужно написать функцию, которая принимает строку SQL-запрос, и возвращает массив полученных из БД данных. Добился только чтобы данные выводились в консоль внутри функции, но как сделать чтобы функция возвращала данные не могу понять. Код:

const Connection = require('tedious').Connection;
const Request = require('tedious').Request;
const { request } = require('http');
const config = require('./config_db');

const connection = new Connection(config);
connection.on('connect', (err) => {err ? console.log(err) : select(query)});

const select = (query) => {
    request = new Request(query);
    request.on('row', (columns) => {
        columns.map(column => {
            console.log(column.value)
        })
    })
    connection.execSql(request)
    return request
};

module.exports = select;

Но такая функция ничего не возвращает.

Я добился чтобы возврат был, но очень большим костылем, типа такого:

const Connection = require('tedious').Connection;
const Request = require('tedious').Request;
const { request } = require('http');
const config = require('./config_db');
const addState = require('./state').addState; // функция делает push в state


const connection = new Connection(config);
connection.on('connect', (err) => {err ? console.log(err) : select(query)});

const select = (query) => {
    request = new Request(query);
    request.on('row', (columns) => {
        columns.map(column => {
            addState(column.value)
        })
    })
    connection.execSql(request)
    const state = require('./state').state // импортирую именно сдесь, потому что если импортировать раньше вернется пустой state
    return state
};

module.exports = select;

Так он еще срабатывает только на второй раз. :)
Как сделать, чтобы функция возвращала данные?

Comments

[Дмитрий Гололобов]

Почитай про промисы и async/await

[Антон]

Дмитрий Гололобов, я в курсе про промисы и асинхронность. Пробовал и с помощью них написать функцию, все равно не возвращает сразу, только через описаный мною второй способ.

Answer 1

[Дмитрий Беляев]

const select = (query) => new Promise((resolve, reject) => {
  const request = new Request(query);
  request.once('error', reject);
  request.once('done', (rowCount, more, rows) => {
    resolve(rows.map(
      columns => columns.map(
        column => column.value
      )
    ));
  });
  connection.execSql(request);
});

Comments

[Антон]

Дмитрий, тут я вообще не понимаю, что вернет эта функция? Нет же return’а.

[Антон]

Дмитрий Беляев, извиняюсь. Туплю. Функция же стрелочная.
Спасибо за ответ.

[Антон]

Дмитрий Беляев, Дмитрий, у вас ошибка в синтаксисе. Не может функция промис возвращать.

[Дмитрий Гололобов]

Антон, ну вот какой же вы упертый человек.
Функция, которую вам написали, вернет промис, который в случае успешного выполнения вернет вам (resolve) массив данных:

rows.map(
      columns => columns.map(
        column => column.value
      )
    )

А в случае ошибки вернет ошибку.
Вызвать вы ее сможете с помощью асинк/авейта например:

try {
   const resultOfSelect = await select(query)
} catch (err) {
   console.log('oops', err)
}