Method parse_fts_query

src/db/sqlengine/sqlengine_impl.cc:162–272

}

Result<FtsCondInfo::Ptr> SQLEngineImpl::parse_fts_query(
    CollectionSchema::Ptr collection, const std::string &field_name,
    const FtsClause &fts, const QueryParams::Ptr &query_params) {
  // Exactly one of query_string_ or match_string_ must be provided.
  bool has_query = !fts.query_string_.empty();
  bool has_match_string = !fts.match_string_.empty();
  if (has_query == has_match_string) {
    return tl::make_unexpected(Status::InvalidArgument(
        "Exactly one of query_string or match_string must be provided"));
  }

  auto *fts_query_param = dynamic_cast<FtsQueryParams *>(query_params.get());
  if (query_params && !fts_query_param) {
    return tl::make_unexpected(Status::InvalidArgument(
        "FTS query only accepts FtsQueryParam, got incompatible query param "
        "type"));
  }

  // Determine default operator once, shared by both query_string and
  // match_string paths. Accept "and"/"or" case-insensitively, empty means OR;
  // any other value is a user error and must be reported, not silently
  // downgraded to OR. strcasecmp is mapped to _stricmp on MSVC by platform.h.
  fts::FtsDefaultOperator default_op = fts::FtsDefaultOperator::OR;
  if (fts_query_param) {
    const auto &op_str = fts_query_param->default_operator();
    if (op_str.empty() || strcasecmp(op_str.c_str(), "or") == 0) {
      default_op = fts::FtsDefaultOperator::OR;
    } else if (strcasecmp(op_str.c_str(), "and") == 0) {
      default_op = fts::FtsDefaultOperator::AND;
    } else {
      return tl::make_unexpected(Status::InvalidArgument(
          "FTS default_operator must be empty, 'and' or 'or' (case-insensitive)"
          ", got: ",
          op_str));
    }
  }

  // Tokenizer pipeline is required by both branches: query_string needs it to
  // tokenize phrase contents and bare terms, match_string needs it to split
  // the natural-language input. Resolve once and share.
  auto *field_schema = collection->get_field(field_name);
  if (!field_schema) {
    return tl::make_unexpected(
        Status::InvalidArgument("FTS field not found: ", field_name));
  }
  auto fts_idx_param =
      std::dynamic_pointer_cast<FtsIndexParams>(field_schema->index_params());
  if (!fts_idx_param) {
    return tl::make_unexpected(Status::InvalidArgument(
        "FTS field has no FtsIndexParams: ", field_name));
  }
  auto pipeline_result = detail::AcquireFtsPipeline(*fts_idx_param);
  if (!pipeline_result.has_value()) {
    return tl::make_unexpected(Status::InternalError(
        "Failed to create tokenizer pipeline for field: ", field_name, " ",
        pipeline_result.error().message()));
  }
  auto &pipeline = pipeline_result.value();