import java.io.InputStreamReader;
import java.sql.*;
import java.util.ArrayList;
import java.util.LinkedList;
import java.io.BufferedReader;
import java.io.FileReader;

public class Diagnostico {

    private final String DATAFILE = "data/disease_data.data";
    private Connection connection = null;

    private void showMenu() {

        int option = -1;
        do {
            System.out.println("Bienvenido a sistema de diagnóstico\n");
            System.out.println("Selecciona una opción:\n");
            System.out.println("\t1. Creación de base de datos y carga de datos.");
            System.out.println("\t2. Realizar diagnóstico.");
            System.out.println("\t3. Listar síntomas de una enfermedad.");
            System.out.println("\t4. Listar enfermedades y sus códigos asociados.");
            System.out.println("\t5. Listar síntomas existentes en la BD y su tipo semántico.");
            System.out.println("\t6. Mostrar estadísticas de la base de datos.");
            System.out.println("\t7. Salir.");
            try {
                option = readInt();
                switch (option) {
                    case 1:
                        crearBD();
                        break;
                    case 2:
                        realizarDiagnostico();
                        break;
                    case 3:
                        listarSintomasEnfermedad();
                        break;
                    case 4:
                        listarEnfermedadesYCodigosAsociados();
                        break;
                    case 5:
                        listarSintomasYTiposSemanticos();
                        break;
                    case 6:
                        mostrarEstadisticasBD();
                        break;
                    case 7:
                        exit();
                        break;
                }
            } catch (Exception e) {
                System.err.println("Opción introducida no válida!");
            }
        } while (option != 7);
        exit();
    }

    private void exit() {
        System.out.println("Saliendo.. ¡hasta otra!");
        System.exit(0);
    }

    /**
     * Método para establecer conexión con la base de datos.
     *
     * @throws Exception Puede lanzar excepción.
     */
    private void conectar() throws Exception {
        if (connection == null) {
            try {
                connection = DriverManager.getConnection(
                        "jdbc:mysql://localhost:3306/diagnostico",
                        "bddx",
                        "bddx_pwd");
            } catch (Exception e) {
                throw new Exception("Could not connect to the database.");
            }
        }
    }

    private void crearBD() {
        try {
            conectar();
            ArrayList<String> sentenciasSQL = new ArrayList<>();
            sentenciasSQL.add("CREATE DATABASE diagnostico;");
            sentenciasSQL.add("CREATE TABLE disease (disease_id VARCHAR(45), name VARCHAR(255));");
            sentenciasSQL.add("CREATE TABLE disease_code (disease_id VARCHAR(45), code VARCHAR(255), source_id VARCHAR(25))");
            sentenciasSQL.add("CREATE TABLE disease_symptom (disease_id VARCHAR(45), symptom_id VARCHAR(25))");
            sentenciasSQL.add("CREATE TABLE code (code VARCHAR(255), source_id VARCHAR(25))");
            sentenciasSQL.add("CREATE TABLE source (source_id VARCHAR(25), name VARCHAR(255))");
            sentenciasSQL.add("CREATE TABLE symptom (cui VARCHAR(25), name VARCHAR(255))");
            sentenciasSQL.add("CREATE TABLE symptom_semantic_type (cui VARCHAR(25), semantic_type_id INT)");
            sentenciasSQL.add("CREATE TABLE semantic_type (semantic_type_id INT, tui VARCHAR(45))");
            for (String sentencia : sentenciasSQL){
                PreparedStatement ps = connection.prepareStatement(sentencia);
                ps.executeUpdate();
            }

            //TODO: Volcar datos en las tablas creadas.

        } catch (Exception e) {
            e.printStackTrace();
        }

    }

    private void realizarDiagnostico() {
        // implementar
    }

    private void listarSintomasEnfermedad() {
        // implementar
    }

    private void listarEnfermedadesYCodigosAsociados() {
        // implementar
    }

    private void listarSintomasYTiposSemanticos() {
        // implementar
    }

    private void mostrarEstadisticasBD() {
        // implementar
    }

    /**
     * Método para leer números enteros de teclado.
     *
     * @return Devuelve el número leído.
     * @throws Exception Puede lanzar excepción.
     */
    private int readInt() throws Exception {
        try {
            System.out.print("> ");
            return Integer.parseInt(new BufferedReader(new InputStreamReader(System.in)).readLine());
        } catch (Exception e) {
            throw new Exception("Not number.");
        }
    }

    /**
     * Método para leer cadenas de teclado.
     *
     * @return Devuelve la cadena leída.
     * @throws Exception Puede lanzar excepción.
     */
    private String readString() throws Exception {
        try {
            System.out.print("> ");
            return new BufferedReader(new InputStreamReader(System.in)).readLine();
        } catch (Exception e) {
            throw new Exception("Error reading line.");
        }
    }

    /**
     * Método para leer el fichero que contiene los datos.
     *
     * @return Devuelve una lista de String con el contenido.
     * @throws Exception Puede lanzar excepción.
     */
    private LinkedList<String> readData() throws Exception {
        LinkedList<String> data = new LinkedList<String>();
        BufferedReader bL = new BufferedReader(new FileReader(DATAFILE));
        while (bL.ready()) {
            data.add(bL.readLine());
        }
        bL.close();
        return data;
    }

    public static void main(String args[]) {
        new Diagnostico().showMenu();
    }
}