Merge pull request #39 from peppy/reduce-bss-query-data

bdach · web-flow · commit 933985ba4728 · 2026-02-24T11:59:54.000+01:00
Reduce data received when querying database via `BeatmapStatusWatcher`
diff --git a/osu.Server.QueueProcessor/BeatmapStatusWatcher.cs b/osu.Server.QueueProcessor/BeatmapStatusWatcher.cs
@@ -56,7 +56,7 @@ public static async Task<BeatmapUpdates> GetUpdatedBeatmapSetsAsync(int? lastQue
 
             if (lastQueueId.HasValue)
             {
-                var items = (await connection.QueryAsync<bss_process_queue_item>("SELECT * FROM bss_process_queue WHERE queue_id > @lastQueueId ORDER BY queue_id LIMIT @limit", new
+                var items = (await connection.QueryAsync<bss_process_queue_item>("SELECT queue_id, beatmapset_id FROM bss_process_queue WHERE queue_id > @lastQueueId ORDER BY queue_id LIMIT @limit", new
                 {
                     lastQueueId,
                     limit
@@ -69,7 +69,7 @@ public static async Task<BeatmapUpdates> GetUpdatedBeatmapSetsAsync(int? lastQue
                 };
             }
 
-            var lastEntry = await connection.QueryFirstOrDefaultAsync<bss_process_queue_item>("SELECT * FROM bss_process_queue ORDER BY queue_id DESC LIMIT 1");
+            var lastEntry = await connection.QueryFirstOrDefaultAsync<bss_process_queue_item>("SELECT queue_id, beatmapset_id FROM bss_process_queue ORDER BY queue_id DESC LIMIT 1");
 
             return new BeatmapUpdates
             {

Original file line number	Diff line number	Diff line change
`@@ -56,7 +56,7 @@ public static async Task<BeatmapUpdates> GetUpdatedBeatmapSetsAsync(int? lastQue`
`56`	`56`
`57`	`57`	`if (lastQueueId.HasValue)`
`58`	`58`	`{`
`59`		`- var items = (await connection.QueryAsync<bss_process_queue_item>("SELECT * FROM bss_process_queue WHERE queue_id > @lastQueueId ORDER BY queue_id LIMIT @limit", new`
	`59`	`+ var items = (await connection.QueryAsync<bss_process_queue_item>("SELECT queue_id, beatmapset_id FROM bss_process_queue WHERE queue_id > @lastQueueId ORDER BY queue_id LIMIT @limit", new`
`60`	`60`	`{`
`61`	`61`	`lastQueueId,`
`62`	`62`	`limit`
`@@ -69,7 +69,7 @@ public static async Task<BeatmapUpdates> GetUpdatedBeatmapSetsAsync(int? lastQue`
`69`	`69`	`};`
`70`	`70`	`}`
`71`	`71`
`72`		`- var lastEntry = await connection.QueryFirstOrDefaultAsync<bss_process_queue_item>("SELECT * FROM bss_process_queue ORDER BY queue_id DESC LIMIT 1");`
	`72`	`+ var lastEntry = await connection.QueryFirstOrDefaultAsync<bss_process_queue_item>("SELECT queue_id, beatmapset_id FROM bss_process_queue ORDER BY queue_id DESC LIMIT 1");`
`73`	`73`
`74`	`74`	`return new BeatmapUpdates`
`75`	`75`	`{`