Kandis exporter geschrieben
Deckel und Sohlhöhe werden gespeichert
This commit is contained in:
@@ -17,17 +17,21 @@ namespace SewerStammGen.DAL.Services.PostgresqlData
|
||||
|
||||
public async Task<Schacht> Create(Schacht entity)
|
||||
{
|
||||
string command = "INSERT INTO " + tableName + " (objektbezeichnung,rechtswert,hochwert,sohlhoehe,deckelhoehe,entwaesserung,ref_projekt_id) VALUES " +
|
||||
"(@1,@2,@3,@4,@5,@6,@7) RETURNING schacht_id";
|
||||
string command = "INSERT INTO " + tableName + " (" +
|
||||
"objektbezeichnung,deckelrechtswert,deckelhochwert," +
|
||||
"sohlrechtswert,sohlhochwert,sohlhoehe,deckelhoehe,entwaesserung,ref_projekt_id) VALUES " +
|
||||
"(@1,@2,@3,@4,@5,@6,@7,@8,@9) RETURNING schacht_id";
|
||||
using(var cmd = new NpgsqlCommand(command,conn))
|
||||
{
|
||||
cmd.Parameters.AddWithValue("1", entity.Objektbezeichnung);
|
||||
cmd.Parameters.AddWithValue("2", entity.RechtsWert);
|
||||
cmd.Parameters.AddWithValue("3", entity.HochWert);
|
||||
cmd.Parameters.AddWithValue("4", entity.SohlHoehe);
|
||||
cmd.Parameters.AddWithValue("5", entity.DeckelHoehe);
|
||||
cmd.Parameters.AddWithValue("6", (int)entity.Entwaesserung);
|
||||
cmd.Parameters.AddWithValue("7", entity.Projekt.Id);
|
||||
cmd.Parameters.AddWithValue("2", entity.DeckelRechtsWert);
|
||||
cmd.Parameters.AddWithValue("3", entity.DeckelHochWert);
|
||||
cmd.Parameters.AddWithValue("4", entity.SohlRechtsWert);
|
||||
cmd.Parameters.AddWithValue("5", entity.SohlHochWert);
|
||||
cmd.Parameters.AddWithValue("6", entity.SohlHoehe);
|
||||
cmd.Parameters.AddWithValue("7", entity.DeckelHoehe);
|
||||
cmd.Parameters.AddWithValue("8", (int)entity.Entwaesserung);
|
||||
cmd.Parameters.AddWithValue("9", entity.Projekt.Id);
|
||||
using var reader = await cmd.ExecuteReaderAsync();
|
||||
reader.Read();
|
||||
entity.Id = reader.GetInt32(0);
|
||||
@@ -51,12 +55,14 @@ namespace SewerStammGen.DAL.Services.PostgresqlData
|
||||
{
|
||||
Id = reader.GetInt32(0),
|
||||
Objektbezeichnung = reader.IsDBNull(1) ? "": reader.GetString(1),
|
||||
RechtsWert = reader.GetDecimal(2),
|
||||
HochWert = reader.GetDecimal(3),
|
||||
SohlHoehe = reader.GetDecimal(4),
|
||||
DeckelHoehe = reader.GetDecimal(5),
|
||||
Entwaesserung = (EEntwaeserung)reader.GetInt32(6),
|
||||
Projekt = new Projekt() { Id = reader.GetInt32(7) },
|
||||
DeckelRechtsWert = reader.GetDecimal(2),
|
||||
DeckelHochWert = reader.GetDecimal(3),
|
||||
DeckelHoehe = reader.GetDecimal(4),
|
||||
SohlRechtsWert = reader.GetDecimal(5),
|
||||
SohlHochWert = reader.GetDecimal(6),
|
||||
SohlHoehe = reader.GetDecimal(7),
|
||||
Entwaesserung = (EEntwaeserung)reader.GetInt32(8),
|
||||
Projekt = new Projekt() { Id = reader.GetInt32(9) },
|
||||
};
|
||||
}
|
||||
|
||||
@@ -87,17 +93,20 @@ namespace SewerStammGen.DAL.Services.PostgresqlData
|
||||
public async Task<Schacht> Update(Schacht entity)
|
||||
{
|
||||
string command = @"UPDATE " + tableName + " SET " +
|
||||
"objektbezeichnung=@1, rechtswert=@2, hochwert=@3, sohlhoehe=@4, deckelhoehe=@5, entwaesserung=@6, ref_projekt_id=@7 WHERE schacht_id=@8";
|
||||
"objektbezeichnung=@1, deckelrechtswert=@2, deckelhochwert=@3, deckelhoehe=@4, " +
|
||||
"sohlrechtswert=@5, sohlhochwert=@6, sohlhoehe=@7, entwaesserung=@8, ref_projekt_id=@9 WHERE schacht_id=@10";
|
||||
using(var cmd = new NpgsqlCommand(command,conn))
|
||||
{
|
||||
cmd.Parameters.AddWithValue("1", entity.Objektbezeichnung);
|
||||
cmd.Parameters.AddWithValue("2", entity.RechtsWert);
|
||||
cmd.Parameters.AddWithValue("3", entity.HochWert);
|
||||
cmd.Parameters.AddWithValue("4", entity.SohlHoehe);
|
||||
cmd.Parameters.AddWithValue("5", entity.DeckelHoehe);
|
||||
cmd.Parameters.AddWithValue("6", (int)entity.Entwaesserung);
|
||||
cmd.Parameters.AddWithValue("7", entity.Projekt.Id);
|
||||
cmd.Parameters.AddWithValue("8", entity.Id);
|
||||
cmd.Parameters.AddWithValue("2", entity.DeckelRechtsWert);
|
||||
cmd.Parameters.AddWithValue("3", entity.DeckelHochWert);
|
||||
cmd.Parameters.AddWithValue("4", entity.DeckelHoehe);
|
||||
cmd.Parameters.AddWithValue("5", entity.SohlRechtsWert);
|
||||
cmd.Parameters.AddWithValue("6", entity.SohlHochWert);
|
||||
cmd.Parameters.AddWithValue("7", entity.SohlHoehe);
|
||||
cmd.Parameters.AddWithValue("8", (int)entity.Entwaesserung);
|
||||
cmd.Parameters.AddWithValue("9", entity.Projekt.Id);
|
||||
cmd.Parameters.AddWithValue("10", entity.Id);
|
||||
|
||||
await cmd.ExecuteNonQueryAsync();
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user