// Filter by MIME type
        final List<OpenSearchAccessResult> htmlResults = dataService.getAccessResultList(builder -> {
            builder.setQuery(QueryBuilders.boolQuery()
                    .must(QueryBuilders.termQuery("sessionId", sessionId))
                    .must(QueryBuilders.termQuery("mimeType", "text/html")));
            builder.setSize(10);
        });

        assertNotNull(htmlResults);

        // Build query to exclude certain kinds
        final BoolQueryBuilder boolQuery = QueryBuilders.boolQuery().must(QueryBuilders.rangeQuery(freqField).gte(1));
        for (final SuggestItem.Kind kind : excludeKinds) {
            boolQuery.mustNot(QueryBuilders.matchPhraseQuery(FieldNames.KINDS, kind.toString()));
        }

import org.codelibs.fess.util.ComponentUtil;
import org.lastaflute.core.message.UserMessages;
import org.opensearch.common.unit.Fuzziness;
import org.opensearch.index.query.QueryBuilder;
import org.opensearch.index.query.QueryBuilders;

/**
 * Query command implementation for handling fuzzy search queries.
 * This class converts Lucene FuzzyQuery objects into OpenSearch fuzzy query builders,

    }

    /**
     * Executes the query command and returns a QueryBuilder.
     * @param context The query context containing search parameters.
     * @param query The Lucene query to execute.
     * @param boost The boost factor to apply.
     * @return The executed QueryBuilder.
     */
    public abstract QueryBuilder execute(final QueryContext context, final Query query, final float boost);

    /**

import org.junit.Before;
import org.junit.BeforeClass;
import org.junit.Test;
import org.opensearch.action.index.IndexResponse;
import org.opensearch.common.xcontent.XContentType;
import org.opensearch.index.query.QueryBuilders;
import org.opensearch.transport.client.Client;

/**
 * Integration tests for ScrollOperationHelper.
 */
public class ScrollOperationHelperTest {

    private static OpenSearchRunner runner;

import org.lastaflute.core.message.UserMessages;
import org.opensearch.index.query.QueryBuilder;
import org.opensearch.index.query.QueryBuilders;
import org.opensearch.index.query.RangeQueryBuilder;

/**
 * Command class for handling term range query execution and conversion.
 * This class processes Lucene TermRangeQuery objects and converts them to OpenSearch QueryBuilder instances.
 */
public class TermRangeQueryCommand extends QueryCommand {

                .setQuery(QueryBuilders.termQuery("sessionId", "id1"))
                .execute()
                .actionGet()
                .getHits()
                .getTotalHits()
                .value() > 0);
        assertTrue(fesenClient.prepareSearch("fess_crawler.queue")
                .setQuery(QueryBuilders.termQuery("sessionId", "id2"))
                .execute()

import org.opensearch.common.unit.Fuzziness;
import org.opensearch.index.query.QueryBuilder;
import org.opensearch.index.query.QueryBuilders;
import org.opensearch.search.sort.SortOrder;

/**
 * Command class for handling term query execution and conversion.
 * This class processes Lucene TermQuery objects and converts them to OpenSearch QueryBuilder instances.
 */
public class TermQueryCommand extends QueryCommand {

        // clean up
        final QueryBuilder queryBuilder = QueryBuilders.rangeQuery(fessConfig.getIndexFieldExpires()).to("now");
        try {
            searchEngineClient.deleteByQuery(fessConfig.getIndexDocumentUpdateIndex(), queryBuilder);

        } catch (final Exception e) {
            logger.error("Could not delete expired documents: {}", queryBuilder, e);
            resultBuf.append(e.getMessage()).append("\n");

                final QueryBuilder expiresCheckQuery = QueryBuilders.boolQuery()//
                        .mustNot(QueryBuilders.rangeQuery(fessConfig.getIndexFieldExpires()).gt("now"))//
                        .mustNot(QueryBuilders.existsQuery(fessConfig.getIndexFieldExpires()));
                queryBuilder.must(expiresCheckQuery);
            }

            try {