Node.js, promise, mysql как выдать результат?

Question

[Axepec]

Добрый день.... Пытаюсь разобраться с промисами и асинхроностью node.js..

getEmail() {
    let emails = [];
      let result = new Promise( (resolve, reject) => {

        this.start();

        this.db.query('SELECT * FROM contacts', (err, res) => {
          if (!!err) {
            return console.log('Error in the Query');
          } else {

            res.forEach(function (item, i) {
              if ((item.email !== '') && (item.email !== null)) {
                emails.push(item.email);
              }
            });

            resolve( emails );
          }
        });

      });
    
    
    result.then( (result) => {
      this.end();
      console.log('i Work! And I return Result! But i last.....');
      return result;
    });

  }

и при выводе как только не пробовал

let promise = new Promise( (resolve,reject) => {
  let result = _db.getEmail();
  resolve(result);
});

promise.then( (result) => console.log(result) );

Результат выполнения:

undefined
i Work! And I return Result! But i last.....

То есть функция считает что она выполнена, а потом выполняется функция....

Answer 1

[Владлен Хеллсайт]

Что-то вы совсем намудрили, всё гораздо проще.

getEmail() {
	return new Promise((resolve, reject) => {
		this.start();

		this.db.query('SELECT * FROM contacts', (err, contacts) => {
			if (err) {
				reject(err);

				return;
			}

			const emails = contacts
				.map(contact => contact.email)
				.filter(Boolean);

			this.end();

			resolve(emails);
		});
	});
}

_db.getEmail()
	.then((emails) => {
		console.log(emails)
	})
	.catch((error) => {
		console.log('Error in the Query', error);
	});

По хорошему бы сделать что бы запросы к БД сразу возвращали Promise тогда это станет гораздо удобней.

Comments

[Axepec]

Спасибо! А можно еще секунду вашего времени?
"По хорошему бы сделать что бы запросы к БД сразу возвращали Promise тогда это станет гораздо удобней."
Как именно вы имеете в виду? Просто убрать из функцию обработку? Получать голый результат, а потом обрабатывать?

[Владлен Хеллсайт]

Axepec, ну я в говорил в адрес класса this.db, я думаю стоит сделать простую обёртку что бы он возвращал Promise при вызове вместо принятия callback'а. Плюс ко всему да, не совсем вижу смысл в обёртках возвращения email'ов. Так как не думаю что это хорошо когда некоторые данные просто пропадают. Да и SQL запрос с * не совсем правильное использование, так как получаете лишнии данные если нужны только email.

[Axepec]

понял, спасибо большое

Answer 2

[Coder321]

_getEmail() {
    const emails = [];
    return new Promise((resolve, reject) => {
        this.start();
        this.db.query('SELECT * FROM contacts', (err, res) => {
            if (!!err) {
                return reject('Error in the Query');
            } else {
                res.forEach(function (item, i) {
                    if ((item.email !== '') && (item.email !== null)) {
                        emails.push(item.email);
                    }
                });
                this.end();
                return resolve(emails);
            }
        });

    });
}

async getEmail(){
    try {
        const emails = await this._getEmail();
    } catch (error) {
        console.log(error);
    };
}