diff options
author | Dennis Kobert <dennis@kobert.dev> | 2021-02-19 11:07:39 +0000 |
---|---|---|
committer | Dennis Kobert <dennis@kobert.dev> | 2021-02-19 11:07:39 +0000 |
commit | a3dda94db49570f7f1e6484b49bca9196c317493 (patch) | |
tree | 07519190d8cfbf76ba7ddf2b170f008ea652f83c /src | |
parent | bc5da83a645c22e10971455b1a180cf62684b275 (diff) |
Fix sql code
Diffstat (limited to 'src')
-rw-r--r-- | src/database.rs | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/database.rs b/src/database.rs index a5204a1..7b548de 100644 --- a/src/database.rs +++ b/src/database.rs @@ -156,9 +156,9 @@ pub async fn match_users(lobby: String, names: &[&str]) -> Result<String, Error> JOIN suser USING (user_id) JOIN track USING (track_id) JOIN lobby USING (lobby_id) - WHERE suser.user_name IN (SELECT user_name FROM users) AND token = $1 + WHERE suser.user_name IN (SELECT * FROM users) AND token = $1 GROUP BY track_id - ---HAVING COUNT(track_id) = (SELECT COUNT(*) FROM users) + HAVING COUNT(track_id) = (SELECT COUNT(*) FROM users) ORDER BY SUM(score) DESC ) AS _ USING (track_id) ; @@ -172,7 +172,7 @@ pub async fn match_users(lobby: String, names: &[&str]) -> Result<String, Error> use futures::{pin_mut, TryStreamExt}; let mut it = client.query_raw(query.as_str(), values).await?; pin_mut!(it); - for row in it.try_next().await? { + while let Some(row) = it.try_next().await? { let name: String = row.get(1); let artist: String = row.get(2); songs = format!("{}{} by {}\n", songs, name, artist); |