Differential D12797 Diff 31275 resources/sql/autopatches/20140805.boardcol.2.php

Changeset View

Standalone View

resources/sql/autopatches/20140805.boardcol.2.php

	Show All 13 Lines

	$cols = array();			$cols = array();
	foreach ($rows as $row) {			foreach ($rows as $row) {
	$cols[$row['src']][] = $row['dst'];			$cols[$row['src']][] = $row['dst'];
	}			}

	$sql = array();			$sql = array();
	foreach ($cols as $col_phid => $obj_phids) {			foreach ($cols as $col_phid => $obj_phids) {
	echo "Migrating column '{$col_phid}'...\n";			echo pht("Migrating column '%s'...", $col_phid)."\n";
	$column = id(new PhabricatorProjectColumn())->loadOneWhere(			$column = id(new PhabricatorProjectColumn())->loadOneWhere(
	'phid = %s',			'phid = %s',
	$col_phid);			$col_phid);
	if (!$column) {			if (!$column) {
	echo "Column '{$col_phid}' does not exist.\n";			echo pht("Column '%s' does not exist.", $col_phid)."\n";
	continue;			continue;
	}			}

	$sequence = 0;			$sequence = 0;
	foreach ($obj_phids as $obj_phid) {			foreach ($obj_phids as $obj_phid) {
	$sql[] = qsprintf(			$sql[] = qsprintf(
	$conn_w,			$conn_w,
	'(%s, %s, %s, %d)',			'(%s, %s, %s, %d)',
	$column->getProjectPHID(),			$column->getProjectPHID(),
	$column->getPHID(),			$column->getPHID(),
	$obj_phid,			$obj_phid,
	$sequence++);			$sequence++);
	}			}
	}			}

	echo "Inserting rows...\n";			echo pht('Inserting rows...')."\n";
	foreach (PhabricatorLiskDAO::chunkSQL($sql) as $chunk) {			foreach (PhabricatorLiskDAO::chunkSQL($sql) as $chunk) {
	queryfx(			queryfx(
	$conn_w,			$conn_w,
	'INSERT INTO %T (boardPHID, columnPHID, objectPHID, sequence)			'INSERT INTO %T (boardPHID, columnPHID, objectPHID, sequence)
	VALUES %Q',			VALUES %Q',
	id(new PhabricatorProjectColumnPosition())->getTableName(),			id(new PhabricatorProjectColumnPosition())->getTableName(),
	$chunk);			$chunk);
	}			}

	echo "Done.\n";			echo pht('Done.')."\n";