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	Alle Termineheutegestern1 Woche15 Tage1 Monat2 Monate6 Monate1 Jahr2 Jahre3 Jahre
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]

Einstellungen für die Site-Sprache

Wenn Sie lieber mit der deutschen Version der Website fortfahren möchten, klicken Sie auf "Abbrechen". Wenn Sie abbrechen, wird diese Meldung während der Sitzung nicht mehr angezeigt.

You are on the German 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 Duits 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

Vous vous trouvez sur la version allemande du site, mais votre système indique que vous préférez utiliser la langue française.

Souhaitez-vous atteindre la page en français?
Cliquez ici pour continuer en français: Consulter la page en français

Deutsche Übersetzung

Sie haben gebeten, diese Seite auf Deutsch zu besuchen. Momentan ist nur die Oberfläche übersetzt, aber noch nicht der gesamte Inhalt.

Wenn Sie mir bei Übersetzungen helfen wollen, ist Ihr Beitrag willkommen. Alles, was Sie tun müssen, ist, sich auf der Website zu registrieren und mir eine Nachricht zu schicken, in der Sie gebeten werden, Sie der Gruppe der Übersetzer hinzuzufügen, die Ihnen die Möglichkeit gibt, die gewünschten Seiten zu übersetzen. Ein Link am Ende jeder übersetzten Seite zeigt an, dass Sie der Übersetzer sind und einen Link zu Ihrem Profil haben.

Vielen Dank im Voraus.

Dokument erstellt 13/09/2004, zuletzt geändert 26/10/2018
Quelle des gedruckten Dokuments:https://www.gaudry.be/de/ast-rf-455.html

Die Infobro ist eine persönliche Seite, deren Inhalt in meiner alleinigen Verantwortung liegt. Der Text ist unter der CreativeCommons-Lizenz (BY-NC-SA) verfügbar. Weitere Informationen auf die Nutzungsbedingungen und dem Autor.