getBulkInsertEventCountsQuery()->execute([$event1, $event2]); $sql = <<getDbalConnection()->fetchAllAssociative($sql); Assert::assertCount(2, $eventCounts); $this->assertEqualsHourlyEventCount($event1, $eventCounts[0]); $this->assertEqualsHourlyEventCount($event2, $eventCounts[1]); } public function test_it_updates_the_event_count_and_updated_datetime_on_duplicate(): void { $event1 = new HourlyEventCount( 'erp', HourlyInterval::createFromDateTime( new \DateTimeImmutable('2020-01-01 10:59:59', new \DateTimeZone('UTC')) ), 100, EventTypes::PRODUCT_CREATED ); $this->getBulkInsertEventCountsQuery()->execute([$event1]); $event2 = new HourlyEventCount( 'erp', HourlyInterval::createFromDateTime( new \DateTimeImmutable('2020-01-01 10:59:59', new \DateTimeZone('UTC')) ), 200, EventTypes::PRODUCT_CREATED ); $this->getBulkInsertEventCountsQuery()->execute([$event2]); $sql = <<getDbalConnection()->fetchAllAssociative($sql); Assert::assertCount(1, $eventCounts); $this->assertEqualsHourlyEventCount($event2, $eventCounts[0]); } private function assertEqualsHourlyEventCount(HourlyEventCount $expected, array $actual): void { Assert::assertEquals( $expected->connectionCode(), $actual['connection_code'] ); Assert::assertEquals( $expected->hourlyInterval()->fromDateTime()->format('Y-m-d H:i:s'), $actual['event_datetime'] ); Assert::assertEquals( $expected->eventCount(), (int) $actual['event_count'] ); Assert::assertEquals( $expected->eventType(), $actual['event_type'] ); } protected function getConfiguration(): Configuration { return $this->catalog->useMinimalCatalog(); } private function getDbalConnection(): DbalConnection { return $this->get('database_connection'); } private function getBulkInsertEventCountsQuery(): BulkInsertEventCountsQueryInterface { return $this->get(DbalBulkInsertEventCountsQuery::class); } }