mirror of
				https://github.com/Alfresco/alfresco-community-repo.git
				synced 2025-10-29 15:21:53 +00:00 
			
		
		
		
	- Included unit test to start NodeCleanupRegistry (sanity check only) - DAO call to 'purgeNodes' - Add job locking to cleanup tasks git-svn-id: https://svn.alfresco.com/repos/alfresco-enterprise/alfresco/HEAD/root@22255 c4b6b30b-aa2e-2d43-bbcb-ca4b014f7261
		
			
				
	
	
		
			556 lines
		
	
	
		
			23 KiB
		
	
	
	
		
			Java
		
	
	
	
	
	
			
		
		
	
	
			556 lines
		
	
	
		
			23 KiB
		
	
	
	
		
			Java
		
	
	
	
	
	
| /*
 | |
|  * Copyright (C) 2005-2010 Alfresco Software Limited.
 | |
|  *
 | |
|  * This file is part of Alfresco
 | |
|  *
 | |
|  * Alfresco is free software: you can redistribute it and/or modify
 | |
|  * it under the terms of the GNU Lesser General Public License as published by
 | |
|  * the Free Software Foundation, either version 3 of the License, or
 | |
|  * (at your option) any later version.
 | |
|  *
 | |
|  * Alfresco is distributed in the hope that it will be useful,
 | |
|  * but WITHOUT ANY WARRANTY; without even the implied warranty of
 | |
|  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 | |
|  * GNU Lesser General Public License for more details.
 | |
|  *
 | |
|  * You should have received a copy of the GNU Lesser General Public License
 | |
|  * along with Alfresco. If not, see <http://www.gnu.org/licenses/>.
 | |
|  */
 | |
| package org.alfresco.repo.node.db;
 | |
| 
 | |
| import java.io.Serializable;
 | |
| import java.util.Date;
 | |
| import java.util.List;
 | |
| import java.util.Locale;
 | |
| import java.util.Map;
 | |
| import java.util.Set;
 | |
| 
 | |
| import javax.transaction.UserTransaction;
 | |
| 
 | |
| import org.alfresco.model.ContentModel;
 | |
| import org.alfresco.repo.domain.node.NodeDAO;
 | |
| import org.alfresco.repo.node.BaseNodeServiceTest;
 | |
| import org.alfresco.repo.node.cleanup.NodeCleanupRegistry;
 | |
| import org.alfresco.repo.transaction.AlfrescoTransactionSupport;
 | |
| import org.alfresco.repo.transaction.RetryingTransactionHelper.RetryingTransactionCallback;
 | |
| import org.alfresco.service.cmr.dictionary.DictionaryService;
 | |
| import org.alfresco.service.cmr.repository.ChildAssociationRef;
 | |
| import org.alfresco.service.cmr.repository.MLText;
 | |
| import org.alfresco.service.cmr.repository.NodeRef;
 | |
| import org.alfresco.service.cmr.repository.NodeService;
 | |
| import org.alfresco.service.namespace.QName;
 | |
| import org.alfresco.service.namespace.RegexQNamePattern;
 | |
| import org.alfresco.service.transaction.TransactionService;
 | |
| import org.springframework.extensions.surf.util.I18NUtil;
 | |
| 
 | |
| /**
 | |
|  * @see org.alfresco.repo.node.db.DbNodeServiceImpl
 | |
|  * 
 | |
|  * @author Derek Hulley
 | |
|  */
 | |
| @SuppressWarnings("unused")
 | |
| public class DbNodeServiceImplTest extends BaseNodeServiceTest
 | |
