Code cleanup

SewerStammGen.DAL/Services/AuftraggeberDataService.cs

@@ -9,33 +9,45 @@ using System.Threading.Tasks;
 
 namespace SewerStammGen.DAL.Services
 {
-    public class AuftraggeberDataService : IAuftraggeberDataService
+    public class AuftraggeberDataService : PostgresqlDataService, IAuftraggeberDataService 
     {
-        string connString = "Host = localhost; Database = SewerGen; Username = SewerGen; Password = SewerGen";
-        NpgsqlDataSource dataSource;
-        NpgsqlConnection? conn = null;
-        public AuftraggeberDataService()
-        {
-            var dataSourceBuilder = new NpgsqlDataSourceBuilder(connString);
-            dataSource = dataSourceBuilder.Build();
+        /*
+         * CREATE TABLE public."Auftraggebers"
+(
+    "Id" serial,
+    "Name" text,
+    "Strasse" text,
+    "Ort" text,
+    "Postleitzahl" text,
+    "Ansprechpartner" text,
+    "Telefonnummer" text,
+    PRIMARY KEY ("Id")
+);
 
-            //OpenConnection();
-            conn = dataSource.OpenConnection();
-
-        }
-        public Task<Auftraggeber> Create(Auftraggeber entity)
+ALTER TABLE IF EXISTS public."Auftraggebers"
+    OWNER to "SewerGen";
+        */
+        public AuftraggeberDataService() : base("public.\"Auftraggebers\"") { }
+        
+        public async Task<Auftraggeber> Create(Auftraggeber entity)
         {
-            throw new NotImplementedException();
-        }
+            string command = "INSERT INTO public.\"Auftraggebers\" (\"Name\", \"Strasse\", \"Ort\", \"Postleitzahl\", \"Ansprechpartner\", \"Telefonnummer\") " +
+                "VALUES(@1,@2,@3,@4,@5,@6) RETURNING \"Id\"";
 
-        public Auftraggeber CreateNonAsync(Auftraggeber entity)
-        {
-            throw new NotImplementedException();
-        }
-
-        public Task<bool> Delete(int id)
-        {
-            throw new NotImplementedException();
+            await using (var cmd = new NpgsqlCommand(command, conn))
+            {
+                cmd.Parameters.AddWithValue("1", entity.Name);
+                cmd.Parameters.AddWithValue("2", entity.Strasse);
+                cmd.Parameters.AddWithValue("3", entity.Ort);
+                cmd.Parameters.AddWithValue("4", entity.Postleitzahl);
+                cmd.Parameters.AddWithValue("5", entity.Ansprechpartner);
+                cmd.Parameters.AddWithValue("6", entity.Telefonnummer);
+                
+                using var reader = await cmd.ExecuteReaderAsync();
+                reader.Read();
+                entity.Id = reader.GetInt32(0);
+            }
+            return entity;
         }
 
         public async Task<Auftraggeber> Get(int id)
@@ -48,9 +60,7 @@ namespace SewerStammGen.DAL.Services
                 reader.Read();
                 result = parseAuftraggeber(reader);
             }
-            
-            return result;
-                    
+            return result;       
         }
 
         private Auftraggeber parseAuftraggeber(NpgsqlDataReader reader)
@@ -81,7 +91,7 @@ namespace SewerStammGen.DAL.Services
             return result;
         }
 
-        public Task<Auftraggeber> Update(int id, Auftraggeber entity)
+        public Task<Auftraggeber> Update(Auftraggeber entity)
         {
             throw new NotImplementedException();
         }