resourceConnection->getConnection(); $connection->insertOnDuplicate( $this->resourceConnection->getTableName(self::TABLE_NAME), [ 'campaign_code' => $campaignCode, 'customer_id' => $customerId, 'email' => $normalizedEmail, 'website_id' => $websiteId, 'store_id' => $storeId, ], [] ); } }