Function prepare_server_struct_for_insert

sql/sql_servers.cc:1265–1314

*/

static FOREIGN_SERVER *
prepare_server_struct_for_insert(LEX_SERVER_OPTIONS *server_options)
{
  FOREIGN_SERVER *server;
  ulong default_port= 0;
  DBUG_ENTER("prepare_server_struct");

  if (!(server= (FOREIGN_SERVER *)alloc_root(&mem, sizeof(FOREIGN_SERVER))))
    DBUG_RETURN(NULL); /* purecov: inspected */

#define SET_SERVER_OR_RETURN(X, DEFAULT)                        \
  do {                                                          \
    if (!(server->X= server_options->X.str ?                    \
            strmake_root(&mem, server_options->X.str,           \
                               server_options->X.length) : "")) \
      DBUG_RETURN(NULL);                                        \
  } while(0)

  /* name and scheme are always set (the parser guarantees it) */
  SET_SERVER_OR_RETURN(server_name, NULL);
  SET_SERVER_OR_RETURN(scheme, NULL);

  /* scheme-specific checks */
  if (!strcasecmp(server->scheme, "mysql"))
  {
    default_port= MYSQL_PORT;
    if (!server_options->host.str && !server_options->socket.str)
    {
      my_error(ER_CANT_CREATE_FEDERATED_TABLE, MYF(0),
               "either HOST or SOCKET must be set");
      DBUG_RETURN(NULL);
    }
  }

  SET_SERVER_OR_RETURN(host, "");
  SET_SERVER_OR_RETURN(db, "");
  SET_SERVER_OR_RETURN(username, "");
  SET_SERVER_OR_RETURN(password, "");
  SET_SERVER_OR_RETURN(socket, "");
  SET_SERVER_OR_RETURN(owner, "");
  copy_option_list(&mem, server, server_options->option_list);

  server->server_name_length= server_options->server_name.length;

  /* set to default_port if not specified */
  server->port= server_options->port > -1 ?
    server_options->port : default_port;

  DBUG_RETURN(server);
}

/*