@Configuration
public class DataResourceConfig {
	
	
	@Value("${spring.datasource.druid.driver-class-name}")
	private String driverClassName;
	@Value("${spring.datasource.druid.url}")
	private String dbUrl;
	@Value("${spring.datasource.druid.username}")
	private String username;
	@Value("${spring.datasource.druid.password}")
	private String password;
	@Value("${spring.datasource.druid.initialSize}")
	private int initialSize;
	@Value("${spring.datasource.druid.minIdle}")
	private int minIdle;
	@Value("${spring.datasource.druid.maxActive}")
	private int maxActive;
	@Value("${spring.datasource.druid.maxWait}")
	private int maxWait;
	@Value("${spring.datasource.druid.timeBetweenEvictionRunsMillis}")
	private int timeBetweenEvictionRunsMillis;
	@Value("${spring.datasource.druid.minEvictableIdleTimeMillis}")
	private int minEvictableIdleTimeMillis;
	@Value("${spring.datasource.druid.validationQuery}")
	private String validationQuery;
	@Value("${spring.datasource.druid.testWhileIdle}")
	private boolean testWhileIdle;
	@Value("${spring.datasource.druid.testOnBorrow}")
	private boolean testOnBorrow;
	@Value("${spring.datasource.druid.testOnReturn}")
	private boolean testOnReturn;
	@Value("${keycenter.client.encrypt}")
	private boolean encrypt;
	
	@Bean(name = "dataSource")
	public DataSource dataSource(KeycenterUtils keycenterUtils) {
		DruidDataSource datasource = new DruidDataSource();
		datasource.setDriverClassName(driverClassName);
		datasource.setUrl(dbUrl);
		if (encrypt) {
			datasource.setUsername(keycenterUtils.decrypt(username));
			datasource.setPassword(keycenterUtils.decrypt(password));
		} else {
			datasource.setUsername(username);
			datasource.setPassword(password);
		}
		datasource.setInitialSize(initialSize);
		datasource.setMinIdle(minIdle);
		datasource.setMaxActive(maxActive);
		datasource.setMaxWait(maxWait);
		datasource.setTimeBetweenEvictionRunsMillis(timeBetweenEvictionRunsMillis);
		datasource.setMinEvictableIdleTimeMillis(minEvictableIdleTimeMillis);
		datasource.setValidationQuery(validationQuery);
		datasource.setTestWhileIdle(testWhileIdle);
		datasource.setTestOnBorrow(testOnBorrow);
		datasource.setTestOnReturn(testOnReturn);
		return datasource;
	}
	
}

  private int minPoolSize = 5;
  private int maxPoolSize = 20;
  private int initialPoolSize = 5;
  private int checkoutTimeout = 3000;
  private boolean removeAbandoned = true;
  private int timeBetweenEvictionRunsMillis = 600000;
  private int minEvictableIdleTimeMillis = 300000;

/**
 * 数据源预热
 *
 * @author zhangyujin
 * @date 2026/1/15
 */
@Service
public class DataSourceWarmUp implements CommandLineRunner {


    /**
     * dataSourceStartWarmUp
     */
    @Resource
    private DataSourceStartWarmUp dataSourceStartWarmUp;

    /**
     * 数据源预热
     */
    @Override
    public void run(String... args) throws Exception {
        dataSourceStartWarmUp.warmUp();
    }

}




import com.baomidou.dynamic.datasource.DynamicRoutingDataSource;
import com.jd.merchant.business.platform.core.common.DbConstants;
import lombok.extern.slf4j.Slf4j;
import org.springframework.retry.annotation.Backoff;
import org.springframework.retry.annotation.Recover;
import org.springframework.retry.annotation.Retryable;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;

/**
 * DataSourceStartWarmUp
 *
 * @author zhangyujin
 * @date 2026/1/15
 */
@Service
@Slf4j
public class DataSourceStartWarmUp {
    /**
     * dynamicRoutingDataSource
     */
    @Resource
    private DynamicRoutingDataSource dynamicRoutingDataSource;

    /**
     * 数据源预热
     */
    @Retryable(value = Exception.class, maxAttempts = 4, backoff = @Backoff(delay = 20000, multiplier = 1.5))
    public void warmUp() {
        DataSource targetDs = dynamicRoutingDataSource.getDataSource(DbConstants.DataSourceName);
        if (targetDs == null) {
            throw new IllegalStateException("数据源 [" + DbConstants.DataSourceName + "] 未找到");
        }

        try (Connection conn = targetDs.getConnection();
             PreparedStatement ps = conn.prepareStatement("SELECT 1");
             ResultSet rs = ps.executeQuery()) {
            if (rs.next()) {
                log.info("数据源 [{}] 预热成功", DbConstants.DataSourceName);
            }
        } catch (Exception e) {
            log.warn("数据源 [{}] 预热失败，原因:{}", DbConstants.DataSourceName, e.getMessage());
            throw new RuntimeException("数据源预热失败，触发重试", e);
        }
    }

    /**
     * 数据源预热后失败了
     */
    @Recover
    public void recoverWarmUp(Exception ex) {
        log.error("所有重试均失败，数据源预热彻底失败", ex);
        throw new RuntimeException("数据源预热最终失败，应用无法安全启动", ex);
    }
}

@DS(DateSourceConstant.SLAVE_TEST)
@ApiOperation(value = "用户信息-单条查询", notes = "用户信息-单条查询-描述")
@RedisCache(RedisConstants.CacheEnum.COMMON)
@LogIndex
@GetMapping("user/{userId}")
@ResponseBody
public BaseRes<UserDemoVO> selectById(@ElParam @PathVariable("userId") Long userId) {
    UserDemoBO userDemoBo = userDemoService.selectById(userId);
    UserDemoVO userDemoVo = UserConverter.INSTANCE.covertUserDemoBoToVo(userDemoBo);
    return BaseRes.buildSuccess(userDemoVo);
}