mirror of
https://we.phorge.it/source/phorge.git
synced 2024-11-27 01:02:42 +01:00
54 lines
1.2 KiB
PHP
54 lines
1.2 KiB
PHP
|
<?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";
|