Skip to content

Commit

Permalink
Rename IndexDescriptor => StoreIndexDescriptor
Browse files Browse the repository at this point in the history
  • Loading branch information
fickludd authored and ragadeeshu committed May 21, 2018
1 parent f151fe8 commit 5aee19c
Show file tree
Hide file tree
Showing 105 changed files with 667 additions and 652 deletions.
Expand Up @@ -32,7 +32,7 @@
import org.neo4j.kernel.impl.store.SchemaRuleAccess; import org.neo4j.kernel.impl.store.SchemaRuleAccess;
import org.neo4j.kernel.impl.store.record.ConstraintRule; import org.neo4j.kernel.impl.store.record.ConstraintRule;
import org.neo4j.kernel.impl.store.record.DynamicRecord; import org.neo4j.kernel.impl.store.record.DynamicRecord;
import org.neo4j.kernel.api.schema.index.IndexDescriptor; import org.neo4j.kernel.api.schema.index.StoreIndexDescriptor;
import org.neo4j.kernel.impl.store.record.LabelTokenRecord; import org.neo4j.kernel.impl.store.record.LabelTokenRecord;
import org.neo4j.kernel.impl.store.record.PropertyKeyTokenRecord; import org.neo4j.kernel.impl.store.record.PropertyKeyTokenRecord;
import org.neo4j.kernel.impl.store.record.RelationshipTypeTokenRecord; import org.neo4j.kernel.impl.store.record.RelationshipTypeTokenRecord;
Expand Down Expand Up @@ -107,9 +107,9 @@ public void check( DynamicRecord record,
return; return;
} }


