package com.extremepvp.MySQL;

import java.util.concurrent.locks.*;

import com.extremepvp.*;

import java.sql.*;
import java.util.concurrent.*;

public class Connect {
	private Main m;
	public static ReentrantLock lock;

	static {
		Connect.lock = new ReentrantLock(true);
	}

	public Connect(final Main m) {
		this.m = m;
	}

	public synchronized Connection trySQLConnection() {
		if (!this.m.sql) {
			this.m.getLogger().info("MySQL Desativado!");
			return null;
		}
		try {
			this.m.getLogger().info("Conectando ao MySQL");
			Class.forName("com.mysql.jdbc.Driver").newInstance();
			final String ip = Main.getInstance().getConfig().getString("sql-host");
			this.m.getLogger().info("Tentando conexão com o mysql em " + ip);
			final String conn = "jdbc:mysql://" + ip + ":" + 3306 + "/"
					+ Main.getInstance().getConfig().getString("sql-db")
					+ "?autoReconnect=true&failOverReadOnly=false&maxReconnects=2147483647";
			return DriverManager.getConnection(conn, "root",
					"");
		} catch (ClassNotFoundException ex2) {
			this.m.getLogger().warning("MySQL Driver nao encontrado!");
			this.m.sql = false;
		} catch (SQLException ex) {
			this.m.getLogger().warning("Erro enquanto tentava conectar ao Mysql!");
			ex.printStackTrace();
			this.m.sql = false;
		} catch (Exception ex3) {
			this.m.getLogger().warning("Erro desconhecido enquanto tentava conectar ao MySQL.");
			this.m.sql = false;
		}
		return null;
	}

