import java.util.List;
import personas.dto.PersonaDTO;
/**
* Esta interfaz contiene los métodos abstractos con las operaciones básicas
* sobre la tabla de Persona CRUD (Create, Read, Update y Delete) Se debe crear
* una clase concreta para implementar el código asociado a cada método
*
* @author Ubaldo
*
*/
public interface PersonaDao {
public int insert(PersonaDTO persona)
throws SQLException;
public int update(PersonaDTO persona)
throws SQLException;
public int delete(PersonaDTO persona)
throws SQLException;
public List<PersonaDTO> select() throws SQLException;
}
_________________________________________________________________________________
import java.sql.*;
import java.util.ArrayList;
import java.util.List;
import personas.dto.PersonaDTO;
/**
* Esta clase implementa la clase PersonaDao es una implementacion con la
* tecnologia JDBC podría haber otro tipo de implementaciones con tecnologias
* como Hibernate, iBatis, SpringJDBC, etc.
*
* @author Ubaldo
*
*/
public class PersonaDaoJDBC implements PersonaDao {
private Connection userConn;
private final String SQL_INSERT = "INSERT INTO persona(nombre, apellido) VALUES(?,?)";
private final String SQL_UPDATE = "UPDATE persona SET nombre=?, apellido=? WHERE id_persona=?";
private final String SQL_DELETE = "DELETE FROM persona WHERE id_persona = ?";
private final String SQL_SELECT = "SELECT id_persona, nombre, apellido FROM persona";
public PersonaDaoJDBC() {
}
public PersonaDaoJDBC(Connection conn) {
this.userConn = conn;
}
/**
* El metodo insert recibe como argumento un objeto DTO el cual viene de
* otra capa, y se extraen sus valores para crear un nuevo registro
*
* @param persona
* @throws java.sql.SQLException
*/
@Override
public int insert(PersonaDTO persona) throws SQLException {
Connection conn = null;
PreparedStatement stmt = null;
int rows = 0;
try {
conn = (this.userConn != null) ? this.userConn
: Conexion.getConnection();
stmt = conn.prepareStatement(SQL_INSERT);
int index = 1;
stmt.setString(index++, persona.getNombre());
stmt.setString(index, persona.getApellido());
System.out.println("Ejecutando query:" + SQL_INSERT);
rows = stmt.executeUpdate();
System.out.println("Registros afectados:" + rows);
} finally {
Conexion.close(stmt);
if (this.userConn == null) {
Conexion.close(conn);
}
}
return rows;
}
@Override
public int update(PersonaDTO persona)
throws SQLException {
Connection conn = null;
PreparedStatement stmt = null;
int rows = 0;
try {
conn = (this.userConn != null) ? this.userConn
: Conexion.getConnection();
System.out.println("Ejecutando query:" + SQL_UPDATE);
stmt = conn.prepareStatement(SQL_UPDATE);
int index = 1;
stmt.setString(index++, persona.getNombre());
stmt.setString(index++, persona.getApellido());
stmt.setInt(index, persona.getId_persona());
rows = stmt.executeUpdate();
System.out.println("Registros actualizados:" + rows);
} finally {
Conexion.close(stmt);
if (this.userConn == null) {
Conexion.close(conn);
}
}
return rows;
}
@Override
public int delete(PersonaDTO persona) throws SQLException {
Connection conn = null;
PreparedStatement stmt = null;
int rows = 0;
try {
conn = (this.userConn != null) ? this.userConn
: Conexion.getConnection();
System.out.println("Ejecutando query:" + SQL_DELETE);
stmt = conn.prepareStatement(SQL_DELETE);
stmt.setInt(1, persona.getId_persona());
rows = stmt.executeUpdate();
System.out.println("Registros eliminados:" + rows);
} finally {
Conexion.close(stmt);
if (this.userConn == null) {
Conexion.close(conn);
}
}
return rows;
}
@Override
public List<PersonaDTO> select() throws SQLException {
Connection conn = null;
PreparedStatement stmt = null;
ResultSet rs = null;
PersonaDTO personaDTO = null;
List<PersonaDTO> personas = new ArrayList<PersonaDTO>();
try {
conn = (this.userConn != null) ? this.userConn : Conexion.getConnection();
stmt = conn.prepareStatement(SQL_SELECT);
rs = stmt.executeQuery();
while (rs.next()) {
int idPersonaTemp = rs.getInt(1);
String nombreTemp = rs.getString(2);
String apellidoTemp = rs.getString(3);
personaDTO = new PersonaDTO();
personaDTO.setId_persona(idPersonaTemp);
personaDTO.setNombre(nombreTemp);
personaDTO.setApellido(apellidoTemp);
personas.add(personaDTO);
}
} finally {
Conexion.close(rs);
Conexion.close(stmt);
if (this.userConn == null) {
Conexion.close(conn);
}
}
return personas;
}
}
_________________________________________________________________________________
package personas.dto;
public class PersonaDTO {
private int id_persona;
private String nombre;
private String apellido;
public PersonaDTO() {
}
public PersonaDTO(int id_persona) {
this.id_persona = id_persona;
}
public int getId_persona() {
return id_persona;
}
public void setId_persona(int id_persona) {
this.id_persona = id_persona;
}
public String getNombre() {
return nombre;
}
public void setNombre(String nombre) {
this.nombre = nombre;
}
public String getApellido() {
return apellido;
}
public void setApellido(String apellido) {
this.apellido = apellido;
}
@Override
public String toString() {
return "Persona{" + "id_persona=" + id_persona + ", nombre=" + nombre + ", apellido=" + apellido + '}';
}
}
No hay comentarios:
Publicar un comentario