anonymous_namespace{SerializeToSql.cpp} Namespace Reference

Functions
std::string	agg_to_string (const Analyzer::AggExpr *agg_expr, const RelAlgExecutionUnit *ra_exe_unit, const Catalog_Namespace::Catalog *catalog)
std::string	where_to_string (const RelAlgExecutionUnit *ra_exe_unit, const Catalog_Namespace::Catalog *catalog)
std::string	join_condition_to_string (const RelAlgExecutionUnit *ra_exe_unit, const Catalog_Namespace::Catalog *catalog)
std::string	targets_to_string (const RelAlgExecutionUnit *ra_exe_unit, const Catalog_Namespace::Catalog *catalog)
std::string	group_by_to_string (const RelAlgExecutionUnit *ra_exe_unit, const Catalog_Namespace::Catalog *catalog)
std::string	from_to_string (const RelAlgExecutionUnit *ra_exe_unit, const Catalog_Namespace::Catalog *catalog)
std::string	maybe (const std::string &prefix, const std::string &clause)

Function Documentation

std::string anonymous_namespace{SerializeToSql.cpp}::agg_to_string	(	const Analyzer::AggExpr *	agg_expr,
		const RelAlgExecutionUnit *	ra_exe_unit,
		const Catalog_Namespace::Catalog *	catalog
	)

Definition at line 119 of file SerializeToSql.cpp.

References Analyzer::AggExpr::get_aggtype(), Analyzer::AggExpr::get_arg(), Analyzer::AggExpr::get_is_distinct(), toString(), and ScalarExprVisitor< T >::visit().

Referenced by ScalarExprToSql::visitAggExpr().

                                                                   {
  ScalarExprToSql scalar_expr_to_sql(ra_exe_unit, catalog);
  const auto agg_type = ::toString(agg_expr->get_aggtype());
  const auto arg =
      agg_expr->get_arg() ? scalar_expr_to_sql.visit(agg_expr->get_arg()) : "*";
  const auto distinct = agg_expr->get_is_distinct() ? "DISTINCT " : "";
  return agg_type + "(" + distinct + arg + ")";
}

Here is the call graph for this function:

Here is the caller graph for this function:

std::string anonymous_namespace{SerializeToSql.cpp}::from_to_string	(	const RelAlgExecutionUnit *	ra_exe_unit,
		const Catalog_Namespace::Catalog *	catalog
	)

Definition at line 278 of file SerializeToSql.cpp.

References RelAlgExecutionUnit::input_descs, join(), and serialize_table_ref().

Referenced by serialize_to_sql().

                                                                    {
  std::vector<std::string> from_strings;
  for (const auto& input_desc : ra_exe_unit->input_descs) {
    const auto table_ref = serialize_table_ref(input_desc.getTableId(), catalog);
    from_strings.push_back(table_ref);
  }
  return boost::algorithm::join(from_strings, ", ");
}

Here is the call graph for this function:

Here is the caller graph for this function:

std::string anonymous_namespace{SerializeToSql.cpp}::group_by_to_string	(	const RelAlgExecutionUnit *	ra_exe_unit,
		const Catalog_Namespace::Catalog *	catalog
	)

Definition at line 268 of file SerializeToSql.cpp.

References RelAlgExecutionUnit::groupby_exprs, join(), and ScalarExprToSql::visitList().

Referenced by serialize_to_sql().

                                                                        {
  if (ra_exe_unit->groupby_exprs.size() == 1 || !ra_exe_unit->groupby_exprs.front()) {
    return "";
  }
  ScalarExprToSql scalar_expr_to_sql(ra_exe_unit, catalog);
  const auto group_by_strings = scalar_expr_to_sql.visitList(ra_exe_unit->groupby_exprs);
  return boost::algorithm::join(group_by_strings, ", ");
}

Here is the call graph for this function:

Here is the caller graph for this function:

std::string anonymous_namespace{SerializeToSql.cpp}::join_condition_to_string	(	const RelAlgExecutionUnit *	ra_exe_unit,
		const Catalog_Namespace::Catalog *	catalog
	)

Definition at line 246 of file SerializeToSql.cpp.

References join(), RelAlgExecutionUnit::join_quals, and ScalarExprToSql::visitList().

Referenced by serialize_to_sql().

                                                                              {
  ScalarExprToSql scalar_expr_to_sql(ra_exe_unit, catalog);
  std::vector<std::string> qual_strings;
  for (const auto& join_level_quals : ra_exe_unit->join_quals) {
    const auto level_qual_strings = scalar_expr_to_sql.visitList(join_level_quals.quals);
    qual_strings.insert(
        qual_strings.end(), level_qual_strings.begin(), level_qual_strings.end());
  }
  return boost::algorithm::join(qual_strings, " AND ");
}

Here is the call graph for this function:

Here is the caller graph for this function:

std::string anonymous_namespace{SerializeToSql.cpp}::maybe	(	const std::string &	prefix,
		const std::string &	clause
	)

Definition at line 288 of file SerializeToSql.cpp.

Referenced by serialize_to_sql().

                                                                  {
  return clause.empty() ? "" : " " + prefix + " " + clause;
}

Here is the caller graph for this function:

std::string anonymous_namespace{SerializeToSql.cpp}::targets_to_string	(	const RelAlgExecutionUnit *	ra_exe_unit,
		const Catalog_Namespace::Catalog *	catalog
	)

Definition at line 258 of file SerializeToSql.cpp.

References join(), RelAlgExecutionUnit::target_exprs, and ScalarExprVisitor< T >::visit().

Referenced by serialize_to_sql().

                                                                       {
  ScalarExprToSql scalar_expr_to_sql(ra_exe_unit, catalog);
  std::vector<std::string> target_strings;
  for (const auto target : ra_exe_unit->target_exprs) {
    target_strings.push_back(scalar_expr_to_sql.visit(target));
  }
  return boost::algorithm::join(target_strings, ", ");
}

Here is the call graph for this function:

Here is the caller graph for this function:

std::string anonymous_namespace{SerializeToSql.cpp}::where_to_string	(	const RelAlgExecutionUnit *	ra_exe_unit,
		const Catalog_Namespace::Catalog *	catalog
	)

Definition at line 235 of file SerializeToSql.cpp.

References join(), RelAlgExecutionUnit::quals, RelAlgExecutionUnit::simple_quals, and ScalarExprToSql::visitList().

Referenced by serialize_to_sql().

                                                                     {
  ScalarExprToSql scalar_expr_to_sql(ra_exe_unit, catalog);
  auto qual_strings = scalar_expr_to_sql.visitList(ra_exe_unit->quals);
  const auto simple_qual_strings =
      scalar_expr_to_sql.visitList(ra_exe_unit->simple_quals);
  qual_strings.insert(
      qual_strings.end(), simple_qual_strings.begin(), simple_qual_strings.end());
  return boost::algorithm::join(qual_strings, " AND ");
}

Here is the call graph for this function:

Here is the caller graph for this function: