flibusta-apps/library_updater
1
0
Fork 0
mirror of https://github.com/flibusta-apps/library_updater.git synced 2025-12-06 15:45:36 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

Add update_genre function to upsert genres

Browse Source 
Replace previous function that managed book_genres. New SQL function
upserts the genres table by source and remote_id, updating code,
description and meta or inserting a new row. Removed book lookup and
book_genres insertion.
This commit is contained in:
Bulat Kurbanov
2025-10-25 20:49:36 +02:00
parent e1af1c2623
commit 65e23787f1
1 changed files with 8 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
src/types.rs
View File

@@ -830,22 +830,17 @@ impl Update for Genre {
async fn before_update(client: &Client) -> Result<(), Box<tokio_postgres::Error>> { async fn before_update(client: &Client) -> Result<(), Box<tokio_postgres::Error>> {
match client.execute( match client.execute(
" "
CREATE OR REPLACE FUNCTION update_book_sequence(source_ smallint, book_ integer, genre_ integer) RETURNS void AS $$ CREATE OR REPLACE FUNCTION update_genre(
DECLARE source_ smallint, remote_id_ int, code_ varchar, description_ varchar, meta_ varchar
book_id integer := -1; ) RETURNS void AS $$
genre_id integer := -1;
BEGIN BEGIN
SELECT id INTO book_id FROM books WHERE source = source_ AND remote_id = book_; IF EXISTS (SELECT * FROM genres WHERE source = source_ AND remote_id = remote_id_) THEN
UPDATE genres SET code = code_, description = description_, meta = meta_
IF book_id IS NULL THEN WHERE source = source_ AND remote_id = remote_id_;
RETURN; RETURN;
END IF; END IF;
INSERT INTO genres (source, remote_id, code, description, meta)
SELECT id INTO genre_id FROM genres WHERE source = source_ AND remote_id = genre_; VALUES (source_, remote_id_, code_, description_, meta_);
IF EXISTS (SELECT * FROM book_genres WHERE book = book_id AND genre = genre_id) THEN
RETURN;
END IF;
INSERT INTO book_genres (book, genre) VALUES (book_id, genre_id);
END; END;
$$ LANGUAGE plpgsql; $$ LANGUAGE plpgsql;
" "