package server.util;

import java.sql.*;
import server.model.players.Client;

public class MadTurnipConnection extends Thread {

	public static Connection con = null;
	public static Statement stm;

	public static void createConnection() {
		try {
			Class.forName("com.mysql.jdbc.Driver").newInstance();
			con = DriverManager.getConnection("jdbc:mysql://deadly-pkz.com/db_name", "user_name" "pass");
			stm = con.createStatement();
		} catch (Exception e) {
			e.printStackTrace();
			con = null;
			stm = null;
		}
	}

	public MadTurnipConnection(){

	}

	public void run() {
		while(true) {
			try {
				if(con == null)
					createConnection();
				else
					ping();
				Thread.sleep(10000);//10 seconds
			} catch (Exception e) {
				e.printStackTrace();
			}
		}
	}

	public static void ping(){
		try {
			String query = "SELECT * FROM donation WHERE username = 'null'";
			query(query);
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

	public static void addDonateItems(final Client c,final String name){
		new Thread(){
			@Override
			public void run()
			{
				try {
					String name2 = name.replaceAll(" ","_");
					String query = "SELECT * FROM donation WHERE username = '"+name2+"'";
					ResultSet rs = query(query);
					boolean b = false;
					while(rs.next()){
						b = true;
						/*if(Integer.parseInt(rs.getString("productid")) == 1){
							c.getItems().addItem(6199,1);
							c.isDonator = 1;*/
						if(Integer.parseInt(rs.getString("productid")) == 1){
							c.getItems().addItem(11694,1);
							c.isDonator = 1;
						} else if(Integer.parseInt(rs.getString("productid")) == 2){
							c.getItems().addItem(11696,1);
							c.getItems().addItem(11724,1);
							c.getItems().addItem(11726,1);
							c.getItems().addItem(11728,1);
							c.isDonator = 1;
						} else if(Integer.parseInt(rs.getString("productid")) == 3){
							c.getItems().addItem(1042,1);
							c.isDonator = 1;
						} else if(Integer.parseInt(rs.getString("productid")) == 4){
							c.getItems().addItem(4151,1);
							c.isDonator = 1;
						} else if(Integer.parseInt(rs.getString("productid")) == 5){
							c.getItems().addItem(11720,1);
							c.getItems().addItem(11718,1);
							c.getItems().addItem(11722,1);
							c.isDonator = 1;
						} else if(Integer.parseInt(rs.getString("productid")) == 6){
							c.getItems().addItem(11698,1);
							c.isDonator = 1;
						} else if(Integer.parseInt(rs.getString("productid")) == 7){
							c.getItems().addItem(11700,1);
							c.isDonator = 1;
						} else if(Integer.parseInt(rs.getString("productid")) == 8){
							c.getItems().addItem(11696,1);
							c.isDonator = 1;
						} else if(Integer.parseInt(rs.getString("productid")) == 9){
							c.getItems().addItem(11730,1);
							c.isDonator = 1;
						} else if(Integer.parseInt(rs.getString("productid")) == 10){
							c.getItems().addItem(11335,1);
							c.isDonator = 1;
						} else if(Integer.parseInt(rs.getString("productid")) == 11){
							c.getItems().addItem(15010,1);
							c.isDonator = 1;
						} else if(Integer.parseInt(rs.getString("productid")) == 12){
							c.getItems().addItem(11235,1);
							c.isDonator = 1;
						} else if(Integer.parseInt(rs.getString("productid")) == 13){
							c.getItems().addItem(10551,1);
							c.isDonator = 1;
						} else if(Integer.parseInt(rs.getString("productid")) == 14){
							c.getItems().addItem(6570,1);
							c.isDonator = 1;
						} else if(Integer.parseInt(rs.getString("productid")) == 15){
							c.getItems().addItem(11283,1);
							c.isDonator = 1;
						} else if(Integer.parseInt(rs.getString("productid")) == 16){
							c.getItems().addItem(1053,1);
							c.getItems().addItem(1055,1);
							c.getItems().addItem(1057,1);
							c.isDonator = 1;
						} else if(Integer.parseInt(rs.getString("productid")) == 17){
							c.getItems().addItem(1038,1);
							c.getItems().addItem(1040,1);
							c.getItems().addItem(1042,1);
							c.getItems().addItem(1044,1);
							c.getItems().addItem(1046,1);
							c.getItems().addItem(1048,1);
							c.isDonator = 1;
						} else if(Integer.parseInt(rs.getString("productid")) == 18){
							c.getItems().addItem(1046,1);
							c.isDonator = 1;
						} else if(Integer.parseInt(rs.getString("productid")) == 19){
							c.getItems().addItem(1048,1);
							c.isDonator = 1;
						} else if(Integer.parseInt(rs.getString("productid")) == 20){
							c.getItems().addItem(1044,1);
							c.isDonator = 1;
						} else if(Integer.parseInt(rs.getString("productid")) == 21){
							c.getItems().addItem(1040,1);
							c.isDonator = 1;
						} else if(Integer.parseInt(rs.getString("productid")) == 22){
							c.getItems().addItem(1038,1);
							c.isDonator = 1;
						} else if(Integer.parseInt(rs.getString("productid")) == 23){
							c.getItems().addItem(15009,1);
							c.isDonator = 1;
						} else if(Integer.parseInt(rs.getString("productid")) == 24){
							c.getItems().addItem(15007,25);
							c.isDonator = 1;
						} else if(Integer.parseInt(rs.getString("productid")) == 25){
							c.getItems().addItem(15008,1);
							c.isDonator = 1;
						} else if(Integer.parseInt(rs.getString("productid")) == 26){
							c.getItems().addItem(995,50000000);
							c.isDonator = 1;
						} else if(Integer.parseInt(rs.getString("productid")) == 27){
							c.getItems().addItem(1050,1);
							c.isDonator = 1;
						} else if(Integer.parseInt(rs.getString("productid")) == 28){
							c.getItems().addItem(13899,1);
							c.getItems().addItem(13887,1);
							c.getItems().addItem(13893,1);
							c.isDonator = 1;
						//} else if(Integer.parseInt(rs.getString("productid")) == 29){
						//if (c.playerRights == 0);
						//	c.playerRights = 1;
						//	c.isDonator = 1;
						//} else if(Integer.parseInt(rs.getString("productid")) == 30){
						//if (c.playerRights <= 1);
						//	c.playerRights = 2;
						//	c.isDonator = 1;
						/*} else if(Integer.parseInt(rs.getString("productid")) == 2){
							c.playerRights = 3;
							c.isDonator = 3;*/

						}
						c.sendMessage("Thanks for donating, your donation will help the server.");
					}
					if(b){
						query("DELETE FROM `donation` WHERE `username` = '"+name2+"';");
					}
				} catch (Exception e) {
					e.printStackTrace();
				}
			}
		}.start();
	}

	public static ResultSet query(String s) throws SQLException {
		try {
			if (s.toLowerCase().startsWith("select")) {
				ResultSet rs = stm.executeQuery(s);
				return rs;
			} else {
				stm.executeUpdate(s);
			}
			return null;
		} catch (Exception e) {
			e.printStackTrace();
		}
		return null;
	}
}