com.mapd.parser.extension.ddl.SqlCreateTable Class Reference

Inheritance diagram for com.mapd.parser.extension.ddl.SqlCreateTable:

Collaboration diagram for com.mapd.parser.extension.ddl.SqlCreateTable:

Public Member Functions
List< SqlNode >	getOperandList ()
void	unparse (SqlWriter writer, int leftPrec, int rightPrec)
String	toString ()

Public Attributes
final boolean	temporary
final SqlIdentifier	name
final SqlNodeList	columnList
SqlNode	query = null

Protected Member Functions
	SqlCreateTable (SqlParserPos pos, boolean temporary, boolean ifNotExists, SqlIdentifier name, SqlNodeList columnList, HeavyDBOptionsMap withOptions, SqlNode query)

Private Attributes
final HeavyDBOptionsMap	options

Static Private Attributes
static final SqlOperator	OPERATOR

Detailed Description

Parse tree for

CREATE TABLE 

statement.

Definition at line 46 of file SqlCreateTable.java.

Constructor & Destructor Documentation

com.mapd.parser.extension.ddl.SqlCreateTable.SqlCreateTable ( SqlParserPos  pos, boolean  temporary, boolean  ifNotExists, SqlIdentifier  name, SqlNodeList  columnList, HeavyDBOptionsMap  withOptions, SqlNode  query  )

inlineprotected

Creates a SqlCreateTable.

Definition at line 57 of file SqlCreateTable.java.

References com.mapd.parser.extension.ddl.SqlCreateTable.columnList, com.mapd.parser.extension.ddl.SqlCreateTable.name, com.mapd.parser.extension.ddl.SqlCreateTable.OPERATOR, com.mapd.parser.extension.ddl.SqlCreateTable.query, and com.mapd.parser.extension.ddl.SqlCreateTable.temporary.

                         {
    super(OPERATOR, pos, false, ifNotExists);
    this.temporary = temporary;
    this.name = Objects.requireNonNull(name);
    this.options = withOptions;
    this.columnList = columnList; // may be null
    this.query = query; // for "CREATE TABLE ... AS query"; may be null
  }

Member Function Documentation

List<SqlNode> com.mapd.parser.extension.ddl.SqlCreateTable.getOperandList ( )

inline

Definition at line 72 of file SqlCreateTable.java.

References com.mapd.parser.extension.ddl.SqlCreateTable.columnList, com.mapd.parser.extension.ddl.SqlCreateTable.name, and com.mapd.parser.extension.ddl.SqlCreateTable.query.

                                        {
    return ImmutableNullableList.of(name, columnList, query);
  }

String com.mapd.parser.extension.ddl.SqlCreateTable.toString ( )

inline

Definition at line 103 of file SqlCreateTable.java.

References com.mapd.parser.extension.ddl.SqlCreateTable.columnList, com.mapd.parser.extension.ddl.SqlCreateTable.name, and com.mapd.parser.extension.ddl.SqlCreateTable.query.

                           {
    JsonBuilder jsonBuilder = new EscapedStringJsonBuilder();
    Map<String, Object> map = jsonBuilder.map();

    jsonBuilder.put(map, "command", "CREATE_TABLE");
    jsonBuilder.put(map, "name", this.name.toString());

    if (query != null) {
      // By default ... toString() seems to single-quote too much stuff
      //    for the SELECT stmt to be executed later
      //    ->
      //    use PrettyWriter to output a cleaner SQL statement
      //
      SqlWriterConfig c = SqlPrettyWriter.config()
                                  .withDialect(CalciteSqlDialect.DEFAULT)
                                  .withQuoteAllIdentifiers(false)
                                  .withSelectListItemsOnSeparateLines(false)
                                  .withWhereListItemsOnSeparateLines(false)
                                  .withValuesListNewline(false);
      SqlPrettyWriter writer = new SqlPrettyWriter(c);
      this.query.unparse(writer, 0, 0);
      jsonBuilder.put(map, "query", writer.toString());
    }

    List<Object> elements_list = jsonBuilder.list();
    if (columnList != null) {
      for (SqlNode elementNode : this.columnList) {
        if (!(elementNode instanceof SqlCall)) {
          throw new CalciteException("Column definition for table " + this.name.toString()
                          + " is invalid: " + elementNode.toString(),
                  null);
        }
        elements_list.add(elementNode);
      }
    }
    jsonBuilder.put(map, "elements", elements_list);
    jsonBuilder.put(map, "temporary", this.temporary);
    jsonBuilder.put(map, "ifNotExists", this.ifNotExists);

    map.put("options", this.options);

    Map<String, Object> payload = jsonBuilder.map();
    payload.put("payload", map);

    // To Debug:
    // System.out.println(jsonBuilder.toJsonString(payload))

    return jsonBuilder.toJsonString(payload);
  }

void com.mapd.parser.extension.ddl.SqlCreateTable.unparse ( SqlWriter  writer, int  leftPrec, int  rightPrec  )

inline

Definition at line 77 of file SqlCreateTable.java.

