SerializeToSql.cpp File Reference

#include "SerializeToSql.h"
#include "ExternalExecutor.h"

Include dependency graph for SerializeToSql.cpp:

Go to the source code of this file.

Namespaces
	anonymous_namespace{SerializeToSql.cpp}

Functions
std::string	anonymous_namespace{SerializeToSql.cpp}::agg_to_string (const Analyzer::AggExpr *agg_expr, const RelAlgExecutionUnit *ra_exe_unit)
std::string	anonymous_namespace{SerializeToSql.cpp}::where_to_string (const RelAlgExecutionUnit *ra_exe_unit)
std::string	anonymous_namespace{SerializeToSql.cpp}::join_condition_to_string (const RelAlgExecutionUnit *ra_exe_unit)
std::string	anonymous_namespace{SerializeToSql.cpp}::targets_to_string (const RelAlgExecutionUnit *ra_exe_unit)
std::string	anonymous_namespace{SerializeToSql.cpp}::group_by_to_string (const RelAlgExecutionUnit *ra_exe_unit)
std::string	anonymous_namespace{SerializeToSql.cpp}::from_to_string (const RelAlgExecutionUnit *ra_exe_unit)
std::string	anonymous_namespace{SerializeToSql.cpp}::maybe (const std::string &prefix, const std::string &clause)
std::string	serialize_table_ref (const int table_id, const Catalog_Namespace::Catalog *catalog)
std::string	serialize_column_ref (const int table_id, const int column_id, const Catalog_Namespace::Catalog *catalog)
ExecutionUnitSql	serialize_to_sql (const RelAlgExecutionUnit *ra_exe_unit)

Function Documentation

std::string serialize_column_ref	(	const int	table_id,
		const int	column_id,
		const Catalog_Namespace::Catalog *	catalog
	)

Definition at line 303 of file SerializeToSql.cpp.

References CHECK, Catalog_Namespace::Catalog::getMetadataForColumn(), and to_string().

Referenced by anonymous_namespace{ExternalExecutor.cpp}::create_table_schema(), and ScalarExprToSql::visitColumnVar().

                                                                          {
  if (table_id >= 0) {
    CHECK(catalog);
    const auto cd = catalog->getMetadataForColumn(table_id, column_id);
    CHECK(cd);
    return cd->columnName;
  }
  return "col" + std::to_string(column_id);
}

Here is the call graph for this function:

Here is the caller graph for this function:

std::string serialize_table_ref	(	const int	table_id,
		const Catalog_Namespace::Catalog *	catalog
	)

Definition at line 292 of file SerializeToSql.cpp.

References CHECK, Catalog_Namespace::Catalog::getMetadataForTable(), and to_string().

Referenced by anonymous_namespace{SerializeToSql.cpp}::from_to_string(), and ScalarExprToSql::visitColumnVar().

                                                                         {
  if (table_id >= 0) {
    CHECK(catalog);
    const auto td = catalog->getMetadataForTable(table_id);
    CHECK(td);
    return td->tableName;
  }
  return "\"#temp" + std::to_string(table_id) + "\"";
}

Here is the call graph for this function:

Here is the caller graph for this function:

ExecutionUnitSql serialize_to_sql

(

const RelAlgExecutionUnit *

ra_exe_unit

)

Definition at line 315 of file SerializeToSql.cpp.

References anonymous_namespace{SerializeToSql.cpp}::from_to_string(), anonymous_namespace{SerializeToSql.cpp}::group_by_to_string(), anonymous_namespace{SerializeToSql.cpp}::join_condition_to_string(), anonymous_namespace{SerializeToSql.cpp}::maybe(), anonymous_namespace{SerializeToSql.cpp}::targets_to_string(), and anonymous_namespace{SerializeToSql.cpp}::where_to_string().

Referenced by ExecutionKernel::runImpl().

                                                                          {
  const auto targets = targets_to_string(ra_exe_unit);
  const auto from = from_to_string(ra_exe_unit);
  const auto join_on = join_condition_to_string(ra_exe_unit);
  const auto where = where_to_string(ra_exe_unit);
  const auto group = group_by_to_string(ra_exe_unit);
  return {"SELECT " + targets + " FROM " + from + maybe("ON", join_on) +
              maybe("WHERE", where) + maybe("GROUP BY", group),
          from};
}

Here is the call graph for this function:

Here is the caller graph for this function: