MultiSelectProperties

package com.dam.jdbc;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.File;
import java.io.IOException;
import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.Scanner;
import java.util.stream.Stream;

public class MultiSelect {
    public static String cfnMDB;
    public static String urlMDB;
    public static String usrMDB;
    public static String pwdMDB;
    public static String cfnPG;
    public static String urlPG;
    public static String usrPG;
    public static String pwdPG;

    public static void main(String[] args) throws ClassNotFoundException, SQLException, IOException {
        menu();
    }
    private static void menu() throws SQLException, IOException, ClassNotFoundException {
        System.out.print("Introduzca una opción:\n"
                + "1.MariaDB\n"
                + "2.Postgresql\n"
                + "0.Salir\n"
                + "Selección: ");
        Scanner scan = new Scanner(System.in);
        int option = scan.nextInt();
        switch(option) {
        case 1:
            getProperties(option);
            querySelect(createConnection(option));
            break;
        case 2:
            getProperties(option);
            querySelect(createConnection(option));
        break;
        default:
            System.exit(0);
        }

    }
    private static Connection createConnection(int option) throws SQLException, ClassNotFoundException {
        if(option==1) {
            Class.forName(cfnMDB);
            Connection connection = DriverManager.getConnection
                    (urlMDB,usrMDB,pwdMDB);
            return connection;
        }else {
            Class.forName(cfnPG);
            Connection connection = DriverManager.getConnection
                    (urlPG,usrPG,pwdPG);
            return connection;
        }

    }
    private static void querySelect(Connection connection) throws SQLException{
        Statement query = connection.createStatement();

        //4. Ejecutar statement y lo guardamos en ResultSet.
        ResultSet queryInfo = query.executeQuery
                ("SELECT * FROM actor");
        //5. Mostrar resultados.

        while(queryInfo.next())
            System.out.println(
                    queryInfo.getInt(1)+ " | " +
                    queryInfo.getString(2)+ " | " +
                    queryInfo.getString(3));


        //6. Cerrar objetos.
            queryInfo.close();
            query.close();
            connection.close();
        //Orden contrario a la creación.
    }

    private static void getProperties(int option) throws IOException {
        Path path = Paths.get("D:\\base.properties");
        BufferedReader br = Files.newBufferedReader(path);
        String line = "";
        String[] fields = null;
        String[] info;
        if(option == 1) {
            while ((line = br.readLine()) != null) {
                if(line.contains("classForNameMariaDB")) {
                    cfnMDB = line.substring(line.indexOf("=")+1);
                }else if(line.contains("urlMariaDB")) {
                    urlMDB = line.substring(line.indexOf("=")+1);
                }else if(line.contains("userMariaDB")) {
                    usrMDB = line.substring(line.indexOf("=")+1);
                }else if(line.contains("passMariaDB")) {
                    pwdMDB = line.substring(line.indexOf("=")+1);
                }
            }
        }else {
            while ((line = br.readLine()) != null) {
                if(line.contains("classForNamePostgresql")) {
                    cfnPG = line.substring(line.indexOf("=")+1);
                }else if(line.contains("urlPostgresql")) {
                    urlPG = line.substring(line.indexOf("=")+1);
                }else if(line.contains("userPostgresql")) {
                    usrPG = line.substring(line.indexOf("=")+1);
                }else if(line.contains("passPostgresql")) {
                    pwdPG = line.substring(line.indexOf("=")+1);
                }
            }
        }

    }
}