master

20140325.push.3.groups.php
View Options

			<?php

			$conn_w = id(new PhabricatorRepository())->establishConnection('w');

			echo pht('Adding transaction log event groups...')."\n";

			$logs = queryfx_all(
			$conn_w,
			'SELECT * FROM %T GROUP BY transactionKey ORDER BY id ASC',
			'repository_pushlog');
			foreach ($logs as $log) {
			$id = $log['id'];
			echo pht('Migrating log %d...', $id)."\n";
			if ($log['pushEventPHID']) {
			continue;
			}

			$event_phid = id(new PhabricatorRepositoryPushEvent())->generatePHID();

			queryfx(
			$conn_w,
			'INSERT INTO %T (phid, repositoryPHID, epoch, pusherPHID, remoteAddress,
			remoteProtocol, rejectCode, rejectDetails)
			VALUES (%s, %s, %d, %s, %d, %s, %d, %s)',
			'repository_pushevent',
			$event_phid,
			$log['repositoryPHID'],
			$log['epoch'],
			$log['pusherPHID'],
			$log['remoteAddress'],
			$log['remoteProtocol'],
			$log['rejectCode'],
			$log['rejectDetails']);

			queryfx(
			$conn_w,
			'UPDATE %T SET pushEventPHID = %s WHERE transactionKey = %s',
			'repository_pushlog',
			$event_phid,
			$log['transactionKey']);
			}

			echo pht('Done.')."\n";