12

package de.fallenbreak.skyfantasy.database;

import com.sun.rowset.CachedRowSetImpl;
import com.zaxxer.hikari.HikariDataSource;
import de.fallenbreak.skyfantasy.SkyFantasyDEAPI;
import org.bukkit.scheduler.BukkitRunnable;

import java.sql.*;

public class MySQL {

    String ip, database, username, password;
    Integer port;

    HikariDataSource hikariDataSource;

    public MySQL(MySQLFile mySQLFile) {
        this.ip = mySQLFile.getIp();
        this.password = mySQLFile.getPassword();
        this.username = mySQLFile.getUsername();
        this.database = mySQLFile.getDatabase();
        this.port = mySQLFile.getPort();

        hikariDataSource = new HikariDataSource();

        hikariDataSource.setJdbcUrl("jdbc:mysql://" + mySQLFile.getIp() + ":" + mySQLFile.getPort() + "/" + mySQLFile.getDatabase());
        hikariDataSource.setUsername(mySQLFile.getUsername());
        hikariDataSource.setPassword(mySQLFile.getPassword());
        hikariDataSource.setMaximumPoolSize(25);

    }

    public void execute(final String query) {
        new BukkitRunnable() {
            @Override
            public void run() {

                try(PreparedStatement preparedStatement = hikariDataSource.getConnection().prepareStatement(query)){
                    preparedStatement.executeUpdate();
                    preparedStatement.close();
                } catch (SQLException e) {
                    System.out.println("[]------[ MYSQL-ERROR ]------[]");
                    System.out.println("Error whilest performing execute.");
                    System.out.println("Command: " + query);
                    System.out.println("-> " + e.getMessage());
                }
            }
        }.runTaskAsynchronously(SkyFantasyDEAPI.getInstance());
    }

    public ResultSet executeQuery(final String qry) {
        Connection connection = null;
        Statement stmt = null;
        ResultSet resultSet = null;
        CachedRowSetImpl crs = null;

        try {
            connection = hikariDataSource.getConnection();

            stmt = connection.createStatement();
            resultSet = stmt.executeQuery(qry);

            crs = new CachedRowSetImpl();
            crs.populate(resultSet);
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            try {
                if (resultSet != null) {
                    resultSet.close();
                }
                if (stmt != null) {
                    stmt.close();
                }
                if (connection != null) {
                    connection.close();
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        return crs;
    }

    public String getSpezificString(String table, String whatreturn, String bedingung, String value) {
        ResultSet  rs = executeQuery("SELECT * FROM " + table + " WHERE " + bedingung + "='" + value + "'");
        String returner = null;

        try {
            if(rs.next()) {
                returner = rs.getString(whatreturn);
            }
        } catch (SQLException e) {
            return null;
        }

        return returner;
    }

    public String getString(String table, String whatreturn) {
        ResultSet  rs = executeQuery("SELECT * FROM " + table);
        String returner = null;

        try {
            if(rs.next()) {
                returner = rs.getString(whatreturn);
            }
        } catch (SQLException e) {
            return null;
        }

        return returner;
    }
}