Differential D7513 Diff 16954 resources/sql/patches/20131106.diffphid.2.mig.php

Changeset View

Standalone View

				<?php

				$diff_table = new DifferentialDiff();
				$conn_w = $diff_table->establishConnection('w');

				$size = 1000;

				$row_iter = id(new LiskMigrationIterator($diff_table))->setPageSize($size);
				$chunk_iter = new PhutilChunkedIterator($row_iter, $size);

				foreach ($chunk_iter as $chunk) {
				$sql = array();

				foreach ($chunk as $diff) {
				$id = $diff->getID();
				echo "Migrating diff ID {$id}...\n";

				$phid = $diff->getPHID();
				if (strlen($phid)) {
				continue;
				}

				$type_diff = DifferentialPHIDTypeDiff::TYPECONST;
				$new_phid = PhabricatorPHID::generateNewPHID($type_diff);

				$sql[] = qsprintf(
				$conn_w,
				'(%d, %s)',
				$id,
				$new_phid);
				}

				if (!$sql) {
				continue;
				}

				foreach (PhabricatorLiskDAO::chunkSQL($sql, ', ') as $sql_chunk) {
				queryfx(
				$conn_w,
				'INSERT IGNORE INTO %T (id, phid) VALUES %Q
				ON DUPLICATE KEY UPDATE phid = VALUES(phid)',
				$diff_table->getTableName(),
				$sql_chunk);
				}
				}

				echo "Done.\n";