import org.exist.dom.QName; //导入依赖的package包/类
@Override
public IntermediateExpr visitComplexQuery(final ComplexQueryContext ctx) {
    if(ctx.queryOperator() != null) {
        final QName qnQueryOperator = toQName(ctx.queryOperator());
        builder.startElement(qnQueryOperator, null);
    }

    visit(ctx.simpleQuery());

    if(ctx.queryOperator() != null) {
        visit(ctx.complexQuery());
        builder.endElement();
    }

    return null;
}
 

import org.exist.dom.QName; //导入依赖的package包/类
@Override
public IntermediateExpr visitSimpleQuery(final SimpleQueryContext ctx) {
    if(ctx.booleanOperator() != null) {
        final QName qnBooleanOperator = toQName(ctx.booleanOperator());
        builder.startElement(qnBooleanOperator, null);
    }

    visit(ctx.sequence());

    if(ctx.booleanOperator() != null) {
        visit(ctx.simpleQuery());
        builder.endElement();
    }

    return null;
}
 

import org.exist.dom.QName; //导入依赖的package包/类
@Override
public IntermediateExpr visitPositionLong(final PositionLongContext ctx) {
    if(ctx.booleanOperator() != null) {
        final QName qnBooleanOperator = toQName(ctx.booleanOperator());
        builder.startElement(qnBooleanOperator, null);
    }

    visit(ctx.positionLongPart());

    if(ctx.booleanOperator() != null) {
        visit(ctx.positionLong());
        builder.endElement();
    }

    return null;
}
 

import org.exist.dom.QName; //导入依赖的package包/类
/**
 * Creates a failure document based on the failure result from the weather web-service
 *
 * @param response The response from the weather web-service call
 *
 * @return An in-memory document representing the failure
 */
private final org.exist.memtree.DocumentImpl createFailureDoc(final ClientResponse response) throws JobException {
    try {
        final MemTreeBuilder builder = new MemTreeBuilder();
        builder.startDocument();

        final DatatypeFactory datatypeFactory = DatatypeFactory.newInstance();
        final XMLGregorianCalendar xmlCal = datatypeFactory.newXMLGregorianCalendar(new GregorianCalendar());

        final AttributesImpl attribs = new AttributesImpl();
        final ClientResponse.Status status = response.getClientResponseStatus();
        attribs.addAttribute(null, "at", "at", "string", xmlCal.toXMLFormat());
        attribs.addAttribute(null, "http-status", "http-status", "string", String.valueOf(status.getStatusCode()));
        attribs.addAttribute(null, "http-reason", "http-status", "string", String.valueOf(status.getReasonPhrase()));

        builder.startElement(new QName("failed"), attribs);
        builder.characters(response.getEntity(String.class));
        builder.endElement();
        builder.endDocument();

        return builder.getDocument();
    } catch(final DatatypeConfigurationException dce) {
        final String msg = "Unable to configure XML DatatypeFactory: " + dce.getMessage();
        throw new JobException(JobException.JobExceptionAction.JOB_ABORT_THIS, msg);
    }
}
 

import org.exist.dom.QName; //导入依赖的package包/类
@Override
public IntermediateExpr visitValueWith(final ValueWithContext ctx) {
    final QName qnBooleanOperator = toQName(ctx.booleanOperator());
    builder.startElement(qnBooleanOperator, null);

    visit(ctx.valuePart());
    visit(ctx.value());

    builder.endElement();

    return null;
}
 

import org.exist.dom.QName; //导入依赖的package包/类
private QName toQName(final QueryOperatorContext queryOperatorContext) {
    final IntermediateExpr queryOperator = visit(queryOperatorContext);
    final QName qnQueryOperator;
    if (queryOperator == WITHIN) {
        qnQueryOperator = QN_WITHIN;
    } else if (queryOperator == CONTAINING) {
        qnQueryOperator = QN_CONTAINING;
    } else {
        throw new IllegalStateException("Unknown queryOperator: " + queryOperator);
    }

    return qnQueryOperator;
}
 

import org.exist.dom.QName; //导入依赖的package包/类
@Override
public void execute(final DBBroker broker) throws EXistException {

    try {

        //setup an output document
        final MemTreeBuilder builder = new MemTreeBuilder();
        builder.startDocument();

        final DatatypeFactory datatypeFactory = DatatypeFactory.newInstance();
        final XMLGregorianCalendar xmlCal = datatypeFactory.newXMLGregorianCalendar(new GregorianCalendar());

        final AttributesImpl attribs = new AttributesImpl();
        attribs.addAttribute(null, "timestamp", "timestamp", "string", xmlCal.toXMLFormat());
        builder.startElement(new QName("stats"), attribs);

        //collect stats
        collectStats(broker, XmldbURI.DB, builder);

        //finalise output document
        builder.endElement();
        builder.endDocument();

        //store stats document
        storeDocument(broker, statsCollection, builder.getDocument(), false);

    } catch(final DatatypeConfigurationException dce) {
        final String msg = "Unable to configure XML DatatypeFactory: " + dce.getMessage();
        LOG.error(msg, dce);
        throw new EXistException(msg, dce);
    } catch(final PermissionDeniedException pde) {
        LOG.error(pde);
        throw new EXistException(pde);
    } catch(final StoreException se) {
        LOG.error(se);
        throw new EXistException(se);
    }
}
 

import org.exist.dom.QName; //导入依赖的package包/类
/**
 * Collects statistics about a Collection and its documents and sub-collections recursively
 * writes the results to the builder
 *
 * @param broker The database broker to use to access the database
 * @param collUri The absolute database URI of the collection to generate statistics for
 * @param builder The builder to write the statistics output to
 */
