diff --git a/SanSystem/Database/UpdateDatabase.cs b/SanSystem/Database/UpdateDatabase.cs index 791362a..2b1c80f 100644 --- a/SanSystem/Database/UpdateDatabase.cs +++ b/SanSystem/Database/UpdateDatabase.cs @@ -82,12 +82,80 @@ namespace Database auftraggeberDA.Update(dtauftraggeber); + //Imprägnierberichte DataTable dtimprägnierberichte = new DataTable(); using (var reader = ObjectReader.Create(source.Imprägnierungen)) { dtimprägnierberichte.Load(reader); } + Command = new SQLiteCommand("SELECT * FROM Projekt",Connection); + SQLiteDataAdapter projektDA = new SQLiteDataAdapter(); + cmd = new SQLiteCommandBuilder(projektDA); + projektDA.SelectCommand = Command; + projektDA.InsertCommand = cmd.GetInsertCommand(); + + Command = new SQLiteCommand("SELECT * FROM Inspektionsobjekt", Connection); + SQLiteDataAdapter objektDA = new SQLiteDataAdapter(); + cmd = new SQLiteCommandBuilder(objektDA); + objektDA.SelectCommand = Command; + objektDA.InsertCommand = cmd.GetInsertCommand(); + + DataTable dtprojekte = new DataTable(); + DataTable dtObjekte = new DataTable(); + projektDA.Fill(dtprojekte); + objektDA.Fill(dtObjekte); + + + int projektID = 1; + // Alle Projekte durch gehen + foreach(Projekt projekt in source.Projekte) + { + DataRow projektRow = dtprojekte.NewRow(); + projektRow["ID"] = projektID; + projektRow["Nummer"] = projekt.Nummer; + projektRow["Ort"] = projekt.Ort; + projektRow["SanierungsIDPrefix"] = projekt.SanierungsIDPrefix; + projektRow["SanierungsIDSuffix"] = projekt.SanierungsIDSuffix; + + int objektID = 1; + // Alle einzelne Inspektionsobjekte + foreach(var inspektionsobjekt in projekt.Objekte) + { + DataRow objektRow = dtObjekte.NewRow(); + objektRow["id"] = objektID; + objektRow["ref_projekt_id"] = projektID; + objektRow["StrasseName"] = inspektionsobjekt.StrasseName; + objektRow["Ort"] = inspektionsobjekt.OrtName; + objektRow["Hausnummer"] = inspektionsobjekt.Hausnummer; + objektRow["Projektnummer"] = inspektionsobjekt.Projektnummer; + objektRow["Objektbezeichnung"] = inspektionsobjekt.Objektbezeichnung; + objektRow["VonPunkt"] = inspektionsobjekt.VonPunkt; + objektRow["BisPunkt"] = inspektionsobjekt.BisPunkt; + objektRow["RohrMaterial"] = inspektionsobjekt.RohrMaterial; + objektRow["Kanalrohrweite"] = inspektionsobjekt.Kanalrohrweite; + objektRow["Haltungslaenge"] = inspektionsobjekt.Haltungslaenge; + objektRow["Schachtlaenge"] = inspektionsobjekt.Schachtlaenge; + objektRow["HaltungGemessen"] = inspektionsobjekt.HaltungGemessen.ToString(); + objektRow["Bemerkung"] = inspektionsobjekt.Bemerkung; + objektRow["Inspektionsrichtung"] = inspektionsobjekt.Inspektionsrichtung; + objektRow["Sanierungsnummer"] = inspektionsobjekt.Sanierungsnummer; + + foreach(Sanierung sanierung in inspektionsobjekt.Sanierung) + { + + } + + dtObjekte.Rows.Add(objektRow); + objektID++; + } + + dtprojekte.Rows.Add(projektRow); + projektID++; + } + projektDA.Update(dtprojekte); + objektDA.Update(dtObjekte); + Connection.Close(); } diff --git a/SanSystem/datenbank.db b/SanSystem/datenbank.db index f665d91..690a986 100644 Binary files a/SanSystem/datenbank.db and b/SanSystem/datenbank.db differ