不要怂,就是干,撸起袖子干!

Commit e2a9c78e by Mick Hansen

Merge pull request #5627 from davidrapin/issue-5626

Added missing transaction in SQLite query interface
2 parents 4c81d9fd d0f618db
Showing with 4 additions and 4 deletions
......@@ -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));
});
});
};
......
Markdown is supported
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!