@Entity
@Table(schema = "#{tenant.schema}")
public class User {
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;
    // 其他屬性和方法...
}

// Hibernate多租戶策略配置
@Bean
public MultiTenantConnectionProvider multiTenantConnectionProvider() {
    return new AbstractMultiTenantConnectionProvider() {
        @Override
        protected ConnectionProvider getAnyConnectionProvider() {
            // 返回通用的數(shù)據(jù)庫連接提供者
        }

        @Override
        protected ConnectionProvider selectConnectionProvider(String tenantIdentifier) {
            // 根據(jù)租戶ID切換數(shù)據(jù)庫連接
        }
    };
}

@Bean
public CurrentTenantResolver currentTenantResolver() {
    return new CurrentTenantResolver() {
        @Override
        public String resolveCurrentTenantIdentifier() {
            // 從上下文中獲取當(dāng)前租戶ID
        }

        @Override
        public boolean validateExistingCurrentSessions() {
            return true;
        }
    };
}

@Entity
@Table(name = "#{tenant.tablePrefix}_users")
public class User {
    // ...
}

// 自定義實體掃描配置
@Configuration
@ComponentScan(basePackages = {"com.example.entity"})
public class EntityScanConfig implements BeanClassLoaderAware, EntityManagerFactoryBuilderCustomizer {

    private ClassLoader classLoader;

    @Override
    public void customize(EntityManagerFactoryBuilder builder) {
        // 注入租戶ID到實體掃描過程中
        builder.persistenceUnitRootLocation(new ClassPathResource("META-INF/persistence.xml"));
        builder.namingStrategy(new CustomNamingStrategy(classLoader));
    }

    // 實現(xiàn)自定義命名策略
    public class CustomNamingStrategy extends ImprovedNamingStrategy {
        // 根據(jù)租戶ID動態(tài)生成表名
    }
}

@Configuration
public class DataSourceConfig {

    @Bean
    @Primary
    @ConfigurationProperties(prefix = "spring.datasource")
    public DataSourceProperties dataSourceProperties() {
        return new DataSourceProperties();
    }

    @Bean
    @Primary
    public DataSource dataSource(DataSourceProperties properties, @Qualifier("multiTenantRoutingDataSource") DataSource multiTenantDataSource) {
        HikariDataSource dataSource = properties.initializeDataSourceBuilder().type(HikariDataSource.class).build();
        if (multiTenantDataSource instanceof HikariDataSource) {
            ((HikariDataSource) dataSource).addHealthCheckRegistry(((HikariDataSource) multiTenantDataSource).getHealthCheckRegistry());
        }
        return dataSource;
    }

    @Bean
    public DataSource multiTenantRoutingDataSource(DataSource defaultDataSource) {
        Map<Object, Object> targetDataSources = new ConcurrentHashMap<>();
        DynamicRoutingDataSource dataSource = new DynamicRoutingDataSource();
        dataSource.setDefaultTargetDataSource(defaultDataSource);
        dataSource.setTargetDataSources(targetDataSources);
        dataSource.afterPropertiesSet();
        return dataSource;
    }

    // 添加租戶數(shù)據(jù)源
    public void addTenantDataSource(String tenantId, DataSource dataSource) {
        ((DynamicRoutingDataSource) multiTenantRoutingDataSource).addDataSource(tenantId, dataSource);
    }

    // 租戶數(shù)據(jù)源切換AOP
    @Aspect
    @Component
    public class TenantDataSourceAspect {
        @Before("@annotation(com.example.annotation.ChangeTenant)")
        public void changeDataSource(JoinPoint joinPoint, ChangeTenant annotation) {
            // 獲取當(dāng)前租戶ID并切換數(shù)據(jù)源
        }
    }
}