Modifier le lazy loading avec Hibernate

Généralités

Procédure

RemoteLazyLoadCollectionCallback

• Dans org.hibernate.collection , ajouter le package callback
• Dans org.hibernate.collection.callback, ajouter la classe suivante :
  
  Code Java  (11 lignes)

  package org.hibernate.collection.callback;
   
  import org.hibernate.collection.PersistentCollection;
  import org.hibernate.engine.SessionImplementor;
   
  public interface RemoteLazyLoadCollectionCallback {
   
  	PersistentCollection lazyLoad(SessionImplementor session,
  			PersistentCollection collection);
   
  }

  Retourner au début du code
  
  

AbstractPersistentCollection

• Dans org.hibernate.collection, ouvrir la classe AbstractPersistentCollection.
• 
  Ajouter un membre statique :
  
  Code Java  (9 lignes)

  private static RemoteLazyLoadCollectionCallback remoteLazyLoadCollectionCallback;
   
  	/**
  	 * @param remoteLazyLoadCollectionCallback the remoteLazyLoadCollectionCallback to set
  	 */
  	public static synchronized void setRemoteLazyLoadCollectionCallback(
  			RemoteLazyLoadCollectionCallback remoteLazyLoadCollectionCallback) {
  		AbstractPersistentCollection.remoteLazyLoadCollectionCallback = remoteLazyLoadCollectionCallback;
  	}

• Ajouter un getter :
  
  Code Java  (3 lignes)

  private boolean isRemote() {
  		return remoteLazyLoadCollectionCallback != null;
  	}

• Dans la méthode protected boolean readSize(), ajouter au début
  Code Java  (3 lignes)

  if (isRemote()) {
  			initialize(true);
  		}

  
  Faire de même pour toutes les méthodes readxxx.
• Modifier la méthode protected final void initialize(boolean writing) comme ceci :
  
  Code Java  (15 lignes)

  protected final void initialize(boolean writing) {
  		if (!initialized) {
  			if (isRemote()) {
  				remoteLazyLoadCollectionCallback.lazyLoad(session, this);
  				setInitialized();
  			} else {
  				if (initializing) {
  					throw new LazyInitializationException(
  							"illegal access to loading collection");
  				}
  				throwLazyInitializationExceptionIfNotConnected();
  				session.initializeCollection(this, writing);
  			}
  		}
  	}

  Retourner au début du code

RemoteLazyLoadProxyCallback

• Dans org.hibernate.proxy , ajouter le package callback
• Dans org.hibernate.proxy.callback, ajouter la classe suivante :
  Code Java  (12 lignes)

  package org.hibernate.proxy.callback;
   
  import java.io.Serializable;
   
  import org.hibernate.engine.SessionImplementor;
   
  public interface RemoteLazyLoadProxyCallback {
   
  	Object lazyLoad(SessionImplementor session, String entityName,
  			Serializable id);
   
  }

  Retourner au début du code

AbstractLazyInitializer

• Dans org.hibernate.proxy, ouvrir la classe AbstractLazyInitializer
• Ajouter un membre statique :
  Code Java  (14 lignes)

  private static RemoteLazyLoadProxyCallback remoteLazyLoadProxyCallback;
   
  	/**
  	 * @param remoteLazyLoadProxyCallback the remoteLazyLoadProxyCallback to set
  	 */
  	public static synchronized void setRemoteLazyLoadProxyCallback(
  			RemoteLazyLoadProxyCallback remoteLazyLoadProxyCallback) {
  		AbstractLazyInitializer.remoteLazyLoadProxyCallback = remoteLazyLoadProxyCallback;
  	}
  Ajouter un getter : 
   
  	private boolean isRemote() {
  		return (remoteLazyLoadProxyCallback != null);
  	}

  Retourner au début du code
• Ajouter un getter :
  Code Java  (3 lignes)

  private boolean isRemote() {
  		return (remoteLazyLoadProxyCallback != null);
  	}

• Modifier la méthode public final void initialize() comme ceci :
  Code Java  (26 lignes)

  public final void initialize() throws HibernateException {
  		if (!initialized) {
  			if (isRemote()) {
  				setImplementation(remoteLazyLoadProxyCallback.lazyLoad(session,
  						entityName, id));
  			} else {
  				if ( session==null ) {
  					throw new LazyInitializationException("could not initialize proxy - no Session");
  				}
  				else if ( !session.isOpen() ) {
  					throw new LazyInitializationException("could not initialize proxy - the owning Session was closed");
  				}
  				else if ( !session.isConnected() ) {
  					throw new LazyInitializationException("could not initialize proxy - the owning Session is disconnected");
  				}
  				else {
  					target = session.immediateLoad(entityName, id);
  					initialized = true;
  					checkTargetState();
  				}
  			}
  		}
  		else {
  			checkTargetState();
  		}
  	}

  Retourner au début du code

Exemple d’appel dans le client

AbstractLazyInitializer
				.setRemoteLazyLoadProxyCallback(new MeatClientLazyLoadProxyCallback());
		AbstractPersistentCollection
				.setRemoteLazyLoadCollectionCallback(new MeatClientLazyLoadCollectionCallback());

