Остановить продолжение цепочки обещаний без вызова ада

Question

Я новичок в использовании узла js, поэтому очень вероятно, что я неправильно понимаю понятие «обещание» и «обратный ад». В любом случае, мне нужно предложения о том, как избежать следующего кода:

var Sequelize = require('sequelize'); 
var DB = new Sequelize('project1db', 'john', 'password123', { 
    host: 'localhost', 
    dialect: 'mysql' 
}); 


var DB_PREFIX = 't_'; 

DB.query(
'CREATE TABLE IF NOT EXISTS `'+DB_PREFIX+'user` (' + 
'`user_id` int(11) UNSIGNED NOT NULL' + 
') ENGINE=InnoDB DEFAULT CHARSET=utf8;',{type: DB.QueryTypes.RAW}) 
.then(function(results) { 
    DB.query(
    'CREATE TABLE IF NOT EXISTS `'+DB_PREFIX+'organization` (' + 
    '`organization_id` int(11) UNSIGNED NOT NULL AUTO_INCREMENT ' + 
    ') ENGINE=InnoDB DEFAULT CHARSET=utf8; ', {type:DB.QueryTypes.RAW}) 
    .then(function(results) { 
     DB.query(
     'CREATE TABLE IF NOT EXISTS `'+DB_PREFIX+'user_organization` (' + 
     '`user_id` int(11) UNSIGNED NOT NULL ' + 
     ') ENGINE=InnoDB DEFAULT CHARSET=utf8; ') 
     .then(function(){ 
      DB.query(
      'CREATE TABLE IF NOT EXISTS `'+DB_PREFIX+'content` (' + 
      '`content_id` int(11) UNSIGNED NOT NULL ' + 
      ') ENGINE=InnoDB DEFAULT CHARSET=utf8; ', {type:DB.QueryTypes.RAW}) 
      .then(function(){ 
      // more queries 
      }).catch(function(err){console.log(err);}); 
     }).catch(function(err){console.log(err);}); 
    }).catch(function(err){console.log(err);}); 
}).catch(function(err){console.log(err);}); 

игнорировать тот факт, что я создаю таблицы с SQL вместо использования сценариев миграции Sequelize, потому что я просто пытаюсь показать точку что у меня есть много запросов mysql, которые должны запускаться последовательно. Если запрос завершается с ошибкой, мне нужно остановить весь скрипт и не дать ему активировать функцию .then(). В моем коде Sequelize я достиг этого, вложив множество вызовов функций необработанных запросов, а затем и catch. Это будет очень сложно устранить, если у меня есть 100 из этих вложенных операторов обратного вызова.

Есть ли альтернативы для меня, чтобы учесть все эти функции обратного вызова?

Answer 1

Sequelize использует (модифицированную версию) Библиотеку bluebird обещает, что означает, что это должно работать:

var Promise = Sequelize.Promise; 

Promise.each([ 
    'CREATE TABLE IF NOT EXISTS `'+DB_PREFIX+'user` (' + 
    '`user_id` int(11) UNSIGNED NOT NULL' + 
    ') ENGINE=InnoDB DEFAULT CHARSET=utf8;', 
    'CREATE TABLE IF NOT EXISTS `'+DB_PREFIX+'organization` (' + 
    '`organization_id` int(11) UNSIGNED NOT NULL AUTO_INCREMENT ' + 
    ') ENGINE=InnoDB DEFAULT CHARSET=utf8; ', 
    'CREATE TABLE IF NOT EXISTS `'+DB_PREFIX+'user_organization` (' + 
    '`user_id` int(11) UNSIGNED NOT NULL ' + 
    ') ENGINE=InnoDB DEFAULT CHARSET=utf8; ', 
    'CREATE TABLE IF NOT EXISTS `'+DB_PREFIX+'content` (' + 
    '`content_id` int(11) UNSIGNED NOT NULL ' + 
    ') ENGINE=InnoDB DEFAULT CHARSET=utf8; ', 
], function runQuery(query) { 
    return DB.query(query, { type: DB.QueryTypes.RAW }); 
}).then(function() { 
    console.log('all done'); 
}).catch(function(err) { 
    console.log(err); 
}); 

Он использует статическую версию .each(), которая будет перебирать элементы массива последовательно проходят каждый к итератору runQuery (который возвращает обещание), и остановится, когда обещание будет отклонено.

Answer 2

Вы уже не ответили на свой вопрос, не используя сценарии миграции? По умолчанию вы хотите запустить сценарии миграции, чтобы настроить свою базу данных и зарегистрировать ее, чтобы вы знали, когда переносились или когда вы в последний раз мигрировали.

Если вам нужны последовательные SQL-команды, вы все равно можете сделать это в пределах 1 команды. В любом случае запрос будет выполняться последовательно. Если вы хотите, чтобы каждая отдельная таблица была моделью, создайте сценарии миграции для этой модели, не делайте этого так.