Method insert_songs_by_ref

src-tauri/database/src/database.rs:208–292

(&self, songs: &mut [Song])

    }

    pub fn insert_songs_by_ref(&self, songs: &mut [Song]) -> Result<()> {
        let mut conn = self.pool.get().unwrap();
        trace!("Inserting songs");
        for song in songs {
            if song.song._id.is_none() {
                song.song._id = Some(Uuid::new_v4().to_string());
            }

            let changed = insert_into(allsongs)
                .values(&song.song)
                .on_conflict(song_path)
                .do_update()
                .set(&song.song)
                .execute(&mut conn)?;

            if changed == 0 {
                continue;
            }

            if let Some(_album) = &mut song.album {
                let album_id_ = self
                    .get_albums(
                        QueryableAlbum::search_by_term(_album.album_name.clone()),
                        false,
                        &mut conn,
                    )?
                    .first()
                    .map(|v| v.album_id.clone().unwrap())
                    .unwrap_or_else(|| self.insert_album(&mut conn, _album).unwrap());

                AlbumBridge::insert_value(album_id_.clone(), song.song._id.clone().unwrap())
                    .insert_into(album_bridge)
                    .on_conflict_do_nothing()
                    .execute(&mut conn)?;

                _album.album_id = Some(album_id_);
            }

            if let Some(_artists) = &mut song.artists {
                for mut _artist in _artists {
                    let artist_id_ = self
                        .get_artists(
                            QueryableArtist::search_by_term(_artist.artist_name.clone()),
                            false,
                            &mut conn,
                        )?
                        .first()
                        .map(|v| v.artist_id.clone().unwrap())
                        .unwrap_or_else(|| self.insert_artist(&mut conn, _artist).unwrap());

                    ArtistBridge::insert_value(artist_id_.clone(), song.song._id.clone().unwrap())
                        .insert_into(artist_bridge)
                        .on_conflict_do_nothing()
                        .execute(&mut conn)?;

                    _artist.artist_id = Some(artist_id_);
                }
            }