AuftraggeberListview intial

This commit is contained in:
2023-07-03 19:15:57 +02:00
parent 287c7aaa0a
commit 33f9da3798
16 changed files with 184 additions and 27 deletions

View File

@@ -19,10 +19,8 @@ namespace SewerStammGen.DAL.Services.PostgresqlData
public async Task<Kanal> Create(Kanal entity)
{
string command = "INSERT INTO " + tableName + " (" +
"objektbezeichnung,ref_startschacht_id,ref_endschacht_id," +
"dn,material,haltungslaenge, entwaesserung,ref_projekt_id) VALUES " +
"(@1,@2,@3,@4,@5,@6,@7,@8) RETURNING haltung_id";
string command = $"INSERT INTO {tableName} (objektbezeichnung,ref_startschacht_id,ref_endschacht_id,dn,material,haltungslaenge, entwaesserung,ref_projekt_id)" +
$"VALUES (@1,@2,@3,@4,@5,@6,@7,@8) RETURNING haltung_id";
using (var cmd = new NpgsqlCommand(command, conn))
{
cmd.Parameters.AddWithValue("1", entity.Objektbezeichnung);
@@ -56,7 +54,7 @@ namespace SewerStammGen.DAL.Services.PostgresqlData
ISchachtDataService schachtDataService = new SchachtDataService(connString);
IEnumerable<Schacht> schaechte = await schachtDataService.GetAllByProjekt(projektID);
string command = "SELECT * FROM " + tableName + " WHERE ref_projekt_id = @1";
string command = $"SELECT * FROM {tableName} WHERE ref_projekt_id = @1";
using (var cmd = new NpgsqlCommand(command, conn))
{
cmd.Parameters.AddWithValue("1", projektID);
@@ -103,15 +101,8 @@ namespace SewerStammGen.DAL.Services.PostgresqlData
public async Task<Kanal> Update(Kanal entity)
{
string command = "UPDATE " + tableName + " SET " +
" objektbezeichnung=@1, " +
" ref_startschacht_id=@2, " +
" ref_endschacht_id=@3, " +
" dn=@4, " +
" material=@5, " +
" haltungslaenge=@6, " +
" entwaesserung=@7 " +
" WHERE haltung_id = @8";
string command = $"UPDATE {tableName} SET objektbezeichnung=@1, " +
$"ref_startschacht_id=@2, ref_endschacht_id=@3, dn=@4, material=@5, haltungslaenge=@6, entwaesserung=@7 WHERE haltung_id = @8";
using(var cmd = new NpgsqlCommand(command,conn))
{
cmd.Parameters.AddWithValue("1", entity.Objektbezeichnung);

View File

@@ -21,8 +21,8 @@ namespace SewerStammGen.DAL.Services.PostgresqlData
public async Task<Projekt> Create(Projekt entity)
{
string command = "INSERT INTO "+tableName+" (projektname, erstelldatum, strasse, ort, exporttype, kodierungssystem,ref_auftraggeber_id) " +
"VALUES(@1,@2,@3,@4,@5,@6,@7) RETURNING projekt_id";
string command = $"INSERT INTO {tableName} (projektname, erstelldatum, strasse, ort, exporttype, kodierungssystem,ref_auftraggeber_id) " +
$"VALUES(@1,@2,@3,@4,@5,@6,@7) RETURNING projekt_id";
if (entity.Auftraggeber.Id == 0)
{
@@ -61,7 +61,7 @@ namespace SewerStammGen.DAL.Services.PostgresqlData
{
Projekt result = new Projekt();
IAuftraggeberDataService auftraggeberDataService = new AuftraggeberDataService(connString);
using (var cmd = new NpgsqlCommand($"SELECT * FROM "+tableName+" WHERE projekt_id = @1", conn))
using (var cmd = new NpgsqlCommand($"SELECT * FROM {tableName} WHERE projekt_id = @1", conn))
{
cmd.Parameters.AddWithValue("1", id);
using var reader = await cmd.ExecuteReaderAsync();
@@ -93,7 +93,7 @@ namespace SewerStammGen.DAL.Services.PostgresqlData
IEnumerable<Auftraggeber> auftraggebers = await auftraggeberDataService.GetAll();
List<Projekt> result = new List<Projekt>();
using (var cmd = new NpgsqlCommand($"SELECT * FROM " + tableName, conn))
using (var cmd = new NpgsqlCommand($"SELECT * FROM {tableName}", conn))
using (var reader = await cmd.ExecuteReaderAsync())
{
while (reader.Read())
@@ -108,7 +108,7 @@ namespace SewerStammGen.DAL.Services.PostgresqlData
public async Task<Projekt> Update(Projekt entity)
{
string command = "UPDATE "+tableName+ " SET projektname=@1, erstelldatum=@2, strasse=@3, ort=@4, exporttype=@5, kodierungssystem=@6,ref_auftraggeber_id=@7 WHERE projekt_id = @8";
string command = $"UPDATE {tableName} SET projektname=@1, erstelldatum=@2, strasse=@3, ort=@4, exporttype=@5, kodierungssystem=@6,ref_auftraggeber_id=@7 WHERE projekt_id = @8";
using (var cmd = new NpgsqlCommand(command, conn))
{
cmd.Parameters.AddWithValue("1", entity.Projektname);