org.neo4j.kernel.impl.store.NodeStore.setHighestPossibleIdInUse()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(4.0k)|赞(0)|评价(0)|浏览(90)

本文整理了Java中org.neo4j.kernel.impl.store.NodeStore.setHighestPossibleIdInUse()方法的一些代码示例,展示了NodeStore.setHighestPossibleIdInUse()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。NodeStore.setHighestPossibleIdInUse()方法的具体详情如下:
包路径:org.neo4j.kernel.impl.store.NodeStore
类名称:NodeStore
方法名:setHighestPossibleIdInUse

NodeStore.setHighestPossibleIdInUse介绍

暂无

代码示例

代码示例来源:origin: neo4j/neo4j

@Override
  public void close()
  {
    super.close();
    monitor.nodesImported( nodeCount );
    nodeStore.setHighestPossibleIdInUse( highestId ); // for the case of #id(long)
  }
}

代码示例来源:origin: neo4j/neo4j

@Override
public void createNode( long id, Map<String, Object> properties, Label... labels )
{
  IdValidator.assertValidId( IdType.NODE, id, maxNodeId );
  if ( nodeStore.isInUse( id ) )
  {
    throw new IllegalArgumentException( "id=" + id + " already in use" );
  }
  long highId = nodeStore.getHighId();
  if ( highId <= id )
  {
    nodeStore.setHighestPossibleIdInUse( id );
  }
  internalCreateNode( id, properties, labels );
}

代码示例来源:origin: neo4j/neo4j

@Test
public void shouldApplyNodeCommandToTheStoreInRecoveryMode() throws Exception
{
  // given
  final BatchTransactionApplier applier = newApplier( true );
  final NodeRecord before = new NodeRecord( 11 );
  before.setLabelField( 42, asList( one, two ) );
  final NodeRecord after = new NodeRecord( 12 );
  after.setInUse( true );
  after.setLabelField( 42, asList( one, two, three ) );
  final Command.NodeCommand command = new Command.NodeCommand( before, after );
  // when
  boolean result = apply( applier, command::handle, transactionToApply );
  // then
  assertFalse( result );
  verify( lockService, times( 1 ) ).acquireNodeLock( command.getKey(), LockService.LockType.WRITE_LOCK );
  verify( nodeStore, times( 1 ) ).setHighestPossibleIdInUse( after.getId() );
  verify( nodeStore, times( 1 ) ).updateRecord( after );
  verify( dynamicLabelStore, times( 1 ) ).setHighestPossibleIdInUse( three.getId() );
}

代码示例来源:origin: neo4j/neo4j

void updateCorrespondingIdGenerators( NeoStores neoStores )
  {
    neoStores.getNodeStore().setHighestPossibleIdInUse( nodeId );
    neoStores.getRelationshipStore().setHighestPossibleIdInUse( relId );
    neoStores.getRelationshipGroupStore().setHighestPossibleIdInUse( relGroupId );
  }
}

代码示例来源:origin: neo4j/neo4j

@Test
public void shouldFreeSecondaryUnitIdOfShrunkRecord() throws Exception
{
  // GIVEN
  EphemeralFileSystemAbstraction fs = efs.get();
  nodeStore = newNodeStore( fs );
  NodeRecord record = new NodeRecord( 5L );
  record.setRequiresSecondaryUnit( true );
  record.setSecondaryUnitId( 10L );
  record.setInUse( true );
  nodeStore.updateRecord( record );
  nodeStore.setHighestPossibleIdInUse( 10L );
  // WHEN
  record.setRequiresSecondaryUnit( false );
  nodeStore.updateRecord( record );
  // THEN
  IdGenerator idGenerator = idGeneratorFactory.get( IdType.NODE );
  verify( idGenerator, never() ).freeId( 5L );
  verify( idGenerator ).freeId( 10L );
}

代码示例来源:origin: neo4j/neo4j

@Test
public void shouldFreeSecondaryUnitIdOfDeletedRecord() throws Exception
{
  // GIVEN
  EphemeralFileSystemAbstraction fs = efs.get();
  nodeStore = newNodeStore( fs );
  NodeRecord record = new NodeRecord( 5L );
  record.setRequiresSecondaryUnit( true );
  record.setSecondaryUnitId( 10L );
  record.setInUse( true );
  nodeStore.updateRecord( record );
  nodeStore.setHighestPossibleIdInUse( 10L );
  // WHEN
  record.setInUse( false );
  nodeStore.updateRecord( record );
  // THEN
  IdGenerator idGenerator = idGeneratorFactory.get( IdType.NODE );
  verify( idGenerator ).freeId( 5L );
  verify( idGenerator ).freeId( 10L );
}

代码示例来源:origin: neo4j/neo4j

store.updateRecord( record );
store.setHighestPossibleIdInUse( highestId );

代码示例来源:origin: neo4j/neo4j

store.updateRecord( record );
store.setHighestPossibleIdInUse( highestId );

代码示例来源:origin: org.neo4j/neo4j-kernel

@Override
  public void close()
  {
    super.close();
    monitor.nodesImported( nodeCount );
    nodeStore.setHighestPossibleIdInUse( highestId ); // for the case of #id(long)
  }
}

代码示例来源:origin: org.neo4j/neo4j-kernel

@Override
public void createNode( long id, Map<String, Object> properties, Label... labels )
{
  IdValidator.assertValidId( IdType.NODE, id, maxNodeId );
  if ( nodeStore.isInUse( id ) )
  {
    throw new IllegalArgumentException( "id=" + id + " already in use" );
  }
  long highId = nodeStore.getHighId();
  if ( highId <= id )
  {
    nodeStore.setHighestPossibleIdInUse( id );
  }
  internalCreateNode( id, properties, labels );
}

相关文章