Use a db transaction when deleting a feed.
This commit is contained in:
parent
d9ef4fed53
commit
12ffe5c231
@ -153,10 +153,13 @@ pub fn remove_feed(pd: &Podcast) -> QueryResult<()> {
|
||||
let db = connection();
|
||||
let con = db.get().unwrap();
|
||||
|
||||
delete_source(&con, pd.source_id())?;
|
||||
delete_podcast(&con, *pd.id())?;
|
||||
delete_podcast_episodes(&con, *pd.id())?;
|
||||
Ok(())
|
||||
con.transaction(|| -> QueryResult<()> {
|
||||
delete_source(&con, pd.source_id())?;
|
||||
delete_podcast(&con, *pd.id())?;
|
||||
delete_podcast_episodes(&con, *pd.id())?;
|
||||
info!("Feed removed from the Database.");
|
||||
Ok(())
|
||||
})
|
||||
}
|
||||
|
||||
pub fn delete_source(con: &SqliteConnection, source_id: i32) -> QueryResult<usize> {
|
||||
|
||||
Loading…
Reference in New Issue
Block a user