private final CassandraArchivaManager cassandraArchivaManager;
- private final ColumnFamilyTemplate<String, String> projectVersionMetadataModelTemplate;
+ private final ColumnFamilyTemplate<String, String> projectVersionMetadataTemplate;
private final ColumnFamilyTemplate<String, String> projectTemplate;
this.configuration = configuration;
this.cassandraArchivaManager = cassandraArchivaManager;
- this.projectVersionMetadataModelTemplate =
+ this.projectVersionMetadataTemplate =
new ThriftColumnFamilyTemplate<String, String>( cassandraArchivaManager.getKeyspace(), //
cassandraArchivaManager.getProjectVersionMetadataFamilyName(),
StringSerializer.get(), //
for ( Row<String, String, String> row : result.get() )
{
- this.projectVersionMetadataModelTemplate.deleteRow( row.getKey() );
+ this.projectVersionMetadataTemplate.deleteRow( row.getKey() );
removeMailingList( row.getKey() );
}
for ( Row<String, String, String> row : result.get() )
{
- this.projectVersionMetadataModelTemplate.deleteRow( row.getKey() );
+ this.projectVersionMetadataTemplate.deleteRow( row.getKey() );
removeMailingList( row.getKey() );
}
for ( Row<String, String, String> row : result.get() )
{
- this.projectVersionMetadataModelTemplate.deleteRow( row.getKey() );
+ this.projectVersionMetadataTemplate.deleteRow( row.getKey() );
removeMailingList( row.getKey() );
}
if ( creation )
{
String cf = cassandraArchivaManager.getProjectVersionMetadataFamilyName();
- Mutator<String> mutator = projectVersionMetadataModelTemplate.createMutator()
+ Mutator<String> mutator = projectVersionMetadataTemplate.createMutator()
// values
.addInsertion( key, cf, column( "projectId", projectId ) ) //
.addInsertion( key, cf, column( "repositoryName", repositoryId ) ) //
}
else
{
- ColumnFamilyUpdater<String, String> updater = projectVersionMetadataModelTemplate.createUpdater( key );
+ ColumnFamilyUpdater<String, String> updater = projectVersionMetadataTemplate.createUpdater( key );
updater.setString( "projectId", projectId );
updater.setString( "repositoryName", repositoryId );
updater.setString( "namespaceId", namespaceId );
removeDependencies( key );
recordDependencies( key, versionMetadata.getDependencies() );
- projectVersionMetadataModelTemplate.update( updater );
+ projectVersionMetadataTemplate.update( updater );
}
String key = result.get().iterator().next().getKey();
ColumnFamilyResult<String, String> columnFamilyResult =
- this.projectVersionMetadataModelTemplate.queryColumns( key );
+ this.projectVersionMetadataTemplate.queryColumns( key );
if ( !columnFamilyResult.hasResults() )
{
{
String cf = this.cassandraArchivaManager.getProjectVersionMetadataFamilyName();
- projectVersionMetadataModelTemplate.createMutator() //
+ projectVersionMetadataTemplate.createMutator() //
.addInsertion( key, cf, column( "namespaceId", namespace.getName() ) ) //
.addInsertion( key, cf, column( "repositoryName", repositoryId ) ) //
.addInsertion( key, cf, column( "projectVersion", projectVersion ) ) //
.withId( id ) //
.build();
- this.projectVersionMetadataModelTemplate.deleteRow( key );
+ this.projectVersionMetadataTemplate.deleteRow( key );
}
@Override
for ( Row<String, String, String> row : result.get().getList() )
{
- this.projectVersionMetadataModelTemplate.deleteRow( row.getKey() );
+ this.projectVersionMetadataTemplate.deleteRow( row.getKey() );
}
RangeSlicesQuery<String, String, String> query = HFactory //