public class MySQL {

    private static HikariConfig config = new HikariConfig();
    private static HikariDataSource ds;

    static {
        config.setJdbcUrl("jdbc:mysql://localhost:3306/mordziaty");
        config.setUsername("root");
        config.setPassword("");
        config.addDataSourceProperty("cachePrepStmts", "true");
        config.addDataSourceProperty("prepStmtCacheSize", "250");
        config.addDataSourceProperty("prepStmtCacheSqlLimit", "2048");
        ds = new HikariDataSource(config);
    }

    public static Connection getConnection() throws SQLException {
        return ds.getConnection();
    }

    public static void createTable() throws SQLException{
        StringBuilder sb = new StringBuilder();

        sb.append("create table if not exists users(");
        sb.append("uuid varchar(36) not null,");
        sb.append("name varchar(20) not null,");
        sb.append("primary key(uuid));");

        try {
            getConnection().createStatement().executeUpdate(sb.toString());
            System.out.print("udalo sie stworzyc tabeleki");
        } catch (SQLException e) {
            e.printStackTrace();
            System.out.print("Nie udalo sie stworzyc tabelek");
        }
    }

    public static void loadData() throws SQLException {
        int i = 0;
        ResultSet rs = getConnection().createStatement().executeQuery("SELECT * FROM `users`");
        while (rs.next()) {
            User u = User.get(UUID.fromString(rs.getString("uuid")));
            u.setName(rs.getString("name"));
            i++;
        }
        Bukkit.getConsoleSender().sendMessage("Loaded " + i + " users");
    }


    public static void saveData() throws SQLException {
        int i = 0;
        for (User u : UserUtils.getUsers()) {
            StringBuilder sb = new StringBuilder();
            sb.append("INSERT INTO users (uuid, name) VALUES (");
            sb.append("'" + u.getUuid().toString() + "',");
            sb.append("'" + u.getName() + "'");
            sb.append(") ON DUPLICATE KEY UPDATE ");
            sb.append("name='" + u.getName() +"';");
            getConnection().createStatement().executeUpdate(sb.toString());
            i++;
        }
        Bukkit.getConsoleSender().sendMessage("Saved " + i + " §users");
    }
}