anonymous_namespace{SerializeToSql.cpp} Namespace Reference

Functions
std::string	agg_to_string (const Analyzer::AggExpr *agg_expr, const RelAlgExecutionUnit *ra_exe_unit)
std::string	where_to_string (const RelAlgExecutionUnit *ra_exe_unit)
std::string	join_condition_to_string (const RelAlgExecutionUnit *ra_exe_unit)
std::string	targets_to_string (const RelAlgExecutionUnit *ra_exe_unit)
std::string	group_by_to_string (const RelAlgExecutionUnit *ra_exe_unit)
std::string	from_to_string (const RelAlgExecutionUnit *ra_exe_unit)
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
	)

Definition at line 120 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);
  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

)

Definition at line 274 of file SerializeToSql.cpp.

References Catalog_Namespace::SysCatalog::getCatalog(), RelAlgExecutionUnit::input_descs, Catalog_Namespace::SysCatalog::instance(), 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_key = input_desc.getTableKey();
    const auto catalog =
        Catalog_Namespace::SysCatalog::instance().getCatalog(table_key.db_id);
    const auto table_ref = serialize_table_ref(table_key.table_id, catalog.get());
    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

)

Definition at line 265 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);
  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

)

Definition at line 245 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);
  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 286 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

)

Definition at line 256 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);
  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

)

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);
  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: