测试腾讯云环境从库查询

src/main/java/cn/quantgroup/xyqb/service/user/impl/UserCenterServiceImpl.java

 package cn.quantgroup.xyqb.service.user.impl;
 
+import cn.quantgroup.tech.db.DSType;
+import cn.quantgroup.tech.db.TargetDataSource;
 import cn.quantgroup.xyqb.entity.UserAttached;
 import cn.quantgroup.xyqb.repository.IUserAttachedRepository;
 import cn.quantgroup.xyqb.service.user.UserCenterService;
@@ -28,6 +30,7 @@ public class UserCenterServiceImpl implements UserCenterService {
     private IUserAttachedRepository userAttachedRepository;
 
     @Override
+    @TargetDataSource(type = DSType.SLAVE)//查询从库
 //    @Cacheable(value = "userAttachedCache", key = "'xyqbUserAttached' + #userId", unless = "#result == null", cacheManager = "cacheManager")
     public UserAttached searchUserAttachedByUserId(long userId) {
         return userAttachedRepository.findByUserId(userId);

src/main/java/cn/quantgroup/xyqb/service/user/impl/UserDetailServiceImpl.java

 package cn.quantgroup.xyqb.service.user.impl;
 
+import cn.quantgroup.tech.db.DSType;
+import cn.quantgroup.tech.db.TargetDataSource;
 import cn.quantgroup.xyqb.Constants;
 import cn.quantgroup.xyqb.entity.User;
 import cn.quantgroup.xyqb.entity.UserDetail;
@@ -51,6 +53,7 @@ public class UserDetailServiceImpl implements IUserDetailService {
     private JdbcTemplate jdbcTemplate;
 
     @Override
+    @TargetDataSource(type = DSType.SLAVE)//查询从库
     public UserDetail findByUserId(Long userId) {
         UserDetail userDetail = userDetailRepository.findByUserId(userId);
         if (null == userDetail) {
@@ -73,6 +76,7 @@ public class UserDetailServiceImpl implements IUserDetailService {
     }
 
     @Override
+    @TargetDataSource(type = DSType.SLAVE)//查询从库
     public UserDetail findByPhoneNo(String phoneNo) {
         return userDetailRepository.findByPhoneNo(phoneNo);
     }

src/main/java/cn/quantgroup/xyqb/service/user/impl/UserServiceImpl.java

 package cn.quantgroup.xyqb.service.user.impl;
 
+import cn.quantgroup.tech.db.DSType;
+import cn.quantgroup.tech.db.TargetDataSource;
 import cn.quantgroup.user.enums.BizType;
 import cn.quantgroup.user.enums.IncomeRangeEnum;
 import cn.quantgroup.xyqb.Constants;
@@ -94,12 +96,14 @@ public class UserServiceImpl implements IUserService, IBaseController {
     private ILockIpv4Service lockIpv4Service;
 
     @Override
+    @TargetDataSource(type = DSType.SLAVE)//查询从库
 //    @Cacheable(value = "usercache", key = "'xyqbuser' + #phone", unless = "#result == null", cacheManager = "cacheManager")
     public User findByPhoneInDb(String phone) {
         return userRepository.findByPhoneNo(phone);
     }
 
     @Override
+    @TargetDataSource(type = DSType.SLAVE)//查询从库
     public Map<Long, String> findPhoneByIdsInDb(List<Long> userIds) {
         if (CollectionUtils.isEmpty(userIds)) {
             return Maps.newHashMap();