From 3a60d8eb6ac94754c646a067f696e50733618c39 Mon Sep 17 00:00:00 2001
From: Peter <peter.schiwy@gmail.com>
Date: Mon, 1 Jun 2026 22:14:34 +0200
Subject: [PATCH] add liegenschaft

---
 src/domain.rs                                 |  1 +
 src/domain/liegenschaft.rs                    |  6 +++
 src/domain/liegenschaft/dataloader.rs         |  0
 src/domain/liegenschaft/entity.rs             |  2 +
 .../liegenschaft/entity/liegenschaft.rs       |  9 ++++
 src/domain/liegenschaft/model.rs              |  9 ++++
 src/domain/liegenschaft/model/liegenschaft.rs | 22 ++++++++
 .../model/liegenschaft_erstelle_input.rs      |  7 +++
 .../model/liegenschaft_loeschen_input.rs      |  7 +++
 .../model/liegenschaft_update_input.rs        | 10 ++++
 src/domain/liegenschaft/queries.rs            |  1 +
 .../liegenschaft/queries/liegenschaft.rs      | 16 ++++++
 src/domain/liegenschaft/repository.rs         | 22 ++++++++
 .../repository/liegenschaft_alle.rs           | 21 ++++++++
 .../repository/liegenschaft_dataloader.rs     |  0
 .../repository/liegenschaft_einen_zeigen.rs   | 25 +++++++++
 .../repository/liegenschaft_erstelle_viele.rs | 51 +++++++++++++++++++
 .../repository/liegenschaft_erstellen.rs      | 30 +++++++++++
 .../repository/liegenschaft_loeschen.rs       | 24 +++++++++
 .../repository/liegenschaft_update.rs         | 28 ++++++++++
 src/domain/liegenschaft/service.rs            | 22 ++++++++
 .../liegenschaft/service/liegenschaft_alle.rs | 12 +++++
 .../service/liegenschaft_dataloader.rs        | 15 ++++++
 .../service/liegenschaft_erstellen.rs         | 30 +++++++++++
 .../service/liegenschaft_erstellen_viele.rs   | 34 +++++++++++++
 .../service/liegenschaft_loeschen.rs          | 30 +++++++++++
 .../service/liegenschaft_update.rs            | 30 +++++++++++
 src/mutations/liegenschaft.rs                 | 46 +++++++++++++++++
 src/mutations/mod.rs                          |  2 +
 src/queries/mod.rs                            |  8 +--
 30 files changed, 516 insertions(+), 4 deletions(-)
 create mode 100644 src/domain/liegenschaft.rs
 create mode 100644 src/domain/liegenschaft/dataloader.rs
 create mode 100644 src/domain/liegenschaft/entity.rs
 create mode 100644 src/domain/liegenschaft/entity/liegenschaft.rs
 create mode 100644 src/domain/liegenschaft/model.rs
 create mode 100644 src/domain/liegenschaft/model/liegenschaft.rs
 create mode 100644 src/domain/liegenschaft/model/liegenschaft_erstelle_input.rs
 create mode 100644 src/domain/liegenschaft/model/liegenschaft_loeschen_input.rs
 create mode 100644 src/domain/liegenschaft/model/liegenschaft_update_input.rs
 create mode 100644 src/domain/liegenschaft/queries.rs
 create mode 100644 src/domain/liegenschaft/queries/liegenschaft.rs
 create mode 100644 src/domain/liegenschaft/repository.rs
 create mode 100644 src/domain/liegenschaft/repository/liegenschaft_alle.rs
 create mode 100644 src/domain/liegenschaft/repository/liegenschaft_dataloader.rs
 create mode 100644 src/domain/liegenschaft/repository/liegenschaft_einen_zeigen.rs
 create mode 100644 src/domain/liegenschaft/repository/liegenschaft_erstelle_viele.rs
 create mode 100644 src/domain/liegenschaft/repository/liegenschaft_erstellen.rs
 create mode 100644 src/domain/liegenschaft/repository/liegenschaft_loeschen.rs
 create mode 100644 src/domain/liegenschaft/repository/liegenschaft_update.rs
 create mode 100644 src/domain/liegenschaft/service.rs
 create mode 100644 src/domain/liegenschaft/service/liegenschaft_alle.rs
 create mode 100644 src/domain/liegenschaft/service/liegenschaft_dataloader.rs
 create mode 100644 src/domain/liegenschaft/service/liegenschaft_erstellen.rs
 create mode 100644 src/domain/liegenschaft/service/liegenschaft_erstellen_viele.rs
 create mode 100644 src/domain/liegenschaft/service/liegenschaft_loeschen.rs
 create mode 100644 src/domain/liegenschaft/service/liegenschaft_update.rs
 create mode 100644 src/mutations/liegenschaft.rs

