import javax.print.attribute.standard.RequestingUserName;
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 List<String> MuleRequestIds = new ArrayList<String>();
    private static Connection conn = null;

    public static void main(String[] args) throws IOException, SQLException {
        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);
        conn = DriverManager.getConnection(connStr, user, pass);

        getJobRequests();
        assignJobToMule();
    }

    private static void assignJobToMule() {
        try {

            for (int i = 0; i < MuleRequestIds.size(); i++) {
                System.out.println(MuleRequestIds.get(i));
            }

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

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

    }

    private static void getJobRequests() {
        try {
            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"));
                }
            }

            while (!q.isEmpty()) {
                String removedele = q.remove();

                MuleRequestIds.add(removedele);
                System.out.println("REMOVED ELEMENT" + removedele);
            }


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


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