package mariadb;
import java.sql.*;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;

public class MariaDB {

   private Connection conexion;

    public Connection getConexion() {
        return conexion;
    }

    public void setConexion(Connection conexion) {
        this.conexion = conexion;
    }

    public MariaDB conectar() {
        try {
            Class.forName("com.mysql.jdbc.Driver");
            String BaseDeDatos = "jdbc:mysql://localhost:3311/unidad1?user=root&password=123456siete";

            setConexion(DriverManager.getConnection(BaseDeDatos));
            if (conexion != null) {
                System.out.println("Conexion exitosa!");
            } else {
                System.out.println("Conexion fallida!");
            }
        } catch (Exception e) {
            e.printStackTrace();
        }

        return this;
    }

    public ResultSet consultar(String sql) {
        ResultSet resultado;
        try {
            Statement sentencia = getConexion().createStatement(ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY);
            resultado = sentencia.executeQuery(sql);
        } catch (SQLException e) {
            e.printStackTrace();
            return null;
        }
        return resultado;
    }

    public boolean ejecutar(String sql) {
        try {
            Statement sentencia = getConexion().createStatement(ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY);
            sentencia.execute(sql);
            sentencia.close();
        } catch (SQLException e) {
            e.printStackTrace();
            return false;
        }
        return true;
    }

           public static void main(String[] args) {
        MariaDB baseDatos = new MariaDB().conectar();

                             ------""""""""""""""EN ESTA PARTE ES DONDE SE REALIZAN LAS CONSULTAS""""""""""""""------

 if (baseDatos.ejecutar("INSERT INTO UNIDAD1.productos(Pro_ID,Pro_descripcion,Pro_nombre,Pro_precio) VALUES(666, 'Fruta Seca', 'Mango', 333)")) {
            System.out.println("Ejecución correcta!");
        } else {
            System.out.println("Ocurrió un problema al ejecutar!");
        }
        ResultSet resultados = baseDatos.consultar("SELECT * FROM productos");
        if (resultados != null) {
            try {
                System.out.println("Producto ID       Desc. Producto         Nombre Producto          Precio Producto");
                System.out.println("---------------------------------------------------------------------------------");
                while (resultados.next()) {
                    System.out.println("  "+resultados.getBigDecimal("Pro_ID")+"                 "+resultados.getString("Pro_descripcion")+"                "
                    +resultados.getString("Pro_nombre")+"                  "+resultados.getBigDecimal("Pro_precio"));
                }
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }
}