FilmesBD

package Locadora;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import javax.swing.JOptionPane;

/**
 * Classe que possui os métodos de acesso ao banco de dados.
 * Com esta classe é possível armazenar diversos filmes e realizar o CRUD.
 * @author Thiago Carelli
 * @since Classe criada em 24/10/2016
 * Obs.: classe aprimorada em
 */
public class FilmeBD {
    Connection conexao;
    Statement comando;
    String sql;
    ResultSet rs;

    //Método para gravação do filme no BD.
    public void salvarNovoFilme (Filme filme) throws SQLException, ClassNotFoundException{
        sql = "INSERT INTO filmes (titulo, diretor, genero, duracao, ator_um, ator_dois, ator_tres, sintese, ano, idade) VALUES ("
                + "'"  + filme.getTitulo()      + "'"
                + ",'" + filme.getDiretor()     + "'"
                + ",'" + filme.getGenero()      + "'"
                + ",'" + filme.getDuracao()     + "'"
                + ",'" + filme.getAtorUm()      + "'"
                + ",'" + filme.getAtorDois()    + "'"
                + ",'" + filme.getAtorTres()    + "'"
                + ",'" + filme.getSintese()     + "'"
                + ","  + filme.getAno()
                + ",'" + filme.getIdade()       + "'"
                + ")";
        conexao = getConnection();
        comando = conexao.createStatement();
        if (comando.executeUpdate(sql) > 0)
            JOptionPane.showMessageDialog(null,"Copia salva com sucesso!");
        else
            JOptionPane.showMessageDialog(null,"ERRO - Problemas na gravação do BD!");
    }

    //Método para buscar dados do filmes no BD pelo titulo.
    public Filme buscarFilmeTitulo (String titulo) throws SQLException, ClassNotFoundException {
        Filme fil = new Filme ();
        sql = "SELECT * FROM filmes WHERE titulo = '" + titulo + "'";
        conexao = getConnection();
        comando = conexao.createStatement();
        rs = comando.executeQuery(sql);
            while (rs.next()){
                fil.setId       (Integer.parseInt(rs.getString(1)));
                fil.setTitulo   (rs.getString(2));
                fil.setDiretor  (rs.getString(3));
                fil.setGenero   (rs.getString(4));
                fil.setDuracao  (rs.getString(5));
                fil.setAtorUm   (rs.getString(6));
                fil.setAtorDois (rs.getString(7));
                fil.setAtorTres (rs.getString(8));
                fil.setSintese  (rs.getString(9));
                fil.setAno      (Integer.parseInt(rs.getString(10)));
                fil.setIdade    (rs.getString(11));
                fil.setStatus   (rs.getString(12));
            }
        return fil;
    }

    //Método para buscar dados do filmes no BD pelo titulo (restrição de ID).
    Filme buscarFilmeTituloId(String titulo, String id1, String id2, String id3, String id4) throws SQLException, ClassNotFoundException {
        Filme fil = new Filme ();
        sql = "SELECT * FROM filmes WHERE titulo = '" + titulo + "' and id <> '" + id1 + "'and id <> '" + id2 + "'and id <> '" + id3 + "'and id <> '" + id4 + "' ";
        conexao = getConnection();
        comando = conexao.createStatement();
        rs = comando.executeQuery(sql);
            while (rs.next()){
                fil.setId       (Integer.parseInt(rs.getString(1)));
                fil.setTitulo   (rs.getString(2));
                fil.setDiretor  (rs.getString(3));
                fil.setGenero   (rs.getString(4));
                fil.setDuracao  (rs.getString(5));
                fil.setAtorUm   (rs.getString(6));
                fil.setAtorDois (rs.getString(7));
                fil.setAtorTres (rs.getString(8));
                fil.setSintese  (rs.getString(9));
                fil.setAno      (Integer.parseInt(rs.getString(10)));
                fil.setIdade    (rs.getString(11));
                fil.setStatus   (rs.getString(12));
            }
        return fil;
    }

