Как мне сделать массив полученные значение из mysql?

Question

[hollanditkzn]

Сделал запрос в бд

let user = ctx.state.user[0];
        let sql = 'SELECT id_theme FROM access WHERE id_user = ?';
        let themes = db.query(sql, [user.id], async (err, result) => {
            if(err) console.error(err);
            console.log(result);
            await result;
        });

У меня на выходе я получаю такие данные

[ RowDataPacket { id_theme: 1 },
  RowDataPacket { id_theme: 2 },
  RowDataPacket { id_theme: 3 },
  RowDataPacket { id_theme: 2 },
  RowDataPacket { id_theme: 3 } ]

Только в pug я не могу его загнать

each theme in themes
                     p=theme

Потому что это объект, а как мне сделать его массивом?

Cannot convert object to primitive value

Пробовал еще

так

await JSON.stringify(result);

но тоже не помогло

Answer 1

[Abcdefgk]

Если вам непременно хочется писать слова async и await, и непременно хочется получить результат запроса в переменную themes, то нужно напейсать примерно так:

asyncFoo();
async function asyncFoo() {
  var themes = await new Promise( resolve => {
    var sql = 'SELECT id_theme FROM access WHERE id_user = ?';
    db.query(sql, [user.id], (err, result) => {
      if(err) console.error(err);
      resolve(result);
    });
  }).then( result => {
    return result;
  };
  console.log(themes);
  // тут его в pug и передавать
}

Стоит ли так заморачиваться ради модных async/await? - Ну, кому-то нравится.

Comments

[hollanditkzn]

Abcdefgk Просто как я знаю запрос к бд должен быть асинхронным и поэтому я использую asnc/await так как это уже привычка в использование koa

[Abcdefgk]

hollanditkzn, Ну, я вот обновил недавно Ноду на компе до восьмой версии и теперь упражняюсь - как можно прикрутить async/await туда, где оно не нужно и бессмысленно.
Можно, конечно, написать и callback-функцию как async (хотя в методе query() драйвера она вызывается как обычный callback, но раз слова модные - можно и написать)

db.query(sql, [user.id], async (err, result) => {
  if(err) console.error(err);
  var res = await Promise.resolve(result);
  console.log(res);
});

Но это ещё более бессмысленно: в переменной res - то же самое, что и в переменной-аргументе result.
А запрос к БД - не "должен быть асинхронным", а он и есть - асинхронный. Поэтому результат запроса и передаётся в аргумент вызова callback-функции, который (вызов) внутри метода query где-то в конце и сделан. От того, что к анонимной функции приписали модное слово async - этому вызову не холодно и не жарко.

[Abcdefgk]

Хе. Ну что вы делаете этим async?
Вот я пишу функцию с колбеком, а потом её вызову:

function foo(callback) {
	var x = 'asdfg';
	callback(x);
}
foo( data => {
	console.log(data);   // asdfg
});

Но можно написать и "круто, как положено в koa":

function foo(callback) {
	var x = 'asdfg';
	callback(x);
}
foo( async data => {
	var data = await Promise.resolve(data);
	console.log(data);   // asdfg
});

[hollanditkzn]

Abcdefgk, У меня такой вопрос, я немного переделал свои код и хотелось понять как это работает
Я создал модель где собираю все sql

запросы

let db = require('../bin/db');
global.Promise = require('bluebird');

let User = {
    theme: function(id){
        return requestUser('SELECT id_theme FROM access WHERE id_user = ?', id);
    }
};

function requestUser(sql, req){
    return new Promise((resolve, reject) => {
        db.query(
            sql,
            [req],
            (err, rows) => {
                if(err) reject(err);
                resolve(rows);
            });
    });
}

module.exports = User;

И в роуте я указал

const User = require('./model/user');
...
.get('/index', async ctx => {
        if(!ctx.isAuthenticated()){
            await ctx.redirect('/');
        }
        let user = ctx.state.user[0];
        let themes = await User.theme(user.id).then(theme => {
            return theme;
        });
        await ctx.render('index', {
            title: 'Главная страница',
            userBy: user,
            themes: themes,
        });
    })

Почему вот именно так работает await User.theme(user.id).then(
там же как бы 2 await выходит.

[Abcdefgk]

hollanditkzn, Во-первых, я не понимаю, что это за метод - User.theme()
Но если это работает, то значит - это "промисифицированная функция" (вообще, в mongoose теперь все методы промисифицированны), то есть она возвращает Promise, она внутри вот такая

function theme(userId) {
  return new Promise( resolve => {
    var theme = ... // здесь код нахождения нужных данных и передачи их, допустим, в переменную theme
    resolve(theme);
  });
}

Теперь, когда она вызвана -User.theme(... - она вернула "промис в ожидании", и остаётся из её resolve данные забрать и применить куда надо. Применить можно либо дальше в then

User.theme(user.id).then(theme => {
  ctx.render('index', {
    title: 'Главная страница',
    userBy: user,
    themes: themes,
  });
});

и тогда async-функция не нужна
Либо, если сильно хочется async/await, то тогда этот колбек-обработчик объявляется как async (как у вас), в then промисифицированной функции пишется не окончательный код, а return (опять же, как у вас), а await - это какбэ команда забрать этот return и отдать в переменную
let themes = await User.theme(...
Лично мне вот эта возможность передачи в переменную данных из Promise представляется единственной настоящей ценностью этих async-функций.
Ну, а await вот здесь
await ctx.render('index',...
тут я уж не знаю - либо оно лишнее, либо они в koa и метод render() написали промисифицированным. Я ещё в Koa не ковырялся подробно.

[Abcdefgk]

hollanditkzn, А! Ну я там не открыл сразу за метод theme(), но оно так и оказалось

function requestUser(sql, req){
    return new Promise((resolve, reject) => {
        db.query(
            sql,
            [req],
            (err, rows) => {
                if(err) reject(err);
                resolve(rows);
            });
    });
}

"промисифицированная функция".
Не понятно тогда, чего я объяснял?

[hollanditkzn]

Abcdefgk, Просто этот запрос не единственный, и так не пробовал. User.theme(...) это то что я в моделе прописал

[Abcdefgk]

hollanditkzn, Не, я увидел - и это нормально сделано, убедительно.

[Abcdefgk]

hollanditkzn, Кстати, эту функцию можно дополнить так:

function requestUser(sql, req){
    return new Promise((resolve, reject) => {
        db.query(
            sql,
            [req],
            (err, rows) => {
                if(err) reject(err);
                resolve(rows);
            });
    }).then( rows => { return rows; });
}

И тогда вызов в обработчике будет короче:
let themes = await User.theme(user.id);
Ну это так, по желанию. ...then хоть там - хоть там.

[Abcdefgk]

А вот ещё что (раз уж сегодня тема - Koa).
Как я догадываюсь, в Koa объект ctx.state - это то же самое, что в Express объект res.locals.
И если я правильно догадываюсь, то вы им не правильно пользуетесь (если я правильно, повторю, догадываюсь). Это, должно быть, то "пространство имён", которое в метод ctx.render() передаётся автоматически.
Это значит, что надо примерно так в обработчике:

if(!ctx.isAuthenticated()){
  await ctx.redirect('/');
}

var state = ctx.state;

var user = state.user[0];                 // чтоб ваш код дальше так же работал
state.title = 'Главная страница';
state.userBy = user;

let themes = await User.theme(user.id).then(theme => {
  return theme;
});
state.themes = themes;

await ctx.render('index');     // хотя, await мне тут продолжает казаться лишним

В метод render передаётся только имя шаблона, а всё остальное уже там автоматически.
Попробуйте на досуге. (и если это так, то я буду считать, что практически разобрался с этим Koa, чиста интуитивно; если попробуете - сообщите о результате).

[hollanditkzn]

Abcdefgk, Раньше я пробовал без await но у меня если честно не получалось. Да и вообще посмотрел render там не включен, надо отдельно его включать koa-view. Но посмотрю на досуге. Просто без него у меня ничего не работает. По крайне мере в роутах не загружает страницу

[Abcdefgk]

hollanditkzn, Нет, может это специфика Koa такая - просто буду знать.
Но я не про await здесь, а про ctx.state
Судя по вашему коду, вы уже каким-то мидловером, выше по стеку запроса, в этот объект добавляете массив юзеров, оттуда берёте let user = ctx.state.user[0];
Ну да ладно, я всего не вижу.

[hollanditkzn]

Abcdefgk, Да он нормально работает так то

[Abcdefgk]

hollanditkzn, Должен быть лучшее Экспресса (в теории, по крайней мере). Как-нибудь доберусь до него. Просто, я сейчас знакомством с Go занят, и меня, как-то, ломает переключаться.

Answer 2

[RidgeA]

Ну, вообще-то в callback возвращается массив

spoiler

если не учитывать что массив в js это частный случай объекта

А как там pug с этим работает не знаю.

Есть подозрение, что эта проблема из-за неправильнй работы с async/await - зачем оно вообще там?

let themes = db.query(sql, [user.id], async (err, result) => {
            if(err) console.error(err);
            console.log(result);
            await result;
        });

Comments

[hollanditkzn]

Нет не в этом деле

[hollanditkzn]

RidgeA переменная theme сама отдает также запрос бд, пот почему не может вывести, то есть там подключение и query все это включилось в переменную theme. А как сделать так чтобы вернуть ответ на запрос?

[RidgeA]

hollanditkzn, а какой магией ответ из функции callback должен попасть в `themes` ?

[hollanditkzn]

RidgeA, Пока я не понял, вот что дает

console.log(themes)

Query {
  domain: null,
  _events: {},
  _eventsCount: 0,
  _maxListeners: undefined,
  _callback: [AsyncFunction],
  _callSite: Error
    at Pool.query (C:\OpenServer\domains\trainingPortal\node_modules\mysql\lib\Pool.js:199:23)
    at router.get.get (C:\OpenServer\domains\trainingPortal\router.js:19:25)
    at dispatch (C:\OpenServer\domains\trainingPortal\node_modules\koa-router\node_modules\koa-compose\index.js:44:32)
    at next (C:\OpenServer\domains\trainingPortal\node_modules\koa-router\node_modules\koa-compose\index.js:45:18)
    at C:\OpenServer\domains\trainingPortal\node_modules\koa-router\lib\router.js:345:16
    at dispatch (C:\OpenServer\domains\trainingPortal\node_modules\koa-router\node_modules\koa-compose\index.js:44:32)
    at C:\OpenServer\domains\trainingPortal\node_modules\koa-router\node_modules\koa-compose\index.js:36:12
    at dispatch (C:\OpenServer\domains\trainingPortal\node_modules\koa-router\lib\router.js:350:31)
    at dispatch (C:\OpenServer\domains\trainingPortal\node_modules\koa-compose\index.js:42:32)
    at next (C:\OpenServer\domains\trainingPortal\node_modules\koa-compose\index.js:43:18)
    at p.then.cont (C:\OpenServer\domains\trainingPortal\node_modules\koa-passport\lib\framework\koa.js:144:16)
    at <anonymous>
    at process._tickCallback (internal/process/next_tick.js:188:7),
  _ended: false,
  _timeout: undefined,
  _idleNext: null,
  _idlePrev: null,
  _idleStart: null,
  _idleTimeout: -1,
  _repeat: null,
  sql: 'SELECT id_theme FROM access WHERE id_user = ?',
  values: [ 1 ],
  typeCast: true,
  nestTables: false,
  _resultSet: null,
  _results: [],
  _fields: [],
  _index: 0,
  _loadError: null }

[RidgeA]

hollanditkzn, предлагаю разобраться как в js работать с асинхронными функциями и как обрабатывать результат вызова функций в callback. Понимание этого механизма - один из ключевых моментов в JS.