Differential D19802 Diff 47307 resources/sql/autopatches/20180914.audit.01.mailkey.php

Changeset View

Standalone View

	<?php			<?php

	$commit_table = new PhabricatorRepositoryCommit();			$commit_table = new PhabricatorRepositoryCommit();
	$commit_conn = $commit_table->establishConnection('w');			$commit_conn = $commit_table->establishConnection('w');
	$commit_name = $commit_table->getTableName();			$commit_name = $commit_table->getTableName();

	$properties_table = new PhabricatorMetaMTAMailProperties();			$properties_table = new PhabricatorMetaMTAMailProperties();
	$conn = $properties_table->establishConnection('w');			$conn = $properties_table->establishConnection('w');

	$iterator = new LiskRawMigrationIterator($commit_conn, $commit_name);			$iterator = new LiskRawMigrationIterator($commit_conn, $commit_name);
	foreach ($iterator as $commit) {			$chunks = new PhutilChunkedIterator($iterator, 100);
	queryfx(			foreach ($chunks as $chunk) {
				$sql = array();
				foreach ($chunk as $commit) {
				$sql[] = qsprintf(
	$conn,			$conn,
	'INSERT IGNORE INTO %T			'(%s, %s, %d, %d)',
	(objectPHID, mailProperties, dateCreated, dateModified)
	VALUES
	(%s, %s, %d, %d)',
	$properties_table->getTableName(),
	$commit['phid'],			$commit['phid'],
	phutil_json_encode(			phutil_json_encode(
	array(			array(
	'mailKey' => $commit['mailKey'],			'mailKey' => $commit['mailKey'],
	)),			)),
	PhabricatorTime::getNow(),			PhabricatorTime::getNow(),
	PhabricatorTime::getNow());			PhabricatorTime::getNow());
	}			}

				queryfx(
				$conn,
				'INSERT IGNORE INTO %R
				(objectPHID, mailProperties, dateCreated, dateModified)
				VALUES %LQ',
				$properties_table,
				$sql);
				}