Build the dao with the DAO classes and implementation
public interface ClienteDAO {
int insertar (ClienteVO cliente);
int eliminar (ClienteVO cliente);
int actualizar (ClienteVO cliente);
Optional<ClienteVO> findById(int idCliente);
Optional<ClienteVO> findByName(String nombre);
Optional<List<ClienteVO>> findAll();
}
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;
import java.util.Optional;
import com.dawes.dao.ClienteDAO;
import com.dawes.modelo.ClienteVO;
public class ClienteDAOImpl implements ClienteDAO {
private Connection con;
private PreparedStatement ps;
private ResultSet rs;
public ClienteDAOImpl(Connection con) {
this.con = con;
}
@Override
public int insertar(ClienteVO cliente) {
try {
ps = con.prepareStatement("INSERT into clientes (nif, nombre, fechaNacimiento, totalVentas) values (?, ?, ?, ?)");
ps.setString(1, cliente.getNif());
ps.setString(2, cliente.getNombre());
ps.setDate(3, Date.valueOf(cliente.getFechaNacimiento()));
ps.setDouble(4, cliente.getTotalVentas());
return ps.executeUpdate();
} catch (SQLException e) {
if(e.getErrorCode()==1062) {
System.out.println("Error al insertar, NIF duplicado ");
}else
System.out.println("Error al insertar en Clientes " + e.getMessage());
return 0;
}
}
// el resto de m�todos est�n sin acabar porque cambi� la tarea
@Override
public int eliminar(ClienteVO cliente) {
try {
ps = con.prepareStatement("delete from clientes where nif =?");
ps.setString(1, cliente.getNif());
return ps.executeUpdate();
} catch (SQLException e) {
System.out.println("Error al eliminar en Clientes " + e.getMessage());
return 2;
}
}
@Override
public int actualizar(ClienteVO cliente) {
try {
ps = con.prepareStatement("UPDATE clientes set nif=?, nombre=?, fechaNacimiento=?, total_ventas=? where idcliente=?");
ps.setString(1, cliente.getNif());
ps.setString(2, cliente.getNombre());
ps.setDate(3, Date.valueOf(cliente.getFechaNacimiento()));
ps.setDouble(4, cliente.getTotalVentas()); // se tienen que actualizar con el importe de cada factura nueva a este cliente
return ps.executeUpdate();
} catch (SQLException e) {
System.out.println("Error al actualizar en Clientes " + e.getMessage());
return 0;
}
}
@Override
public Optional<ClienteVO> findById(int idCliente) {
try {
ps = con.prepareStatement("select * from clientes where idCliente=?");
ps.setInt(1, idCliente);
rs = ps.executeQuery();
if(rs.next() ) {
return Optional.of(new ClienteVO(rs.getInt(1), rs.getString(2), rs.getString(3), rs.getDate(4).toLocalDate(), rs.getDouble(5)));
}else
return Optional.of(new ClienteVO());
} catch (SQLException e) {
System.out.println("Error al consultar Cliente por ID " + e.getMessage());
return Optional.empty();
}
}
@Override
public Optional<ClienteVO> findByName(String nombre) {
try {
ps = con.prepareStatement("select * from clientes where nombre=?");
ps.setString(1, nombre);
rs = ps.executeQuery();
if(rs.next() ) {
return Optional.of(new ClienteVO(rs.getInt(1), rs.getString(2), rs.getString(3), rs.getDate(4).toLocalDate(), rs.getDouble(5)));
}else
return Optional.of(new ClienteVO());
} catch (SQLException e) {
System.out.println("Error al consultar Cliente por nombre" + e.getMessage());
return Optional.empty();
}
}
@Override
public Optional<List<ClienteVO>> findAll() {
List<ClienteVO> clientes = new ArrayList();
try {
ps = con.prepareStatement("select * from clientes");
rs = ps.executeQuery();
while(rs.next() ) {
clientes.add(new ClienteVO(rs.getInt(1), rs.getString(2), rs.getString(3), rs.getDate(4).toLocalDate(), rs.getDouble(5)));
}
return Optional.of(clientes);
} catch (SQLException e) {
System.out.println("Error al consultar todos Clientes " + e.getMessage());
return Optional.empty();
}
}
}
Build the service and implementation
public interface ServicioCliente {
int insertar(ClienteVO cliente);
int eliminar(ClienteVO cliente);
int actualizar(ClienteVO cliente);
Optional<ClienteVO> findById(int idCliente);
Optional<ClienteVO> findByName(String nombre);
Optional<List<ClienteVO>> findAll();
}
public class ServicioClienteImpl implements ServicioCliente {
private MysqlDAOFactory factoria;
private ClienteDAO c;
public ServicioClienteImpl() {
factoria = MysqlDAOFactory.conectar();
c = factoria.getClienteDAOImpl();
}
@Override
public int insertar(ClienteVO cliente) {
return c.insertar(cliente);
}
@Override
public int eliminar(ClienteVO cliente) {
return c.eliminar(cliente);
}
@Override
public int actualizar(ClienteVO cliente) {
return c.actualizar(cliente);
}
@Override
public Optional<ClienteVO> findById(int idCliente) {
return c.findById(idCliente);
}
@Override
public Optional<ClienteVO> findByName(String nombre) {
return c.findByName(nombre);
}
@Override
public Optional<List<ClienteVO>> findAll() {
return c.findAll();
}
}