diff --git a/src/domain.rs b/src/domain.rs
index 92bf6ba..51f5645 100644
--- a/src/domain.rs
+++ b/src/domain.rs
@@ -1,4 +1,5 @@
 pub mod benutzer;
 pub mod gruppe;
+pub mod liegenschaft;
 pub mod rolle;
 pub mod typ;
diff --git a/src/domain/liegenschaft.rs b/src/domain/liegenschaft.rs
new file mode 100644
index 0000000..758c8f6
--- /dev/null
+++ b/src/domain/liegenschaft.rs
@@ -0,0 +1,6 @@
+pub mod dataloader;
+pub mod entity;
+pub mod model;
+pub mod queries;
+pub mod repository;
+pub mod service;
diff --git a/src/domain/liegenschaft/dataloader.rs b/src/domain/liegenschaft/dataloader.rs
new file mode 100644
index 0000000..e69de29
diff --git a/src/domain/liegenschaft/entity.rs b/src/domain/liegenschaft/entity.rs
new file mode 100644
index 0000000..3a51104
--- /dev/null
+++ b/src/domain/liegenschaft/entity.rs
@@ -0,0 +1,2 @@
+pub mod liegenschaft;
+pub use liegenschaft::Liegenschaft;
diff --git a/src/domain/liegenschaft/entity/liegenschaft.rs b/src/domain/liegenschaft/entity/liegenschaft.rs
new file mode 100644
index 0000000..1073b58
--- /dev/null
+++ b/src/domain/liegenschaft/entity/liegenschaft.rs
@@ -0,0 +1,9 @@
+use crate::scalar::{Id, Time};
+
+pub struct Liegenschaft {
+    pub id_liegenschaft: Id,
+    pub id: String,
+    pub liegenschaftname: String,
+    pub erstellt_am: Option<Time>,
+    pub geaendert_am: Option<Time>,
+}
diff --git a/src/domain/liegenschaft/model.rs b/src/domain/liegenschaft/model.rs
new file mode 100644
index 0000000..c4d8f2d
--- /dev/null
+++ b/src/domain/liegenschaft/model.rs
@@ -0,0 +1,9 @@
+mod liegenschaft;
+mod liegenschaft_erstelle_input;
+mod liegenschaft_loeschen_input;
+mod liegenschaft_update_input;
+
+pub use liegenschaft::Liegenschaft;
+pub use liegenschaft_erstelle_input::LiegenschaftErstelleInput;
+pub use liegenschaft_loeschen_input::LiegenschaftLoeschenInput;
+pub use liegenschaft_update_input::LiegenschaftUpdateInput;
diff --git a/src/domain/liegenschaft/model/liegenschaft.rs b/src/domain/liegenschaft/model/liegenschaft.rs
new file mode 100644
index 0000000..d0b6977
--- /dev/null
+++ b/src/domain/liegenschaft/model/liegenschaft.rs
@@ -0,0 +1,22 @@
+use async_graphql::{ComplexObject, SimpleObject};
+
+use crate::scalar::Time;
+
+#[derive(sqlx::FromRow, SimpleObject, Clone, Debug)]
+#[graphql(complex)]
+pub struct Liegenschaft {
+    /// Die ULID einer Liegenschaft
+    pub id: String,
+
+    /// Der Liegenschaftname
+    pub liegenschaftname: String,
+
+    /// Wann die Liegenschaft erstellt wurde
+    pub erstellt_am: Time,
+
+    /// Wann die Liegenschaft geaendert wurde
+    pub geaendert_am: Time,
+}
+
+#[ComplexObject]
+impl Liegenschaft {}
diff --git a/src/domain/liegenschaft/model/liegenschaft_erstelle_input.rs b/src/domain/liegenschaft/model/liegenschaft_erstelle_input.rs
new file mode 100644
index 0000000..7a4426c
--- /dev/null
+++ b/src/domain/liegenschaft/model/liegenschaft_erstelle_input.rs
@@ -0,0 +1,7 @@
+use async_graphql::InputObject;
+
+#[derive(InputObject)]
+pub struct LiegenschaftErstelleInput {
+    /// Der Name eines Geräteliegenschafts
+    pub liegenschaftname: String,
+}
diff --git a/src/domain/liegenschaft/model/liegenschaft_loeschen_input.rs b/src/domain/liegenschaft/model/liegenschaft_loeschen_input.rs
new file mode 100644
index 0000000..db11d76
--- /dev/null
+++ b/src/domain/liegenschaft/model/liegenschaft_loeschen_input.rs
@@ -0,0 +1,7 @@
+use async_graphql::InputObject;
+
+#[derive(InputObject)]
+pub struct LiegenschaftLoeschenInput {
+    /// Die ULID einer Liegenschaft
+    pub id: String,
+}
diff --git a/src/domain/liegenschaft/model/liegenschaft_update_input.rs b/src/domain/liegenschaft/model/liegenschaft_update_input.rs
new file mode 100644
index 0000000..2b61d59
--- /dev/null
+++ b/src/domain/liegenschaft/model/liegenschaft_update_input.rs
@@ -0,0 +1,10 @@
+use async_graphql::InputObject;
+
+#[derive(InputObject)]
+pub struct LiegenschaftUpdateInput {
+    /// Die ULID einer Liegenschaft
+    pub id: String,
+
+    /// Der Name einer Liegenschaft
+    pub liegenschaftname: String,
+}
diff --git a/src/domain/liegenschaft/queries.rs b/src/domain/liegenschaft/queries.rs
new file mode 100644
index 0000000..0f2ea98
--- /dev/null
+++ b/src/domain/liegenschaft/queries.rs
@@ -0,0 +1 @@
+pub mod liegenschaft;
diff --git a/src/domain/liegenschaft/queries/liegenschaft.rs b/src/domain/liegenschaft/queries/liegenschaft.rs
new file mode 100644
index 0000000..4c5ae61
--- /dev/null
+++ b/src/domain/liegenschaft/queries/liegenschaft.rs
@@ -0,0 +1,16 @@
+use async_graphql::{Context, FieldResult, Object};
+use sqlx::postgres::PgPool;
+
+use crate::domain::liegenschaft::{model::Liegenschaft, service::Service};
+
+#[derive(Default)]
+pub struct LiegenschaftQuery {}
+
+#[Object(extends)]
+impl LiegenschaftQuery {
+    async fn liegenschaften(&self, ctx: &Context<'_>) -> FieldResult<Vec<Liegenschaft>> {
+        let pool = ctx.data::<PgPool>()?;
+        let liegenschaften = Service::new(pool.clone()).liegenschaft_alle().await?;
+        Ok(liegenschaften)
+    }
+}
diff --git a/src/domain/liegenschaft/repository.rs b/src/domain/liegenschaft/repository.rs
new file mode 100644
index 0000000..b7d8747
--- /dev/null
+++ b/src/domain/liegenschaft/repository.rs
@@ -0,0 +1,22 @@
+mod liegenschaft_alle;
+mod liegenschaft_dataloader;
+mod liegenschaft_einen_zeigen;
+mod liegenschaft_erstelle_viele;
+mod liegenschaft_erstellen;
+mod liegenschaft_loeschen;
+mod liegenschaft_update;
+
+#[derive(Debug, Clone)]
+pub struct Repository {}
+
+impl Repository {
+    pub fn new() -> Repository {
+        Repository {}
+    }
+}
+
+impl Default for Repository {
+    fn default() -> Self {
+        Self::new()
+    }
+}
diff --git a/src/domain/liegenschaft/repository/liegenschaft_alle.rs b/src/domain/liegenschaft/repository/liegenschaft_alle.rs
new file mode 100644
index 0000000..c31c7fa
--- /dev/null
+++ b/src/domain/liegenschaft/repository/liegenschaft_alle.rs
@@ -0,0 +1,21 @@
+use anyhow::Error;
+
+use super::Repository;
+use crate::{database::Queryer, domain::liegenschaft::model};
+
+impl Repository {
+    pub async fn liegenschaft_alle<'c, C: Queryer<'c>>(
+        &self,
+        db: C,
+    ) -> Result<Vec<model::Liegenschaft>, Error> {
+        const QUERY: &str = r#"
+            SELECT id, erstellt_am, geaendert_am, liegenschaftname FROM liegenschaften
+        "#;
+
+        let liegenschaften = sqlx::query_as::<_, model::Liegenschaft>(QUERY)
+            .fetch_all(db)
+            .await?;
+
+        Ok(liegenschaften)
+    }
+}
diff --git a/src/domain/liegenschaft/repository/liegenschaft_dataloader.rs b/src/domain/liegenschaft/repository/liegenschaft_dataloader.rs
new file mode 100644
index 0000000..e69de29
diff --git a/src/domain/liegenschaft/repository/liegenschaft_einen_zeigen.rs b/src/domain/liegenschaft/repository/liegenschaft_einen_zeigen.rs
new file mode 100644
index 0000000..936b2a3
--- /dev/null
+++ b/src/domain/liegenschaft/repository/liegenschaft_einen_zeigen.rs
@@ -0,0 +1,25 @@
+use anyhow::Error;
+
+use super::Repository;
+use crate::{database::Queryer, domain::liegenschaft::model, scalar::Id};
+
+impl Repository {
+    pub async fn liegenschaft_zeige_einen<'c, C: Queryer<'c>>(
+        &self,
+        db: C,
+        id: Id,
+    ) -> Result<model::Liegenschaft, Error> {
+        const QUERY: &str = r#"
+            SELECT id, erstellt_am, geaendert_am, liegenschaftname
+            FROM liegenschaften
+            WHERE id = $1
+        "#;
+
+        let row = sqlx::query_as::<_, model::Liegenschaft>(QUERY)
+            .bind(id)
+            .fetch_one(db)
+            .await?;
+
+        Ok(row)
+    }
+}
diff --git a/src/domain/liegenschaft/repository/liegenschaft_erstelle_viele.rs b/src/domain/liegenschaft/repository/liegenschaft_erstelle_viele.rs
new file mode 100644
index 0000000..d4f11a8
--- /dev/null
+++ b/src/domain/liegenschaft/repository/liegenschaft_erstelle_viele.rs
@@ -0,0 +1,51 @@
+use anyhow::Error;
+
+use super::Repository;
+use crate::database::Queryer;
+use crate::domain::liegenschaft::entity;
+use crate::domain::liegenschaft::model::{self};
+use crate::scalar::{Id, Time};
+
+impl Repository {
+    pub async fn liegenschaft_viele_erstellen<'c, C: Queryer<'c>>(
+        &self,
+        db: C,
+        liegenschaften: &[entity::Liegenschaft], // input: &[Liegenschaft],
+    ) -> Result<Vec<model::Liegenschaft>, Error> {
+        let id_liegenschaft: Vec<Id> = liegenschaften.iter().map(|t| t.id_liegenschaft).collect();
+
+        let id: Vec<String> = liegenschaften.iter().map(|t| t.id.clone()).collect();
+
+        let liegenschaftnamen: Vec<String> = liegenschaften
+            .iter()
+            .map(|t| t.liegenschaftname.clone())
+            .collect();
+
+        let erstellt_am: Vec<Option<Time>> = liegenschaften.iter().map(|t| t.erstellt_am).collect();
+
+        let geaendert_am: Vec<Option<Time>> =
+            liegenschaften.iter().map(|t| t.geaendert_am).collect();
+
+        const QUERY: &str = r#"
+            INSERT INTO liegenschaften (id_liegenschaft, id, liegenschaftname, erstellt_am, geaendert_am)
+            SELECT * FROM UNNEST(
+                $1::uuid[],
+                $2::text[],
+                $3::text[],
+                $4::TIMESTAMP[],
+                $5::TIMESTAMP[]
+            ) RETURNING id, erstellt_am, geaendert_am, liegenschaftname;
+        "#;
+
+        let rows = sqlx::query_as::<_, model::Liegenschaft>(QUERY)
+            .bind(id_liegenschaft)
+            .bind(id)
+            .bind(liegenschaftnamen)
+            .bind(erstellt_am)
+            .bind(geaendert_am)
+            .fetch_all(db)
+            .await?;
+
+        Ok(rows)
+    }
+}
diff --git a/src/domain/liegenschaft/repository/liegenschaft_erstellen.rs b/src/domain/liegenschaft/repository/liegenschaft_erstellen.rs
new file mode 100644
index 0000000..3986a94
--- /dev/null
+++ b/src/domain/liegenschaft/repository/liegenschaft_erstellen.rs
@@ -0,0 +1,30 @@
+use anyhow::Error;
+
+use super::Repository;
+use crate::database::Queryer;
+use crate::domain::liegenschaft::{entity, model};
+
+impl Repository {
+    pub async fn liegenschaft_erstellen<'c, C: Queryer<'c>>(
+        &self,
+        db: C,
+        liegenschaft: &entity::Liegenschaft,
+    ) -> Result<model::Liegenschaft, Error> {
+        const QUERY: &str = r#"
+            INSERT INTO liegenschaften (id_liegenschaft, id, erstellt_am, geaendert_am, liegenschaftname) VALUES (
+                $1, $2, $3, $4, $5
+            ) RETURNING id, erstellt_am, geaendert_am, liegenschaftname;
+        "#;
+
+        let liegenschaft = sqlx::query_as::<_, model::Liegenschaft>(QUERY)
+            .bind(liegenschaft.id_liegenschaft)
+            .bind(liegenschaft.id.to_string())
+            .bind(liegenschaft.erstellt_am)
+            .bind(liegenschaft.geaendert_am)
+            .bind(&liegenschaft.liegenschaftname)
+            .fetch_one(db)
+            .await?;
+
+        Ok(liegenschaft)
+    }
+}
diff --git a/src/domain/liegenschaft/repository/liegenschaft_loeschen.rs b/src/domain/liegenschaft/repository/liegenschaft_loeschen.rs
new file mode 100644
index 0000000..61a183e
--- /dev/null
+++ b/src/domain/liegenschaft/repository/liegenschaft_loeschen.rs
@@ -0,0 +1,24 @@
+use anyhow::Error;
+
+use super::Repository;
+use crate::database::Queryer;
+use crate::domain::liegenschaft::{entity, model};
+
+impl Repository {
+    pub async fn liegenschaft_loeschen<'c, C: Queryer<'c>>(
+        &self,
+        db: C,
+        liegenschaft: &entity::Liegenschaft,
+    ) -> Result<model::Liegenschaft, Error> {
+        const QUERY: &str = r#"
+            DELETE FROM liegenschaften WHERE id=$1 RETURNING id, erstellt_am, geaendert_am, liegenschaftname;
+        "#;
+
+        let liegenschaft = sqlx::query_as::<_, model::Liegenschaft>(QUERY)
+            .bind(liegenschaft.id.to_string())
+            .fetch_one(db)
+            .await?;
+
+        Ok(liegenschaft)
+    }
+}
diff --git a/src/domain/liegenschaft/repository/liegenschaft_update.rs b/src/domain/liegenschaft/repository/liegenschaft_update.rs
new file mode 100644
index 0000000..25be578
--- /dev/null
+++ b/src/domain/liegenschaft/repository/liegenschaft_update.rs
@@ -0,0 +1,28 @@
+use anyhow::Error;
+
+use super::Repository;
+use crate::database::Queryer;
+use crate::domain::liegenschaft::{entity, model};
+
+impl Repository {
+    pub async fn liegenschaft_update<'c, C: Queryer<'c>>(
+        &self,
+        db: C,
+        liegenschaft: &entity::Liegenschaft,
+    ) -> Result<model::Liegenschaft, Error> {
+        const QUERY: &str = r#"
+            UPDATE liegenschaften
+            SET geaendert_am = $2, liegenschaftname = $3 WHERE id = $1
+            RETURNING id, erstellt_am, geaendert_am, liegenschaftname;
+        "#;
+
+        let liegenschaft = sqlx::query_as::<_, model::Liegenschaft>(QUERY)
+            .bind(liegenschaft.id.to_string())
+            .bind(liegenschaft.geaendert_am)
+            .bind(&liegenschaft.liegenschaftname)
+            .fetch_one(db)
+            .await?;
+
+        Ok(liegenschaft)
+    }
+}
diff --git a/src/domain/liegenschaft/service.rs b/src/domain/liegenschaft/service.rs
new file mode 100644
index 0000000..b25de6b
--- /dev/null
+++ b/src/domain/liegenschaft/service.rs
@@ -0,0 +1,22 @@
+mod liegenschaft_alle;
+// mod liegenschaft_dataloader;
+mod liegenschaft_erstellen;
+mod liegenschaft_erstellen_viele;
+mod liegenschaft_loeschen;
+mod liegenschaft_update;
+
+use super::repository::Repository;
+use crate::database::DB;
+
+#[derive(Debug)]
+pub struct Service {
+    repo: Repository,
+    pub db: DB,
+}
+
+impl Service {
+    pub fn new(db: DB) -> Self {
+        let repo = Repository::new();
+        Self { repo, db }
+    }
+}
diff --git a/src/domain/liegenschaft/service/liegenschaft_alle.rs b/src/domain/liegenschaft/service/liegenschaft_alle.rs
new file mode 100644
index 0000000..20a6a49
--- /dev/null
+++ b/src/domain/liegenschaft/service/liegenschaft_alle.rs
@@ -0,0 +1,12 @@
+use anyhow::Error;
+
+use crate::domain::liegenschaft::model;
+
+use super::Service;
+
+impl Service {
+    pub async fn liegenschaft_alle(&self) -> Result<Vec<model::Liegenschaft>, Error> {
+        let liegenschaft = self.repo.liegenschaft_alle(&self.db).await?;
+        Ok(liegenschaft)
+    }
+}
diff --git a/src/domain/liegenschaft/service/liegenschaft_dataloader.rs b/src/domain/liegenschaft/service/liegenschaft_dataloader.rs
new file mode 100644
index 0000000..cf5b122
--- /dev/null
+++ b/src/domain/liegenschaft/service/liegenschaft_dataloader.rs
@@ -0,0 +1,15 @@
+use std::{collections::HashMap, sync::Arc};
+
+use crate::{domain::liegenschaft::model::Liegenschaft, scalar::Id};
+
+use super::Service;
+
+impl Service {
+    pub async fn liegenschaft_dataloader(
+        &self,
+        keys: &[Id],
+    ) -> Result<HashMap<Id, Vec<Liegenschaft>>, Arc<sqlx::Error>> {
+        let liegenschaften_dataloader = self.repo.liegenschaft_dataloader(&self.db, keys).await?;
+        Ok(liegenschaften_dataloader)
+    }
+}
diff --git a/src/domain/liegenschaft/service/liegenschaft_erstellen.rs b/src/domain/liegenschaft/service/liegenschaft_erstellen.rs
new file mode 100644
index 0000000..1405571
--- /dev/null
+++ b/src/domain/liegenschaft/service/liegenschaft_erstellen.rs
@@ -0,0 +1,30 @@
+use anyhow::Error;
+use chrono::Utc;
+use ulid::Ulid;
+
+use super::Service;
+use crate::domain::liegenschaft::{
+    entity,
+    model::{self, LiegenschaftErstelleInput},
+};
+
+impl Service {
+    pub async fn liegenschaft_erstellen(
+        &self,
+        input: LiegenschaftErstelleInput,
+    ) -> Result<model::Liegenschaft, Error> {
+        let liegenschaft_input = entity::Liegenschaft {
+            id_liegenschaft: Ulid::new().into(),
+            id: Ulid::new().to_string(),
+            liegenschaftname: input.liegenschaftname,
+            erstellt_am: Some(Utc::now()),
+            geaendert_am: Some(Utc::now()),
+        };
+
+        let liegenschaft = self
+            .repo
+            .liegenschaft_erstellen(&self.db, &liegenschaft_input)
+            .await?;
+        Ok(liegenschaft)
+    }
+}
diff --git a/src/domain/liegenschaft/service/liegenschaft_erstellen_viele.rs b/src/domain/liegenschaft/service/liegenschaft_erstellen_viele.rs
new file mode 100644
index 0000000..7a15409
--- /dev/null
+++ b/src/domain/liegenschaft/service/liegenschaft_erstellen_viele.rs
@@ -0,0 +1,34 @@
+use anyhow::Error;
+use chrono::Utc;
+use ulid::Ulid;
+
+use super::Service;
+use crate::domain::liegenschaft::{
+    entity,
+    model::{self, LiegenschaftErstelleInput},
+};
+
+impl Service {
+    pub async fn liegenschaft_erstellen_viele(
+        &self,
+        input: &[LiegenschaftErstelleInput],
+    ) -> Result<Vec<model::Liegenschaft>, Error> {
+        let liegenschaften_input: Vec<entity::Liegenschaft> = input
+            .iter()
+            .map(|t| entity::Liegenschaft {
+                id_liegenschaft: Ulid::new().into(),
+                id: Ulid::new().to_string(),
+                liegenschaftname: t.liegenschaftname.clone(),
+                erstellt_am: Some(Utc::now()),
+                geaendert_am: Some(Utc::now()),
+            })
+            .collect();
+
+        let liegenschaften = self
+            .repo
+            .liegenschaft_viele_erstellen(&self.db, &liegenschaften_input)
+            .await?;
+
+        Ok(liegenschaften)
+    }
+}
diff --git a/src/domain/liegenschaft/service/liegenschaft_loeschen.rs b/src/domain/liegenschaft/service/liegenschaft_loeschen.rs
new file mode 100644
index 0000000..c0d7e99
--- /dev/null
+++ b/src/domain/liegenschaft/service/liegenschaft_loeschen.rs
@@ -0,0 +1,30 @@
+use anyhow::Error;
+use chrono::Utc;
+use ulid::Ulid;
+
+use super::Service;
+use crate::domain::liegenschaft::{
+    entity,
+    model::{self, LiegenschaftLoeschenInput},
+};
+
+impl Service {
+    pub async fn liegenschaft_loeschen(
+        &self,
+        input: LiegenschaftLoeschenInput,
+    ) -> Result<model::Liegenschaft, Error> {
+        let liegenschaft_input = entity::Liegenschaft {
+            id_liegenschaft: Ulid::new().into(),
+            id: input.id,
+            liegenschaftname: String::new(),
+            erstellt_am: None,
+            geaendert_am: Some(Utc::now()),
+        };
+
+        let liegenschaft = self
+            .repo
+            .liegenschaft_loeschen(&self.db, &liegenschaft_input)
+            .await?;
+        Ok(liegenschaft)
+    }
+}
diff --git a/src/domain/liegenschaft/service/liegenschaft_update.rs b/src/domain/liegenschaft/service/liegenschaft_update.rs
new file mode 100644
index 0000000..c07ae43
--- /dev/null
+++ b/src/domain/liegenschaft/service/liegenschaft_update.rs
@@ -0,0 +1,30 @@
+use anyhow::Error;
+use chrono::Utc;
+use ulid::Ulid;
+
+use super::Service;
+use crate::domain::liegenschaft::{
+    entity,
+    model::{self, LiegenschaftUpdateInput},
+};
+
+impl Service {
+    pub async fn liegenschaft_update(
+        &self,
+        input: LiegenschaftUpdateInput,
+    ) -> Result<model::Liegenschaft, Error> {
+        let liegenschaft_input = entity::Liegenschaft {
+            id_liegenschaft: Ulid::new().into(),
+            id: input.id,
+            liegenschaftname: input.liegenschaftname,
+            erstellt_am: None,
+            geaendert_am: Some(Utc::now()),
+        };
+
+        let liegenschaft = self
+            .repo
+            .liegenschaft_update(&self.db, &liegenschaft_input)
+            .await?;
+        Ok(liegenschaft)
+    }
+}
diff --git a/src/mutations/liegenschaft.rs b/src/mutations/liegenschaft.rs
new file mode 100644
index 0000000..4641ae3
--- /dev/null
+++ b/src/mutations/liegenschaft.rs
@@ -0,0 +1,46 @@
+use crate::domain::liegenschaft::{
+    model::{Liegenschaft, LiegenschaftErstelleInput, LiegenschaftLoeschenInput, LiegenschaftUpdateInput},
+    service::Service,
+};
+
+use async_graphql::{Context, FieldResult};
+use sqlx::postgres::PgPool;
+
+#[derive(Default)]
+pub struct LiegenschaftMutation;
+
+#[async_graphql::Object]
+impl LiegenschaftMutation {
+    async fn erstelle_liegenschaft(&self, ctx: &Context<'_>, input: LiegenschaftErstelleInput) -> FieldResult<Liegenschaft> {
+        let pool = ctx.data::<PgPool>()?;
+
+        let liegenschaft = Service::new(pool.clone()).liegenschaft_erstellen(input).await?;
+        Ok(liegenschaft)
+    }
+
+    async fn erstelle_viele_liegenschaften(
+        &self,
+        ctx: &Context<'_>,
+        input: Vec<LiegenschaftErstelleInput>,
+    ) -> FieldResult<Vec<Liegenschaft>> {
+        let pool = ctx.data::<PgPool>()?;
+
+        let gruppe = Service::new(pool.clone())
+            .liegenschaft_erstellen_viele(&input)
+            .await?;
+        Ok(gruppe)
+    }
+
+    async fn update_liegenschaft(&self, ctx: &Context<'_>, input: LiegenschaftUpdateInput) -> FieldResult<Liegenschaft> {
+        let pool = ctx.data::<PgPool>()?;
+
+        let liegenschaft = Service::new(pool.clone()).liegenschaft_update(input).await?;
+        Ok(liegenschaft)
+    }
+
+    async fn loesche_liegenschaft(&self, ctx: &Context<'_>, input: LiegenschaftLoeschenInput) -> FieldResult<Liegenschaft> {
+        let pool = ctx.data::<PgPool>()?;
+        let liegenschaft = Service::new(pool.clone()).liegenschaft_loeschen(input).await?;
+        Ok(liegenschaft)
+    }
+}
diff --git a/src/mutations/mod.rs b/src/mutations/mod.rs
index 5d4dc5f..b9e67e6 100644
--- a/src/mutations/mod.rs
+++ b/src/mutations/mod.rs
@@ -2,6 +2,7 @@ pub mod benutzer;
 pub mod gruppe;
 // pub mod hersteller;
 // pub mod modell;
