~drizzle-trunk/drizzle/development

#include <locale.h>

#endif

 

 

const char *VER= "14.14";

 

  *default_charset= (char*) MYSQL_DEFAULT_CHARSET_NAME;

static char *histfile;

static char *histfile_tmp;

static GString *default_prompt= NULL;

static char *full_username=0,*part_username=0;

static int wait_time = 5;

  com_rehash(GString *str, char*), com_tee(GString *str, char*),

  com_notee(GString *str, char*), com_charset(GString *str,char*),

  com_prompt(GString *str, char*), com_delimiter(GString *str, char*),

 

static int read_and_execute(bool interactive);

static int sql_connect(char *host,char *database,char *user,char *password,

    "Reconnect to the server. Optional arguments are db and host." },

  { "delimiter", 'd', com_delimiter,    1,

    "Set statement delimiter. NOTE: Takes the rest of the line as new delimiter." },

  { "ego",    'G', com_ego,    0,

    "Send command to mysql server, display result vertically."},

  { "exit",   'q', com_quit,   0, "Exit mysql. Same as quit."},

  { "go",     'g', com_go,     0, "Send command to mysql server." },

  { "help",   'h', com_help,   1, "Display this help." },

  { "nopager",'n', com_nopager,0, "Disable pager, print to stdout." },

  { "notee",  't', com_notee,  0, "Don't write into outfile." },

  { "pager",  'P', com_pager,  1,

    "Set PAGER [to_pager]. Print the query results via PAGER." },

  { "print",  'p', com_print,  0, "Print current command." },

  { "prompt", 'R', com_prompt, 1, "Change your mysql prompt."},

  { "quit",   'q', com_quit,   0, "Quit mysql." },

  { "source", '.', com_source, 1,

    "Execute an SQL script file. Takes a file name as an argument."},

  { "status", 's', com_status, 0, "Get status information from the server."},

  { "tee",    'T', com_tee,    1,

    "Set outfile [to_outfile]. Append everything into given outfile." },

  { "use",    'u', com_use,    1,

  DBUG_PROCESS(argv[0]);

 

  delimiter_str= delimiter;

  prompt_counter=0;

 

  outfile[0]=0;                 // no (default) outfile

                  "Your Drizzle connection id is %lu\nServer version: %s\n",

                  mysql_thread_id(&mysql), server_version_string(&mysql));

  put_info(glob_buffer->str,INFO_INFO);

 

  initialize_readline((char*) my_progname);

  if (!status.batch && !quick && !opt_html && !opt_xml)

  {

    /* read-history from file, default ~/.mysql_history*/

    if (getenv("MYSQL_HISTFILE"))

    else if (getenv("HOME"))

    {

      histfile=(char*) my_malloc((uint) strlen(getenv("HOME"))

 

  if (sig >= 0)

    put_info(sig ? "Aborted" : "Bye", INFO_RESULT);

  g_string_free(glob_buffer,true);

  g_string_free(processed_prompt,true);

  my_free(opt_password,MYF(MY_ALLOW_ZERO_PTR));

  my_free(opt_mysql_unix_port,MYF(MY_ALLOW_ZERO_PTR));

  my_free(histfile,MYF(MY_ALLOW_ZERO_PTR));

  my_free(current_user,MYF(MY_ALLOW_ZERO_PTR));

  my_free(full_username,MYF(MY_ALLOW_ZERO_PTR));

  my_free(part_username,MYF(MY_ALLOW_ZERO_PTR));

#ifdef HAVE_SMEM

  my_free(shared_memory_base_name,MYF(MY_ALLOW_ZERO_PTR));

#endif

  MYSQL *kill_mysql= NULL;

 

  /* terminate if no query being executed, or we already tried interrupting */

    goto err;

 

  kill_mysql= mysql_init(kill_mysql);

  if (!mysql_real_connect(kill_mysql,current_host, current_user, opt_password,

                          "", opt_mysql_port, opt_mysql_unix_port,0))

    goto err;

 

  /* kill_buffer is always big enough because max length of %lu is 15 */

  sprintf(kill_buffer, "KILL /*!50000 QUERY */ %lu", mysql_thread_id(&mysql));

  {"one-database", 'o',

   "Only update the default database. This is useful for skipping updates to other database in the update log.",

   0, 0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0},

  {"pager", OPT_PAGER,

   "Pager to use to display results. If you don't supply an option the default pager is taken from your ENV variable PAGER. Valid pagers are less, more, cat [> filename], etc. See interactive help (\\h) also. This option does not work in batch mode. Disable with --disable-pager. This option is disabled by default.",

   0, 0, 0, GET_STR, OPT_ARG, 0, 0, 0, 0, 0, 0},

  {"no-pager", OPT_NOPAGER,

   "Disable pager and print to stdout. See interactive help (\\h) also. WARNING: option deprecated; use --disable-pager instead.",

   0, 0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0},

  {"password", 'p',

   "Password to use when connecting to server. If password is not given it's asked from the tty.",

   0, 0, 0, GET_STR, OPT_ARG, 0, 0, 0, 0, 0, 0},

    }

    if (embedded_server_arg_count == MAX_SERVER_ARGS-1 ||

        !(embedded_server_args[embedded_server_arg_count++]=

    {

      put_info("Can't use server argument", INFO_ERROR);

      return 0;

    {

      char *start= argument;

      my_free(opt_password, MYF(MY_ALLOW_ZERO_PTR));

      while (*argument) *argument++= 'x';               // Destroy argument

      if (*start)

        start[1]=0 ;

 

  tmp= (char *) getenv("MYSQL_HOST");

  if (tmp)

 

  pagpoint= getenv("PAGER");

  if (!((char*) (pagpoint)))

  {

    skip_updates= 0;

    my_free(current_db, MYF(MY_ALLOW_ZERO_PTR));

  }

  if (tty_password)

    opt_password= get_tty_password(NullS);

    if (!interactive)

    {

      line=batch_readline(status.line_buff);

      /*

        Skip UTF8 Byte Order Marker (BOM) 0xEFBBBF.

        Editors like "notepad" put this marker in

          (uchar) line[2] == 0xBF)

        line+= 3;

      line_number++;

        status.query_start_line=line_number;

    }

    else

      if (opt_outfile)

        fputs(prompt, OUTFILE);

      line= readline(prompt);

      /*

        When Ctrl+d or Ctrl+z is pressed, the line may be NULL on some OS

        which may cause coredump.

      Check if line is a mysql command line

      (We want to allow help, print and clear anywhere at line start

    */

        && !ml_comment && !in_string && (com=find_command(line,0)))

    {

      if ((*com->func)(glob_buffer,line) > 0)

        add_history(line);

      continue;

    }

      break;

  }

  /* if in batch mode, send last query even if it doesn't end with \g or go */

 

  if (!interactive && !status.exit_status)

  {

    remove_cntrl(glob_buffer);

    {

      status.exit_status=1;

      if (com_go(glob_buffer,line) <= 0)

  char *end;

  DBUG_ENTER("find_command");

  DBUG_PRINT("enter",("name: '%s'  char: %d", name ? name : "NULL", cmd_char));

 

  if (!name)

  {

 

 

static bool add_line(GString *buffer,char *line,char *in_string,

{

  uchar inchar;

  char buff[80], *pos, *out;

  bool need_space= 0;

  bool ss_comment= 0;

  DBUG_ENTER("add_line");

 

  if (!line[0] && (buffer->len==0))

    DBUG_RETURN(0);

  if (status.add_to_history && line[0] && not_in_history(line))

    add_history(line);

  char *end_of_line=line+(uint) strlen(line);

 

  for (pos=out=line ; (inchar= (uchar) *pos) ; pos++)

  {

    if (!preserve_comments)

    {

      // Skip spaces at the beggining of a statement

      continue;

    }

#endif

    if (!*ml_comment && inchar == '\\' &&

        !(mysql.server_status & SERVER_STATUS_NO_BACKSLASH_ESCAPES))

    {

             !my_strnncoll(charset_info, (uchar*) pos, 10,

                           (const uchar*) "delimiter ", 10))

    {

      // Flush previously accepted characters

      if (out != line)

      {

        out= line;

      }

 

      // Flush possible comments in the buffer

      {

        if (com_go(buffer, 0) > 0) // < 0 is not fatal

          DBUG_RETURN(1);

        g_string_truncate(buffer,0);

      }

 

        Delimiter wants the get rest of the given line as argument to

        allow one to change ';' to ';;' and back

      */

      g_string_append(buffer,pos);

      if (com_delimiter(buffer, pos) > 0)

        DBUG_RETURN(1);

 

      g_string_truncate(buffer,0);

      break;

    }

    else if (!*ml_comment && !*in_string && is_prefix(pos, delimiter))

    {

      // Found a statement. Continue parsing after the delimiter

      pos+= delimiter_length;

 

 

      pos--;

 

      if ((com= find_command(buffer->str, 0)))

      {

 

        if (com_go(buffer, 0) > 0)             // < 0 is not fatal

          DBUG_RETURN(1);

      }

      g_string_truncate(buffer,0);

    }

    else if (!*ml_comment

    }

    else if (*ml_comment && !ss_comment && inchar == '*' && *(pos + 1) == '/')

    {

      if (preserve_comments)

      {

        *out++= *pos++;                       // copy '*'

    }

    else

    {

      // Add found char to buffer

      if (!*in_string && inchar == '/' && *(pos + 1) == '*' &&

          *(pos + 2) == '!')

          *out++= ' ';

        need_space= 0;

        *out++= (char) inchar;

      }

    }

  }

  if (out != line || (buffer->len > 0))

  {

    *out++='\n';

 

    if (e)

    {

      e = e->pNext;

      return ptr;

    }

    while (e && !ptr)

    {                                   /* find valid entry in bucket */

      if ((uint) strlen(e->str) == b->nKeyLength)

      /* find the next used entry */

      e = e->pNext;

      if (!e)

  {

    MYSQL_ROW row= mysql_fetch_row(res);

    if (row[0])

    mysql_free_result(res);

  }

}

    server_cmd= cmd_buf;

  }

 

  if (!connected && reconnect())

    return 1;

 

  int           err= 0;

 

  interrupted_query= 0;

 

  /* Remove garbage for nicer messages */

  remove_cntrl(buffer);

 

static void init_pager()

{

  if (!opt_nopager)

  {

    if (!(PAGER= popen(pager, "w")))

    }

  }

  else

    PAGER= stdout;

}

 

static void end_pager()

{

  if (!opt_nopager)

    pclose(PAGER);

}

 

 

  Sorry, this command is not available in Windows.

*/

 

static int

{

  char pager_name[FN_REFLEN], *end, *param;

 

  tee_fprintf(stdout, "PAGER set to stdout\n");

  return 0;

}

 

/* If arg is given, exit without errors. This happens on command 'quit' */

 

}

 

 

 

static int

com_print(GString *buffer,char *line __attribute__((unused)))

    if (tmp && *tmp)

    {

      my_free(current_db, MYF(MY_ALLOW_ZERO_PTR));

      tmp= get_arg(buff, 1);

      if (tmp)

      {

        my_free(current_host,MYF(MY_ALLOW_ZERO_PTR));

      }

    }

    else

      opt_rehash= 0;                            /* purecov: tested */

    }

    // command used

    g_string_truncate(buffer, 0);

  }

  else

  status.line_buff=line_buff;

  status.file_name=source_name;

  // Empty command buffer

  g_string_truncate(glob_buffer, 0);

  error= read_and_execute(false);

  // Continue as before

        return put_error(&mysql);

    }

    my_free(current_db,MYF(MY_ALLOW_ZERO_PTR));

    if (select_db > 1)

      build_completion_hash(opt_rehash, 1);

  }

    tee_fprintf(stdout, "\nAll updates ignored to this database\n");

    vidattr(A_NORMAL);

  }

  tee_fprintf(stdout, "Current pager:\t\t%s\n", pager);

  tee_fprintf(stdout, "Using outfile:\t\t'%s'\n", opt_outfile ? outfile : "");

  tee_fprintf(stdout, "Using delimiter:\t%s\n", delimiter);

  tee_fprintf(stdout, "Server version:\t\t%s\n", server_version_string(&mysql));

  tee_fprintf(stdout, "Protocol version:\t%d\n", mysql_get_proto_info(&mysql));

  char *end= start + (buffer->len);

  while (start < end && !my_isgraph(charset_info,end[-1]))

    end--;

}

 

 

static const char * construct_prompt()

{

  // Erase the old prompt

  g_string_truncate(processed_prompt, 0);

 

  // Get the date struct

  struct tm *t = localtime(&lclock);

 

  /* parse thru the settings for the prompt */

  {

    if (*c != PROMPT_CHAR)

    {

    }

    else

    {

      (result=mysql_use_result(&mysql)))

  {

    MYSQL_ROW cur=mysql_fetch_row(result);

    (void) mysql_fetch_row(result);             // Read eof

  }

}

  char *ptr=strchr(line, ' ');

  prompt_counter = 0;

  my_free(current_prompt,MYF(MY_ALLOW_ZERO_PTR));

  if (!ptr)

    tee_fprintf(stdout, "Returning to default PROMPT of %s\n",

                default_prompt->str);