package DBAnbindung;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.Vector;

import javax.swing.JOptionPane;

public class Main {

	public static void main(String[] args) throws Exception {
		//verbindungHerstellen();
		//tabelleErstellen();
		//artEinfuegen();
		//artAktualisieren();
		//infoAbrufen();
		trySelect();
	}

	public static Connection verbindungHerstellen() throws Exception{

		try{
			String treiber = "com.mysql.jdbc.Driver";  //Notizen: fkt, sinn, treiber, auslagern, demo
			String url = "jdbc:mysql://localhost:3306/beispiel";
			String benutzer = "root";
			String passwort = "";
			Class.forName(treiber);

			Connection conn = DriverManager.getConnection(url,benutzer,passwort);
			System.out.println("Verbindung zur Datenbank hergestellt");
			return conn;
		} catch(Exception f){
			System.out.println("Fehler beim Verbinden: "+f);
		}


		return null;
	}

	public static void tabelleErstellen() throws Exception {
		try{
			Connection conn = verbindungHerstellen();  //Notizen: Kassensystem, sql if not..., demo
			String sql = "CREATE TABLE IF NOT EXISTS benutzer(benutzernr int NOT NULL AUTO_INCREMENT, vorname varchar(255), nname varchar(255), PRIMARY KEY(benutzernr))";
			PreparedStatement pst = conn.prepareStatement(sql);
			pst.executeUpdate();
		} catch(Exception f){
			System.out.println("Fehler beim erstellen der Tabelle: "+f);
		} finally {
			System.out.println("Erstellen der Tabelle wurde erfolgreich probiert");
		}
	}

	public static void artEinfuegen() throws Exception {
		final String var1 = JOptionPane.showInputDialog("Name des Artikels eingeben: ");  //kassensystem, ausgelagert, ähnlicher auf bau, demo, GUI nicht vergessen
		final String var2 = JOptionPane.showInputDialog("Preis des Artikels eingeben: ");
		try {
			String sql = "INSERT INTO beispiel (name, preis) VALUES ('"+var1+"', '"+var2+"')";
			Connection conn = verbindungHerstellen();
			PreparedStatement pst = conn.prepareStatement(sql);
			pst.executeUpdate();
		} catch(Exception f) {
			System.out.println("Fehler beim Einfügen der Attribute: "+f);

		} finally {
			System.out.println("Informationen erfolgreich in die Tabelle eingetragen");

		}

	}

	public static void artAktualisieren() throws Exception {
		final String neuerName = "Kopfsalat";  //Kassensystem, auslagern, aufbau = insert, demo ,GUI nicht vergessen
		final String neuerPreis = "0.89";
		final String gewünschteArtikelnr = "8";
		try {
			String sql = "UPDATE beispiel SET name = '"+neuerName+"', preis = '"+neuerPreis+"' WHERE artikelnr = "+gewünschteArtikelnr+"" ;
			Connection conn = verbindungHerstellen();
			PreparedStatement pst = conn.prepareStatement(sql);
			pst.executeUpdate();
		} catch(Exception f) {
			System.out.println("Fehler beim Aktualisieren der Attribute: "+f);

		} finally {
			System.out.println("Informationen der Tabelle erfolgreich Aktualisiert.");

		}

	}

	public static Vector<String> infoAbrufen() throws Exception {
		try{
			Connection conn = verbindungHerstellen(); //Kassensystem, auslagern, aufbau, demo, GUI
			String query = "SELECT * FROM beispiel";
			PreparedStatement pst = conn.prepareStatement(query);

			ResultSet erg = pst.executeQuery();
			//Vector<String> selectInfo = new Vector<String>();

			while(erg.next()) {
				Vector<String> selectInfo = new Vector<String>();
			    selectInfo.add(erg.getString("artikelnr"));
			    selectInfo.add(erg.getString("name"));
			    selectInfo.add(erg.getString("preis"));

			    System.out.println(selectInfo);

			}
			System.out.println("Informationen Erfolgreich abgerufen");
		} catch(Exception f) {
			System.out.println("Beim Abrufen der Informationen ist ein Fehler unterlaufen: " +f);

		}
		return null;
	}




public static void trySelect() throws Exception {
	try{
		Connection conn = verbindungHerstellen();
		String var1 = JOptionPane.showInputDialog("Suchen Sie 'artikelnr' 'name' oder 'preis': ");
		String var2 = JOptionPane.showInputDialog("Was ist ihnen bekannt? 'artikelnr', 'name' oder 'preis': ");
		String par1 = JOptionPane.showInputDialog("Geben Sie den gesuchten Parameter ein: (Name in '' setzen)");
		String query = "SELECT "+var1+" FROM beispiel WHERE "+var2+" = "+par1+"";
		PreparedStatement pst = conn.prepareStatement(query);

		ResultSet erg = pst.executeQuery();
		//Vector<String> selectInfo = new Vector<String>();

		while(erg.next()) {
			Vector<String> selectInfo = new Vector<String>();
		    selectInfo.add(erg.getString(var1));

		    JOptionPane.showMessageDialog(null, selectInfo);

		}
		System.out.println("Informationen Erfolgreich abgerufen");
	} catch(Exception f) {
		System.out.println("Beim Abrufen der Informationen ist ein Fehler unterlaufen: " +f);

	}
}

}