Homec4science
Diffusion Phabricator (stable) Browse

phab/resources/sql/autopatches/20180418.alamanc.interface.unique.php
409e207378b4stable

Last Change
Raw File

20180418.alamanc.interface.unique.php
View Options

<?php
$interface_table = new AlmanacInterface();
$binding_table = new AlmanacBinding();
$interface_conn = $interface_table->establishConnection('w');
queryfx(
$interface_conn,
'LOCK TABLES %T WRITE, %T WRITE',
$interface_table->getTableName(),
$binding_table->getTableName());
$seen = array();
foreach (new LiskMigrationIterator($interface_table) as $interface) {
$device = $interface->getDevicePHID();
$network = $interface->getNetworkPHID();
$address = $interface->getAddress();
$port = $interface->getPort();
$key = "{$device}/{$network}/{$address}/{$port}";
// If this is the first copy of this row we've seen, mark it as seen and
// move on.
if (empty($seen[$key])) {
$seen[$key] = $interface->getID();
continue;
}
$survivor = queryfx_one(
$interface_conn,
'SELECT * FROM %T WHERE id = %d',
$interface_table->getTableName(),
$seen[$key]);
$bindings = queryfx_all(
$interface_conn,
'SELECT * FROM %T WHERE interfacePHID = %s',
$binding_table->getTableName(),
$interface->getPHID());
// Repoint bindings to the survivor.
foreach ($bindings as $binding) {
// Check if there's already a binding to the survivor.
$existing = queryfx_one(
$interface_conn,
'SELECT * FROM %T WHERE interfacePHID = %s and devicePHID = %s and '.
'servicePHID = %s',
$binding_table->getTableName(),
$survivor['phid'],
$binding['devicePHID'],
$binding['servicePHID']);
if (!$existing) {
// Reattach this binding to the survivor.
queryfx(
$interface_conn,
'UPDATE %T SET interfacePHID = %s WHERE id = %d',
$binding_table->getTableName(),
$survivor['phid'],
$binding['id']);
} else {
// Binding to survivor already exists. Remove this now-redundant binding.
queryfx(
$interface_conn,
'DELETE FROM %T WHERE id = %d',
$binding_table->getTableName(),
$binding['id']);
}
}
queryfx(
$interface_conn,
'DELETE FROM %T WHERE id = %d',
$interface_table->getTableName(),
$interface->getID());
}
queryfx(
$interface_conn,
'ALTER TABLE %T ADD UNIQUE KEY `key_unique` '.
'(devicePHID, networkPHID, address, port)',
$interface_table->getTableName());
queryfx(
$interface_conn,
'UNLOCK TABLES');
c4science · Help