From 46322f94c6b5afdfd0c62ebce0812540a1d3f80f Mon Sep 17 00:00:00 2001 From: Peter Date: Wed, 27 May 2026 14:31:33 +0200 Subject: [PATCH] =?UTF-8?q?rolle=20update=20hinzugef=C3=BCgt?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/domain/rolle/repository/rolle_update.rs | 28 +++++++++++++++++++++ src/domain/rolle/repository/update_rolle.rs | 0 src/domain/rolle/service/rolle_erstellen.rs | 3 --- 3 files changed, 28 insertions(+), 3 deletions(-) create mode 100644 src/domain/rolle/repository/rolle_update.rs delete mode 100644 src/domain/rolle/repository/update_rolle.rs diff --git a/src/domain/rolle/repository/rolle_update.rs b/src/domain/rolle/repository/rolle_update.rs new file mode 100644 index 0000000..fc1f00f --- /dev/null +++ b/src/domain/rolle/repository/rolle_update.rs @@ -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 { + 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) + } +} diff --git a/src/domain/rolle/repository/update_rolle.rs b/src/domain/rolle/repository/update_rolle.rs deleted file mode 100644 index e69de29..0000000 diff --git a/src/domain/rolle/service/rolle_erstellen.rs b/src/domain/rolle/service/rolle_erstellen.rs index 1b87b06..195865b 100644 --- a/src/domain/rolle/service/rolle_erstellen.rs +++ b/src/domain/rolle/service/rolle_erstellen.rs @@ -17,9 +17,6 @@ impl Service { 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?; Ok(rolle) }