private UpdateNode createNode(ReadGraph g, Resource r1, Resource r2) throws DatabaseException {
UpdateNode node = null;
if (r1 != null && r2 != null) {
- node = createNode(g, UpdateStatus.EXIST, r1);
+ UpdateOp op = updateOps.getUpdateOp(r1);
+ if (op == null)
+ op = updateOps.getUpdateOp(r2);
+ if (op == null)
+ node = createNode(g, UpdateStatus.EXIST, r1);
+ else
+ node = createNode(g, UpdateStatus.EXIST, op);
nodes.put(r1, node);
nodes.put(r2, node);
} else if (r1 != null) {
}
public UpdateNode addNode(ReadGraph g, Resource r1, Resource r2) throws DatabaseException {
- if (r1 != null && r2 != null) {
- return null;
- }
if (nodes.containsKey(r1))
return nodes.get(r1);
if (nodes.containsKey(r2))
if (!handleCustom(g, op)) {
if (op.isAdd()) {
addNode(g, null,op.getResource());
- } else {
+ } else if (op.isDelete()){
addNode(g, op.getResource(), null);
+ } else if (op.isChange()) {
+ Resource l = getChanges().getComparable().containsLeft(op.getResource()) ? op.getResource() :getChanges().getComparable().getLeft(op.getResource());
+ Resource r = getChanges().getComparable().containsRight(op.getResource()) ? op.getResource() :getChanges().getComparable().getRight(op.getResource());
+ addNode(g, l, r);
}
}
}