forked from Ruderverein-Donau-Linz/rowt
44 lines
1010 B
Rust
44 lines
1010 B
Rust
use serde::Serialize;
|
|
use sqlx::{FromRow, Row, SqlitePool};
|
|
|
|
#[derive(FromRow, Serialize, Clone)]
|
|
pub struct Stat {
|
|
name: String,
|
|
rowed_km: i32,
|
|
}
|
|
|
|
impl Stat {
|
|
pub async fn get_rowed_km(db: &SqlitePool) -> Vec<Stat> {
|
|
//TODO: switch to query! macro again (once upgraded to sqlite 3.42 on server)
|
|
sqlx::query(
|
|
"
|
|
SELECT u.name, SUM(sub.distance_in_km) AS rowed_km
|
|
FROM user u
|
|
INNER JOIN (
|
|
SELECT r.rower_id AS user_id, l.distance_in_km
|
|
FROM logbook l
|
|
INNER JOIN rower r ON l.id = r.logbook_id
|
|
WHERE l.distance_in_km IS NOT NULL
|
|
|
|
UNION ALL
|
|
|
|
SELECT l.shipmaster AS user_id, l.distance_in_km
|
|
FROM logbook l
|
|
WHERE l.distance_in_km IS NOT NULL
|
|
) sub ON u.id = sub.user_id
|
|
GROUP BY u.name
|
|
ORDER BY rowed_km DESC;
|
|
",
|
|
)
|
|
.fetch_all(db)
|
|
.await
|
|
.unwrap()
|
|
.into_iter()
|
|
.map(|row| Stat {
|
|
name: row.get("name"),
|
|
rowed_km: row.get("rowed_km"),
|
|
})
|
|
.collect()
|
|
}
|
|
}
|