Pārlūkot izejas kodu

selectdb_group_commit

huangpingkang 11 mēneši atpakaļ
vecāks
revīzija
96d0559edb

+ 2 - 2
job-adq/src/main/java/cn/com/ctop/job/adq/data/mapper/AdqAccountReportMapper.java

@@ -9,11 +9,11 @@ import java.util.List;
 
 public interface AdqAccountReportMapper {
     void addAccountHourList(@Param("adds") List<AdqAdvertiserReportHour> hourList);
-    @DS("selectdb_group_commit")
+    @DS("sd_group_commit")
     void addAccountHourListSD(@Param("adds") List<AdqAdvertiserReportHour> hourList);
 
     void addAccountDailyList(@Param("adds") List<AdqAdvertiserReportDaily> dailyList);
-    @DS("selectdb_group_commit")
+    @DS("sd_group_commit")
     void addAccountDailyListSD(@Param("adds") List<AdqAdvertiserReportDaily> dailyList);
 
     void updateAdqAccountStatus();

+ 1 - 1
job-adq/src/main/java/cn/com/ctop/job/adq/data/mapper/AdqAdIncomeMapper.java

@@ -11,7 +11,7 @@ public interface AdqAdIncomeMapper {
 
     void insertAdqAdIncome(List<AdqPublisherAdunitGeneral> reports);
 
-    @DS("selectdb_group_commit")
+    @DS("sd_group_commit")
     void insertAdqAdIncomeSD(List<AdqPublisherAdunitGeneral> reports);
 
     List<JSONObject> queryAdqIaaMiniApp(@Param("appId")String appId);

+ 2 - 2
job-adq/src/main/java/cn/com/ctop/job/adq/data/mapper/AdqAssetReportMapper.java

@@ -8,10 +8,10 @@ import java.util.List;
 
 public interface AdqAssetReportMapper {
     void insertAdqAssetReportDaily(List<AdqAssetReportDaily> reports);
-    @DS("selectdb_group_commit")
+    @DS("sd_group_commit")
     void insertAdqAssetReportDailySD(List<AdqAssetReportDaily> reports);
 
     void insertAdqAssetInfo(List<AdqAssetInfo> infos);
-    @DS("selectdb_group_commit")
+    @DS("sd_group_commit")
     void insertAdqAssetInfoSD(List<AdqAssetInfo> infos);
 }

+ 2 - 2
job-adq/src/main/java/cn/com/ctop/job/adq/data/mapper/AdqCreativeReportMapper.java

@@ -11,13 +11,13 @@ import java.util.List;
 public interface AdqCreativeReportMapper {
     void addsHourList(@Param("adds") List<AdqCreativeReportHour> hourList);
 
-    @DS("selectdb_group_commit")
+    @DS("sd_group_commit")
     void addsHourListSD(@Param("adds") List<AdqCreativeReportHour> hourList);
 
     List<JSONObject> getAccountList(@Param("accountId") Long accountId);
 
     void addsDaily(@Param("adds") List<AdqCreativeReportDaily> dailies);
-    @DS("selectdb_group_commit")
+    @DS("sd_group_commit")
     void addsDailySD(@Param("adds") List<AdqCreativeReportDaily> dailies);
 
 }

+ 1 - 1
job-adq/src/main/java/cn/com/ctop/job/adq/data/mapper/AdqFlowDetailsReportDailyMapper.java

@@ -18,7 +18,7 @@ public interface AdqFlowDetailsReportDailyMapper {
     List<AdvertiserAccount> getAdAccount();
 
     void replaceFlowDetailsReportDailies(@Param("list") List<AdqFlowDetailsReportDaily> dailyList);
-    @DS("selectdb_group_commit")
+    @DS("sd_group_commit")
     void replaceFlowDetailsReportDailiesSD(@Param("list") List<AdqFlowDetailsReportDaily> dailyList);
 
 }

+ 1 - 1
job-adq/src/main/resources/application.yml

@@ -93,7 +93,7 @@ spring:
           username: data
           password: hr@2025..
           driver-class-name: com.mysql.jdbc.Driver
-        selectdb_group_commit:
+        sd_group_commit:
           ## 注意此selectdb数据源不支持列更新,insert into 对于未指定列会被置为null,类似tidb replace into
           url: jdbc:mysql://selectdb-cn-vym4at1qw04.selectdbfe.rds.aliyuncs.com:9030/media_api?characterEncoding=UTF-8&useUnicode=true&useSSL=false&useServerPrepStmts=true&useLocalSessionState=true&rewriteBatchedStatements=true&cachePrepStmts=true&prepStmtCacheSqlLimit=99999&prepStmtCacheSize=500&sessionVariables=group_commit=async_mode,enable_nereids_planner=false
           username: data