+pub mod liegenschaft;
 pub mod rolle;
 pub mod typ;
 
@@ -15,4 +16,5 @@ pub struct Mutation(
     benutzer::BenutzerMutation,
     gruppe::GruppeMutation,
     rolle::RolleMutation,
+    liegenschaft::LiegenschaftMutation,
 );
diff --git a/src/queries/mod.rs b/src/queries/mod.rs
index a07e85e..9abf127 100644
--- a/src/queries/mod.rs
+++ b/src/queries/mod.rs
@@ -1,8 +1,8 @@
 // pub mod hersteller;
 // pub mod modell;
 use crate::domain::{
-    benutzer::queries::benutzer, gruppe::queries::gruppe, rolle::queries::rolle,
-    typ::queries::typ::TypQuery,
+    benutzer::queries::benutzer, gruppe::queries::gruppe, liegenschaft::queries::liegenschaft,
+    rolle::queries::rolle, typ::queries::typ::TypQuery,
 };
 
 use async_graphql::MergedObject;
@@ -13,6 +13,6 @@ pub struct Query(
     benutzer::BenutzerQuery,
     rolle::RolleQuery,
     gruppe::GruppeQuery,
-    // modell::ModellQuery,
-    // hersteller::HerstellerQuery,
+    liegenschaft::LiegenschaftQuery, // modell::ModellQuery,
+                                     // hersteller::HerstellerQuery,
 );