Package jetbrains.buildServer.vcs.impl

Class VcsModificationsStorageImpl

java.lang.Object

jetbrains.buildServer.vcs.impl.VcsModificationsStorageImpl

All Implemented Interfaces:

VcsModificationsStorage, org.springframework.beans.factory.InitializingBean

public class VcsModificationsStorageImpl
extends Object
implements VcsModificationsStorage, org.springframework.beans.factory.InitializingBean

Author:

Pavel.Sher Date: 03.07.2007

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	VcsModificationsStorageImpl.RelationTuple
static interface	VcsModificationsStorageImpl.VcsModificationPersister

Field Summary

Fields

Modifier and Type	Field	Description
static String	TEAMCITY_ORACLE_FETCH_SIZE
static String	VCS_HISTORY_CACHE_CLEANUP_MAX_CHANGES_TO_UNLOAD
static String	VCS_HISTORY_LOADER_ATTRIBUTES_CONCURRENT_LOADING
static String	VCS_HISTORY_LOADER_ATTRIBUTES_PAGE_SIZE

Constructor Summary

Constructors

Constructor	Description
VcsModificationsStorageImpl(VcsChangesStorage changesStorage, EventDispatcher<ProjectsImportListener> importEvents, CriticalErrors criticalErrors)

Method Summary

Modifier and Type	Method	Description
void	addEdgeRelations(SVcsModification modification, List<Map<String,RelationType>> newEdgeRelations)
void	afterPropertiesSet()
Set<SVcsModification>	cleanupExpiredModificationsFromCache()	Removes expired modifications from cache.
Set<SVcsModification>	cleanupModificationsFromCache(long minChangeTimestamp)
void	clearCache()	Clears the whole modifications cache.
SVcsModification	findCached(long id)
List<SVcsModification>	findExpiredModificationsRelatedToBuildType(String buildTypeId, long startModId, int maxChangesToReturn)
List<SVcsModification>	findExpiredModificationsRelatedToVcsRoot(VcsRootInstance vcsRootInstance, long startModId, int maxChangesToReturn)
SVcsModification	findFirstCachedModification(VcsRootInstance vcsRoot)
SVcsModification	findLastCachedModificationUpTo(VcsRootInstance vcsRoot, long upperBoundModificationId)
SVcsModification	findLastModification(LVcsRootInstance vcsRoot)
SVcsModification	findModificationById(long modId)
List<SVcsModification>	findModificationsByDisplayVersion(String version)
Collection<SVcsModification>	findModificationsByIds(Collection<Long> modificationIds)
List<SVcsModification>	findModificationsByUsername(String userName)
List<SVcsModification>	findModificationsByVersion(String version)
Map<String,SVcsModification>	findModificationsByVersions(VcsRootInstance root, Collection<String> versions)	For the specified VCS root instance and a set of revisions lookups corresponding SVcsModification instances and returns them as map of revision to the found instance.
List<SVcsModification>	getAllModifications()
List<SVcsModification>	getAllModificationsSince(Date sinceDate)
Map<String,String>	getAttributes(long modificationId)
static String	getBuildTypeId(SBuildType buildType)
VcsModificationsStorageImpl.VcsModificationPersister	getDefaultPersister()
Collection<SVcsModification>	getDuplicates(SVcsModification modification, boolean byDisplayVersion)
long	getMaxModificationId()
long	getMinModificationId()
static long	getModificationDigest(SVcsModification modification)
RelatedConfigurations	getModificationRelations(SVcsModification modification)
Collection<SVcsModification>	getModificationsWithSameVersion(VcsRootInstance root, String modificationVcsVersion)
int	getNumberOfModificationsInCache()
static int	getVcsModificationMaxAgeDays()
VcsModificationsStorageImpl.VcsModificationPersister	getVcsModificationPersister()
boolean	isVcsChangesCacheInitialized()
List<VcsChange>	loadChangedFiles(long modificationId)
Map<Long,List<VcsChange>>	loadChangedFiles(Set<Long> modificationIds)
Collection<SVcsModification>	loadMissingVcsRootModifications(VcsRootInstance rootInstance)
Collection<SVcsModification>	loadModificationsInRange(long minModId, long maxModId)	Loads modifications from DB into the cache in the interval [minModId, maxModId)
void	optimizeVcsChangesCacheForReadPerformance()
SVcsModification	persistModification(long id, ModificationData modificationData, Collection<SBuildType> relatedConfigurations, Map<String,RelationType> changeTypes, List<Map<String,RelationType>> edgeRelations, Date registrationDate)
void	processModifications(ItemProcessor<SVcsModification> processor)	Processes all modifications from newest to oldest
void	processModifications(ItemProcessor<SVcsModification> processor, long startModId)	Processes all modifications starting from one with max id less or equal to specified starting point.
void	processModificationsBackwards(ItemProcessor<SVcsModification> processor)	Processes all modifications from oldest to newest
void	processModificationsBackwards(ItemProcessor<SVcsModification> processor, long startModId)	Processes all modifications from oldest to newest starting from the specified modification id.
void	setBuildTypeVcsChangeRelationsMigrationProcess(BuildTypeVcsChangeRelationsMigrationProcess buildTypeVcsChangeRelationsMigrationProcess)
void	setBuildTypeVcsRoots(BuildTypeVcsRootsEx buildTypeVcsRoots)
void	setEntitiesIdsGroups(EntitiesIdsGroups entitiesIdsGroups)
void	setIdSequences(NumericIdSequences idSequences)
void	setServerEventDispatcher(EventDispatcher<BuildServerListener> serverEventDispatcher)
void	setSqlRunner(SQLRunnerEx sqlRunner)
void	setVcsChangesGraphQuery(VcsChangesGraphQuery vcsChangesGraphQuery)
void	setVcsModificationPersister(VcsModificationsStorageImpl.VcsModificationPersister vcsModificationPersister)
void	setVcsRootInstancesManager(VcsRootInstancesManagerEx vcsRootInstancesManager)
void	setVmFactory(VcsModificationFactory vmFactory)
void	updateDescription(long modificationId, String value)
void	updateModificationRelatedConfigurations(SVcsModification modification, Map<String,RelationType> changeTypes)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

