mirror of
https://github.com/Alfresco/alfresco-community-repo.git
synced 2025-08-07 17:49:17 +00:00
Fixed ALF-10280: Slow to report « Duplicate entry » in database.
- DuplicateChildNodeNameException implements DoNotRetryException - Must be merged back to V3.4 git-svn-id: https://svn.alfresco.com/repos/alfresco-enterprise/alfresco/HEAD/root@30468 c4b6b30b-aa2e-2d43-bbcb-ca4b014f7261
This commit is contained in:
@@ -20,6 +20,7 @@ package org.alfresco.repo.node;
|
|||||||
|
|
||||||
import java.io.Serializable;
|
import java.io.Serializable;
|
||||||
import java.util.Collections;
|
import java.util.Collections;
|
||||||
|
import java.util.HashMap;
|
||||||
import java.util.Locale;
|
import java.util.Locale;
|
||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
|
|
||||||
@@ -30,6 +31,7 @@ import org.alfresco.repo.security.authentication.AuthenticationUtil;
|
|||||||
import org.alfresco.repo.transaction.RetryingTransactionHelper.RetryingTransactionCallback;
|
import org.alfresco.repo.transaction.RetryingTransactionHelper.RetryingTransactionCallback;
|
||||||
import org.alfresco.service.ServiceRegistry;
|
import org.alfresco.service.ServiceRegistry;
|
||||||
import org.alfresco.service.cmr.repository.AssociationRef;
|
import org.alfresco.service.cmr.repository.AssociationRef;
|
||||||
|
import org.alfresco.service.cmr.repository.DuplicateChildNodeNameException;
|
||||||
import org.alfresco.service.cmr.repository.MLText;
|
import org.alfresco.service.cmr.repository.MLText;
|
||||||
import org.alfresco.service.cmr.repository.NodeRef;
|
import org.alfresco.service.cmr.repository.NodeRef;
|
||||||
import org.alfresco.service.cmr.repository.NodeRef.Status;
|
import org.alfresco.service.cmr.repository.NodeRef.Status;
|
||||||
@@ -211,11 +213,14 @@ public class NodeServiceTest extends TestCase
|
|||||||
ContentModel.TYPE_FOLDER).getChildRef();
|
ContentModel.TYPE_FOLDER).getChildRef();
|
||||||
for (int i = 1; i < liveNodeRefs.length; i++)
|
for (int i = 1; i < liveNodeRefs.length; i++)
|
||||||
{
|
{
|
||||||
|
Map<QName, Serializable> props = new HashMap<QName, Serializable>(3);
|
||||||
|
props.put(ContentModel.PROP_NAME, "depth-" + i);
|
||||||
liveNodeRefs[i] = nodeService.createNode(
|
liveNodeRefs[i] = nodeService.createNode(
|
||||||
liveNodeRefs[i-1],
|
liveNodeRefs[i-1],
|
||||||
ContentModel.ASSOC_CONTAINS,
|
ContentModel.ASSOC_CONTAINS,
|
||||||
QName.createQName(NAMESPACE, "depth-" + i),
|
QName.createQName(NAMESPACE, "depth-" + i),
|
||||||
ContentModel.TYPE_FOLDER).getChildRef();
|
ContentModel.TYPE_FOLDER,
|
||||||
|
props).getChildRef();
|
||||||
}
|
}
|
||||||
return null;
|
return null;
|
||||||
}
|
}
|
||||||
@@ -383,4 +388,39 @@ public class NodeServiceTest extends TestCase
|
|||||||
AssociationRef assocRef = nodeService.getAssoc(Long.MAX_VALUE);
|
AssociationRef assocRef = nodeService.getAssoc(Long.MAX_VALUE);
|
||||||
assertNull("Should get null for missing ID of association. ", assocRef);
|
assertNull("Should get null for missing ID of association. ", assocRef);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public void testDuplicateChildNodeName()
|
||||||
|
{
|
||||||
|
final NodeRef[] liveNodeRefs = new NodeRef[3];
|
||||||
|
final NodeRef workspaceRootNodeRef = nodeService.getRootNode(StoreRef.STORE_REF_WORKSPACE_SPACESSTORE);
|
||||||
|
buildNodeHierarchy(workspaceRootNodeRef, liveNodeRefs);
|
||||||
|
|
||||||
|
// Get the name of the last node
|
||||||
|
final String lastName = (String) nodeService.getProperty(liveNodeRefs[2], ContentModel.PROP_NAME);
|
||||||
|
// Now create a node with the same name
|
||||||
|
RetryingTransactionCallback<NodeRef> newNodeCallback = new RetryingTransactionCallback<NodeRef>()
|
||||||
|
{
|
||||||
|
@Override
|
||||||
|
public NodeRef execute() throws Throwable
|
||||||
|
{
|
||||||
|
Map<QName, Serializable> props = new HashMap<QName, Serializable>(3);
|
||||||
|
props.put(ContentModel.PROP_NAME, lastName);
|
||||||
|
return nodeService.createNode(
|
||||||
|
liveNodeRefs[1],
|
||||||
|
ContentModel.ASSOC_CONTAINS,
|
||||||
|
QName.createQName(NAMESPACE, "duplicate"),
|
||||||
|
ContentModel.TYPE_FOLDER,
|
||||||
|
props).getChildRef();
|
||||||
|
}
|
||||||
|
};
|
||||||
|
try
|
||||||
|
{
|
||||||
|
txnService.getRetryingTransactionHelper().doInTransaction(newNodeCallback);
|
||||||
|
fail("Duplicate child node name not detected.");
|
||||||
|
}
|
||||||
|
catch (DuplicateChildNodeNameException e)
|
||||||
|
{
|
||||||
|
// Expected
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
@@ -0,0 +1,30 @@
|
|||||||
|
/*
|
||||||
|
* 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.transaction;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Marker interface for the exceptions that should not trigger retries, regardless of
|
||||||
|
* the contained causal exceptions.
|
||||||
|
*
|
||||||
|
* @author Derek Hulley
|
||||||
|
* @since 3.4.6
|
||||||
|
*/
|
||||||
|
public interface DoNotRetryException
|
||||||
|
{
|
||||||
|
}
|
@@ -541,7 +541,8 @@ public class RetryingTransactionHelper
|
|||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Sometimes, the exception means retry and sometimes not.
|
* Sometimes, the exception means retry and sometimes not. The stack of exceptions is also checked
|
||||||
|
* for any occurence of {@link DoNotRetryException} and, if found, nothing is returned.
|
||||||
*
|
*
|
||||||
* @param cause the cause to examine
|
* @param cause the cause to examine
|
||||||
* @return Returns the original cause if it is a valid retry cause, otherwise <tt>null</tt>
|
* @return Returns the original cause if it is a valid retry cause, otherwise <tt>null</tt>
|
||||||
@@ -554,6 +555,11 @@ public class RetryingTransactionHelper
|
|||||||
{
|
{
|
||||||
return null;
|
return null;
|
||||||
}
|
}
|
||||||
|
else if (ExceptionStackUtil.getCause(cause, DoNotRetryException.class) != null)
|
||||||
|
{
|
||||||
|
// Someone decided that the txn should NOT retry
|
||||||
|
return null;
|
||||||
|
}
|
||||||
else if (retryCause instanceof SQLGrammarException
|
else if (retryCause instanceof SQLGrammarException
|
||||||
&& ((SQLGrammarException) retryCause).getErrorCode() != 3960)
|
&& ((SQLGrammarException) retryCause).getErrorCode() != 3960)
|
||||||
{
|
{
|
||||||
|
@@ -19,16 +19,20 @@
|
|||||||
package org.alfresco.service.cmr.repository;
|
package org.alfresco.service.cmr.repository;
|
||||||
|
|
||||||
import org.springframework.extensions.surf.util.I18NUtil;
|
import org.springframework.extensions.surf.util.I18NUtil;
|
||||||
|
import org.alfresco.repo.transaction.DoNotRetryException;
|
||||||
import org.alfresco.service.namespace.QName;
|
import org.alfresco.service.namespace.QName;
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Thrown when a child node <b>cm:name</b> property violates the data dictionary
|
* Thrown when a child node <b>cm:name</b> property violates the data dictionary
|
||||||
* <b>duplicate</b> child association constraint.
|
* <b>duplicate</b> child association constraint.
|
||||||
|
* <p/>
|
||||||
|
* Note that this exception may be triggered by database constraints but must
|
||||||
|
* still NOT trigger transaction retries.
|
||||||
*
|
*
|
||||||
* @author Derek Hulley
|
* @author Derek Hulley
|
||||||
*/
|
*/
|
||||||
public class DuplicateChildNodeNameException extends RuntimeException
|
public class DuplicateChildNodeNameException extends RuntimeException implements DoNotRetryException
|
||||||
{
|
{
|
||||||
private static final long serialVersionUID = 5143099335847200453L;
|
private static final long serialVersionUID = 5143099335847200453L;
|
||||||
|
|
||||||
|
Reference in New Issue
Block a user