ForgeFlux/starchart
2
0
Fork 0
Code Issues Pull requests 2 Projects Releases Packages Wiki Activity Actions

feat: impl interface to del user and repo sqlx sqlite

Browse source
This commit is contained in:
Aravinth Manivannan 2022-05-17 16:15:04 +05:30
parent 5481055e45
commit 65176bbdea
Signed by: realaravinth
GPG key ID: AD9F0F08E855ED88
2 changed files with 54 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
db/db-sqlx-sqlite/sqlx-data.json
View file

@ -54,6 +54,16 @@
},
"query": "SELECT ID FROM starchart_forge_type WHERE name = $1"
},
"364c8e3d147318b864fd28ad284f225aaace9479b5cf0428fb97f0e5689e248d": {
"describe": {
"columns": [],
"nullable": [],
"parameters": {
"Right": 2
}
},
"query": " DELETE FROM starchart_users WHERE username = $1 AND \n hostname_id = (SELECT ID FROM starchart_forges WHERE hostname = $2)"
},
"6f5ca3d71a541eb6f33e37a5889c048536ab6ad7e81a6236d73aa71433c13717": {
"describe": {
"columns": [],
@ -140,6 +150,16 @@
},
"query": "\n INSERT INTO starchart_repository_topic_mapping ( topic_id, repository_id )\n VALUES (\n (SELECT ID FROM starchart_project_topics WHERE name = $1),\n (SELECT ID FROM starchart_repositories WHERE html_url = $2)\n );"
},
"ed20e6fcac091172778119cdfc68c8e511224205a0bb7c74df192dcdfbfe63f2": {
"describe": {
"columns": [],
"nullable": [],
"parameters": {
"Right": 3
}
},
"query": " DELETE FROM starchart_repositories\n WHERE \n name = $1\n AND\n owner_id = ( SELECT ID FROM starchart_users WHERE username = $2)\n AND\n hostname_id = (SELECT ID FROM starchart_forges WHERE hostname = $3)"
},
"f52cde89ec10d5ca2151c9df6ae273ee0d52af9f79bb776765cfa716aad6af53": {
"describe": {
"columns": [],

34
db/db-sqlx-sqlite/src/lib.rs
View file

@ -296,6 +296,40 @@ impl SCDatabase for Database {
Ok(())
}
/// delete user
async fn delete_user(&self, username: &str, hostname: &str) -> DBResult<()> {
sqlx::query!(
" DELETE FROM starchart_users WHERE username = $1 AND
hostname_id = (SELECT ID FROM starchart_forges WHERE hostname = $2)",
username,
hostname
)
.execute(&self.pool)
.await
.map_err(map_register_err)?;
Ok(())
}
/// delete repository
async fn delete_repository(&self, owner: &str, name: &str, hostname: &str) -> DBResult<()> {
sqlx::query!(
" DELETE FROM starchart_repositories
WHERE
name = $1
AND
owner_id = ( SELECT ID FROM starchart_users WHERE username = $2)
AND
hostname_id = (SELECT ID FROM starchart_forges WHERE hostname = $3)",
name,
owner,
hostname
)
.execute(&self.pool)
.await
.map_err(map_register_err)?;
Ok(())
}
}
fn now_unix_time_stamp() -> i64 {