From ac1e589dd33f3b7250bfa5d254f37755734287e6 Mon Sep 17 00:00:00 2001 From: Pontus Melke Date: Wed, 14 Mar 2018 20:02:57 +0100 Subject: [PATCH] Use Kernel API to create nodes --- .../java/org/neo4j/kernel/impl/core/NodeProxy.java | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/community/kernel/src/main/java/org/neo4j/kernel/impl/core/NodeProxy.java b/community/kernel/src/main/java/org/neo4j/kernel/impl/core/NodeProxy.java index b622131d0887..3dfa9f8ac9bb 100644 --- a/community/kernel/src/main/java/org/neo4j/kernel/impl/core/NodeProxy.java +++ b/community/kernel/src/main/java/org/neo4j/kernel/impl/core/NodeProxy.java @@ -541,11 +541,13 @@ public Relationship createRelationshipTo( Node otherNode, RelationshipType type //{ // throw new IllegalArgumentException( "Nodes do not belong to same graph database." ); //} - try ( Statement statement = spi.statement() ) + + KernelTransaction transaction = safeAcquireTransaction(); + try ( Statement ignore = transaction.acquireStatement() ) { - int relationshipTypeId = statement.tokenWriteOperations().relationshipTypeGetOrCreateForName( type.name() ); - long relationshipId = statement.dataWriteOperations() - .relationshipCreate( relationshipTypeId, nodeId, otherNode.getId() ); + int relationshipTypeId = transaction.tokenWrite().relationshipTypeGetOrCreateForName( type.name() ); + long relationshipId = transaction.dataWrite() + .relationshipCreate( nodeId, relationshipTypeId, otherNode.getId() ); return spi.newRelationshipProxy( relationshipId, nodeId, relationshipTypeId, otherNode.getId() ); } catch ( IllegalTokenNameException e )