clean families; Fixes #1171
This commit is contained in:
+15
-2
@@ -93,11 +93,24 @@ GROUP BY family.id;"
|
|||||||
}
|
}
|
||||||
|
|
||||||
pub async fn clean_families_without_members(db: &SqlitePool) {
|
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(
|
sqlx::query(
|
||||||
"DELETE FROM family
|
"DELETE FROM family
|
||||||
WHERE id NOT IN (
|
WHERE id NOT IN (
|
||||||
SELECT DISTINCT family_id
|
SELECT DISTINCT family_id
|
||||||
FROM user
|
FROM user
|
||||||
WHERE family_id IS NOT NULL
|
WHERE family_id IS NOT NULL
|
||||||
);",
|
);",
|
||||||
)
|
)
|
||||||
|
|||||||
Reference in New Issue
Block a user