[Symfony][Doctrine]批量处理-具有ManyToOne关系的批量插入=错误:通过该关系找到了一个新实体



我有两个具有ManyToOne关系的实体:播放列表和播放列表视频。一个播放列表可以包含多个视频。播放列表视频属于播放列表。播放列表已存在于数据库中。

我正在尝试使用批量插入,但我得到:

A new entity was found through the relationship 'AppEntityPlaylistPlaylistVideo#playlist' that was not configured to cascade persist operations for entity: AppEntityPlaylistPlaylist__1. 
To solve this issue: Either explicitly call EntityManager#persist() on this unknown entity or configure cascade persist this association in the mapping for example @ManyToOne(..,cascade={"persist"}).

播放列表实体:

class Playlist
{
/**
* @ORMOneToMany(targetEntity=PlaylistVideo::class, mappedBy="playlist")
* @Groups({"playlist"})
*/
private Collection $videos;
...
public function addVideo(PlaylistVideo $video): self
{
if (!$this->videos->contains($video)) {
$this->videos[] = $video;
$video->setPlaylist($this);
}
return $this;
}

播放列表视频实体:

class PlaylistVideo
{
/**
* @ORMManyToOne(targetEntity=Playlist::class, inversedBy="videos")
* @ORMJoinColumn(nullable=false)
*/
private Playlist $playlist;
...
public function setPlaylist(Playlist $playlist): self
{
$this->playlist = $playlist;
return $this;
}

批量处理-批量插页:

/**
* Batch Processing - Bulk Inserts
* @param VideoDto[] $videos
*/
public function bulkInserts(Playlist $playlist, array $videos)
{
$this->em->getConnection()->getConfiguration()->setSQLLogger(null);
$videosAmount = count($videos);
$batchSize = 50;
for ($i = 0; $i < $videosAmount; $i++) {
$video = $videos[$i];
$playlistVideo = (new PlaylistVideo())
->setPlaylist($playlist)
->setVideoId($video->id)
->setTitle($video->title);
$this->em->persist($playlistVideo);
if (($i % $batchSize) === 0) {
$this->em->flush();
$this->em->clear();
}
}
$this->em->flush();
$this->em->clear();
}

我无法添加cascade={"persist"}(在播放列表视频@ORMManyToOne()中(,因为我不想最终有很多播放列表。

我已经尝试了所有的东西,但我不能只是把视频添加到播放列表中。

您调用$this->em->clear((;并且在它之后使用相同的播放列表实体。EntityManager不再知道它。你需要重新加载。

for ($i = 0; $i < $videosAmount; $i++) {
$video = $videos[$i];
$playlistVideo = (new PlaylistVideo())
->setPlaylist($playlist)
->setVideoId($video->id)
->setTitle($video->title);
$this->em->persist($playlistVideo);
if (($i % $batchSize) === 0) {
$this->em->flush();
$this->em->clear();
// Reload the Playlist entity after clearing the EntityManager
$playlist = $this->em->getRepository(Playlist::class)->find($playlist->getId());
}
}

相关内容

最新更新