TEAMCITY_ORACLE_FETCH_SIZE

public static final String TEAMCITY_ORACLE_FETCH_SIZE

See Also:

Constant Field Values

VCS_HISTORY_LOADER_ATTRIBUTES_PAGE_SIZE

public static final String VCS_HISTORY_LOADER_ATTRIBUTES_PAGE_SIZE

See Also:

Constant Field Values

VCS_HISTORY_LOADER_ATTRIBUTES_CONCURRENT_LOADING

public static final String VCS_HISTORY_LOADER_ATTRIBUTES_CONCURRENT_LOADING

See Also:

Constant Field Values

VCS_HISTORY_CACHE_CLEANUP_MAX_CHANGES_TO_UNLOAD

public static final String VCS_HISTORY_CACHE_CLEANUP_MAX_CHANGES_TO_UNLOAD

See Also:

Constant Field Values

Constructor Detail

VcsModificationsStorageImpl

public VcsModificationsStorageImpl(@NotNull
                                   VcsChangesStorage changesStorage,
                                   @NotNull
                                   EventDispatcher<ProjectsImportListener> importEvents,
                                   @NotNull
                                   CriticalErrors criticalErrors)

Method Detail

getDefaultPersister

@NotNull
public VcsModificationsStorageImpl.VcsModificationPersister getDefaultPersister()

setVmFactory

public void setVmFactory(@NotNull
                         VcsModificationFactory vmFactory)

setSqlRunner

public void setSqlRunner(@NotNull
                         SQLRunnerEx sqlRunner)

setIdSequences

public void setIdSequences(NumericIdSequences idSequences)

setVcsChangesGraphQuery

public void setVcsChangesGraphQuery(@NotNull
                                    VcsChangesGraphQuery vcsChangesGraphQuery)

setBuildTypeVcsRoots

public void setBuildTypeVcsRoots(@NotNull
                                 BuildTypeVcsRootsEx buildTypeVcsRoots)

setVcsRootInstancesManager

public void setVcsRootInstancesManager(@NotNull
                                       VcsRootInstancesManagerEx vcsRootInstancesManager)

setServerEventDispatcher

public void setServerEventDispatcher(@NotNull
                                     EventDispatcher<BuildServerListener> serverEventDispatcher)

setEntitiesIdsGroups

public void setEntitiesIdsGroups(@NotNull
                                 EntitiesIdsGroups entitiesIdsGroups)

setBuildTypeVcsChangeRelationsMigrationProcess

public void setBuildTypeVcsChangeRelationsMigrationProcess(@NotNull
                                                           BuildTypeVcsChangeRelationsMigrationProcess buildTypeVcsChangeRelationsMigrationProcess)

loadModificationsInRange

@NotNull
public Collection<SVcsModification> loadModificationsInRange(long minModId,
                                                             long maxModId)

Loads modifications from DB into the cache in the interval [minModId, maxModId)

Parameters:

minModId - min modification id (included)

maxModId - max modification id (excluded)

Returns:

collection of loaded modifications (unsorted)

loadMissingVcsRootModifications

@NotNull
public Collection<SVcsModification> loadMissingVcsRootModifications(@NotNull
                                                                    VcsRootInstance rootInstance)

afterPropertiesSet

public void afterPropertiesSet()

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

getModificationDigest

public static long getModificationDigest(@NotNull
                                         SVcsModification modification)

