dbalConnection = $dbalConnection; } /** * @return PeriodEventCount[] */ public function execute(DateTimePeriod $period): array { $connectionCodes = $this->getConnectionCodes(); $perConnection = $this->getPeriodErrorCountPerConnection($period, $connectionCodes); $forAllConnections = $this->getPeriodErrorCountForAllConnections($period, $connectionCodes); return $this->createPeriodEventCountPerConnection( $period, $connectionCodes, \array_merge($perConnection, $forAllConnections) ); } /** * @return string[] */ private function getConnectionCodes(): array { $sql = <<dbalConnection->executeQuery( $sql, [ 'flow_type' => FlowType::DATA_SOURCE, ], ); $connectionCodes = []; while ($code = $resultStmt->fetchOne()) { $connectionCodes[] = $code; } return $connectionCodes; } /** * Return the count of errors per hour for each connection. * * @param string[] $connectionCodes * * @return array */ private function getPeriodErrorCountPerConnection(DateTimePeriod $period, array $connectionCodes): array { $sql = <<= :from_datetime AND error_datetime < :up_to_datetime GROUP BY connection_code, event_datetime ORDER BY connection_code ASC, error_datetime ASC SQL; return $this->dbalConnection->executeQuery( $sql, [ 'connection_codes' => $connectionCodes, 'from_datetime' => $period->start(), 'up_to_datetime' => $period->end(), ], [ 'connection_codes' => Connection::PARAM_STR_ARRAY, 'from_datetime' => Types::DATETIME_IMMUTABLE, 'up_to_datetime' => Types::DATETIME_IMMUTABLE, ] )->fetchAllAssociative(); } /** * Return the count of errors per hour for all the connections. * * @param string[] $connectionCodes * * @return array */ private function getPeriodErrorCountForAllConnections(DateTimePeriod $period, array $connectionCodes): array { $sql = <<= :from_datetime AND error_datetime < :up_to_datetime GROUP BY error_datetime ORDER BY error_datetime ASC SQL; return $this->dbalConnection->executeQuery( $sql, [ 'all' => AllConnectionCode::CODE, 'connection_codes' => $connectionCodes, 'from_datetime' => $period->start(), 'up_to_datetime' => $period->end(), ], [ 'connection_codes' => Connection::PARAM_STR_ARRAY, 'from_datetime' => Types::DATETIME_IMMUTABLE, 'up_to_datetime' => Types::DATETIME_IMMUTABLE, ] )->fetchAllAssociative(); } }