Fix AVM mising a directory add event??

Lucane PATH now working for the staging area
XPath is trying for all AVM stores (enven layers)
- missing support for no name space mathing all ....and suport for names attributes ... on the AVM nodeservice

git-svn-id: https://svn.alfresco.com/repos/alfresco-enterprise/alfresco/HEAD/root@5753 c4b6b30b-aa2e-2d43-bbcb-ca4b014f7261
This commit is contained in:
Andrew Hind
2007-05-22 16:18:24 +00:00
parent 7f5c55247b
commit 28996e9a03
2 changed files with 38 additions and 12 deletions

View File

@@ -67,7 +67,7 @@ public class AVMLuceneIndexerAndSearcherFactory extends AbstractLuceneIndexerAnd
public AVMLuceneIndexerAndSearcherFactory() public AVMLuceneIndexerAndSearcherFactory()
{ {
s_logger.error("Creating AVMLuceneIndexerAndSearcherFactory"); //s_logger.error("Creating AVMLuceneIndexerAndSearcherFactory");
} }
/** /**

View File

@@ -96,11 +96,6 @@ public class AVMLuceneIndexerImpl extends AbstractLuceneIndexerImpl<String> impl
private ContentService contentService; private ContentService contentService;
@SuppressWarnings("unused")
private int srcVersion = -1;
private int dstVersion = -1;
private Set<String> indexedPaths = new HashSet<String>(); private Set<String> indexedPaths = new HashSet<String>();
/** /**
@@ -170,8 +165,6 @@ public class AVMLuceneIndexerImpl extends AbstractLuceneIndexerImpl<String> impl
public void index(String store, int srcVersion, int dstVersion) public void index(String store, int srcVersion, int dstVersion)
{ {
checkAbleToDoWork(IndexUpdateStatus.SYNCRONOUS); checkAbleToDoWork(IndexUpdateStatus.SYNCRONOUS);
this.srcVersion = srcVersion;
this.dstVersion = dstVersion;
String path = store + ":/"; String path = store + ":/";
List<AVMDifference> changeList = avmSyncService.compare(srcVersion, path, dstVersion, path, null); List<AVMDifference> changeList = avmSyncService.compare(srcVersion, path, dstVersion, path, null);
@@ -194,12 +187,14 @@ public class AVMLuceneIndexerImpl extends AbstractLuceneIndexerImpl<String> impl
{ {
indexDirectory(dstDesc); indexDirectory(dstDesc);
} }
reindexAllAncestors(difference.getDestinationPath());
} }
// New Delete // New Delete
else if (!srcDesc.isDeleted() && ((dstDesc == null) || dstDesc.isDeleted())) else if (!srcDesc.isDeleted() && ((dstDesc == null) || dstDesc.isDeleted()))
{ {
delete(difference.getSourcePath()); delete(difference.getSourcePath());
delete(difference.getDestinationPath()); delete(difference.getDestinationPath());
reindexAllAncestors(difference.getDestinationPath());
} }
// Existing delete // Existing delete
else if (srcDesc.isDeleted() && dstDesc.isDeleted()) else if (srcDesc.isDeleted() && dstDesc.isDeleted())
@@ -213,6 +208,8 @@ public class AVMLuceneIndexerImpl extends AbstractLuceneIndexerImpl<String> impl
// Should only reindex if the path has changed - not anything on a directory // Should only reindex if the path has changed - not anything on a directory
reindex(difference.getSourcePath(), srcDesc.isDirectory()); reindex(difference.getSourcePath(), srcDesc.isDirectory());
reindex(difference.getDestinationPath(), dstDesc.isDirectory()); reindex(difference.getDestinationPath(), dstDesc.isDirectory());
reindexAllAncestors(difference.getDestinationPath());
reindexAllAncestors(difference.getDestinationPath());
} }
break; break;
case AVMDifference.DIRECTORY: case AVMDifference.DIRECTORY:
@@ -226,6 +223,35 @@ public class AVMLuceneIndexerImpl extends AbstractLuceneIndexerImpl<String> impl
} }
} }
/*
* Nasty catch all fix up (as changes imply the parents may all have changed
*/
private void reindexAllAncestors(String destinationPath)
{
String[] splitPath = splitPath(destinationPath);
String store = splitPath[0];
String pathInStore = splitPath[1];
SimplePath simplePath = new SimplePath(pathInStore);
StringBuilder pathBuilder = new StringBuilder();
pathBuilder.append(store).append(":/");
reindex(pathBuilder.toString(), false);
boolean requiresSep = false;
for (int i = 0; i < simplePath.size() - 1; i++)
{
if(requiresSep)
{
pathBuilder.append("/");
}
else
{
requiresSep = true;
}
pathBuilder.append(simplePath.get(i));
reindex(pathBuilder.toString(), false);
}
}
private void indexDirectory(AVMNodeDescriptor dir) private void indexDirectory(AVMNodeDescriptor dir)
{ {
Map<String, AVMNodeDescriptor> children = avmService.getDirectoryListing(dir); Map<String, AVMNodeDescriptor> children = avmService.getDirectoryListing(dir);
@@ -244,7 +270,7 @@ public class AVMLuceneIndexerImpl extends AbstractLuceneIndexerImpl<String> impl
protected List<Document> createDocuments(String stringNodeRef, boolean isNew, boolean indexAllProperties, protected List<Document> createDocuments(String stringNodeRef, boolean isNew, boolean indexAllProperties,
boolean includeDirectoryDocuments) boolean includeDirectoryDocuments)
{ {
AVMNodeDescriptor desc = avmService.lookup(dstVersion, stringNodeRef); AVMNodeDescriptor desc = avmService.lookup(-1, stringNodeRef);
List<Document> docs = new ArrayList<Document>(); List<Document> docs = new ArrayList<Document>();
if(desc == null) if(desc == null)
{ {
@@ -280,7 +306,7 @@ public class AVMLuceneIndexerImpl extends AbstractLuceneIndexerImpl<String> impl
if (desc != null) if (desc != null)
{ {
NodeRef nodeRef = AVMNodeConverter.ToNodeRef(dstVersion, stringNodeRef); NodeRef nodeRef = AVMNodeConverter.ToNodeRef(-1, stringNodeRef);
Document xdoc = new Document(); Document xdoc = new Document();
xdoc.add(new Field("ID", nodeRef.toString(), Field.Store.YES, xdoc.add(new Field("ID", nodeRef.toString(), Field.Store.YES,
@@ -301,7 +327,7 @@ public class AVMLuceneIndexerImpl extends AbstractLuceneIndexerImpl<String> impl
boolean isAtomic = true; boolean isAtomic = true;
Map<QName, Serializable> properties = getIndexableProperties(desc, node, nodeRef, dstVersion, stringNodeRef); Map<QName, Serializable> properties = getIndexableProperties(desc, node, nodeRef, -1, stringNodeRef);
for (QName propertyName : properties.keySet()) for (QName propertyName : properties.keySet())
{ {
Serializable value = properties.get(propertyName); Serializable value = properties.get(propertyName);
@@ -430,7 +456,7 @@ public class AVMLuceneIndexerImpl extends AbstractLuceneIndexerImpl<String> impl
xdoc.add(new Field("TYPE", ISO9075.getXPathName(typeQName), Field.Store.YES, xdoc.add(new Field("TYPE", ISO9075.getXPathName(typeQName), Field.Store.YES,
Field.Index.UN_TOKENIZED, Field.TermVector.NO)); Field.Index.UN_TOKENIZED, Field.TermVector.NO));
for (QName classRef : avmService.getAspects(dstVersion, stringNodeRef)) for (QName classRef : avmService.getAspects(-1, stringNodeRef))
{ {
xdoc.add(new Field("ASPECT", ISO9075.getXPathName(classRef), Field.Store.YES, xdoc.add(new Field("ASPECT", ISO9075.getXPathName(classRef), Field.Store.YES,
Field.Index.UN_TOKENIZED, Field.TermVector.NO)); Field.Index.UN_TOKENIZED, Field.TermVector.NO));