    //Método para buscar dados do filmes no BD pelo ID.
    Filme buscarFilmeId(int id1, int id2, int id3, int id4) throws SQLException, ClassNotFoundException {
        Filme fil = new Filme ();
        sql = "SELECT * FROM filmes WHERE id = '" + id1 + "' || id = '" + id2 + "'|| id = '" + id3 + "'|| id || '" + id4 + "' ";
        conexao = getConnection();
        comando = conexao.createStatement();
        rs = comando.executeQuery(sql);
            while (rs.next()){
                fil.setId(Integer.parseInt(rs.getString(1)));
                fil.setTitulo(rs.getString(2));
                fil.setDiretor(rs.getString(3));
                fil.setGenero(rs.getString(4));
                fil.setDuracao(rs.getString(5));
                fil.setAtorUm(rs.getString(6));
                fil.setAtorDois(rs.getString(7));
                fil.setAtorTres(rs.getString(8));
                fil.setSintese(rs.getString(9));
                fil.setAno(Integer.parseInt(rs.getString(10)));
                fil.setIdade(rs.getString(11));
                fil.setStatus(rs.getString(12));
            }
        return fil;
    }

    //Método para atualizar os dados do cadastro do filme pelo nome.
    public void alterarFilmeTitulo (Filme filme, String titulo) throws SQLException, ClassNotFoundException{
        String sql;
        conexao = getConnection();
        comando = conexao.createStatement();
        sql = "UPDATE filmes SET "
                + "titulo = '"          + filme.getTitulo()     + "'"
                + ",diretor = '"        + filme.getDiretor()    + "'"
                + ",genero  = '"        + filme.getGenero()     + "'"
                + ",duracao = '"        + filme.getDuracao()    + "'"
                + ",atorUm = '"         + filme.getAtorUm()     + "'"
                + ",atorDois = '"       + filme.getAtorDois()   + "'"
                + ",atorTres = '"       + filme.getAtorTres()   + "'"
                + ",sintese = '"        + filme.getSintese()    + "'"
                + ",ano = "             + filme.getAno()
                + ",idade = '"          + filme.getIdade()      + "'"
                + ",status = '"         + filme.getStatus()     + "'"
                + " WHERE titulo = '"   + titulo                + "'";
        comando.executeUpdate(sql);
        JOptionPane.showMessageDialog(null, "Dados do filente alterados com sucesso!");
    }


    //Método para deletar os dados do filme do BD.
    public void excluirfilme (String titulo) throws SQLException, ClassNotFoundException{
        String sql;
        conexao = getConnection();
        comando = conexao.createStatement();
        sql = "DELETE FROM filmes WHERE titulo ='" + titulo + "'";
        comando.executeUpdate(sql);
        JOptionPane.showMessageDialog (null,"O filente foi excluido!");
    }

    //Método para listagem de todos os filmes.
    public ResultSet buscarTodosFilmes(String titulo) throws SQLException, ClassNotFoundException {
        conexao = getConnection();
        comando = conexao.createStatement();
        sql = "SELECT * FROM filmes WHERE titulo <> '" + titulo + "' ORDER BY titulo";
        rs = comando.executeQuery(sql);
        return rs;
    }

    //Método para estabelecer a conexão com o BD.
        public Connection getConnection() throws SQLException, ClassNotFoundException{
        Connection con;
        Class.forName("com.mysql.jdbc.Driver");
        //con = DriverManager.getConnection("jdbc:derby://localhost:1527/Locadora", "usuario", "123");
        //con = DriverManager.getConnection("jdbc:mysql://localhost:3306/locadora", "root", "");
        con = DriverManager.getConnection("jdbc:mysql://mysql.criacao.de/db_testethi", "db_testethi", "NSacer2010");
        return con;
    }

} // Fim da classe