Reviewed-on: #1212
This commit was merged in pull request #1212.
This commit is contained in:
+15
-2
@@ -93,11 +93,24 @@ GROUP BY family.id;"
|
||||
}
|
||||
|
||||
pub async fn clean_families_without_members(db: &SqlitePool) {
|
||||
sqlx::query(
|
||||
"UPDATE user SET family_id = NULL
|
||||
WHERE family_id IN (
|
||||
SELECT family_id FROM user
|
||||
WHERE family_id IS NOT NULL
|
||||
GROUP BY family_id
|
||||
HAVING COUNT(*) = 1
|
||||
);",
|
||||
)
|
||||
.execute(db)
|
||||
.await
|
||||
.unwrap();
|
||||
|
||||
sqlx::query(
|
||||
"DELETE FROM family
|
||||
WHERE id NOT IN (
|
||||
SELECT DISTINCT family_id
|
||||
FROM user
|
||||
SELECT DISTINCT family_id
|
||||
FROM user
|
||||
WHERE family_id IS NOT NULL
|
||||
);",
|
||||
)
|
||||
|
||||
Reference in New Issue
Block a user