package net.akamie.snycs.freebuild.api;

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

public class MySQL {

	private String HOST = "";
	private String PORT = "";
	private String DATABASE = "";
	private String USER = "";
	private String PASSWORD = "";

	private Connection con;
//---------------------------------------------------------------------------------------------------------------------------------------------------
	public MySQL(String host, String database, String port, String user, String password){
		this.HOST = host;
		this.PORT = port;
		this.DATABASE = database;
		this.USER = user;
		this.PASSWORD = password;

		connect();
	}
//---------------------------------------------------------------------------------------------------------------------------------------------------
	public void connect() {
		try{
			con = DriverManager.getConnection("jdbc:mysql://" + HOST + ":" + PORT + "/" + DATABASE + "?autoReconnect=true", USER, PASSWORD);
			System.out.println("[MySQL] Die Verbindung zur Datenbank wurde erfolgreich hergestellt.");
		}catch(SQLException e){
			System.out.println("[MySQL] Die Verbindung zur Datenbank ist Fehlgeschlagen! Fehler: " + e);
		}
	}
//---------------------------------------------------------------------------------------------------------------------------------------------------
	public void close(){
		try{
			if(con != null){
			con.close();
			System.out.println("[MySQL] Die Verbindung zur Datenbank wurde erfolgreich geschlossen.");
			}
		}catch(SQLException e){
			System.out.println("[MySQL] Fehler beim schließen der Datenbankverbindung! Fehler: " + e);
		}
	}
//---------------------------------------------------------------------------------------------------------------------------------------------------
	public void update(String querry){
		try{
			Statement st = con.createStatement();
			st.executeUpdate(querry);
			st.close();
		}catch(SQLException e){
			connect();
			System.err.println(e);
		}
	}
//---------------------------------------------------------------------------------------------------------------------------------------------------
	public ResultSet query(String querry){
		ResultSet rs = null;
		try{
			Statement st = con.createStatement();
			rs = st.executeQuery(querry);
		}catch(SQLException e){
			connect();
			System.err.println(e);
		}
		return rs;
	}
}