Package eu.dnetlib.broker.common.stats

Interface OpenaireDsStatRepository

All Superinterfaces:

org.springframework.data.repository.CrudRepository<OpenaireDsStat,OpenaireDsStatPK>, org.springframework.data.jpa.repository.JpaRepository<OpenaireDsStat,OpenaireDsStatPK>, org.springframework.data.repository.PagingAndSortingRepository<OpenaireDsStat,OpenaireDsStatPK>, org.springframework.data.repository.query.QueryByExampleExecutor<OpenaireDsStat>, org.springframework.data.repository.Repository<OpenaireDsStat,OpenaireDsStatPK>

public interface OpenaireDsStatRepository
extends org.springframework.data.jpa.repository.JpaRepository<OpenaireDsStat,OpenaireDsStatPK>

Method Summary

Modifier and Type	Method	Description
long	countDatasourcesWithEvents()
void	deleteAlertsByDsId(String dsId)
long	totalEvents()

Methods inherited from interface org.springframework.data.repository.CrudRepository

count, delete, deleteAll, deleteAll, deleteAllById, deleteById, existsById, findById, save

Methods inherited from interface org.springframework.data.jpa.repository.JpaRepository

deleteAllByIdInBatch, deleteAllInBatch, deleteAllInBatch, deleteInBatch, findAll, findAll, findAll, findAll, findAllById, flush, getById, getOne, saveAll, saveAllAndFlush, saveAndFlush

Methods inherited from interface org.springframework.data.repository.PagingAndSortingRepository

findAll

Methods inherited from interface org.springframework.data.repository.query.QueryByExampleExecutor

count, exists, findAll, findOne

Method Details

totalEvents

@Query(value="select sum(size) from oa_datasource_stats",
       nativeQuery=true)
long totalEvents()

countDatasourcesWithEvents

@Query(value="select count(distinct name) from oa_datasource_stats where size > 0",
       nativeQuery=true)
long countDatasourcesWithEvents()

deleteAlertsByDsId

@Modifying
@Query(value="delete from oa_datasource_stats where topic like \'ALERT/%\' and lower(id) = lower(?)",
       nativeQuery=true)
void deleteAlertsByDsId(String dsId)