	public void prepareSQL(final Connection con) {
		if (this.m.sql) {
			this.SQLQuerySync(
					"CREATE TABLE IF NOT EXISTS `playertitles` (`ID` int(10) unsigned NOT NULL AUTO_INCREMENT, `Uuid` varchar(255) NOT NULL, `titles` varchar(255), `activetitle` int(10), PRIMARY KEY (`ID`)) ENGINE=InnoDB DEFAULT CHARSET=UTF8 AUTO_INCREMENT=1 ;");
			this.SQLQuerySync(
					"CREATE TABLE IF NOT EXISTS `playerranking` (`ID` int(10) unsigned NOT NULL AUTO_INCREMENT, `Uuid` varchar(255) NOT NULL, `coins` int(10), `rewards` varchar(255), `xp` int(10), `xptotal` int(10), `level` int(10), PRIMARY KEY (`ID`)) ENGINE=InnoDB DEFAULT CHARSET=UTF8 AUTO_INCREMENT=1 ;");
			this.SQLQuerySync(
					"CREATE TABLE IF NOT EXISTS `ranks` (`id` int(10) unsigned NOT NULL AUTO_INCREMENT, `uuid` varchar(255) NOT NULL, `rank` varchar(255) NOT NULL, PRIMARY KEY (`ID`)) ENGINE=InnoDB DEFAULT CHARSET=UTF8 AUTO_INCREMENT=1 ;");
			this.SQLQuerySync(
					"CREATE TABLE IF NOT EXISTS `Expires` (`id` int(10) unsigned NOT NULL AUTO_INCREMENT, `uuid` varchar(255) NOT NULL, `expire` varchar(255) NOT NULL, `group` varchar(255) NOT NULL, PRIMARY KEY (`ID`)) ENGINE=InnoDB DEFAULT CHARSET=UTF8 AUTO_INCREMENT=1 ;");
			this.SQLQuerySync(
					"CREATE TABLE IF NOT EXISTS `multiplier` (`id` int(10) unsigned NOT NULL AUTO_INCREMENT, `multiplier` int(10), PRIMARY KEY (`ID`)) ENGINE=InnoDB DEFAULT CHARSET=UTF8 AUTO_INCREMENT=1 ;");
			this.SQLQuerySync(
					"CREATE TABLE IF NOT EXISTS `uuidfetcher` (`id` int(10) unsigned NOT NULL AUTO_INCREMENT, `uuid` varchar(255) NOT NULL, `name` varchar(255) NOT NULL, `lastip` varchar(255) NOT NULL, PRIMARY KEY (`ID`)) ENGINE=InnoDB DEFAULT CHARSET=UTF8 AUTO_INCREMENT=1 ;");
			this.SQLQuerySync(
					"CREATE TABLE IF NOT EXISTS `rewards` (`ID` int(10) unsigned NOT NULL AUTO_INCREMENT, `Uuid` varchar(255) NOT NULL, PRIMARY KEY (`ID`)) ENGINE=InnoDB DEFAULT CHARSET=UTF8 AUTO_INCREMENT=1 ;");
			this.SQLQuerySync(
					"CREATE TABLE IF NOT EXISTS `copahg` (`id` int(10) unsigned NOT NULL AUTO_INCREMENT, `uuid` varchar(255) NOT NULL, `grupo` varchar(255) NOT NULL, PRIMARY KEY (`ID`)) ENGINE=InnoDB DEFAULT CHARSET=UTF8 AUTO_INCREMENT=1 ;");
			this.SQLQuerySync(
					"CREATE TABLE IF NOT EXISTS `motd` (`ID` int(10) unsigned NOT NULL AUTO_INCREMENT, `server` varchar(255) NOT NULL, `motd` varchar(255) NOT NULL, PRIMARY KEY (`ID`)) ENGINE=InnoDB DEFAULT CHARSET=UTF8 AUTO_INCREMENT=1 ;");
			this.SQLQuerySync(
					"CREATE TABLE IF NOT EXISTS `broadcast` (`ID` int(10) unsigned NOT NULL AUTO_INCREMENT, `message` varchar(255) NOT NULL, PRIMARY KEY (`ID`)) ENGINE=InnoDB DEFAULT CHARSET=UTF8 AUTO_INCREMENT=1 ;");
			this.SQLQuerySync(
					"CREATE TABLE IF NOT EXISTS `changelog` (`ID` int(10) unsigned NOT NULL AUTO_INCREMENT, `changes` varchar(255) NOT NULL, PRIMARY KEY (`ID`)) ENGINE=InnoDB DEFAULT CHARSET=UTF8 AUTO_INCREMENT=1 ;");
			this.SQLQuerySync(
					"CREATE TABLE IF NOT EXISTS `clans` (`ID` int(10) unsigned NOT NULL AUTO_INCREMENT, `name` varchar(255) NOT NULL, `tag` varchar(255) NOT NULL, PRIMARY KEY (`ID`)) ENGINE=InnoDB DEFAULT CHARSET=UTF8 AUTO_INCREMENT=1 ;");
			this.SQLQuerySync(
					"CREATE TABLE IF NOT EXISTS `clans_players` (`ID` int(10) unsigned NOT NULL AUTO_INCREMENT, `name` varchar(255) NOT NULL, `uuid` varchar(255) NOT NULL, `rank` varchar(255) NOT NULL, PRIMARY KEY (`ID`)) ENGINE=InnoDB DEFAULT CHARSET=UTF8 AUTO_INCREMENT=1 ;");
			this.SQLQuerySync(
					"CREATE TABLE IF NOT EXISTS `clans_status` (`ID` int(10) unsigned NOT NULL AUTO_INCREMENT, `name` varchar(255) NOT NULL, `kills` int(10), `deaths` int(10), `wins` int(10), `coins` int(10), `elo` int(10), PRIMARY KEY (`ID`)) ENGINE=InnoDB DEFAULT CHARSET=UTF8 AUTO_INCREMENT=1 ;");
			this.SQLQuerySync(
					"CREATE TABLE IF NOT EXISTS `fakebanned` (`ID` int(10) unsigned NOT NULL AUTO_INCREMENT, `Uuid` varchar(255) NOT NULL, PRIMARY KEY (`ID`)) ENGINE=InnoDB DEFAULT CHARSET=UTF8 AUTO_INCREMENT=1 ;");
			this.m.getLogger().info("Criando Tabelas no SQL");
		}
	}

	public static void SQLdisconnect(final Connection con) {
		try {
			if (con != null && !con.isClosed()) {
				con.close();
			}
		} catch (SQLException e) {
			e.printStackTrace();
		}
	}

	public void SQLdisconnect() {
		try {
			if (this.m.mainConnection != null && !this.m.mainConnection.isClosed()) {
				this.m.mainConnection.close();
			}
		} catch (SQLException e) {
			e.printStackTrace();
		}
	}

	public void SQLQuery(final String sql) {
		if (!this.m.sql) {
			return;
		}
		final ExecutorService executor = Executors.newCachedThreadPool();
		executor.execute(new Thread(new Runnable() {
			@Override
			public void run() {
				Connect.lock.lock();
				try {
					final Statement stmt = Connect.this.m.mainConnection.createStatement();
					stmt.executeUpdate(sql);
					stmt.close();
				} catch (SQLException e) {
					Connect.this.m.getLogger().info("Erro ao tentar executar Query");
					Connect.this.m.getLogger().info(sql);
					Connect.this.m.getLogger().info(e.getMessage());
				}
				Connect.lock.unlock();
			}
		}));
		executor.shutdown();
	}

	public void SQLQuerySync(final String sql) {
		if (!this.m.sql) {
			return;
		}
		try {
			final Statement stmt = this.m.mainConnection.createStatement();
			stmt.executeUpdate(sql);
			stmt.close();
		} catch (SQLException e) {
			this.m.getLogger().info("Erro ao tentar executar Query");
			this.m.getLogger().info(sql);
			this.m.getLogger().info(e.getMessage());
		}
	}
}