PRODUTO DAO
/*
* To change this license header, choose License Headers in Project Properties.
* To change this template file, choose Tools | Templates
* and open the template in the editor.
*/
package br.com.dao;
import br.com.classes.Produtos;
import br.com.conexao.ConnectionFactory;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
/**
*
* @author Renan
*/
public class ProdutoDAO {
private Connection conexao;
public void abrirconexao(){
if(conexao==null){
conexao = ConnectionFactory.getConexao();
}
}
public void fecharConexao(){
try{
conexao.close();
}catch(SQLException ex){
}
}
public void cadastrarProduto (Produtos produto){
Connection conexao = ConnectionFactory.getConexao();
try{
String cadastroProduto = "Insert into produto (cod_barras, nome, qtdade, unidade_medida, id_marca, id_fornecedor, preco_compra, preco_venda,"
+ "estoque_min, data_inc, data_alt) values"
+ "(?,?,?,?,?,?,?,?,?,?,?)";
PreparedStatement pstmt = conexao.prepareStatement(cadastroProduto);
pstmt.setString(1, produto.getCod_barras());
pstmt.setString(2, produto.getNome());
pstmt.setFloat(3, produto.getQtdade());
pstmt.setString(4, produto.getUnidade_medida());
pstmt.setInt(5, produto.getId_marca());
pstmt.setInt(6, produto.getId_fornecedor());
pstmt.setFloat(7, produto.getPreco_compra());
pstmt.setFloat(8, produto.getPreco_venda());
pstmt.setInt(9, produto.getEstoque_min());
pstmt.setString(10, produto.getData_inc());
pstmt.setString(11, produto.getData_alt());
int resultado = pstmt.executeUpdate();
if(resultado!=1){
System.out.println("Houve um erro na inserção, tente novamente!");
}else{
System.out.println("Produto inserido com sucesso!");
}
pstmt.close();
}catch(SQLException e){
System.out.println("Ocorreu algum erro no banco de dados, tente novamente!");
while(e!=null){
System.out.println("Sql state: "+e.getSQLState());
System.out.println("Mensagem: "+e.getMessage());
System.out.println("Error code: "+e.getErrorCode());
e = e.getNextException();
}
}finally{
System.out.println("Encerrando conexão");
try{
conexao.close();
System.out.println("Conexão Terminada");
}catch(SQLException ex){
}
}
}
public void alterarProduto(Produtos produto){
Connection conexao = ConnectionFactory.getConexao();
try{
String alteraProduto = "Update produto set cod_barras = ?, nome = ?, qtdade = ?, unidade_medida = ?, "
+ "id_marca = ?, id_fornecedor = ?, preco_compra = ?, preco_venda = ?, estoque_min = ?, data_inc = ?, data_alt = ? "
+ " where id = ?";
PreparedStatement pstmt = conexao.prepareStatement(alteraProduto);
pstmt.setString(1, produto.getCod_barras());
pstmt.setString(2, produto.getNome());
pstmt.setFloat(3, produto.getQtdade());
pstmt.setString(4, produto.getUnidade_medida());
pstmt.setInt(5, produto.getId_marca());
pstmt.setInt(6, produto.getId_fornecedor());
pstmt.setFloat(7, produto.getPreco_compra());
pstmt.setFloat(8, produto.getPreco_venda());
pstmt.setInt(9, produto.getEstoque_min());
pstmt.setString(10, produto.getData_inc());
pstmt.setString(11, produto.getData_alt());
pstmt.setInt(12, produto.getId());
int alteracoes = pstmt.executeUpdate();
if(alteracoes!=1){
System.out.println("Houve um erro na alteração, tente novamente!");
}else{
System.out.println("Produto alterado com sucesso!");
}
pstmt.close();
}catch(SQLException e){
System.out.println("Ocorreu algum erro no banco de dados, tente novamente!");
while(e!=null){
System.out.println("Sql state: "+e.getSQLState());
System.out.println("Mensagem: "+e.getMessage());
System.out.println("Error code: "+e.getErrorCode());
e = e.getNextException();
}
}finally{
System.out.println("Encerrando conexão");
try{
conexao.close();
System.out.println("Conexão Terminada");
}catch(SQLException ex){
}
}
}
public void excluirProduto (int id){
Connection conexao = ConnectionFactory.getConexao();
try{
String excluiProduto = "Delete from produto where id= ?";
PreparedStatement pstmt = conexao.prepareStatement(excluiProduto);
pstmt.setInt(1, id);
int remocoes = pstmt.executeUpdate();
if(remocoes!=1){
System.out.println("Houve um erro na remoção, tente novamente!");
}else{
System.out.println("Produto removido com sucesso!");
}
pstmt.close();
}catch(SQLException e){
System.out.println("Ocorreu algum erro no banco de dados, tente novamente!");
while(e!=null){
System.out.println("Sql state: "+e.getSQLState());
System.out.println("Mensagem: "+e.getMessage());
System.out.println("Error code: "+e.getErrorCode());
e = e.getNextException();
}
}finally{
System.out.println("Encerrando conexão");
try{
conexao.close();
System.out.println("Conexão Terminada");
}catch(SQLException ex){
}
}
}
public List<Produtos> listarProdutoCodigo(String cod_barras){
Connection conexao = ConnectionFactory.getConexao();
List<Produtos> produtos = new ArrayList();
try{
String consultaProduto = "Select * from produto where cod_barras like ?";
PreparedStatement pstmt = conexao.prepareStatement(consultaProduto);
pstmt.setString(1, cod_barras);
ResultSet rs = pstmt.executeQuery();
Produtos produto;
while(rs.next()){
produto = new Produtos();
produto.setId(rs.getInt("id"));
produto.setCod_barras(rs.getString("cod_barras"));
produto.setNome(rs.getString("nome"));
produto.setQtdade(rs.getFloat("qtdade"));
produto.setUnidade_medida(rs.getString("unidade_medida"));
produto.setId_marca(rs.getInt("id_marca"));
produto.setId_fornecedor(rs.getInt("id_fornecedor"));
produto.setPreco_compra(rs.getFloat("preco_compra"));
produto.setPreco_venda(rs.getFloat("preco_venda"));
produto.setEstoque_min(rs.getInt("estoque_min"));
produto.setData_inc(rs.getString("data_inc"));
produto.setData_alt(rs.getString("data_alt"));
produtos.add(produto);
}
pstmt.close();
}catch(SQLException e){
System.out.println("Ocorreu algum erro no banco de dados, tente novamente!");
while(e!=null){
System.out.println("Sql state: "+e.getSQLState());
System.out.println("Mensagem: "+e.getMessage());
System.out.println("Error code: "+e.getErrorCode());
e = e.getNextException();
}
}finally{
System.out.println("Encerrando conexão");
try{
conexao.close();
System.out.println("Conexão Terminada");
}catch(SQLException ex){
}
}
return produtos;
}
public List<Produtos> listarProduto (String nome){
Connection conexao = ConnectionFactory.getConexao();
List<Produtos> produtos = new ArrayList();
try{
String consultaProduto = "Select * from produto where nome like ?";
PreparedStatement pstmt = conexao.prepareStatement(consultaProduto);
pstmt.setString(1, nome);
ResultSet rs = pstmt.executeQuery();
Produtos produto;
while(rs.next()){
produto = new Produtos();
produto.setId(rs.getInt("id"));
produto.setCod_barras(rs.getString("cod_barras"));
produto.setNome(rs.getString("nome"));
produto.setQtdade(rs.getFloat("qtdade"));
produto.setUnidade_medida(rs.getString("unidade_medida"));
produto.setId_marca(rs.getInt("id_marca"));
produto.setId_fornecedor(rs.getInt("id_fornecedor"));
produto.setPreco_compra(rs.getFloat("preco_compra"));
produto.setPreco_venda(rs.getFloat("preco_venda"));
produto.setEstoque_min(rs.getInt("estoque_min"));
produto.setData_inc(rs.getString("data_inc"));
produto.setData_alt(rs.getString("data_alt"));
produtos.add(produto);
}
pstmt.close();
}catch(SQLException e){
System.out.println("Ocorreu algum erro no banco de dados, tente novamente!");
while(e!=null){
System.out.println("Sql state: "+e.getSQLState());
System.out.println("Mensagem: "+e.getMessage());
System.out.println("Error code: "+e.getErrorCode());
e = e.getNextException();
}
}finally{
System.out.println("Encerrando conexão");
try{
conexao.close();
System.out.println("Conexão Terminada");
}catch(SQLException ex){
}
}
return produtos;
}
public int buscaIdProduto(String nome){
Connection conexao = ConnectionFactory.getConexao();
try{
String consultaProduto = "Select * from produto where nome like ?";
PreparedStatement pstmt = conexao.prepareStatement(consultaProduto);
pstmt.setString(1, nome);
ResultSet rs = pstmt.executeQuery();
Produtos produto;
rs.next();
int id = rs.getInt("id");
pstmt.close();
return id;
}catch(SQLException e){
System.out.println("Ocorreu algum erro no banco de dados, tente novamente!");
while(e!=null){
System.out.println("Sql state: "+e.getSQLState());
System.out.println("Mensagem: "+e.getMessage());
System.out.println("Error code: "+e.getErrorCode());
e = e.getNextException();
}
}finally{
System.out.println("Encerrando conexão");
try{
conexao.close();
System.out.println("Conexão Terminada");
}catch(SQLException ex){
}
}
return 0;
}
public int buscaIdProdutoCod(String codigo_barras){
Connection conexao = ConnectionFactory.getConexao();
try{
String consultaProduto = "Select * from produto where cod_barras = ?";
PreparedStatement pstmt = conexao.prepareStatement(consultaProduto);
pstmt.setString(1, codigo_barras);
ResultSet rs = pstmt.executeQuery();
Produtos produto;
rs.next();
int id = rs.getInt("id");
pstmt.close();
return id;
}catch(SQLException e){
System.out.println("Ocorreu algum erro no banco de dados, tente novamente!");
while(e!=null){
System.out.println("Sql state: "+e.getSQLState());
System.out.println("Mensagem: "+e.getMessage());
System.out.println("Error code: "+e.getErrorCode());
e = e.getNextException();
}
}finally{
System.out.println("Encerrando conexão");
try{
conexao.close();
System.out.println("Conexão Terminada");
}catch(SQLException ex){
}
}
return 0;
}
public String[] buscaProdutoPorId (int id_produto){
Connection conexao = ConnectionFactory.getConexao();
try{
String consultaProduto = "Select * from produto where id = ?";
PreparedStatement pstmt = conexao.prepareStatement(consultaProduto);
pstmt.setInt(1, id_produto);
ResultSet rs = pstmt.executeQuery();
rs.next();
String nome = rs.getString("nome");
Float preco_venda = rs.getFloat("preco_venda");
String valores[] = new String[2];
valores[0] = nome;
valores[1] = String.valueOf(preco_venda);
pstmt.close();
return valores;
}catch(SQLException e){
System.out.println("Ocorreu algum erro no banco de dados, tente novamente!");
while(e!=null){
System.out.println("Sql state: "+e.getSQLState());
System.out.println("Mensagem: "+e.getMessage());
System.out.println("Error code: "+e.getErrorCode());
e = e.getNextException();
}
}finally{
System.out.println("Encerrando conexão");
try{
conexao.close();
System.out.println("Conexão Terminada");
}catch(SQLException ex){
}
}
return null;
}
}
USUARIO DAO
package br.com.dao;
import br.com.classes.Usuario;
import br.com.conexao.ConnectionFactory;
import java.sql.Connection;
import java.sql.Date;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
public class UsuarioDAO {
private Connection conexao;
public void abrirconexao(){
if(conexao==null){
conexao = ConnectionFactory.getConexao();
}
}
public void fecharConexao(){
try{
conexao.close();
}catch(SQLException ex){
}
}
public void cadastrarUsuario (Usuario usuario){
Connection conexao = ConnectionFactory.getConexao();
try{
String cadastroUsuario = "Insert into usuario (nome, rua, numero, bairro, cep, telefone_res, telefone_cel,"
+ "cpf, rg, data_nasc, usuario, senha, email, data_inc, status, cidade, estado, data_alt) values"
+ "(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)";
PreparedStatement pstmt = conexao.prepareStatement(cadastroUsuario);
pstmt.setString(1, usuario.getNome());
pstmt.setString(2, usuario.getRua());
pstmt.setInt(3, usuario.getNumero());
pstmt.setString(4, usuario.getBairro());
pstmt.setString(5, usuario.getCep());
pstmt.setString(6, usuario.getTelefone_res());
pstmt.setString(7, usuario.getTelefone_cel());
pstmt.setString(8, usuario.getCpf());
pstmt.setString(9, usuario.getRg());
pstmt.setString(10, usuario.getData_nasc());
pstmt.setString(11, usuario.getUsuario());
pstmt.setString(12, usuario.getSenha());
pstmt.setString(13, usuario.getEmail());
pstmt.setString(14, usuario.getData_inc());
pstmt.setInt(15, usuario.getStatus());
pstmt.setString(16, usuario.getCidade());
pstmt.setString(17, usuario.getEstado());
pstmt.setString(18, usuario.getData_alt());
int resultado = pstmt.executeUpdate();
if(resultado!=1){
System.out.println("Houve um erro na inserção, tente novamente!");
}else{
System.out.println("Usuário inserido com sucesso!");
}
pstmt.close();
}catch(SQLException e){
System.out.println("Ocorreu algum erro no banco de dados, tente novamente!");
while(e!=null){
System.out.println("Sql state: "+e.getSQLState());
System.out.println("Mensagem: "+e.getMessage());
System.out.println("Error code: "+e.getErrorCode());
e = e.getNextException();
}
}finally{
System.out.println("Encerrando conexão");
try{
conexao.close();
System.out.println("Conexão Terminada");
}catch(SQLException ex){
}
}
}
public void alterarUsuario(Usuario usuario){
Connection conexao = ConnectionFactory.getConexao();
try{
String alteraUsuario = "Update usuario set nome = ?, rua = ?, numero = ?, bairro = ?, "
+ "cep = ?, telefone_res = ?, telefone_cel = ?, cpf = ?, rg = ?, data_nasc = ?, "
+ "usuario = ?, senha = ?, email = ?, data_inc = ?, status = ?, cidade = ?, estado = ?, data_alt = ? where id = ?";
PreparedStatement pstmt = conexao.prepareStatement(alteraUsuario);
pstmt.setString(1, usuario.getNome());
pstmt.setString(2, usuario.getRua());
pstmt.setInt(3, usuario.getNumero());
pstmt.setString(4, usuario.getBairro());
pstmt.setString(5, usuario.getCep());
pstmt.setString(6, usuario.getTelefone_res());
pstmt.setString(7, usuario.getTelefone_cel());
pstmt.setString(8, usuario.getCpf());
pstmt.setString(9, usuario.getRg());
pstmt.setString(10, usuario.getData_nasc());
pstmt.setString(11, usuario.getUsuario());
pstmt.setString(12, usuario.getSenha());
pstmt.setString(13, usuario.getEmail());
pstmt.setString(14, usuario.getData_inc());
pstmt.setInt(15, usuario.getStatus());
pstmt.setString(16, usuario.getCidade());
pstmt.setString(17, usuario.getEstado());
pstmt.setString(18, usuario.getData_alt());
pstmt.setInt(19, usuario.getId());
int alteracoes = pstmt.executeUpdate();
if(alteracoes!=1){
System.out.println("Houve um erro na alteração, tente novamente!");
}else{
System.out.println("Usuário alterado com sucesso!");
}
pstmt.close();
}catch(SQLException e){
System.out.println("Ocorreu algum erro no banco de dados, tente novamente!");
while(e!=null){
System.out.println("Sql state: "+e.getSQLState());
System.out.println("Mensagem: "+e.getMessage());
System.out.println("Error code: "+e.getErrorCode());
e = e.getNextException();
}
}finally{
System.out.println("Encerrando conexão");
try{
conexao.close();
System.out.println("Conexão Terminada");
}catch(SQLException ex){
}
}
}
public void excluirUsuario (int id){
Connection conexao = ConnectionFactory.getConexao();
try{
String excluiUsuario = "Delete from usuario where id= ?";
PreparedStatement pstmt = conexao.prepareStatement(excluiUsuario);
pstmt.setInt(1, id);
int remocoes = pstmt.executeUpdate();
if(remocoes!=1){
System.out.println("Houve um erro na remoção, tente novamente!");
}else{
System.out.println("Usuário removido com sucesso!");
}
pstmt.close();
}catch(SQLException e){
System.out.println("Ocorreu algum erro no banco de dados, tente novamente!");
while(e!=null){
System.out.println("Sql state: "+e.getSQLState());
System.out.println("Mensagem: "+e.getMessage());
System.out.println("Error code: "+e.getErrorCode());
e = e.getNextException();
}
}finally{
System.out.println("Encerrando conexão");
try{
conexao.close();
System.out.println("Conexão Terminada");
}catch(SQLException ex){
}
}
}
public List<Usuario> listarUsuario(String nome){
Connection conexao = ConnectionFactory.getConexao();
List<Usuario> usuarios = new ArrayList();
try{
String consultaUsuario = "Select * from usuario where nome like ?";
PreparedStatement pstmt = conexao.prepareStatement(consultaUsuario);
pstmt.setString(1, nome);
ResultSet rs = pstmt.executeQuery();
Usuario usuario;
while(rs.next()){
usuario = new Usuario();
usuario.setId(rs.getInt("id"));
usuario.setNome(rs.getString("nome"));
usuario.setRua(rs.getString("rua"));
usuario.setNumero(rs.getInt("numero"));
usuario.setBairro(rs.getString("bairro"));
usuario.setCep(rs.getString("cep"));
usuario.setTelefone_res(rs.getString("telefone_res"));
usuario.setTelefone_cel(rs.getString("telefone_cel"));
usuario.setCpf(rs.getString("cpf"));
usuario.setRg(rs.getString("rg"));
usuario.setData_nasc(rs.getString("data_nasc"));
usuario.setUsuario(rs.getString("usuario"));
usuario.setSenha(rs.getString("senha"));
usuario.setEmail(rs.getString("email"));
usuario.setData_inc(rs.getString("data_inc"));
usuario.setStatus(rs.getInt("status"));
usuario.setCidade(rs.getString("cidade"));
usuario.setEstado(rs.getString("estado"));
usuario.setData_alt(rs.getString("data_alt"));
usuarios.add(usuario);
}
pstmt.close();
}catch(SQLException e){
System.out.println("Ocorreu algum erro no banco de dados, tente novamente!");
while(e!=null){
System.out.println("Sql state: "+e.getSQLState());
System.out.println("Mensagem: "+e.getMessage());
System.out.println("Error code: "+e.getErrorCode());
e = e.getNextException();
}
}finally{
System.out.println("Encerrando conexão");
try{
conexao.close();
System.out.println("Conexão Terminada");
}catch(SQLException ex){
}
}
return usuarios;
}
public int buscaIdUsuario(String nome){
Connection conexao = ConnectionFactory.getConexao();
try{
String consultaUsuario = "Select * from usuario where usuario like ?";
PreparedStatement pstmt = conexao.prepareStatement(consultaUsuario);
pstmt.setString(1, nome);
ResultSet rs = pstmt.executeQuery();
Usuario usuario;
rs.next();
int id = rs.getInt("id");
pstmt.close();
return id;
}catch(SQLException e){
System.out.println("Ocorreu algum erro no banco de dados, tente novamente!");
while(e!=null){
System.out.println("Sql state: "+e.getSQLState());
System.out.println("Mensagem: "+e.getMessage());
System.out.println("Error code: "+e.getErrorCode());
e = e.getNextException();
}
}finally{
System.out.println("Encerrando conexão");
try{
conexao.close();
System.out.println("Conexão Terminada");
}catch(SQLException ex){
}
}
return 0;
}
public String buscaUsuarioPorId(int id_usuario){
Connection conexao = ConnectionFactory.getConexao();
try{
String consultaCliente = "Select * from usuario where id = ?";
PreparedStatement pstmt = conexao.prepareStatement(consultaCliente);
pstmt.setInt(1, id_usuario);
ResultSet rs = pstmt.executeQuery();
Usuario usuario;
rs.next();
String nome_usuario = rs.getString("usuario");
pstmt.close();
return nome_usuario;
}catch(SQLException e){
System.out.println("Ocorreu algum erro no banco de dados, tente novamente!");
while(e!=null){
System.out.println("Sql state: "+e.getSQLState());
System.out.println("Mensagem: "+e.getMessage());
System.out.println("Error code: "+e.getErrorCode());
e = e.getNextException();
}
}finally{
System.out.println("Encerrando conexão");
try{
conexao.close();
System.out.println("Conexão Terminada");
}catch(SQLException ex){
}
}
return "Não informado";
}
}