import org.openrdf.model.vocabulary.FOAF; //导入依赖的package包/类
private static User getUser( Resource id, RepositoryConnection rc )
		throws RepositoryException {

	LinkedHashModel model = new LinkedHashModel( Iterations.asList(
			rc.getStatements( id, null, null, false ) ) );
	org.openrdf.model.Model namer = model.filter( id, FOAF.ACCOUNT, null );
	RemoteUserImpl user = new RemoteUserImpl( namer.objectString() );
	model.removeAll( namer );

	for ( Statement stmt : model ) {
		URI pred = stmt.getPredicate();
		String val = stmt.getObject().stringValue();

		for ( Map.Entry<UserProperty, URI> en : PROPMAP.entrySet() ) {
			if ( en.getValue().equals( pred ) ) {
				user.setProperty( en.getKey(), val );
			}
		}
	}

	return user;
}
 

import org.openrdf.model.vocabulary.FOAF; //导入依赖的package包/类
private static Resource getId( User t, RepositoryConnection rc )
		throws RepositoryException {
	List<Statement> stmts = Iterations.asList( rc.getStatements( null, RDF.TYPE,
			FOAF.PERSON, false ) );
	Resource idToRemove = null;
	for ( Statement s : stmts ) {
		Resource sbj = s.getSubject();
		List<Statement> individuals
				= Iterations.asList( rc.getStatements( sbj, FOAF.ACCOUNT, null, false ) );
		for ( Statement ind : individuals ) {
			if ( ind.getObject().stringValue().equals( t.getUsername() ) ) {
				idToRemove = sbj;
			}
		}
	}

	return idToRemove;
}
 

import org.openrdf.model.vocabulary.FOAF; //导入依赖的package包/类
private static Collection<Statement> getCreateStatements( Resource id, User t,
		ValueFactory vf ) {
	List<Statement> stmts = new ArrayList<>();
	stmts.add( new StatementImpl( id, RDF.TYPE, FOAF.PERSON ) );
	stmts.add( new StatementImpl( id, FOAF.ACCOUNT, vf.createLiteral( t.getUsername() ) ) );

	for ( Map.Entry<UserProperty, URI> en : PROPMAP.entrySet() ) {
		UserProperty prop = en.getKey();

		String str = t.getProperty( prop );
		if ( !str.trim().isEmpty() ) {
			stmts.add( new StatementImpl( id, en.getValue(), vf.createLiteral( str ) ) );
		}
	}

	return stmts;
}
 

import org.openrdf.model.vocabulary.FOAF; //导入依赖的package包/类
@Test
public void testSingleStatementPattern() throws Exception {
    // Insert data
    insert(OWL.THING, RDF.TYPE, OWL.CLASS);
    insert(FOAF.PERSON, RDF.TYPE, OWL.CLASS, 1);
    insert(FOAF.PERSON, RDFS.SUBCLASSOF, OWL.THING);
    insert(VF.createURI("urn:Alice"), RDF.TYPE, FOAF.PERSON);
    dao.flush();
    // Define query and expected results
    final String query = "SELECT * WHERE {\n"
            + "  ?individual a ?type .\n"
            + "}";
    List<String> varNames = Arrays.asList("individual", "type");
    Multiset<BindingSet> expectedSolutions = HashMultiset.create();
    expectedSolutions.add(new ListBindingSet(varNames, OWL.THING, OWL.CLASS));
    expectedSolutions.add(new ListBindingSet(varNames, FOAF.PERSON, OWL.CLASS));
    expectedSolutions.add(new ListBindingSet(varNames, VF.createURI("urn:Alice"), FOAF.PERSON));
    // Execute pipeline and verify results
    testPipelineQuery(query, expectedSolutions);
}
 

import org.openrdf.model.vocabulary.FOAF; //导入依赖的package包/类
@Test
public void testSelectQuery() throws Exception {
    String text = "PREFIX foaf: <" + FOAF.NAMESPACE + ">\n"
            + "SELECT * WHERE {\n"
            + "  ?x a foaf:Person .\n"
            + "  ?y a foaf:Person .\n"
            + "  ?x foaf:knows ?y .\n"
            + "}";
    ParsedQuery query = new SPARQLParser().parseQuery(text, null);
    AntecedentVisitor visitor = new AntecedentVisitor();
    query.getTupleExpr().visit(visitor);
    Set<StatementPattern> expected = Sets.newHashSet(
            new StatementPattern(new Var("x"), c(RDF.TYPE), c(FOAF.PERSON)),
            new StatementPattern(new Var("y"), c(RDF.TYPE), c(FOAF.PERSON)),
            new StatementPattern(new Var("x"), c(FOAF.KNOWS), new Var("y")));
    Assert.assertEquals(expected, visitor.getAntecedents());
}
 

