rolle update hinzugefügt
This commit is contained in:
28
src/domain/rolle/repository/rolle_update.rs
Normal file
28
src/domain/rolle/repository/rolle_update.rs
Normal file
@@ -0,0 +1,28 @@
|
|||||||
|
use anyhow::Error;
|
||||||
|
|
||||||
|
use super::Repository;
|
||||||
|
use crate::database::Queryer;
|
||||||
|
use crate::domain::rolle::{entity, model};
|
||||||
|
|
||||||
|
impl Repository {
|
||||||
|
pub async fn rolle_update<'c, C: Queryer<'c>>(
|
||||||
|
&self,
|
||||||
|
db: C,
|
||||||
|
rolle: &entity::Rolle,
|
||||||
|
) -> Result<model::Rolle, Error> {
|
||||||
|
const QUERY: &str = r#"
|
||||||
|
UPDATE rollen
|
||||||
|
SET geaendert_am = $2, rollennname = $3 WHERE id = $1
|
||||||
|
RETURNING id, geaendert_am, rollenname, rollenname;
|
||||||
|
"#;
|
||||||
|
|
||||||
|
let rolle = sqlx::query_as::<_, model::Rolle>(QUERY)
|
||||||
|
.bind(rolle.id)
|
||||||
|
.bind(rolle.geaendert_am)
|
||||||
|
.bind(&rolle.gruppenname)
|
||||||
|
.fetch_one(db)
|
||||||
|
.await?;
|
||||||
|
|
||||||
|
Ok(rolle)
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -17,9 +17,6 @@ impl Service {
|
|||||||
geaendert_am: Some(Utc::now()),
|
geaendert_am: Some(Utc::now()),
|
||||||
};
|
};
|
||||||
|
|
||||||
// let created_id = self.repo.rolle_erstellen(&self.db, &rolle_input).await?;
|
|
||||||
// let rolle = self.repo.find_rolle_by_id(&self.db, created_id).await?;
|
|
||||||
|
|
||||||
let rolle = self.repo.rolle_erstellen(&self.db, &rolle_input).await?;
|
let rolle = self.repo.rolle_erstellen(&self.db, &rolle_input).await?;
|
||||||
Ok(rolle)
|
Ok(rolle)
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user