我有两个具有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());
}
}