Exemples d'implémentations des callbacks

public class MeatClientLazyLoadProxyCallback implements
        RemoteLazyLoadProxyCallback {
 
    public Object lazyLoad(SessionImplementor session, String entityName,
            Serializable id) {
 
//        Thread.dumpStack();
        Object result = ServiceLocator.getService(LazyInitFacade.class).get(entityName,
                        id);
        if(result == null){
            LogFactory.getLog(getClass()).error(entityName+" - "+ id +" is NULL ‹‹‹‹‹‹‹‹‹‹‹‹‹‹‹‹‹‹‹‹‹‹‹‹");
        }
        return result;
    }
 
}

public class MeatClientLazyLoadCollectionCallback implements
        RemoteLazyLoadCollectionCallback {
 
    @SuppressWarnings("unchecked")
    public PersistentCollection lazyLoad(SessionImplementor session,
            PersistentCollection collection) {
        PersistentCollection result = ServiceLocator.getService(
                LazyInitFacade.class).initializeCollection(collection, true);
        Field field;
        if (collection instanceof PersistentSet) {
            field = ReflectionUtils.findField(PersistentSet.class, "set",
                    Set.class);
        } else if (collection instanceof PersistentBag) {
            field = ReflectionUtils.findField(PersistentBag.class, "bag",
                    List.class);
        } else if (collection instanceof PersistentList) {
            field = ReflectionUtils.findField(PersistentList.class, "list",
                    List.class);
        } else if (collection instanceof PersistentMap) {
            field = ReflectionUtils.findField(PersistentMap.class, "map",
                    Map.class);
        } else {
            throw new RuntimeException(new NotSupportedException(collection
                    .getClass()
                    + " is not yet supported"));
        }
        Field snapshot = ReflectionUtils.findField(collection.getClass(),
                "storedSnapshot");
        if (snapshot != null) {
            ReflectionUtils.makeAccessible(snapshot);
            Object o = ReflectionUtils.getField(snapshot, collection);
            if (o == null) {
                ReflectionUtils.setField(snapshot, collection, new HashMap());
            }
        }
        ReflectionUtils.makeAccessible(field);
        ReflectionUtils.setField(field, collection, result);
        return result;
    }
 
}

Cannot modify header information - headers already sent by ([Ubuntu]Supprimer le son au démarrage

Sélection, tri et recherche d'articles

FILTRER :	Toutes les catégories(Office) - Access(Office) - Excel(Office) - Outlook(Office) - PowerPoint(Office) - WordBase de RegistreDéveloppementDiversDOSdotNetGraphismeGravureInternetInternet ExplorerJavaJeuxLinuxMultimédiaNavigateursPeer to peerSécuritéSuite OfficeWindows (Généralités)Windows 2000Windows 2003 SrvWindows NTWindows VistaWindows Xp	Toutes les datesaujourd'huihier1 semaine15 jours1 mois2 mois6 mois1 an2 ans3 ans
TRIER :	1er critère : Par défautcatégoriedatepopularité	2e critère : Par défautcatégoriedatepopularité
CHERCHER :		Dans les titres	Dans le contenu

[Afficher les liens en fonction des critères du formulaire ci-dessus]

Paramètres de langue du site

Si vous préférez continuer sur le site en français, cliquez sur "Annuler". Si vous annulez, ce message n'apparaîtra plus durant la session.

You are on the French version of the site, but your system indicates that you prefer to use the English language.
The entire site is not translated yet, but the menus and buttons on the interface are largely translated.

Would you like to reach the page in English?
Click here to continue in English: Consult the English version of this page

U bevindt zich op de Franse versie van de site, maar uw systeem geeft aan dat u liever de Nederlandse taal gebruikt.
De hele site is nog niet vertaald, maar de menu's en knoppen op de interface zijn grotendeels vertaald.

Wilt u de pagina in het Nederlands bereiken?
Klik hier om door te gaan in het Nederlands: Raadpleeg de Nederlandse versie van deze pagina

Sie befinden sich in der französischen Version der Website, Ihr System gibt jedoch an, dass Sie die deutsche Sprache bevorzugen.
Die gesamte Site ist noch nicht übersetzt, aber die Menüs und Schaltflächen auf der Benutzeroberfläche sind weitgehend übersetzt.

Möchten Sie die Seite auf Deutsch erreichen?
Klicken Sie hier, um fortzufahren: Konsultieren Sie die deutsche Version dieser Seite

Version en cache

20/12/2024 23:14:22 Cette version de la page est en cache (à la date du 20/12/2024 23:14:22) afin d'accélérer le traitement. Vous pouvez activer le mode utilisateur dans le menu en haut pour afficher la dernère version de la page.

Document créé le 13/09/2004, dernière modification le 26/10/2018
Source du document imprimé : https://www.gaudry.be/ast-rf-455.html

L'infobrol est un site personnel dont le contenu n'engage que moi. Le texte est mis à disposition sous licence CreativeCommons(BY-NC-SA). Plus d'info sur les conditions d'utilisation et sur l'auteur.