package fr.frinka.SQL;

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

import org.bukkit.entity.Player;

public class SqlConnection {

	private Connection connection;
	private String urlbase, host, database, user, pass;

	public SqlConnection(String urlbase, String host, String database, String user, String pass) {
		this.urlbase = urlbase;
		this.host = host;
		this.database = database;
		this.user = user;
		this.pass = pass;
	}

	public void connection() {
		if (!isConnected()) {
			try {
				connection = DriverManager.getConnection(urlbase + host + "/" + database, user, pass);
				System.out.println("connected ok");
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
	}

	public void disconnect() {
		if (isConnected()) {
			try {
				connection.close();
				System.out.println("connected off");
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
	}

	public boolean isConnected() {
		return connection != null;
	}

	public void createAccount(Player player) {
		try {
			PreparedStatement q = connection.prepareStatement("SELECT money FROM PlayerMoney WHERE uuid = ?");
			q.setString(1, player.getUniqueId().toString());

			ResultSet rs = q.executeQuery();

			if (!rs.next()) {
				q.close();
				PreparedStatement q1 = connection.prepareStatement("INSERT INTO PlayerMoney (uuid,money) VALUES (?,?)");
				q1.setString(1, player.getUniqueId().toString());
				q1.setInt(2, 0);
				q1.execute();
				q1.close();
			}
		} catch (SQLException e) {
			e.printStackTrace();
		}
	}

	public int getBalance(Player player) {
		// SELECT

		try {
			PreparedStatement q = connection.prepareStatement("SELECT money FROM PlayerMoney WHERE uuid = ?");
			q.setString(1, player.getUniqueId().toString());

			int balance = 0;
			ResultSet rs = q.executeQuery();

			while (rs.next()) {
				balance = rs.getInt("money");
			}

			q.close();

			return balance;

		} catch (SQLException e) {
			e.printStackTrace();
		}

		return 0;
	}

	public void addMoney(Player player, int amount) {
		// UPDATE

		int balance = getBalance(player);
		int newbalance = balance + amount;

		try {
			PreparedStatement rs = connection.prepareStatement("UPDATE money SET money = ? WHERE uuid = ?");
			rs.setInt(1, newbalance);
			rs.setString(2, player.getUniqueId().toString());
			rs.executeUpdate();
			rs.close();

		} catch (SQLException e) {
			e.printStackTrace();
		}

	}

	public void removeMoney(Player player, int amount) {
		// UPDATE

		int balance = getBalance(player);
		int newbalance = balance - amount;

		if (newbalance <= 0) {
			return;
		}

		try {
			PreparedStatement rs = connection.prepareStatement("UPDATE money SET money = ? WHERE uuid = ?");
			rs.setInt(1, newbalance);
			rs.setString(2, player.getUniqueId().toString());
			rs.executeUpdate();
			rs.close();

		} catch (SQLException e) {
			e.printStackTrace();
		}

	}

}