package Logic;

//Einbinden der nötigen Pakete
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class Connector {

	// Parameter für Verbindungsaufbau definieren
	private String driver = "com.mysql.jdbc.Driver";
	public static String server = "localhost";
	private String url = "jdbc:mysql://" + server + "/Musikvoting";
	private String user = "DBMS";
	private Connection con;

	public void update(String sql) {// update methode mit den normalen einlog
									// daten
		try {
			// JDBC-Treiber laden
			Class.forName(this.driver);
			con = DriverManager.getConnection(this.url, this.user, Temp.getPassword());
			// Statement erstellen
			Statement stmt = con.createStatement();
			// SQL-Anweisungen ausführen
			stmt.executeUpdate(sql);
		} catch (Exception ex) { // Fehler abfangen
			ex.printStackTrace();// Fehlermeldung ausgeben
		}
	}

	public ResultSet select(String sql) {// select methode mit den normalen
											// einlog daten die ein Resultset
											// zurück gibt
		try {
			// JDBC-Treiber laden
			Class.forName(this.driver);
			// Verbindung aufbauen
			con = DriverManager.getConnection(this.url, this.user, Temp.getPassword());
			// Statement erstellen
			Statement stmt = con.createStatement();
			// SQL-Anweisungen ausführen
			ResultSet rs = stmt.executeQuery(sql);
			return rs;
		} catch (Exception ex) { // Fehler abfangen
			ex.printStackTrace();// Fehlermeldung ausgeben
			return null;
		}
	}

	public void rupdate(String sql) {// update methode mit den root einlog daten
		try {
			// JDBC-Treiber laden
			Class.forName(this.driver);
			con = DriverManager.getConnection(this.url, "root", "");
			// Statement erstellen
			Statement stmt = con.createStatement();
			// SQL-Anweisungen ausführen
			stmt.executeUpdate(sql);
		} catch (Exception ex) { // Fehler abfangen
			ex.printStackTrace();// Fehlermeldung ausgeben
		}
	}

	public ResultSet rselect(String sql) {// select methode mit den root einlog
											// daten die ein Resultset zurück
											// gibt
		try {
			// JDBC-Treiber laden
			Class.forName(this.driver);
			// Verbindung aufbauen
			con = DriverManager.getConnection(this.url, "root", "");
			// Statement erstellen
			Statement stmt = con.createStatement();
			// SQL-Anweisungen ausführen
			ResultSet rs = stmt.executeQuery(sql);
			return rs;
		} catch (Exception ex) { // Fehler abfangen
			ex.printStackTrace();// Fehlermeldung ausgeben
			return null;
		}
	}

	public void closeCon() {// Methode zum schliesen der Connection
		try {
			this.con.close();
		} catch (SQLException e) {
			System.out.println("Fuck this gay earth");
			e.printStackTrace();
		}
	}

	public void startDatabase() {// erstellen der Datenbank
		// Parameter für Verbindungsaufbau definieren
		try {
			String url = "jdbc:mysql://" + server + "/?";
			// JDBC-Treiber laden
			Class.forName(driver);
			con = DriverManager.getConnection(this.url, this.user, Temp.getPassword());
			// SQL-Anweisungen ausführen
			Statement stmt = con.createStatement();
			stmt.executeUpdate("CREATE DATABASE IF NOT EXISTS Musikvoting;");
			con.close();
		} catch (Exception e) {
			System.out.println("create database ERROR");
		}

	}

	public boolean checkDatabase() {// Überprüfung ob die Datenbank existiert
		try {
			Class.forName(driver);
			con = DriverManager.getConnection(this.url, this.user, Temp.getPassword());
			con.close();
			return true;
		} catch (Exception e) {
			e.printStackTrace();
			return false;
		}

	}

	public String getServer() {
		return server;
	}

}