Cours CNAM par J. Laforgue

Exemple03_Persistance2

Retour

Télécharger

Exemple de persistance des instances d'une classe (Personne) dans une base de données MySQL.
Cet exemple utilise les notations (plus de fichier de configuration Personne.hbm.xml)

README.txt
Exemple03.java

// Exemple de persistance des instances d'une classe (Personne) dans une base de données MySQL.
//   Cet exemple utilise les notations (plus de  fichier de configuration Personne.hbm.xml)
//
import org.hibernate.*;
import org.hibernate.cfg.*;
import java.sql.*;
import java.util.*;

import fr.cnam.test.*;
import fr.cnam.ihm.*;
import fr.cnam.tore.*;

public class Exemple03 implements FormulaireInt
{ 
  Configuration       config ;
  SessionFactory      sessionFactory;
  ArrayList<Personne> liste;
  Formulaire          form;
  Session             sessionPersist;

// Ce programe 
  //    permet de verifier l'utilisation en sauvegarde/chagerment
  //    et en mode persistance
  //
  public static void main(String[] args) throws Exception
  {
    // Creation de l'exemple
    new Exemple03();
  }

public Exemple03()
  {
    // ------------ Configuration de la persistance
    //
    config = new Configuration();
    // Configuration du mapping de la classe Personne
    //config.addClass(fr.cnam.test.Personne.class);
    // le fichier Personne.hbm.xml n'existe pas car on utilise les annotations
    //    voir le fichier Personne.java
    // Il faut par contre ajouter dans le fichier hibernate.cfg.xml la ligne :
    //     <mapping class="fr.cnam.test.Personne"/>
    //
    
    // Configuration de la session avec la base de données : 
    //    voir le contenu du fichier hibernate.cfg.xml
    sessionFactory = config.configure("hibernate.cfg.xml").buildSessionFactory();

// pour tester la persistance
    sessionPersist = sessionFactory.openSession();
    
    // ----------- Initialisation du metier
    liste=new ArrayList<Personne>();
    liste.add(new Personne("LAFONT","Pierre",32));
    liste.add(new Personne("DUPONT","Paul",46));
    liste.add(new Personne("ROCKY","Balboa",75));

// ----------- Initialisation de l'IHM
    form = new Formulaire("PERSITANCE 1",this,700,600,true);
    form.addText("NOM","Nom",true,"");
    form.addText("PRENOM","Prenom",true,"");
    form.addText("AGE","Age",true,"");
    form.addButton("AJOUTER","Ajouter");
    form.addText("ID","Id",true,"");
    form.addButton("MODIFIER","Modifier");
    form.addButton("LISTER","Lister");

form.addLabel("");
    form.addButton("SAUVER","Sauver");
    form.addButton("CHARGER","Charger");
    form.addLabel("");
    form.addButton("LECTURE_BASE","Lecture base");
    form.addLabel("");
    form.addButton("PERSIST","Persist");
    form.addButton("FLUSH","Flush");
    form.setPosition(250,0);
    form.addZoneText("RESULTAT",
                     "Resultat",
                     false,
                     "",
                     400,
                     600);
    form.afficher();
  }

public void submit(Formulaire form,String nomSubmit)
  {
    if (nomSubmit.equals("AJOUTER"))
      {
        String nom    = form.getValeurChamp("NOM");
        String prenom = form.getValeurChamp("PRENOM");
        int    age    = Integer.parseInt(form.getValeurChamp("AGE"));
        liste.add(new Personne(nom,prenom,age));
        lister();
      }

if (nomSubmit.equals("MODIFIER"))
      {
        String nom    = form.getValeurChamp("NOM");
        String prenom = form.getValeurChamp("PRENOM");
        int    age    = Integer.parseInt(form.getValeurChamp("AGE"));
        int    id     = Integer.parseInt(form.getValeurChamp("ID"));
        for(Personne p:liste)
          if(p.getId()==id){
            p.setNom(nom);
            p.setPrenom(prenom);
            p.setAge(age);
            break;
          }
        lister();
      }
    
    if (nomSubmit.equals("LISTER"))
      {
        lister();
      }

if (nomSubmit.equals("SAUVER"))
      {
        // Ouverture de la session
        Session session = sessionFactory.openSession();
                
        //
        Transaction tx = null; 
        try { 
          tx = session.beginTransaction(); 
          for(Personne p:liste)
            session.saveOrUpdate(p);
          session.flush();
          tx.commit();
        } catch (Exception e) {
          if (tx != null) {
            tx.rollback();
          }
          throw e;
        } finally { 
          session.close(); 
        } 
      } 
    
    if (nomSubmit.equals("PERSIST"))
      {
        // Ouverture de la session de persistance (a faire qu'1 fois)
        sessionPersist = sessionFactory.openSession();
                
        try { 
          for(Personne p:liste) sessionPersist.persist(p);
          sessionPersist.flush();
        } catch (Exception e) {
          throw e;
        } finally { 
        } 
      }

if (nomSubmit.equals("FLUSH"))
      {
        sessionPersist.flush();
      }
    
    if (nomSubmit.equals("CHARGER"))
      {
        Session session = sessionFactory.openSession();
                
        // 
        liste.clear();
        int id=1;
        while(true)
          {
            Personne p = (Personne)session.get(Personne.class,id);
            if(p==null) break;
            liste.add(p);
            id=id+1;
          }
        
        session.close();

lister();
      }

if (nomSubmit.equals("LECTURE_BASE"))
      {
        Session session = sessionFactory.openSession();
        String res="LECTURE EN BASE\n";
        int id=1;
        while(true)
          {
            Personne p = (Personne)session.get(Personne.class,id);
            if(p==null) break;
            res = res+p.toString()+"\n";
            id=id+1;
          }
        form.setValeurChamp("RESULTAT",res);
        session.close(); 
      }
  }

public String lister() {
    String res="LECTURE EN MEMOIRE\n";
    for(Personne p:liste)res=res+p.toString()+"\n";
    form.setValeurChamp("RESULTAT",res);
    return res;
  }

public void exit()
  {
    sessionFactory.close();
  }

}

