FileDocCategorySizeDatePackage
EntityClassloaderTestBase.javaAPI DocJBoss 4.2.113915Fri Jul 13 20:53:06 BST 2007org.jboss.ejb3.test.clusteredentity.unit

EntityClassloaderTestBase

public class EntityClassloaderTestBase extends org.jboss.test.JBossClusteredTestCase
Base class for tests involving clustered entities with a scoped classloader.
author
Brian Stansberry
version
$Id: EntityUnitTestCase.java 57207 2006-09-26 12:06:13Z dimitris@jboss.org $

Fields Summary
public static final String
EAR_NAME
public static final String
JAR_NAME
public static final String
PERSISTENCE_UNIT_NAME
protected Logger
log
protected static final long
SLEEP_TIME
static boolean
deployed0
static boolean
deployed1
protected static final org.jboss.ejb3.test.clusteredentity.classloader.AccountHolderPK
SMITH
protected static final org.jboss.ejb3.test.clusteredentity.classloader.AccountHolderPK
JONES
protected static final org.jboss.ejb3.test.clusteredentity.classloader.AccountHolderPK
BARNEY
protected org.jboss.ejb3.test.clusteredentity.classloader.EntityQueryTest
sfsb0
protected org.jboss.ejb3.test.clusteredentity.classloader.EntityQueryTest
sfsb1
Constructors Summary
public EntityClassloaderTestBase(String name)

   
     
   
      super(name);
