Spring Boot多租户切换失效：无法切换租户查询问题求助

核心问题分析 #

你遇到的本质问题是：同一个请求线程内，Hibernate Session/数据库连接一旦建立，就会绑定当前租户对应的数据源，后续修改TenantContext无法触发数据源重新路由。即使添加了@Transactional(REQUIRES_NEW)，如果是Service内部方法调用，Spring AOP不会拦截，导致新事务不生效，数据源无法切换。

具体解决方案 #

方案1：拆分独立事务方法，规避内部调用AOP失效 #

将不同租户的查询逻辑拆分为独立的Service方法，每个方法标注@Transactional(REQUIRES_NEW)，确保每次查询都开启全新事务，从而重新获取对应租户的数据源。

修改Service层代码

@Service
@RequiredArgsConstructor
public class EvGroupService {
    private final EvGroupRepository evGroupRepository;

    @Transactional(propagation = Propagation.REQUIRES_NEW)
    public EvGroup findByCodeFromCommonTenant(String grp) {
        TenantContext.setCurrentTenant("COMMON_TENANT");
        try {
            return evGroupRepository.findByCode(grp);
        } finally {
            TenantContext.clear();
        }
    }

    @Transactional(propagation = Propagation.REQUIRES_NEW)
    public EvGroup findByCodeFromSpecificTenantA(String grp) {
        TenantContext.setCurrentTenant("SPECIFIC_TENANT_A");
        try {
            return evGroupRepository.findByCode(grp);
        } finally {
            TenantContext.clear();
        }
    }
}

修改Controller层代码

@RestController
@RequiredArgsConstructor
public class TEST_ControllerImpl extends SessionFactoryUtil implements TEST_Controller {
    private final EvGroupService evGroupService;

    @Override
    public ResponseEntity<?> getGrp(String token, String grp) {
        EvGroup result1 = evGroupService.findByCodeFromCommonTenant(grp);
        EvGroup result2 = evGroupService.findByCodeFromSpecificTenantA(grp);

        return ResponseEntity.ok(convert(result1));
    }
}

方案2：使用TransactionTemplate手动管理事务 #

如果不想拆分方法，可直接在Controller中用TransactionTemplate执行不同租户的查询，强制每次执行都开启新事务：

配置TransactionTemplate

@Configuration
public class TransactionConfig {
    @Bean
    public TransactionTemplate transactionTemplate(PlatformTransactionManager transactionManager) {
        return new TransactionTemplate(transactionManager);
    }
}

修改Controller代码

@RestController
@RequiredArgsConstructor
public class TEST_ControllerImpl extends SessionFactoryUtil implements TEST_Controller {
    private final EvGroupRepository evGroupRepository;
    private final TransactionTemplate transactionTemplate;

    @Override
    public ResponseEntity<?> getGrp(String token, String grp) {
        // 查询COMMON_TENANT
        EvGroup result1 = transactionTemplate.execute(status -> {
            TenantContext.setCurrentTenant("COMMON_TENANT");
            try {
                return evGroupRepository.findByCode(grp);
            } finally {
                TenantContext.clear();
            }
        });

        // 查询SPECIFIC_TENANT_A
        EvGroup result2 = transactionTemplate.execute(status -> {
            TenantContext.setCurrentTenant("SPECIFIC_TENANT_A");
            try {
                return evGroupRepository.findByCode(grp);
            } finally {
                TenantContext.clear();
            }
        });

        return ResponseEntity.ok(convert(result1));
    }
}

关键注意事项 #

• 事务边界必须包裹租户上下文设置：确保租户切换在事务开启前完成，否则数据源路由会使用旧的租户值。
• 必须用try-finally清理TenantContext：避免线程池复用导致的租户上下文泄露。
• Entity的Schema动态配置：如果你的Entity固定绑定某个Schema（比如@Table(schema = "COMMON_SCHEMA")），需要调整为动态Schema映射，或者针对不同租户创建对应的Entity，否则会出现表不存在的异常。

内容的提问来源于stack exchange，提问作者Donald Duck