Terminal.java

import java.io.*;
import java.util.*;

/** La classe Terminal permet de réaliser ses premiers programmes Java en permettant d'afficher dans la console d'exécution des données de type différents, et en permettant de saisir au clavier des données de type différents.<BR>
    Elle permet aussi de lire et écrire un fichier texte
    Cette classe contient que des méthodes statiques. */
public class Terminal{

// Le buffer standard  de lecture = le clavier
    private static BufferedReader in =
        new BufferedReader(new InputStreamReader(System.in));

/** Cette méthode lit un fichier texte et retourne le contenu du fichier sous la forme d'un  tableau de String dont chaque element est une ligne du fichier.
        @param nomFichier le nom du fichier qui doit être dans le répertoire courant.
        @return String[] le contenu du fichier ou null si erreur de lecture
*/
    public static String[] lireFichierTexte(String nomFichier)
    {
        try{
            File fichier = new File(nomFichier);
            if (! fichier.exists())
                {
                    System.out.println("Le fichier "+nomFichier+" n'existe pas ou n'est pas accessible");
                    return null;
                }
            FileInputStream fis = new FileInputStream(new File(nomFichier));
            
            byte[] buffer = new byte[(int)fichier.length()];
            fis.read(buffer);
            fis.close();
            String str = new String(buffer);

// On enleve le caractère '\r' code 13 qui est ajouté en Windows
            // Les fins de ligne dans un fichier texte créé sous Windows
            //  se termine par \r\n.
            // Il faut enlever le \r car il a des effets perturbant sur
            //  la méthode System.out.print et est pris comme un caractère de plus
            //  qu'il faut éliminer
            //  
            String texte = str.replaceAll(""+(char)(13),"");
            
            // Les lignes du fichier sont mises dans un tableau
            //
            String[] mots = texte.split("\n");

return(mots);
        }
        catch(Exception ex)
            {
              return null;
            }
    }

/** Cette méthode permet de créer un fichier texte à partir du contenu d'un StringBuffer.
        @param nomFichier Le nom du fichier qui est créé dans le répertoire courant
        @param strbuf Le StringBuffer contenant le texte à écrire. 
        @exception TerminalException (de type RuntimeException) si erreur d'écriture
    */
    public static void ecrireFichier(String nomFichier,
                                     StringBuffer strbuf)
    {
        try{
            File fichier = new File(nomFichier);
            FileOutputStream fos = new FileOutputStream(new File(nomFichier));
            
            byte[] buffer = strbuf.toString().getBytes();
            fos.write(buffer);
            fos.close();
        }
        catch(Exception ex)
            {
                exceptionHandler(ex);
            }
    }

/** Cette méthode lit une chaîne de caractère
        @return String la chaîne saisie dans la console d'exécution
       @exception TerminalException (de type RuntimeException) si erreur de lecture
    */
    public static String lireString() // Lire un String
    {
        String tmp="";
        char C='\0';
        try {
            tmp = in.readLine();
        }
        catch (IOException e)
            {
                exceptionHandler(e);
            }
        return tmp;
    }
    public static String lireString(String str) // Lire un String
    {
      System.out.print(str);
        String tmp="";
        char C='\0';
        try {
            tmp = in.readLine();
        }
        catch (IOException e)
            {
                exceptionHandler(e);
            }
        return tmp;
    }

/** Cette méthode lit un entier
        @return int L'entier saisi dans la console d'exécution
       @exception TerminalException (de type RuntimeException) si la saisie n'est pas un entier ou erreur de lecture
    */
    public static int lireInt()  // Lire un entier
    {
        int x=0;
        try {
            x=Integer.parseInt(lireString());
        }
        catch (NumberFormatException e) {
            exceptionHandler(e);
        }    
        return x ;
    }

/** Cette méthode lit un boolean (false ou true)
        @return boolean Le boolean saisi dans la console d'exécution
       @exception TerminalException (de type RuntimeException) si erreur de lecture. <BR>
       Tout autre valeur que TRUE, FALSE, true ou false, retourne la valeur false
    */
    public static boolean lireBoolean()  // Lire un entier
    {
        boolean b = true;
        try {
            b = Boolean.valueOf(lireString()).booleanValue();
        }
        catch (NumberFormatException e) {
            exceptionHandler(e);
        }    
        return b;
    }

/** Cette méthode lit un double
        @return double Le double saisi dans la console d'exécution
       @exception TerminalException (de type RuntimeException) si la valeur saisie n'est pas un double ou ereur de lecture.
    */
    public  static double lireDouble()  // Lire un double
    {
        double x=0.0;
        try {
            x=Double.valueOf(lireString()).doubleValue();
        }
        catch (NumberFormatException e) {
            exceptionHandler(e);
        }    
        return x ;
    }

/** Cette méthode lit un caractère.
       @exception TerminalException (de type RuntimeException) si erreur de lecture.<BR>
       Si on saisit plus d'1 caractère alors le caractère retourné est le premier.
    */
    public  static char lireChar()  // Lire un caractere
    {
        String tmp=lireString();
        if (tmp.length()==0)
            return '\n';
        else 
            {
                return tmp.charAt(0);
            }
    }

/** Cette méthode écrit une chaine et ne revient pas à la ligne.
        @param s la chaine à écrire
    */
    public static void ecrireString(String s){ // Afficher un String
        System.out.print(s);
    }

/** Cette méthode écrit une chaine et revient à la ligne.
        @param s la chaine à écrire
    */
    public static void ecrireStringln(String s) // Afficher un String
    {
        ecrireString(s);
        sautDeLigne();
    }

/** Cette méthode écrit un entier et ne revient pas à la ligne.
        @param i l'entier à écrire
    */
    public static void ecrireInt(int i)  // Afficher un entier
    {
        ecrireString(""+i);
    }

/** Cette méthode écrit un entier et revient à la ligne.
        @param i l'entier à écrire
    */
    public static void ecrireIntln(int i)  // Afficher un entier
    {
        ecrireString(""+i);
        sautDeLigne();
    }

/** Cette méthode écrit un booléan et ne revient pas à la ligne.
        @param b le booléen à écrire
    */
    public static void ecrireBoolean(boolean b){
        ecrireString(""+b);
    }

/** Cette méthode écrit un booléan et revient à la line.
        @param b le booléen à écrire
    */
    public static void ecrireBooleanln(boolean b){
        ecrireString(""+b);
        sautDeLigne();
    }

/** Cette méthode écrit un double et ne revient pas à la ligne.
        @param d le double à écrire
    */
    public  static void ecrireDouble(double d)  // Afficher un double
    {
        ecrireString(""+d);
    }

/** Cette méthode écrit un double et revient à la ligne.
        @param d le double à écrire
    */
    public  static void ecrireDoubleln(double d)  // Afficher un double
    {
        ecrireDouble(d);
        sautDeLigne();
    }

/** Cette méthode écrit un caractère et ne revient pas à la ligne.
        @param c le caractère à écrire
    */
    public  static void ecrireChar(char c)  // Afficher un caractere
    {
        ecrireString(""+c);
    }

/** Cette méthode écrit un caractère et revient à la ligne.
        @param c le caractère à écrire
    */
    public  static void ecrireCharln(char c)  // Afficher un caractere
    {
        ecrireChar(c);
        sautDeLigne();
    }

/** Cette méthode revient à la ligne.
    */
    public static void sautDeLigne(){
        try{
            System.out.println();
        }catch(Exception ex){
            exceptionHandler(ex);
        }
    }

/** Cette méthode retourne l'exception TerminalException
    */
    protected static void exceptionHandler(Exception ex){
        TerminalException err = new TerminalException(ex);
        throw err;
    }

/** Cette méthode écrit une exception avec la pile dans la console
        @param ex l'exception à écrire
    */
    public static void ecrireException(Throwable ex){
        ecrireString(ex.toString());
        ex.printStackTrace(System.out);
    }
}

