package datenbanken;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
import java.sql.ResultSet;
import java.io.*;


class Aktionen {

    public void anzeigen (Connection verbindung){
        int auswahl = 0;
        try {
            InputStreamReader isr = new InputStreamReader(System.in);
            BufferedReader br = new BufferedReader(isr);
            System.out.println("Welcher Artikel soll angezeigt werden?");
            String eingabe = br.readLine();
            auswahl = Integer.parseInt(eingabe);
        }
        catch (IOException e){
            System.out.print("Eingabe nicht möglich.");
        }
        try {
            Statement befehl = verbindung.createStatement();
            String SQL = "SELECT * FROM Produkte WHERE Artikelnummer = "+auswahl;
            ResultSet rs = befehl.executeQuery(SQL);
            rs.next( );
            String pr = rs.getString("Produkttyp");
            System.out.println("Produkttyp: "+pr);
            int preis = rs.getInt("Preis");
            System.out.println("Preis: "+preis);
            int anz = rs.getInt("Anzahl");
            System.out.println("Anzahl: "+anz);
        }
        catch ( SQLException err ) {
            System.out.println( err.getMessage( ) );
        }

    }
    public void preis (Connection verbindung){
        int auswahl = 0;
        int preisNeu = 0;
        try {
            InputStreamReader isr = new InputStreamReader(System.in);
            BufferedReader br = new BufferedReader(isr);
            System.out.println("Artikelnummer:");
            String eingabe = br.readLine();
            auswahl = Integer.parseInt(eingabe);
            System.out.println("Neuer Preis:");
            String eingabe2 = br.readLine();
            preisNeu = Integer.parseInt(eingabe2);
        }
        catch (IOException e){
            System.out.print("Eingabe nicht möglich.");
        }
        try {
            Statement befehl = verbindung.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_UPDATABLE);
            String SQL = "SELECT * FROM Produkte WHERE Artikelnummer = "+auswahl;
            ResultSet rs = befehl.executeQuery(SQL);
            rs.next( );
            rs.updateInt("Preis",preisNeu);
            rs.updateRow();
        }
        catch ( SQLException err ) {
            System.out.println( err.getMessage( ) );
        }

    }
    public void anzahl (Connection verbindung){
        int auswahl = 0;
        int anzahlNeu = 0;
        try {
            InputStreamReader isr = new InputStreamReader(System.in);
            BufferedReader br = new BufferedReader(isr);
            System.out.println("Artikelnummer:");
            String eingabe = br.readLine();
            auswahl = Integer.parseInt(eingabe);
            System.out.println("Neue Anzahl:");
            String eingabe2 = br.readLine();
            anzahlNeu = Integer.parseInt(eingabe2);
        }
        catch (IOException e){
            System.out.print("Eingabe nicht möglich.");
        }
        try {
            Statement befehl = verbindung.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_UPDATABLE);
            String SQL = "SELECT * FROM Produkte WHERE Artikelnummer = "+auswahl;
            ResultSet rs = befehl.executeQuery(SQL);
            rs.next( );
            rs.updateInt("Anzahl",anzahlNeu);
            rs.updateRow();
        }
        catch ( SQLException err ) {
            System.out.println( err.getMessage( ) );
        }

    }
    public void hinzufuegen (Connection verbindung){
        int artikelnummer = 0;
        String produkttyp = "";
        int preis = 0;
        int anzahl = 0;
        try {
            InputStreamReader isr = new InputStreamReader(System.in);
            BufferedReader br = new BufferedReader(isr);
            System.out.println("Artikelnummer:");
            String eingabe = br.readLine();
            artikelnummer = Integer.parseInt(eingabe);
            System.out.println("Produkttyp:");
            produkttyp = br.readLine();
            System.out.println("Preis:");
            eingabe = br.readLine();
            preis = Integer.parseInt(eingabe);
            System.out.println("Anzahl:");
            eingabe = br.readLine();
            anzahl = Integer.parseInt(eingabe);
        }
        catch (IOException e){
            System.out.print("Eingabe nicht möglich.");
        }
        try {
            Statement befehl = verbindung.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_UPDATABLE);
            String SQL = "INSERT INTO Produkte " + "VALUES ("+artikelnummer
                    +", '"+produkttyp+"', "+preis+", "+anzahl+")";
            befehl.executeUpdate(SQL);
        }
        catch ( SQLException err ) {
            System.out.println( err.getMessage( ) );
        }

    }
}
public class Datenbanken {

    public static void main(String[] args) {

        String host = "jdbc:derby://localhost:1527/Produkte";
        String username = "mitarbeiter1";
        String password = "xyz";
        int auswahl = -1;
        Aktionen aktion = new Aktionen();

        try {
            Connection verbindung = DriverManager.getConnection(host, username, password);
            while (auswahl != 0){

                try {
                    InputStreamReader isr = new InputStreamReader(System.in);
                    BufferedReader br = new BufferedReader(isr);
                    System.out.println("Aktion auswählen");
                    System.out.println("Produktinformationen anzeigen: 1");
                    System.out.println("Preis ändern: 2");
                    System.out.println("Anzahl ändern: 3");
                    System.out.println("Produkt hinzufügen: 4");
                    System.out.println("Programm beenden: 0");

                    String eingabe = br.readLine();
                    auswahl = Integer.parseInt(eingabe);
                }
                catch (IOException e){
                    System.out.print("Eingabe nicht möglich.");
                }

                if (auswahl == 1){
                    aktion.anzeigen(verbindung);
                }
                else if (auswahl == 2){
                    aktion.preis(verbindung);
                }
                else if (auswahl == 3){
                    aktion.anzahl(verbindung);
                }
                else if (auswahl == 4){
                    aktion.hinzufuegen(verbindung);
                }
                else if (auswahl == 0){
                    System.out.println("Auf Wiedersehen!");
                }
                else {
                    System.out.println("Ungültige Eingabe");
                }
            }
        }
        catch ( SQLException err ) {
            System.out.println( err.getMessage( ) );
        }
    }
}