From c7b0174742fb963778ec0dd5a8461c1abfa86ecb Mon Sep 17 00:00:00 2001 From: alikia2x Date: Tue, 14 Oct 2025 01:55:46 +0800 Subject: [PATCH] fix: the SQL to write producer column into songs table --- packages/crawler/mq/task/collectSongs.ts | 11 +++++++++-- 1 file changed, 9 insertions(+), 2 deletions(-) diff --git a/packages/crawler/mq/task/collectSongs.ts b/packages/crawler/mq/task/collectSongs.ts index 031177e..b187af7 100644 --- a/packages/crawler/mq/task/collectSongs.ts +++ b/packages/crawler/mq/task/collectSongs.ts @@ -18,12 +18,19 @@ export async function collectSongs() { export async function insertIntoSongs(sql: Psql, aid: number) { await sql` - INSERT INTO songs (aid, published_at, duration, image) + INSERT INTO songs (aid, published_at, duration, image, producer) VALUES ( $1, (SELECT published_at FROM bilibili_metadata WHERE aid = ${aid}), (SELECT duration FROM bilibili_metadata WHERE aid = ${aid}), - (SELECT cover_url FROM bilibili_metadata WHERE aid = ${aid}) + (SELECT cover_url FROM bilibili_metadata WHERE aid = ${aid}), + ( + SELECT username + FROM bilibili_user bu + JOIN bilibili_metadata bm + ON bm.uid = bu.uid + WHERE bm.aid = ${aid} + ) ) ON CONFLICT DO NOTHING `;