getDuplicates

@NotNull
public Collection<SVcsModification> getDuplicates(@NotNull
                                                  SVcsModification modification,
                                                  boolean byDisplayVersion)

Specified by:

getDuplicates in interface VcsModificationsStorage

Parameters:

modification - modification to get duplicates for

byDisplayVersion - if true, comparison will be done not by version, but by displayVersion

Returns:

findModificationsByDisplayVersion

@NotNull
public List<SVcsModification> findModificationsByDisplayVersion(@NotNull
                                                                String version)

Specified by:

findModificationsByDisplayVersion in interface VcsModificationsStorage

getModificationsWithSameVersion

@NotNull
public Collection<SVcsModification> getModificationsWithSameVersion(@NotNull
                                                                    VcsRootInstance root,
                                                                    @NotNull
                                                                    String modificationVcsVersion)

Specified by:

getModificationsWithSameVersion in interface VcsModificationsStorage

findModificationsByVersions

@NotNull
public Map<String,SVcsModification> findModificationsByVersions(@NotNull
                                                                      VcsRootInstance root,
                                                                      @NotNull
                                                                      Collection<String> versions)

Description copied from interface: VcsModificationsStorage

For the specified VCS root instance and a set of revisions lookups corresponding SVcsModification instances and returns them as map of revision to the found instance.

Specified by:

findModificationsByVersions in interface VcsModificationsStorage

Parameters:

root - vcs root instance where to perform lookup

versions - set of versions for which to perform lookup

Returns:

map of version to the SVcsModification instance

findModificationsByVersion

@NotNull
public List<SVcsModification> findModificationsByVersion(@NotNull
                                                         String version)

Specified by:

findModificationsByVersion in interface VcsModificationsStorage

findCached

@Nullable
public SVcsModification findCached(long id)

Specified by:

findCached in interface VcsModificationsStorage

loadChangedFiles

@NotNull
public List<VcsChange> loadChangedFiles(long modificationId)

Specified by:

loadChangedFiles in interface VcsModificationsStorage

loadChangedFiles

@NotNull
public Map<Long,List<VcsChange>> loadChangedFiles(@NotNull
                                                        Set<Long> modificationIds)

Specified by:

loadChangedFiles in interface VcsModificationsStorage

findExpiredModificationsRelatedToBuildType

@NotNull
public List<SVcsModification> findExpiredModificationsRelatedToBuildType(@NotNull
                                                                         String buildTypeId,
                                                                         long startModId,
                                                                         int maxChangesToReturn)

Specified by:

findExpiredModificationsRelatedToBuildType in interface VcsModificationsStorage

findExpiredModificationsRelatedToVcsRoot

@NotNull
public List<SVcsModification> findExpiredModificationsRelatedToVcsRoot(@NotNull
                                                                       VcsRootInstance vcsRootInstance,
                                                                       long startModId,
                                                                       int maxChangesToReturn)

Specified by:

findExpiredModificationsRelatedToVcsRoot in interface VcsModificationsStorage

getNumberOfModificationsInCache

public int getNumberOfModificationsInCache()

Specified by:

getNumberOfModificationsInCache in interface VcsModificationsStorage

getAttributes

@NotNull
public Map<String,String> getAttributes(long modificationId)

Specified by:

getAttributes in interface VcsModificationsStorage

cleanupExpiredModificationsFromCache

@NotNull
public Set<SVcsModification> cleanupExpiredModificationsFromCache()

Description copied from interface: VcsModificationsStorage

Removes expired modifications from cache.

Specified by:

cleanupExpiredModificationsFromCache in interface VcsModificationsStorage

Returns:

clearCache

public void clearCache()

Description copied from interface: VcsModificationsStorage

Clears the whole modifications cache.

Specified by:

clearCache in interface VcsModificationsStorage

isVcsChangesCacheInitialized

public boolean isVcsChangesCacheInitialized()

Specified by:

isVcsChangesCacheInitialized in interface VcsModificationsStorage

Returns:

true if internal cache of VCS changes is initialized

cleanupModificationsFromCache

@NotNull
public Set<SVcsModification> cleanupModificationsFromCache(long minChangeTimestamp)

findLastModification

@Nullable
public SVcsModification findLastModification(@NotNull
                                             LVcsRootInstance vcsRoot)

Specified by:

findLastModification in interface VcsModificationsStorage

findLastCachedModificationUpTo

@Nullable
public SVcsModification findLastCachedModificationUpTo(@NotNull
                                                       VcsRootInstance vcsRoot,
                                                       long upperBoundModificationId)

Specified by:

findLastCachedModificationUpTo in interface VcsModificationsStorage

findFirstCachedModification

@Nullable
public SVcsModification findFirstCachedModification(@NotNull
                                                    VcsRootInstance vcsRoot)

