jenkins-bot has submitted this change and it was merged. Change subject: Replace EchoBatchRowUpdate with BatchRowUpdate ......................................................................
Replace EchoBatchRowUpdate with BatchRowUpdate Also removes tests for the class. Bug: T119253 Change-Id: I4c0d7187c2b847297dd0867faecba26185cfba37 Depends-On: Iccafbbdb06711463fee0f30a11326c7771df30e2 --- M autoload.php D includes/BatchRowUpdate.php M includes/UserLocator.php M includes/iterator/FilteredSequentialIterator.php M includes/schemaUpdate.php M maintenance/updateEchoSchemaForSuppression.php D tests/phpunit/BatchRowUpdateTest.php 7 files changed, 7 insertions(+), 715 deletions(-) Approvals: Catrope: Looks good to me, approved jenkins-bot: Verified diff --git a/autoload.php b/autoload.php index ae40880..1a0fa7d 100644 --- a/autoload.php +++ b/autoload.php @@ -9,7 +9,6 @@ 'ApiEchoMarkSeen' => __DIR__ . '/includes/api/ApiEchoMarkSeen.php', 'ApiEchoNotifications' => __DIR__ . '/includes/api/ApiEchoNotifications.php', 'ApiEchoNotificationsTest' => __DIR__ . '/tests/phpunit/api/ApiEchoNotificationsTest.php', - 'BatchRowUpdateTest' => __DIR__ . '/tests/phpunit/BatchRowUpdateTest.php', 'CallbackFilterIterator' => __DIR__ . '/includes/iterator/CallbackFilterIterator.php', 'ContainmentSetTest' => __DIR__ . '/tests/phpunit/ContainmentSetTest.php', 'EchoAbstractEntity' => __DIR__ . '/includes/model/AbstractEntity.php', @@ -20,9 +19,6 @@ 'EchoAttributeManager' => __DIR__ . '/includes/AttributeManager.php', 'EchoAttributeManagerTest' => __DIR__ . '/tests/phpunit/AttributeManagerTest.php', 'EchoBasicFormatter' => __DIR__ . '/includes/formatters/BasicFormatter.php', - 'EchoBatchRowIterator' => __DIR__ . '/includes/BatchRowUpdate.php', - 'EchoBatchRowUpdate' => __DIR__ . '/includes/BatchRowUpdate.php', - 'EchoBatchRowWriter' => __DIR__ . '/includes/BatchRowUpdate.php', 'EchoCachedList' => __DIR__ . '/includes/ContainmentSet.php', 'EchoCallbackIterator' => __DIR__ . '/includes/iterator/CallbackIterator.php', 'EchoCatchableFatalErrorException' => __DIR__ . '/includes/exception/CatchableFatalErrorException.php', @@ -80,7 +76,6 @@ 'EchoPageLinkedPresentationModel' => __DIR__ . '/includes/formatters/PageLinkedPresentationModel.php', 'EchoRevertedPresentationModel' => __DIR__ . '/includes/formatters/RevertedPresentationModel.php', 'EchoRevisionLocalCache' => __DIR__ . '/includes/cache/RevisionLocalCache.php', - 'EchoRowUpdateGenerator' => __DIR__ . '/includes/BatchRowUpdate.php', 'EchoSeenTime' => __DIR__ . '/includes/SeenTime.php', 'EchoSuppressionRowUpdateGenerator' => __DIR__ . '/includes/schemaUpdate.php', 'EchoTalkPageFunctionalTest' => __DIR__ . '/tests/phpunit/TalkPageFunctionalTest.php', diff --git a/includes/BatchRowUpdate.php b/includes/BatchRowUpdate.php deleted file mode 100644 index 1a92b93..0000000 --- a/includes/BatchRowUpdate.php +++ /dev/null @@ -1,455 +0,0 @@ -<?php -/** - * Provides components to update a tables rows via a batching process - * - * This program is free software; you can redistribute it and/or modify - * it under the terms of the GNU General Public License as published by - * the Free Software Foundation; either version 2 of the License, or - * (at your option) any later version. - * - * This program is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - * GNU General Public License for more details. - * - * You should have received a copy of the GNU General Public License along - * with this program; if not, write to the Free Software Foundation, Inc., - * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. - * http://www.gnu.org/copyleft/gpl.html - * - * @file - * @ingroup Maintenance - */ - -/** - * Ties together the batch update components to provide a composable method - * of batch updating rows in a database. To use create a class implementing - * the EchoRowUpdateGenerator interface and configure the EchoBatchRowIterator and - * EchoBatchRowWriter for access to the correct table. The components will - * handle reading, writing, and waiting for slaves while the generator implementation - * handles generating update arrays for singular rows. - * - * Instantiate: - * $updater = new EchoBatchRowUpdate( - * new EchoBatchRowIterator( $dbr, 'some_table', 'primary_key_column', 500 ), - * new EchoBatchRowWriter( $dbw, 'some_table', 'clusterName' ), - * new MyImplementationOfEchoRowUpdateGenerator - * ); - * - * Run: - * $updater->execute(); - * - * An example maintenance script utilizing the EchoBatchRowUpdate can be located in the Echo - * extension file maintenance/updateSchema.php - * - * @ingroup Maintenance - */ -class EchoBatchRowUpdate { - /** - * @var EchoBatchRowIterator $reader Iterator that returns an array of database rows - */ - protected $reader; - - /** - * @var EchoBatchRowWriter $writer Writer capable of pushing row updates to the database - */ - protected $writer; - - /** - * @var EchoRowUpdateGenerator $generator Generates single row updates based on the rows content - */ - protected $generator; - - /** - * @var callable $output Output callback - */ - protected $output; - - /** - * @param EchoBatchRowIterator $reader Iterator that returns an array of database rows - * @param EchoBatchRowWriter $writer Writer capable of pushing row updates to the database - * @param EchoRowUpdateGenerator $generator Generates single row updates based on the rows content - */ - public function __construct( EchoBatchRowIterator $reader, EchoBatchRowWriter $writer, EchoRowUpdateGenerator $generator ) { - $this->reader = $reader; - $this->writer = $writer; - $this->generator = $generator; - $this->output = function () { - }; // nop - } - - /** - * Runs the batch update process - */ - public function execute() { - foreach ( $this->reader as $rows ) { - $updates = array(); - foreach ( $rows as $row ) { - $update = $this->generator->update( $row ); - if ( $update ) { - $updates[] = array( - 'primaryKey' => $this->reader->extractPrimaryKeys( $row ), - 'changes' => $update, - ); - } - } - - if ( $updates ) { - $this->output( "Processing " . count( $updates ) . " rows\n" ); - $this->writer->write( $updates ); - } - } - - $this->output( "Completed\n" ); - } - - /** - * Accepts a callable which will receive a single parameter containing - * string status updates - * - * @param callable $output A callback taking a single string parameter to output - * - * @throws MWException - */ - public function setOutput( $output ) { - if ( !is_callable( $output ) ) { - throw new MWException( 'Provided $output param is required to be callable.' ); - } - $this->output = $output; - } - - /** - * Write out a status update - * - * @param string $text The value to print - */ - protected function output( $text ) { - call_user_func( $this->output, $text ); - } -} - -/** - * Interface for generating updates to single rows in the database. - * - * @ingroup Maintenance - */ -interface EchoRowUpdateGenerator { - - /** - * Given a database row, generates an array mapping column names to updated value within the database row - * - * Sample Response: - * return array( - * 'some_col' => 'new value', - * 'other_col' => 99, - * ); - * - * @param stdClass $row A row from the database - * @return array Map of column names to updated value within the database row. When no update is required - * returns an empty array. - */ - public function update( $row ); -} - -/** - * Updates database rows by primary key in batches. There are two options for writing to tables - * with a composite primary key. - * - * @ingroup Maintenance - */ -class EchoBatchRowWriter { - /** - * @var DatabaseBase $db The database to write to - */ - protected $db; - - /** - * @var string $table The name of the table to update - */ - protected $table; - - /** - * @var string $clusterName A cluster name valid for use with LBFactory - */ - protected $clusterName; - - /** - * @param DatabaseBase $db The database to write to - * @param string $table The name of the table to update - * @param string|bool $clusterName A cluster name valid for use with LBFactory - */ - public function __construct( DatabaseBase $db, $table, $clusterName = false ) { - $this->db = $db; - $this->table = $table; - $this->clusterName = $clusterName; - } - - /** - * @param array $updates Array of arrays each containing two keys, 'primaryKey' and 'changes'. - * primaryKey must contain a map of column names to values sufficient to uniquely identify the row - * changes must contain a map of column names to update values to apply to the row - */ - public function write( array $updates ) { - $this->db->begin(); - - foreach ( $updates as $update ) { - // echo "Updating: ";var_dump( $update['primaryKey'] ); - // echo "With values: ";var_dump( $update['changes'] ); - $this->db->update( - $this->table, - $update['changes'], - $update['primaryKey'], - __METHOD__ - ); - } - - $this->db->commit(); - wfWaitForSlaves( false, false, $this->clusterName ); - } -} - -/** - * Fetches rows batched into groups from the database in ascending order of the primary key(s). - * - * @ingroup Maintenance - */ -class EchoBatchRowIterator implements RecursiveIterator { - - /** - * @var DatabaseBase $db The database to read from - */ - protected $db; - - /** - * @var string $table The name of the table to read from - */ - protected $table; - - /** - * @var array $primaryKey The name of the primary key(s) - */ - protected $primaryKey; - - /** - * @var integer $batchSize The number of rows to fetch per iteration - */ - protected $batchSize; - - /** - * @var array $conditions Array of strings containing SQL conditions to add to the query - */ - protected $conditions = array(); - - /** - * @var array $joinConditions - */ - protected $joinConditions = array(); - - /** - * @var array $fetchColumns List of column names to select from the table suitable for use with DatabaseBase::select() - */ - protected $fetchColumns; - - /** - * @var string $orderBy SQL Order by condition generated from $this->primaryKey - */ - protected $orderBy; - - /** - * @var array $current The current iterator value - */ - private $current = array(); - - /** - * @var integer key 0-indexed number of pages fetched since self::reset() - */ - private $key; - - /** - * @param DatabaseBase $db The database to read from - * @param string $table The name of the table to read from - * @param string|array $primaryKey The name or names of the primary key columns - * @param integer $batchSize The number of rows to fetch per iteration - * - * @throws MWException - */ - public function __construct( DatabaseBase $db, $table, $primaryKey, $batchSize ) { - if ( $batchSize < 1 ) { - throw new MWException( 'Batch size must be at least 1 row.' ); - } - $this->db = $db; - $this->table = $table; - $this->primaryKey = (array)$primaryKey; - $this->fetchColumns = $this->primaryKey; - $this->orderBy = implode( ' ASC,', $this->primaryKey ) . ' ASC'; - $this->batchSize = $batchSize; - } - - /** - * @param string $condition Query conditions suitable for use with DatabaseBase::select - */ - public function addConditions( array $conditions ) { - $this->conditions = array_merge( $this->conditions, $conditions ); - } - - public function addJoinConditions( array $conditions ) { - $this->joinConditions = array_merge( $this->joinConditions, $conditions ); - } - - /** - * @param array $columns List of column names to select from the table suitable for use with DatabaseBase::select() - */ - public function setFetchColumns( array $columns ) { - // If it's not the all column selector merge in the primary keys we need - if ( count( $columns ) === 1 && reset( $columns ) === '*' ) { - $this->fetchColumns = $columns; - } else { - $this->fetchColumns = array_unique( array_merge( $this->primaryKey, $columns ) ); - } - } - - /** - * Extracts the primary key(s) from a database row. - * - * @param stdClass $row An individual database row from this iterator - * @return array Map of primary key column to value within the row - */ - public function extractPrimaryKeys( $row ) { - $pk = array(); - foreach ( $this->primaryKey as $column ) { - $pk[$column] = $row->$column; - } - - return $pk; - } - - /** - * @return array The most recently fetched set of rows from the database - */ - public function current() { - return $this->current; - } - - /** - * @return integer 0-indexed count of the page number fetched - */ - public function key() { - return $this->key; - } - - /** - * Reset the iterator to the begining of the table. - */ - public function rewind() { - $this->key = -1; // self::next() will turn this into 0 - $this->current = array(); - $this->next(); - } - - /** - * @return boolean True when the iterator is in a valid state - */ - public function valid() { - return (bool)$this->current; - } - - /** - * @return boolean True when this result set has rows - */ - public function hasChildren() { - return $this->current && count( $this->current ); - } - - /** - * @return RecursiveIterator - */ - public function getChildren() { - return new EchoNotRecursiveIterator( new ArrayIterator( $this->current ) ); - } - - /** - * Fetch the next set of rows from the database. - */ - public function next() { - $res = $this->db->select( - $this->table, - $this->fetchColumns, - $this->buildConditions(), - __METHOD__, - array( - 'LIMIT' => $this->batchSize, - 'ORDER BY' => $this->orderBy, - ), - $this->joinConditions - ); - - // The iterator is converted to an array because in addition to returning it - // in self::current() we need to use the end value in self::buildConditions() - $this->current = iterator_to_array( $res ); - $this->key++; - } - - /** - * Uses the primary key list and the maximal result row from the previous iteration to build - * an SQL condition sufficient for selecting the next page of results. All except the final - * key use `=` conditions while the final key uses a `>` condition - * - * Example output: - * array( '( foo = 42 AND bar > 7 ) OR ( foo > 42 )' ) - * - * @return array The SQL conditions necessary to select the next set of rows in the batched query - */ - protected function buildConditions() { - if ( !$this->current ) { - return $this->conditions; - } - - $maxRow = end( $this->current ); - $maximumValues = array(); - foreach ( $this->primaryKey as $column ) { - $maximumValues[$column] = $this->db->addQuotes( $maxRow->$column ); - } - - $pkConditions = array(); - // For example: If we have 3 primary keys - // first run through will generate - // col1 = 4 AND col2 = 7 AND col3 > 1 - // second run through will generate - // col1 = 4 AND col2 > 7 - // and the final run through will generate - // col1 > 4 - while ( $maximumValues ) { - $pkConditions[] = $this->buildGreaterThanCondition( $maximumValues ); - array_pop( $maximumValues ); - } - - $conditions = $this->conditions; - $conditions[] = sprintf( '( %s )', implode( ' ) OR ( ', $pkConditions ) ); - - return $conditions; - } - - /** - * Given an array of column names and their maximum value generate an SQL - * condition where all keys except the last match $quotedMaximumValues - * exactly and the last column is greater than the matching value in $quotedMaximumValues - * - * @param array $quotedMaximumValues The maximum values quoted with $this->db->addQuotes() - * @return string An SQL condition that will select rows where all columns match the - * maximum value exactly except the last column which must be greater than the provided - * maximum value - */ - protected function buildGreaterThanCondition( array $quotedMaximumValues ) { - $keys = array_keys( $quotedMaximumValues ); - $lastColumn = end( $keys ); - $lastValue = array_pop( $quotedMaximumValues ); - $conditions = array(); - foreach ( $quotedMaximumValues as $column => $value ) { - $conditions[] = "$column = $value"; - } - $conditions[] = "$lastColumn > $lastValue"; - - return implode( ' AND ', $conditions ); - } -} - diff --git a/includes/UserLocator.php b/includes/UserLocator.php index f0b3e37..81e086e 100644 --- a/includes/UserLocator.php +++ b/includes/UserLocator.php @@ -16,7 +16,7 @@ return array(); } - $it = new EchoBatchRowIterator( + $it = new BatchRowIterator( wfGetDB( DB_SLAVE, 'watchlist' ), /* $table = */ 'watchlist', /* $primaryKeys = */ array( 'wl_user' ), diff --git a/includes/iterator/FilteredSequentialIterator.php b/includes/iterator/FilteredSequentialIterator.php index 24f46b1..4fae0bf 100644 --- a/includes/iterator/FilteredSequentialIterator.php +++ b/includes/iterator/FilteredSequentialIterator.php @@ -13,7 +13,7 @@ * $users = new EchoFilteredSequentialIterator; * $users->add( array( $userA, $userB, $userC ) ); * - * $it = new EchoBatchRowIterator( ... ); + * $it = new BatchRowIterator( ... ); * ... * $it = new RecursiveIteratorIterator( $it ); * $users->add( new EchoCallbackIterator( $it, function( $row ) { @@ -25,7 +25,7 @@ * ... * } * - * By default the EchoBatchRowIterator returns an array of rows, this class + * By default the BatchRowIterator returns an array of rows, this class * expects a stream of user objects. To bridge that gap the * RecursiveIteratorIterator is used to flatten and the EchoCallbackIterator * is used to transform each database $row into a User object. diff --git a/includes/schemaUpdate.php b/includes/schemaUpdate.php index ee02ce1..5c20e43 100644 --- a/includes/schemaUpdate.php +++ b/includes/schemaUpdate.php @@ -5,7 +5,7 @@ * Updates event_page_id based on event_page_title and event_page_namespace * Updates extra data for page-linked events to contain page id's */ -class EchoSuppressionRowUpdateGenerator implements EchoRowUpdateGenerator { +class EchoSuppressionRowUpdateGenerator implements RowUpdateGenerator { /** * @var callable Hack to allow replacing Title::newFromText in tests */ diff --git a/maintenance/updateEchoSchemaForSuppression.php b/maintenance/updateEchoSchemaForSuppression.php index 7feb863..0dd9123 100644 --- a/maintenance/updateEchoSchemaForSuppression.php +++ b/maintenance/updateEchoSchemaForSuppression.php @@ -34,15 +34,15 @@ public function execute() { global $wgEchoCluster; - $reader = new EchoBatchRowIterator( MWEchoDbFactory::getDB( DB_SLAVE ), $this->table, $this->idField, $this->mBatchSize ); + $reader = new BatchRowIterator( MWEchoDbFactory::getDB( DB_SLAVE ), $this->table, $this->idField, $this->mBatchSize ); $reader->addConditions( array( "event_page_title IS NOT NULL", "event_page_id" => null, ) ); - $updater = new EchoBatchRowUpdate( + $updater = new BatchRowUpdate( $reader, - new EchoBatchRowWriter( MWEchoDbFactory::getDB( DB_MASTER ), $this->table, $wgEchoCluster ), + new BatchRowWriter( MWEchoDbFactory::getDB( DB_MASTER ), $this->table, $wgEchoCluster ), new EchoSuppressionRowUpdateGenerator ); $updater->setOutput( array( $this, '__internalOutput' ) ); diff --git a/tests/phpunit/BatchRowUpdateTest.php b/tests/phpunit/BatchRowUpdateTest.php deleted file mode 100644 index ecb2360..0000000 --- a/tests/phpunit/BatchRowUpdateTest.php +++ /dev/null @@ -1,248 +0,0 @@ -<?php - -require_once __DIR__ . "/../../includes/BatchRowUpdate.php"; - -/** - * Tests for BatchRowUpdate and its components - * @group Echo - */ -class BatchRowUpdateTest extends MediaWikiTestCase { - - public function testWriterBasicFunctionality() { - $db = $this->mockDb(); - $writer = new EchoBatchRowWriter( $db, 'echo_event' ); - - $updates = array( - self::mockUpdate( array( 'something' => 'changed' ) ), - self::mockUpdate( array( 'otherthing' => 'changed' ) ), - self::mockUpdate( array( 'and' => 'something', 'else' => 'changed' ) ), - ); - - $db->expects( $this->exactly( count( $updates ) ) ) - ->method( 'update' ); - - $writer->write( $updates ); - } - - protected static function mockUpdate( array $changes ) { - static $i = 0; - - return array( - 'primaryKey' => array( 'event_id' => $i++ ), - 'changes' => $changes, - ); - } - - public function testReaderBasicIterate() { - $db = $this->mockDb(); - $batchSize = 2; - $reader = new EchoBatchRowIterator( $db, 'some_table', 'id_field', $batchSize ); - - $response = $this->genSelectResult( $batchSize, /*numRows*/ 5, function() { - static $i = 0; - - return array( 'id_field' => ++$i ); - } ); - $db->expects( $this->exactly( count( $response ) ) ) - ->method( 'select' ) - ->will( $this->consecutivelyReturnFromSelect( $response ) ); - - $pos = 0; - foreach ( $reader as $rows ) { - $this->assertEquals( $response[$pos], $rows, "Testing row in position $pos" ); - $pos++; - } - // -1 is because the final array() marks the end and isnt included - $this->assertEquals( count( $response ) - 1, $pos ); - } - - public static function provider_readerGetPrimaryKey() { - $row = array( - 'id_field' => 42, - 'some_col' => 'dvorak', - 'other_col' => 'samurai', - ); - - return array( - - array( - 'Must return single column pk when requested', - array( 'id_field' => 42 ), - $row - ), - - array( - 'Must return multiple column pks when requested', - array( 'id_field' => 42, 'other_col' => 'samurai' ), - $row - ), - - ); - } - - /** - * @dataProvider provider_readerGetPrimaryKey - */ - public function testReaderGetPrimaryKey( $message, array $expected, array $row ) { - $reader = new EchoBatchRowIterator( $this->mockDb(), 'some_table', array_keys( $expected ), 8675309 ); - $this->assertEquals( $expected, $reader->extractPrimaryKeys( (object)$row ), $message ); - } - - public static function provider_readerSetFetchColumns() { - return array( - - array( - 'Must merge primary keys into select conditions', - // Expected column select - array( 'foo', 'bar' ), - // primary keys - array( 'foo' ), - // setFetchColumn - array( 'bar' ) - ), - - array( - 'Must not merge primary keys into the all columns selector', - // Expected column select - array( '*' ), - // primary keys - array( 'foo' ), - // setFetchColumn - array( '*' ), - ), - - array( - 'Must not duplicate primary keys into column selector', - // Expected column select. - // TODO: figure out how to only assert the array_values portion and not the keys - array( 0 => 'foo', 1 => 'bar', 3 => 'baz' ), - // primary keys - array( 'foo', 'bar', ), - // setFetchColumn - array( 'bar', 'baz' ), - ), - ); - } - - /** - * @dataProvider provider_readerSetFetchColumns - */ - public function testReaderSetFetchColumns( $message, array $columns, array $primaryKeys, array $fetchColumns ) { - $db = $this->mockDb(); - $db->expects( $this->once() ) - ->method( 'select' ) - ->with( 'some_table', $columns )// only testing second parameter of DatabaseBase::select - ->will( $this->returnValue( new ArrayIterator( array() ) ) ); - - $reader = new EchoBatchRowIterator( $db, 'some_table', $primaryKeys, 22 ); - $reader->setFetchColumns( $fetchColumns ); - // triggers first database select - $reader->rewind(); - } - - public static function provider_readerSelectConditions() { - return array( - - array( - "With single primary key must generate id > 'value'", - // Expected second iteration - array( "( id_field > '3' )" ), - // Primary key(s) - 'id_field', - ), - - array( - 'With multiple primary keys the first conditions must use >= and the final condition must use >', - // Expected second iteration - array( "( id_field = '3' AND foo > '103' ) OR ( id_field > '3' )" ), - // Primary key(s) - array( 'id_field', 'foo' ), - ), - - ); - } - - /** - * Slightly hackish to use reflection, but asserting different parameters - * to consecutive calls of DatabaseBase::select in phpunit is error prone - * - * @dataProvider provider_readerSelectConditions - */ - public function testReaderSelectConditionsMultiplePrimaryKeys( $message, $expectedSecondIteration, $primaryKeys, $batchSize = 3 ) { - $results = $this->genSelectResult( $batchSize, $batchSize * 3, function () { - static $i = 0, $j = 100, $k = 1000; - - return array( 'id_field' => ++$i, 'foo' => ++$j, 'bar' => ++$k ); - } ); - $db = $this->mockDbConsecutiveSelect( $results ); - - $conditions = array( 'bar' => 42, 'baz' => 'hai' ); - $reader = new EchoBatchRowIterator( $db, 'some_table', $primaryKeys, $batchSize ); - $reader->addConditions( $conditions ); - - $buildConditions = new ReflectionMethod( $reader, 'buildConditions' ); - $buildConditions->setAccessible( true ); - - // On first iteration only the passed conditions must be used - $this->assertEquals( $conditions, $buildConditions->invoke( $reader ), - 'First iteration must return only the conditions passed in addConditions' ); - $reader->rewind(); - - // Second iteration must use the maximum primary key of last set - $this->assertEquals( - $conditions + $expectedSecondIteration, - $buildConditions->invoke( $reader ), - $message - ); - } - - protected function mockDbConsecutiveSelect( array $retvals ) { - $db = $this->mockDb(); - $db->expects( $this->any() ) - ->method( 'select' ) - ->will( $this->consecutivelyReturnFromSelect( $retvals ) ); - $db->expects( $this->any() ) - ->method( 'addQuotes' ) - ->will( $this->returnCallback( function ( $value ) { - return "'$value'"; // not real quoting: doesn't matter in test - } ) ); - - return $db; - } - - protected function consecutivelyReturnFromSelect( array $results ) { - $retvals = array(); - foreach ( $results as $rows ) { - // The DatabaseBase::select method returns iterators, so we do too. - $retvals[] = $this->returnValue( new ArrayIterator( $rows ) ); - } - - return call_user_func_array( array( $this, 'onConsecutiveCalls' ), $retvals ); - } - - protected function genSelectResult( $batchSize, $numRows, $rowGenerator ) { - $res = array(); - for ( $i = 0; $i < $numRows; $i += $batchSize ) { - $rows = array(); - for ( $j = 0; $j < $batchSize && $i + $j < $numRows; $j++ ) { - $rows [] = (object)call_user_func( $rowGenerator ); - } - $res[] = $rows; - } - $res[] = array(); // termination condition requires empty result for last row - return $res; - } - - protected function mockDb() { - // Cant mock from DatabaseType or DatabaseBase, they dont - // have the full gamut of methods - $databaseMysql = $this->getMockBuilder( 'DatabaseMysql' ) - ->disableOriginalConstructor() - ->getMock(); - $databaseMysql->expects( $this->any() ) - ->method( 'isOpen' ) - ->will( $this->returnValue( true ) ); - - return $databaseMysql; - } -} -- To view, visit https://gerrit.wikimedia.org/r/259397 To unsubscribe, visit https://gerrit.wikimedia.org/r/settings Gerrit-MessageType: merged Gerrit-Change-Id: I4c0d7187c2b847297dd0867faecba26185cfba37 Gerrit-PatchSet: 6 Gerrit-Project: mediawiki/extensions/Echo Gerrit-Branch: master Gerrit-Owner: Sn1per <geof...@gmail.com> Gerrit-Reviewer: Catrope <roan.katt...@gmail.com> Gerrit-Reviewer: Legoktm <legoktm.wikipe...@gmail.com> Gerrit-Reviewer: Mattflaschen <mflasc...@wikimedia.org> Gerrit-Reviewer: Sn1per <geof...@gmail.com> Gerrit-Reviewer: jenkins-bot <> _______________________________________________ MediaWiki-commits mailing list MediaWiki-commits@lists.wikimedia.org https://lists.wikimedia.org/mailman/listinfo/mediawiki-commits