Differential D21608 Diff 51440 resources/sql/autopatches/20210215.changeset.02.phid-populate.php

Changeset View

Standalone View

resources/sql/autopatches/20210215.changeset.02.phid-populate.php

	<?php			<?php

	$phid_type = DifferentialChangesetPHIDType::TYPECONST;			$phid_type = DifferentialChangesetPHIDType::TYPECONST;

	$changeset_table = new DifferentialChangeset();			$changeset_table = new DifferentialChangeset();

	$conn = $changeset_table->establishConnection('w');			$conn = $changeset_table->establishConnection('w');
	$table_name = $changeset_table->getTableName();			$table_name = $changeset_table->getTableName();

	$chunk_size = 4096;			$chunk_size = 4096;

	$temporary_table = 'tmp_20210215_changeset_id_map';			$temporary_table = 'tmp_20210215_changeset_id_map';

				try {
	queryfx(			queryfx(
	$conn,			$conn,
	'CREATE TEMPORARY TABLE %T (			'CREATE TEMPORARY TABLE %T (
	changeset_id INT UNSIGNED NOT NULL AUTO_INCREMENT PRIMARY KEY,			changeset_id INT UNSIGNED NOT NULL AUTO_INCREMENT PRIMARY KEY,
	changeset_phid VARBINARY(64) NOT NULL)',			changeset_phid VARBINARY(64) NOT NULL)',
	$temporary_table);			$temporary_table);
				} catch (AphrontAccessDeniedQueryException $ex) {
				throw new PhutilProxyException(
				pht(
				'Failed to "CREATE TEMPORARY TABLE". You may need to "GRANT" the '.
				'current MySQL user this permission.'),
				$ex);
				}

	$table_iterator = id(new LiskRawMigrationIterator($conn, $table_name))			$table_iterator = id(new LiskRawMigrationIterator($conn, $table_name))
	->setPageSize($chunk_size);			->setPageSize($chunk_size);

	$chunk_iterator = new PhutilChunkedIterator($table_iterator, $chunk_size);			$chunk_iterator = new PhutilChunkedIterator($table_iterator, $chunk_size);
	foreach ($chunk_iterator as $chunk) {			foreach ($chunk_iterator as $chunk) {

	$map = array();			$map = array();
	▲ Show 20 Lines • Show All 44 Lines • Show Last 20 Lines