EBernhardson has uploaded a new change for review.
https://gerrit.wikimedia.org/r/203962
Change subject: Update rows with missing workflow_page_id
......................................................................
Update rows with missing workflow_page_id
In some cases we have created workflow instances before the related Title
has an ArticleID assigned to it. This goes through and sets that value.
Change-Id: I7a48f09fcdcb9ec3def002e4ad907b2c59f64687
---
A maintenance/FlowUpdateWorkflowPageId.php
1 file changed, 123 insertions(+), 0 deletions(-)
git pull ssh://gerrit.wikimedia.org:29418/mediawiki/extensions/Flow
refs/changes/62/203962/1
diff --git a/maintenance/FlowUpdateWorkflowPageId.php
b/maintenance/FlowUpdateWorkflowPageId.php
new file mode 100644
index 0000000..d4ce2ba
--- /dev/null
+++ b/maintenance/FlowUpdateWorkflowPageId.php
@@ -0,0 +1,123 @@
+<?php
+
+use Flow\Container;
+use Flow\Model\UUID;
+use Flow\Model\PostRevision;
+
+$IP = getenv( 'MW_INSTALL_PATH' );
+if ( $IP === false ) {
+ $IP = dirname( __FILE__ ) . '/../../..';
+}
+require_once( "$IP/maintenance/Maintenance.php" );
+require_once __DIR__ . "/../../Echo/includes/BatchRowUpdate.php";
+
+/**
+ * Update all xxx_user_wiki field to have the correct wiki name
+ *
+ * @ingroup Maintenance
+ */
+class FlowUpdateWorkflowPageId extends LoggedUpdateMaintenance {
+
+ public function __construct() {
+ parent::__construct();
+ $this->mDescription = "Update workflow_page_id with the page id
of its specified ns/titlz";
+ $this->setBatchSize( 300 );
+ }
+
+ /**
+ * This is a top-to-bottom update, the process is like this:
+ * workflow -> header -> header revision -> history
+ * workflow -> topic list -> post tree revision -> post revision ->
history
+ *
+ * Some side effect, the script will also update those *_user_wiki
fields with
+ * empty *_user_id and *_user_ip, but this doesn't hurt. Alternatively,
we could
+ * add a check user_id != 0 and user_ip is not null to the query, but
this will
+ * result in more db queries
+ *
+ */
+ protected function doDBUpdates() {
+ global $wgFlowCluster, $wgLang;
+
+ $dbw = Flow\Container::get( 'db.factory' )->getDB( DB_MASTER );
+
+ $it = new EchoBatchRowIterator(
+ $dbw,
+ 'flow_workflow',
+ 'workflow_id',
+ $this->mBatchSize
+ );
+ $it->setFetchColumns( array( '*' ) );
+ $it->addConditions( array(
+ 'workflow_wiki' => wfWikiId(),
+ 'workflow_page_id' => 0,
+ ) );
+
+
+ $gen = new WorkflowPageIdUpdateGenerator( $wgLang );
+ $writer = new EchoBatchRowWriter( $dbw, 'flow_workflow',
$wgFlowCluster );
+ $updater = new EchoBatchRowUpdate( $it, $writer, $gen );
+
+ $updater->execute();
+
+ $this->output( $gen->report() );
+
+ return true;
+ }
+
+
+ /**
+ * Get the update key name to go in the update log table
+ *
+ * @return string
+ */
+ protected function getUpdateKey() {
+ return __CLASS__;
+ }
+}
+
+class WorkflowPageIdUpdateGenerator implements EchoRowUpdateGenerator {
+ /**
+ * @var Language|StubUserLang
+ */
+ protected $lang;
+ protected $fixedCount = 0;
+ protected $failed = array();
+
+ /**
+ * @param Language|StubUserLang $lang
+ */
+ public function __construct( $lang ) {
+ $this->lang = $lang;
+ }
+
+ public function update( $row ) {
+ $title = Title::makeTitleSafe( $row->workflow_namespace,
$row->workflow_title_text );
+ if ( $title === null ) {
+ throw new Exception( sprintf(
+ 'Could not create title for %s at %s:%s',
+ UUID::create( $row->workflow_id
)->getAlphadecimal(),
+ $this->lang->getNsText(
$row->workflow_namespace ) ?: $row->workflow_namespace,
+ $row->workflow_title_text
+ ) );
+ }
+
+ if ( $title->getArticleID() !== (int)$row->workflow_page_id ) {
+ // This makes the assumption the page has not moved or
been deleted?
+ ++$this->fixedCount;
+ return array(
+ 'workflow_page_id' => $title->getArticleID(),
+ );
+ } else {
+ // No id exists for this workflow?
+ $this->failed[] = $row;
+ return array();
+ }
+ }
+
+ public function report() {
+ return "Updated {$this->fixedCount} workflows\n\nFailed: " .
print_r( $this->failed, true );
+ }
+}
+
+$maintClass = "FlowUpdateWorkflowPageId";
+require_once( DO_MAINTENANCE );
--
To view, visit https://gerrit.wikimedia.org/r/203962
To unsubscribe, visit https://gerrit.wikimedia.org/r/settings
Gerrit-MessageType: newchange
Gerrit-Change-Id: I7a48f09fcdcb9ec3def002e4ad907b2c59f64687
Gerrit-PatchSet: 1
Gerrit-Project: mediawiki/extensions/Flow
Gerrit-Branch: master
Gerrit-Owner: EBernhardson <[email protected]>
_______________________________________________
MediaWiki-commits mailing list
[email protected]
https://lists.wikimedia.org/mailman/listinfo/mediawiki-commits