if ( rule instanceof IndexDescriptor ) if ( rule instanceof StoreIndexDescriptor )
{ {
strategy.checkIndexRule( (IndexDescriptor)rule, record, records, engine ); strategy.checkIndexRule( (StoreIndexDescriptor)rule, record, records, engine );
} }
else if ( rule instanceof ConstraintRule ) else if ( rule instanceof ConstraintRule )
{ {
Expand All @@ -124,7 +124,7 @@ else if ( rule instanceof ConstraintRule )


private interface CheckStrategy private interface CheckStrategy
{ {
void checkIndexRule( IndexDescriptor rule, DynamicRecord record, RecordAccess records, void checkIndexRule( StoreIndexDescriptor rule, DynamicRecord record, RecordAccess records,
CheckerEngine<DynamicRecord,ConsistencyReport.SchemaConsistencyReport> engine ); CheckerEngine<DynamicRecord,ConsistencyReport.SchemaConsistencyReport> engine );


void checkConstraintRule( ConstraintRule rule, DynamicRecord record, void checkConstraintRule( ConstraintRule rule, DynamicRecord record,
Expand All @@ -138,7 +138,7 @@ void checkConstraintRule( ConstraintRule rule, DynamicRecord record,
private class RulesCheckStrategy implements CheckStrategy private class RulesCheckStrategy implements CheckStrategy
{ {
@Override @Override
public void checkIndexRule( IndexDescriptor rule, DynamicRecord record, RecordAccess records, public void checkIndexRule( StoreIndexDescriptor rule, DynamicRecord record, RecordAccess records,
CheckerEngine<DynamicRecord,ConsistencyReport.SchemaConsistencyReport> engine ) CheckerEngine<DynamicRecord,ConsistencyReport.SchemaConsistencyReport> engine )
{ {
checkSchema( rule, record, records, engine ); checkSchema( rule, record, records, engine );
Expand Down Expand Up @@ -176,7 +176,7 @@ public void checkConstraintRule( ConstraintRule rule, DynamicRecord record,
private class ObligationsCheckStrategy implements CheckStrategy private class ObligationsCheckStrategy implements CheckStrategy
{ {
@Override @Override
public void checkIndexRule( IndexDescriptor rule, DynamicRecord record, RecordAccess records, public void checkIndexRule( StoreIndexDescriptor rule, DynamicRecord record, RecordAccess records,
CheckerEngine<DynamicRecord,ConsistencyReport.SchemaConsistencyReport> engine ) CheckerEngine<DynamicRecord,ConsistencyReport.SchemaConsistencyReport> engine )
{ {
if ( rule.canSupportUniqueConstraint() ) if ( rule.canSupportUniqueConstraint() )
Expand Down
Expand Up @@ -48,7 +48,7 @@
import org.neo4j.kernel.impl.store.SchemaStorage; import org.neo4j.kernel.impl.store.SchemaStorage;
import org.neo4j.kernel.impl.store.StoreAccess; import org.neo4j.kernel.impl.store.StoreAccess;
import org.neo4j.kernel.impl.store.record.AbstractBaseRecord; import org.neo4j.kernel.impl.store.record.AbstractBaseRecord;
import org.neo4j.kernel.api.schema.index.IndexDescriptor; import org.neo4j.kernel.api.schema.index.StoreIndexDescriptor;


import static java.lang.String.format; import static java.lang.String.format;
import static org.neo4j.consistency.checking.full.MultiPassStore.ARRAYS; import static org.neo4j.consistency.checking.full.MultiPassStore.ARRAYS;
Expand Down Expand Up @@ -190,7 +190,7 @@ public List<ConsistencyCheckerTask> createTasksForFullCheck( boolean checkLabelS
if ( checkIndexes ) if ( checkIndexes )
{ {
tasks.add( new IndexDirtyCheckTask() ); tasks.add( new IndexDirtyCheckTask() );
for ( IndexDescriptor indexRule : indexes.onlineRules() ) for ( StoreIndexDescriptor indexRule : indexes.onlineRules() )
{ {
tasks.add( recordScanner( format( "Index_%d", indexRule.getId() ), tasks.add( recordScanner( format( "Index_%d", indexRule.getId() ),
new IndexIterator( indexes.accessorFor( indexRule ) ), new IndexIterator( indexes.accessorFor( indexRule ) ),
Expand Down Expand Up @@ -258,7 +258,7 @@ private class IndexDirtyCheckTask extends ConsistencyCheckerTask
@Override @Override
public void run() public void run()
{ {
for ( IndexDescriptor indexRule : indexes.onlineRules() ) for ( StoreIndexDescriptor indexRule : indexes.onlineRules() )
{ {
if ( indexes.accessorFor( indexRule ).isDirty() ) if ( indexes.accessorFor( indexRule ).isDirty() )
{ {
Expand Down
Expand Up @@ -24,13 +24,13 @@
import org.neo4j.consistency.report.ConsistencyReport; import org.neo4j.consistency.report.ConsistencyReport;
import org.neo4j.consistency.store.RecordAccess; import org.neo4j.consistency.store.RecordAccess;
import org.neo4j.consistency.store.synthetic.IndexEntry; import org.neo4j.consistency.store.synthetic.IndexEntry;
import org.neo4j.kernel.api.schema.index.IndexDescriptor; import org.neo4j.kernel.api.schema.index.StoreIndexDescriptor;


public class IndexCheck implements RecordCheck<IndexEntry, ConsistencyReport.IndexConsistencyReport> public class IndexCheck implements RecordCheck<IndexEntry, ConsistencyReport.IndexConsistencyReport>
{ {
private final IndexDescriptor indexRule; private final StoreIndexDescriptor indexRule;


public IndexCheck( IndexDescriptor indexRule ) public IndexCheck( StoreIndexDescriptor indexRule )
{ {
this.indexRule = indexRule; this.indexRule = indexRule;
} }
Expand Down
Expand Up @@ -42,7 +42,7 @@
import org.neo4j.internal.kernel.api.schema.SchemaDescriptor; import org.neo4j.internal.kernel.api.schema.SchemaDescriptor;
import org.neo4j.kernel.api.exceptions.index.IndexNotApplicableKernelException; import org.neo4j.kernel.api.exceptions.index.IndexNotApplicableKernelException;
import org.neo4j.kernel.impl.api.LookupFilter; import org.neo4j.kernel.impl.api.LookupFilter;
import org.neo4j.kernel.api.schema.index.IndexDescriptor; import org.neo4j.kernel.api.schema.index.StoreIndexDescriptor;
import org.neo4j.kernel.impl.store.record.NodeRecord; import org.neo4j.kernel.impl.store.record.NodeRecord;
import org.neo4j.kernel.impl.store.record.PropertyBlock; import org.neo4j.kernel.impl.store.record.PropertyBlock;
import org.neo4j.kernel.impl.store.record.PropertyRecord; import org.neo4j.kernel.impl.store.record.PropertyRecord;
Expand Down Expand Up @@ -95,7 +95,7 @@ private void matchIndexesToNode(
{ {
Set<Long> labels = NodeLabelReader.getListOfLabels( record, records, engine ); Set<Long> labels = NodeLabelReader.getListOfLabels( record, records, engine );
IntObjectMap<PropertyBlock> nodePropertyMap = null; IntObjectMap<PropertyBlock> nodePropertyMap = null;
for ( IndexDescriptor indexRule : indexes.onlineRules() ) for ( StoreIndexDescriptor indexRule : indexes.onlineRules() )
{ {
long labelId = indexRule.schema().keyId(); long labelId = indexRule.schema().keyId();
if ( labels.contains( labelId ) ) if ( labels.contains( labelId ) )
Expand Down Expand Up @@ -129,7 +129,7 @@ private void matchIndexesToNode(
} }


private void verifyNodeCorrectlyIndexedUniquely( long nodeId, Value[] propertyValues, private void verifyNodeCorrectlyIndexedUniquely( long nodeId, Value[] propertyValues,
CheckerEngine<NodeRecord,ConsistencyReport.NodeConsistencyReport> engine, IndexDescriptor indexRule, CheckerEngine<NodeRecord,ConsistencyReport.NodeConsistencyReport> engine, StoreIndexDescriptor indexRule,
IndexReader reader ) IndexReader reader )
{ {
IndexQuery[] query = seek( indexRule.schema(), propertyValues ); IndexQuery[] query = seek( indexRule.schema(), propertyValues );
Expand All @@ -156,7 +156,7 @@ private void verifyNodeCorrectlyIndexedUniquely( long nodeId, Value[] propertyVa


private void reportIncorrectIndexCount( Value[] propertyValues, private void reportIncorrectIndexCount( Value[] propertyValues,
CheckerEngine<NodeRecord,ConsistencyReport.NodeConsistencyReport> engine, CheckerEngine<NodeRecord,ConsistencyReport.NodeConsistencyReport> engine,
IndexDescriptor indexRule, StoreIndexDescriptor indexRule,
long count ) long count )
{ {
if ( count == 0 ) if ( count == 0 )
Expand Down
Expand Up @@ -37,19 +37,19 @@
import org.neo4j.kernel.impl.store.RecordStore; import org.neo4j.kernel.impl.store.RecordStore;
import org.neo4j.kernel.impl.store.SchemaStorage; import org.neo4j.kernel.impl.store.SchemaStorage;
import org.neo4j.kernel.impl.store.record.DynamicRecord; import org.neo4j.kernel.impl.store.record.DynamicRecord;
import org.neo4j.kernel.api.schema.index.IndexDescriptor; import org.neo4j.kernel.api.schema.index.StoreIndexDescriptor;


public class IndexAccessors implements Closeable public class IndexAccessors implements Closeable
{ {
private final MutableLongObjectMap<IndexAccessor> accessors = new LongObjectHashMap<>(); private final MutableLongObjectMap<IndexAccessor> accessors = new LongObjectHashMap<>();
private final List<IndexDescriptor> onlineIndexRules = new ArrayList<>(); private final List<StoreIndexDescriptor> onlineIndexRules = new ArrayList<>();
private final List<IndexDescriptor> notOnlineIndexRules = new ArrayList<>(); private final List<StoreIndexDescriptor> notOnlineIndexRules = new ArrayList<>();


public IndexAccessors( IndexProviderMap providers, public IndexAccessors( IndexProviderMap providers,
RecordStore<DynamicRecord> schemaStore, RecordStore<DynamicRecord> schemaStore,
IndexSamplingConfig samplingConfig ) throws IOException IndexSamplingConfig samplingConfig ) throws IOException
{ {
Iterator<IndexDescriptor> indexes = new SchemaStorage( schemaStore ).indexesGetAll(); Iterator<StoreIndexDescriptor> indexes = new SchemaStorage( schemaStore ).indexesGetAll();
for (; ; ) for (; ; )
{ {
try try
Expand All @@ -59,7 +59,7 @@ public IndexAccessors( IndexProviderMap providers,
// we intentionally only check indexes that are online since // we intentionally only check indexes that are online since
// - populating indexes will be rebuilt on next startup // - populating indexes will be rebuilt on next startup
// - failed indexes have to be dropped by the user anyways // - failed indexes have to be dropped by the user anyways
IndexDescriptor indexDescriptor = indexes.next(); StoreIndexDescriptor indexDescriptor = indexes.next();
if ( indexDescriptor.isIndexWithoutOwningConstraint() ) if ( indexDescriptor.isIndexWithoutOwningConstraint() )
{ {
notOnlineIndexRules.add( indexDescriptor ); notOnlineIndexRules.add( indexDescriptor );
Expand Down Expand Up @@ -88,30 +88,30 @@ public IndexAccessors( IndexProviderMap providers,
} }
} }


for ( IndexDescriptor indexRule : onlineIndexRules ) for ( StoreIndexDescriptor indexRule : onlineIndexRules )
{ {
long indexId = indexRule.getId(); long indexId = indexRule.getId();
accessors.put( indexId, provider( providers, indexRule ) accessors.put( indexId, provider( providers, indexRule )
.getOnlineAccessor( indexRule, samplingConfig ) ); .getOnlineAccessor( indexRule, samplingConfig ) );
} }
} }


private IndexProvider provider( IndexProviderMap providers, IndexDescriptor indexRule ) private IndexProvider provider( IndexProviderMap providers, StoreIndexDescriptor indexRule )
{ {
return providers.apply( indexRule.providerDescriptor() ); return providers.apply( indexRule.providerDescriptor() );
} }


public Collection<IndexDescriptor> notOnlineRules() public Collection<StoreIndexDescriptor> notOnlineRules()
{ {
return notOnlineIndexRules; return notOnlineIndexRules;
} }


public IndexAccessor accessorFor( IndexDescriptor indexRule ) public IndexAccessor accessorFor( StoreIndexDescriptor indexRule )
{ {
return accessors.get( indexRule.getId() ); return accessors.get( indexRule.getId() );
} }


public Iterable<IndexDescriptor> onlineRules() public Iterable<StoreIndexDescriptor> onlineRules()
{ {
return onlineIndexRules; return onlineIndexRules;
} }
Expand Down
Expand Up @@ -31,7 +31,7 @@
import org.neo4j.consistency.store.synthetic.LabelScanDocument; import org.neo4j.consistency.store.synthetic.LabelScanDocument;
import org.neo4j.kernel.impl.annotations.Documented; import org.neo4j.kernel.impl.annotations.Documented;
import org.neo4j.kernel.impl.store.record.DynamicRecord; import org.neo4j.kernel.impl.store.record.DynamicRecord;
import org.neo4j.kernel.api.schema.index.IndexDescriptor; import org.neo4j.kernel.api.schema.index.StoreIndexDescriptor;
import org.neo4j.kernel.impl.store.record.LabelTokenRecord; import org.neo4j.kernel.impl.store.record.LabelTokenRecord;
import org.neo4j.kernel.impl.store.record.NeoStoreRecord; import org.neo4j.kernel.impl.store.record.NeoStoreRecord;
import org.neo4j.kernel.impl.store.record.NodeRecord; import org.neo4j.kernel.impl.store.record.NodeRecord;
Expand Down Expand Up @@ -194,13 +194,13 @@ interface NodeConsistencyReport extends PrimitiveConsistencyReport
void dynamicRecordChainCycle( DynamicRecord nextRecord ); void dynamicRecordChainCycle( DynamicRecord nextRecord );


@Documented( "This node was not found in the expected index." ) @Documented( "This node was not found in the expected index." )
void notIndexed( IndexDescriptor index, Object[] propertyValues ); void notIndexed( StoreIndexDescriptor index, Object[] propertyValues );


@Documented( "This node was found in the expected index, although multiple times" ) @Documented( "This node was found in the expected index, although multiple times" )
void indexedMultipleTimes( IndexDescriptor index, Object[] propertyValues, long count ); void indexedMultipleTimes( StoreIndexDescriptor index, Object[] propertyValues, long count );


@Documented( "There is another node in the unique index with the same property value(s)." ) @Documented( "There is another node in the unique index with the same property value(s)." )
void uniqueIndexNotUnique( IndexDescriptor index, Object[] propertyValues, long duplicateNodeId ); void uniqueIndexNotUnique( StoreIndexDescriptor index, Object[] propertyValues, long duplicateNodeId );


@Documented( "The referenced relationship group record is not in use." ) @Documented( "The referenced relationship group record is not in use." )
void relationshipGroupNotInUse( RelationshipGroupRecord group ); void relationshipGroupNotInUse( RelationshipGroupRecord group );
Expand Down
Expand Up @@ -20,13 +20,13 @@
package org.neo4j.consistency.store.synthetic; package org.neo4j.consistency.store.synthetic;


import org.neo4j.kernel.impl.store.record.AbstractBaseRecord; import org.neo4j.kernel.impl.store.record.AbstractBaseRecord;
import org.neo4j.kernel.api.schema.index.IndexDescriptor; import org.neo4j.kernel.api.schema.index.StoreIndexDescriptor;


public class IndexRecord extends AbstractBaseRecord public class IndexRecord extends AbstractBaseRecord
{ {
private final IndexDescriptor indexRule; private final StoreIndexDescriptor indexRule;


public IndexRecord( IndexDescriptor indexRule ) public IndexRecord( StoreIndexDescriptor indexRule )
{ {
super( indexRule.getId() ); super( indexRule.getId() );
this.indexRule = indexRule; this.indexRule = indexRule;
Expand Down
Expand Up @@ -29,7 +29,7 @@
import org.neo4j.kernel.impl.store.SchemaStorage; import org.neo4j.kernel.impl.store.SchemaStorage;
import org.neo4j.kernel.impl.store.record.ConstraintRule; import org.neo4j.kernel.impl.store.record.ConstraintRule;
import org.neo4j.kernel.impl.store.record.DynamicRecord; import org.neo4j.kernel.impl.store.record.DynamicRecord;
import org.neo4j.kernel.api.schema.index.IndexDescriptor; import org.neo4j.kernel.api.schema.index.StoreIndexDescriptor;
import org.neo4j.kernel.impl.store.record.LabelTokenRecord; import org.neo4j.kernel.impl.store.record.LabelTokenRecord;
import org.neo4j.kernel.impl.store.record.PropertyKeyTokenRecord; import org.neo4j.kernel.impl.store.record.PropertyKeyTokenRecord;
import org.neo4j.storageengine.api.schema.SchemaRule; import org.neo4j.storageengine.api.schema.SchemaRule;
Expand Down Expand Up @@ -88,7 +88,7 @@ public void shouldReportInvalidLabelReferences() throws Exception


DynamicRecord record = inUse( dynamicRecord( schemaRuleId ) ); DynamicRecord record = inUse( dynamicRecord( schemaRuleId ) );
IndexProvider.Descriptor providerDescriptor = new IndexProvider.Descriptor( "in-memory", "1.0" ); IndexProvider.Descriptor providerDescriptor = new IndexProvider.Descriptor( "in-memory", "1.0" );
IndexDescriptor rule = indexRule( schemaRuleId, labelId, propertyKeyId, providerDescriptor ); StoreIndexDescriptor rule = indexRule( schemaRuleId, labelId, propertyKeyId, providerDescriptor );
when( checker().ruleAccess.loadSingleSchemaRule( schemaRuleId ) ).thenReturn( rule ); when( checker().ruleAccess.loadSingleSchemaRule( schemaRuleId ) ).thenReturn( rule );


LabelTokenRecord labelTokenRecord = add( notInUse( new LabelTokenRecord( labelId ) ) ); LabelTokenRecord labelTokenRecord = add( notInUse( new LabelTokenRecord( labelId ) ) );
Expand All @@ -109,7 +109,7 @@ public void shouldReportInvalidPropertyReferenceFromIndexRule() throws Exception


DynamicRecord record = inUse( dynamicRecord( schemaRuleId ) ); DynamicRecord record = inUse( dynamicRecord( schemaRuleId ) );
IndexProvider.Descriptor providerDescriptor = new IndexProvider.Descriptor( "in-memory", "1.0" ); IndexProvider.Descriptor providerDescriptor = new IndexProvider.Descriptor( "in-memory", "1.0" );
IndexDescriptor rule = indexRule( schemaRuleId, labelId, propertyKeyId, providerDescriptor ); StoreIndexDescriptor rule = indexRule( schemaRuleId, labelId, propertyKeyId, providerDescriptor );
when( checker().ruleAccess.loadSingleSchemaRule( schemaRuleId ) ).thenReturn( rule ); when( checker().ruleAccess.loadSingleSchemaRule( schemaRuleId ) ).thenReturn( rule );


add( inUse( new LabelTokenRecord( labelId ) ) ); add( inUse( new LabelTokenRecord( labelId ) ) );
Expand Down Expand Up @@ -157,7 +157,7 @@ public void shouldReportUniquenessConstraintNotReferencingBack() throws Exceptio


IndexProvider.Descriptor providerDescriptor = new IndexProvider.Descriptor( "in-memory", "1.0" ); IndexProvider.Descriptor providerDescriptor = new IndexProvider.Descriptor( "in-memory", "1.0" );


IndexDescriptor rule1 = constraintIndexRule( ruleId1, labelId, propertyKeyId, providerDescriptor, (long) ruleId2 ); StoreIndexDescriptor rule1 = constraintIndexRule( ruleId1, labelId, propertyKeyId, providerDescriptor, (long) ruleId2 );
ConstraintRule rule2 = uniquenessConstraintRule( ruleId2, labelId, propertyKeyId, ruleId2 ); ConstraintRule rule2 = uniquenessConstraintRule( ruleId2, labelId, propertyKeyId, ruleId2 );


when( checker().ruleAccess.loadSingleSchemaRule( ruleId1 ) ).thenReturn( rule1 ); when( checker().ruleAccess.loadSingleSchemaRule( ruleId1 ) ).thenReturn( rule1 );
Expand Down Expand Up @@ -187,7 +187,7 @@ public void shouldNotReportConstraintIndexRuleWithoutBackReference() throws Exce


IndexProvider.Descriptor providerDescriptor = new IndexProvider.Descriptor( "in-memory", "1.0" ); IndexProvider.Descriptor providerDescriptor = new IndexProvider.Descriptor( "in-memory", "1.0" );


IndexDescriptor rule = constraintIndexRule( ruleId, labelId, propertyKeyId, providerDescriptor ); StoreIndexDescriptor rule = constraintIndexRule( ruleId, labelId, propertyKeyId, providerDescriptor );


when( checker().ruleAccess.loadSingleSchemaRule( ruleId ) ).thenReturn( rule ); when( checker().ruleAccess.loadSingleSchemaRule( ruleId ) ).thenReturn( rule );


Expand Down Expand Up @@ -266,7 +266,7 @@ public void shouldReportConstraintIndexNotReferencingBack() throws Exception


IndexProvider.Descriptor providerDescriptor = new IndexProvider.Descriptor( "in-memory", "1.0" ); IndexProvider.Descriptor providerDescriptor = new IndexProvider.Descriptor( "in-memory", "1.0" );


IndexDescriptor rule1 = constraintIndexRule( ruleId1, labelId, propertyKeyId, providerDescriptor, (long) ruleId1 ); StoreIndexDescriptor rule1 = constraintIndexRule( ruleId1, labelId, propertyKeyId, providerDescriptor, (long) ruleId1 );
ConstraintRule rule2 = uniquenessConstraintRule( ruleId2, labelId, propertyKeyId, ruleId1 ); ConstraintRule rule2 = uniquenessConstraintRule( ruleId2, labelId, propertyKeyId, ruleId1 );


when( checker().ruleAccess.loadSingleSchemaRule( ruleId1 ) ).thenReturn( rule1 ); when( checker().ruleAccess.loadSingleSchemaRule( ruleId1 ) ).thenReturn( rule1 );
Expand Down Expand Up @@ -298,8 +298,8 @@ public void shouldReportTwoConstraintIndexesReferencingSameConstraint() throws E


IndexProvider.Descriptor providerDescriptor = new IndexProvider.Descriptor( "in-memory", "1.0" ); IndexProvider.Descriptor providerDescriptor = new IndexProvider.Descriptor( "in-memory", "1.0" );


IndexDescriptor rule1 = constraintIndexRule( ruleId1, labelId, propertyKeyId, providerDescriptor, (long) ruleId1 ); StoreIndexDescriptor rule1 = constraintIndexRule( ruleId1, labelId, propertyKeyId, providerDescriptor, (long) ruleId1 );
IndexDescriptor rule2 = constraintIndexRule( ruleId2, labelId, propertyKeyId, providerDescriptor, (long) ruleId1 ); StoreIndexDescriptor rule2 = constraintIndexRule( ruleId2, labelId, propertyKeyId, providerDescriptor, (long) ruleId1 );


when( checker().ruleAccess.loadSingleSchemaRule( ruleId1 ) ).thenReturn( rule1 ); when( checker().ruleAccess.loadSingleSchemaRule( ruleId1 ) ).thenReturn( rule1 );
when( checker().ruleAccess.loadSingleSchemaRule( ruleId2 ) ).thenReturn( rule2 ); when( checker().ruleAccess.loadSingleSchemaRule( ruleId2 ) ).thenReturn( rule2 );
Expand All @@ -325,7 +325,7 @@ public void shouldReportUnreferencedConstraintIndex() throws Exception


IndexProvider.Descriptor providerDescriptor = new IndexProvider.Descriptor( "in-memory", "1.0" ); IndexProvider.Descriptor providerDescriptor = new IndexProvider.Descriptor( "in-memory", "1.0" );


IndexDescriptor rule = constraintIndexRule( ruleId, labelId, propertyKeyId, providerDescriptor, (long) ruleId ); StoreIndexDescriptor rule = constraintIndexRule( ruleId, labelId, propertyKeyId, providerDescriptor, (long) ruleId );


when( checker().ruleAccess.loadSingleSchemaRule( ruleId ) ).thenReturn( rule ); when( checker().ruleAccess.loadSingleSchemaRule( ruleId ) ).thenReturn( rule );


Expand Down Expand Up @@ -353,8 +353,8 @@ public void shouldReportTwoIndexRulesWithDuplicateContent() throws Exception


IndexProvider.Descriptor providerDescriptor = new IndexProvider.Descriptor( "in-memory", "1.0" ); IndexProvider.Descriptor providerDescriptor = new IndexProvider.Descriptor( "in-memory", "1.0" );


IndexDescriptor rule1 = constraintIndexRule( ruleId1, labelId, propertyKeyId, providerDescriptor, (long) ruleId1 ); StoreIndexDescriptor rule1 = constraintIndexRule( ruleId1, labelId, propertyKeyId, providerDescriptor, (long) ruleId1 );
IndexDescriptor rule2 = constraintIndexRule( ruleId2, labelId, propertyKeyId, providerDescriptor, (long) ruleId2 ); StoreIndexDescriptor rule2 = constraintIndexRule( ruleId2, labelId, propertyKeyId, providerDescriptor, (long) ruleId2 );


when( checker().ruleAccess.loadSingleSchemaRule( ruleId1 ) ).thenReturn( rule1 ); when( checker().ruleAccess.loadSingleSchemaRule( ruleId1 ) ).thenReturn( rule1 );
when( checker().ruleAccess.loadSingleSchemaRule( ruleId2 ) ).thenReturn( rule2 ); when( checker().ruleAccess.loadSingleSchemaRule( ruleId2 ) ).thenReturn( rule2 );
Expand Down

0 comments on commit 5aee19c

Please sign in to comment.