em->getConnection(); $leadEventLogRepository = $this->em->getRepository(LeadEventLog::class); \assert($leadEventLogRepository instanceof LeadEventLogRepository); $insertStatement = $connection->prepare('INSERT INTO `'.MAUTIC_TABLE_PREFIX.'campaign_lead_event_log` (`event_id`, `lead_id`, `rotation`, `is_scheduled`, `system_triggered`) VALUES (?, ?, ?, ?, ?);'); $connection->executeQuery('SET FOREIGN_KEY_CHECKS=0;'); foreach ($this->getLeadCampaignEventData($eventId) as $row) { $insertStatement->executeQuery($row); } $connection->executeQuery('SET FOREIGN_KEY_CHECKS=1;'); Assert::assertCount(3, $leadEventLogRepository->findAll()); $leadEventLogRepository->removeEventLogs([(string) $eventId]); Assert::assertCount(0, $leadEventLogRepository->findAll()); } private function getLeadCampaignEventData(int $eventId): array { return [ [$eventId, 100, 200, 1, 1], [$eventId, 101, 201, 1, 1], [$eventId, 102, 202, 1, 1], ]; } }