Как упростить и оптимизирвоать запрос mysql в node.js?

Question

[Ilya78rus]

Всем привет.
Имеются запросы в бд с проверкой на актуальность и пополнением баланса. Необходимо оптимизировать запрос, возможно сократив время обработки. Тк иногда запрос даже не обрабатывается. Приложение высоконагруженное и необходима быстрота отработки запроса (ибо одновременно может быть более 1000 таких запросов на пополнение баланса). У самого сделать это не получается, поэтому прошу помощи у вас, выручите пожалуйста

$app.mysql.getConnection(function(err, connection) {
            if(err) {
              self.error('[Balance2] '+ err);
              return;
            }
            connection.query("SELECT * FROM `trade_log` WHERE `tradeId` = ? and `status` = 'send'", offer.tradeofferid, function(err, rows, fields) { //Тут проверка имеется ли такая запись в бд
              if(err) {
                self.error('[Balance3] '+ err);
                return;
              }
              if(typeof rows[0] == "undefined") {
                return;
              }

              connection.query('UPDATE `trade_log` SET status = "success" WHERE tradeId = ?', offer.tradeofferid, function(err, results) { //Если имеется, то ставим статус success
                if(err) {
                  self.error(err);
                  return;
                }

                if(results.affectedRows == 0) {
                  self.debug("NOT UPDATE TRADE OFFER #" + offer.tradeofferid);
                  return;
                }

                connection.query("SELECT * FROM `trade_log` WHERE `tradeId` = ? and `status` = 'success'", offer.tradeofferid, function(err, rows, fields) { //Получаем оставшиеся данные записи
                  if(err) {
                    self.error(err);
                    return;
                  }

                  var sum = rows[0].sum;
                  connection.query('UPDATE `users` SET `balance` = `balance` + ? WHERE steam_id = ?', [sum, offer.steamid_other], function(err, results) { //Пополняем баланс
                    if(err) {
                      self.error(err);
                      return;
                    }

                    if(results.affectedRows == 0) {
                      self.debug("NOT UPDATE USER BALANCE steamid=" + offer.steamid_other + ", sum=" + sum);
                      return;
                    }

                    self.debug("TRADE OFFER #" + offer.tradeofferid + " ОТ: " + offer.steamid_other + " БЫЛ ПОДТВЕРЖДЕН");	  
			$app.io.emit('deposit', {
				steam_id: offer.steamid_other,
				sum: sum,
			});
                  });
                });
              });
            });

            connection.release();
          });

Answer 1

[Rsa97]

UPDATE `trade_log` AS `tl`
  JOIN `users` AS `u` ON `tl`.`tradeId` = ? AND `tl`.`status` = 'send' 
    AND `u`.`steam_id` = `tl`.`steamid_other`
  SET `tl`.`status` = 'success', `u`.`balance` = `u`.`balance` + `tl`.`sum`

P.S. Поправил малость. Сразу не посмотрел, откуда сумма берётся. И не посмотрел ещё, что надо отправлять данные, а значит ещё запрос на выборку придётся сделать

SELECT `steamid_other`, `sum` 
  FROM `trade_log` 
  WHERE `tradeId` = ? AND `status` = 'success'

Comments

[Ilya78rus]

Одним запросом можно решить всю эту задачу?

[Rsa97]

Ilya78rus: Да. При условии, что пользователь с таким steam_id точно есть в базе.

[Ilya78rus]

Rsa97: А как проверить выполнен ли запрос?
тк приложение получает данные со стороннего ресурса. Данных много и нужно проверить имеется ли в бд строка с идентификатором tradeId, если имеется, то пополняем баланс и выводим информацию что баланс пополнен. То есть если такой строки нету - не выводим ничего, если есть - выводим в консоль что баланс пополнен

[Rsa97]

Ilya78rus: А вторым запросом - на выборку. Если он выдал строку, значит запрос на изменение был выполнен и status изменился на 'success'.

[Ilya78rus]

Rsa97: Спасибо