allow to reset database

This commit is contained in:
2022-05-16 18:48:55 +02:00
parent 2542dce79f
commit f362d7b2a0
2 changed files with 7 additions and 3 deletions

View File

@@ -17,7 +17,7 @@ namespace it_projekt
{ {
connection.Open(); connection.Open();
string sql = "SELECT stammdaten.id, stammdaten.firstname, stammdaten.lastname, stammdaten.creationdate, abteilung.kuerzel, abteilung.name FROM `stammdaten` JOIN abteilung GROUP BY stammdaten.id; "; string sql = "SELECT stammdaten.id,stammdaten.firstname, stammdaten.lastname, stammdaten.creationdate, abteilung.kuerzel, abteilung.name FROM `stammdaten` JOIN abteilung WHERE abteilungs_id = abteilung.id;";
MySqlCommand cmd = new MySqlCommand(sql, connection); MySqlCommand cmd = new MySqlCommand(sql, connection);
MySqlDataReader rdr = cmd.ExecuteReader(); MySqlDataReader rdr = cmd.ExecuteReader();
Persons = new List<Person>(); Persons = new List<Person>();
@@ -33,9 +33,7 @@ namespace it_projekt
{ {
Console.WriteLine(ex.ToString()); Console.WriteLine(ex.ToString());
} }
connection.Close(); connection.Close();
Console.WriteLine("Done.");
} }
public static Database getDatabase(string username, string password) public static Database getDatabase(string username, string password)
@@ -46,5 +44,10 @@ namespace it_projekt
} }
return _database; return _database;
} }
public static void resetDatabase()
{
_database = null;
}
} }
} }

View File

@@ -39,6 +39,7 @@ namespace it_projekt
db = Database.getDatabase(user, password); db = Database.getDatabase(user, password);
if (db.Persons == null) if (db.Persons == null)
{ {
Database.resetDatabase();
MessageBox.Show("Connection to Database failed! \nPlease Try again.", "Database Error!"); MessageBox.Show("Connection to Database failed! \nPlease Try again.", "Database Error!");
} }
else { else {