Changeset 66:5b568de5ee0d in AnnotationManagerN4J for src/main/java/de/mpiwg/itgroup/annotations/neo4j/AnnotationStore.java
Legend:
- Unmodified
- Added
- Removed
-
src/main/java/de/mpiwg/itgroup/annotations/neo4j/AnnotationStore.java
r63 r66 63 63 nodeIndexes = new ArrayList<Index<Node>>(5); 64 64 // List.set(enum.ordinal(), val) seems not to work. 65 nodeIndexes.add(NodeTypes.ANNOTATION.ordinal(), graphDb.index().forNodes("annotations")); 66 nodeIndexes.add(NodeTypes.PERSON.ordinal(), graphDb.index().forNodes("persons")); 67 nodeIndexes.add(NodeTypes.TARGET.ordinal(), graphDb.index().forNodes("targets")); 68 nodeIndexes.add(NodeTypes.GROUP.ordinal(), graphDb.index().forNodes("groups")); 69 nodeIndexes.add(NodeTypes.TAG.ordinal(), graphDb.index().forNodes("tags")); 70 nodeIndexes.add(NodeTypes.RESOURCE.ordinal(), graphDb.index().forNodes("resources")); 65 try ( Transaction tx = graphDb.beginTx() ) 66 { 67 nodeIndexes.add(NodeTypes.ANNOTATION.ordinal(), graphDb.index().forNodes("annotations")); 68 nodeIndexes.add(NodeTypes.PERSON.ordinal(), graphDb.index().forNodes("persons")); 69 nodeIndexes.add(NodeTypes.TARGET.ordinal(), graphDb.index().forNodes("targets")); 70 nodeIndexes.add(NodeTypes.GROUP.ordinal(), graphDb.index().forNodes("groups")); 71 nodeIndexes.add(NodeTypes.TAG.ordinal(), graphDb.index().forNodes("tags")); 72 nodeIndexes.add(NodeTypes.RESOURCE.ordinal(), graphDb.index().forNodes("resources")); 73 tx.success(); 74 } 71 75 } 72 76 … … 138 142 query = "*"; 139 143 } 140 IndexHits<Node> actorNodes = idx.query(key, query); 141 for (Node actorNode : actorNodes) { 142 Actor actor = createActorFromNode(actorNode); 143 actors.add((T) actor); 144 try (Transaction tx = graphDb.beginTx()) { 145 IndexHits<Node> actorNodes = idx.query(key, query); 146 for (Node actorNode : actorNodes) { 147 Actor actor = createActorFromNode(actorNode); 148 actors.add((T) actor); 149 } 150 tx.success(); 144 151 } 145 152 return actors; … … 187 194 query = "*"; 188 195 } 189 IndexHits<Node> actorNodes = idx.query(key, query); 190 for (Node actorNode : actorNodes) { 191 Uri uri = createUriFromNode(actorNode); 192 uris.add((T) uri); 196 try (Transaction tx = graphDb.beginTx()) { 197 IndexHits<Node> actorNodes = idx.query(key, query); 198 for (Node actorNode : actorNodes) { 199 Uri uri = createUriFromNode(actorNode); 200 uris.add((T) uri); 201 } 202 tx.success(); 193 203 } 194 204 return uris; … … 233 243 query = "*"; 234 244 } 235 IndexHits<Node> annotNodes = idx.query(key, query); 236 for (Node annotNode : annotNodes) { 237 Annotation annotation = createAnnotationFromNode(annotNode); 238 annotations.add(annotation); 245 try (Transaction tx = graphDb.beginTx()) { 246 IndexHits<Node> annotNodes = idx.query(key, query); 247 for (Node annotNode : annotNodes) { 248 Annotation annotation = createAnnotationFromNode(annotNode); 249 annotations.add(annotation); 250 } 251 tx.success(); 239 252 } 240 253 return annotations; … … 255 268 query = "*"; 256 269 } 257 IndexHits<Node> groupNodes = idx.query(key, query); 258 for (Node groupNode : groupNodes) { 259 Tag tag = createTagFromNode(groupNode); 260 tags.add(tag); 270 try (Transaction tx = graphDb.beginTx()) { 271 IndexHits<Node> groupNodes = idx.query(key, query); 272 for (Node groupNode : groupNodes) { 273 Tag tag = createTagFromNode(groupNode); 274 tags.add(tag); 275 } 276 tx.success(); 261 277 } 262 278 return tags;
Note: See TracChangeset
for help on using the changeset viewer.