import org.openrdf.rio.RDFWriterRegistry; //导入依赖的package包/类
/**
 * This is needed, because Rio is unable to find the Parser/Writer Factories
 * automatically when the jar gets deployed as plugin inside the Neo4j
 * Server.
 */
private synchronized void initRio() {
	if (!rioInitialized) {
		RDFParserRegistry parserRegistry = RDFParserRegistry.getInstance();
		parserRegistry.add(new TurtleParserFactory());
		parserRegistry.add(new YARSParserFactory());
		parserRegistry.add(new RDFXMLParserFactory());
		parserRegistry.add(new NTriplesParserFactory());
		parserRegistry.add(new RDFJSONParserFactory());
		RDFWriterRegistry writerRegistry = RDFWriterRegistry.getInstance();
		writerRegistry.add(new TurtleWriterFactory());
		writerRegistry.add(new YARSWriterFactory());
		writerRegistry.add(new RDFXMLWriterFactory());
		writerRegistry.add(new NTriplesWriterFactory());
		writerRegistry.add(new RDFJSONWriterFactory());
		rioInitialized = true;
	}
}
 

import org.openrdf.rio.RDFWriterRegistry; //导入依赖的package包/类
/**
 * Get all statements and export them as RDF.
 * 
 * @param repository the Repository object
 * @param request the HttpServletRequest object
 * @param response the HttpServletResponse object
 * @return a model and view for exporting the statements.
 * @throws ClientHTTPException throws when errors in parameters 
 */
private ModelAndView getExportStatementsResult(final Repository repository, final HttpServletRequest request,
		final HttpServletResponse response)
		throws ClientHTTPException {
	ProtocolUtil.logRequestParameters(request);

	ValueFactory vf = repository.getValueFactory();

	URI graph = getGraphName(request, vf);

	RDFWriterFactory rdfWriterFactory = ProtocolUtil.getAcceptableService(request, response,
			RDFWriterRegistry.getInstance());

	Map<String, Object> model = new HashMap<String, Object>();

	model.put(ExportStatementsView.CONTEXTS_KEY, new Resource[] { graph });
	model.put(ExportStatementsView.FACTORY_KEY, rdfWriterFactory);
	model.put(ExportStatementsView.USE_INFERENCING_KEY, true);
	model.put(ExportStatementsView.HEADERS_ONLY, METHOD_HEAD.equals(request.getMethod()));
	return new ModelAndView(ExportStatementsView.getInstance(), model);
}
 

import org.openrdf.rio.RDFWriterRegistry; //导入依赖的package包/类
/**
 * This is needed, because Rio is unable to find the Parser/Writer Factories
 * automatically when the jar gets deployed as plugin inside the Neo4j
 * Server.
 */
private synchronized void initRio() {
	if (!rioInitialized) {
		RDFParserRegistry parserRegistry = RDFParserRegistry.getInstance();
		parserRegistry.add(new TurtleParserFactory());
		parserRegistry.add(new RDFXMLParserFactory());
		parserRegistry.add(new NTriplesParserFactory());
		parserRegistry.add(new RDFJSONParserFactory());
		RDFWriterRegistry writerRegistry = RDFWriterRegistry.getInstance();
		writerRegistry.add(new TurtleWriterFactory());
		writerRegistry.add(new RDFXMLWriterFactory());
		writerRegistry.add(new NTriplesWriterFactory());
		writerRegistry.add(new RDFJSONWriterFactory());
		rioInitialized = true;
	}
}
 

import org.openrdf.rio.RDFWriterRegistry; //导入依赖的package包/类
private RDFWriter createWriter(StringWriter writer) {
	RDFWriter result=null;
	if(format.equals(Format.TURTLE)) {
		result=new TurtlePrettyPrinter(new MemValueFactory().createURI(baseURI.toString()),writer);
	} else {
		RDFWriterRegistry registry=RDFWriterRegistry.getInstance();
		RDFFormat rawFormat=Rio.getWriterFormatForMIMEType(format.getMime(),RDFFormat.RDFXML);
		RDFWriterFactory factory=registry.get(rawFormat);
		result=factory.getWriter(writer);
		if(format.equals(Format.JSON_LD)) {
			result.getWriterConfig().set(JSONLDSettings.JSONLD_MODE,JSONLDMode.FLATTEN);
			result.getWriterConfig().set(BasicWriterSettings.PRETTY_PRINT,true);
		}
	}
	return result;
}
 

import org.openrdf.rio.RDFWriterRegistry; //导入依赖的package包/类
/**
 * Create a new RDF streaming output that uses the given connection to
 * stream RDF triples in the given format from the a graph.
 *
 * @param conn the repository connection
 * @param format the RDF format
 * @param contexts the graphs to stream from
 */
public RDFStreamingOutput(
		RepositoryConnection conn,
		RDFFormat format,
		Resource... contexts) {
	super(conn);
	this.contexts = contexts;
	this.factory = RDFWriterRegistry.getInstance().get(format);
}
 

