daily pastebin goal
19%
SHARE
TWEET

boi

a guest Nov 6th, 2018 111 Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
  1. package dao;
  2.  
  3.  
  4. import java.sql.Connection;
  5. import java.sql.PreparedStatement;
  6. import java.sql.ResultSet;
  7. import java.sql.SQLException;
  8. import java.sql.Statement;
  9. import java.util.ArrayList;
  10. import java.util.List;
  11. import java.util.logging.Level;
  12. import java.util.logging.Logger;
  13.  
  14. import excepciones.BusinessException;
  15. import jdbc.ConexionJdbc;
  16. import pojos.Usuario;
  17.  
  18. public class DaoUsuario extends DaoGenerico<Usuario, Integer> implements InterfaceDaoGenerico<Usuario, Integer> {
  19.     Connection con = ConexionJdbc.getConnection();
  20.     Usuario usuario = new Usuario();
  21.     @Override
  22.     public void grabar(Usuario objeto) throws BusinessException {
  23.         Statement stmt = null;
  24.         ResultSet rs = null;
  25.         PreparedStatement pstmt = null;
  26.         try {
  27.             stmt = con.createStatement();
  28.             String sql = "SELECT * from usuario where idusuario ="+objeto.getIdusuario();
  29.             rs = stmt.executeQuery(sql);
  30.             if (rs==null) {
  31.                 sql = "INSERT INTO usuarios VALUES(null,?,?,?,?,?,?,?,?,?,?,?,?,?,?)";
  32.                 pstmt = con.prepareStatement(sql);
  33.                 pstmt.setString(1, objeto.getUsername());
  34.                 pstmt.setString(2, objeto.getPassword());
  35.                 pstmt.setInt(3, objeto.getTipo());
  36.                 pstmt.setInt(4, objeto.getRol());
  37.                 pstmt.setString(5, objeto.getGrupo());
  38.                 pstmt.setInt(6, objeto.getDepartamento());
  39.                 pstmt.setString(7, objeto.getNombre());
  40.                 pstmt.setString(8, objeto.getApellido1());
  41.                 pstmt.setString(9, objeto.getApellido2());
  42.                 pstmt.setString(10, objeto.getDomicilio());
  43.                 pstmt.setString(11, objeto.getPoblacion());
  44.                 pstmt.setString(12, objeto.getCodpostal());
  45.                 pstmt.setString(13, objeto.getEmail());
  46.                 pstmt.setString(14, objeto.getTelefono());
  47.                 con.commit();
  48.                 System.out.println("Usuario añadido correctamente");
  49.             }
  50.         }catch(SQLException e) {
  51.             Logger.getLogger(DaoUsuario.class.getName()).log(Level.SEVERE, "Error de sql", e);
  52.             System.out.println("Error en DaoUsuario metodo grabar");
  53.             throw new BusinessException("Error en DaoUsuario metodo grabar");
  54.         }finally {
  55.             ConexionJdbc.cerrar(stmt);
  56.             ConexionJdbc.cerrar(pstmt);
  57.         }
  58.     }
  59.  
  60.     @Override
  61.     public void actualizar(Usuario objeto) throws BusinessException {
  62.         Statement stmt = null;
  63.         ResultSet rs = null;
  64.         PreparedStatement pstmt = null;
  65.         try {
  66.             stmt = con.createStatement();
  67.             String sql = "SELECT * from usuario where idusuario ="+objeto.getIdusuario();
  68.             rs = stmt.executeQuery(sql);
  69.             if (rs!=null) {
  70.                 sql = "update usuarios set username = ?, password = ?, tipo = ?, rol = ?, grupo = ?, departamento = ?, nombre = ?, apellido1 = ?, apellido2 = ?, domicilio = ?, poblacion = ?, codpostal = ?, email = ?, telefono = ? where idusuario = ?";
  71.                 pstmt = con.prepareStatement(sql);
  72.                 pstmt.setString(1, objeto.getUsername());
  73.                 pstmt.setString(2, objeto.getPassword());
  74.                 pstmt.setInt(3, objeto.getTipo());
  75.                 pstmt.setInt(4, objeto.getRol());
  76.                 pstmt.setString(5, objeto.getGrupo());
  77.                 pstmt.setInt(6, objeto.getDepartamento());
  78.                 pstmt.setString(7, objeto.getNombre());
  79.                 pstmt.setString(8, objeto.getApellido1());
  80.                 pstmt.setString(9, objeto.getApellido2());
  81.                 pstmt.setString(10, objeto.getDomicilio());
  82.                 pstmt.setString(11, objeto.getPoblacion());
  83.                 pstmt.setString(12, objeto.getCodpostal());
  84.                 pstmt.setString(13, objeto.getEmail());
  85.                 pstmt.setString(14, objeto.getTelefono());
  86.                 pstmt.setInt(15, objeto.getIdusuario());
  87.                 con.commit();
  88.                 System.out.println("Usuario actualizado correctamente");
  89.             }
  90.            
  91.         }catch(SQLException e) {
  92.             Logger.getLogger(DaoUsuario.class.getName()).log(Level.SEVERE, "Error de sql", e);
  93.             System.out.println("Error en DaoUsuario metodo Actualizar");
  94.             throw new BusinessException("Error en DaoUsuario metodo Actualizar");
  95.         }finally {
  96.             ConexionJdbc.cerrar(stmt);
  97.             ConexionJdbc.cerrar(pstmt);
  98.         }
  99.     }
  100.  
  101.     @Override
  102.     public void grabarOActualizar(Usuario objeto) throws BusinessException {
  103.         Statement stmt = null;
  104.         ResultSet rs = null;
  105.         PreparedStatement pstmt = null;
  106.         try {
  107.             stmt = con.createStatement();
  108.             String sql = "SELECT * from usuario where idusuario ="+objeto.getIdusuario();
  109.             rs = stmt.executeQuery(sql);
  110.             if (rs==null) {
  111.                 sql = "INSERT INTO usuarios VALUES(null,?,?,?,?,?,?,?,?,?,?,?,?,?,?)";
  112.                 pstmt = con.prepareStatement(sql);
  113.                 pstmt.setString(1, objeto.getUsername());
  114.                 pstmt.setString(2, objeto.getPassword());
  115.                 pstmt.setInt(3, objeto.getTipo());
  116.                 pstmt.setInt(4, objeto.getRol());
  117.                 pstmt.setString(5, objeto.getGrupo());
  118.                 pstmt.setInt(6, objeto.getDepartamento());
  119.                 pstmt.setString(7, objeto.getNombre());
  120.                 pstmt.setString(8, objeto.getApellido1());
  121.                 pstmt.setString(9, objeto.getApellido2());
  122.                 pstmt.setString(10, objeto.getDomicilio());
  123.                 pstmt.setString(11, objeto.getPoblacion());
  124.                 pstmt.setString(12, objeto.getCodpostal());
  125.                 pstmt.setString(13, objeto.getEmail());
  126.                 pstmt.setString(14, objeto.getTelefono());
  127.                 con.commit();
  128.                 System.out.println("Usuario añadido correctamente");
  129.             }else {
  130.                 sql = "update usuarios set username = ?, password = ?, tipo = ?, rol = ?, grupo = ?, departamento = ?, nombre = ?, apellido1 = ?, apellido2 = ?, domicilio = ?, poblacion = ?, codpostal = ?, email = ?, telefono = ? where idusuario = ?";
  131.                 pstmt = con.prepareStatement(sql);
  132.                 pstmt.setString(1, objeto.getUsername());
  133.                 pstmt.setString(2, objeto.getPassword());
  134.                 pstmt.setInt(3, objeto.getTipo());
  135.                 pstmt.setInt(4, objeto.getRol());
  136.                 pstmt.setString(5, objeto.getGrupo());
  137.                 pstmt.setInt(6, objeto.getDepartamento());
  138.                 pstmt.setString(7, objeto.getNombre());
  139.                 pstmt.setString(8, objeto.getApellido1());
  140.                 pstmt.setString(9, objeto.getApellido2());
  141.                 pstmt.setString(10, objeto.getDomicilio());
  142.                 pstmt.setString(11, objeto.getPoblacion());
  143.                 pstmt.setString(12, objeto.getCodpostal());
  144.                 pstmt.setString(13, objeto.getEmail());
  145.                 pstmt.setString(14, objeto.getTelefono());
  146.                 pstmt.setInt(15, objeto.getIdusuario());
  147.                 con.commit();
  148.                 System.out.println("Usuario actualizado correctamente");
  149.             }
  150.            
  151.         }catch(SQLException e) {
  152.             Logger.getLogger(DaoUsuario.class.getName()).log(Level.SEVERE, "Error de sql", e);
  153.             System.out.println("Error en DaoUsuario metodo grabarOActualizar");
  154.             throw new BusinessException("Error en DaoUsuario metodo grabarOActualizar");
  155.         }finally {
  156.             ConexionJdbc.cerrar(stmt);
  157.             ConexionJdbc.cerrar(pstmt);
  158.         }
  159.     }
  160.  
  161.     @Override
  162.     public void borrar(Usuario objeto) throws BusinessException {
  163.         Statement stmt = null;
  164.         try {
  165.             stmt = con.createStatement();
  166.             int idUsuario = objeto.getIdusuario();
  167.             String sql = "DELETE FROM usuario where idusuario = "+idUsuario;
  168.             if(stmt.executeUpdate(sql)==1) {
  169.                 System.out.println("El usuario ha sido eliminado");
  170.             }else {
  171.                 System.out.println("El usuario no existe");
  172.             }
  173.                
  174.         }catch(SQLException e) {
  175.             Logger.getLogger(DaoUsuario.class.getName()).log(Level.SEVERE, "Error de sql", e);
  176.             System.out.println("Error en DaoUsuario metodo borrarPorUsuario");
  177.             throw new BusinessException("Error en DaoUsuario metodo borrarPorUsuario");
  178.        
  179.         }finally {
  180.             ConexionJdbc.cerrar(stmt);
  181.         }
  182.     }
  183.  
  184.     @Override
  185.     public void borrar(Integer id) throws BusinessException {
  186.         Statement stmt = null;
  187.         try {
  188.             stmt = con.createStatement();
  189.             String sql = "DELETE FROM usuario where idusuario ="+id;
  190.             if(stmt.executeUpdate(sql)==1) {
  191.                 System.out.println("El usuario ha sido eliminado");
  192.             }else {
  193.                 System.out.println("El usuario no existe");
  194.             }
  195.         }catch(SQLException e) {
  196.             Logger.getLogger(DaoUsuario.class.getName()).log(Level.SEVERE, "Error de sql", e);
  197.             System.out.println("Error en DaoUsuario metodo borrarPorId");
  198.             throw new BusinessException("Error en DaoUsuario metodo borrarPorId");
  199.        
  200.         }finally {
  201.             ConexionJdbc.cerrar(stmt);
  202.         }
  203.     }
  204.  
  205.     @Override
  206.     public Usuario buscarPorId(Integer id) throws BusinessException {
  207.         Statement stmt = null;
  208.         ResultSet rs = null;
  209.         try {
  210.             stmt = con.createStatement();
  211.             String sql = "SELECT * FROM usuario where idusuario ="+id;
  212.             rs = stmt.executeQuery(sql);
  213.                 if(rs!=null) {
  214.                    
  215.                     while(rs.next()) {
  216.                         int idOut = rs.getInt(1);
  217.                         String userOut = rs.getString(2);
  218.                         String passOut = rs.getString(3);
  219.                         int tipoOut = rs.getInt(4);
  220.                         int rolOut= rs.getInt(5);
  221.                         String grupoOut = rs.getString(6);
  222.                         int dep = rs.getInt(7);
  223.                         String nameOut = rs.getString(8);
  224.                         String ape1Out = rs.getString(9);
  225.                         String ape2Out = rs.getString(10);
  226.                         String domicilio = rs.getString(11);
  227.                         String poblacion = rs.getString(12);
  228.                         String codpostal = rs.getString(13);
  229.                         String email = rs.getString(14);
  230.                         String telefono = rs.getString(15);
  231.                        
  232.                         usuario.setApellido1(ape1Out);
  233.                         usuario.setApellido2(ape2Out);
  234.                         usuario.setCodpostal(codpostal);
  235.                         usuario.setDepartamento(dep);
  236.                         usuario.setDomicilio(domicilio);
  237.                         usuario.setEmail(email);
  238.                         usuario.setGrupo(grupoOut);
  239.                         usuario.setIdusuario(idOut);
  240.                         usuario.setNombre(nameOut);
  241.                         usuario.setPassword(passOut);
  242.                         usuario.setPoblacion(poblacion);
  243.                         usuario.setRol(rolOut);
  244.                         usuario.setTelefono(telefono);
  245.                         usuario.setTipo(tipoOut);
  246.                         usuario.setUsername(userOut);
  247.                        
  248.                     }
  249.                 }
  250.             }catch (SQLException e) {
  251.                 Logger.getLogger(DaoUsuario.class.getName()).log(Level.SEVERE, "Error de sql", e);
  252.                 System.out.println("Error en DaoUsuario metodo buscarPorId");
  253.                 throw new BusinessException("Error en DaoUsuario metodo buscarPorId");
  254.            
  255.             } finally {
  256.                 ConexionJdbc.cerrar(rs);
  257.             }
  258.        
  259.         return usuario;
  260.  
  261.     }
  262.  
  263.     @Override
  264.     public List<Usuario> buscarTodos() throws BusinessException {
  265.         List<Usuario> list=new ArrayList<Usuario>();
  266.         Statement stmt = null;
  267.         ResultSet rs = null;
  268.         try {
  269.             stmt = con.createStatement();
  270.  
  271.             String sql = "SELECT * FROM usuario";
  272.             rs = stmt.executeQuery(sql);
  273.                 if(rs!=null) {
  274.                    
  275.                     while(rs.next()) {
  276.                         int idOut = rs.getInt(1);
  277.                         String userOut = rs.getString(2);
  278.                         String passOut = rs.getString(3);
  279.                         int tipoOut = rs.getInt(4);
  280.                         int rolOut= rs.getInt(5);
  281.                         String grupoOut = rs.getString(6);
  282.                         int dep = rs.getInt(7);
  283.                         String nameOut = rs.getString(8);
  284.                         String ape1Out = rs.getString(9);
  285.                         String ape2Out = rs.getString(10);
  286.                         String domicilio = rs.getString(11);
  287.                         String poblacion = rs.getString(12);
  288.                         String codpostal = rs.getString(13);
  289.                         String email = rs.getString(14);
  290.                         String telefono = rs.getString(15);
  291.                        
  292.                         usuario.setApellido1(ape1Out);
  293.                         usuario.setApellido2(ape2Out);
  294.                         usuario.setCodpostal(codpostal);
  295.                         usuario.setDepartamento(dep);
  296.                         usuario.setDomicilio(domicilio);
  297.                         usuario.setEmail(email);
  298.                         usuario.setGrupo(grupoOut);
  299.                         usuario.setIdusuario(idOut);
  300.                         usuario.setNombre(nameOut);
  301.                         usuario.setPassword(passOut);
  302.                         usuario.setPoblacion(poblacion);
  303.                         usuario.setRol(rolOut);
  304.                         usuario.setTelefono(telefono);
  305.                         usuario.setTipo(tipoOut);
  306.                         usuario.setUsername(userOut);
  307.                        
  308.                         list.add(usuario);
  309.                     }
  310.                 }
  311.             }catch (SQLException e) {
  312.                 Logger.getLogger(DaoUsuario.class.getName()).log(Level.SEVERE, "Error de sql", e);
  313.                 System.out.println("Error en DaoUsuario metodo buscarTodos");
  314.                 throw new BusinessException("Error en DaoUsuario metodo buscarTodos");
  315.             } finally {
  316.                 ConexionJdbc.cerrar(rs);
  317.             }
  318.  
  319.        
  320.         return list;
  321.     }
  322.    
  323.  
  324. }
RAW Paste Data
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy. OK, I Understand
 
Top