Как лучше всего писать синхронный код в Node (для последовательных запросов к БД)?

Question

[Spooky 2020]

Нужно последовательно выполнить несколько запросов к БД, каждый новый запрос зависит от результатов предыдущих.
В свое время решал это используя промисы, но получалось настолько громоздко и неудобно, что вместо Node я стал
использовать пайтон и php. Еще неудобно, что нельзя напрямую использовать this внутри connection.<methodName>()
Может сейчас уже появились более удобные способы? Подскажите куда копать/смотреть. Фрагмент кода прилагаю.

promise hell

ConstructorName.prototype.process = function() {
	const connection = mysql.createConnection({
		host: "-",
		user: "-",
		password: "-",
		database: "-"
	});
	connection.connect();

	new Promise(function (resolve, reject) {
		connection.query("SHOW TABLES", (err, results, fields) => {
			if (err) reject(err);
			results.some(item => (Object.values(item).indexOf('<tablename>') !== - 1)) 
			? resolve('таблица в порядке')
			: reject(`Таблица с именем ${'name'} не обнаружена`);
		});
	})
	.then(
		result => {
			return new Promise(function (resolve, reject) {
				connection.query(`SHOW COLUMNS FROM  <tablename>`, (err, results, fields) => {
					if (err) reject(err);
					const tableFields = results.map(item => item["Field"]);
					["<fieldname>", "<fieldname>", "<fieldname>", "<fieldname>"].every(item => tableFields.indexOf(item) !== -1)
					? resolve('Поля в порядке')
					: reject(`поле с именем ${'<fieldname>'} не обнаружено`);
				})
			})
		},
		error => { console.log(error) }
	)
	// Дальше множество аналогичного кода в .then(тоска-печаль)...
	.finally(
		() => connection.end()
	);
};

Comments

[Lynn «Кофеман»]

async/await уже давно есть

[Spooky 2020]

Lynn «Кофеман», немного сахара тут никак не поможет. Другие варианты есть?

[Lynn «Кофеман»]

Чего это не поможет?
Просто надо ещё взять что-нибудь на промисах для работы с mysql. Наверняка такие библиотеки есть.

Answer 1

[Yuriy Vorobyov]

Да, сейчас есть синтаксический сахар в виде async/await. Об этом можно прочитать здесь и здесь

ConstructorName.prototype.process = async () => {
  const connection = mysql.createConnection({
    host: "-",
    user: "-",
    password: "-",
    database: "-"
  });
  connection.connect();

  const operation = new Promise((resolve, reject) =>  {
    connection.query("SHOW TABLES", (err, results, fields) => {
      if (err) reject(err);
      results.some(item => (Object.values(item).indexOf('<tablename>') !== - 1)) 
      ? resolve('таблица в порядке')
      : reject(`Таблица с именем ${'name'} не обнаружена`);
    });
  });

  try {
    const result = await operation;

    const newOperation = new Promise(function (resolve, reject) {
      connection.query(`SHOW COLUMNS FROM  <tablename>`, (err, results, fields) => {
        if (err) reject(err);
        const tableFields = results.map(item => item["Field"]);
        ["<fieldname>", "<fieldname>", "<fieldname>", "<fieldname>"].every(item => tableFields.indexOf(item) !== -1)
        ? resolve('Поля в порядке')
        : reject(`поле с именем ${'<fieldname>'} не обнаружено`);
      })
    });

    await newOperation;
  } catch (error) {
    console.log(error);
  } finally {
    connection.end();
  }
};

Comments

[Spooky 2020]

Спасибо за развернутый ответ. Я в курсе про async/await, но было познавательно у видеть как их можно применить конкретно в моем случае. Но даже с ними, "традиционные" языки для этого удобнее, увы :(

P.S.
Кстати, у меня тут в коде используется не правильный подход использования промиса, но никто и внимания не обратил. Специалисты, блин :))