import org.openrdf.model.vocabulary.FOAF; //导入依赖的package包/类
@Test
public void testConstructQuery() throws Exception {
    String text = "PREFIX foaf: <" + FOAF.NAMESPACE + ">\n"
            + "CONSTRUCT {\n"
            + "  ?y foaf:knows ?x .\n"
            + "  ?y <urn:knows> ?x .\n"
            + "  ?x <urn:knows> ?y .\n"
            + "} WHERE {\n"
            + "  ?x a foaf:Person .\n"
            + "  ?y a foaf:Person .\n"
            + "  ?x foaf:knows ?y .\n"
            + "}";
    ParsedQuery query = new SPARQLParser().parseQuery(text, null);
    AntecedentVisitor visitor = new AntecedentVisitor();
    query.getTupleExpr().visit(visitor);
    Set<StatementPattern> expected = Sets.newHashSet(
            new StatementPattern(new Var("x"), c(RDF.TYPE), c(FOAF.PERSON)),
            new StatementPattern(new Var("y"), c(RDF.TYPE), c(FOAF.PERSON)),
            new StatementPattern(new Var("x"), c(FOAF.KNOWS), new Var("y")));
    Assert.assertEquals(expected, visitor.getAntecedents());
}
 

import org.openrdf.model.vocabulary.FOAF; //导入依赖的package包/类
@Test
public void testComplexQuery() throws Exception {
    String text = "PREFIX foaf: <" + FOAF.NAMESPACE + ">\n"
            + "PREFIX ex: <" + EX + ">\n"
            + "SELECT * WHERE {\n"
            + "  { ?x a foaf:Person } UNION {\n"
            + "    GRAPH ex:Graph1 { ?y a foaf:Person }\n"
            + "  } .\n"
            + "  GRAPH ex:Graph2 {\n"
            + "    ?x foaf:knows ?y .\n"
            + "  }\n ."
            + "  OPTIONAL { ?x foaf:mbox ?m } .\n"
            + "  FILTER (?x != ?y) .\n"
            + "}";
    ParsedQuery query = new SPARQLParser().parseQuery(text, null);
    AntecedentVisitor visitor = new AntecedentVisitor();
    query.getTupleExpr().visit(visitor);
    Set<StatementPattern> expected = Sets.newHashSet(
            new StatementPattern(Scope.NAMED_CONTEXTS, new Var("y"), c(RDF.TYPE), c(FOAF.PERSON), c(G1)),
            new StatementPattern(new Var("x"), c(RDF.TYPE), c(FOAF.PERSON)),
            new StatementPattern(Scope.NAMED_CONTEXTS, new Var("x"), c(FOAF.KNOWS), new Var("y"), c(G2)),
            new StatementPattern(new Var("x"), c(FOAF.MBOX), new Var("m")));
    Assert.assertEquals(expected, visitor.getAntecedents());
}
 

import org.openrdf.model.vocabulary.FOAF; //导入依赖的package包/类
@Test
public void testBNodeQuery() throws Exception {
    String text = "PREFIX foaf: <" + FOAF.NAMESPACE + ">\n"
            + "SELECT * WHERE {\n"
            + "  ?x a [ rdfs:subClassOf foaf:Person ] .\n"
            + "  ?x foaf:knows ?y .\n"
            + "}";
    ParsedQuery query = new SPARQLParser().parseQuery(text, null);
    AntecedentVisitor visitor = new AntecedentVisitor();
    query.getTupleExpr().visit(visitor);
    Set<StatementPattern> actual = visitor.getAntecedents();
    Assert.assertEquals(3, actual.size());
    StatementPattern knows = new StatementPattern(new Var("x"), c(FOAF.KNOWS), new Var("y"));
    Assert.assertTrue(actual.remove(knows));
    Assert.assertTrue(actual.removeIf(sp -> {
        return sp.getSubjectVar().equals(new Var("x"))
                && RDF.TYPE.equals(sp.getPredicateVar().getValue())
                && sp.getObjectVar().getValue() == null;
    }));
    Assert.assertTrue(actual.removeIf(sp -> {
        return sp.getSubjectVar().getValue() == null
                && RDFS.SUBCLASSOF.equals(sp.getPredicateVar().getValue())
                && FOAF.PERSON.equals(sp.getObjectVar().getValue());
    }));
}
 

