Add logging to rm query DAO implementation

This commit is contained in:
Roy Wetherall
2019-08-29 09:50:57 +10:00
parent 30f770a504
commit 4518cd8615
3 changed files with 53 additions and 5 deletions

View File

@@ -56,4 +56,6 @@ log4j.logger.org.alfresco.module.org_alfresco_module_rm.patch=info
# Job debug # Job debug
# #
#log4j.logger.org.alfresco.module.org_alfresco_module_rm.job=debug #log4j.logger.org.alfresco.module.org_alfresco_module_rm.job=debug
log4j.logger.org.alfresco.repo.web.scripts.roles.DynamicAuthoritiesGet=info log4j.logger.org.alfresco.repo.web.scripts.roles.DynamicAuthoritiesGet=info
log4j.logger.org.alfresco.module.org_alfresco_module_rm.query.RecordsManagementQueryDAOImpl=debug

View File

@@ -43,7 +43,6 @@ import org.alfresco.repo.tenant.TenantService;
import org.alfresco.repo.version.Version2Model; import org.alfresco.repo.version.Version2Model;
import org.alfresco.service.cmr.repository.InvalidNodeRefException; import org.alfresco.service.cmr.repository.InvalidNodeRefException;
import org.alfresco.service.cmr.repository.NodeRef; 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.QName;
import org.alfresco.util.Pair; import org.alfresco.util.Pair;
import org.apache.commons.logging.Log; import org.apache.commons.logging.Log;
@@ -58,6 +57,11 @@ import org.mybatis.spring.SqlSessionTemplate;
*/ */
public class RecordsManagementQueryDAOImpl implements RecordsManagementQueryDAO, RecordsManagementModel public class RecordsManagementQueryDAOImpl implements RecordsManagementQueryDAO, RecordsManagementModel
{ {
/** logger */
@SuppressWarnings("unused")
private static final Log logger = LogFactory.getLog(RecordsManagementQueryDAOImpl.class);
/** query names */
private static final String COUNT_IDENTIFIER = "alfresco.query.rm.select_CountRMIndentifier"; private static final String COUNT_IDENTIFIER = "alfresco.query.rm.select_CountRMIndentifier";
private static final String GET_CHILDREN_PROPERTY_VALUES = "select_GetStringPropertyValuesOfChildren"; private static final String GET_CHILDREN_PROPERTY_VALUES = "select_GetStringPropertyValuesOfChildren";
private static final String SELECT_NODE_IDS_WHICH_REFERENCE_CONTENT_URL = "select_NodeIdsWhichReferenceContentUrl"; private static final String SELECT_NODE_IDS_WHICH_REFERENCE_CONTENT_URL = "select_NodeIdsWhichReferenceContentUrl";
@@ -152,9 +156,21 @@ public class RecordsManagementQueryDAOImpl implements RecordsManagementQueryDAO,
} }
/**
* Get a set of node reference which reference the provided content URL
*
* @param String contentUrl content URL
* @return Set<String> set of node references as strings
*/
@Override @Override
public Set<String> getNodeRefsWhichReferenceContentUrl(String contentUrl) public Set<String> getNodeRefsWhichReferenceContentUrl(String contentUrl)
{ {
if (logger.isDebugEnabled())
{
logger.debug("Getting nodes that reference content URL = " + contentUrl);
}
// create the content URL entity used to query for nodes
ContentUrlEntity contentUrlEntity = new ContentUrlEntity(); ContentUrlEntity contentUrlEntity = new ContentUrlEntity();
contentUrlEntity.setContentUrl(contentUrl); contentUrlEntity.setContentUrl(contentUrl);
if (contentUrlEntity.getContentUrlShort() != null) if (contentUrlEntity.getContentUrlShort() != null)
@@ -162,28 +178,60 @@ public class RecordsManagementQueryDAOImpl implements RecordsManagementQueryDAO,
contentUrlEntity.setContentUrlShort(contentUrlEntity.getContentUrlShort().toLowerCase()); contentUrlEntity.setContentUrlShort(contentUrlEntity.getContentUrlShort().toLowerCase());
} }
if (logger.isDebugEnabled())
{
logger.debug("Executing query " + SELECT_NODE_IDS_WHICH_REFERENCE_CONTENT_URL);
}
// Get all the node ids which reference the given content url // Get all the node ids which reference the given content url
List<Long> nodeIds = template.selectList(SELECT_NODE_IDS_WHICH_REFERENCE_CONTENT_URL, contentUrlEntity); List<Long> nodeIds = template.selectList(SELECT_NODE_IDS_WHICH_REFERENCE_CONTENT_URL, contentUrlEntity);
if (logger.isDebugEnabled())
{
logger.debug("Query " + SELECT_NODE_IDS_WHICH_REFERENCE_CONTENT_URL + " returned " + nodeIds.size() + " results");
}
// create a set of uuids which reference the content url // create a set of uuids which reference the content url
Set<String> nodesReferencingContentUrl = new HashSet<>(); Set<String> nodesReferencingContentUrl = new HashSet<>();
for(Long nodeId : nodeIds) for(Long nodeId : nodeIds)
{ {
StringBuilder logMessage = null;
String uuidToAdd; String uuidToAdd;
if (logger.isDebugEnabled())
{
logMessage = new StringBuilder("Adding uuid ");
}
// if the referencing node is a version2Store reference to the content url, add the uuid for the version 2 frozen node ref // if the referencing node is a version2Store reference to the content url, add the uuid for the version 2 frozen node ref
NodeRef version2FrozenNodeRef = (NodeRef) nodeDAO.getNodeProperty(nodeId, Version2Model.PROP_QNAME_FROZEN_NODE_REF); NodeRef version2FrozenNodeRef = (NodeRef) nodeDAO.getNodeProperty(nodeId, Version2Model.PROP_QNAME_FROZEN_NODE_REF);
if (version2FrozenNodeRef != null) if (version2FrozenNodeRef != null)
{ {
uuidToAdd = version2FrozenNodeRef.getId(); uuidToAdd = version2FrozenNodeRef.getId();
if (logger.isDebugEnabled())
{
logMessage.append(uuidToAdd).append(" (from version)");
}
} }
// add the uuid for the node ref of the referencing node // add the uuid for the node ref of the referencing node
else else
{ {
uuidToAdd = (String) nodeDAO.getNodeProperty(nodeId, ContentModel.PROP_NODE_UUID); uuidToAdd = (String) nodeDAO.getNodeProperty(nodeId, ContentModel.PROP_NODE_UUID);
if (logger.isDebugEnabled())
{
logMessage.append(uuidToAdd);
}
} }
nodesReferencingContentUrl.add(uuidToAdd); nodesReferencingContentUrl.add(uuidToAdd);
if (logger.isDebugEnabled())
{
logger.debug(logMessage.toString());
}
} }
return nodesReferencingContentUrl; return nodesReferencingContentUrl;

View File

@@ -46,8 +46,6 @@ import org.apache.commons.io.IOUtils;
import org.apache.commons.lang.StringUtils; import org.apache.commons.lang.StringUtils;
import org.springframework.extensions.webscripts.GUID; import org.springframework.extensions.webscripts.GUID;
import javax.xml.soap.Node;
/** /**
* Integration test for RM-4804 * Integration test for RM-4804
* *