aboutsummaryrefslogtreecommitdiff
path: root/src/main/scala/uk/ac/ox/cs/rsacomb/Main.scala
blob: f54884fa1b2b1cd45fdac723e90aaf3f9cff949b (plain) (blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
package uk.ac.ox.cs.rsacomb

/* Java imports */
import java.io.File
import java.util.HashMap
import scala.collection.JavaConverters._

import tech.oxfordsemantic.jrdfox.client.UpdateType
import tech.oxfordsemantic.jrdfox.logic.sparql.statement.SelectQuery
import tech.oxfordsemantic.jrdfox.logic.expression.{IRI, Term}

/* Local imports */
import util.{Logger, RDFoxUtil, RSA}
import sparql.ConjunctiveQuery

object RSAComb extends App {

  val help: String = """
  rsacomb - combined approach for CQ answering for RSA ontologies.

  USAGE
    rsacomb <query> <ontology> ...

  where
    - query: a (single) SPARQL query file.
    - ontology: one or more ontologies.

  """

  /* Simple arguments handling
   *
   * TODO: use something better later on
   */

  if (args.length < 2) {
    println(help)
    sys.exit;
  }

  val queryPath = new File(args(0))
  val ontoPaths = args.drop(1).map(new File(_))

  if (!queryPath.isFile || !ontoPaths.forall(_.isFile)) {
    println("The provided arguments are not regular files.\n\n")
    println(help)
    sys.exit;
  }

  /* TODO: It might be required to check if the ontology in input is
   * Horn-ALCHOIQ. At the moment we are assuming this is always the
   * case.
   */

  val ontology = RSAOntology(ontoPaths: _*)
  if (ontology.isRSA) {

    Logger print "Ontology is RSA!"

    /** Read SPARQL query from file */
    val strQuery = RDFoxUtil.loadQueryFromFile(queryPath.getAbsoluteFile)
    val query = ConjunctiveQuery parse strQuery

    query match {
      case Some(query) => {
        val answers = ontology ask query
        Logger.print(s"$answers", Logger.QUIET)
        Logger print s"Number of answer: ${answers.length} (${answers.lengthWithMultiplicity})"

        val unfiltered = ontology askUnfiltered query
        unfiltered map { u =>
          Logger.print(
            s"Number of unfiltered answers: ${u.length} (${u.map(_._1).sum}).",
            Logger.DEBUG
          )
          //u foreach println
          val spurious = {
            val sp =
              RDFoxUtil.buildDescriptionQuery("SP", query.variables.length)
            ontology.queryDataStore(query, sp, RSA.Prefixes)
          }
          spurious map { s =>
            Logger.print(
              s"Number of spurious answers: ${s.length} (${s.map(_._1).sum})",
              Logger.DEBUG
            )
            //s foreach println
            val perc =
              if (u.length > 0) (s.length / u.length.toFloat) * 100 else 0
            Logger.print(
              s"Percentage of spurious answers: $perc%",
              Logger.DEBUG
            )
          }

        }
      }
      case None =>
        throw new RuntimeException("Submitted query is not conjunctive")
    }

  }
}