wikimedia / mediawiki

		$ticket = $factory->getEmptyTransactionTicket( __METHOD__ );

		// Update page_touched (skipping pages already touched since the root job).

		// Check $wgUpdateRowsPerQuery for sanity; batch jobs are sized by that already.

		foreach ( array_chunk( $pageIds, $wgUpdateRowsPerQuery ) as $batch ) {

			$factory->commitAndWaitForReplication( __METHOD__, $ticket );

			$dbw->update( 'page',

				[ 'page_touched' => $dbw->timestamp( $touchTimestamp ) ],

				[ 'page_id' => $batch,

					// don't invalidated pages that were already invalidated

					"page_touched < " . $dbw->addQuotes( $dbw->timestamp( $touchTimestamp ) )

				],

				__METHOD__

			);

		}

		// Get the list of affected pages (races only mean something else did the purge)

		$titleArray = TitleArray::newFromResult( $dbw->select(

			'page',

				$batchSize = $services->getMainConfig()->get( 'UpdateRowsPerQuery' );

				$ticket = $lbFactory->getEmptyTransactionTicket( __METHOD__ );

				foreach ( array_chunk( $ids, $batchSize ) as $idBatch ) {

					$dbw->update(

						'page',

						[ 'page_touched' => $now ],

						[

							'page_id' => $idBatch,

							'page_touched < ' . $dbw->addQuotes( $now ) // handle races

						],

						__METHOD__

					);

					$lbFactory->commitAndWaitForReplication( __METHOD__, $ticket );

				}

			},

			__METHOD__

		);