import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.sql.*;
import java.time.ZoneId;
import java.util.*;

public class Main {

    private static String MuleRequestId;

    public static void main(String[] args) throws IOException {
        getJobRequests();
        assignJobToMule();
    }

    private static void assignJobToMule() {
        try {
            String host = "localhost:3306";
            String db = "muling";
            String user = "root";
            String pass = "";
            String connStr = String.format("jdbc:mysql://%s/%s?useUnicode=true&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=UTC", host, db);
            Connection conn = DriverManager.getConnection(connStr, user, pass);

            ResultSet results = conn.createStatement().executeQuery("SELECT * FROM mulerequest WHERE MuleRequestId='" + MuleRequestId + "'");
            while (results.next()){
                System.out.println(results.getString("MuleRequestId"));
            }

        } catch (SQLException e) {
            System.out.println(e);
        }

    }

    private static void getJobRequests() {
        try {
            String host = "localhost:3306";
            String db = "muling";
            String user = "root";
            String pass = "";
            String connStr = String.format("jdbc:mysql://%s/%s?useUnicode=true&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=UTC", host, db);
            Connection conn = DriverManager.getConnection(connStr, user, pass);
            ResultSet results = conn.createStatement().executeQuery("SELECT * FROM mulerequest WHERE MuleJobStatus='in-progress'");

            PriorityQueue<String> q = new PriorityQueue<String>();
            while (results.next()) {
                if (results.getString("MuleJobStatus").equals("in-progress")) {
                    q.add(results.getString("MuleRequestId"));
                }
            }

            String removedele = q.remove();

            MuleRequestId = removedele;
            System.out.println("REMOVED ELEMENT" + removedele);

            System.out.printf("%s ", q);
            System.out.println();


        } catch (SQLException e) {
            System.out.println(e);
        }
    }

}