lectorSQL

package ejercicio3;

import java.io.BufferedReader;
import java.io.FileNotFoundException;
import java.io.FileReader;
import java.io.IOException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.logging.Level;
import java.util.logging.Logger;

public class ManejadorConexion {

    private Connection conn;
    private BufferedReader lector;

    public ManejadorConexion(){
        abrirConex();
        System.out.println("Conex Abierta!");
        leerSQL("ferreteria");
        System.out.println("Tablas construidas!");
        leerSQL("ferreteria_datos");
        System.out.println("Datos colocados!");
    }
    private void abrirConex(){
        String nombreFichero = "";
        try {
            conn = DriverManager.getConnection("jdbc:mysql://localhost/", "root", "");
        } catch (SQLException ex) {
            Logger.getLogger(ManejadorConexion.class.getName()).log(Level.SEVERE, null, ex);
        }
        if(!existeBD("ferreteria")){
            System.out.println("BD no encontrada creando una...");
            String query = "CREATE DATABASE ferreteria";
            try {
                PreparedStatement s = conn.prepareStatement(query);
                s.executeUpdate();
                s.close();
                conn.close();
                conn = DriverManager.getConnection("jdbc:mysql://localhost/ferreteria","root","");
            } catch (SQLException ex) {
                Logger.getLogger(ManejadorConexion.class.getName()).log(Level.SEVERE, null, ex);
            }
        }else{
            try {
                conn.close();
                conn = DriverManager.getConnection("jdbc:mysql://localhost/ferreteria","root","");
            } catch (SQLException ex) {
                Logger.getLogger(ManejadorConexion.class.getName()).log(Level.SEVERE, null, ex);
            }
        }
    }
    private void leerSQL(String fichero){
        try {
            lector = new BufferedReader(new FileReader("bd/"+fichero+".sql"));
            int letra;
            String query = "";
            try {
                while((letra = lector.read()) != -1){
                    if((char)letra != ';'){
                        if((char)letra != '\n'){
                            query += (char)letra;
                        }
                    }else{
                        query += ';';
                        try {
                            PreparedStatement s = conn.prepareStatement(query);
                            s.executeUpdate();
                            s.close();
                        } catch (SQLException ex) {
                            //Logger.getLogger(ManejadorConexion.class.getName()).log(Level.SEVERE, null, ex);
                        }
                        query = "";
                    }
                }
            } catch (IOException ex) {
                //Logger.getLogger(ManejadorConexion.class.getName()).log(Level.SEVERE, null, ex);
            }
        } catch (FileNotFoundException ex) {
            Logger.getLogger(ManejadorConexion.class.getName()).log(Level.SEVERE, null, ex);
        }
    }
    private boolean existeBD(String nombre){
        try {
            ResultSet r = conn.getMetaData().getCatalogs();
            while(r.next()){
                if(nombre.equals(r.getString(1))){
                    r.close();
                    return true;
                }
            }
        } catch (SQLException ex) {
            Logger.getLogger(ManejadorConexion.class.getName()).log(Level.SEVERE, null, ex);
        }
        return false;
    }
}