package datenhaltung;

import java.sql.*;

import daten.Student;
import daten.StudentenContainer;

import util.InvalideAttributeException;

public class Datei {

    private static String treiber = "com.mysql.jdbc.Driver";
    private static String datenbank = "jdbc:mysql://aioml.informatik.uni-augsburg.de:3306/theDatabase";
    private String benutzer;
    private String passwort;
    private Connection connection;

    public Datei(String benutzer, String passwort) {
        this.benutzer = benutzer;
        this.passwort = passwort;
        try{//Verbindung herstellen
            Class.forName(treiber);
        }catch(ClassNotFoundException e){
            System.err.println("Keine Treiberklasse");
            System.exit(0);     }

        try{
            connection = DriverManager.getConnection(datenbank,benutzer,passwort);
        }catch(SQLException e){System.err.println("Keine Verbindung hergestellt!!!");
        System.exit(0);
        }

        }

    public void load(StudentenContainer container) {

        try{Statement abfrage = connection.createStatement();

        String befehl = "SELECT * FROM Student";

        ResultSet ergebnis = abfrage.executeQuery(befehl);

        while (ergebnis.next()){
                Student s = new Student(Integer.parseInt(ergebnis.getString(3)));
                s.setNachname(ergebnis.getString(2));
                s.setVorname(ergebnis.getString(1));
                container.addStudentAusDatenbank(s);
        }


        abfrage.close();
        ergebnis.close();
        }catch(SQLException e){
            System.err.println("Laden nicht erfolgreich");
        }
    }

    public void save(StudentenContainer container){
        System.out.println("Operation steht nicht zur VerfŸgung!");
    }

    public void add(Student s) {
        try{Statement abfrage = connection.createStatement();

        String befehl =
            "INSERT INTO Student VALUES ('"
            + s.getVorname()
            + ",'"
            + s.getNachname()
            + "','"
            + s.getMatrikelnummer()
            + "')";


       abfrage.executeUpdate(befehl);
        abfrage.close();
        }catch(SQLException e){
            System.err.println("Student konnte nicht hinzugefügt werden!!");
        }


    }

    public void delete(Student s) {
        try{ Statement abfrage = connection.createStatement();

        String befehl =
            "DELETE FROM Student WHERE Matrikelnummer = '"
            + s.getMatrikelnummer()
            + "'";

        abfrage.executeUpdate(befehl);

        abfrage.close();
        }catch(SQLException e){
            System.err.println("Löschen fehlgeschlagen");
        }
    }

    public void modify(Student s) {
        try{Statement abfrage = connection.createStatement();

        String befehl =
            "UPDATE Student SET Vorname = '"
            + s.getVorname()
            + "', Nachname = '"
            + s.getNachname()
            + "' WHERE Matrikelnummer = '"
            + s.getMatrikelnummer()
            + "'";

        abfrage.executeUpdate(befehl);

        abfrage.close();
        }
        catch(SQLException e){
            System.err.println("Modifizieren fehlgeschlagen");
        }
        }
    }