feat(database/guild): adding the create/delete function
This commit is contained in:
parent
cf2ed59d62
commit
7a248785ac
1 changed files with 16 additions and 0 deletions
|
|
@ -47,6 +47,22 @@ fn protect_select(asked: Protect) -> &'static str {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
pub async fn create(db: &PgPool, guild_id: &str) -> Result<(), sqlx::Error> {
|
||||||
|
query("INSERT INTO guilds (guild_id) VALUES ($1) ON CONFLICT DO NOTHING")
|
||||||
|
.bind(guild_id)
|
||||||
|
.execute(db)
|
||||||
|
.await?;
|
||||||
|
Ok(())
|
||||||
|
}
|
||||||
|
|
||||||
|
pub async fn delete(db: &PgPool, guild_id: &str) -> Result<(), sqlx::Error> {
|
||||||
|
query("DELETE FROM guilds WHERE guild_id = $1")
|
||||||
|
.bind(guild_id)
|
||||||
|
.execute(db)
|
||||||
|
.await?;
|
||||||
|
Ok(())
|
||||||
|
}
|
||||||
|
|
||||||
pub async fn get(db: &PgPool, guild_id: &str) -> Result<Option<Guild>, sqlx::Error> {
|
pub async fn get(db: &PgPool, guild_id: &str) -> Result<Option<Guild>, sqlx::Error> {
|
||||||
let guild: Option<Guild> = query_as::<_, Guild>(
|
let guild: Option<Guild> = query_as::<_, Guild>(
|
||||||
"SELECT * FROM guilds WHERE guild_id = $1",
|
"SELECT * FROM guilds WHERE guild_id = $1",
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue