package de.keyhdtv.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 = "134.255.254.199";
	private String database = "michaelf_spieldaten";
	private String user = "michaelf";
	private String password = "test";

	private Connection con;

	public MySQL() {

		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;

	}

}