Method execute

src/db/sqlengine/sqlengine_impl.cc:58–98

    : profiler_(std::move(profiler)) {}

Result<DocPtrList> SQLEngineImpl::execute(
    CollectionSchema::Ptr collection, SearchQuery query,
    const std::vector<Segment::Ptr> &segments) {
  if (segments.empty()) {
    return DocPtrList{};
  }

  // Check filter satisfiability once before the loop (result depends only on
  // the query, not on segment data).
  auto first_query_info = build_query_info(collection, query, nullptr);
  if (!first_query_info) {
    return tl::make_unexpected(first_query_info.error());
  }
  if (first_query_info.value()->is_filter_unsatisfiable()) {
    LOG_WARN("filter is unsatisfiable: %s",
             first_query_info.value()->to_string().c_str());
    return {};
  }
  // Capture output field schema before query_infos are moved into the planner.
  auto select_item_meta_ptrs =
      first_query_info.value()->select_item_schema_ptrs();

  // Build a separate QueryInfo per segment so the optimizer can mutate each
  // independently.  Reuse first_query_info for segment 0.
  std::vector<QueryInfo::Ptr> query_infos;
  query_infos.reserve(segments.size());
  query_infos.emplace_back(std::move(first_query_info.value()));
  for (size_t i = 1; i < segments.size(); ++i) {
    auto query_info = build_query_info(collection, query, nullptr);
    if (!query_info) {
      return tl::make_unexpected(query_info.error());
    }
    query_infos.emplace_back(std::move(query_info.value()));
  }
  auto reader = search_by_query_info(collection, segments, &query_infos);
  if (!reader) {
    return tl::make_unexpected(Status::InternalError(
        "Execute plan failed (query): ", reader.error().c_str()));
  }
  return fill_result(select_item_meta_ptrs, reader.value().get());
}

SearchQuery from_group_by(const GroupByVectorQuery &gq) {
  SearchQuery sq;