Entityframework hinzugefügt

SewerStammGen.EntityFramework/Services/Common/NonQueryDataService.cs

@@ -0,0 +1,54 @@
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.ChangeTracking;
+using Shared.Domain;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace SewerStammGen.EntityFramework.Services.Common
+{
+    class NonQueryDataService<T> where T: DBObject
+    {
+        private readonly SewerStammGenDbContextFactory _contextFactory;
+
+        public NonQueryDataService(SewerStammGenDbContextFactory contextFactory)
+        {
+            _contextFactory = contextFactory;
+        }
+        public async Task<T> Create(T entity)
+        {
+            using SewerStammGenDbContext context = _contextFactory.CreateDbContext();
+            EntityEntry<T> createdEntity = await context.Set<T>().AddAsync(entity);
+            await context.SaveChangesAsync();
+            return createdEntity.Entity;
+        }
+
+        public T CreateNonAsync(T entity)
+        {
+            using SewerStammGenDbContext context = _contextFactory.CreateDbContext();
+            EntityEntry<T> createdEntity = context.Set<T>().Add(entity);
+            context.SaveChanges();
+            return createdEntity.Entity;
+        }
+
+        public async Task<bool> Delete(int id)
+        {
+            using SewerStammGenDbContext context = _contextFactory.CreateDbContext();
+            T entity = await context.Set<T>().FirstOrDefaultAsync((e) => e.Id == id);
+            context.Set<T>().Remove(entity);
+            await context.SaveChangesAsync();
+            return true;
+        }
+        public async Task<T> Update(int id, T entity)
+        {
+            using SewerStammGenDbContext context = _contextFactory.CreateDbContext();
+            entity.Id = id;
+            context.Set<T>().Update(entity);
+            await context.SaveChangesAsync();
+            return entity;
+        }
+
+    }
+}