package ru.MySQL;

import java.io.File;
import java.sql.*;
import java.util.ArrayList;
import java.util.List;

import org.apache.logging.log4j.core.appender.rolling.SizeBasedTriggeringPolicy;
import org.bukkit.configuration.file.FileConfiguration;
import org.bukkit.entity.Player;

import ru.main;

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

    @SuppressWarnings("deprecation")
	public SQLClass() throws Exception{
	FileConfiguration c = plugin.getConfig();
	String database = c.getString("mysql.database");
	user = c.getString("mysql.user");
	pass = c.getString("mysql.password");
	String host = c.getString("mysql.host");
	int port = c.getInt("mysql.port");
	url = "jdbc:mysql://" + host + ":" + port + "/" + database;
	Connection conn = getConnectinon();
	Statement s = conn.createStatement();
	s.executeUpdate("CREATE TABLE IF NOT EXISTS lsrvcore_tag(name, tags TEXT);");
	s.close();
	conn.close();
    }

public static Connection getConnectinon() throws SQLException {
if(user != null)
	return DriverManager.getConnection(url, user, pass);
 else return DriverManager.getConnection(url);
}
public static void SaveData(Player player, String tag) {
try {
	Connection conn = getConnectinon();
	Statement s = conn.createStatement();
	String ss = GetSQL(player);
	String ssd = ss.replace(ss, ss + "," + tag);
	s.executeUpdate(String.format("INSERT INTO lsrvcore_tag (name, tags TEXT) VALUES (%d, %s);",player, ssd));
	s.close();
	conn.close();
	return;

} catch(Exception e) {
e.printStackTrace();
}
}
public static String GetSQL(Player player) {
try {
	Connection conn = getConnectinon();
	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;
}
}