Examples of org.apache.maven.index.FlatSearchResponse

org.apache.maven.index.FlatSearchResponse
A flat search response. @see Indexer#searchFlat(FlatSearchRequest)

        //    Occur.SHOULD );


        FlatSearchRequest flatSearchRequest =
            new FlatSearchRequest( q, indexer.getIndexingContexts().get( repositoryConfig.getId() ) );


        FlatSearchResponse response = indexer.searchFlat( flatSearchRequest );


        assertTrue( new File( repositoryConfig.getLocation(), ".indexer" ).exists() );
        assertFalse( new File( repositoryConfig.getLocation(), ".index" ).exists() );


        // should return 1 hit
        assertEquals( 1, response.getTotalHitsCount() );


        // remove added artifact from index
        task = new ArtifactIndexingTask( repositoryConfig, artifactFile, ArtifactIndexingTask.Action.DELETE,
                                         getIndexingContext() );
        indexingExecutor.executeTask( task );


        task = new ArtifactIndexingTask( repositoryConfig, artifactFile, ArtifactIndexingTask.Action.FINISH,
                                         getIndexingContext() );
        indexingExecutor.executeTask( task );


        q = new BooleanQuery();
        q.add( indexer.constructQuery( MAVEN.GROUP_ID, new SourcedSearchExpression( "org.apache.archiva" ) ),
               Occur.SHOULD );
        q.add( indexer.constructQuery( MAVEN.ARTIFACT_ID,
                                       new SourcedSearchExpression( "archiva-index-methods-jar-test" ) ),
               Occur.SHOULD );


        assertTrue( new File( repositoryConfig.getLocation(), ".indexer" ).exists() );
        assertFalse( new File( repositoryConfig.getLocation(), ".index" ).exists() );


        flatSearchRequest = new FlatSearchRequest( q, getIndexingContext() );


        response = indexer.searchFlat( flatSearchRequest );
        // artifact should have been removed from the index!
        assertEquals( 0, response.getTotalHitsCount() );//.totalHits );


        // TODO: test it was removed from the packaged index also
    }

View Full Code Here

        q.add(
            indexer.constructQuery( MAVEN.ARTIFACT_ID, new StringSearchExpression( "archiva-index-methods-jar-test" ) ),
            Occur.SHOULD );


        FlatSearchRequest request = new FlatSearchRequest( q, getIndexingContext() );
        FlatSearchResponse response = indexer.searchFlat( request );


        Set<ArtifactInfo> results = response.getResults();


        ArtifactInfo artifactInfo = results.iterator().next();
        assertEquals( "org.apache.archiva", artifactInfo.groupId );
        assertEquals( "archiva-index-methods-jar-test", artifactInfo.artifactId );
        assertEquals( "test-repo", artifactInfo.repository );


        assertEquals( 1, response.getTotalHits() );
    }

View Full Code Here

                            {
                                q.add( nexusIndexer.constructQuery( MAVEN.PACKAGING, new SourcedSearchExpression(
                                    ac.getArtifactInfo().packaging ) ), BooleanClause.Occur.MUST );
                            }
                            FlatSearchRequest flatSearchRequest = new FlatSearchRequest( q, context );
                            FlatSearchResponse flatSearchResponse = nexusIndexer.searchFlat( flatSearchRequest );
                            if ( flatSearchResponse.getResults().isEmpty() )
                            {
                                log.debug( "Adding artifact '{}' to index..", ac.getArtifactInfo() );
                                nexusIndexer.addArtifactToIndex( ac, context );
                            }
                            else

View Full Code Here

                            {
                                q.add( nexusIndexer.constructQuery( MAVEN.PACKAGING, new SourcedSearchExpression(
                                    ac.getArtifactInfo().packaging ) ), BooleanClause.Occur.MUST );
                            }
                            FlatSearchRequest flatSearchRequest = new FlatSearchRequest( q, context );
                            FlatSearchResponse flatSearchResponse = nexusIndexer.searchFlat( flatSearchRequest );
                            if ( flatSearchResponse.getResults().isEmpty() )
                            {
                                log.debug( "Adding artifact '{}' to index..", ac.getArtifactInfo() );
                                nexusIndexer.addArtifactToIndex( ac, context );
                            }
                            else

