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

public class SQL {

	private String HOST = "HOSTNAME";
	private String DATABASE = "DATABASE";
	private String USER = "USER";
	private String PASSWORD = "PW";
	private Boolean mysql = true;
	private static File sqlfile = new File("plugins/Cloud/Database.sqlite");
	private Connection con;


	public boolean isConnected(){
		if(con == null){
			return false;
		}else{
			return true;
		}
	}



	public void setHOST(String hOST) {
		if(this.mysql == true){
			HOST = hOST;
		}
	}

	public void setDATABASE(String dATABASE) {
		if(this.mysql == true){
			DATABASE = dATABASE;
		}
	}

	public void setUSER(String uSER) {
		if(this.mysql == true){
			USER = uSER;
		}
	}

	public void setPASSWORD(String pASSWORD) {
		if(this.mysql == true){
			PASSWORD = pASSWORD;
		}
	}

	public SQL(boolean MySQL){
		this.mysql = MySQL;
	}

	public void connect() {
		if(this.mysql == true){
			try {

				con = DriverManager.getConnection("jdbc:mysql://" + HOST + ":3306/" + DATABASE + "?autoReconnect=true", USER, PASSWORD);
				System.out.println("[SQL] Die Verbindung zur SQL wurde hergestellt!");

			} catch (SQLException e) {
				System.out.println("[SQL] Die Verbindung zur SQL ist fehlgeschlagen! Fehler: " + e.getMessage());
			}
		}else{
			try {
				try{
					Class.forName("org.sqlite.JDBC");
				}catch (ClassNotFoundException localClassNotFoundException){

				}
				con = DriverManager.getConnection("jdbc:sqlite:" + sqlfile.getAbsolutePath());
				System.out.println("[SQL] Die Verbindung zur SQL wurde hergestellt!");
			} catch (SQLException e) {
				System.out.println("[SQL] Die Verbindung zur SQL ist fehlgeschlagen! Fehler: " + e.getMessage());
			}
		}
	}

	public void close() {
		try {
			if(con != null) {
				con.close();
				System.out.println("[SQL] Die Verbindung zur SQL wurde Erfolgreich beendet!");
			}

		} catch (SQLException e) {
			System.out.println("[SQL] Fehler beim beenden der Verbindung zur SQL! Fehler: " + e.getMessage());
		}

	}

	public void update(String qry) {
		try {
			Statement st = con.createStatement();
			st.executeUpdate(qry);
			st.close();
		} catch (SQLException e) {
			connect();
			System.err.println(e);
		}
	}

	public ResultSet query(String qry) {
		ResultSet rs = null;
		try {
			Statement st = con.createStatement();
			rs = st.executeQuery(qry);
		} catch (SQLException e) {
			connect();
			System.err.println(e);
		}
		return rs;
	}
}