Differential D10160 Diff 24463 resources/sql/autopatches/20140805.boardcol.2.php

Changeset View

Standalone View

				<?php

				// Was PhabricatorEdgeConfig::TYPE_COLUMN_HAS_OBJECT
				$type_has_object = 44;

				$column = new PhabricatorProjectColumn();
				$conn_w = $column->establishConnection('w');

				$rows = queryfx_all(
				$conn_w,
				'SELECT src, dst FROM %T WHERE type = %d',
				PhabricatorEdgeConfig::TABLE_NAME_EDGE,
				$type_has_object);

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

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

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

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

				echo "Done.\n";