Author: sergiykarpenko Date: 2009-11-09 05:52:43 -0500 (Mon, 09 Nov 2009) New Revision: 503 Modified: jcr/branches/1.12.0-JBC/component/core/src/main/java/org/exoplatform/services/jcr/impl/core/query/SearchManager.java jcr/branches/1.12.0-JBC/component/core/src/main/java/org/exoplatform/services/jcr/impl/core/query/SearchManagerImpl.java jcr/branches/1.12.0-JBC/component/core/src/main/java/org/exoplatform/services/jcr/impl/core/query/cacheloader/IndexerCacheLoader.java Log: EXOJCR-202: IndexerCacheLoader updated Modified: jcr/branches/1.12.0-JBC/component/core/src/main/java/org/exoplatform/services/jcr/impl/core/query/SearchManager.java =================================================================== --- jcr/branches/1.12.0-JBC/component/core/src/main/java/org/exoplatform/services/jcr/impl/core/query/SearchManager.java 2009-11-09 09:54:44 UTC (rev 502) +++ jcr/branches/1.12.0-JBC/component/core/src/main/java/org/exoplatform/services/jcr/impl/core/query/SearchManager.java 2009-11-09 10:52:43 UTC (rev 503) @@ -20,6 +20,7 @@ import org.exoplatform.services.jcr.impl.core.SessionDataManager; import org.exoplatform.services.jcr.impl.core.SessionImpl; +import java.io.IOException; import java.util.Set; import javax.jcr.Node; @@ -90,4 +91,14 @@ */ Set<String> getNodesByUri(final String uri) throws RepositoryException; + /** + * Update Index storege for next uuid lists. + * + * @param removedNodes - removed nodes uuid set + * @param addedNodes - added nodes uuid set + * @throws RepositoryException + * @throws IOException + */ + public void updateIndex(Set<String> removedNodes, Set<String> addedNodes) throws RepositoryException, IOException; + } Modified: jcr/branches/1.12.0-JBC/component/core/src/main/java/org/exoplatform/services/jcr/impl/core/query/SearchManagerImpl.java =================================================================== --- jcr/branches/1.12.0-JBC/component/core/src/main/java/org/exoplatform/services/jcr/impl/core/query/SearchManagerImpl.java 2009-11-09 09:54:44 UTC (rev 502) +++ jcr/branches/1.12.0-JBC/component/core/src/main/java/org/exoplatform/services/jcr/impl/core/query/SearchManagerImpl.java 2009-11-09 10:52:43 UTC (rev 503) @@ -327,6 +327,40 @@ addedNodes.add(uuid); } + try + { + updateIndex(removedNodes, addedNodes); + } + catch (RepositoryException e) + { + log.error("Error indexing changes " + e, e); + } + catch (IOException e) + { + log.error("Error indexing changes " + e, e); + try + { + handler.logErrorChanges(removedNodes, addedNodes); + } + catch (IOException ioe) + { + log.warn("Exception occure when errorLog writed. Error log is not complete. " + ioe, ioe); + } + } + + if (log.isDebugEnabled()) + { + log.debug("onEvent: indexing finished in " + String.valueOf(System.currentTimeMillis() - time) + " ms."); + } + + } + + /** + * {@inheritDoc} + */ + public void updateIndex(final Set<String> removedNodes, final Set<String> addedNodes) throws RepositoryException, + IOException + { Iterator<NodeData> addedStates = new Iterator<NodeData>() { private final Iterator<String> iter = addedNodes.iterator(); @@ -402,32 +436,9 @@ if (removedNodes.size() > 0 || addedNodes.size() > 0) { - try - { - handler.updateNodes(removedIds, addedStates); - } - catch (RepositoryException e) - { - log.error("Error indexing changes " + e, e); - } - catch (IOException e) - { - log.error("Error indexing changes " + e, e); - try - { - handler.logErrorChanges(removedNodes, addedNodes); - } - catch (IOException ioe) - { - log.warn("Exception occure when errorLog writed. Error log is not complete. " + ioe, ioe); - } - } + handler.updateNodes(removedIds, addedStates); } - if (log.isDebugEnabled()) - { - log.debug("onEvent: indexing finished in " + String.valueOf(System.currentTimeMillis() - time) + " ms."); - } } public void createNewOrAdd(String key, ItemState state, Map<String, List<ItemState>> updatedNodes) Modified: jcr/branches/1.12.0-JBC/component/core/src/main/java/org/exoplatform/services/jcr/impl/core/query/cacheloader/IndexerCacheLoader.java =================================================================== --- jcr/branches/1.12.0-JBC/component/core/src/main/java/org/exoplatform/services/jcr/impl/core/query/cacheloader/IndexerCacheLoader.java 2009-11-09 09:54:44 UTC (rev 502) +++ jcr/branches/1.12.0-JBC/component/core/src/main/java/org/exoplatform/services/jcr/impl/core/query/cacheloader/IndexerCacheLoader.java 2009-11-09 10:52:43 UTC (rev 503) @@ -16,48 +16,8 @@ */ package org.exoplatform.services.jcr.impl.core.query.cacheloader; -import org.apache.lucene.index.IndexReader; -import org.apache.lucene.index.Term; -import org.apache.lucene.search.BooleanQuery; -import org.apache.lucene.search.WildcardQuery; -import org.apache.lucene.search.BooleanClause.Occur; -import org.exoplatform.container.configuration.ConfigurationManager; -import org.exoplatform.services.document.DocumentReaderService; -import org.exoplatform.services.jcr.config.QueryHandlerEntry; -import org.exoplatform.services.jcr.config.QueryHandlerParams; -import org.exoplatform.services.jcr.config.RepositoryConfigurationException; -import org.exoplatform.services.jcr.core.nodetype.NodeTypeDataManager; -import org.exoplatform.services.jcr.dataflow.ItemDataConsumer; import org.exoplatform.services.jcr.dataflow.ItemState; -import org.exoplatform.services.jcr.datamodel.InternalQName; -import org.exoplatform.services.jcr.datamodel.ItemData; -import org.exoplatform.services.jcr.datamodel.NodeData; -import org.exoplatform.services.jcr.datamodel.PropertyData; -import org.exoplatform.services.jcr.datamodel.QPath; -import org.exoplatform.services.jcr.datamodel.ValueData; -import org.exoplatform.services.jcr.impl.Constants; -import org.exoplatform.services.jcr.impl.core.LocationFactory; -import org.exoplatform.services.jcr.impl.core.NamespaceRegistryImpl; -import org.exoplatform.services.jcr.impl.core.SessionDataManager; -import org.exoplatform.services.jcr.impl.core.SessionImpl; -import org.exoplatform.services.jcr.impl.core.query.AbstractQueryImpl; -import org.exoplatform.services.jcr.impl.core.query.IndexException; -import org.exoplatform.services.jcr.impl.core.query.IndexingTree; -import org.exoplatform.services.jcr.impl.core.query.QueryHandler; -import org.exoplatform.services.jcr.impl.core.query.QueryHandlerContext; -import org.exoplatform.services.jcr.impl.core.query.RepositoryIndexSearcherHolder; import org.exoplatform.services.jcr.impl.core.query.SearchManager; -import org.exoplatform.services.jcr.impl.core.query.SystemSearchManagerHolder; -import org.exoplatform.services.jcr.impl.core.query.lucene.FieldNames; -import org.exoplatform.services.jcr.impl.core.query.lucene.LuceneVirtualTableResolver; -import org.exoplatform.services.jcr.impl.core.query.lucene.QueryHits; -import org.exoplatform.services.jcr.impl.core.query.lucene.ScoreNode; -import org.exoplatform.services.jcr.impl.core.query.lucene.SearchIndex; -import org.exoplatform.services.jcr.impl.core.value.NameValue; -import org.exoplatform.services.jcr.impl.core.value.PathValue; -import org.exoplatform.services.jcr.impl.core.value.ValueFactoryImpl; -import org.exoplatform.services.jcr.impl.dataflow.AbstractValueData; -import org.exoplatform.services.jcr.impl.dataflow.persistent.WorkspacePersistentDataManager; import org.exoplatform.services.jcr.impl.storage.jbosscache.AbstractWriteOnlyCacheLoader; import org.exoplatform.services.log.ExoLogger; import org.exoplatform.services.log.Log; @@ -65,27 +25,12 @@ import org.jboss.cache.Fqn; import org.jboss.cache.Modification; -import java.io.IOException; -import java.lang.reflect.Constructor; -import java.lang.reflect.InvocationTargetException; -import java.util.ArrayList; -import java.util.Collection; import java.util.HashMap; import java.util.HashSet; -import java.util.Iterator; import java.util.List; import java.util.Map; -import java.util.NoSuchElementException; import java.util.Set; -import java.util.StringTokenizer; -import javax.jcr.Node; -import javax.jcr.PropertyType; -import javax.jcr.RepositoryException; -import javax.jcr.Value; -import javax.jcr.query.InvalidQueryException; -import javax.jcr.query.Query; - /** * Created by The eXo Platform SAS. * @@ -94,100 +39,23 @@ * @author <a href=&quot;karpenko.sergiy(a)gmail.com&quot;&gt;Karpenko Sergiy</a> * @version $Id: CacheIndexer.java 111 2008-11-11 11:11:11Z serg $ */ -public class IndexerCacheLoader extends AbstractWriteOnlyCacheLoader implements SearchManager +public class IndexerCacheLoader extends AbstractWriteOnlyCacheLoader { + /** * Logger instance for this class */ private static final Log log = ExoLogger.getLogger(IndexerCacheLoader.class); - protected QueryHandlerEntry config; + SearchManager searchManager = null; - /** - * Text extractor for extracting text content of binary properties. - */ - protected DocumentReaderService extractor; - - /** - * QueryHandler where query execution is delegated to - */ - protected QueryHandler handler; - - /** - * The shared item state manager instance for the workspace. - */ - protected ItemDataConsumer itemMgr; - - /** - * The namespace registry of the repository. - */ - protected NamespaceRegistryImpl nsReg; - - /** - * The node type registry. - */ - protected NodeTypeDataManager nodeTypeDataManager; - - /** - * QueryHandler of the parent search manager or <code>null</code> if there - * is none. - */ - protected SearchManager parentSearchManager; - - // protected QPath indexingRoot; - // - // protected List<QPath> excludedPaths = new ArrayList<QPath>(); - - protected IndexingTree indexingTree; - - private ConfigurationManager cfm; - - protected LuceneVirtualTableResolver virtualTableResolver; - public IndexerCacheLoader() { - int i = 0; - i++; } - /** - * Creates a new <code>SearchManager</code>. - * - * @param config - * the search configuration. - * @param nsReg - * the namespace registry. - * @param ntReg - * the node type registry. - * @param itemMgr - * the shared item state manager. - * @param rootNodeId - * the id of the root node. - * @param parentMgr - * the parent search manager or <code>null</code> if there is no - * parent search manager. - * @param excludedNodeId - * id of the node that should be excluded from indexing. Any - * descendant of that node will also be excluded from indexing. - * @throws RepositoryException - * if the search manager cannot be initialized - * @throws RepositoryConfigurationException - */ - public IndexerCacheLoader(QueryHandlerEntry config, NamespaceRegistryImpl nsReg, NodeTypeDataManager ntReg, - WorkspacePersistentDataManager itemMgr, SystemSearchManagerHolder parentSearchManager, - DocumentReaderService extractor, ConfigurationManager cfm, final RepositoryIndexSearcherHolder indexSearcherHolder) - throws RepositoryException, RepositoryConfigurationException + public void registerSearchManager(SearchManager manager) { - - this.extractor = extractor; - indexSearcherHolder.addIndexSearcher(this); - this.config = config; - this.nodeTypeDataManager = ntReg; - this.nsReg = nsReg; - this.itemMgr = itemMgr; - this.cfm = cfm; - this.virtualTableResolver = new LuceneVirtualTableResolver(nodeTypeDataManager, nsReg); - this.parentSearchManager = parentSearchManager != null ? parentSearchManager.get() : null; + searchManager = manager; } private String parseUUID(Fqn fqn) @@ -210,11 +78,9 @@ @Override public void put(List<Modification> modifications) throws Exception { - if (handler == null) + if (searchManager == null) return; - long time = System.currentTimeMillis(); - // nodes that need to be removed from the index. final Set<String> removedNodes = new HashSet<String>(); // nodes that need to be added to the index. @@ -373,607 +239,13 @@ // } // } - // TODO make quick changes for (String uuid : updatedNodes.keySet()) { removedNodes.add(uuid); addedNodes.add(uuid); } - Iterator<NodeData> addedStates = new Iterator<NodeData>() - { - private final Iterator<String> iter = addedNodes.iterator(); + searchManager.updateIndex(removedNodes, addedNodes); - public boolean hasNext() - { - return iter.hasNext(); - } - - public NodeData next() - { - - // cycle till find a next or meet the end of set - do - { - String id = iter.next(); - try - { - ItemData item = itemMgr.getItemData(id); - if (item != null) - { - if (item.isNode()) - return (NodeData)item; // return node - else - log.warn("Node not found, but property " + id + ", " + item.getQPath().getAsString() - + " found. "); - } - else - log.warn("Unable to index node with id " + id + ", node does not exist."); - - } - catch (RepositoryException e) - { - log.error("Can't read next node data " + id, e); - } - } - while (iter.hasNext()); // get next if error or node not found - - return null; // we met the end of iterator set - } - - public void remove() - { - throw new UnsupportedOperationException(); - } - }; - - Iterator<String> removedIds = new Iterator<String>() - { - private final Iterator<String> iter = removedNodes.iterator(); - - public boolean hasNext() - { - return iter.hasNext(); - } - - public String next() - { - return nextNodeId(); - } - - public String nextNodeId() throws NoSuchElementException - { - return iter.next(); - } - - public void remove() - { - throw new UnsupportedOperationException(); - - } - }; - - if (removedNodes.size() > 0 || addedNodes.size() > 0) - { - try - { - handler.updateNodes(removedIds, addedStates); - } - catch (RepositoryException e) - { - log.error("Error indexing changes " + e, e); - } - catch (IOException e) - { - log.error("Error indexing changes " + e, e); - try - { - handler.logErrorChanges(removedNodes, addedNodes); - } - catch (IOException ioe) - { - log.warn("Exception occure when errorLog writed. Error log is not complete. " + ioe, ioe); - } - } - } - - if (log.isDebugEnabled()) - { - log.debug("onEvent: indexing finished in " + String.valueOf(System.currentTimeMillis() - time) + " ms."); - } - } - - /** - * Creates a query object from a node that can be executed on the workspace. - * - * @param session - * the session of the user executing the query. - * @param itemMgr - * the item manager of the user executing the query. Needed to - * return <code>Node</code> instances in the result set. - * @param node - * a node of type nt:query. - * @return a <code>Query</code> instance to execute. - * @throws InvalidQueryException - * if <code>absPath</code> is not a valid persisted query (that - * is, a node of type nt:query) - * @throws RepositoryException - * if any other error occurs. - */ - public Query createQuery(SessionImpl session, SessionDataManager sessionDataManager, Node node) - throws InvalidQueryException, RepositoryException - { - AbstractQueryImpl query = createQueryInstance(); - query.init(session, sessionDataManager, handler, node); - return query; - } - - /** - * Creates a query object that can be executed on the workspace. - * - * @param session - * the session of the user executing the query. - * @param itemMgr - * the item manager of the user executing the query. Needed to - * return <code>Node</code> instances in the result set. - * @param statement - * the actual query statement. - * @param language - * the syntax of the query statement. - * @return a <code>Query</code> instance to execute. - * @throws InvalidQueryException - * if the query is malformed or the <code>language</code> is - * unknown. - * @throws RepositoryException - * if any other error occurs. - */ - public Query createQuery(SessionImpl session, SessionDataManager sessionDataManager, String statement, - String language) throws InvalidQueryException, RepositoryException - { - AbstractQueryImpl query = createQueryInstance(); - query.init(session, sessionDataManager, handler, statement, language); - return query; - } - - /** - * just for test use only - */ - public QueryHandler getHandler() - { - return handler; - } - - public void createNewOrAdd(String key, ItemState state, Map<String, List<ItemState>> updatedNodes) - { - List<ItemState> list = updatedNodes.get(key); - if (list == null) - { - list = new ArrayList<ItemState>(); - updatedNodes.put(key, list); - } - list.add(state); - - } - - public void start() - { - - if (log.isDebugEnabled()) - log.debug("start"); - try - { - if (indexingTree == null) - { - List<QPath> excludedPath = new ArrayList<QPath>(); - // Calculating excluded node identifiers - excludedPath.add(Constants.JCR_SYSTEM_PATH); - - //if (config.getExcludedNodeIdentifers() != null) - String excludedNodeIdentifer = - config.getParameterValue(QueryHandlerParams.PARAM_EXCLUDED_NODE_IDENTIFERS, null); - if (excludedNodeIdentifer != null) - { - StringTokenizer stringTokenizer = new StringTokenizer(excludedNodeIdentifer); - while (stringTokenizer.hasMoreTokens()) - { - - try - { - ItemData excludeData = itemMgr.getItemData(stringTokenizer.nextToken()); - if (excludeData != null) - excludedPath.add(excludeData.getQPath()); - } - catch (RepositoryException e) - { - log.warn(e.getLocalizedMessage()); - } - } - } - - NodeData indexingRootData = null; - String rootNodeIdentifer = config.getParameterValue(QueryHandlerParams.PARAM_ROOT_NODE_ID, null); - if (rootNodeIdentifer != null) - { - try - { - ItemData indexingRootDataItem = itemMgr.getItemData(rootNodeIdentifer); - if (indexingRootDataItem != null && indexingRootDataItem.isNode()) - indexingRootData = (NodeData)indexingRootDataItem; - } - catch (RepositoryException e) - { - log.warn(e.getLocalizedMessage() + " Indexing root set to " + Constants.ROOT_PATH.getAsString()); - - } - - } - else - { - try - { - indexingRootData = (NodeData)itemMgr.getItemData(Constants.ROOT_UUID); - } - catch (RepositoryException e) - { - log.error("Fail to load root node data"); - } - } - - indexingTree = new IndexingTree(indexingRootData, excludedPath); - } - - initializeQueryHandler(); - } - catch (RepositoryException e) - { - log.error(e.getLocalizedMessage()); - handler = null; - throw new RuntimeException(e.getLocalizedMessage(), e.getCause()); - } - catch (RepositoryConfigurationException e) - { - log.error(e.getLocalizedMessage()); - handler = null; - throw new RuntimeException(e.getLocalizedMessage(), e.getCause()); - } - } - - public void stop() - { - handler.close(); - log.info("Search manager stopped"); - } - - // /** - // * Checks if the given event should be excluded based on the - // * {@link #excludePath} setting. - // * - // * @param event - // * observation event - // * @return <code>true</code> if the event should be excluded, - // * <code>false</code> otherwise - // */ - // protected boolean isExcluded(ItemState event) { - // - // for (QPath excludedPath : excludedPaths) { - // if (event.getData().getQPath().isDescendantOf(excludedPath) - // || event.getData().getQPath().equals(excludedPath)) - // return true; - // } - // - // return !event.getData().getQPath().isDescendantOf(indexingRoot) - // && !event.getData().getQPath().equals(indexingRoot); - // } - - protected QueryHandlerContext createQueryHandlerContext(QueryHandler parentHandler) - throws RepositoryConfigurationException - { - - QueryHandlerContext context = - new QueryHandlerContext(itemMgr, indexingTree, nodeTypeDataManager, nsReg, parentHandler, getIndexDir(), - extractor, true, virtualTableResolver); - return context; - } - - protected String getIndexDir() throws RepositoryConfigurationException - { - String dir = config.getParameterValue(QueryHandlerParams.PARAM_INDEX_DIR, null); - if (dir == null) - { - log.warn(QueryHandlerParams.PARAM_INDEX_DIR + " parameter not found. Using outdated parameter name " - + QueryHandlerParams.OLD_PARAM_INDEX_DIR); - dir = config.getParameterValue(QueryHandlerParams.OLD_PARAM_INDEX_DIR); - } - return dir; - } - - /** - * Initializes the query handler. - * - * @throws RepositoryException - * if the query handler cannot be initialized. - * @throws RepositoryConfigurationException - * @throws ClassNotFoundException - */ - protected void initializeQueryHandler() throws RepositoryException, RepositoryConfigurationException - { - // initialize query handler - String className = config.getType(); - if (className == null) - throw new RepositoryConfigurationException("Content hanler configuration fail"); - - try - { - Class qHandlerClass = Class.forName(className, true, this.getClass().getClassLoader()); - Constructor constuctor = qHandlerClass.getConstructor(QueryHandlerEntry.class, ConfigurationManager.class); - handler = (QueryHandler)constuctor.newInstance(config, cfm); - QueryHandler parentHandler = (this.parentSearchManager != null) ? parentSearchManager.getHandler() : null; - QueryHandlerContext context = createQueryHandlerContext(parentHandler); - handler.init(context); - - } - catch (SecurityException e) - { - throw new RepositoryException(e.getMessage(), e); - } - catch (IllegalArgumentException e) - { - throw new RepositoryException(e.getMessage(), e); - } - catch (ClassNotFoundException e) - { - throw new RepositoryException(e.getMessage(), e); - } - catch (NoSuchMethodException e) - { - throw new RepositoryException(e.getMessage(), e); - } - catch (InstantiationException e) - { - throw new RepositoryException(e.getMessage(), e); - } - catch (IllegalAccessException e) - { - throw new RepositoryException(e.getMessage(), e); - } - catch (InvocationTargetException e) - { - throw new RepositoryException(e.getMessage(), e); - } - catch (IOException e) - { - throw new RepositoryException(e.getMessage(), e); - } - } - - /** - * Creates a new instance of an {@link AbstractQueryImpl} which is not - * initialized. - * - * @return an new query instance. - * @throws RepositoryException - * if an error occurs while creating a new query instance. - */ - protected AbstractQueryImpl createQueryInstance() throws RepositoryException - { - try - { - String queryImplClassName = handler.getQueryClass(); - Object obj = Class.forName(queryImplClassName).newInstance(); - if (obj instanceof AbstractQueryImpl) - { - return (AbstractQueryImpl)obj; - } - else - { - throw new IllegalArgumentException(queryImplClassName + " is not of type " - + AbstractQueryImpl.class.getName()); - } - } - catch (Throwable t) - { - throw new RepositoryException("Unable to create query: " + t.toString(), t); - } - } - - /** - * {@inheritDoc} - */ - public Set<String> getFieldNames() throws IndexException - { - final Set<String> fildsSet = new HashSet<String>(); - if (handler instanceof SearchIndex) - { - IndexReader reader = null; - try - { - reader = ((SearchIndex)handler).getIndexReader(); - final Collection fields = reader.getFieldNames(IndexReader.FieldOption.ALL); - for (final Object field : fields) - { - fildsSet.add((String)field); - } - } - catch (IOException e) - { - throw new IndexException(e.getLocalizedMessage(), e); - } - finally - { - try - { - if (reader != null) - reader.close(); - } - catch (IOException e) - { - throw new IndexException(e.getLocalizedMessage(), e); - } - } - - } - return fildsSet; - } - - public Set<String> getNodesByNodeType(final InternalQName nodeType) throws RepositoryException - { - - return getNodes(virtualTableResolver.resolve(nodeType, true)); - } - - /** - * Return set of uuid of nodes. Contains in names prefixes maped to the - * given uri - * - * @param prefix - * @return - * @throws RepositoryException - */ - public Set<String> getNodesByUri(final String uri) throws RepositoryException - { - Set<String> result; - final int defaultClauseCount = BooleanQuery.getMaxClauseCount(); - try - { - - // final LocationFactory locationFactory = new - // LocationFactory(this); - final ValueFactoryImpl valueFactory = new ValueFactoryImpl(new LocationFactory(nsReg)); - BooleanQuery.setMaxClauseCount(Integer.MAX_VALUE); - BooleanQuery query = new BooleanQuery(); - - final String prefix = nsReg.getNamespacePrefixByURI(uri); - query.add(new WildcardQuery(new Term(FieldNames.LABEL, prefix + ":*")), Occur.SHOULD); - // name of the property - query.add(new WildcardQuery(new Term(FieldNames.PROPERTIES_SET, prefix + ":*")), Occur.SHOULD); - - result = getNodes(query); - - // value of the property - - try - { - final Set<String> props = getFieldNames(); - - query = new BooleanQuery(); - for (final String fieldName : props) - { - if (!FieldNames.PROPERTIES_SET.equals(fieldName)) - { - query.add(new WildcardQuery(new Term(fieldName, "*" + prefix + ":*")), Occur.SHOULD); - } - } - } - catch (final IndexException e) - { - throw new RepositoryException(e.getLocalizedMessage(), e); - } - - final Set<String> propSet = getNodes(query); - // Manually check property values; - for (final String uuid : propSet) - { - if (isPrefixMatch(valueFactory, uuid, prefix)) - { - result.add(uuid); - } - } - } - finally - { - BooleanQuery.setMaxClauseCount(defaultClauseCount); - } - - return result; - } - - private boolean isPrefixMatch(final InternalQName value, final String prefix) throws RepositoryException - { - return value.getNamespace().equals(nsReg.getNamespaceURIByPrefix(prefix)); - } - - private boolean isPrefixMatch(final QPath value, final String prefix) throws RepositoryException - { - for (int i = 0; i < value.getEntries().length; i++) - { - if (isPrefixMatch(value.getEntries()[i], prefix)) - { - return true; - } - } - return false; - } - - /** - * @param valueFactory - * @param dm - * @param uuid - * @param prefix - * @throws RepositoryException - */ - private boolean isPrefixMatch(final ValueFactoryImpl valueFactory, final String uuid, final String prefix) - throws RepositoryException - { - - final ItemData node = itemMgr.getItemData(uuid); - if (node != null && node.isNode()) - { - final List<PropertyData> props = itemMgr.getChildPropertiesData((NodeData)node); - for (final PropertyData propertyData : props) - { - if (propertyData.getType() == PropertyType.PATH || propertyData.getType() == PropertyType.NAME) - { - for (final ValueData vdata : propertyData.getValues()) - { - final Value val = - valueFactory.loadValue(((AbstractValueData)vdata).createTransientCopy(), propertyData.getType()); - if (propertyData.getType() == PropertyType.PATH) - { - if (isPrefixMatch(((PathValue)val).getQPath(), prefix)) - { - return true; - } - } - else if (propertyData.getType() == PropertyType.NAME) - { - if (isPrefixMatch(((NameValue)val).getQName(), prefix)) - { - return true; - } - } - } - } - } - } - return false; - } - - /** - * @param query - * @return - * @throws RepositoryException - */ - private Set<String> getNodes(final org.apache.lucene.search.Query query) throws RepositoryException - { - Set<String> result = new HashSet<String>(); - try - { - QueryHits hits = handler.executeQuery(query); - - ScoreNode sn; - - while ((sn = hits.nextScoreNode()) != null) - { - // Node node = session.getNodeById(sn.getNodeId()); - result.add(sn.getNodeId()); - } - } - catch (IOException e) - { - throw new RepositoryException(e.getLocalizedMessage(), e); - } - return result; - } - }