import java.io.*;
import java.sql.*;

public class JDBCVerwaltung {

    public static void main(String[] args) throws FileNotFoundException, IOException {
        BufferedReader in = new BufferedReader(new InputStreamReader(System.in));

        System.out.println("*** JDBC Verwaltung ***");

        try {

            /*BufferedReader in = new BufferedReader(new InputStreamReader(System.in));
            System.out.print("Username: ");
            String user = in.readLine();
            System.out.print("Passwort: ");
            String pass = in.readLine();
            in.close();
            Statement statement = connect(user, pass);*/

            Connection con = connect();

            File KundeCSV = new File("KUNDE.CSV");
            BufferedReader fin = new BufferedReader(new FileReader(KundeCSV));


            Statement stmt = con.createStatement();

            System.out.print("Tippen Sie 0, um die Kunden aus KUNDE.CSV in die Datenbank einzufügen, ansonsten 1: ");
            int kchoice = Integer.parseInt(in.readLine());
            if (kchoice == 0)
                AlterDB.insertKunden(stmt, fin);

            int execute;


            do {

                welcomeScreen();
                execute = Integer.parseInt(in.readLine());
                System.out.println();

                switch (execute){
                    case 1:
                        ShowDB.showAllArtikel(stmt);
                        break;
                    case 2:
                        ShowDB.showAllLager(stmt);
                        break;
                    case 3:
                        ShowDB.showLagerbestände(stmt, in);
                        break;
                    case 4:
                        ShowDB.showAllKunden(stmt);
                        break;
                    case 5:
                        ShowDB.stammdatenUndLagerbestand(stmt, in);
                        break;
                    case 6:
                        AlterDB.addWertToLagerbestand(stmt, in);
                        break;
                    case 7:
                        AlterDB.addBestellung(stmt, in);
                        break;
                    case 8:
                        AlterDB.addBestToLagerbestand(stmt, in);
                        break;
                    case 9:
                        break;
                    default:
                        System.out.println("Bitte geben Sie eine Zahl zwischen 1 bis 9 ein");
                        break;
                }

            }while (execute >0 && execute < 9);


        } catch (SQLException e) {
            System.out.println(e.getMessage());
        }

    }

    public static Connection connect() throws SQLException {
        String user = "dbprak41";
        String pass = "dbth2019";
        String server = "feuerbach";
        String url = "jdbc:postgresql://"+server+".nt.fh-koeln.de/postgres?user="+user+"&password="+pass;
        Connection dbConnection = null;

        try {
            Class.forName("org.postgresql.Driver").newInstance();
        } catch (Exception e) {
            System.out.println("Fehler beim Laden des Treibers: "+ e.getMessage());
        }

        try {
            dbConnection = DriverManager.getConnection(url);
        } catch (SQLException e) {
            System.out.println("Fehler beim Verbindungsaufbau zur Datenbank.");
            System.out.println(e.getMessage());
        }
        return dbConnection;
    }

    public static Connection connect(String user, String pass) throws SQLException {
        String server = "feuerbach";
        String url = "jdbc:postgresql://"+server+".nt.fh-koeln.de/postgres?user="+user+"&password="+pass;
        Connection dbConnection = null;

        try {
            Class.forName("org.postgresql.Driver").newInstance();
        } catch (Exception e) {
            System.out.println("Fehler beim Laden des Treibers: "+ e.getMessage());
        }

        try {
            dbConnection = DriverManager.getConnection(url);
        } catch (SQLException e) {
            System.out.println("Fehler beim Verbindungsaufbau zur Datenbank.");
            System.out.println(e.getMessage());
        }
        return dbConnection;
    }

     public static void welcomeScreen() {
            System.out.println("\n1) Tippen Sie 1 zum Anzeigen aller Artikel");
            System.out.println("2) Tippen Sie 2 zum Anzeigen aller Lager");
            System.out.println("3) Tippen Sie 3 zum Anzeigen aller Lagerbestände anhand einer Lagernummer");
            System.out.println("4) Tippen Sie 4 zum Anzeigen aller Kunden");
            System.out.println("6) Tippen Sie 5, um anhand einer Artikelnummer die zugehörigen Lagerbestände anzuzeigen");
            System.out.println("5) Tippen Sie 6, um die Spalte 'Wert=Stucke*Preise' Lagerbestand zu ergänzen " +
                    "und die Werte eines Artikels zu aktualisieren");
            System.out.println("7) Tippen Sie 7, um eine Bestellung hinzuzufügen");
            System.out.println("8) Tippen Sie 8, um einem Lagerbestand eine Bestellung hinzuzufügen");
            System.out.println("9) Tippen Sie 9 zum Beenden des Programms");
            System.out.print("Auswahl: ");
        }
}