import org.openrdf.rio.RDFWriterRegistry; //导入依赖的package包/类
private FileFormatServiceRegistry<? extends FileFormat, ?> getRegistryInstance(SparqlQueryType queryType) {
	switch(queryType){
		case TUPLE_QUERY: return TupleQueryResultWriterRegistry.getInstance();
		case GRAPH_QUERY: return RDFWriterRegistry.getInstance();
		case BOOLEAN_QUERY: return BooleanQueryResultWriterRegistry.getInstance();
	}
	return null;
}
 

import org.openrdf.rio.RDFWriterRegistry; //导入依赖的package包/类
@Override
protected void doQuery(QueryDefinition query, WriterConfig config,
		RepositoryConnection cxn, OutputStream os) throws Exception {
	final GraphQuery sailGraphQuery = cxn
			.prepareGraphQuery(query.getQueryLanguage(), query.getQuery(),
					config.getBaseUri());
	final RDFFormat format = RDFFormat.forMIMEType(config.getContentType(),
			RDFFormat.RDFXML);
	// final RDFFormat format = RDFWriterRegistry.getInstance()
	// .getFileFormatForMIMEType(config.getFormat());
	final RDFWriter w = RDFWriterRegistry.getInstance().get(format)
			.getWriter(os);
	applyConfig(w);
	sailGraphQuery.evaluate(w);
}
 

import org.openrdf.rio.RDFWriterRegistry; //导入依赖的package包/类
/**
 * Get all statements and export them as RDF.
 * 
 * @param repository the Repository object
 * @param request the HttpServletRequest object
 * @param response the HttpServletResponse object
 * @return a model and view for exporting the statements.
 * @throws ClientHTTPException throws when there errors in parsing the request
 */
private ModelAndView getExportStatementsResult(final Repository repository, final HttpServletRequest request,
		final HttpServletResponse response)
		throws ClientHTTPException {
	ProtocolUtil.logRequestParameters(request);

	ValueFactory vf = repository.getValueFactory();

	Resource subj = ProtocolUtil.parseResourceParam(request, SUBJECT_PARAM_NAME, vf);
	URI pred = ProtocolUtil.parseURIParam(request, PREDICATE_PARAM_NAME, vf);
	Value obj = ProtocolUtil.parseValueParam(request, OBJECT_PARAM_NAME, vf);
	Resource[] contexts = ProtocolUtil.parseContextParam(request, CONTEXT_PARAM_NAME, vf);
	boolean useInferencing = ProtocolUtil.parseBooleanParam(request, INCLUDE_INFERRED_PARAM_NAME, true);

	RDFWriterFactory rdfWriterFactory = ProtocolUtil.getAcceptableService(request, response,
			RDFWriterRegistry.getInstance());

	Map<String, Object> model = new HashMap<String, Object>();
	model.put(ExportStatementsView.SUBJECT_KEY, subj);
	model.put(ExportStatementsView.PREDICATE_KEY, pred);
	model.put(ExportStatementsView.OBJECT_KEY, obj);
	model.put(ExportStatementsView.CONTEXTS_KEY, contexts);
	model.put(ExportStatementsView.USE_INFERENCING_KEY, Boolean.valueOf(useInferencing));
	model.put(ExportStatementsView.FACTORY_KEY, rdfWriterFactory);
	model.put(ExportStatementsView.HEADERS_ONLY, METHOD_HEAD.equals(request.getMethod()));
	model.put(ExportStatementsView.REPO_KEY, repository);
	return new ModelAndView(ExportStatementsView.getInstance(), model);
}
 

import org.openrdf.rio.RDFWriterRegistry; //导入依赖的package包/类
/**
 * returns a list of all mimetypes which can be produced by implemented serializers
 * @return
 */
@Override
public List<String> getProducedTypes() {
    Set<String> producedTypes = new LinkedHashSet<String>();
       for(RDFFormat format : RDFWriterRegistry.getInstance().getKeys()) {
           // Ignore binary formats
           if(format.hasCharset()) {
               producedTypes.addAll(format.getMIMETypes());
           }
       }
       return new ArrayList<String>(producedTypes);
}
 

import org.openrdf.rio.RDFWriterRegistry; //导入依赖的package包/类
/**
 * This method is required as at last check the BinaryRDFWriterFactory was not fully implemeneted.
 * @param format
 * @param writer
 * @return 
 */
private static RDFWriter getWriterIfPossible(RDFFormat format, Writer writer){
    RDFWriterRegistry register =  RDFWriterRegistry.getInstance();
    RDFWriterFactory factory = register.get(format);
    if (factory == null){
        return null;
    }
    try {
        return factory.getWriter(writer);
    } catch (Exception ex){
        logger.error(ex);
        return null;
    }
}
 

import org.openrdf.rio.RDFWriterRegistry; //导入依赖的package包/类
/**
 * Returns a {@link RDFWriterFactory} that produces RDF data according to a
 * given MIME-type.
 *
 * @param mimetype the mimetype
 * @return the corresponding writer factory
 */
private RDFWriterFactory getRDFWriterFactory(String mimetype) {
	RDFWriterRegistry registry = RDFWriterRegistry.getInstance();
	return registry.get(getRDFFormat(mimetype));
}