Methods Summary
public static java.lang.StringcreateCacheRegionPrefix(java.lang.String earName, java.lang.String jarName, java.lang.String unitName)

      StringBuilder sb = new StringBuilder();
      if (earName != null)
      {
         sb.append(earName);
         if (!earName.endsWith(".ear")) 
            sb.append("_ear");
         sb.append(",");
      }
      if (jarName != null)
      {
         sb.append(jarName);
         if (!jarName.endsWith(".jar"))
            sb.append("_jar");
         sb.append(",");
      }
      sb.append(unitName);
      String raw = sb.toString();
      // Replace any '.' otherwise the JBoss Cache integration may replace
      // it with a '/' and it will become a level in the FQN
      String escaped = raw.replace('.", '_");
      return escaped;
protected java.lang.StringcreateRegionName(java.lang.String noPrefix)

      String prefix = createCacheRegionPrefix(getEarName(), getJarName(), getPersistenceUnitName());
      return "/" + prefix + "/" + noPrefix.replace('.", '/");
protected java.lang.StringgetEarName()

      return EAR_NAME;
protected org.jboss.ejb3.test.clusteredentity.classloader.EntityQueryTestgetEntityQueryTest(java.lang.String nodeJNDIAddress)

      Properties prop1 = new Properties();
      prop1.put("java.naming.factory.initial", "org.jnp.interfaces.NamingContextFactory");
      prop1.put("java.naming.factory.url.pkgs", "org.jboss.naming:org.jnp.interfaces");
      prop1.put("java.naming.provider.url", "jnp://" + nodeJNDIAddress + ":1099");
   
      log.info("===== Naming properties for " + nodeJNDIAddress + ": ");
      log.info(prop1);
      log.info("Create InitialContext for " + nodeJNDIAddress);
      InitialContext ctx1 = new InitialContext(prop1);
   
      log.info("Lookup sfsb from " + nodeJNDIAddress);
      EntityQueryTest eqt = (EntityQueryTest)ctx1.lookup(getEarName() + "/EntityQueryTestBean/remote");
      eqt.getCache(isOptimistic());
      
      return eqt;
protected java.lang.StringgetJarName()

      return JAR_NAME;
protected java.lang.StringgetPersistenceUnitName()

      return PERSISTENCE_UNIT_NAME;
protected booleanisOptimistic()

      return false;
protected voidmodifyEntities(org.jboss.ejb3.test.clusteredentity.classloader.EntityQueryTest bean)

      bean.updateAccountBranch(1001, "63088");
      bean.updateAccountBalance(2001, 15);
      
      log.info("Entities modified");
protected voidqueryTest(boolean setupEntities, boolean useNamedQuery, boolean useNamedRegion, boolean expectInactivatedRegion)
Executes a series of entity operations and queries, checking that expected modifications and reads of the query cache occur.

param
setupEntities true if entities don't exist and need to be created; false if they should exist and need to be returned to their initial state
param
useNamedQuery true if named queries are to be used; false if the EJBQL should be passed to the Query
param
useNamedRegion true if the query should be cached in "AccountRegion"; false if it should be cached in the default region
param
expectInactivatedRegion true if the test should assume the query cache region is inactive on each server until accessed on that server; false if it should be assumed the region is activated and able to receive replication events.

      if (setupEntities)
         standardEntitySetup();
      else
         restoreEntities(sfsb0);
      
      resetRegionUsageState();
      
      // Initial ops on node 0
      
      String regionName = createRegionName(useNamedRegion ? "AccountRegion" : StandardQueryCache.class.getName());
      
      // Query on post code count
      assertEquals("63088 has correct # of accounts", 6, sfsb0.getCountForBranch("63088", useNamedQuery, useNamedRegion));
      
      assertTrue("Query cache used " + regionName, 
                 sfsb0.getSawRegionModification(regionName));
      // Clear the access state
      sfsb0.getSawRegionAccess(regionName);
      
      log.info("First query on node0 done");
      
      // Do it again from node 1
      // Sleep a bit to allow async repl to happen
      sleep(SLEEP_TIME);
      
      // If region isn't activated yet, should not have been modified      
      if (expectInactivatedRegion)
      {
         assertFalse("Query cache remotely modified " + regionName, 
                      sfsb1.getSawRegionModification(regionName));
         // Clear the access state
         sfsb1.getSawRegionAccess(regionName);
      }
      else //if (useNamedRegion)
      {
         assertTrue("Query cache remotely modified " + regionName, 
                    sfsb1.getSawRegionModification(regionName));
         // Clear the access state
         sfsb1.getSawRegionAccess(regionName);         
      }
      
      assertEquals("63088 has correct # of accounts", 6, sfsb1.getCountForBranch("63088", useNamedQuery, useNamedRegion));
      
      if (expectInactivatedRegion)
      {
         // Query should have activated the region and then been inserted
         assertTrue("Query cache modified " + regionName, 
                    sfsb1.getSawRegionModification(regionName));
         // Clear the access state
         sfsb1.getSawRegionAccess(regionName);
      }
      
      log.info("First query on node 1 done");
      
      // We now have the query cache region activated on both nodes.
      
      // Sleep a bit to allow async repl to happen
      sleep(SLEEP_TIME);
      
      // Do some more queries on node 0
      
      assertEquals("Correct branch for Smith", "94536", sfsb0.getBranch(SMITH, useNamedQuery, useNamedRegion));
      
      assertEquals("Correct high balances for Jones", 40, sfsb0.getTotalBalance(JONES, useNamedQuery, useNamedRegion));
      
      assertTrue("Query cache used " + regionName, 
                 sfsb0.getSawRegionModification(regionName));
      // Clear the access state
      sfsb0.getSawRegionAccess(regionName);
      
      log.info("Second set of queries on node0 done");
      
      // Sleep a bit to allow async repl to happen
      sleep(SLEEP_TIME);
      
      // Do it again from node 1
      
      // First check if the previous queries replicated (if the region is replicable)
      
      assertTrue("Query cache remotely modified " + regionName, 
                 sfsb1.getSawRegionModification(regionName));
      // Clear the access state
      sfsb1.getSawRegionAccess(regionName);
      
      assertEquals("Correct branch for Smith", "94536", sfsb1.getBranch(SMITH, useNamedQuery, useNamedRegion));
      
      assertEquals("Correct high balances for Jones", 40, sfsb1.getTotalBalance(JONES, useNamedQuery, useNamedRegion));
      
      // Should be no change; query was already there
      assertFalse("Query cache modified " + regionName, 
                  sfsb1.getSawRegionModification(regionName));
      assertTrue("Query cache accessed " + regionName, 
                 sfsb1.getSawRegionAccess(regionName));
      
      log.info("Second set of queries on node1 done");
      
      // Modify underlying data on node 1
      modifyEntities(sfsb1);
      
      // Confirm query results are correct on node 0
      
      assertEquals("63088 has correct # of accounts", 7, sfsb0.getCountForBranch("63088", useNamedQuery, useNamedRegion));
      
      assertEquals("Correct branch for Smith", "63088", sfsb0.getBranch(SMITH, useNamedQuery, useNamedRegion));
      
      assertEquals("Correct high balances for Jones", 50, sfsb0.getTotalBalance(JONES, useNamedQuery, useNamedRegion));
      
      log.info("Third set of queries on node0 done");
protected voidresetRegionUsageState()

  
      String stdName = createRegionName(StandardQueryCache.class.getName());
      String acctName = createRegionName("AccountRegion");
      
      sfsb0.getSawRegionModification(stdName);
      sfsb0.getSawRegionModification(acctName);
      
      sfsb0.getSawRegionAccess(stdName);
      sfsb0.getSawRegionAccess(acctName);
      
      sfsb1.getSawRegionModification(stdName);
      sfsb1.getSawRegionModification(acctName);
      
      sfsb1.getSawRegionAccess(stdName);
      sfsb1.getSawRegionAccess(acctName);
      
      log.info("Region usage state cleared");
protected voidrestoreEntities(org.jboss.ejb3.test.clusteredentity.classloader.EntityQueryTest bean)

      // Undo the mods done in queryTest
      bean.updateAccountBranch(1001, "94536");
      bean.updateAccountBalance(2001, 5);
      
      log.info("Standard entities restored to initial state");
protected voidsetUp()

      super.setUp();
      
      sfsb0 = getEntityQueryTest(System.getProperty("jbosstest.cluster.node0"));
      sfsb1 = getEntityQueryTest(System.getProperty("jbosstest.cluster.node1"));  
      sfsb0.cleanup();
      sfsb1.cleanup();
protected voidsleep(long millis)

      try
      {
         Thread.sleep(millis);
      }
      catch (InterruptedException e)
      {
         log.warn("Interrupted while sleeping", e);
      }
protected voidstandardEntitySetup()

//      sfsb0.createAccountHolder(SMITH, "94536");
      sfsb0.createAccount(SMITH, new Integer(1001), new Integer(5), "94536");
      sfsb0.createAccount(SMITH, new Integer(1002), new Integer(15), "94536");
      sfsb0.createAccount(SMITH, new Integer(1003), new Integer(20), "94536");
      
//      sfsb0.createAccountHolder(JONES, "63088");
      sfsb0.createAccount(JONES, new Integer(2001), new Integer(5), "63088");
      sfsb0.createAccount(JONES, new Integer(2002), new Integer(15), "63088");
      sfsb0.createAccount(JONES, new Integer(2003), new Integer(20), "63088");
      
//      sfsb0.createAccountHolder(BARNEY, "63088");
      sfsb0.createAccount(BARNEY, new Integer(3001), new Integer(5), "63088");
      sfsb0.createAccount(BARNEY, new Integer(3002), new Integer(15), "63088");
      sfsb0.createAccount(BARNEY, new Integer(3003), new Integer(20), "63088");
      
      log.info("Standard entities created");
protected voidtearDown()

      if (sfsb0 != null)
      {
         try
         {
            sfsb0.remove();
         }
         catch (Exception e) {}
      }
      if (sfsb1 != null)
      {
         try
         {
            sfsb1.remove();
         }
         catch (Exception e) {}
      }
      
      sfsb0 = sfsb1 = null;