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 b622131d08877..3dfa9f8ac9bbe 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 )