View Full Code Here

  public FlatSearchResponse searchArtifactFlat(String gTerm, String aTerm, String vTerm, String pTerm, String cTerm,
                                               String repositoryId, Integer from, Integer count, Integer hitLimit)
      throws NoSuchRepositoryException
  {
    if (gTerm == null && aTerm == null && vTerm == null) {
      return new FlatSearchResponse(null, -1, new HashSet<ArtifactInfo>());
    }


    BooleanQuery bq = new BooleanQuery();


    if (gTerm != null) {

View Full Code Here

      throws NoSuchRepositoryException
  {
    LockedIndexingContexts lockedContexts = lockSearchTargetIndexingContexts(repositoryId);


    if (lockedContexts == null) {
      return new FlatSearchResponse(req.getQuery(), 0, Collections.<ArtifactInfo>emptySet());
    }


    try {
      req.getContexts().addAll(lockedContexts.contexts.values());


      FlatSearchResponse result = mavenIndexer.searchFlat(req);


      postprocessResults(result.getResults());


      return result;
    }
    catch (BooleanQuery.TooManyClauses e) {
      if (log.isDebugEnabled()) {
        log.debug("Too many clauses exception caught:", e);
      }


      // XXX: a hack, I am sending too many results by setting the totalHits value to -1!
      return new FlatSearchResponse(req.getQuery(), -1, new HashSet<ArtifactInfo>());
    }
    catch (IOException e) {
      log.error("Got I/O exception while searching for query \"" + req.getQuery() + "\"", e);


      return new FlatSearchResponse(req.getQuery(), 0, new HashSet<ArtifactInfo>());
    }
    finally {
      lockedContexts.lock.unlock();
    }
  }

View Full Code Here

        try
        {
            FlatSearchRequest request = new FlatSearchRequest( q );
            request.setContexts( getIndexingContexts( indexingContextIds ) );


            FlatSearchResponse response = indexer.searchFlat( request );


            if ( response == null || response.getTotalHits() == 0 )
            {
                SearchResults results = new SearchResults();
                results.setLimits( limits );
                return results;
            }

View Full Code Here

                            {
                                q.add( nexusIndexer.constructQuery( MAVEN.PACKAGING, new SourcedSearchExpression(
                                    ac.getArtifactInfo().packaging ) ), BooleanClause.Occur.MUST );
                            }
                            FlatSearchRequest flatSearchRequest = new FlatSearchRequest( q, context );
                            FlatSearchResponse flatSearchResponse = nexusIndexer.searchFlat( flatSearchRequest );
                            if ( flatSearchResponse.getResults().isEmpty() )
                            {
                                log.debug( "Adding artifact '{}' to index..", ac.getArtifactInfo() );
                                nexusIndexer.addArtifactToIndex( ac, context );
                            }
                            else

View Full Code Here


        FlatSearchRequest rq = new FlatSearchRequest( iQuery );
        rq.setContexts(
            Arrays.asList( nexusIndexer.getIndexingContexts().get( "remote-" + getRemoteRepository().getId() ) ) );


        FlatSearchResponse response = nexusIndexer.searchFlat( rq );


        log.info( "returned hit count:" + response.getReturnedHitsCount() );
        assertEquals( 8, response.getReturnedHitsCount() );
    }

View Full Code Here

                                                                  mavenIndexerUtils.getAllIndexCreators() );
            context.setSearchable( true );
        }


        FlatSearchRequest request = new FlatSearchRequest( q );
        FlatSearchResponse response = indexer.searchFlat( request );


        assertTrue( new File( repositoryConfig.getLocation(), ".indexer" ).exists() );
        assertFalse( new File( repositoryConfig.getLocation(), ".index" ).exists() );
        assertEquals( 1, response.getTotalHits() );


        Set<ArtifactInfo> results = response.getResults();


        ArtifactInfo artifactInfo = results.iterator().next();
        assertEquals( "org.apache.archiva", artifactInfo.groupId );
        assertEquals( "archiva-index-methods-jar-test", artifactInfo.artifactId );
        assertEquals( "test-repo", artifactInfo.repository );

View Full Code Here

0 1 2 3 4 5 6

TOP

Related Classes of org.apache.maven.index.FlatSearchResponse

org.apache.archiva.indexer.search.MavenRepositorySearch

org.apache.archiva.indexer.search.NexusRepositorySearch

org.apache.archiva.scheduler.indexing.ArchivaIndexingTaskExecutor

org.apache.archiva.scheduler.indexing.ArchivaIndexingTaskExecutorTest

org.apache.archiva.scheduler.indexing.DownloadRemoteIndexTaskTest

org.apache.maven.index.AbstractNexusIndexerTest

org.apache.maven.index.archetype.AbstractArchetypeDataSource

org.apache.maven.index.cli.AbstractNexusIndexerCliTest

org.apache.maven.index.creator.OsgiArtifactIndexCreatorTest

org.apache.maven.index.DefaultIndexNexusIndexerTest

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.