Examples of QueryHandler


Examples of com.hp.hpl.jena.graph.query.QueryHandler

    Sink<Pair<Node, Map<Node, Set<Node>>>> sink = new SinkEntityOutput(out, prologue, SyntaxLabels.createNodeToLabel()) ;
    write ( sink, graph ) ;
  }

  private static void write (Sink<Pair<Node, Map<Node, Set<Node>>>> sink, Graph graph) {
    QueryHandler queryHandler = graph.queryHandler() ;
    ExtendedIterator<Node> subjects = queryHandler.subjectsFor(Node.ANY, Node.ANY) ;
    try {
      Map<Node, Set<Node>> predicates = new HashMap<Node, Set<Node>>() ;
      while ( subjects.hasNext() ) {
        Node subject = subjects.next() ;
        ExtendedIterator<Triple> triples = graph.find(subject, Node.ANY, Node.ANY) ;
View Full Code Here

Examples of com.ikanow.infinit.e.api.knowledge.QueryHandler

    }
    //TESTED (entire block)
   
    // 3) run saved query:
   
    QueryHandler queryHandler = new QueryHandler();
   
    StringBuffer errorString = new StringBuffer();
    StringBuffer communityIdStrList = new StringBuffer();
    for (ObjectId commId: savedQuery.getQueryInfo().getQuery().communityIds) {
      if (communityIdStrList.length() > 0) {
        communityIdStrList.append(',');
      }
      communityIdStrList.append(commId.toString());
    }//TESTED
   
    try {
      //DEBUG
      //System.out.println("COMMS="+communityIdStrList.toString() + ": QUERY=" + query.toApi());
     
      // (should have a version of this that just returns the IPs from the index engine)
      // (for now this will do)
      ResponsePojo rp = queryHandler.doQuery(savedQuery._parentShare.getOwner().get_id().toString(),
          query, communityIdStrList.toString(), errorString);
     
      if (null == rp) {
        throw new RuntimeException(errorString.toString()); // (handled below)
      }
View Full Code Here

Examples of org.apache.cassandra.cql3.QueryHandler

    public Message.Response execute(QueryState state)
    {
        try
        {
            QueryHandler handler = state.getClientState().getCQLQueryHandler();
            ParsedStatement.Prepared prepared = handler.getPrepared(statementId);
            if (prepared == null)
                throw new PreparedQueryNotFoundException(statementId);

            options.prepare(prepared.boundNames);
            CQLStatement statement = prepared.statement;

            if (options.getPageSize() == 0)
                throw new ProtocolException("The page size cannot be 0");

            UUID tracingId = null;
            if (isTracingRequested())
            {
                tracingId = UUIDGen.getTimeUUID();
                state.prepareTracingSession(tracingId);
            }

            if (state.traceNextQuery())
            {
                state.createTracingSession();

                ImmutableMap.Builder<String, String> builder = ImmutableMap.builder();
                if (options.getPageSize() > 0)
                    builder.put("page_size", Integer.toString(options.getPageSize()));

                // TODO we don't have [typed] access to CQL bind variables here.  CASSANDRA-4560 is open to add support.
                Tracing.instance.begin("Execute CQL3 prepared query", builder.build());
            }

            Message.Response response = handler.processPrepared(statement, state, options);
            if (options.skipMetadata() && response instanceof ResultMessage.Rows)
                ((ResultMessage.Rows)response).result.metadata.setSkipMetadata();

            if (tracingId != null)
                response.setTracingId(tracingId);
View Full Code Here

Examples of org.apache.cxf.transports.http.QueryHandler

                            EndpointInfo ei = d.getEndpointInfo();
                            String ctxUri = request.getPathInfo();
                            String baseUri = request.getRequestURL().toString()
                                + "?" + request.getQueryString();
   
                            QueryHandler selectedHandler =
                                findQueryHandler(queryHandlerRegistry, ei, ctxUri, baseUri);
                           
                            if (selectedHandler != null) {
                                respondUsingQueryHandler(selectedHandler, res, ei, ctxUri, baseUri);
                                return true;
View Full Code Here

Examples of org.apache.cxf.transports.http.QueryHandler

    private void setUpQuery() throws Exception {
        QueryHandlerRegistry qrh =
            control.createMock(QueryHandlerRegistry.class);
        EasyMock.expect(bus.getExtension(QueryHandlerRegistry.class)).andReturn(qrh).anyTimes();
        QueryHandler qh = control.createMock(QueryHandler.class);
        List<QueryHandler> handlers = new ArrayList<QueryHandler>();
        handlers.add(qh);
        EasyMock.expect(qrh.getHandlers()).andReturn(handlers);
        String base = ROOT + URI + "?" + QUERY;
        EasyMock.expect(qh.isRecognizedQuery(EasyMock.eq(base),
                                             EasyMock.eq(PATH),
                                             EasyMock.same(endpoint))).andReturn(Boolean.TRUE);
        EasyMock.expect(qh.getResponseContentType(EasyMock.eq(base),
                                                  EasyMock.eq(PATH))).andReturn(XML);
        ServletOutputStream sos = control.createMock(ServletOutputStream.class);
        EasyMock.expect(response.getOutputStream()).andReturn(sos);
        qh.writeResponse(EasyMock.eq(base), EasyMock.eq(PATH), EasyMock.same(endpoint), EasyMock.same(sos));
        EasyMock.expectLastCall();
        sos.flush();
        EasyMock.expectLastCall();
    }
View Full Code Here

Examples of org.apache.cxf.transports.http.QueryHandler

                       
                        String ctxUri = request.getPathInfo();
                        String baseUri = request.getRequestURL().toString()
                            + "?" + request.getQueryString();

                        QueryHandler selectedHandler =
                            findQueryHandler(queryHandlerRegistry, ei, ctxUri, baseUri);
                       
                        if (selectedHandler != null) {
                            respondUsingQueryHandler(selectedHandler, res, ei, ctxUri, baseUri);
                            return true;
View Full Code Here

Examples of org.apache.cxf.transports.http.QueryHandler

                       
                        String ctxUri = request.getPathInfo();
                        String baseUri = request.getRequestURL().toString()
                            + "?" + request.getQueryString();

                        QueryHandler selectedHandler =
                            findQueryHandler(queryHandlerRegistry, ei, ctxUri, baseUri);
                       
                        if (selectedHandler != null) {
                            respondUsingQueryHandler(selectedHandler, res, ei, ctxUri, baseUri);
                            return;
View Full Code Here

Examples of org.apache.cxf.transports.http.QueryHandler

    private void setUpQuery() throws Exception {
        QueryHandlerRegistry qrh =
            control.createMock(QueryHandlerRegistry.class);
        EasyMock.expect(bus.getExtension(QueryHandlerRegistry.class)).andReturn(qrh).anyTimes();
        QueryHandler qh = control.createMock(QueryHandler.class);
        List<QueryHandler> handlers = new ArrayList<QueryHandler>();
        handlers.add(qh);
        EasyMock.expect(qrh.getHandlers()).andReturn(handlers);
        String base = ROOT + URI + "?" + QUERY;
        EasyMock.expect(qh.isRecognizedQuery(EasyMock.eq(base),
                                             EasyMock.eq(PATH),
                                             EasyMock.same(endpoint))).andReturn(Boolean.TRUE);
        EasyMock.expect(qh.getResponseContentType(EasyMock.eq(base),
                                                  EasyMock.eq(PATH))).andReturn(XML);
        ServletOutputStream sos = control.createMock(ServletOutputStream.class);
        EasyMock.expect(response.getOutputStream()).andReturn(sos);
        qh.writeResponse(EasyMock.eq(base), EasyMock.eq(PATH), EasyMock.same(endpoint), EasyMock.same(sos));
        EasyMock.expectLastCall();
        sos.flush();
        EasyMock.expectLastCall();
    }
View Full Code Here

Examples of org.apache.jackrabbit.core.query.QueryHandler

    public QueryHits executeQuery(QueryImpl queryImpl,
                                  Query query,
                                  QName[] orderProps,
                                  boolean[] orderSpecs) throws IOException {
        checkOpen();
        QueryHandler parentHandler = getContext().getParentHandler();
        IndexReader parentReader = null;
        if (parentHandler instanceof SearchIndex) {
            parentReader = ((SearchIndex) parentHandler).index.getIndexReader();
        }
View Full Code Here

Examples of org.apache.jackrabbit.core.query.QueryHandler

                        String className = getAttribute(
                                element, CLASS_ATTRIBUTE, DEFAULT_QUERY_HANDLER);
                        BeanConfig config = new BeanConfig(
                                className, parseParameters(element));

                        QueryHandler handler =
                            (QueryHandler) config.newInstance();
                        try {
                            handler.init(fs, context);
                            return handler;
                        } catch (IOException e) {
                            throw new RepositoryException(
                                    "Unable to initialize query handler: " + handler, e);
                        }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.