如何用ParameterizedSparqlString实现支持空参数的RDF三元组插入？

需要插入一组RDF三元组，其中部分对象值可能为空，空值时不插入对应三元组。例如要插入以下三元组，name和age的值可能为空：

<http://example.org/resource/123> a <http://example.org/type/person> 
<http://example.org/resource/123> <http://example.org/property/name> name
<http://example.org/resource/123> <http://example.org/property/age> age

原本可以通过条件拼接字符串实现：

String query = triple1 + (name == null ? "" : triple2) + (age == null ? "" : triple3);

但尝试用ParameterizedSparqlString实现静态查询模板时，遇到空值调用asUpdate()崩溃的问题，崩溃栈如下：

java.lang.NullPointerException
    at org.apache.jena.datatypes.xsd.XSDDatatype.unparse(XSDDatatype.java:284)
    at org.apache.jena.graph.impl.LiteralLabelImpl.getLexicalForm(LiteralLabelImpl.java:303)
    at org.apache.jena.graph.Node_Literal.getLiteralLexicalForm(Node_Literal.java:43)
    at org.apache.jena.sparql.util.FmtUtils.stringForLiteral(FmtUtils.java:200)
    at org.apache.jena.sparql.util.FmtUtils.stringForNode(FmtUtils.java:371)
    at org.apache.jena.sparql.util.FmtUtils.stringForNode(FmtUtils.java:348)
    at org.apache.jena.query.ParameterizedSparqlString.stringForNode(ParameterizedSparqlString.java:1355)
    at org.apache.jena.query.ParameterizedSparqlString.toString(ParameterizedSparqlString.java:1400)
    at org.apache.jena.query.ParameterizedSparqlString.asUpdate(ParameterizedSparqlString.java:1499)
    at org.apache.jena.query.ParameterizedSparqlString.asUpdate(ParameterizedSparqlString.java:1487)

原因分析 #

ParameterizedSparqlString不支持传入null作为字面量值，当尝试设置null字面量时，底层序列化SPARQL语句时会尝试解析空值，触发NullPointerException。

解决方案 #

方法1：动态构建三元组集合 #

通过代码动态创建要插入的三元组，只添加非空值对应的条目：

// 初始化基础三元组（类型声明）
Graph graph = Factory.createDefaultGraph();
Node subjectNode = NodeFactory.createURI(subject);
Node typePredicate = NodeFactory.createURI("http://www.w3.org/1999/02/22-rdf-syntax-ns#type");
Node personType = NodeFactory.createURI("http://example.org/type/person");
graph.add(Triple.create(subjectNode, typePredicate, personType));

// 添加name三元组（非空时）
if (object1 != null) {
    Node namePredicate = NodeFactory.createURI(predicate1);
    Node nameLiteral = NodeFactory.createLiteral(object1);
    graph.add(Triple.create(subjectNode, namePredicate, nameLiteral));
}

// 添加age三元组（非空时）
if (object2 != null) {
    Node agePredicate = NodeFactory.createURI(predicate2);
    Node ageLiteral = NodeFactory.createLiteral(Integer.toString(object2), null, XSDDatatype.XSDinteger);
    graph.add(Triple.create(subjectNode, agePredicate, ageLiteral));
}

// 构建并执行更新
Update update = UpdateFactory.create("INSERT DATA { " + FmtUtils.stringForGraph(graph) + " }");
UpdateExec.service("http://localhost:3030/demo").update(update).execute();

方法2：SPARQL条件过滤（结合VALUES子句） #

利用SPARQL的VALUES和过滤逻辑，让引擎自动跳过空值对应的三元组：

ParameterizedSparqlString queryString = new ParameterizedSparqlString();
queryString.setCommandText("""
    INSERT {
        ?s a <http://example.org/type/person> .
        OPTIONAL { ?s ?p1 ?o1 }
        OPTIONAL { ?s ?p2 ?o2 }
    }
    WHERE {
        VALUES (?s ?p1 ?o1 ?p2 ?o2) { (?subject ?pred1 ?obj1 ?pred2 ?obj2) }
        FILTER (!BOUND(?o1) || STRLEN(?o1) > 0)
        FILTER (!BOUND(?o2) || ?o2 > 0)
    }
    """);

queryString.setIri("subject", subject);
queryString.setIri("pred1", predicate1);
if (object1 != null) {
    queryString.setLiteral("obj1", object1);
} else {
    // 绑定未定义变量，让FILTER过滤掉该条目
    queryString.setVar("obj1", Var.alloc("unbound"));
}

queryString.setIri("pred2", predicate2);
if (object2 != null) {
    queryString.setLiteral("obj2", object2);
} else {
    queryString.setVar("obj2", Var.alloc("unbound"));
}

UpdateExec.service("http://localhost:3030/demo").update(queryString.asUpdate()).execute();

方法3：动态调整SPARQL模板结构 #

根据参数是否为空，动态生成只包含有效三元组的SPARQL模板：

List<String> triples = new ArrayList<>();
triples.add("?s a <http://example.org/type/person>");
if (object1 != null) {
    triples.add("?s ?p1 ?o1");
}
if (object2 != null) {
    triples.add("?s ?p2 ?o2");
}

String sparqlTemplate = "INSERT DATA { " + String.join(" ; ", triples) + " }";
ParameterizedSparqlString queryString = new ParameterizedSparqlString(sparqlTemplate);

queryString.setIri("s", subject);
if (object1 != null) {
    queryString.setIri("p1", predicate1);
    queryString.setLiteral("o1", object1);
}
if (object2 != null) {
    queryString.setIri("p2", predicate2);
    queryString.setLiteral("o2", object2);
}

UpdateExec.service("http://localhost:3030/demo").update(queryString.asUpdate()).execute();

内容的提问来源于stack exchange，提问作者Arturs