/** Classe de définition de l'exception TerminalException qui peut être retournée dans l'usage des méthodes de la classe Terminal. */
class TerminalException extends RuntimeException{
    Exception ex;
    TerminalException(Exception e){
        ex = e;
    }
}

      compil.bat
      fr
         cnam
            ihm
            test
               MySQL5MyISAMDialect.java
               Personne.java

package fr.cnam.test;

import javax.persistence.*;

@Entity
  @Table(name="personnes")
  public class Personne
  {
    @Id
      @GeneratedValue
      private Integer id;

@Column
      private String nom;

@Column
      private String prenom;

@Column
      private Integer age;

public Personne()
    {
      id=0;
      nom="";
      prenom="";
      age=0;
    }

public Personne(String nom,String prenom,Integer age)
    {
      this.nom=nom;
      this.prenom=prenom;
      this.age=age;
    }
  
    public String toString() {
      return String.format("%2d %15s %15s %2d",id,nom,prenom,age);
    }

public Integer getId(){return id;}
    public String getNom(){return nom;}
    public String getPrenom(){return prenom;}
    public Integer getAge(){return age;}
    
    public void setId(Integer id){this.id=id;}
    public void setNom(String nom){this.nom=nom;}
    public void setPrenom(String prenom){this.prenom=prenom;}
    public void setAge(Integer age){this.age=age;}

}

