package exemplodb;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;


public class ConexaoMysql extends ConexaoGenerica{
    private static final String DRIVER = "com.mysql.jdbc.Driver";
    private static final String URL = "jdbc:mysql:";
    private Connection conexao;
    private String usuario,senha,database,servidor;
    private int porta;

    @Override
    public void conectarDB() {
        try {
           Class.forName(DRIVER);
           conexao = DriverManager.getConnection(
                   URL+"//"+
                   servidor+":"+
                   porta+"/"+
                   database,
                   usuario,
                   senha);
        } catch (ClassNotFoundException ex) {
           System.out.println("Driver Inválido\n"
            + ex.getMessage()+"\nDriver:"+DRIVER);
        } catch (SQLException sqlex){
           System.out.println("URL Inválida | Usuario| Senha\n" +
                   sqlex.getMessage()+"\n"+URL+
                   "//"+servidor+"/"+database+","+usuario+",****");
        }

    }

    @Override
    public boolean desconectarDB() {
      if(conexao != null)
      try{
        conexao.close();
        return true;
       }catch (SQLException ex){
          System.out.println(
                  "Erro fechando a Conexão\n"+
                   ex.getMessage());
       }
       return false;
    }

    @Override
    public boolean isConectado() {
       return conexao != null;
    }

    @Override
    public ArrayList<Object> execSQL(String comandoSQL) {
      ArrayList<Object> dados = new ArrayList<Object>();
      try {
        Statement st = conexao.createStatement();
        ResultSet rs = st.executeQuery(comandoSQL);
        ResultSetMetaData rsdata = rs.getMetaData();
        while(rs.next()){
          Object itens[]=new
                      Object[rsdata.getColumnCount()];
          for(int i=1;i<=rsdata.getColumnCount();i++){
             itens[i-1] = rs.getString(i);
          }
          dados.add(itens);
        }
        return dados;
      } catch (SQLException ex) {
        System.out.println("Erro de SELECT"+
                           "\n"+comandoSQL);
        return null;
      }
    }

    @Override
    public int execUpdateInsertDelete(String SQL) {
        return 0;
    }

    @Override
    public void setUsuario(String usuario) {
      this.usuario = usuario;
    }

    @Override
    public void setSenha(String senha) {
      this.senha = senha;
    }

    @Override
    public void setServidor(String servidor) {
      this.servidor = servidor;
    }

    @Override
    public void setDataBase(String database) {
      this.database = database;
    }

    @Override
    public void setPorta(int porta) {
        this.porta = porta;
    }

}