Differential D19790 Diff 47258 src/infrastructure/edges/editor/PhabricatorEdgeEditor.php

Changeset View

Standalone View

src/infrastructure/edges/editor/PhabricatorEdgeEditor.php

Show First 20 Lines • Show All 269 Lines • ▼ Show 20 Lines	foreach ($adds as $src_type => $edges) {
$inserts[] = array($conn_w, $sql);		$inserts[] = array($conn_w, $sql);
}		}

foreach ($inserts as $insert) {		foreach ($inserts as $insert) {
list($conn_w, $sql) = $insert;		list($conn_w, $sql) = $insert;
$conn_w->openTransaction();		$conn_w->openTransaction();
$this->openTransactions[] = $conn_w;		$this->openTransactions[] = $conn_w;

foreach (array_chunk($sql, 256) as $chunk) {		foreach (PhabricatorLiskDAO::chunkSQL($sql) as $chunk) {
queryfx(		queryfx(
$conn_w,		$conn_w,
'INSERT INTO %T (src, type, dst, dateCreated, seq, dataID)		'INSERT INTO %T (src, type, dst, dateCreated, seq, dataID)
VALUES %Q ON DUPLICATE KEY UPDATE dataID = VALUES(dataID)',		VALUES %LQ ON DUPLICATE KEY UPDATE dataID = VALUES(dataID)',
PhabricatorEdgeConfig::TABLE_NAME_EDGE,		PhabricatorEdgeConfig::TABLE_NAME_EDGE,
implode(', ', $chunk));		$chunk);
}		}
}		}
}		}


/**		/**
* Remove queued edges.		* Remove queued edges.
*		*
Show All 22 Lines	foreach ($deletes as $delete) {
list($conn_w, $sql) = $delete;		list($conn_w, $sql) = $delete;

$conn_w->openTransaction();		$conn_w->openTransaction();
$this->openTransactions[] = $conn_w;		$this->openTransactions[] = $conn_w;

foreach (array_chunk($sql, 256) as $chunk) {		foreach (array_chunk($sql, 256) as $chunk) {
queryfx(		queryfx(
$conn_w,		$conn_w,
'DELETE FROM %T WHERE (%Q)',		'DELETE FROM %T WHERE %LO',
PhabricatorEdgeConfig::TABLE_NAME_EDGE,		PhabricatorEdgeConfig::TABLE_NAME_EDGE,
implode(' OR ', $chunk));		$chunk);
}		}
}		}
}		}


/**		/**
* Save open transactions.		* Save open transactions.
*		*
▲ Show 20 Lines • Show All 73 Lines • Show Last 20 Lines