package de.KlickMich.RobTheBank.sql;

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 = "mysql.mc-host24.de";
	private String database = "db_43080";
	private String user = "db_43080";
	private String password = "2f8cd2cf6a";

	private Connection con;

	public MySQL() {

		connect();
	}

	public MySQL(String host, String database, String user) {
		this.host = host;
		this.database = database;
		this.user = user;

		connect();
	}

	public void connect() {
		try {
			con = DriverManager.getConnection("jdbc:mysql://" + host + ":3306/" + database + "?autoReconnect=true", user, password);
			System.out.println("[MySQL] Erfolgreich verbunden.");
		} catch (SQLException ex) {
			ex.printStackTrace();
			System.out.println("[MySQL] Verbinden fehlgeschlagen!");
		}
	}

	public void close() {
		try {
			if(con != null) {
				con.close();
			}
		} catch(SQLException ex) {
			ex.printStackTrace();
		}
	}

	public ResultSet query(String qry) {
		ResultSet rs = null;

		try {
			Statement st = con.createStatement();
			rs = st.executeQuery(qry);
		} catch(SQLException ex) {
			connect();
			ex.printStackTrace();
		}

		return rs;
	}

	public void update(String qry) {
		try {
			Statement st = con.createStatement();
			st.executeUpdate(qry);
			st.close();
		} catch(SQLException ex) {
			connect();
			ex.printStackTrace();
		}
	}

	public Connection getConnection(){
		return con;

	}

}