マルチテナントプラグイン

public interface TenantLineHandler {

    /**
     * テナント ID 値の式を取得します。単一の ID 値のみをサポートします
     *
     * @return テナント ID 値の式
     */
    Expression getTenantId();

    /**
     * テナントフィールド名を取得します
     * デフォルトのフィールド名は: tenant_id
     *
     * @return テナントフィールド名
     */
    default String getTenantIdColumn() {
        return "tenant_id";
    }

    /**
     * テーブル名に基づいて、マルチテナント条件の追加をスキップするかどうかを判断します
     * デフォルトではすべて解析し、マルチテナント条件を追加します
     *
     * @param tableName テーブル名
     * @return スキップするかどうか, true: スキップする, false: 解析してマルチテナント条件を追加する必要がある
     */
    default boolean ignoreTable(String tableName) {
        return false;
    }

    /**
     * テナントフィールドの挿入ロジックをスキップします
     *
     * @param columns        挿入フィールド
     * @param tenantIdColumn テナント ID フィールド
     * @return
     */
    default boolean ignoreInsert(List<Column> columns, String tenantIdColumn) {
        return columns.stream().map(Column::getColumnName).anyMatch(i -> i.equalsIgnoreCase(tenantIdColumn));
    }
}

@Component
public class CustomTenantHandler implements TenantLineHandler {

    @Override
    public Expression getTenantId() {
        // テナントコンテキストがあり、現在のユーザーのテナントを取得できると仮定します
         Long tenantId = TenantContextHolder.getCurrentTenantId();
        // テナントIDの式を返します。LongValue は JSQLParser の bigint 型を表すクラスです
        return new LongValue(tenantId);;
    }

    @Override
    public String getTenantIdColumn() {
        return "tenant_id";
    }

    @Override
    public boolean ignoreTable(String tableName) {
        // 必要に応じて、このテーブルを無視するかどうかを返します
        return false;
    }

}

@Configuration
@MapperScan("com.yourpackage.mapper")
public class MybatisPlusConfig {

    @Autowired
    private CustomTenantHandler customTenantHandler;

    @Bean
    public MybatisPlusInterceptor mybatisPlusInterceptor() {
        MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
        TenantLineInnerInterceptor tenantInterceptor = new TenantLineInnerInterceptor();
        tenantInterceptor.setTenantLineHandler(customTenantHandler);
        interceptor.addInnerInterceptor(tenantInterceptor);
        return interceptor;
    }
}

static {
    // デフォルトでシリアライズをサポート FstSerialCaffeineJsqlParseCache, JdkSerialCaffeineJsqlParseCache
    JsqlParserGlobal.setJsqlParseCache(new JdkSerialCaffeineJsqlParseCache(
      (cache) -> cache.maximumSize(1024)
      .expireAfterWrite(5, TimeUnit.SECONDS))
    );
}