feat: create job to count address transaction

src/main/java/org/cardanofoundation/job/repository/ledgersync/AddressTxCountRepository.java

@@ -0,0 +1,16 @@
+package org.cardanofoundation.job.repository.ledgersync;
+
+import jakarta.transaction.Transactional;
+
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Modifying;
+import org.springframework.data.jpa.repository.Query;
+
+import org.cardanofoundation.explorer.common.entity.ledgersync.AddressTxCount;
+
+public interface AddressTxCountRepository extends JpaRepository<AddressTxCount, Long> {
+  @Modifying(clearAutomatically = true)
+  @Transactional
+  @Query(value = "REFRESH MATERIALIZED VIEW address_tx_count", nativeQuery = true)
+  void refreshMaterializedView();
+}

src/main/java/org/cardanofoundation/job/schedules/AggregateAnalyticSchedule.java

@@ -6,6 +6,7 @@
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
+import org.cardanofoundation.job.repository.ledgersync.AddressTxCountRepository;
 import org.cardanofoundation.job.repository.ledgersync.LatestTokenBalanceRepository;
 import org.cardanofoundation.job.repository.ledgersync.aggregate.AggregateAddressTokenRepository;
 import org.cardanofoundation.job.repository.ledgersync.aggregate.AggregateAddressTxBalanceRepository;
@@ -18,6 +19,7 @@ public class AggregateAnalyticSchedule {
   private final AggregateAddressTokenRepository aggregateAddressTokenRepository;
   private final AggregateAddressTxBalanceRepository aggregateAddressTxBalanceRepository;
   private final LatestTokenBalanceRepository latestTokenBalanceRepository;
+  private final AddressTxCountRepository addressTxCountRepository;
 
   @Scheduled(
       cron = "0 20 0 * * *",
@@ -55,4 +57,13 @@ public void refreshLatestTokenBalance() {
         "End Job refreshLatestTokenBalance, Time taken {}ms",
         System.currentTimeMillis() - currentTime);
   }
+
+  @Scheduled(fixedRateString = "${jobs.agg-address.fixed-delay}")
+  public void updateTxCountTable() {
+    log.info("Start job to update tx count for address");
+    long startTime = System.currentTimeMillis();
+    addressTxCountRepository.refreshMaterializedView();
+    long executionTime = System.currentTimeMillis() - startTime;
+    log.info("Update tx count for address successfully, takes: [{} ms]", executionTime);
+  }
 }

src/main/resources/config/application-dev.yaml

@@ -138,6 +138,8 @@ jobs:
   tx-chart:
     enabled: ${TX_CHART_JOB_ENABLED:true}
     fixed-delay: ${TX_CHART_FIXED_DELAY:300000}
+  agg-address:
+    fixed-delay: ${AGG_ADDRESS_FIXED_DELAY:300000}
   install-batch: 100
   limit-content: ${LIMIT_CONTENT_PER_SHEET:1000000}
 

src/main/resources/config/application-local.yaml

@@ -138,6 +138,8 @@ jobs:
   tx-chart:
     enabled: ${TX_CHART_JOB_ENABLED:true}
     fixed-delay: ${TX_CHART_FIXED_DELAY:300000}
+  agg-address:
+    fixed-delay: ${AGG_ADDRESS_FIXED_DELAY:300000}
   install-batch: 100
   limit-content: ${LIMIT_CONTENT_PER_SHEET:1000000}
 

src/main/resources/config/application-prod.yaml

@@ -138,6 +138,8 @@ jobs:
   tx-chart:
     enabled: ${TX_CHART_JOB_ENABLED:true}
     fixed-delay: ${TX_CHART_FIXED_DELAY:300000}
+  agg-address:
+    fixed-delay: ${AGG_ADDRESS_FIXED_DELAY:300000}
   install-batch: 100
   limit-content: ${LIMIT_CONTENT_PER_SHEET:1000000}
 

src/main/resources/db/migration/ledgersync/V1_3_24__add_materialized_view_for_address_tx_count_.sql

@@ -0,0 +1,8 @@
+DROP MATERIALIZED VIEW IF EXISTS address_tx_count;
+
+CREATE MATERIALIZED VIEW address_tx_count AS
+SELECT add.address                        AS address,
+       count(distinct ata.tx_hash)                        AS tx_count
+FROM address add
+         left join address_tx_amount ata on ata.address = add.address
+GROUP BY add.address;