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

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

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

Public Member Functions
	SqlInsertIntoTable (SqlParserPos pos, SqlNode table, SqlNode query, SqlNodeList columnList)
List< SqlNode >	getOperandList ()
void	unparse (SqlWriter writer, int leftPrec, int rightPrec)
String	toString ()

Public Attributes
final SqlNode	name
final SqlNodeList	columnList
SqlNode	query = null

Static Private Attributes
static final SqlOperator	OPERATOR

Detailed Description

Class that encapsulates all information associated with a INSERT INTO TABLE DDL command.

Definition at line 26 of file SqlInsertIntoTable.java.

Constructor & Destructor Documentation

com.mapd.parser.extension.ddl.SqlInsertIntoTable.SqlInsertIntoTable ( SqlParserPos  pos, SqlNode  table, SqlNode  query, SqlNodeList  columnList  )

inline

Definition at line 34 of file SqlInsertIntoTable.java.

References com.mapd.parser.extension.ddl.SqlInsertIntoTable.columnList, com.mapd.parser.extension.ddl.SqlInsertIntoTable.OPERATOR, and com.mapd.parser.extension.ddl.SqlInsertIntoTable.query.

                                                                                  {
    super(OPERATOR, pos);
    this.name = table;
    this.query = query;
    this.columnList = columnList; // may be null
  }

Member Function Documentation

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

inline

Definition at line 43 of file SqlInsertIntoTable.java.

                                        {
    return null;
  }

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

inline

Definition at line 67 of file SqlInsertIntoTable.java.

References com.mapd.parser.extension.ddl.SqlInsertIntoTable.columnList.

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

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

    // 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);
    map.put("query", writer.toString());

    if (columnList != null) {
      List<Object> col_list = jsonBuilder.list();
      for (SqlNode col : this.columnList) {
        col_list.add(col.toString());
      }
      jsonBuilder.put(map, "columns", col_list);
    }

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

    return jsonBuilder.toJsonString(payload);
  }

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

inline

Definition at line 48 of file SqlInsertIntoTable.java.

References com.mapd.parser.extension.ddl.SqlInsertIntoTable.columnList, and com.mapd.parser.extension.ddl.SqlInsertIntoTable.query.

                                                                     {
    writer.keyword("INSERT");
    writer.keyword("INTO");
    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.newlineAndIndent();
      query.unparse(writer, 0, 0);
    }
  }

Member Data Documentation

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

Definition at line 28 of file SqlInsertIntoTable.java.

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

final SqlNode com.mapd.parser.extension.ddl.SqlInsertIntoTable.name

Definition at line 27 of file SqlInsertIntoTable.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(), 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(), TableFunctionsFactory_declbracket.Bracket.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.SqlInsertIntoTable.OPERATOR

staticprivate

Initial value:

=
          new SqlSpecialOperator("INSERT_INTO_TABLE_AS_SELECT", SqlKind.OTHER_DDL)

Definition at line 31 of file SqlInsertIntoTable.java.

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

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

Definition at line 29 of file SqlInsertIntoTable.java.

Referenced by 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.SqlInsertIntoTable.SqlInsertIntoTable(), com.mapd.parser.extension.ddl.SqlInsertIntoTable.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().

---

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/SqlInsertIntoTable.java