| {
 | |
|     private TransactionService txnService;
 | |
|     private NodeDAO nodeDAO;
 | |
|     private DictionaryService dictionaryService;
 | |
|     
 | |
|     protected NodeService getNodeService()
 | |
|     {
 | |
|         // Force cascading
 | |
|         DbNodeServiceImpl dbNodeServiceImpl = (DbNodeServiceImpl) applicationContext.getBean("dbNodeServiceImpl");
 | |
|         
 | |
|         return (NodeService) applicationContext.getBean("dbNodeService");
 | |
|     }
 | |
| 
 | |
|     @Override
 | |
|     protected void onSetUpInTransaction() throws Exception
 | |
|     {
 | |
|         super.onSetUpInTransaction();
 | |
|         txnService = (TransactionService) applicationContext.getBean("transactionComponent");
 | |
|         nodeDAO = (NodeDAO) applicationContext.getBean("nodeDAO");
 | |
|         dictionaryService = (DictionaryService) applicationContext.getBean("dictionaryService");
 | |
|     }
 | |
|     
 | |
|     /**
 | |
|      * Manually trigger the cleanup registry
 | |
|      */
 | |
|     public void testNodeCleanupRegistry() throws Exception
 | |
|     {
 | |
|         setComplete();
 | |
|         endTransaction();
 | |
|         NodeCleanupRegistry cleanupRegistry = (NodeCleanupRegistry) applicationContext.getBean("nodeCleanupRegistry");
 | |
|         cleanupRegistry.doClean();
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Deletes a child node and then iterates over the children of the parent node,
 | |
|      * getting the QName.  This caused some issues after we did some optimization
 | |
|      * using lazy loading of the associations.
 | |
|      */
 | |
|     public void testLazyLoadIssue() throws Exception
 | |
|     {
 | |
|         Map<QName, ChildAssociationRef> assocRefs = buildNodeGraph();
 | |
|         // commit results
 | |
|         setComplete();
 | |
|         endTransaction();
 | |
| 
 | |
|         UserTransaction userTransaction = txnService.getUserTransaction();
 | |
|         
 | |
|         try
 | |
|         {
 | |
|             userTransaction.begin();
 | |
|             
 | |
|             ChildAssociationRef n6pn8Ref = assocRefs.get(QName.createQName(BaseNodeServiceTest.NAMESPACE, "n6_p_n8"));
 | |
|             NodeRef n6Ref = n6pn8Ref.getParentRef();
 | |
|             NodeRef n8Ref = n6pn8Ref.getChildRef();
 | |
|             
 | |
|             // delete n8
 | |
|             nodeService.deleteNode(n8Ref);
 | |
|             
 | |
|             // get the parent children
 | |
|             List<ChildAssociationRef> assocs = nodeService.getChildAssocs(n6Ref);
 | |
|             for (ChildAssociationRef assoc : assocs)
 | |
|             {
 | |
|                 // just checking
 | |
|             }
 | |
|             
 | |
|             userTransaction.commit();
 | |
|         }
 | |
|         catch(Exception e)
 | |
|         {
 | |
|             try { userTransaction.rollback(); } catch (IllegalStateException ee) {}
 | |
|             throw e;
 | |
|         }
 | |
|     }
 | |
|     
 | |
|     /**
 | |
|      * Checks that the node status changes correctly during:
 | |
|      * <ul>
 | |
|      *   <li>creation</li>
 | |
|      *   <li>property changes</li>
 | |
|      *   <li>aspect changes</li>
 | |
|      *   <li>moving</li>
 | |
|      *   <li>deletion</li>
 | |
|      * </ul>
 | |
|      */
 | |
|     public void testNodeStatus() throws Throwable
 | |
|     {
 | |
|         Map<QName, ChildAssociationRef> assocRefs = buildNodeGraph();
 | |
|         // get the node to play with
 | |
|         ChildAssociationRef n6pn8Ref = assocRefs.get(QName.createQName(BaseNodeServiceTest.NAMESPACE, "n6_p_n8"));
 | |
|         final NodeRef n6Ref = n6pn8Ref.getParentRef();
 | |
|         final NodeRef n8Ref = n6pn8Ref.getChildRef();
 | |
|         final Map<QName, Serializable> properties = nodeService.getProperties(n6Ref);
 | |
| 
 | |
|         // commit results
 | |
|         setComplete();
 | |
|         endTransaction();
 | |
| 
 | |
|         // change property - check status
 | |
|         RetryingTransactionCallback<Object> changePropertiesWork = new RetryingTransactionCallback<Object>()
 | |
|         {
 | |
|             public Object execute()
 | |
|             {
 | |
|                 nodeService.setProperty(n6Ref, ContentModel.PROP_CREATED, new Date());
 | |
|                 return null;
 | |
|             }
 | |
|         };
 | |
|         executeAndCheck(n6Ref, changePropertiesWork);
 | |
|         
 | |
|         // add an aspect
 | |
|         RetryingTransactionCallback<Object> addAspectWork = new RetryingTransactionCallback<Object>()
 | |
|         {
 | |
|             public Object execute()
 | |
|             {
 | |
|                 nodeService.addAspect(n6Ref, ASPECT_QNAME_TEST_MARKER, null);
 | |
|                 return null;
 | |
|             }
 | |
|         };
 | |
|         executeAndCheck(n6Ref, addAspectWork);
 | |
|         
 | |
|         // remove an aspect
 | |
|         RetryingTransactionCallback<Object> removeAspectWork = new RetryingTransactionCallback<Object>()
 | |
|         {
 | |
|             public Object execute()
 | |
|             {
 | |
|                 nodeService.removeAspect(n6Ref, ASPECT_QNAME_TEST_MARKER);
 | |
|                 return null;
 | |
|             }
 | |
|         };
 | |
|         executeAndCheck(n6Ref, removeAspectWork);
 | |
|         
 | |
|         // move the node
 | |
|         RetryingTransactionCallback<Object> moveNodeWork = new RetryingTransactionCallback<Object>()
 | |
|         {
 | |
|             public Object execute()
 | |
|             {
 | |
|                 nodeService.moveNode(
 | |
|                         n6Ref,
 | |
|                         rootNodeRef,
 | |
|                         ASSOC_TYPE_QNAME_TEST_CHILDREN,
 | |
|                         QName.createQName(NAMESPACE, "moved"));
 | |
|                 return null;
 | |
|             }
 | |
|         };
 | |
|         executeAndCheck(n6Ref, moveNodeWork);
 | |
|         
 | |
|         // delete the node
 | |
|         RetryingTransactionCallback<Object> deleteNodeWork = new RetryingTransactionCallback<Object>()
 | |
|         {
 | |
|             public Object execute()
 | |
|             {
 | |
|                 nodeService.deleteNode(n6Ref);
 | |
|                 return null;
 | |
|             }
 | |
|         };
 | |
|         executeAndCheck(n6Ref, deleteNodeWork);
 | |
|         
 | |
|         // check cascade-deleted nodes
 | |
|         RetryingTransactionCallback<Object> checkCascadeCallback = new RetryingTransactionCallback<Object>()
 | |
|         {
 | |
|             public Object execute()
 | |
|             {
 | |
|                 // check n6
 | |
|                 NodeRef.Status n6Status = nodeDAO.getNodeRefStatus(n6Ref);
 | |
|                 if (!n6Status.isDeleted())
 | |
|                 {
 | |
|                     throw new RuntimeException("Deleted node does not have deleted status");
 | |
|                 }
 | |
|                 // n8 is a primary child - it should be deleted too
 | |
|                 NodeRef.Status n8Status = nodeDAO.getNodeRefStatus(n8Ref);
 | |
|                 if (!n8Status.isDeleted())
 | |
|                 {
 | |
|                     throw new RuntimeException("Cascade-deleted node does not have deleted status");
 | |
|                 }
 | |
|                 return null;
 | |
|             }
 | |
|         };
 | |
|         retryingTransactionHelper.doInTransaction(checkCascadeCallback);
 | |
|         
 | |
|         // check node recreation
 | |
|         RetryingTransactionCallback<Object> checkRecreateCallback = new RetryingTransactionCallback<Object>()
 | |
|         {
 | |
|             public Object execute()
 | |
|             {
 | |
|                 properties.put(ContentModel.PROP_STORE_PROTOCOL, n6Ref.getStoreRef().getProtocol());
 | |
|                 properties.put(ContentModel.PROP_STORE_IDENTIFIER, n6Ref.getStoreRef().getIdentifier());
 | |
|                 properties.put(ContentModel.PROP_NODE_UUID, n6Ref.getId());
 | |
| 
 | |
|                 // recreate n6
 | |
|                 nodeService.createNode(
 | |
|                         rootNodeRef,
 | |
|                         ASSOC_TYPE_QNAME_TEST_CHILDREN,
 | |
|                         QName.createQName(NAMESPACE, "recreated-n6"),
 | |
|                         ContentModel.TYPE_CONTAINER,
 | |
|                         properties);
 | |
|                 return null;
 | |
|             }
 | |
|         };
 | |
|         retryingTransactionHelper.doInTransaction(checkRecreateCallback);
 | |
|     }
 | |
|     
 | |
|     private void executeAndCheck(NodeRef nodeRef, RetryingTransactionCallback<Object> callback) throws Throwable
 | |
|     {
 | |
|         UserTransaction txn = txnService.getUserTransaction();
 | |
|         txn.begin();
 | |
|         
 | |
|         NodeRef.Status currentStatus = nodeService.getNodeStatus(nodeRef);
 | |
|         assertNotNull(currentStatus);
 | |
|         String currentTxnId = AlfrescoTransactionSupport.getTransactionId();
 | |
|         assertNotNull(currentTxnId);
 | |
|         assertNotSame(currentTxnId, currentStatus.getChangeTxnId());
 | |
|         try
 | |
|         {
 | |
|             callback.execute();
 | |
|             // get the status
 | |
|             NodeRef.Status newStatus = nodeService.getNodeStatus(nodeRef);
 | |
|             assertNotNull(newStatus);
 | |
|             // check
 | |
|             assertEquals("Change didn't update status", currentTxnId, newStatus.getChangeTxnId());
 | |
|             txn.commit();
 | |
|         }
 | |
|         catch (Throwable e)
 | |
|         {
 | |
|             try { txn.rollback(); } catch (Throwable ee) {}
 | |
|             throw e;
 | |
|         }
 | |
|     }
 | |
|     
 | |
|     public void testMLTextValues() throws Exception
 | |
|     {
 | |
|         // Set the server default locale
 | |
|         Locale.setDefault(Locale.ENGLISH);
 | |
|         
 | |
|         MLText mlTextProperty = new MLText();
 | |
|         mlTextProperty.addValue(Locale.ENGLISH, "Very good!");
 | |
|         mlTextProperty.addValue(Locale.FRENCH, "Très bon!");
 | |
|         mlTextProperty.addValue(Locale.GERMAN, "Sehr gut!");
 | |
| 
 | |
|         nodeService.setProperty(
 | |
|                 rootNodeRef,
 | |
|                 BaseNodeServiceTest.PROP_QNAME_ML_TEXT_VALUE,
 | |
|                 mlTextProperty);
 | |
|         
 | |
|         // Check unfiltered property retrieval
 | |
|         Serializable textValueDirect = nodeService.getProperty(
 | |
|                 rootNodeRef,
 | |
|                 BaseNodeServiceTest.PROP_QNAME_ML_TEXT_VALUE);
 | |
|         assertEquals(
 | |
|                 "MLText type not returned direct",
 | |
|                 mlTextProperty,
 | |
|                 textValueDirect);
 | |
|         
 | |
|         // Check unfiltered mass property retrieval
 | |
|         Map<QName, Serializable> propertiesDirect = nodeService.getProperties(rootNodeRef);
 | |
|         assertEquals(
 | |
|                 "MLText type not returned direct in Map",
 | |
|                 mlTextProperty,
 | |
|                 propertiesDirect.get(BaseNodeServiceTest.PROP_QNAME_ML_TEXT_VALUE));
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Ensure that plain strings going into MLText properties is handled
 | |
|      */
 | |
|     @SuppressWarnings("unchecked")
 | |
|     public void testStringIntoMLTextProperty() throws Exception
 | |
|     {
 | |
|         String text = "Hello";
 | |
|         nodeService.setProperty(rootNodeRef, PROP_QNAME_ML_TEXT_VALUE, text);
 | |
|         Serializable mlTextCheck = nodeService.getProperty(rootNodeRef, PROP_QNAME_ML_TEXT_VALUE);
 | |
|         assertTrue("Plain string insertion should be returned as MLText", mlTextCheck instanceof MLText);
 | |
|         Locale defaultLocale = I18NUtil.getLocale();
 | |
|         MLText mlTextCheck2 = (MLText) mlTextCheck;
 | |
|         String mlTextDefaultCheck = mlTextCheck2.getDefaultValue();
 | |
|         assertEquals("Default MLText value was not set correctly", text, mlTextDefaultCheck);
 | |
|         
 | |
|         // Reset the property
 | |
|         nodeService.setProperty(rootNodeRef, PROP_QNAME_ML_TEXT_VALUE, null);
 | |
|         Serializable nullValueCheck = nodeService.getProperty(rootNodeRef, PROP_QNAME_ML_TEXT_VALUE);
 | |
|         
 | |
|         // Now, just pass a String in
 | |
|         nodeService.setProperty(rootNodeRef, PROP_QNAME_ML_TEXT_VALUE, text);
 | |
|         // Now update the property with some MLText
 | |
|         MLText mlText = new MLText();
 | |
|         mlText.addValue(Locale.ENGLISH, "Very good!");
 | |
|         mlText.addValue(Locale.FRENCH, "Très bon!");
 | |
|         mlText.addValue(Locale.GERMAN, "Sehr gut!");
 | |
|         nodeService.setProperty(rootNodeRef, PROP_QNAME_ML_TEXT_VALUE, mlText);
 | |
|         // Get it back and check
 | |
|         mlTextCheck = nodeService.getProperty(rootNodeRef, PROP_QNAME_ML_TEXT_VALUE);
 | |
|         assertEquals("Setting of MLText over String failed.", mlText, mlTextCheck);
 | |
|     }
 | |
|     
 | |
|     /**
 | |
|      * Ensure that plain strings going into MLText properties is handled
 | |
|      */
 | |
|     @SuppressWarnings("unchecked")
 | |
|     public void testSingleStringMLTextProperty() throws Exception
 | |
|     {
 | |
|         // Set the property with single-value MLText
 | |
|         MLText mlText = new MLText();
 | |
|         mlText.addValue(Locale.GERMAN, "Sehr gut!");
 | |
|         nodeService.setProperty(rootNodeRef, PROP_QNAME_ML_TEXT_VALUE, mlText);
 | |
|         // Get it back and check
 | |
|         MLText mlTextCheck = (MLText) nodeService.getProperty(rootNodeRef, PROP_QNAME_ML_TEXT_VALUE);
 | |
|         assertEquals("Setting of MLText over String failed.", mlText, mlTextCheck);
 | |
|     }
 | |
|     
 | |
|     /**
 | |
|      * It would appear that an issue has arisen with creating and deleting nodes
 | |
|      * in the same transaction.
 | |
|      */
 | |
|     public void testInTransactionCreateAndDelete() throws Exception
 | |
|     {
 | |
|         // Create a node
 | |
|         NodeRef nodeRef = nodeService.createNode(
 | |
|                 rootNodeRef,
 | |
|                 ASSOC_TYPE_QNAME_TEST_CHILDREN,
 | |
|                 QName.createQName(NAMESPACE, this.getName()),
 | |
|                 TYPE_QNAME_TEST_CONTENT).getChildRef();
 | |
|         // Delete the node
 | |
|         nodeService.deleteNode(nodeRef);
 | |
|     }
 | |
|     
 | |
|     public void testAspectRemovalWithCommit() throws Throwable
 | |
|     {
 | |
|        // Create a node to add the aspect to
 | |
|        NodeRef sourceNodeRef = nodeService.createNode(
 | |
|                rootNodeRef,
 | |
|                ASSOC_TYPE_QNAME_TEST_CHILDREN,
 | |
|                QName.createQName(BaseNodeServiceTest.NAMESPACE, "testAspectRemoval-source"),
 | |
|                ContentModel.TYPE_CONTAINER).getChildRef();
 | |
|        
 | |
|        // Create a target for the associations
 | |
|        NodeRef targetNodeRef = nodeService.createNode(
 | |
|                rootNodeRef,
 | |
|                ASSOC_TYPE_QNAME_TEST_CHILDREN,
 | |
|                QName.createQName(BaseNodeServiceTest.NAMESPACE, "testAspectRemoval-target"),
 | |
|                ContentModel.TYPE_CONTAINER).getChildRef();
 | |
|        
 | |
|        // Add the aspect to the source
 | |
|        nodeService.addAspect(sourceNodeRef, ASPECT_WITH_ASSOCIATIONS, null);
 | |
|        // Make the associations
 | |
|        nodeService.addChild(
 | |
|                sourceNodeRef,
 | |
|                targetNodeRef,
 | |
|                ASSOC_ASPECT_CHILD_ASSOC,
 | |
|                QName.createQName(NAMESPACE, "aspect-child"));
 | |
|        nodeService.createAssociation(sourceNodeRef, targetNodeRef, ASSOC_ASPECT_NORMAL_ASSOC);
 | |
|        
 | |
|        // Check that the correct associations are present
 | |
|        assertEquals("Expected exactly one child",
 | |
|                1, nodeService.getChildAssocs(sourceNodeRef).size());
 | |
|        assertEquals("Expected exactly one target",
 | |
|                1, nodeService.getTargetAssocs(sourceNodeRef, RegexQNamePattern.MATCH_ALL).size());
 | |
|        
 | |
|        // Force a commit here
 | |
|        setComplete();
 | |
|        endTransaction();
 | |
|        
 | |
|        // start another transaction to remove the aspect
 | |
|        UserTransaction txn = txnService.getUserTransaction();
 | |
|        txn.begin();
 | |
|        
 | |
|        try
 | |
|        {
 | |
|           Set<QName> aspects = nodeService.getAspects(sourceNodeRef); 
 | |
|           int noAspectsBefore = aspects.size();
 | |
|           
 | |
|           // Now remove the aspect
 | |
|           nodeService.removeAspect(sourceNodeRef, ASPECT_WITH_ASSOCIATIONS);
 | |
|           
 | |
|           // Check that the associations were removed
 | |
|           assertEquals("Expected exactly zero child",
 | |
|                   0, nodeService.getChildAssocs(sourceNodeRef).size());
 | |
|           assertEquals("Expected exactly zero target",
 | |
|                   0, nodeService.getTargetAssocs(sourceNodeRef, RegexQNamePattern.MATCH_ALL).size());
 | |
|           aspects = nodeService.getAspects(sourceNodeRef); 
 | |
|           assertEquals("Expected exactly one less aspect",
 | |
|                   noAspectsBefore-1, aspects.size());
 | |
|           
 | |
|           txn.commit();
 | |
|        }
 | |
|        catch (Throwable e)
 | |
|        {
 | |
|            try { txn.rollback(); } catch (Throwable ee) {}
 | |
|            throw e;
 | |
|        }
 | |
|     }
 | |
|     
 | |
|     /**
 | |
|      * Test Get Child Assocs By Property Value
 | |
|      * @throws Exception
 | |
|      */
 | |
|     public void testGetChildAssocsByPropertyValue() throws Exception
 | |
|     {
 | |
|         Map<QName, ChildAssociationRef> assocRefs;
 | |
|         
 | |
|         assocRefs = buildNodeGraph();
 | |
|         
 | |
|         ChildAssociationRef rootRef = assocRefs.get(QName.createQName(BaseNodeServiceTest.NAMESPACE, "root"));
 | |
|         ChildAssociationRef n1Ref = assocRefs.get(QName.createQName(BaseNodeServiceTest.NAMESPACE, "root_p_n1"));
 | |
|         ChildAssociationRef n2Ref = assocRefs.get(QName.createQName(BaseNodeServiceTest.NAMESPACE, "root_p_n2"));
 | |
|         
 | |
|         /**
 | |
|          *  Positive test - get n1 and n2 by the value of a text property in this case PROP_SUBJECT which 
 | |
|          *  contains "Hello World"
 | |
|          */
 | |
|         {
 | |
|             NodeRef parentNodeRef = n1Ref.getParentRef();
 | |
|             NodeRef childNodeRef =   n1Ref.getChildRef();
 | |
|             assertTrue(nodeService.exists(parentNodeRef));
 | |
|             assertTrue(nodeService.exists(childNodeRef));
 | |
|             
 | |
|             String subject = "Hello World";
 | |
|             nodeService.setProperty(n1Ref.getChildRef(), ContentModel.PROP_SUBJECT, subject);      
 | |
|             List<ChildAssociationRef> refs = nodeService.getChildAssocsByPropertyValue(parentNodeRef, ContentModel.PROP_SUBJECT, subject);
 | |
|             assertTrue("failed to read one assoc", refs.size() == 1);
 | |
|             assertTrue("content not correct", refs.contains(n1Ref));
 | |
|             
 | |
|             // Now go for another two documents.
 | |
|             nodeService.setProperty(n2Ref.getChildRef(), ContentModel.PROP_SUBJECT, subject);      
 | |
|             refs = nodeService.getChildAssocsByPropertyValue(parentNodeRef, ContentModel.PROP_SUBJECT, subject);
 | |
|             assertTrue("failed to read two assocs", refs.size() == 2);
 | |
|             assertTrue("content not correct", refs.contains(n1Ref));
 | |
|             assertTrue("content not correct", refs.contains(n2Ref));
 | |
|         }
 | |
|         
 | |
|         /**
 | |
|          * Positive tests of various types that should be accepted by the query 
 | |
|          */
 | |
|         {
 | |
|             NodeRef parentNodeRef = n1Ref.getParentRef();
 | |
|             NodeRef childNodeRef =   n1Ref.getChildRef();
 | |
|             assertTrue(nodeService.exists(parentNodeRef));
 | |
|             assertTrue(nodeService.exists(childNodeRef));
 | |
|             
 | |
|             // integer
 | |
|             int count = 123;
 | |
|             nodeService.setProperty(n1Ref.getChildRef(), ContentModel.PROP_COUNTER, count);      
 | |
|             List<ChildAssociationRef> refs = nodeService.getChildAssocsByPropertyValue(parentNodeRef, ContentModel.PROP_COUNTER, count);
 | |
|             assertTrue("failed to read one assoc", refs.size() == 1);
 | |
|             assertTrue("content not correct", refs.contains(n1Ref));
 | |
|             
 | |
|             // Double
 | |
|             Double alfLat = new Double(51.5216666);
 | |
|             Double alfLon = new Double(0.43);
 | |
|             nodeService.setProperty(n1Ref.getChildRef(), ContentModel.PROP_LATITUDE, alfLat);      
 | |
|             refs = nodeService.getChildAssocsByPropertyValue(parentNodeRef, ContentModel.PROP_LATITUDE, alfLat);
 | |
|             assertTrue("failed to read one assoc", refs.size() == 1);
 | |
|             assertTrue("content not correct", refs.contains(n1Ref));
 | |
|             
 | |
|             // float
 | |
|             // not implemeted due to float precision issues with float equals.
 | |
|             //float score = 1.3f;
 | |
|             //nodeService.setProperty(n1Ref.getChildRef(), ContentModel.PROP_RATING_SCORE, score);      
 | |
|             //refs = nodeService.getChildAssocsByPropertyValue(parentNodeRef, ContentModel.PROP_RATING_SCORE, score);
 | |
|             //assertTrue("failed to read one assoc", refs.size() == 1);
 | |
|             //assertTrue("content not correct", refs.contains(n1Ref));
 | |
|             
 | |
|             // Boolean TRUE
 | |
|             Boolean beauty = Boolean.TRUE;
 | |
|             nodeService.setProperty(n1Ref.getChildRef(), ContentModel.PROP_ENABLED, beauty); 
 | |
|             assertTrue((Boolean)nodeService.getProperty(n1Ref.getChildRef(), ContentModel.PROP_ENABLED));
 | |
|             refs = nodeService.getChildAssocsByPropertyValue(parentNodeRef, ContentModel.PROP_ENABLED, beauty);
 | |
|             assertTrue("failed to read one assoc", refs.size() == 1);
 | |
|             assertTrue("content not correct", refs.contains(n1Ref));
 | |
|             
 | |
|             // Boolean FALSE
 | |
|             beauty = Boolean.FALSE;
 | |
|             nodeService.setProperty(n1Ref.getChildRef(), ContentModel.PROP_ENABLED, beauty); 
 | |
|             assertTrue(!(Boolean)nodeService.getProperty(n1Ref.getChildRef(), ContentModel.PROP_ENABLED));
 | |
|             refs = nodeService.getChildAssocsByPropertyValue(parentNodeRef, ContentModel.PROP_ENABLED, beauty);
 | |
|             assertTrue("failed to read one assoc", refs.size() == 1);
 | |
|            
 | |
|         }
 | |
|         
 | |
|         /**
 | |
|          * Negative test - invalid to search on sys:node-dbid
 | |
|          */
 | |
|         try
 | |
|         {
 | |
|             List<ChildAssociationRef> refs = nodeService.getChildAssocsByPropertyValue(n1Ref.getParentRef(), ContentModel.PROP_NODE_DBID, "Fail");
 | |
|             fail("sys:node-dbid not rejected");
 | |
|         }
 | |
|         catch (IllegalArgumentException ie)
 | |
|         {
 | |
|             // expect to go here
 | |
|         }
 | |
|         
 | |
|         /**
 | |
|          * Negative test - invalid to search on type MLText
 | |
|          */
 | |
|         try
 | |
|         {
 | |
|             Serializable title = (String)nodeService.getProperty(n1Ref.getChildRef(), ContentModel.PROP_TITLE);
 | |
|             List<ChildAssociationRef> refs = nodeService.getChildAssocsByPropertyValue(n1Ref.getParentRef(), ContentModel.PROP_NAME, title);
 | |
|             fail("MLText type not rejected");
 | |
|         }
 | |
|         catch (IllegalArgumentException ie)
 | |
|         {
 | |
|             // expect to go here
 | |
|         }
 | |
|     }
 | |
| }
 |