@@ -555,7 +555,7 @@ public void removeLayer(@Name("name") String name) {
555
555
public Stream <NodeResult > addNodeToLayer (@ Name ("layerName" ) String name , @ Name ("node" ) Node node ) {
556
556
EditableLayer layer = getEditableLayerOrThrow (tx , spatial (), name );
557
557
Node geomNode = layer .add (tx , node ).getGeomNode ();
558
- layer .close (tx );
558
+ layer .finalizeTransaction (tx );
559
559
return streamNode (geomNode );
560
560
}
561
561
@@ -564,7 +564,7 @@ public Stream<NodeResult> addNodeToLayer(@Name("layerName") String name, @Name("
564
564
public Stream <CountResult > addNodesToLayer (@ Name ("layerName" ) String name , @ Name ("nodes" ) List <Node > nodes ) {
565
565
EditableLayer layer = getEditableLayerOrThrow (tx , spatial (), name );
566
566
int count = layer .addAll (tx , nodes );
567
- layer .close (tx );
567
+ layer .finalizeTransaction (tx );
568
568
return Stream .of (new CountResult (count ));
569
569
}
570
570
@@ -573,7 +573,7 @@ public Stream<CountResult> addNodesToLayer(@Name("layerName") String name, @Name
573
573
public Stream <NodeResult > addNodeIdToLayer (@ Name ("layerName" ) String name , @ Name ("nodeId" ) String nodeId ) {
574
574
EditableLayer layer = getEditableLayerOrThrow (tx , spatial (), name );
575
575
Node geomNode = layer .add (tx , tx .getNodeByElementId (nodeId )).getGeomNode ();
576
- layer .close (tx );
576
+ layer .finalizeTransaction (tx );
577
577
return streamNode (geomNode );
578
578
}
579
579
@@ -584,7 +584,7 @@ public Stream<CountResult> addNodeIdsToLayer(@Name("layerName") String name,
584
584
EditableLayer layer = getEditableLayerOrThrow (tx , spatial (), name );
585
585
List <Node > nodes = nodeIds .stream ().map (id -> tx .getNodeByElementId (id )).collect (Collectors .toList ());
586
586
int count = layer .addAll (tx , nodes );
587
- layer .close (tx );
587
+ layer .finalizeTransaction (tx );
588
588
return Stream .of (new CountResult (count ));
589
589
}
590
590
@@ -593,7 +593,7 @@ public Stream<CountResult> addNodeIdsToLayer(@Name("layerName") String name,
593
593
public Stream <NodeIdResult > removeNodeFromLayer (@ Name ("layerName" ) String name , @ Name ("node" ) Node node ) {
594
594
EditableLayer layer = getEditableLayerOrThrow (tx , spatial (), name );
595
595
layer .removeFromIndex (tx , node .getElementId ());
596
- layer .close (tx );
596
+ layer .finalizeTransaction (tx );
597
597
return streamNode (node .getElementId ());
598
598
}
599
599
@@ -607,7 +607,7 @@ public Stream<CountResult> removeNodesFromLayer(@Name("layerName") String name,
607
607
layer .removeFromIndex (tx , node .getElementId ());
608
608
}
609
609
int after = layer .getIndex ().count (tx );
610
- layer .close (tx );
610
+ layer .finalizeTransaction (tx );
611
611
return Stream .of (new CountResult (before - after ));
612
612
}
613
613
@@ -616,7 +616,7 @@ public Stream<CountResult> removeNodesFromLayer(@Name("layerName") String name,
616
616
public Stream <NodeIdResult > removeNodeFromLayer (@ Name ("layerName" ) String name , @ Name ("nodeId" ) String nodeId ) {
617
617
EditableLayer layer = getEditableLayerOrThrow (tx , spatial (), name );
618
618
layer .removeFromIndex (tx , nodeId );
619
- layer .close (tx );
619
+ layer .finalizeTransaction (tx );
620
620
return streamNode (nodeId );
621
621
}
622
622
@@ -631,7 +631,7 @@ public Stream<CountResult> removeNodeIdsFromLayer(@Name("layerName") String name
631
631
layer .removeFromIndex (tx , nodeId );
632
632
}
633
633
int after = layer .getIndex ().count (tx );
634
- layer .close (tx );
634
+ layer .finalizeTransaction (tx );
635
635
return Stream .of (new CountResult (before - after ));
636
636
}
637
637
@@ -642,7 +642,7 @@ public Stream<NodeResult> addGeometryWKTToLayer(@Name("layerName") String name,
642
642
EditableLayer layer = getEditableLayerOrThrow (tx , spatial (), name );
643
643
WKTReader reader = new WKTReader (layer .getGeometryFactory ());
644
644
Node node = addGeometryWkt (layer , reader , geometryWKT );
645
- layer .close (tx );
645
+ layer .finalizeTransaction (tx );
646
646
return streamNode (node );
647
647
}
648
648
@@ -654,7 +654,7 @@ public Stream<NodeResult> addGeometryWKTsToLayer(@Name("layerName") String name,
654
654
WKTReader reader = new WKTReader (layer .getGeometryFactory ());
655
655
return geometryWKTs .stream ().map (geometryWKT -> addGeometryWkt (layer , reader , geometryWKT ))
656
656
.map (NodeResult ::new )
657
- .onClose (() -> layer .close (tx ));
657
+ .onClose (() -> layer .finalizeTransaction (tx ));
658
658
}
659
659
660
660
private Node addGeometryWkt (EditableLayer layer , WKTReader reader , String geometryWKT ) {
@@ -673,7 +673,7 @@ public Stream<CountResult> importShapefile(
673
673
@ Name ("uri" ) String uri ) throws IOException {
674
674
EditableLayerImpl layer = getEditableLayerOrThrow (tx , spatial (), name );
675
675
List <Node > nodes = importShapefileToLayer (uri , layer , 1000 );
676
- layer .close (tx );
676
+ layer .finalizeTransaction (tx );
677
677
return Stream .of (new CountResult (nodes .size ()));
678
678
}
679
679
0 commit comments