package ru.lisenochek.clans.sql;

import ru.lisenochek.clans.Logger;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;

public class SQLManager {

    private static Connection connection;
    private static Statement statement;
    private static ResultSet resultSet;

    public synchronized static void initSQL() {

        try {
            openConnection();
            createTable();
        } catch (Exception e) {
            Logger.error("Что-то пошло не так и произошло исключение:");
            e.printStackTrace();
        } finally {
            Logger.success("База данных успешно подключена!");
        }
    }

    public synchronized static void closeConnection() {

        try {
            if (!connection.isClosed()) connection.close();
        } catch (Exception e) {
            Logger.error("Произошло исключение при выполнении запроса. Исключение:");
            Logger.error(e.getMessage());
        }
    }

    public synchronized static void openConnection() {

        try {
            Class.forName("org.sqlite.JDBC");
            connection = DriverManager.getConnection("jdbc:sqlite:plugins/Clans/Database.db");
            statement = connection.createStatement();
        } catch (Exception e) {
            Logger.error("Что-то пошло не так и произошло исключение:");
            e.printStackTrace();
        }
    }

    public synchronized static void createTable() {

        try {
            executeQuery("CREATE TABLE if not exists CLANS ('id' INTEGER NOT NULL, 'name' TEXT NOT NULL, 'leader' TEXT NOT NULL);");
        } catch (Exception e) {
            Logger.error("Что-то пошло не так и произошло исключение:");
            e.printStackTrace();
        }
    }

    public synchronized static void createClan(int id, String clanName, String leaderName) {

        try {
            executeQuery("INSERT INTO CLANS ('id', 'name', 'leader') VALUES ('" + id + "'" + "," + "'" + clanName + "'" + "," + "'" + leaderName + "'" + ");");
        } catch (Exception e) {
            Logger.error("Что-то пошло не так и произошло исключение:");
            e.printStackTrace();
        }
    }

    private synchronized static boolean executeQuery(String query) {

        try {
            if (query == null || query.equals("")) {
                Logger.error("Невозможно выполнить запрос. Причина: запрос пустой.");
                return false;
            }

            statement.execute(query);
            closeConnection();
            openConnection();
            return true;
        } catch (Exception e) {
            Logger.error("Произошло исключение при выполнении запроса. Исключение:");
            Logger.error(e.getMessage());
            return false;
        }
    }
}