tore
hibernate.cfg.xml

<?xml version='1.0' encoding='utf-8'?>
<!DOCTYPE hibernate-configuration PUBLIC
        "-//Hibernate/Hibernate Configuration DTD 3.0//EN"
        "http://www.hibernate.org/dtd/hibernate-configuration-3.0.dtd">

<hibernate-configuration>

<session-factory>

<property name="connection.driver_class">com.mysql.jdbc.Driver</property>
        <property name="connection.url">jdbc:mysql://localhost:3306/labo</property>
        <property name="connection.username">root</property>
        <property name="connection.password"></property>
        <property name="connection.useSSL">false</property>
        <property name="connection.serverTimezone">UTC</property>

<property name="connection.pool_size">2</property>

<property name="dialect">fr.cnam.test.MySQL5MyISAMDialect</property>

<property name="current_session_context_class">thread</property>

<property name="cache.provider_class">org.hibernate.cache.internal.NoCacheProvider</property>

<property name="show_sql">true</property>

<property name="hbm2ddl.auto">update</property>

<mapping class="fr.cnam.test.Personne"/>

</session-factory>

</hibernate-configuration>

run.bat

Cours d'Informatique par Jacques LAFORGUE

Retour

Télécharger

Cours d'Informatique
par Jacques LAFORGUE