package net.luckyverse.Manager;

import net.luckyverse.Log;

import java.net.SocketException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class SqlManager {

    private Connection conn = null;
    private Statement stat = null;

    private String ip;
    private String port;
    private String user;
    private String pass;
    private String db;

    public SqlManager(String ip, String port, String user, String password, String db) {

        this.ip = ip;
        this.port = port;
        this.user = user;
        this.pass = password;
        this.db = db;


        Log.send("Попытка подключиться к SQL");
        reconect();
    }

    public void reconect() {
        try {
            try {
                String driver = "com.mysql.jdbc.Driver";
                Class.forName(driver).newInstance();
            } catch (ClassNotFoundException e) {
                e.printStackTrace();
            }
        } catch (InstantiationException | IllegalAccessException e) {
            e.printStackTrace();
        }

        try {
            this.conn = DriverManager.getConnection(
                    "jdbc:mysql://" + ip + ":" + port + "/" + db + "?" + "user=" + user + "&password=" + pass);
            if (!conn.isClosed()) {
                Log.send("Соединение установлено");
                this.stat = conn.createStatement();
                stat.setQueryTimeout(60);
            }

        } catch (SQLException ex) { // handle any errors
            Log.send("[SQL] сгенерирована ошибка: ");
            System.out.println("SQLException: " + ex.getMessage());
            System.out.println("SQLState: " + ex.getSQLState());
            System.out.println("VendorError: " + ex.getErrorCode());

        }
    }

    public void closeConnection() {
        try {
            conn.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    public Connection getConectrion() {
        return conn;
    }

    public void run(String code) {
        try {
            stat.executeUpdate(code);
        } catch (SQLException ex) {
            closeConnection();
            reconect();
            try {
                stat.executeUpdate(code);
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

    public ResultSet get(String code) {

        try {
            return stat.executeQuery(code);
        } catch (SQLException ex) {
            closeConnection();
            reconect();
            try {
                return stat.executeQuery(code);
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        return null;
    }

}