package me.quickscythe.hyversecore.utils;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Properties;

/**
* The IDatabase is a simple class that adds all the utils you need to communicate with an SQL server.
*
* @author  Cameron Witcher
* @version 1.0
* @since   2016-12-09
*/
public class IDatabase {



	public Connection connection;
	private Properties properties;
	private String user;
	private String pass;
	private String url;

	public IDatabase(String host, String database, Integer port, String username, String password) {
		this.properties = new Properties();
		this.user = username;
		this.pass = password;
		this.properties.setProperty("user", username);
		this.properties.setProperty("password", password);
		this.url = "jdbc:mysql://" + host + ":" + port + "/" + database;
	}

	public Boolean init() {
		try {
//		      String url = "jdbc:mysql://localhost:3306/test";
//		      Properties info = new Properties();
//		      info.put("user", "root");
//		      info.put("password", "test");
			Class.forName("com.mysql.jdbc.Driver");
			connection = DriverManager.getConnection(url, user, pass);

		      if (connection != null) {
		        System.out.println("Successfully connected to MySQL database test");
		        return true;
		      }

		    } catch (SQLException | ClassNotFoundException ex) {
		      System.out.println("An error occurred while connecting MySQL databse");
		      ex.printStackTrace();
		      return false;
		    }
//		try {
//			if (connection != null && !connection.isClosed()) {
//				return true;
//			}
//			Class.forName("com.mysql.jbdc.Driver");
//			this.connection = DriverManager.getConnection(url, user, pass);
//			return true;
//		} catch (Exception exception) {
//			exception.printStackTrace();
//			return false;
		return false;
//		}
	}

	public ResultSet query(String query, Object... values) {
		try {
			PreparedStatement statement = prepare(query, values);
			if (statement == null) {
				return null;
			}
			return statement.executeQuery();
		} catch (Exception exception) {
			return null;
		}
	}

	public Integer update(String query, Object... values) {
		try {
			PreparedStatement statement = prepare(query, values);
			if (statement == null) {
				return -1;
			}
			return statement.executeUpdate();
		} catch (Exception exception) {
			exception.printStackTrace();
			return -1;
		}



	}

	public boolean input(String query, Object... values) {
		try {
			PreparedStatement statement = prepare(query, values);
			if (statement == null) {
				return false;
			}
			return statement.execute();
		} catch (Exception exception) {
			return false;
		}



	}

	private PreparedStatement prepare(String query, Object... values) {
		try {
			if (!init()) {
				return null;
			}
			PreparedStatement statement = connection.prepareStatement(query);
			for (int i = 0; i < values.length; i++) {
				statement.setObject(i + 1, values[i]);
			}
			return statement;
		} catch (Exception exception) {
			return null;
		}
	}
}