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
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
|
package uk.ac.ox.cs.pagoda.reasoner;
import org.semanticweb.owlapi.model.OWLOntology;
import uk.ac.ox.cs.pagoda.multistage.MultiStageQueryEngine;
import uk.ac.ox.cs.pagoda.owl.EqualitiesEliminator;
import uk.ac.ox.cs.pagoda.query.AnswerTuples;
import uk.ac.ox.cs.pagoda.query.QueryRecord;
import uk.ac.ox.cs.pagoda.query.QueryRecord.Step;
import uk.ac.ox.cs.pagoda.reasoner.light.BasicQueryEngine;
import uk.ac.ox.cs.pagoda.rules.DatalogProgram;
import uk.ac.ox.cs.pagoda.util.Timer;
import uk.ac.ox.cs.pagoda.util.Utility;
import uk.ac.ox.cs.pagoda.util.disposable.DisposedException;
class RLUQueryReasoner extends QueryReasoner {
DatalogProgram program;
BasicQueryEngine rlLowerStore, rlUpperStore;
boolean multiStageTag, equalityTag;
Timer t = new Timer();
public RLUQueryReasoner(boolean multiStageTag, boolean considerEqualities) {
this.multiStageTag = multiStageTag;
this.equalityTag = considerEqualities;
rlLowerStore = new BasicQueryEngine("rl-lower-bound");
if(!multiStageTag)
rlUpperStore = new BasicQueryEngine("rl-upper-bound");
else
rlUpperStore = new MultiStageQueryEngine("rl-upper-bound", false);
}
@Override
public void evaluate(QueryRecord queryRecord) {
if(isDisposed()) throw new DisposedException();
AnswerTuples ans = null;
t.reset();
try {
ans = rlLowerStore.evaluate(queryRecord.getQueryText(), queryRecord.getAnswerVariables());
Utility.logDebug(t.duration());
queryRecord.updateLowerBoundAnswers(ans);
} finally {
if (ans != null) ans.dispose();
}
queryRecord.addProcessingTime(Step.LOWER_BOUND, t.duration());
ans = null;
t.reset();
try {
ans = rlUpperStore.evaluate(queryRecord.getQueryText(), queryRecord.getAnswerVariables());
Utility.logDebug(t.duration());
queryRecord.updateUpperBoundAnswers(ans);
} finally {
if (ans != null) ans.dispose();
}
queryRecord.addProcessingTime(Step.UPPER_BOUND, t.duration());
if(queryRecord.isProcessed())
queryRecord.setDifficulty(Step.UPPER_BOUND);
}
@Override
public void evaluateUpper(QueryRecord queryRecord) {
if(isDisposed()) throw new DisposedException();
AnswerTuples ans = null;
try {
ans = rlUpperStore.evaluate(queryRecord.getQueryText(), queryRecord.getAnswerVariables());
Utility.logDebug(t.duration());
queryRecord.updateUpperBoundAnswers(ans, true);
} finally {
if (ans != null) ans.dispose();
}
}
@Override
public void dispose() {
super.dispose();
if (rlLowerStore != null) rlLowerStore.dispose();
if (rlUpperStore != null) rlUpperStore.dispose();
}
@Override
public void loadOntology(OWLOntology o) {
if(isDisposed()) throw new DisposedException();
if (!equalityTag) {
EqualitiesEliminator eliminator = new EqualitiesEliminator(o);
o = eliminator.getOutputOntology();
eliminator.save();
}
OWLOntology ontology = o;
program = new DatalogProgram(ontology);
importData(program.getAdditionalDataFile());
}
@Override
public boolean preprocess() {
if(isDisposed()) throw new DisposedException();
String datafile = getImportedData();
rlLowerStore.importRDFData("data", datafile);
rlLowerStore.materialise("lower program", program.getLower().toString());
rlUpperStore.importRDFData("data", datafile);
rlUpperStore.materialiseRestrictedly(program, null);
return isConsistent();
}
@Override
public boolean isConsistent() {
if(isDisposed()) throw new DisposedException();
String[] X = new String[] { "X" };
AnswerTuples ans = null;
try {
ans = rlLowerStore.evaluate(QueryRecord.botQueryText, X);
if (ans.isValid()) return false;
} finally {
if (ans != null) ans.dispose();
}
ans = null;
try {
ans = rlUpperStore.evaluate(QueryRecord.botQueryText, X);
if (!ans.isValid()) return true;
} finally {
if (ans != null) ans.dispose();
}
Utility.logDebug("The consistency of the data has not been determined yet.");
return true;
}
}
|