Specified by:

findFirstCachedModification in interface VcsModificationsStorage

findModificationsByUsername

@NotNull
public List<SVcsModification> findModificationsByUsername(@NotNull
                                                          String userName)

Specified by:

findModificationsByUsername in interface VcsModificationsStorage

findModificationById

@Nullable
public SVcsModification findModificationById(long modId)

Specified by:

findModificationById in interface VcsModificationsStorage

findModificationsByIds

@NotNull
public Collection<SVcsModification> findModificationsByIds(@NotNull
                                                           Collection<Long> modificationIds)

Specified by:

findModificationsByIds in interface VcsModificationsStorage

processModifications

public void processModifications(@NotNull
                                 ItemProcessor<SVcsModification> processor)

Description copied from interface: VcsModificationsStorage

Processes all modifications from newest to oldest

Specified by:

processModifications in interface VcsModificationsStorage

Parameters:

processor - callback to call for each modification

processModificationsBackwards

public void processModificationsBackwards(@NotNull
                                          ItemProcessor<SVcsModification> processor)

Description copied from interface: VcsModificationsStorage

Processes all modifications from oldest to newest

Specified by:

processModificationsBackwards in interface VcsModificationsStorage

Parameters:

processor - callback to call for each modification

processModificationsBackwards

public void processModificationsBackwards(@NotNull
                                          ItemProcessor<SVcsModification> processor,
                                          long startModId)

Description copied from interface: VcsModificationsStorage

Processes all modifications from oldest to newest starting from the specified modification id.

Specified by:

processModificationsBackwards in interface VcsModificationsStorage

Parameters:

processor - callback to call for each modification

processModifications

public void processModifications(@NotNull
                                 ItemProcessor<SVcsModification> processor,
                                 long startModId)

Description copied from interface: VcsModificationsStorage

Processes all modifications starting from one with max id less or equal to specified starting point.

Specified by:

processModifications in interface VcsModificationsStorage

Parameters:

processor - callback to call for each modification

getAllModifications

@NotNull
public List<SVcsModification> getAllModifications()

Specified by:

getAllModifications in interface VcsModificationsStorage

getAllModificationsSince

@NotNull
public List<SVcsModification> getAllModificationsSince(@NotNull
                                                       Date sinceDate)

Specified by:

getAllModificationsSince in interface VcsModificationsStorage

getBuildTypeId

@NotNull
public static String getBuildTypeId(@NotNull
                                    SBuildType buildType)

getMinModificationId

public long getMinModificationId()

Specified by:

getMinModificationId in interface VcsModificationsStorage

Returns:

minimal cached modification id available at the moment (changes older than this id must not be traversed), or 0 if cache is empty.

getMaxModificationId

public long getMaxModificationId()

Specified by:

getMaxModificationId in interface VcsModificationsStorage

Returns:

maximal cached modification id at the moment, or -1 if cache is empty.

persistModification

@NotNull
public SVcsModification persistModification(long id,
                                            @NotNull
                                            ModificationData modificationData,
                                            @NotNull
                                            Collection<SBuildType> relatedConfigurations,
                                            @NotNull
                                            Map<String,RelationType> changeTypes,
                                            @NotNull
                                            List<Map<String,RelationType>> edgeRelations,
                                            @NotNull
                                            Date registrationDate)

Specified by:

persistModification in interface VcsModificationsStorage

addEdgeRelations

public void addEdgeRelations(@NotNull
                             SVcsModification modification,
                             @NotNull
                             List<Map<String,RelationType>> newEdgeRelations)

Specified by:

addEdgeRelations in interface VcsModificationsStorage

updateModificationRelatedConfigurations

public void updateModificationRelatedConfigurations(@NotNull
                                                    SVcsModification modification,
                                                    @NotNull
                                                    Map<String,RelationType> changeTypes)

Specified by:

updateModificationRelatedConfigurations in interface VcsModificationsStorage

updateDescription

public void updateDescription(long modificationId,
                              @NotNull
                              String value)

Specified by:

updateDescription in interface VcsModificationsStorage

getModificationRelations

@NotNull
public RelatedConfigurations getModificationRelations(@NotNull
                                                      SVcsModification modification)

Specified by:

getModificationRelations in interface VcsModificationsStorage

setVcsModificationPersister

public void setVcsModificationPersister(@NotNull
                                        VcsModificationsStorageImpl.VcsModificationPersister vcsModificationPersister)

getVcsModificationPersister

@NotNull
public VcsModificationsStorageImpl.VcsModificationPersister getVcsModificationPersister()

optimizeVcsChangesCacheForReadPerformance

public void optimizeVcsChangesCacheForReadPerformance()

getVcsModificationMaxAgeDays

public static int getVcsModificationMaxAgeDays()