source: bus-n-go-pavel-216049/bus-n-go-backend/src/main/kotlin/mk/ukim/finki/busngobackend/service/MaterializedViewService.kt

package mk.ukim.finki.busngobackend.service

import org.springframework.jdbc.core.JdbcTemplate
import org.springframework.stereotype.Service
import org.springframework.transaction.annotation.Transactional

@Service
class MaterializedViewService(
    private val jdbcTemplate: JdbcTemplate,
) {
    @Transactional
    fun refreshAverageTimeDiffs() {
        val sql = "REFRESH MATERIALIZED VIEW CONCURRENTLY project.avg_time_diffs;"
        jdbcTemplate.execute(sql)
    }

    @Transactional
    fun refreshCommutesByHour() {
        val sql = "refresh materialized view concurrently project.most_busy_part_of_the_day;"
        jdbcTemplate.execute(sql)
    }

    @Transactional
    fun refreshFinesPerLine() {
        val sql = "refresh materialized view concurrently project.kazna_po_linija;"
        jdbcTemplate.execute(sql)
    }

    @Transactional
    fun refreshTotalIncome() {
        val sql = "refresh materialized view concurrently project.total_income;"
        jdbcTemplate.execute(sql)
    }
}