replica update 2

src/main/java/app/services/ShardingService.java

@@ -5,10 +5,12 @@ import jakarta.persistence.EntityManager;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import java.util.List;
 
 @Service
+@Transactional("RoTransactionManager")
 public class ShardingService {
 
     @Autowired

src/main/java/app/services/db/DetectService.java

@@ -9,10 +9,12 @@ import jakarta.persistence.PersistenceContext;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import java.util.*;
 
 @Service
+@Transactional("RoTransactionManager")
 public class DetectService {
 
     EntityManager entityManager;

src/main/java/app/services/db/DonateService.java

@@ -12,6 +12,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.stereotype.Component;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import java.math.BigDecimal;
 import java.util.HashMap;
@@ -20,6 +21,7 @@ import java.util.Map;
 import java.util.Optional;
 
 @Component
+@Transactional("RoTransactionManager")
 public class DonateService {
 
     EntityManager entityManager;

src/main/java/app/services/db/UsertimeService.java

@@ -16,7 +16,7 @@ import java.sql.Timestamp;
 import java.util.*;
 
 @Service
-@Transactional
+@Transactional("RoTransactionManager")
 public class UsertimeService {
 
     EntityManager entityManager;

src/main/java/app/updates/BanCountUpdater.java

@@ -10,10 +10,12 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
 
 import java.time.Instant;
 
 @Component
+@Transactional("RoTransactionManager")
 public class BanCountUpdater extends BaseUpdater{
     private Stats stats;
     @Value("${backend.updates.ban_count}")

src/main/java/app/updates/CountriesUpdater.java

@@ -13,12 +13,14 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
 
 import java.io.IOException;
 import java.net.UnknownHostException;
 import java.util.Map;
 
 @Component
+@Transactional("RoTransactionManager")
 public class CountriesUpdater extends BaseUpdater{
     Stats stats;
     GeoIP geoIP;

src/main/java/app/updates/UniqueUpdater.java

@@ -11,10 +11,12 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
 
 import static java.time.Instant.now;
 
 @Component
+@Transactional("RoTransactionManager")
 public class UniqueUpdater extends BaseUpdater{
     Stats stats;