fix

.gitignore

@@ -0,0 +1,41 @@
+# Created by .ignore support plugin (hsz.mobi)
+# Package Files #
+*.jar
+*.war
+*.nar
+*.ear
+*.zip
+*.tar.gz
+*.rar
+target/
+
+# Compiled class file
+*.class
+
+# Log file
+*.log
+
+### Gradle Files ###
+.gradle
+/build/
+!gradle/wrapper/gradle-wrapper.jar
+
+### eclipse ###
+.classpath
+.factorypath
+.project
+
+### IntelliJ IDEA ###
+.idea
+*.iws
+*.iml
+*.ipr
+/out/
+
+### svn ###
+.svn
+
+### gitgnore ###
+*.gitgnore
+.gitgnore
+/gradle/wrapper/

src/main/java/com/zcxk/meterreadingsystemv2/controller/TestController.java

@@ -50,7 +50,18 @@ public class TestController {
     public AjaxMessage testGetUser(
     ) {
         //meterReadService.testGetUser();
-        meterReadService.test(null);
+        //meterReadService.test(null);
+        meterReadService.testQ(null);
+        return new AjaxMessage<>(ResultStatus.OK);
+    }
+
+    @GetMapping("test2")
+    @ApiOperation(value = "测试2")
+    public AjaxMessage testGetUser2(
+    ) {
+        //meterReadService.testGetUser();
+        //meterReadService.test(null);
+        meterReadService.testQ2(null);
         return new AjaxMessage<>(ResultStatus.OK);
     }
 

src/main/java/com/zcxk/meterreadingsystemv2/dbs/DataSourceConfigurer.java

@@ -55,6 +55,9 @@ public class DataSourceConfigurer {
         dataSource.setPassword(evn.getProperty( prefix + "password"));
         dataSource.setDriverClassName(evn.getProperty( prefix + "driver-class-name"));
         dataSource.setDbType(evn.getProperty( prefix + "type"));
+        dataSource.setConnectionErrorRetryAttempts(1);
+        dataSource.setBreakAfterAcquireFailure(true); // 请求失败之后中断
+        dataSource.setMaxWait(5000);//请求失败后等待时间
         return dataSource;
     }
 

src/main/java/com/zcxk/meterreadingsystemv2/service/MeterReadService.java

@@ -8,4 +8,7 @@ public interface MeterReadService {
     void test(String name);
 
 
+    void testQ(Object o);
+
+    void testQ2(Object o);
 }

src/main/java/com/zcxk/meterreadingsystemv2/service/impl/MeterReadServiceImpl.java

@@ -3,12 +3,14 @@ package com.zcxk.meterreadingsystemv2.service.impl;
 import com.zcxk.meterreadingsystemv2.dao.DeviceDataDimMapper;
 import com.zcxk.meterreadingsystemv2.dao.DeviceMapper;
 import com.zcxk.meterreadingsystemv2.dao.YcblhbMapper;
+import com.zcxk.meterreadingsystemv2.dao.YhsbgxbMapper;
 import com.zcxk.meterreadingsystemv2.dbs.DynamicDataSource;
 import com.zcxk.meterreadingsystemv2.dbs.DynamicDataSourceContextHolder;
 import com.zcxk.meterreadingsystemv2.dbs.SwitchDB;
 import com.zcxk.meterreadingsystemv2.dto.DeviceCustomerInfo;
 import com.zcxk.meterreadingsystemv2.entity.InstallList;
 import com.zcxk.meterreadingsystemv2.entity.Ycblhb;
+import com.zcxk.meterreadingsystemv2.entity.Yhsbgxb;
 import com.zcxk.meterreadingsystemv2.service.MeterReadService;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -34,7 +36,24 @@ public class MeterReadServiceImpl implements MeterReadService {
     private DeviceDataDimMapper deviceDataDimMapper;
     @Autowired
     private DeviceMapper deviceMapper;
+    @Resource
+    private YhsbgxbMapper yhsbgxbMapper;
+
+    @Override
+    public void testQ(Object o) {
+        DynamicDataSourceContextHolder.setDataSourceKey("xp");
+        log.info("＝＝＝＝＝service当前连接的数据库是:" + DynamicDataSourceContextHolder.getDataSourceKey());
+        Yhsbgxb yhsbgxb = yhsbgxbMapper.findByBsm("2100011");
+        System.out.println(yhsbgxb);
+    }
 
+    @Override
+    public void testQ2(Object o) {
+        DynamicDataSourceContextHolder.setDataSourceKey("balikun");
+        log.info("＝＝＝＝＝service当前连接的数据库是:" + DynamicDataSourceContextHolder.getDataSourceKey());
+        Yhsbgxb yhsbgxb = yhsbgxbMapper.findByBsm("2100011");
+        System.out.println(yhsbgxb);
+    }
 
     @Override
     public void test(String name) {