dbConnection = $dbConnection; } /** * Returns an object PurgeableVersionList at each iteration * * Key set pagination. @see https://use-the-index-luke.com/sql/partial-results/fetch-next-page * This query is doing row lookup to filter on resource name. * As most of the versions are for products, the rows are not filtered by "resource_name" filter most of the time. * It's therefore not a big deal to do row lookup. */ public function youngerThan(string $resourceName, \DateTime $date, int $listSize): iterable { $query = << :last_id) OR logged_at > :logged_at ) ORDER BY logged_at ASC, id ASC LIMIT :list_size SQL; return $this->fetchVersionIds($query, $resourceName, $date, $listSize, 0); } /** * Returns an object PurgeableVersionList at each iteration * * Key set pagination. @see https://use-the-index-luke.com/sql/partial-results/fetch-next-page * This query is doing row lookup to filter on resource name. * As most of the versions are for products, the rows are not filtered by "resource_name" filter most of the time. * It's therefore not a big deal to do row lookup. * * Please note that we iterate in the opposite direction by ordering by DESC both columns logged_at and id. * In fact, it's not possible to iterate efficiently in the same direction as for the youngerThan method. */ public function olderThan(string $resourceName, \DateTime $date, int $listSize): iterable { $query = <<fetchVersionIds($query, $resourceName, $date, $listSize, PHP_INT_MAX); } private function fetchVersionIds( string $query, string $resourceName, \DateTime $date, int $listSize, int $startingId ): iterable { $loggedAt = $date->format('Y-m-d'); $statement = $this->dbConnection->prepare($query); $statement->bindParam('resource_name', $resourceName, \PDO::PARAM_STR); $statement->bindParam('list_size', $listSize, \PDO::PARAM_INT); $lastId = $startingId; do { $statement->bindParam('logged_at', $loggedAt, \PDO::PARAM_STR); $statement->bindParam('last_id', $lastId, \PDO::PARAM_INT); $results = $statement->executeQuery()->fetchAllAssociative(); if (!empty($results)) { $lastResult = end($results); $lastId = $lastResult['id']; $loggedAt = $lastResult['logged_at']; yield new PurgeableVersionList( $resourceName, array_map(function ($row) { return intval($row['id']); }, $results) ); } } while (!empty($results)); } public function countByResource(string $resourceName): int { $query = 'SELECT COUNT(*) FROM pim_versioning_version WHERE resource_name = :resource_name'; $count = $this->dbConnection->executeQuery($query, [ 'resource_name' => $resourceName, ])->fetchOne(); return intval($count); } }