Module: YbDDLParser::Native

Defined in:

ext/yb_ddl_parser/yb_ddl_parser_ext.c

Class Method Summary

• .parse(sql) ⇒ Object

Class Method Details

.parse(sql) ⇒ Object

# File 'ext/yb_ddl_parser/yb_ddl_parser_ext.c', line 1690

static VALUE
native_parse(VALUE self, VALUE sql)
{
  Check_Type(sql, T_STRING);

  VALUE result = Qnil;

  PG_TRY();
  {
    List *raw_statements = raw_parser(StringValueCStr(sql), RAW_PARSE_DEFAULT);
    VALUE statements = rb_ary_new_capa(list_length(raw_statements));

    ListCell *cell;
    foreach(cell, raw_statements)
    {
      RawStmt *raw_stmt = castNode(RawStmt, lfirst(cell));
      rb_ary_push(statements, build_statement_hash(sql, raw_stmt));
    }

    result = rb_hash_new();
    rb_hash_aset(result, symbol_key("statements"), statements);
    rb_hash_aset(result, symbol_key("errors"), rb_ary_new());
  }
  PG_CATCH();
  {
    VALUE error = rb_hash_new();
    rb_hash_aset(error, symbol_key("message"),
                 rb_str_new_cstr(yb_parser_last_error_message()));
    if (yb_parser_last_error_position() > 0)
      rb_hash_aset(error, symbol_key("position"),
                   INT2NUM(yb_parser_last_error_position()));

    VALUE errors = rb_ary_new();
    rb_ary_push(errors, error);

    result = rb_hash_new();
    rb_hash_aset(result, symbol_key("statements"), rb_ary_new());
    rb_hash_aset(result, symbol_key("errors"), errors);
  }
  PG_END_TRY();

  return result;
}