import org.openrdf.model.vocabulary.FOAF; //导入依赖的package包/类
@Test
public void testGeneralConsequent() throws Exception {
    String text = "CONSTRUCT {\n"
            + "  ?x ?p2 ?y"
            + "} WHERE {\n"
            + "  ?x ?p1 ?y .\n"
            + "  ?p1 rdfs:subPropertyOf ?p2 .\n"
            + "}";
    ParsedGraphQuery query = (ParsedGraphQuery) PARSER.parseQuery(text, null);
    SpinConstructRule rule = new SpinConstructRule(OWL.THING, RL_PRP_SPO1, query);
    Multiset<StatementPattern> expectedAntecedents = HashMultiset.create(Arrays.asList(
            new StatementPattern(new Var("p1"), ac(RDFS.SUBPROPERTYOF), new Var("p2")),
            new StatementPattern(new Var("x"), new Var("p1"), new Var("y"))));
    Multiset<StatementPattern> expectedConsequents = HashMultiset.create(Arrays.asList(
            new StatementPattern(new Var("subject"), new Var("predicate"), new Var("object"))));
    Assert.assertEquals(expectedAntecedents, HashMultiset.create(rule.getAntecedentPatterns()));
    Assert.assertEquals(expectedConsequents, HashMultiset.create(rule.getConsequentPatterns()));
    Assert.assertFalse(rule.hasAnonymousConsequent());
    // Basic pattern matches
    Assert.assertTrue(rule.canConclude(new StatementPattern(new Var("a"), new Var("b"), new Var("c"))));
    // Narrower patterns match (constants in place of variables)
    Assert.assertTrue(rule.canConclude(new StatementPattern(new Var("x"), c(RDFS.SUBPROPERTYOF), c(OWL.THING))));
    Assert.assertTrue(rule.canConclude(new StatementPattern(c(OWL.NOTHING), new Var("prop"), c(OWL.THING))));
    Assert.assertTrue(rule.canConclude(new StatementPattern(c(FOAF.PERSON), c(RDFS.SUBCLASSOF), new Var("x"))));
    Assert.assertTrue(rule.canConclude(new StatementPattern(c(OWL.NOTHING), c(RDFS.SUBCLASSOF), c(FOAF.PERSON))));
}
 

import org.openrdf.model.vocabulary.FOAF; //导入依赖的package包/类
@Test
public void testConcreteSP() {
    Extension extension = new Extension(new SingletonSet(),
            new ExtensionElem(new ValueConstant(FOAF.PERSON), "x"),
            new ExtensionElem(new ValueConstant(RDF.TYPE), "y"),
            new ExtensionElem(new ValueConstant(OWL.CLASS), "z"));
    Projection projection = new Projection(extension, new ProjectionElemList(
            new ProjectionElem("x", "subject"),
            new ProjectionElem("y", "predicate"),
            new ProjectionElem("z", "object")));
    ConstructConsequentVisitor visitor = new ConstructConsequentVisitor();
    projection.visit(visitor);
    Set<StatementPattern> expected = Sets.newHashSet(
            new StatementPattern(s(FOAF.PERSON), p(RDF.TYPE), o(OWL.CLASS)));
    Assert.assertEquals(expected, visitor.getConsequents());
}
 

import org.openrdf.model.vocabulary.FOAF; //导入依赖的package包/类
/**
 * Identifiers for managed URI must be be directly served by the dictionary, without involving the decoratee.
 * 
 * @throws Exception never otherwise the test fails.
 */
@Test
public void getURIWithManagedId() throws Exception {
	final URI managedUri = buildResource(FOAF.NAMESPACE + System.currentTimeMillis());

	final String n3 = NTriplesUtil.toNTriplesString(managedUri);

	when(_dummyIndex.getQuick(any(byte[].class))).thenReturn(n3);
	when(_dummyIndex.get(n3)).thenReturn(ValueDictionaryBase.NOT_SET);

	byte[] id = _cut.getID(managedUri, _isPredicate);

	final Value value = _cut.getValue(id, _isPredicate);
	assertEquals(managedUri, value);

	verify(_decoratee, times(0)).getValue(id, _isPredicate);
}
 