private void collectStats(final DBBroker broker, final XmldbURI collUri, final MemTreeBuilder builder) throws PermissionDeniedException {

    final Collection collection = broker.getCollection(collUri);

    final AttributesImpl attribs = new AttributesImpl();
    attribs.addAttribute(null, "name", "name", "string", collection.getURI().lastSegment().toString());
    attribs.addAttribute(null, "uri", "uri", "string", collection.getURI().toString());
    attribs.addAttribute(null, "sub-collections", "sub-collections", "string", Integer.toString(collection.getChildCollectionCount(broker)));
    attribs.addAttribute(null, "documents", "documents", "string", Integer.toString(collection.getDocumentCountNoLock(broker)));

    builder.startElement(new QName("collection"), attribs);

    final Iterator<DocumentImpl> itDocs = collection.iteratorNoLock(broker);
    while(itDocs.hasNext()) {
        final DocumentImpl doc = itDocs.next();

        final AttributesImpl docAttribs = new AttributesImpl();
        docAttribs.addAttribute(null, "name", "name", "string", doc.getURI().lastSegment().toString());
        docAttribs.addAttribute(null, "uri", "uri", "string", doc.getURI().toString());
        docAttribs.addAttribute(null, "nodes", "nodes", "string", Long.toString(countNodes(doc)));

        builder.startElement(new QName("document"), docAttribs);
        builder.endElement();
    }

    final Iterator<XmldbURI> itColls = collection.collectionIteratorNoLock(broker);
    while(itColls.hasNext()) {
        final XmldbURI childCollUri = collUri.append(itColls.next());
        collectStats(broker, childCollUri, builder);
    }

    builder.endElement();
}
 

import org.exist.dom.QName; //导入依赖的package包/类
/**
 * Constructs the in-memory XML document:
 * <hello>world</hello>
 *
 * @return The in-memory XML document
 */
private Sequence sayHelloWorld() {
    final MemTreeBuilder builder = new MemTreeBuilder();
    builder.startDocument();
    builder.startElement(new QName("hello", HelloModule.NS, HelloModule.NS_PREFIX), null);
    builder.characters("world");
    builder.endElement();
    builder.endDocument();

    return builder.getDocument();
}
 

import org.exist.dom.QName; //导入依赖的package包/类
@Override
public void execute(final DBBroker sysBroker, final Map<String, List<? extends Object>> params) {

    //get the target parameter for where to store the modules summary
    final List<? extends Object> maybeTarget = params.get("target");
    if(maybeTarget == null || maybeTarget.size() != 1) {
        LOG.error("Missing 'target' parameter which provides the database uri for storing the modules summary!");
        return;

    } else {
        final String target = (String)maybeTarget.get(0);

        //start a document
        final MemTreeBuilder builder = new MemTreeBuilder();
        builder.startDocument();
        builder.startElement(new QName("modules-summary"), null);

        //get java modules info into document
        final Configuration existConf = sysBroker.getConfiguration();
        buildModulesSummary(existConf, builder);

        //finish document
        builder.endElement();
        builder.endDocument();

        //store document
        storeDocument(sysBroker, XmldbURI.create(target), builder.getDocument());
    }
}
 

import org.exist.dom.QName; //导入依赖的package包/类
/**
 * Writes a summary of a module to the builder
 *
 * @param configuredModule The configured module. key is the URI, value is the implementing class.
 * @param builder The builder for writing out the summary
 */
private void buildModuleSummary(final  Map.Entry<String, Class<?>> configuredModule, final MemTreeBuilder builder) {

    //instantiate an instance of the module
    final Class<InternalModule> moduleClass = (Class<InternalModule>)configuredModule.getValue();
    final Constructor ctr = moduleClass.getConstructors()[0];
    final Object[] ctrParams = new Object[ctr.getParameterTypes().length];

    AttributesImpl attribs;
    String description = null;
    try {
        final InternalModule module = (InternalModule)ctr.newInstance(ctrParams);
        attribs = new AttributesImpl();
        attribs.addAttribute(null, "prefix", "prefix", "string", module.getDefaultPrefix());
        attribs.addAttribute(null, "uri", "uri", "string", module.getNamespaceURI());
        attribs.addAttribute(null, "class", "class", "string", moduleClass.getName());
        attribs.addAttribute(null, "released-in", "released-in", "string", module.getReleaseVersion());

        description = module.getDescription();

    } catch(final Exception e) {
        LOG.error("Unable to build module summary for: " + moduleClass.getName(), e);

        attribs = new AttributesImpl();
        attribs.addAttribute(null, "uri", "uri", "string", configuredModule.getKey());
        attribs.addAttribute(null, "class", "class", "string", moduleClass.getName());
    }

    builder.startElement(new QName("module"), attribs);
    if(description != null) {
        builder.characters(description);
    }
    builder.endElement();
}
 

import org.exist.dom.QName; //导入依赖的package包/类
private static QName QName(final String localPart) {
    return new QName(localPart, CQLModule.CQL_MODULE_NS, CQLModule.CQL_MODULE_PREFIX);
}
 

import org.exist.dom.QName; //导入依赖的package包/类
public AttributesBuilder add(final QName name, final String value) {
    attrs.addAttribute("", name.getLocalPart(), name.getLocalPart(), "CDATA", value);
    return this;
}
 

import org.exist.dom.QName; //导入依赖的package包/类
public CouchbaseErrorCode(final String code, final String description) {
    super(new QName(code, NAMESPACE_URI, PREFIX), description);
}
 

import org.exist.dom.QName; //导入依赖的package包/类
private MARCErrorCode(final String aCode, final String aMessage) {
    super(new QName(aCode, MARCModule.NAMESPACE_URI, MARCModule.PREFIX), aMessage);
}