🐛 Fixed 3.0 migration on SQLite with many posts (#11302)

refs https://github.com/TryGhost/Ghost/pull/11270

- Fixed 3.0/11-update-posts-html migration which failed in scenario when more than 999 posts with posts_meta relation were present
- The issue was originally spotted here: https://github.com/TryGhost/Ghost/pull/11270#issuecomment-546248308
- The main problem is in the `SELECT` statement which is generated for `findAll` method in Bookshelf which creates `WHERE IN(post_ids_here)` statement with all posts in the database
- Using knex directly as that's a preferred way to write migrations (does not depend on the model layer)
This commit is contained in:
Naz Gargol 2019-10-29 13:16:47 +01:00 committed by Kevin Ansfield
parent 640c4a82f1
commit 9b347d6d95

View File

@ -1,7 +1,7 @@
const _ = require('lodash'); const _ = require('lodash');
const Promise = require('bluebird'); const Promise = require('bluebird');
const htmlToText = require('html-to-text');
const common = require('../../../../lib/common'); const common = require('../../../../lib/common');
const models = require('../../../../models');
const converters = require('../../../../lib/mobiledoc/converters'); const converters = require('../../../../lib/mobiledoc/converters');
module.exports.config = { module.exports.config = {
@ -9,7 +9,7 @@ module.exports.config = {
}; };
module.exports.up = (options) => { module.exports.up = (options) => {
const postAllColumns = ['id', 'html', 'mobiledoc']; const columns = ['id', 'html', 'mobiledoc', 'plaintext'];
let localOptions = _.merge({ let localOptions = _.merge({
context: {internal: true}, context: {internal: true},
@ -17,14 +17,15 @@ module.exports.up = (options) => {
}, options); }, options);
common.logging.info('Starting re-generation of posts html.'); common.logging.info('Starting re-generation of posts html.');
return localOptions
return models.Post.findAll(_.merge({columns: postAllColumns}, localOptions)) .transacting('posts')
.then(function (posts) { .select(columns)
return Promise.map(posts.models, function (post) { .then((posts) => {
return Promise.map(posts, function (post) {
let mobiledoc; let mobiledoc;
try { try {
mobiledoc = JSON.parse(post.get('mobiledoc') || null); mobiledoc = JSON.parse(post.mobiledoc || null);
if (!mobiledoc) { if (!mobiledoc) {
common.logging.warn(`No mobiledoc for ${post.id}. Skipping.`); common.logging.warn(`No mobiledoc for ${post.id}. Skipping.`);
@ -37,7 +38,33 @@ module.exports.up = (options) => {
const html = converters.mobiledocConverter.render(mobiledoc); const html = converters.mobiledocConverter.render(mobiledoc);
return models.Post.edit({html}, _.merge({id: post.id}, localOptions)); const updatedAttrs = {
html: html
};
// NOTE: block comes straight from the Post model (https://github.com/TryGhost/Ghost/blob/3.0.0/core/server/models/post.js#L416)
if (html !== post.html || !post.plaintext) {
const plaintext = htmlToText.fromString(post.html, {
wordwrap: 80,
ignoreImage: true,
hideLinkHrefIfSameAsText: true,
preserveNewlines: true,
returnDomByDefault: true,
uppercaseHeadings: false
});
// CASE: html is e.g. <p></p>
// @NOTE: Otherwise we will always update the resource to `plaintext: ''` and Bookshelf thinks that this
// value was modified.
if (plaintext || plaintext !== post.plaintext) {
updatedAttrs.plaintext = plaintext;
}
}
return localOptions
.transacting('posts')
.where('id', '=', post.id)
.update(updatedAttrs);
}, {concurrency: 100}); }, {concurrency: 100});
}) })
.then(() => { .then(() => {