Function parse_server_options_json

sql/sql_servers.cc:332–370

}

static bool parse_server_options_json(FOREIGN_SERVER *server, char *ptr)
{
  enum json_types vt;
  const char *keyname, *keyname_end, *v;
  int v_len, nkey= 0;
  engine_option_value *option_list_last;
  DBUG_ENTER("parse_server_options_json");
  while ((vt= json_get_object_nkey(ptr, ptr+strlen(ptr), nkey++,
                    &keyname, &keyname_end, &v, &v_len)) != JSV_NOTHING)
  {
    if (vt != JSV_STRING)
      DBUG_RETURN(TRUE);
    /*
      We have to make copies here to create "clean" strings and
      avoid mutating ptr.
    */
    Lex_cstring name= {keyname, keyname_end}, value= {v, v + v_len},
      name_copy= safe_lexcstrdup_root(&mem, name),
      value_copy= safe_lexcstrdup_root(&mem, value);
    engine_option_value *option= new (&mem) engine_option_value(
      engine_option_value::Name(name_copy),
      engine_option_value::Value(value_copy), true);
    option->link(&server->option_list, &option_list_last);
    if (option->value.length)
    {
      LEX_CSTRING *optval= &option->value;
      char *unescaped= (char *) alloca(optval->length);
      int len= json_unescape_json(optval->str, optval->str + optval->length,
                                  unescaped, unescaped + optval->length);
      if (len < 0)
        DBUG_RETURN(TRUE);
      DBUG_ASSERT(len <= (int) optval->length);
      if (len < (int) optval->length)
        strncpy((char *) optval->str, unescaped, len);
      optval->length= len;
    }
  }
  DBUG_RETURN(FALSE);
}

/*
  Initialize structures responsible for servers used in federated