From 649f85cc6574422df707447160fa963128db2f07 Mon Sep 17 00:00:00 2001 From: infin_caishuxiao Date: Fri, 23 Feb 2018 11:29:12 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A4=9A=E6=95=B0=E6=8D=AE=E6=BA=90=E4=BF=AE?= =?UTF-8?q?=E5=A4=8Dmapper=E7=BB=91=E5=AE=9A=E7=9A=84bug?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../risk/table/prd/extend/RiskStatsDTO.java | 18 ++++++++---------- .../job/executor/core/config/PrdDbConfig.java | 6 ++++++ .../executor/core/config/StatsDbConfig.java | 8 +++++++- .../RiskCountStatisticsJobHandler.java | 4 +--- .../src/main/resources/application.properties | 7 +++---- .../resources/mapping/prd/TRiskRuleMapper.xml | 12 ++++++++++-- 6 files changed, 35 insertions(+), 20 deletions(-) diff --git a/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/table/prd/extend/RiskStatsDTO.java b/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/table/prd/extend/RiskStatsDTO.java index 13d692ba..f51e7f5e 100644 --- a/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/table/prd/extend/RiskStatsDTO.java +++ b/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/table/prd/extend/RiskStatsDTO.java @@ -3,10 +3,16 @@ package com.infincash.statistics.risk.table.prd.extend; import java.util.Date; public class RiskStatsDTO { - String riskRuleId; + String riskRuleId; int count; Date time; + public Date getTime() { + return time; + } + public void setTime(Date time) { + this.time = time; + } public String getRiskRuleId() { return riskRuleId; } @@ -18,13 +24,5 @@ public class RiskStatsDTO { } public void setCount(int count) { this.count = count; - } - public Date getTime() { - return time; - } - public void setTime(Date time) { - this.time = time; - } - - + } } diff --git a/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/xxl/job/executor/core/config/PrdDbConfig.java b/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/xxl/job/executor/core/config/PrdDbConfig.java index 9c10e753..c890aa05 100644 --- a/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/xxl/job/executor/core/config/PrdDbConfig.java +++ b/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/xxl/job/executor/core/config/PrdDbConfig.java @@ -10,10 +10,13 @@ import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; +import org.springframework.core.io.support.PathMatchingResourcePatternResolver; @Configuration @MapperScan(basePackages = {"com.infincash.statistics.risk.mapper.prd"}, sqlSessionFactoryRef = "sqlSessionFactoryPrd") public class PrdDbConfig { + static final String MAPPER_LOCATION = "classpath:mapping/prd/*.xml"; + @Autowired @Qualifier("prd") private DataSource prd; @@ -22,6 +25,9 @@ public class PrdDbConfig { public SqlSessionFactory sqlSessionFactoryPrd() throws Exception { SqlSessionFactoryBean factoryBean = new SqlSessionFactoryBean(); factoryBean.setDataSource(prd); + factoryBean.setMapperLocations( + new PathMatchingResourcePatternResolver().getResources(MAPPER_LOCATION) + ); return factoryBean.getObject(); } diff --git a/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/xxl/job/executor/core/config/StatsDbConfig.java b/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/xxl/job/executor/core/config/StatsDbConfig.java index a0b93c02..ce4fb563 100644 --- a/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/xxl/job/executor/core/config/StatsDbConfig.java +++ b/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/xxl/job/executor/core/config/StatsDbConfig.java @@ -10,10 +10,13 @@ import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; +import org.springframework.core.io.support.PathMatchingResourcePatternResolver; @Configuration @MapperScan(basePackages = {"com.infincash.statistics.risk.mapper.stats"}, sqlSessionFactoryRef = "sqlSessionFactoryStats") public class StatsDbConfig { + static final String MAPPER_LOCATION = "classpath:mapping/stats/*.xml"; + @Autowired @Qualifier("stats") private DataSource stats; @@ -21,7 +24,10 @@ public class StatsDbConfig { @Bean public SqlSessionFactory sqlSessionFactoryStats() throws Exception { SqlSessionFactoryBean factoryBean = new SqlSessionFactoryBean(); - factoryBean.setDataSource(stats); // 使用titan数据源, 连接titan库 + factoryBean.setDataSource(stats); + factoryBean.setMapperLocations( + new PathMatchingResourcePatternResolver().getResources(MAPPER_LOCATION) + ); return factoryBean.getObject(); } diff --git a/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/xxl/job/executor/service/jobhandler/RiskCountStatisticsJobHandler.java b/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/xxl/job/executor/service/jobhandler/RiskCountStatisticsJobHandler.java index 5d8f0226..b10f05bc 100644 --- a/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/xxl/job/executor/service/jobhandler/RiskCountStatisticsJobHandler.java +++ b/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/xxl/job/executor/service/jobhandler/RiskCountStatisticsJobHandler.java @@ -32,10 +32,8 @@ public class RiskCountStatisticsJobHandler extends IJobHandler { public ReturnT execute(String param) throws Exception { List aa = service.countRecentRisk(); for (RiskStatsDTO a:aa) { - XxlJobLogger.log(a.getRiskRuleId() + a.getCount() + a.getTime().toGMTString()); + XxlJobLogger.log(a.getRiskRuleId() +", "+ a.getCount()+", "+ a.getTime()); } - XxlJobLogger.log("beat at:"); return SUCCESS; } - } diff --git a/xxl-job-executor-samples/xxl-job-executor-db/src/main/resources/application.properties b/xxl-job-executor-samples/xxl-job-executor-db/src/main/resources/application.properties index eac60995..55025ee1 100644 --- a/xxl-job-executor-samples/xxl-job-executor-db/src/main/resources/application.properties +++ b/xxl-job-executor-samples/xxl-job-executor-db/src/main/resources/application.properties @@ -8,10 +8,9 @@ spring.datasource.stats.username=jobopr spring.datasource.stats.password=jobopr666 spring.datasource.stats.driver-class-name=com.mysql.jdbc.Driver - - -mybatis.mapper-locations=classpath:mapping/*/*.xml -mybatis.type-aliases-package=com.infincash.statistics.risk.table +# multi datasource no need declare here +#mybatis.mapper-locations=classpath:mapping/*.xml +#mybatis.type-aliases-package=com.infincash.statistics.risk.table # web port server.port=9001 diff --git a/xxl-job-executor-samples/xxl-job-executor-db/src/main/resources/mapping/prd/TRiskRuleMapper.xml b/xxl-job-executor-samples/xxl-job-executor-db/src/main/resources/mapping/prd/TRiskRuleMapper.xml index 930de187..2934299a 100644 --- a/xxl-job-executor-samples/xxl-job-executor-db/src/main/resources/mapping/prd/TRiskRuleMapper.xml +++ b/xxl-job-executor-samples/xxl-job-executor-db/src/main/resources/mapping/prd/TRiskRuleMapper.xml @@ -1,11 +1,19 @@ - + \ No newline at end of file