* @copyright 2019 Akeneo SAS (http://www.akeneo.com) * @license http://opensource.org/licenses/osl-3.0.php Open Software License (OSL 3.0) */ class DbalSelectPeriodEventCountPerConnectionQuery implements SelectPeriodEventCountPerConnectionQueryInterface { use PeriodEventCountTrait; private Connection $dbalConnection; public function __construct(Connection $dbalConnection) { $this->dbalConnection = $dbalConnection; } /** * @return PeriodEventCount[] */ public function execute( string $eventType, DateTimePeriod $period ): array { $connectionCodes = $this->getConnectionCodes($eventType); $perConnection = $this->getPeriodEventCountPerConnection($eventType, $period, $connectionCodes); $forAllConnections = $this->getPeriodEventCountForAllConnections($eventType, $period, $connectionCodes); return $this->createPeriodEventCountPerConnection( $period, $connectionCodes, \array_merge($perConnection, $forAllConnections), ); } /** * @return string[] */ private function getConnectionCodes(string $eventType): array { $sql = <<dbalConnection->executeQuery( $sql, [ 'flow_type' => $this->getFlowTypeForEventType($eventType), ], ); $connectionCodes = []; while ($code = $resultStmt->fetchOne()) { $connectionCodes[] = $code; } return $connectionCodes; } /** * @param string[] $connectionCodes * * @return array */ private function getPeriodEventCountPerConnection( string $eventType, DateTimePeriod $period, array $connectionCodes ): array { $sql = <<= :from_datetime AND audit.event_datetime < :up_to_datetime AND audit.event_type = :event_type WHERE connection_code IN (:connection_codes) ORDER BY conn.code, audit.event_datetime SQL; return $this->dbalConnection->executeQuery( $sql, [ 'event_type' => $eventType, 'from_datetime' => $period->start(), 'up_to_datetime' => $period->end(), 'connection_codes' => $connectionCodes, ], [ 'from_datetime' => Types::DATETIME_IMMUTABLE, 'up_to_datetime' => Types::DATETIME_IMMUTABLE, 'connection_codes' => Connection::PARAM_STR_ARRAY, ] )->fetchAllAssociative(); } /** * @param string[] $connectionCodes * * @return array */ private function getPeriodEventCountForAllConnections( string $eventType, DateTimePeriod $period, array $connectionCodes ): array { $sql = <<= :from_datetime AND event_datetime < :up_to_datetime AND event_type = :event_type GROUP BY event_datetime ORDER BY event_datetime SQL; return $this->dbalConnection->executeQuery( $sql, [ 'all' => AllConnectionCode::CODE, 'event_type' => $eventType, 'from_datetime' => $period->start(), 'up_to_datetime' => $period->end(), 'connection_codes' => $connectionCodes, ], [ 'from_datetime' => Types::DATETIME_IMMUTABLE, 'up_to_datetime' => Types::DATETIME_IMMUTABLE, 'connection_codes' => Connection::PARAM_STR_ARRAY, ] )->fetchAllAssociative(); } private function getFlowTypeForEventType(string $eventType): string { $flowType = ''; switch ($eventType) { case EventTypes::PRODUCT_CREATED: case EventTypes::PRODUCT_UPDATED: $flowType = FlowType::DATA_SOURCE; break; case EventTypes::PRODUCT_READ: $flowType = FlowType::DATA_DESTINATION; break; default: throw new \LogicException( \sprintf('$eventType must be "product_created", "product_updated" or "product_read", but "%s" given.', $eventType) ); } return $flowType; } }