litvinovg/vitro
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

updates to migration of VocabularySourceReference

Browse source
This commit is contained in:
stellamit 2011-11-06 01:23:10 +00:00
parent d1a772d22f
commit 59f141c581
1 changed files with 72 additions and 50 deletions
Download patch file Download diff file Expand all files Collapse all files

122
webapp/src/edu/cornell/mannlib/vitro/webapp/ontology/update/ABoxUpdater.java
View file

@ -454,9 +454,7 @@ public class ABoxUpdater {
} finally { } finally {
aboxModel.leaveCriticalSection(); aboxModel.leaveCriticalSection();
} }
} }
} }
private void deleteProperty(AtomicOntologyChange propObj) throws IOException{ private void deleteProperty(AtomicOntologyChange propObj) throws IOException{
@ -561,9 +559,7 @@ public class ABoxUpdater {
logger.log("Changed " + renamePropRetractModel.size() + " statement" + logger.log("Changed " + renamePropRetractModel.size() + " statement" +
((renamePropRetractModel.size() > 1) ? "s" : "") + ((renamePropRetractModel.size() > 1) ? "s" : "") +
" with predicate " + propObj.getSourceURI() + " to use " + " with predicate " + propObj.getSourceURI() + " to use " +
propObj.getDestinationURI() + " instead"); propObj.getDestinationURI() + " instead");
} }
} }
@ -574,43 +570,28 @@ public class ABoxUpdater {
Property hasSubjectArea = ResourceFactory.createProperty("http://vivoweb.org/ontology/core#hasSubjectArea"); Property hasSubjectArea = ResourceFactory.createProperty("http://vivoweb.org/ontology/core#hasSubjectArea");
Property subjectAreaFor = ResourceFactory.createProperty("http://vivoweb.org/ontology/core#subjectAreaFor"); Property subjectAreaFor = ResourceFactory.createProperty("http://vivoweb.org/ontology/core#subjectAreaFor");
HashSet<Resource> resourcesToDelete = new HashSet<Resource>();
migrateExternalConcepts(hasSubjectArea, subjectAreaFor, resourcesToDelete);
migrateExternalConcepts(hasResearchArea, researchAreaOf, resourcesToDelete);
int count = 0;
Iterator<Resource> iter = resourcesToDelete.iterator();
while (iter.hasNext()) {
deleteIndividual(iter.next());
count++;
}
if (count > 0) {
logger.log("migrated " + count + " external concept" + ((count == 1) ? "" : "s"));
}
return;
}
private void migrateExternalConcepts(Property hasConcept, Property conceptOf, HashSet<Resource> resourcesToDelete) throws IOException {
Property sourceVocabularyReference = ResourceFactory.createProperty("http://vivoweb.org/ontology/core#sourceVocabularyReference"); Property sourceVocabularyReference = ResourceFactory.createProperty("http://vivoweb.org/ontology/core#sourceVocabularyReference");
Property linkURI = ResourceFactory.createProperty("http://vivoweb.org/ontology/core#linkURI"); Property linkURI = ResourceFactory.createProperty("http://vivoweb.org/ontology/core#linkURI");
Property linkAnchorText = ResourceFactory.createProperty("http://vivoweb.org/ontology/core#linkAnchorText");
HashSet<Resource> resourcesToDelete = new HashSet<Resource>();
Model additions = ModelFactory.createDefaultModel();
int subjectRefCount = 0;
int researchRefCount = 0;
Model additions = ModelFactory.createDefaultModel();
int count = 0;
aboxModel.enterCriticalSection(Lock.WRITE); aboxModel.enterCriticalSection(Lock.WRITE);
try { try {
StmtIterator iter1 = aboxModel.listStatements((Resource) null, sourceVocabularyReference, (RDFNode) null); StmtIterator iter = aboxModel.listStatements((Resource) null, sourceVocabularyReference, (RDFNode) null);
while (iter1.hasNext()) { while (iter.hasNext()) {
Statement stmt1 = iter1.next(); Statement stmt = iter.next();
Resource subjectArea = stmt1.getSubject(); Resource subjectAreaResource = stmt.getSubject();
if (!stmt1.getObject().isResource()) continue; if (!stmt.getObject().isResource()) continue;
Resource vocabularySourceReference = stmt1.getObject().asResource(); Resource vocabularySourceReference = stmt.getObject().asResource();
Statement linkURIStmt = aboxModel.getProperty(vocabularySourceReference, linkURI); Statement linkURIStmt = aboxModel.getProperty(vocabularySourceReference, linkURI);
@ -620,37 +601,78 @@ public class ABoxUpdater {
if (externalConceptResource == null) continue; if (externalConceptResource == null) continue;
Statement conceptLabelStmt = aboxModel.getProperty(subjectArea, RDFS.label); Statement conceptLabelStmt = aboxModel.getProperty(vocabularySourceReference, linkAnchorText);
if (conceptLabelStmt == null) {
conceptLabelStmt = aboxModel.getProperty(subjectAreaResource, RDFS.label);
}
if (conceptLabelStmt != null) { if (conceptLabelStmt != null) {
additions.add(externalConceptResource, RDFS.label, conceptLabelStmt.getObject().asLiteral()); additions.add(externalConceptResource, RDFS.label, conceptLabelStmt.getObject().asLiteral());
} }
StmtIterator iter2 = aboxModel.listStatements((Resource) null, hasConcept, subjectArea); subjectRefCount += migrateConceptReferences(externalConceptResource, subjectAreaResource, hasSubjectArea, subjectAreaFor, additions);
while (iter2.hasNext()) { researchRefCount += migrateConceptReferences(externalConceptResource, subjectAreaResource, hasResearchArea, researchAreaOf, additions);
Statement stmt2 = iter2.next();
Resource agent = stmt2.getSubject();
additions.add(agent, hasConcept, externalConceptResource);
additions.add(externalConceptResource, conceptOf, agent);
}
resourcesToDelete.add(subjectArea);
count++; resourcesToDelete.add(subjectAreaResource);
} }
aboxModel.add(additions); aboxModel.add(additions);
} finally { } finally {
aboxModel.leaveCriticalSection(); aboxModel.leaveCriticalSection();
} }
if (count > 0) {
logger.log("migrated " + count + " external " + hasConcept.getLocalName() + " reference" + ((count == 1) ? "" : "s"));
}
record.recordAdditions(additions); record.recordAdditions(additions);
int count = 0;
Iterator<Resource> iter = resourcesToDelete.iterator();
while (iter.hasNext()) {
Resource ind = iter.next();
deleteIndividual(ind);
count++;
}
if (count > 0) {
logger.log("migrated " + count + " external concept" + ((count == 1) ? "" : "s"));
}
if (subjectRefCount > 0) {
logger.log("migrated " + subjectRefCount + " external " + hasSubjectArea.getLocalName() + " reference" + ((subjectRefCount == 1) ? "" : "s"));
}
if (researchRefCount > 0) {
logger.log("migrated " + researchRefCount + " external " + hasResearchArea.getLocalName() + " reference" + ((researchRefCount == 1) ? "" : "s"));
}
return; return;
} }
protected int migrateConceptReferences(Resource externalConceptResource, Resource subjectArea, Property hasConcept, Property conceptOf, Model additions) throws IOException {
int count = 0;
aboxModel.enterCriticalSection(Lock.WRITE);
try {
StmtIterator iter = aboxModel.listStatements((Resource) null, hasConcept, subjectArea);
while (iter.hasNext()) {
Statement stmt = iter.next();
Resource agent = stmt.getSubject();
if (!additions.contains(agent, hasConcept, externalConceptResource)) {
additions.add(agent, hasConcept, externalConceptResource);
count++;
}
if (!additions.contains(externalConceptResource, conceptOf, agent)) {
additions.add(externalConceptResource, conceptOf, agent);
}
}
} finally {
aboxModel.leaveCriticalSection();
}
return count;
}
public void logChanges(Statement oldStatement, Statement newStatement) throws IOException { public void logChanges(Statement oldStatement, Statement newStatement) throws IOException {
logChange(oldStatement,false); logChange(oldStatement,false);