package ru.MySQL;

import java.sql.*;
import org.bukkit.entity.Player;

import ru.main;

public class SQLClass {
	private main plugin;
	private static String url;

	public SQLClass() throws Exception{
        this.plugin = plugin;
        String user = plugin.getConfig().getString("mysql.login");
        String pass = plugin.getConfig().getString("mysql.password");
        int port = plugin.getConfig().getInt("mysql.port");
        String db = plugin.getConfig().getString("mysql.db");
        String host = plugin.getConfig().getString("mysql.ip");
    	String url = "jdbc:mysql://" + host + ":" + port + "/" + 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, tags TEXT);");
	s.close();
	conn.close();
    }
public void SaveData(Player player, String tag) {
try {
    String user = plugin.getConfig().getString("mysql.login");
    String pass = plugin.getConfig().getString("mysql.password");
	Connection conn = DriverManager.getConnection(url, user, pass);
	Statement s = conn.createStatement();
	String ss = GetSQL(player);
	String ssd = ss.replace(ss, ss + "," + tag);
	s.executeUpdate(String.format("INSERT INTO lsrvcore_tag (name NOT NULL, tags TEXT NOT NULL) VALUES (%d, %s);",player, ssd));
	s.close();
	conn.close();
	return;

} catch(Exception e) {
e.printStackTrace();
}
}
public String GetSQL(Player player) {
try {
    String user = plugin.getConfig().getString("mysql.login");
    String pass = plugin.getConfig().getString("mysql.password");
	Connection conn = DriverManager.getConnection(url, user, pass);
Statement s = conn.createStatement();
	ResultSet rs = s.executeQuery(String.format("SELECT (name, tags) FROM lsrvcore_tag WHERE name=%s", player));
	while(rs.next()) {
		String outs = rs.getString("tags");
		s.close();
		conn.close();
		return outs;
	}
	} catch(Exception e) {
		e.printStackTrace();
}
return null;
}
}