使用SPARQL向Blazegraph插入三元组时遇QueryBadFormed错误求助

你的SPARQL插入语句存在两个核心语法错误，导致Blazegraph返回格式错误：

1. URI未使用尖括号包裹 #

SPARQL中，资源的URI必须用<>包裹才能被正确识别。你的代码直接将omim和meddra的URL值拼接进查询，若这些值本身没有包含<>，生成的查询会触发语法错误。

2. 字符串类型的rdfs:label未加引号 #

rdfs:label的值是文本字符串，必须用双引号（或单引号）包裹，否则SPARQL解析器会将其视为未定义的标识符，引发格式错误。如果字符串中包含引号，还需要做转义处理。

修复后的代码 #

from SPARQLWrapper import SPARQLWrapper, JSON

for index, row in df_omim.iterrows():
    omim = row['mim_number']
    omim_label = row['preferred_title_symbol']
    rel = row['skos_rel']
    meddra = row['MDR_code']
    
    # 给URI添加尖括号，给字符串添加双引号并转义内部的引号
    safe_label = omim_label.replace('"', '\\"')
    queryString = """ 
                    PREFIX skos: <http://www.w3.org/2004/02/skos/core#>
                    PREFIX rdfs: <http://www.w3.org/2000/01/rdf-schema#>
                    
                    INSERT DATA {
                    GRAPH <http://example.org/mapping> 
                    { <%s> skos:%s <%s> ;
                         rdfs:label "%s" .}} 
                  """ %(omim, rel, meddra, safe_label)
    
    sparql = SPARQLWrapper("http://blazegraph/namespace/HC2/sparql/update")
    sparql.setQuery(queryString)
    sparql.method = 'POST'
    # 可选：设置返回格式，便于调试错误
    sparql.setReturnFormat(JSON)
    try:
        sparql.query()
    except Exception as e:
        print(f"Error at row {index}: {str(e)}")
        print(f"Generated query: {queryString}")

额外优化建议 #

• 使用参数化查询避免注入：直接字符串拼接存在SPARQL注入风险，建议使用SPARQLWrapper的参数绑定功能：

  queryString = """ 
                  PREFIX skos: <http://www.w3.org/2004/02/skos/core#>
                  PREFIX rdfs: <http://www.w3.org/2000/01/rdf-schema#>
                  
                  INSERT DATA {
                  GRAPH <http://example.org/mapping> 
                  { ?omim skos:?rel ?meddra ;
                       rdfs:label ?label .}} 
                """
  sparql.setQuery(queryString)
  sparql.addParameter("omim", omim)
  sparql.addParameter("rel", rel)
  sparql.addParameter("meddra", meddra)
  sparql.addParameter("label", omim_label)
  

• 批量插入提升性能：循环逐行插入效率较低，建议收集所有三元组后批量插入，减少HTTP请求次数。

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