References com.mapd.parser.extension.ddl.SqlCreateTable.columnList, com.mapd.parser.extension.ddl.SqlCreateTable.query, and com.mapd.parser.extension.ddl.SqlCreateTable.temporary.

                                                                     {
    writer.keyword("CREATE");
    if (temporary) {
      writer.keyword("TEMPORARY");
    }
    writer.keyword("TABLE");
    if (ifNotExists) {
      writer.keyword("IF NOT EXISTS");
    }
    name.unparse(writer, leftPrec, rightPrec);
    if (columnList != null) {
      SqlWriter.Frame frame = writer.startList("(", ")");
      for (SqlNode c : columnList) {
        writer.sep(",");
        c.unparse(writer, 0, 0);
      }
      writer.endList(frame);
    }
    if (query != null) {
      writer.keyword("AS");
      writer.newlineAndIndent();
      query.unparse(writer, 0, 0);
    }
  }

Member Data Documentation

final SqlNodeList com.mapd.parser.extension.ddl.SqlCreateTable.columnList

Definition at line 49 of file SqlCreateTable.java.

Referenced by com.mapd.parser.extension.ddl.SqlCreateTable.getOperandList(), com.mapd.parser.extension.ddl.SqlCreateTable.SqlCreateTable(), com.mapd.parser.extension.ddl.SqlCreateTable.toString(), and com.mapd.parser.extension.ddl.SqlCreateTable.unparse().

final SqlIdentifier com.mapd.parser.extension.ddl.SqlCreateTable.name

Definition at line 48 of file SqlCreateTable.java.

Referenced by TableFunctionsFactory_declbracket.Bracket.__repr__(), TableFunctionsFactory_declbracket.Bracket.__str__(), TableFunctionsFactory_declbracket.Bracket.apply_column(), TableFunctionsFactory_declbracket.Bracket.apply_namespace(), TableFunctionsFactory_declbracket.Bracket.format_sizer(), com.mapd.parser.extension.ddl.SqlCreateTable.getOperandList(), TableFunctionsFactory_declbracket.Bracket.normalize(), heavydb.extension_functions.ttypes.TUserDefinedFunction.read(), heavydb.extension_functions.ttypes.TUserDefinedTableFunction.read(), heavydb.thrift.ttypes.TDashboardGrantees.read(), heavydb.thrift.ttypes.TGeoFileLayerInfo.read(), heavydb.thrift.ttypes.TCustomExpression.read(), com.mapd.parser.extension.ddl.SqlCreateTable.SqlCreateTable(), TableFunctionsFactory_declbracket.Bracket.tostring(), com.mapd.parser.extension.ddl.SqlCreateTable.toString(), heavydb.extension_functions.ttypes.TUserDefinedFunction.write(), heavydb.extension_functions.ttypes.TUserDefinedTableFunction.write(), heavydb.thrift.ttypes.TDashboardGrantees.write(), heavydb.thrift.ttypes.TGeoFileLayerInfo.write(), and heavydb.thrift.ttypes.TCustomExpression.write().

final SqlOperator com.mapd.parser.extension.ddl.SqlCreateTable.OPERATOR

staticprivate

Initial value:

=
          new SqlSpecialOperator("CREATE TABLE", SqlKind.CREATE_TABLE)

Definition at line 53 of file SqlCreateTable.java.

Referenced by com.mapd.parser.extension.ddl.SqlCreateTable.SqlCreateTable().

final HeavyDBOptionsMap com.mapd.parser.extension.ddl.SqlCreateTable.options

private

Definition at line 51 of file SqlCreateTable.java.

SqlNode com.mapd.parser.extension.ddl.SqlCreateTable.query = null

Definition at line 50 of file SqlCreateTable.java.

Referenced by com.mapd.parser.extension.ddl.SqlCreateTable.getOperandList(), heavydb.thrift.Heavy.sql_execute_args.read(), heavydb.thrift.Heavy.sql_execute_df_args.read(), heavydb.thrift.Heavy.sql_execute_gdf_args.read(), heavydb.thrift.Heavy.sql_validate_args.read(), heavydb.thrift.Heavy.query_get_outer_fragment_count_args.read(), com.mapd.parser.extension.ddl.SqlCreateTable.SqlCreateTable(), com.mapd.parser.extension.ddl.SqlCreateTable.toString(), com.mapd.parser.extension.ddl.SqlCreateTable.unparse(), heavydb.thrift.Heavy.sql_execute_args.write(), heavydb.thrift.Heavy.sql_execute_df_args.write(), heavydb.thrift.Heavy.sql_execute_gdf_args.write(), heavydb.thrift.Heavy.sql_validate_args.write(), and heavydb.thrift.Heavy.query_get_outer_fragment_count_args.write().

final boolean com.mapd.parser.extension.ddl.SqlCreateTable.temporary

Definition at line 47 of file SqlCreateTable.java.

Referenced by com.mapd.parser.extension.ddl.SqlCreateTable.SqlCreateTable(), and com.mapd.parser.extension.ddl.SqlCreateTable.unparse().

---

The documentation for this class was generated from the following file:

• /home/jenkins-slave/workspace/core-os-doxygen/java/calcite/src/main/java/com/mapd/parser/extension/ddl/SqlCreateTable.java