Skip to content

Commit

Permalink
Do not create explicit transactions using local graph in tests
Browse files Browse the repository at this point in the history
  • Loading branch information
MishaDemianenko committed Jul 17, 2017
1 parent 34425a4 commit 3c7e96b
Showing 1 changed file with 13 additions and 19 deletions.
Expand Up @@ -38,10 +38,10 @@
import java.util.function.Function; import java.util.function.Function;
import java.util.stream.Collectors; import java.util.stream.Collectors;


import org.neo4j.graphdb.Transaction;
import org.neo4j.graphdb.factory.GraphDatabaseSettings; import org.neo4j.graphdb.factory.GraphDatabaseSettings;
import org.neo4j.kernel.api.KernelTransaction; import org.neo4j.kernel.api.KernelTransaction;
import org.neo4j.kernel.enterprise.builtinprocs.QueryId; import org.neo4j.kernel.enterprise.builtinprocs.QueryId;
import org.neo4j.kernel.impl.coreapi.InternalTransaction;
import org.neo4j.kernel.impl.factory.GraphDatabaseFacade; import org.neo4j.kernel.impl.factory.GraphDatabaseFacade;
import org.neo4j.server.security.enterprise.auth.plugin.api.PredefinedRoles; import org.neo4j.server.security.enterprise.auth.plugin.api.PredefinedRoles;
import org.neo4j.test.Barrier; import org.neo4j.test.Barrier;
Expand Down Expand Up @@ -640,16 +640,15 @@ public void shouldHaveSetTXMetaDataProcedure() throws Throwable
} }


@Test @Test
public void readUpdatedMetadataValue() throws Exception public void readUpdatedMetadataValue() throws Throwable
{ {
GraphDatabaseFacade localGraph = neo.getLocalGraph(); String testValue = "testValue";
try ( Transaction transaction = localGraph.beginTx() ) String testKey = "test";
GraphDatabaseFacade graph = neo.getLocalGraph();
try ( InternalTransaction transaction = neo.beginLocalTransactionAsUser( writeSubject, KernelTransaction.Type.explicit ) )
{ {
String testValue = "testValue"; graph.execute( "CALL dbms.setTXMetaData({" + testKey + ":'" + testValue + "'})" );
String testKey = "test"; Map<String,Object> metadata = (Map<String,Object>) graph.execute( "CALL dbms.getTXMetaData " ).next().get( "metadata" );
localGraph.execute( "CALL dbms.setTXMetaData({" + testKey + ":'" + testValue + "'})" );
Map<String,Object> metadata =
(Map<String,Object>) localGraph.execute( "CALL dbms.getTXMetaData " ).next().get( "metadata" );
assertEquals( testValue, metadata.get( testKey ) ); assertEquals( testValue, metadata.get( testKey ) );
} }
} }
Expand All @@ -659,19 +658,14 @@ public void readEmptyMetadataInOtherTransaction()
{ {
String testValue = "testValue"; String testValue = "testValue";
String testKey = "test"; String testKey = "test";
GraphDatabaseFacade localGraph = neo.getLocalGraph();
try ( Transaction transaction = localGraph.beginTx() )
{
localGraph.execute( "CALL dbms.setTXMetaData", map( "data", map( testKey, testValue ) ) );
transaction.success();
}


try ( Transaction ignored = localGraph.beginTx() ) assertEmpty( writeSubject, "CALL dbms.setTXMetaData({" + testKey + ":'" + testValue + "'})" );
assertSuccess( writeSubject, "CALL dbms.getTXMetaData", mapResourceIterator ->
{ {
Map<String,Object> metadata = Map<String,Object> metadata = mapResourceIterator.next();
(Map<String,Object>) localGraph.execute( "CALL dbms.getTXMetaData " ).next().get( "metadata" );
assertNull( metadata.get( testKey ) ); assertNull( metadata.get( testKey ) );
} mapResourceIterator.close();
} );
} }


//---------- procedure guard ----------- //---------- procedure guard -----------
Expand Down

0 comments on commit 3c7e96b

Please sign in to comment.