package ru.MySQL;

import java.sql.*;

import org.bukkit.ChatColor;
import org.bukkit.entity.Player;

import ru.main;
import ru.utils.EconomyManager;

public class SQLClass{

	public SQLClass() throws Exception{
        String user = main.instance.getConfig().getString("mysql.login");
        String pass = main.instance.getConfig().getString("mysql.password");
        String db = main.instance.getConfig().getString("mysql.db");
        String host = main.instance.getConfig().getString("mysql.ip");
    	String url = "jdbc:mysql://"+ host + ":3306" + "/" + db;
	Class.forName("com.mysql.jdbc.Driver").getConstructor().newInstance();
	Connection conn = DriverManager.getConnection(url, user, pass);
	Statement s = conn.createStatement();
	s.executeUpdate("CREATE TABLE IF NOT EXISTS lsrvcore_tag(name TEXT, tags TEXT);");
	s.close();
	conn.close();
}
public void SaveData(String player, String tag) {
try {
    String user = main.instance.getConfig().getString("mysql.login");
    String pass = main.instance.getConfig().getString("mysql.password");
    String db = main.instance.getConfig().getString("mysql.db");
    String host = main.instance.getConfig().getString("mysql.ip");
	String url = "jdbc:mysql://"+ host + ":3306" + "/" + db;
	Connection conn = DriverManager.getConnection(url, user, pass);
	Statement s = conn.createStatement();
	String ss = GetSQL(player);
	String ssd = ss.replace(ss, ss + "," + tag);
	s.executeUpdate("UPDATE lsrvcore_tag SET tags = '" + ssd + "' WHERE name = '" + player + "';");
	s.close();
	conn.close();
	return;

} catch(Exception e) {
e.printStackTrace();
}
}
public String GetSQL(String player) throws SQLException {
    String user = main.instance.getConfig().getString("mysql.login");
    String pass = main.instance.getConfig().getString("mysql.password");
    String db = main.instance.getConfig().getString("mysql.db");
    String host = main.instance.getConfig().getString("mysql.ip");
	String url = "jdbc:mysql://"+ host + ":3306" + "/" + db;
	Connection conn = DriverManager.getConnection(url, user, pass);
Statement s = conn.createStatement();
	ResultSet rs = s.executeQuery("SELECT name, tags FROM lsrvcore_tag WHERE name='" + player +"';");
	while(rs.next()) {
		String outs = rs.getString("tags");
		s.close();
		conn.close();
	return outs;
	}
	return null;
}
public void SaveJoin(String player) throws SQLException {
    String user = main.instance.getConfig().getString("mysql.login");
    String pass = main.instance.getConfig().getString("mysql.password");
    String db = main.instance.getConfig().getString("mysql.db");
    String host = main.instance.getConfig().getString("mysql.ip");
	String url = "jdbc:mysql://"+ host + ":3306" + "/" + db;
	String d = GetSQL(player) ;
	if(!(d.equals(null) || !d.equals("none"))) {
		Connection conn;
		conn = DriverManager.getConnection(url, user, pass);
		Statement s;
		s = conn.createStatement();
	    s.executeUpdate("INSERT INTO `lsrvcore_tag`(`name`, `tags`) VALUES ('"+ player +"','none')");
		s.close();
		conn.close();
	}else{
		return;


}
}
}