import org.openrdf.model.vocabulary.FOAF; //导入依赖的package包/类
/**
 * Tests remove() method with managed URI.
 * 
 * @throws Exception never otherwise the test fails.
 */
@Test
public void removeManagedURI() throws Exception {
	final String[] managedNamespaces = {
			FOAF.NAMESPACE,
			RDFS.NAMESPACE,
			OWL.NAMESPACE };

	for (final String managedNamespace : managedNamespaces) {
		assertTrue(_cut.contains(managedNamespace));

		final Value uri = buildResource(managedNamespace + randomString());
		final String n3 = NTriplesUtil.toNTriplesString(uri);

		_cut.removeValue(uri, _isPredicate);
		verify(_dummyIndex).remove(n3);

		reset(_dummyIndex);
	}
}
 

import org.openrdf.model.vocabulary.FOAF; //导入依赖的package包/类
static Model generateModel(RepositoryResult<Statement> statements) {

		Model model = null;
		try {
			model = Iterations.addAll(statements, new LinkedHashModel());
		} catch (RepositoryException e) {
			e.printStackTrace();
		}

		model.setNamespace("rdf", RDF.NAMESPACE);
		model.setNamespace("rdfs", RDFS.NAMESPACE);
		model.setNamespace("foaf", FOAF.NAMESPACE);
		model.setNamespace("schema", schema);
		model.setNamespace("dbpedia", dbpedia);
		model.setNamespace("dc", dublin);
		return model;
	}
 

import org.openrdf.model.vocabulary.FOAF; //导入依赖的package包/类
/**
 * Saves as RDF the graph created.
 *
 * @throws RepositoryException
 * @throws RDFHandlerException
 * @throws IOException
 */
private void SaveRdf() throws RepositoryException, RDFHandlerException, IOException {
    RepositoryResult statements = src.getStatements(null, null, null, true);

    Model model = new LinkedHashModel();

    java.util.ArrayList arr = new java.util.ArrayList();
    while (statements.hasNext()) {
        arr.add(statements.next());
    }
    model.addAll(arr);

    model.setNamespace("rdf", RDF.NAMESPACE);
    model.setNamespace("rdfs", RDFS.NAMESPACE);
    model.setNamespace("xsd", XMLSchema.NAMESPACE);
    model.setNamespace("foaf", FOAF.NAMESPACE);
    model.setNamespace("ex", "");

    Rio.write(model, new java.io.FileWriter(new java.io.File(outputFileName),false), RDFFormat.TURTLE);
    
    CloseAllConnections();
}
 

import org.openrdf.model.vocabulary.FOAF; //导入依赖的package包/类
@Test
public void testParsing() throws ParseException {
    List<PatchLine> patchLines = parser.parsePatch();

    Iterator<PatchLine> it = patchLines.iterator();

    Assert.assertTrue(it.hasNext());
    checkPatchLine(it.next(), PatchLine.Operator.DELETE, bob, FOAF.NAME, lcBob);

    Assert.assertTrue(it.hasNext());
    checkPatchLine(it.next(), PatchLine.Operator.ADD, bob, FOAF.NAME, ucBob);

    Assert.assertTrue(it.hasNext());
    checkPatchLine(it.next(), PatchLine.Operator.ADD, null, FOAF.KNOWS, alice);

    Assert.assertTrue(it.hasNext());
    checkPatchLine(it.next(), PatchLine.Operator.DELETE, null, null, charlie);
}
 

import org.openrdf.model.vocabulary.FOAF; //导入依赖的package包/类
@Test
public void testApplyPatch() throws Exception {
    RepositoryConnection con = repository.getConnection();
    try {
        con.begin();

        Assert.assertTrue(con.hasStatement(bob, FOAF.NAME, lcBob, false));
        Assert.assertFalse(con.hasStatement(bob, FOAF.NAME, ucBob, false));
        Assert.assertFalse(con.hasStatement(bob, FOAF.KNOWS, alice, false));
        Assert.assertTrue(con.hasStatement(bob, FOAF.KNOWS, charlie, false));

        RdfPatchUtil.applyPatch(con, this.getClass().getResourceAsStream("/illustrative.rdfp"));

        Assert.assertFalse(con.hasStatement(bob, FOAF.NAME, lcBob, false));
        Assert.assertTrue(con.hasStatement(bob, FOAF.NAME, ucBob, false));
        Assert.assertTrue(con.hasStatement(bob, FOAF.KNOWS, alice, false));
        Assert.assertFalse(con.hasStatement(bob, FOAF.KNOWS, charlie, false));

        con.commit();
    } finally {
        con.close();
    }
}
 

