mirror of
https://we.phorge.it/source/phorge.git
synced 2024-11-14 19:02:41 +01:00
f010730e49
Summary: Ref T2222. This implements step (1) described there, which is moving over all the inline comments. The old and new tables are simliar. The only real trick here is that `transactionPHID` and `legacyCommentID` mean roughly the same thing (`null` if the inline is a draft, non-null if it has been submitted) but we don't have real `transactionPHID`s yet. We just make some up -- we'll backfill them later. Two risks here: - I need to take a second look at the keys on this table. I think we need to tweak them a bit, and it will be less disruptive to do that before this migration than after. - This will take a while for Facebook, and other large installs with tens of thousands of revisions. I'll communicate this. I'm otherwise pretty satisfied with this, seems to work well and is pretty low risk / non-disruptive. Test Plan: - Before migrating, then after migrating: - Made a bunch of inlines (drafts, submitted). - Edited and deleted inlines. - Verified inlines showed up in preview. - Verified that inlines aren't indexed when they're drafts (`bin/search index D935`). - Verified that inlines ARE indexed when they're not drafts. - Verified that drafts inlines make revisions appear as "with draft" in the revision list. - Made left, right, and draft inlines. - Migrated (`bin/storage upgrade`). - Verified that my inlines from before the migration still showed up. - (Repeated all the stuff above.) - Manually inspected the inline comment table. Reviewers: btrahan Reviewed By: btrahan CC: FacebookPOC, aran Maniphest Tasks: T2222 Differential Revision: https://secure.phabricator.com/D7139
90 lines
2.3 KiB
PHP
90 lines
2.3 KiB
PHP
<?php
|
|
|
|
$revision_table = new DifferentialRevision();
|
|
$conn_w = $revision_table->establishConnection('w');
|
|
$conn_w->openTransaction();
|
|
|
|
$src_table = 'differential_inlinecomment';
|
|
$dst_table = 'differential_transaction_comment';
|
|
|
|
echo "Migrating Differential inline comments to new format...\n";
|
|
|
|
$content_source = PhabricatorContentSource::newForSource(
|
|
PhabricatorContentSource::SOURCE_LEGACY,
|
|
array())->serialize();
|
|
|
|
$rows = new LiskRawMigrationIterator($conn_w, $src_table);
|
|
foreach ($rows as $row) {
|
|
$id = $row['id'];
|
|
|
|
$revision_id = $row['revisionID'];
|
|
|
|
echo "Migrating inline #{$id} (D{$revision_id})...\n";
|
|
|
|
$revision_row = queryfx_one(
|
|
$conn_w,
|
|
'SELECT phid FROM %T WHERE id = %d',
|
|
$revision_table->getTableName(),
|
|
$revision_id);
|
|
if (!$revision_row) {
|
|
continue;
|
|
}
|
|
|
|
$revision_phid = $revision_row['phid'];
|
|
|
|
if ($row['commentID']) {
|
|
$xaction_phid = PhabricatorPHID::generateNewPHID(
|
|
PhabricatorApplicationTransactionPHIDTypeTransaction::TYPECONST,
|
|
DifferentialPHIDTypeRevision::TYPECONST);
|
|
} else {
|
|
$xaction_phid = null;
|
|
}
|
|
|
|
$comment_phid = PhabricatorPHID::generateNewPHID(
|
|
PhabricatorPHIDConstants::PHID_TYPE_XCMT,
|
|
DifferentialPHIDTypeRevision::TYPECONST);
|
|
|
|
queryfx(
|
|
$conn_w,
|
|
'INSERT IGNORE INTO %T
|
|
(id, phid, transactionPHID, authorPHID, viewPolicy, editPolicy,
|
|
commentVersion, content, contentSource, isDeleted,
|
|
dateCreated, dateModified, revisionPHID, changesetID,
|
|
isNewFile, lineNumber, lineLength, hasReplies, legacyCommentID)
|
|
VALUES (%d, %s, %ns, %s, %s, %s,
|
|
%d, %s, %s, %d,
|
|
%d, %d, %s, %nd,
|
|
%d, %d, %d, %d, %nd)',
|
|
$dst_table,
|
|
|
|
// id, phid, transactionPHID, authorPHID, viewPolicy, editPolicy
|
|
$row['id'],
|
|
$comment_phid,
|
|
$xaction_phid,
|
|
$row['authorPHID'],
|
|
'public',
|
|
$row['authorPHID'],
|
|
|
|
// commentVersion, content, contentSource, isDeleted
|
|
1,
|
|
$row['content'],
|
|
$content_source,
|
|
0,
|
|
|
|
// dateCreated, dateModified, revisionPHID, changesetID
|
|
$row['dateCreated'],
|
|
$row['dateModified'],
|
|
$revision_phid,
|
|
$row['changesetID'],
|
|
|
|
// isNewFile, lineNumber, lineLength, hasReplies, legacyCommentID
|
|
$row['isNewFile'],
|
|
$row['lineNumber'],
|
|
$row['lineLength'],
|
|
0,
|
|
$row['commentID']);
|
|
|
|
}
|
|
|
|
$conn_w->saveTransaction();
|
|
echo "Done.\n";
|