Merge pull request sequelize#5627 from davidrapin/issue-5626

mickhansen · mickhansen · commit e2a9c78ed661 · 2016-03-22T16:51:28.000+01:00
Added missing transaction in SQLite query interface
diff --git a/lib/dialects/sqlite/query-interface.js b/lib/dialects/sqlite/query-interface.js
@@ -29,14 +29,14 @@ var removeColumn = function(tableName, attributeName, options) {
   var self = this;
   options = options || {};
 
-  return this.describeTable(tableName).then(function(fields) {
+  return this.describeTable(tableName, options).then(function(fields) {
     delete fields[attributeName];
 
     var sql = self.QueryGenerator.removeColumnQuery(tableName, fields)
       , subQueries = sql.split(';').filter(function(q) { return q !== ''; });
 
     return Promise.each(subQueries, function(subQuery) {
-      return self.sequelize.query(subQuery + ';', { raw: true, logging: options.logging });
+      return self.sequelize.query(subQuery + ';', Utils._.assign({raw: true}, options));
     });
   });
 };
@@ -68,7 +68,7 @@ var changeColumn = function(tableName, attributes, options) {
       , subQueries = sql.split(';').filter(function(q) { return q !== ''; });
 
     return Promise.each(subQueries, function(subQuery) {
-      return self.sequelize.query(subQuery + ';', { raw: true, logging: options.logging });
+      return self.sequelize.query(subQuery + ';', Utils._.assign({raw: true}, options));
     });
   });
 };
@@ -101,7 +101,7 @@ var renameColumn = function(tableName, attrNameBefore, attrNameAfter, options) {
       , subQueries = sql.split(';').filter(function(q) { return q !== ''; });
 
     return Promise.each(subQueries, function(subQuery) {
-      return self.sequelize.query(subQuery + ';', { raw: true, logging: options.logging });
+      return self.sequelize.query(subQuery + ';', Utils._.assign({raw: true}, options));
     });
   });
 };
