package me.kw.nh.database;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.UUID;

import org.bukkit.Bukkit;
import org.bukkit.entity.Player;
import org.bukkit.scheduler.BukkitRunnable;

public class DatabaseManager {

	private Connection connection;
	private String host, database, username, password;
	private Statement statement;

	public void setValues(String host, String database, String username, String password){
		this.host = host;
		this.database = database;
		this.username = username;
		this.password = password;
	}

	private BukkitRunnable r = new BukkitRunnable(){
		@Override
		public void run(){
			try {
	            openConnection();
	            statement = connection.createStatement();
	        } catch (ClassNotFoundException e) {
	            e.printStackTrace();
	        } catch (SQLException e) {
	            e.printStackTrace();
	        }
		}
	};

	public BukkitRunnable getRun(){
		return r;
	}

	public void openConnection() throws SQLException, ClassNotFoundException {
	    if (connection != null && !connection.isClosed()) {
	        return;
	    }

	    synchronized (this) {
	        if (connection != null && !connection.isClosed()) {
	            return;
	        }
	        Class.forName("com.mysql.jdbc.Driver");
	        connection = DriverManager.getConnection("jdbc:mysql://" + this.host+ "/" + this.database, this.username, this.password);
	    }
	}

	public Integer retrievePlayerPoints(Player p) throws SQLException{
		ResultSet result = statement.executeQuery("SELECT points FROM users WHERE `UUID` =  '" +  p.getUniqueId().toString() + "'");
		result.next();
		Integer points = result.getInt("points");
		return points;
	}

	public Integer retrievePlayerExp(Player p) throws SQLException{
		ResultSet result = statement.executeQuery("SELECT exp FROM users WHERE `UUID` =  '" +  p.getUniqueId().toString() + "'");
		result.next();
		Integer exp = result.getInt("exp");
		return exp;
	}

	public Integer retrievePlayerServerID(Player p) throws SQLException{
		ResultSet result = statement.executeQuery("SELECT current_server_id FROM users WHERE `UUID` =  '" +  p.getUniqueId().toString() + "'");
		result.next();
		Integer id = result.getInt("current_server_id");
		return id;
	}

	public void setPlayerPoints(Player p, Integer points) throws SQLException{
		statement.executeUpdate("UPDATE  `users` SET  `points` =" + points + " WHERE  `UUID` =  '" +  p.getUniqueId().toString() + "'");
	}

	public void setPlayerExp(Player p, Integer exp) throws SQLException{
		statement.executeUpdate("UPDATE  `users` SET  `exp` =" + exp + " WHERE  `UUID` =  '" +  p.getUniqueId().toString() + "'");
	}

	public void addPlayerPoints(Player p, Integer points) throws SQLException{
		statement.executeUpdate("UPDATE  `users` SET  `points` =" + (this.retrievePlayerPoints(p) + points) + " WHERE  `UUID` =  '" +  p.getUniqueId().toString() + "'");
	}

	public void setPlayerServer(Player p, Integer current_server_id) throws SQLException{
		statement.executeUpdate("UPDATE  `users` SET  `current_server_id` =" + current_server_id + " WHERE  `UUID` =  '" +  p.getUniqueId().toString() + "'");
	}

	public void addUser(Player p) throws SQLException{
		statement.executeUpdate("INSERT INTO `users`(`UUID`, `points`, `current_server_id`, `exp`) VALUES ('" + p.getUniqueId().toString() + "',0, 0, 0);");
	}

	//WARPS
	public Integer retrieveWarpX(String name) throws SQLException{
		ResultSet result = statement.executeQuery("SELECT x FROM warps WHERE name = '" + name + "';");
		result.next();
		Integer x = result.getInt("x");
		return x;
	}
	public Integer retrieveWarpY(String name) throws SQLException{
		ResultSet result = statement.executeQuery("SELECT y FROM warps WHERE name = '" + name + "';");
		result.next();
		Integer y = result.getInt("y");
		return y;
	}
	public Integer retrieveWarpZ(String name) throws SQLException{
		ResultSet result = statement.executeQuery("SELECT z FROM warps WHERE name = '" + name + "';");
		result.next();
		Integer z = result.getInt("z");
		return z;
	}

	public String retrieveWarpName(String name) throws SQLException{
		ResultSet result = statement.executeQuery("SELECT name FROM warps WHERE name = '" + name + "';");
		result.next();
		String namez = result.getString("name");
		return namez;
	}

	public void addWarp(String name, Integer x, Integer y, Integer z) throws SQLException{
		statement.executeUpdate("INSERT INTO warps(ID, name, x, y, z) VALUES (0, '" + name + "'," + x + ", " + y + ", " + z + ");");
	}



}