public class conexion {
    private Connection con;
    
    public Connection conexion() throws Exception 
    {
        Class.forName("com.mysql.jdbc.Driver");
        con= DriverManager.getConnection("jdbc:mysql://localhost:3306/db_compras","root", "xxxxxxxx");
        return con;
    }
    
    public ResultSet obtenerResultado(String consulta) throws Exception
    {
        ResultSet rs=null;
        Statement st;
        
        con= conexion();
        st= con.createStatement();
        rs= st.executeQuery(consulta);
        
        return rs;   
    }
    
    public void cerrarConexion() throws Exception
    {
        con.close();
        con=null;
    }
    
    public void realizarTransaccion(String query) throws Exception
    {
        try
        {
            Statement st1;
            con= conexion();
            con.setAutoCommit(false);

            st1= con.createStatement();
            st1.execute(query);

            con.commit();
            con.setAutoCommit(true);

            st1.close();
            con.close();
            JOptionPane.showMessageDialog(null, "LA TRASACCION SE REALIZO CORRECTAMENTE");
        }
        catch(Exception ex)
        {
            con.rollback();
            JOptionPane.showMessageDialog(null, "ERROR" + ex);
        }
        
    }
}