import org.openrdf.model.vocabulary.FOAF; //导入依赖的package包/类
@Override
public Collection<User> getAll() {
	RepositoryConnection rc = store.getConnection();
	List<User> users = new ArrayList<>();
	try {
		for ( Statement stmt : Iterations.asList( rc.getStatements( null, RDF.TYPE,
				FOAF.PERSON, false ) ) ) {
			users.add( getUser( stmt.getSubject(), rc ) );
		}
	}
	catch ( RepositoryException e ) {
		log.error( e, e );
	}
	return users;
}
 

import org.openrdf.model.vocabulary.FOAF; //导入依赖的package包/类
public boolean exists( String username ) {
	RepositoryConnection rc = store.getConnection();

	try {
		return rc.hasStatement( null, FOAF.ACCOUNT,
				new LiteralImpl( username ), false );
	}
	catch ( RepositoryException e ) {
		log.error( e, e );
	}

	return false;
}
 

import org.openrdf.model.vocabulary.FOAF; //导入依赖的package包/类
@Test
public void testGetSheetNames() throws IOException {
	LowMemXlsReader rdr = new LowMemXlsReader( CUSTOM );
	ImportMetadata data = rdr.getMetadata();


	Map<String, String> namespaces = new HashMap<>( Utility.DEFAULTNAMESPACES );
	namespaces.put( FOAF.PREFIX, FOAF.NAMESPACE );
	namespaces.put( "northwind", "http://seman.tc/models/northwind#" );
	namespaces.put( "dct", "http://purl.org/dc/terms/" );
	namespaces.put( "schema", "http://schema.org/" );
	assertEquals( namespaces, data.getNamespaces() );
}
 

import org.openrdf.model.vocabulary.FOAF; //导入依赖的package包/类
@Test
public void testSubClassInferenceQuery() throws Exception {
    final String ontology = "INSERT DATA { GRAPH <http://updated/test> {\n"
            + "  <urn:Agent> owl:equivalentClass <http://dbpedia.org/ontology/Agent> . \n"
            + "  <urn:Person> rdfs:subClassOf <urn:Agent> . \n"
            + "  [ owl:equivalentClass <http://schema.org/Person> ] rdfs:subClassOf <http://dbpedia.org/ontology/Agent> . \n"
            + "  <" + FOAF.PERSON.stringValue() + "> owl:equivalentClass <http://dbpedia.org/ontology/Person> . \n"
            + "  <" + FOAF.PERSON.stringValue() + "> owl:equivalentClass <urn:Person> . \n"
            + "  <http://dbpedia.org/ontology/Engineer> rdfs:subClassOf <http://dbpedia.org/ontology/Person> . \n"
            + "  <http://dbpedia.org/ontology/Engineer> rdfs:subClassOf <http://example.org/Person> . \n"
            + "  <http://dbpedia.org/ontology/Engineer> owl:equivalentClass <http://www.wikidata.org/entity/Q81096> . \n"
            + "}}";
    final String instances = "INSERT DATA { GRAPH <http://updated/test> {\n"
            + "  <urn:Alice> a <http://schema.org/Person> . \n"
            + "  <urn:Bob> a <http://www.wikidata.org/entity/Q81096> . \n"
            + "  <urn:Carol> a <http://example.org/Person> . \n"
            + "  <urn:Dan> a <http://example.org/Engineer> . \n"
            + "  <urn:Eve> a <urn:Agent> . \n"
            + "}}";
    final String query = "SELECT ?x { GRAPH <http://updated/test> { ?x a <urn:Agent> } } \n";
    conn.prepareUpdate(QueryLanguage.SPARQL, ontology).execute();
    inferenceEngine.refreshGraph();
    conn.prepareUpdate(QueryLanguage.SPARQL, instances).execute();
    conn.prepareTupleQuery(QueryLanguage.SPARQL, query).evaluate(resultHandler);
    final Set<Value> expected = new HashSet<>();
    expected.add(vf.createURI("urn:Alice"));
    expected.add(vf.createURI("urn:Bob"));
    expected.add(vf.createURI("urn:Eve"));
    final Set<Value> returned = new HashSet<>();
    for (final BindingSet bs : solutions) {
        returned.add(bs.getBinding("x").getValue());
    }
    Assert.assertEquals(expected, returned);
    Assert.assertEquals(expected.size(), solutions.size());
}