VIVO-1009 Tweak the handling of TDB transactions.
This commit is contained in:
parent
12ccf8ed9e
commit
c69138b737
1 changed files with 8 additions and 7 deletions
|
@ -63,7 +63,6 @@ public class RDFServiceTDB extends RDFServiceJena {
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
dataset.begin(ReadWrite.WRITE);
|
|
||||||
try {
|
try {
|
||||||
insureThatInputStreamsAreResettable(changeSet);
|
insureThatInputStreamsAreResettable(changeSet);
|
||||||
|
|
||||||
|
@ -72,18 +71,20 @@ public class RDFServiceTDB extends RDFServiceJena {
|
||||||
}
|
}
|
||||||
notifyListenersOfPreChangeEvents(changeSet);
|
notifyListenersOfPreChangeEvents(changeSet);
|
||||||
|
|
||||||
|
dataset.begin(ReadWrite.WRITE);
|
||||||
|
try {
|
||||||
applyChangeSetToModel(changeSet, dataset);
|
applyChangeSetToModel(changeSet, dataset);
|
||||||
|
dataset.commit();
|
||||||
|
} finally {
|
||||||
|
dataset.end();
|
||||||
|
}
|
||||||
|
|
||||||
notifyListenersOfChanges(changeSet);
|
notifyListenersOfChanges(changeSet);
|
||||||
notifyListenersOfPostChangeEvents(changeSet);
|
notifyListenersOfPostChangeEvents(changeSet);
|
||||||
|
|
||||||
dataset.commit();
|
|
||||||
return true;
|
return true;
|
||||||
} catch (Exception e) {
|
} catch (Exception e) {
|
||||||
log.error(e, e);
|
log.error(e, e);
|
||||||
throw new RDFServiceException(e);
|
throw new RDFServiceException(e);
|
||||||
} finally {
|
|
||||||
dataset.end();
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Add table
Reference in a new issue