package DBAnbindung;

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

public class Main {

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

	public static void artActuallisieren() throws Exception {
		final String neuerName = "Kopfsalat";
		final String neuerPreis = "0.69";
		final String gewünschteArtikelnr = "8";
		try {
			String sql = "UPDATE beispiel SET name = '"+neuerName+"', preis = '"+neuerPreis+"' WHERE artikelnr = "+gewünschteArtikelnr+"" ;
			Connection con = verbindungHerstellen();
			PreparedStatement post = con.prepareStatement(sql);
			post.executeUpdate();
		} catch(Exception e) {
			System.out.println("Fehler beim Einfügen der Attribute: "+e);

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

		}

	}

	public static Vector<String> infoAbrufen() throws Exception {
		try{
			Connection con = verbindungHerstellen();
			String query = "SELECT * FROM beispiel";
			PreparedStatement stm = con.prepareStatement(query);

			ResultSet erg = stm.executeQuery();

			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 e) {
			System.out.println("Beim Abrufen der Informationen ist ein Fehler unterlaufen: " +e);

		}
		return null;
	}

	public static void artEinfuegen() throws Exception {
		final String var1 = "Brötchen";
		final String var2 = "0.13";
		try {
			String sql = "INSERT INTO beispiel (name, preis) VALUES ('"+var1+"', '"+var2+"')";
			Connection con = verbindungHerstellen();
			PreparedStatement post = con.prepareStatement(sql);
			post.executeUpdate();
		} catch(Exception e) {
			System.out.println("Fehler beim Einfügen der Attribute: "+e);

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

		}

	}

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

	public static Connection verbindungHerstellen() throws Exception{
		try{
			String treiber = "com.mysql.jdbc.Driver";
			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 e){
			System.out.println("Fehler beim Verbinden: "+e);
		}


		return null;
	}

}