Téléchargez le fichier audiodescription : Partie 5, Chapitre 4
Vous trouverez sous la vidéo les codes source du cours. Pensez à répondre au quiz et réaliser votre activité, accessibles depuis la sidebar à droite.
Codes source
Notre classe gérant les exceptions pour les Beans, BeanException.java :
package com.octest.beans;
public class BeanException extends Exception {
public BeanException(String message) {
super(message);
}
}Une classe très similaire pour les exceptions du DAO, DaoException.java :
package com.octest.dao;
public class DaoException extends Exception {
public DaoException(String message) {
super(message);
}
}Notre Bean Utilisateur.java renvoie une BeanException si on essaie de faire rentrer un nom trop long de plus de 10 caractères (limite arbitraire que j'ai fixée ici) :
package com.octest.beans;
public class Utilisateur {
private String nom;
private String prenom;
public String getNom() {
return nom;
}
public void setNom(String nom) throws BeanException {
if (nom.length() > 10) {
throw new BeanException("Le nom est trop grand ! (10 caractères maximum)");
}
else {
this.nom = nom;
}
}
public String getPrenom() {
return prenom;
}
public void setPrenom(String prenom) {
this.prenom = prenom;
}
}La DaoFactory.java change peu. On y ajoute seulement unsetAutoCommit(false) après la connexion pour que l'on puisse gérer les transactions nous-mêmes.
package com.octest.dao;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class DaoFactory {
private String url;
private String username;
private String password;
DaoFactory(String url, String username, String password) {
this.url = url;
this.username = username;
this.password = password;
}
public static DaoFactory getInstance() {
try {
Class.forName("com.mysql.jdbc.Driver");
} catch (ClassNotFoundException e) {
}
DaoFactory instance = new DaoFactory(
"jdbc:mysql://localhost:3306/javaee", "root", "");
return instance;
}
public Connection getConnection() throws SQLException {
Connection connexion = DriverManager.getConnection(url, username, password);
connexion.setAutoCommit(false);
return connexion;
}
// Récupération du Dao
public UtilisateurDao getUtilisateurDao() {
return new UtilisateurDaoImpl(this);
}
}L'implémentation du DAO DaoUtilisateurImpl.java renvoie des DAO Exception en cas d'erreur (par exemple erreur de connexion à la base de données). Le détail de l'erreur SQL est masqué à l'utilisateur du DAO, qui n'a pas à savoir dans le détail ce qui s'est passé. C'est pour cela qu'on ne renvoie pas une SqlException.
package com.octest.dao;
import java.sql.*;
import java.util.ArrayList;
import java.util.List;
import com.octest.beans.BeanException;
import com.octest.beans.Utilisateur;
public class UtilisateurDaoImpl implements UtilisateurDao {
private DaoFactory daoFactory;
UtilisateurDaoImpl(DaoFactory daoFactory) {
this.daoFactory = daoFactory;
}
@Override
public void ajouter(Utilisateur utilisateur) throws DaoException {
Connection connexion = null;
PreparedStatement preparedStatement = null;
try {
connexion = daoFactory.getConnection();
preparedStatement = connexion.prepareStatement("INSERT INTO noms(nom, prenom) VALUES(?, ?);");
preparedStatement.setString(1, utilisateur.getNom());
preparedStatement.setString(2, utilisateur.getPrenom());
preparedStatement.executeUpdate();
connexion.commit();
} catch (SQLException e) {
try {
if (connexion != null) {
connexion.rollback();
}
} catch (SQLException e2) {
}
throw new DaoException("Impossible de communiquer avec la base de données");
}
finally {
try {
if (connexion != null) {
connexion.close();
}
} catch (SQLException e) {
throw new DaoException("Impossible de communiquer avec la base de données");
}
}
}
@Override
public List<Utilisateur> lister() throws DaoException {
List<Utilisateur> utilisateurs = new ArrayList<Utilisateur>();
Connection connexion = null;
Statement statement = null;
ResultSet resultat = null;
try {
connexion = daoFactory.getConnection();
statement = connexion.createStatement();
resultat = statement.executeQuery("SELECT nom, prenom FROM noms;");
while (resultat.next()) {
String nom = resultat.getString("nom");
String prenom = resultat.getString("prenom");
Utilisateur utilisateur = new Utilisateur();
utilisateur.setNom(nom);
utilisateur.setPrenom(prenom);
utilisateurs.add(utilisateur);
}
} catch (SQLException e) {
throw new DaoException("Impossible de communiquer avec la base de données");
} catch (BeanException e) {
throw new DaoException("Les données de la base sont invalides");
}
finally {
try {
if (connexion != null) {
connexion.close();
}
} catch (SQLException e) {
throw new DaoException("Impossible de communiquer avec la base de données");
}
}
return utilisateurs;
}
}Cette implémentation gère aussi les transactions, avec des commit et des rollback pour enregistrer ou annuler un ensemble de modifications.
La servlet Test.java récupère les erreurs éventuelles du Dao ou du Bean. S'il y a une erreur, on crée une variable d'erreur contenant le message qu'on transmet à la vue.
package com.octest.servlets;
import java.io.IOException;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import com.octest.beans.Utilisateur;
import com.octest.dao.*;
/**
* Servlet implementation class Test
*/
@WebServlet("/Test")
public class Test extends HttpServlet {
private static final long serialVersionUID = 1L;
private UtilisateurDao utilisateurDao;
public void init() throws ServletException {
DaoFactory daoFactory = DaoFactory.getInstance();
this.utilisateurDao = daoFactory.getUtilisateurDao();
}
protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
try {
request.setAttribute("utilisateurs", utilisateurDao.lister());
}
catch (DaoException e) {
request.setAttribute("erreur", e.getMessage());
}
this.getServletContext().getRequestDispatcher("/WEB-INF/bonjour.jsp").forward(request, response);
}
public void doPost( HttpServletRequest request, HttpServletResponse response ) throws ServletException, IOException {
try {
Utilisateur utilisateur = new Utilisateur();
utilisateur.setNom(request.getParameter("nom"));
utilisateur.setPrenom(request.getParameter("prenom"));
utilisateurDao.ajouter(utilisateur);
request.setAttribute("utilisateurs", utilisateurDao.lister());
}
catch (Exception e) {
request.setAttribute("erreur", e.getMessage());
}
this.getServletContext().getRequestDispatcher("/WEB-INF/bonjour.jsp").forward(request, response);
}
}Cette variable d'erreur est affichée au début de la JSP bonjour.jsp si elle est présente :
<%@ page pageEncoding="UTF-8" %>
<%@ taglib uri="http://java.sun.com/jsp/jstl/core" prefix="c" %>
<!DOCTYPE html>
<html>
<head>
<meta charset="utf-8" />
<title>Test</title>
</head>
<body>
<c:if test="${ !empty erreur }"><p style="color:red;"><c:out value="${ erreur }" /></p></c:if>
<form method="post" action="bonjour">
<p>
<label for="nom">Nom : </label>
<input type="text" name="nom" id="nom" />
</p>
<p>
<label for="prenom">Prénom : </label>
<input type="text" name="prenom" id="prenom" />
</p>
<input type="submit" />
</form>
<ul>
<c:forEach var="utilisateur" items="${ utilisateurs }">
<li><c:out value="${ utilisateur.prenom }" /> <c:out value="${ utilisateur.nom }" /></li>
</c:forEach>
</ul>
</body>
</html>Voici ce que ça donne au final sur notre vue :
Toutes les informations sur les erreurs sont donc transmises par remontée d'exceptions jusqu'à la vue !
