artin/OBP-API
1
0
Fork 0
mirror of https://github.com/OpenBankProject/OBP-API.git synced 2026-02-06 19:16:53 +00:00
Code Issues Packages Projects Releases Wiki Activity

feature/Add MetricsArchive table 4

Browse Source
This commit is contained in:
Marko Milić 2022-12-02 13:57:00 +01:00
parent 924e271333
commit bf30fabb5b
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
obp-api/src/main/scala/code/scheduler/MetricsArchiveScheduler.scala
View File

@ -40,9 +40,9 @@ object MetricsArchiveScheduler extends MdcLoggable {
case days if days > 364 => days
case _ => 365
}
val oneYearAgo: Date = new Date(currentTime.getTime - (oneDayInMillis * days))
val someYearsAgo: Date = new Date(currentTime.getTime - (oneDayInMillis * days))
// Delete the outdated rows from the table "MetricsArchive"
MetricsArchive.bulkDelete_!!(By_<=(MetricsArchive.date, oneYearAgo))
MetricsArchive.bulkDelete_!!(By_<=(MetricsArchive.date, someYearsAgo))
}
def conditionalDeleteMetricsRow() = {
@ -53,12 +53,12 @@ object MetricsArchiveScheduler extends MdcLoggable {
}
val someDaysAgo: Date = new Date(currentTime.getTime - (oneDayInMillis * days))
// Get the data from the table "Metric" older than specified by retain_metrics_days
val chunkOfData = APIMetrics.apiMetrics.vend.getAllMetrics(List(OBPToDate(someDaysAgo)))
chunkOfData map { i =>
val canditateMetricRowsToMove = APIMetrics.apiMetrics.vend.getAllMetrics(List(OBPToDate(someDaysAgo)))
canditateMetricRowsToMove map { i =>
// and copy it to the table "MetricsArchive"
copyRowToMetricsArchive(i)
}
val maybeDeletedRows: List[(Boolean, Long)] = chunkOfData map { i =>
val maybeDeletedRows: List[(Boolean, Long)] = canditateMetricRowsToMove map { i =>
// and delete it after successful coping
MetricsArchive.find(By(MetricsArchive.primaryKey, i.getPrimaryKey())) match {
case Full(_) => (MappedMetric.bulkDelete_!!(By(MappedMetric.id, i.getPrimaryKey())), i.getPrimaryKey())