diff options
| author | Federico Igne <federico.igne@cs.ox.ac.uk> | 2021-06-23 16:30:45 +0100 |
|---|---|---|
| committer | Federico Igne <federico.igne@cs.ox.ac.uk> | 2021-06-23 16:31:07 +0100 |
| commit | b4ddcd3f489aa217cda56140274c5b6d91a75c10 (patch) | |
| tree | 2f9b77ca5e9a15b3a8456798ab1bef4888be9c93 | |
| parent | 7ab2d819947c03a6618e273d5996a171f0217119 (diff) | |
| download | RSAComb-b4ddcd3f489aa217cda56140274c5b6d91a75c10.tar.gz RSAComb-b4ddcd3f489aa217cda56140274c5b6d91a75c10.zip | |
Fix automatic query building
The API for the SKOLEM operator is changed in RDFox but the helper
functions using it were not ported to the new syntax.
4 files changed, 31 insertions, 14 deletions
diff --git a/src/main/scala/uk/ac/ox/cs/rsacomb/Main.scala b/src/main/scala/uk/ac/ox/cs/rsacomb/Main.scala index 74084af..f9de801 100644 --- a/src/main/scala/uk/ac/ox/cs/rsacomb/Main.scala +++ b/src/main/scala/uk/ac/ox/cs/rsacomb/Main.scala | |||
| @@ -119,9 +119,23 @@ object RSAComb extends App { | |||
| 119 | 119 | ||
| 120 | ConjunctiveQuery.parse(query) match { | 120 | ConjunctiveQuery.parse(query) match { |
| 121 | case Some(query) => { | 121 | case Some(query) => { |
| 122 | // Retrieve answers | ||
| 122 | val answers = rsa ask query | 123 | val answers = rsa ask query |
| 123 | Logger.print(s"$answers", Logger.VERBOSE) | 124 | Logger.print(s"$answers", Logger.VERBOSE) |
| 124 | Logger print s"Number of answers: ${answers.length} (${answers.lengthWithMultiplicity})" | 125 | Logger print s"Number of answers: ${answers.length} (${answers.lengthWithMultiplicity})" |
| 126 | // Retrieve unfiltered answers | ||
| 127 | val unfiltered = rsa.queryDataStore( | ||
| 128 | """ | ||
| 129 | SELECT (count(?K) as ?COUNT) | ||
| 130 | WHERE { | ||
| 131 | ?K a rsa:QM . | ||
| 132 | } | ||
| 133 | """, | ||
| 134 | RSA.Prefixes | ||
| 135 | ) | ||
| 136 | unfiltered.foreach((u) => | ||
| 137 | Logger print s"Number of unfiltered answers: ${u.head._2}" | ||
| 138 | ) | ||
| 125 | } | 139 | } |
| 126 | case None => | 140 | case None => |
| 127 | throw new RuntimeException("Submitted query is not conjunctive") | 141 | throw new RuntimeException("Submitted query is not conjunctive") |
diff --git a/src/main/scala/uk/ac/ox/cs/rsacomb/RSAOntology.scala b/src/main/scala/uk/ac/ox/cs/rsacomb/RSAOntology.scala index c7b3bf0..0e10f89 100644 --- a/src/main/scala/uk/ac/ox/cs/rsacomb/RSAOntology.scala +++ b/src/main/scala/uk/ac/ox/cs/rsacomb/RSAOntology.scala | |||
| @@ -556,7 +556,6 @@ class RSAOntology(val original: OWLOntology, val datafiles: File*) { | |||
| 556 | * [[uk.ac.ox.cs.rsacomb.RSAOntology.ask RSAOntology.ask]]. | 556 | * [[uk.ac.ox.cs.rsacomb.RSAOntology.ask RSAOntology.ask]]. |
| 557 | * @note This method has been introduced mostly for debugging purposes. | 557 | * @note This method has been introduced mostly for debugging purposes. |
| 558 | * | 558 | * |
| 559 | * @param cq a CQ used to compute the environment. | ||
| 560 | * @param query query to be executed against the environment | 559 | * @param query query to be executed against the environment |
| 561 | * @param prefixes additional prefixes for the query. It defaults to | 560 | * @param prefixes additional prefixes for the query. It defaults to |
| 562 | * an empty set. | 561 | * an empty set. |
| @@ -564,7 +563,6 @@ class RSAOntology(val original: OWLOntology, val datafiles: File*) { | |||
| 564 | * @return a collection of answers to the input query. | 563 | * @return a collection of answers to the input query. |
| 565 | */ | 564 | */ |
| 566 | def queryDataStore( | 565 | def queryDataStore( |
| 567 | cq: ConjunctiveQuery, | ||
| 568 | query: String, | 566 | query: String, |
| 569 | prefixes: Prefixes = new Prefixes(), | 567 | prefixes: Prefixes = new Prefixes(), |
| 570 | opts: ju.Map[String, String] = new ju.HashMap[String, String]() | 568 | opts: ju.Map[String, String] = new ju.HashMap[String, String]() |
| @@ -588,7 +586,7 @@ class RSAOntology(val original: OWLOntology, val datafiles: File*) { | |||
| 588 | cq: ConjunctiveQuery | 586 | cq: ConjunctiveQuery |
| 589 | ): Option[Seq[(Long, Seq[Resource])]] = { | 587 | ): Option[Seq[(Long, Seq[Resource])]] = { |
| 590 | val query = RDFoxUtil.buildDescriptionQuery("QM", cq.variables.length) | 588 | val query = RDFoxUtil.buildDescriptionQuery("QM", cq.variables.length) |
| 591 | queryDataStore(cq, query, RSA.Prefixes) | 589 | queryDataStore(query, RSA.Prefixes) |
| 592 | } | 590 | } |
| 593 | 591 | ||
| 594 | def self(axiom: OWLSubClassOfAxiom): Set[Term] = { | 592 | def self(axiom: OWLSubClassOfAxiom): Set[Term] = { |
diff --git a/src/main/scala/uk/ac/ox/cs/rsacomb/filtering/RevisedFilteringProgram.scala b/src/main/scala/uk/ac/ox/cs/rsacomb/filtering/RevisedFilteringProgram.scala index 3773423..8787b43 100644 --- a/src/main/scala/uk/ac/ox/cs/rsacomb/filtering/RevisedFilteringProgram.scala +++ b/src/main/scala/uk/ac/ox/cs/rsacomb/filtering/RevisedFilteringProgram.scala | |||
| @@ -401,13 +401,14 @@ class RevisedFilteringProgram(val query: ConjunctiveQuery) | |||
| 401 | val answerQuery: String = { | 401 | val answerQuery: String = { |
| 402 | val arity = query.answer.size | 402 | val arity = query.answer.size |
| 403 | if (arity > 0) { | 403 | if (arity > 0) { |
| 404 | val variables = (0 until arity).mkString("?X", " ?X", "") | 404 | val answer = query.answer mkString " " |
| 405 | val bounded = query.bounded mkString " " | ||
| 405 | s""" | 406 | s""" |
| 406 | SELECT ${query.answer mkString ""} | 407 | SELECT $answer |
| 407 | WHERE { | 408 | WHERE { |
| 408 | ?K a rsa:Ans . | 409 | ?K a rsa:Ans . |
| 409 | TT <http://oxfordsemantic.tech/RDFox#SKOLEM> { ${query.answer mkString ""} ${query.bounded mkString ""} ?K } . | 410 | TT <http://oxfordsemantic.tech/RDFox#SKOLEM> { $answer $bounded ?K } . |
| 410 | } | 411 | } |
| 411 | """ | 412 | """ |
| 412 | } else { | 413 | } else { |
| 413 | "ASK { ?X a rsa:Ans }" | 414 | "ASK { ?X a rsa:Ans }" |
diff --git a/src/main/scala/uk/ac/ox/cs/rsacomb/util/RDFoxUtil.scala b/src/main/scala/uk/ac/ox/cs/rsacomb/util/RDFoxUtil.scala index 6833640..82aa971 100644 --- a/src/main/scala/uk/ac/ox/cs/rsacomb/util/RDFoxUtil.scala +++ b/src/main/scala/uk/ac/ox/cs/rsacomb/util/RDFoxUtil.scala | |||
| @@ -275,12 +275,16 @@ object RDFoxUtil { | |||
| 275 | arity: Int | 275 | arity: Int |
| 276 | ): String = { | 276 | ): String = { |
| 277 | if (arity > 0) { | 277 | if (arity > 0) { |
| 278 | (0 until arity).mkString("SELECT ?X", " ?X", "\n") + | 278 | val variables = (0 until arity).mkString("?X", " ?X", "") |
| 279 | (0 until arity) | 279 | s""" |
| 280 | .map(i => s"?S rsa:${pred :: Nth(i)} ?X$i .") | 280 | SELECT $variables |
| 281 | .mkString("WHERE {\n", "\n", "\n}") | 281 | WHERE { |
| 282 | ?K a rsa:$pred. | ||
| 283 | TT <http://oxfordsemantic.tech/RDFox#SKOLEM> { $variables ?K } . | ||
| 284 | } | ||
| 285 | """ | ||
| 282 | } else { | 286 | } else { |
| 283 | s"ASK { ?X a rsa:$pred }" | 287 | "ASK { ?X a rsa:Ans }" |
| 284 | } | 288 | } |
| 285 | } | 289 | } |
| 286 | 290 | ||
