mysql.cc 75 KB
Newer Older
monty@mashka.mysql.fi's avatar
monty@mashka.mysql.fi committed
1
/* Copyright (C) 2000-2003 MySQL AB
monty@hundin.mysql.fi's avatar
monty@hundin.mysql.fi committed
2

bk@work.mysql.com's avatar
bk@work.mysql.com committed
3 4 5 6
   This program is free software; you can redistribute it and/or modify
   it under the terms of the GNU General Public License as published by
   the Free Software Foundation; either version 2 of the License, or
   (at your option) any later version.
monty@hundin.mysql.fi's avatar
monty@hundin.mysql.fi committed
7

bk@work.mysql.com's avatar
bk@work.mysql.com committed
8 9 10 11
   This program is distributed in the hope that it will be useful,
   but WITHOUT ANY WARRANTY; without even the implied warranty of
   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
   GNU General Public License for more details.
monty@hundin.mysql.fi's avatar
monty@hundin.mysql.fi committed
12

bk@work.mysql.com's avatar
bk@work.mysql.com committed
13 14 15 16 17 18 19 20 21
   You should have received a copy of the GNU General Public License
   along with this program; if not, write to the Free Software
   Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */

/* mysql command tool
 * Commands compatible with mSQL by David J. Hughes
 *
 * Written by:
 *   Michael 'Monty' Widenius
jani@hynda.mysql.fi's avatar
merge  
jani@hynda.mysql.fi committed
22 23 24 25 26 27 28
 *   Andi Gutmans  <andi@zend.com>
 *   Zeev Suraski  <zeev@zend.com>
 *   Jani Tolonen  <jani@mysql.com>
 *   Matt Wagner   <matt@mysql.com>
 *   Jeremy Cole   <jcole@mysql.com>
 *   Tonu Samuel   <tonu@mysql.com>
 *   Harrison Fisk <hcfisk@buffalo.edu>
bk@work.mysql.com's avatar
bk@work.mysql.com committed
29 30 31
 *
 **/

monty@hundin.mysql.fi's avatar
monty@hundin.mysql.fi committed
32
#include "client_priv.h"
bk@work.mysql.com's avatar
bk@work.mysql.com committed
33
#include <m_ctype.h>
34
#include <stdarg.h>
bk@work.mysql.com's avatar
bk@work.mysql.com committed
35 36
#include <my_dir.h>
#ifndef __GNU_LIBRARY__
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
37
#define __GNU_LIBRARY__		      // Skip warnings in getopt.h
bk@work.mysql.com's avatar
bk@work.mysql.com committed
38 39 40
#endif
#include "my_readline.h"
#include <signal.h>
tonu@x153.internalnet's avatar
tonu@x153.internalnet committed
41
#include <violite.h>
bk@work.mysql.com's avatar
bk@work.mysql.com committed
42

43
const char *VER= "12.22";
44

monty@donna.mysql.com's avatar
monty@donna.mysql.com committed
45 46 47
/* Don't try to make a nice table if the data is too big */
#define MAX_COLUMN_LENGTH	     1024

jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
48
gptr sql_alloc(unsigned size);	     // Don't use mysqld alloc for these
bk@work.mysql.com's avatar
bk@work.mysql.com committed
49 50 51 52 53 54 55 56 57 58 59 60 61 62
void sql_element_free(void *ptr);
#include "sql_string.h"

extern "C" {
#if defined(HAVE_CURSES_H) && defined(HAVE_TERM_H)
#include <curses.h>
#include <term.h>
#else
#if defined(HAVE_TERMIOS_H)
#include <termios.h>
#include <unistd.h>
#elif defined(HAVE_TERMBITS_H)
#include <termbits.h>
#elif defined(HAVE_ASM_TERMBITS_H) && (!defined __GLIBC__ || !(__GLIBC__ > 2 || __GLIBC__ == 2 && __GLIBC_MINOR__ > 0))
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
63
#include <asm/termbits.h>		// Standard linux
bk@work.mysql.com's avatar
bk@work.mysql.com committed
64 65 66 67 68 69 70 71
#endif
#undef VOID
#if defined(HAVE_TERMCAP_H)
#include <termcap.h>
#else
#ifdef HAVE_CURSES_H
#include <curses.h>
#endif
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
72
#undef SYSV				// hack to avoid syntax error
bk@work.mysql.com's avatar
bk@work.mysql.com committed
73 74 75 76 77 78
#ifdef HAVE_TERM_H
#include <term.h>
#endif
#endif
#endif

jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
79
#undef bcmp				// Fix problem with new readline
monty@hundin.mysql.fi's avatar
monty@hundin.mysql.fi committed
80
#if defined( __WIN__) || defined(OS2)
bk@work.mysql.com's avatar
bk@work.mysql.com committed
81
#include <conio.h>
monty@mashka.mysql.fi's avatar
monty@mashka.mysql.fi committed
82
#elif !defined(__NETWARE__)
bk@work.mysql.com's avatar
bk@work.mysql.com committed
83 84 85 86 87 88 89 90
#include <readline/readline.h>
#define HAVE_READLINE
#endif
  //int vidattr(long unsigned int attrs);	// Was missing in sun curses
}

#if !defined(HAVE_VIDATTR)
#undef vidattr
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
91
#define vidattr(A) {}			// Can't get this to work
bk@work.mysql.com's avatar
bk@work.mysql.com committed
92 93
#endif

monty@mashka.mysql.fi's avatar
monty@mashka.mysql.fi committed
94
#ifdef FN_NO_CASE_SENCE
bk@work.mysql.com's avatar
bk@work.mysql.com committed
95 96 97 98 99
#define cmp_database(A,B) my_strcasecmp((A),(B))
#else
#define cmp_database(A,B) strcmp((A),(B))
#endif

monty@mashka.mysql.fi's avatar
monty@mashka.mysql.fi committed
100 101 102 103
#if !defined( __WIN__) && !defined( OS2) && !defined(__NETWARE__) && (!defined(HAVE_mit_thread) || !defined(THREAD))
#define USE_POPEN
#endif

bk@work.mysql.com's avatar
bk@work.mysql.com committed
104 105
#include "completion_hash.h"

jani@hynda.mysql.fi's avatar
merge  
jani@hynda.mysql.fi committed
106 107
#define PROMPT_CHAR '\\'

bk@work.mysql.com's avatar
bk@work.mysql.com committed
108 109 110 111 112 113 114 115 116 117 118
typedef struct st_status
{
  int exit_status;
  ulong query_start_line;
  char *file_name;
  LINE_BUFFER *line_buff;
  bool batch,add_to_history;
} STATUS;


static HashTable ht;
119
static char **defaults_argv;
bk@work.mysql.com's avatar
bk@work.mysql.com committed
120 121 122 123 124

enum enum_info_type { INFO_INFO,INFO_ERROR,INFO_RESULT};
typedef enum enum_info_type INFO_TYPE;

static MYSQL mysql;			/* The connection */
125 126
static my_bool info_flag=0,ignore_errors=0,wait_flag=0,quick=0,
               connected=0,opt_raw_data=0,unbuffered=0,output_tables=0,
127
	       rehash=1,skip_updates=0,safe_updates=0,one_database=0,
jani@hynda.mysql.fi's avatar
merge  
jani@hynda.mysql.fi committed
128
	       opt_compress=0, using_opt_local_infile=0,
129 130
	       vertical=0, line_numbers=1, column_names=1,opt_html=0,
               opt_xml=0,opt_nopager=1, opt_outfile=0, named_cmds= 0,
131
               tty_password= 0, opt_nobeep=0;
jani@hynda.mysql.fi's avatar
merge  
jani@hynda.mysql.fi committed
132
static uint verbose=0,opt_silent=0,opt_mysql_port=0, opt_local_infile=0;
bk@work.mysql.com's avatar
bk@work.mysql.com committed
133 134 135
static my_string opt_mysql_unix_port=0;
static int connect_flag=CLIENT_INTERACTIVE;
static char *current_host,*current_db,*current_user=0,*opt_password=0,
jani@hynda.mysql.fi's avatar
merge  
jani@hynda.mysql.fi committed
136
            *current_prompt=0, *default_charset;
bk@work.mysql.com's avatar
bk@work.mysql.com committed
137 138
static char *histfile;
static String glob_buffer,old_buffer;
jani@hynda.mysql.fi's avatar
merge  
jani@hynda.mysql.fi committed
139 140
static String processed_prompt;
static char *full_username=0,*part_username=0,*default_prompt=0;
141
static int wait_time = 5;
bk@work.mysql.com's avatar
bk@work.mysql.com committed
142
static STATUS status;
143
static ulong select_limit,max_join_size,opt_connect_timeout=0;
monty@hundin.mysql.fi's avatar
monty@hundin.mysql.fi committed
144
static char mysql_charsets_dir[FN_REFLEN+1];
145
static const char *xmlmeta[] = {
146 147 148 149
  "&", "&amp;",
  "<", "&lt;",
  0, 0
};
jani@hynda.mysql.fi's avatar
merge  
jani@hynda.mysql.fi committed
150 151 152 153 154 155 156 157
static const char *day_names[]={"Sun","Mon","Tue","Wed","Thu","Fri","Sat"};
static const char *month_names[]={"Jan","Feb","Mar","Apr","May","Jun","Jul",
			    "Aug","Sep","Oct","Nov","Dec"};
static char default_pager[FN_REFLEN];
static char pager[FN_REFLEN], outfile[FN_REFLEN];
static FILE *PAGER, *OUTFILE;
static MEM_ROOT hash_mem_root;
static uint prompt_counter;
bk@work.mysql.com's avatar
bk@work.mysql.com committed
158 159 160 161 162 163 164

#include "sslopt-vars.h"

#ifndef DBUG_OFF
const char *default_dbug_option="d:t:o,/tmp/mysql.trace";
#endif

jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
165 166 167
void tee_fprintf(FILE *file, const char *fmt, ...);
void tee_fputs(const char *s, FILE *file);
void tee_puts(const char *s, FILE *file);
168
void tee_putc(int c, FILE *file);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
169 170 171 172
/* The names of functions that actually do the manipulation. */
static int get_options(int argc,char **argv);
static int com_quit(String *str,char*),
	   com_go(String *str,char*), com_ego(String *str,char*),
173
	   com_print(String *str,char*),
bk@work.mysql.com's avatar
bk@work.mysql.com committed
174 175 176
	   com_help(String *str,char*), com_clear(String *str,char*),
	   com_connect(String *str,char*), com_status(String *str,char*),
	   com_use(String *str,char*), com_source(String *str, char*),
177
	   com_rehash(String *str, char*), com_tee(String *str, char*),
monty@mashka.mysql.fi's avatar
monty@mashka.mysql.fi committed
178
           com_notee(String *str, char*),
jani@hynda.mysql.fi's avatar
merge  
jani@hynda.mysql.fi committed
179
           com_prompt(String *str, char*);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
180

monty@mashka.mysql.fi's avatar
monty@mashka.mysql.fi committed
181
#ifdef USE_POPEN
182
static int com_nopager(String *str, char*), com_pager(String *str, char*),
monty@mashka.mysql.fi's avatar
monty@mashka.mysql.fi committed
183
           com_edit(String *str,char*), com_shell(String *str, char *);
184 185
#endif

bk@work.mysql.com's avatar
bk@work.mysql.com committed
186 187 188 189 190
static int read_lines(bool execute_commands);
static int sql_connect(char *host,char *database,char *user,char *password,
		       uint silent);
static int put_info(const char *str,INFO_TYPE info,uint error=0);
static void safe_put_field(const char *pos,ulong length);
191
static void xmlencode_print(const char *src, uint length);
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
192 193
static void init_pager();
static void end_pager();
monty@mashka.mysql.fi's avatar
monty@mashka.mysql.fi committed
194
static void init_tee(const char *);
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
195
static void end_tee();
jani@hynda.mysql.fi's avatar
merge  
jani@hynda.mysql.fi committed
196 197 198
static const char* construct_prompt();
static void init_username();
static void add_int_to_prompt(int toadd);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
199 200 201 202 203 204 205 206 207 208 209 210 211

/* A structure which contains information on the commands this program
   can understand. */

typedef struct {
  const char *name;		/* User printable name of the function. */
  char cmd_char;		/* msql command character */
  int (*func)(String *str,char *); /* Function to call to do the job. */
  bool takes_params;		/* Max parameters for command */
  const char *doc;		/* Documentation for this function.  */
} COMMANDS;

static COMMANDS commands[] = {
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
212 213 214
  { "help",   'h', com_help,   0, "Display this help." },
  { "?",      '?', com_help,   0, "Synonym for `help'." },
  { "clear",  'c', com_clear,  0, "Clear command."},
215
  { "connect",'r', com_connect,1,
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
216
    "Reconnect to the server. Optional arguments are db and host." },
monty@mashka.mysql.fi's avatar
monty@mashka.mysql.fi committed
217
#ifdef USE_POPEN
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
218
  { "edit",   'e', com_edit,   0, "Edit command with $EDITOR."},
219
#endif
220
  { "ego",    'G', com_ego,    0,
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
221 222 223
    "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." },
monty@mashka.mysql.fi's avatar
monty@mashka.mysql.fi committed
224
#ifdef USE_POPEN
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
225 226 227
  { "nopager",'n', com_nopager,0, "Disable pager, print to stdout." },
#endif
  { "notee",  't', com_notee,  0, "Don't write into outfile." },
monty@mashka.mysql.fi's avatar
monty@mashka.mysql.fi committed
228
#ifdef USE_POPEN
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
229 230 231 232
  { "pager",  'P', com_pager,  1, 
    "Set PAGER [to_pager]. Print the query results via PAGER." },
#endif
  { "print",  'p', com_print,  0, "Print current command." },
jani@hynda.mysql.fi's avatar
merge  
jani@hynda.mysql.fi committed
233
  { "prompt", 'R', com_prompt, 1, "Change your mysql prompt."},
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
234 235
  { "quit",   'q', com_quit,   0, "Quit mysql." },
  { "rehash", '#', com_rehash, 0, "Rebuild completion hash." },
bk@work.mysql.com's avatar
bk@work.mysql.com committed
236
  { "source", '.', com_source, 1,
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
237 238
    "Execute a SQL script file. Takes a file name as an argument."},
  { "status", 's', com_status, 0, "Get status information from the server."},
monty@mashka.mysql.fi's avatar
monty@mashka.mysql.fi committed
239
#ifdef USE_POPEN
240 241
  { "system", '!', com_shell,  1, "Execute a system shell command."},
#endif
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
242 243
  { "tee",    'T', com_tee,    1, 
    "Set outfile [to_outfile]. Append everything into given outfile." },
244
  { "use",    'u', com_use,    1,
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
245
    "Use another database. Takes database name as argument." },
bk@work.mysql.com's avatar
bk@work.mysql.com committed
246

jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
247
  /* Get bash-like expansion for some commands */
248 249 250 251 252 253 254 255 256 257 258 259 260 261 262 263 264 265 266
  { "create table",     0, 0, 0, ""},
  { "create database",  0, 0, 0, ""},
  { "drop",             0, 0, 0, ""},
  { "select",           0, 0, 0, ""},
  { "insert",           0, 0, 0, ""},
  { "replace",          0, 0, 0, ""},
  { "update",           0, 0, 0, ""},
  { "delete",           0, 0, 0, ""},
  { "explain",          0, 0, 0, ""},
  { "show databases",   0, 0, 0, ""},
  { "show fields from", 0, 0, 0, ""},
  { "show keys from",   0, 0, 0, ""},
  { "show tables",      0, 0, 0, ""},
  { "load data from",   0, 0, 0, ""},
  { "alter table",      0, 0, 0, ""},
  { "set option",       0, 0, 0, ""},
  { "lock tables",      0, 0, 0, ""},
  { "unlock tables",    0, 0, 0, ""},
  { (char *)NULL,       0, 0, 0, ""}
bk@work.mysql.com's avatar
bk@work.mysql.com committed
267 268 269
};

static const char *load_default_groups[]= { "mysql","client",0 };
270 271
static const char *server_default_groups[]=
{ "server", "embedded", "mysql_SERVER", 0 };
bk@work.mysql.com's avatar
bk@work.mysql.com committed
272 273 274 275 276 277 278 279 280 281 282 283 284

#ifdef HAVE_READLINE
extern "C" void add_history(char *command); /* From readline directory */
extern "C" int read_history(char *command);
extern "C" int write_history(char *command);
static void initialize_readline (char *name);
#endif

static COMMANDS *find_command (char *name,char cmd_name);
static bool add_line(String &buffer,char *line,char *in_string);
static void remove_cntrl(String &buffer);
static void print_table_data(MYSQL_RES *result);
static void print_table_data_html(MYSQL_RES *result);
285
static void print_table_data_xml(MYSQL_RES *result);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
286 287 288 289 290 291 292 293 294 295 296 297 298 299 300 301 302
static void print_tab_data(MYSQL_RES *result);
static void print_table_data_vertically(MYSQL_RES *result);
static ulong start_timer(void);
static void end_timer(ulong start_time,char *buff);
static void mysql_end_timer(ulong start_time,char *buff);
static void nice_time(double sec,char *buff,bool part_second);
static sig_handler mysql_end(int sig);


int main(int argc,char *argv[])
{
  char buff[80];

  MY_INIT(argv[0]);
  DBUG_ENTER("main");
  DBUG_PROCESS(argv[0]);

jani@hynda.mysql.fi's avatar
merge  
jani@hynda.mysql.fi committed
303 304 305 306 307 308
  default_prompt = my_strdup(getenv("MYSQL_PS1") ? 
			     getenv("MYSQL_PS1") : 
			     "mysql> ",MYF(MY_WME));
  current_prompt = my_strdup(default_prompt,MYF(MY_WME));
  prompt_counter=0;

monty@mashka.mysql.fi's avatar
monty@mashka.mysql.fi committed
309 310
  outfile[0]=0;			// no (default) outfile
  strmov(pager, "stdout");	// the default, if --pager wasn't given
311 312 313 314 315
  {
    char *tmp=getenv("PAGER");
    if (tmp)
      strmov(default_pager,tmp);
  }
bk@work.mysql.com's avatar
bk@work.mysql.com committed
316 317 318 319 320 321 322 323 324
  if (!isatty(0) || !isatty(1))
  {
    status.batch=1; opt_silent=1;
    ignore_errors=0;
  }
  else
    status.add_to_history=1;
  status.exit_status=1;
  load_defaults("my",load_default_groups,&argc,&argv);
325
  defaults_argv=argv;
326
  if (get_options(argc, (char **) argv))
bk@work.mysql.com's avatar
bk@work.mysql.com committed
327
  {
328
    free_defaults(defaults_argv);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
329 330 331 332 333
    my_end(0);
    exit(1);
  }
  if (status.batch && !status.line_buff &&
      !(status.line_buff=batch_readline_init(max_allowed_packet+512,stdin)))
334 335
  {
    free_defaults(defaults_argv);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
336
    exit(1);
337
  }
bk@work.mysql.com's avatar
bk@work.mysql.com committed
338
  glob_buffer.realloc(512);
339 340 341
  mysql_server_init(0, NULL, (char**) server_default_groups);
  completion_hash_init(&ht, 128);
  init_alloc_root(&hash_mem_root, 16384, 0);
342
  bzero((char*) &mysql, sizeof(mysql));
bk@work.mysql.com's avatar
bk@work.mysql.com committed
343 344 345
  if (sql_connect(current_host,current_db,current_user,opt_password,
		  opt_silent))
  {
346 347 348
    quick=1;					// Avoid history
    status.exit_status=1;
    mysql_end(-1);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
349 350 351 352 353
  }
  if (!status.batch)
    ignore_errors=1;				// Don't abort monitor
  signal(SIGINT, mysql_end);			// Catch SIGINT to clean up

jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
354
  /*
355
    Run in interactive mode like the ingres/postgres monitor
bk@work.mysql.com's avatar
bk@work.mysql.com committed
356 357 358 359 360
  */

  put_info("Welcome to the MySQL monitor.  Commands end with ; or \\g.",
	   INFO_INFO);
  sprintf((char*) glob_buffer.ptr(),
361
	  "Your MySQL connection id is %lu to server version: %s\n",
bk@work.mysql.com's avatar
bk@work.mysql.com committed
362 363 364 365 366
	  mysql_thread_id(&mysql),mysql_get_server_info(&mysql));
  put_info((char*) glob_buffer.ptr(),INFO_INFO);

#ifdef HAVE_READLINE
  initialize_readline(my_progname);
367
  if (!status.batch && !quick && !opt_html && !opt_xml)
bk@work.mysql.com's avatar
bk@work.mysql.com committed
368
  {
369
    /* read-history from file, default ~/.mysql_history*/
bk@work.mysql.com's avatar
bk@work.mysql.com committed
370 371 372 373
    if (getenv("MYSQL_HISTFILE"))
      histfile=my_strdup(getenv("MYSQL_HISTFILE"),MYF(MY_WME));
    else if (getenv("HOME"))
    {
374 375
      histfile=(char*) my_malloc((uint) strlen(getenv("HOME"))
				 + (uint) strlen("/.mysql_history")+2,
bk@work.mysql.com's avatar
bk@work.mysql.com committed
376 377 378 379 380 381 382
				 MYF(MY_WME));
      if (histfile)
	sprintf(histfile,"%s/.mysql_history",getenv("HOME"));
    }
    if (histfile)
    {
      if (verbose)
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
383
	tee_fprintf(stdout, "Reading history-file %s\n",histfile);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
384 385 386 387
      read_history(histfile);
    }
  }
#endif
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
388
  sprintf(buff, 
389
	  "Type 'help;' or '\\h' for help. Type '\\c' to clear the buffer.\n");
bk@work.mysql.com's avatar
bk@work.mysql.com committed
390 391
  put_info(buff,INFO_INFO);
  status.exit_status=read_lines(1);		// read lines and execute them
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
392 393
  if (opt_outfile)
    end_tee();
bk@work.mysql.com's avatar
bk@work.mysql.com committed
394 395 396 397 398 399 400 401
  mysql_end(0);
#ifndef _lint
  DBUG_RETURN(0);				// Keep compiler happy
#endif
}

sig_handler mysql_end(int sig)
{
402
  mysql_close(&mysql);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
403
#ifdef HAVE_READLINE
404
  if (!status.batch && !quick && !opt_html && !opt_xml)
bk@work.mysql.com's avatar
bk@work.mysql.com committed
405 406 407
  {
    /* write-history */
    if (verbose)
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
408
      tee_fprintf(stdout, "Writing history-file %s\n",histfile);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
409 410 411 412
    write_history(histfile);
  }
  batch_readline_end(status.line_buff);
  completion_hash_free(&ht);
413 414
  free_root(&hash_mem_root,MYF(0));

bk@work.mysql.com's avatar
bk@work.mysql.com committed
415
#endif
416 417
  if (sig >= 0)
    put_info(sig ? "Aborted" : "Bye", INFO_RESULT);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
418 419
  glob_buffer.free();
  old_buffer.free();
jani@hynda.mysql.fi's avatar
merge  
jani@hynda.mysql.fi committed
420
  processed_prompt.free();
bk@work.mysql.com's avatar
bk@work.mysql.com committed
421 422 423 424 425 426
  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_db,MYF(MY_ALLOW_ZERO_PTR));
  my_free(current_host,MYF(MY_ALLOW_ZERO_PTR));
  my_free(current_user,MYF(MY_ALLOW_ZERO_PTR));
jani@hynda.mysql.fi's avatar
merge  
jani@hynda.mysql.fi committed
427 428 429 430
  my_free(full_username,MYF(MY_ALLOW_ZERO_PTR));
  my_free(part_username,MYF(MY_ALLOW_ZERO_PTR));
  my_free(default_prompt,MYF(MY_ALLOW_ZERO_PTR));
  my_free(current_prompt,MYF(MY_ALLOW_ZERO_PTR));
431
  mysql_server_end();
432
  free_defaults(defaults_argv);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
433 434 435 436
  my_end(info_flag ? MY_CHECK_ERROR | MY_GIVE_INFO : 0);
  exit(status.exit_status);
}

437 438

static struct my_option my_long_options[] =
bk@work.mysql.com's avatar
bk@work.mysql.com committed
439
{
440 441 442 443
  {"help", '?', "Display this help and exit.", 0, 0, 0, GET_NO_ARG, NO_ARG, 0,
   0, 0, 0, 0, 0},
  {"auto-rehash", OPT_AUTO_REHASH,
   "Enable automatic rehashing. One doesn't need to use 'rehash' to get table and field completion, but startup and reconnecting may take a longer time. Disable with --disable-auto-rehash.",
444
   (gptr*) &rehash, (gptr*) &rehash, 0, GET_BOOL, NO_ARG, 1, 0, 0, 0, 0, 0},
445
  {"no-auto-rehash", 'A',
446
   "No automatic rehashing. One has to use 'rehash' to get table and field completion. This gives a quicker start of mysql and disables rehashing on reconnect. WARNING: options deprecated; use --disable-auto-rehash instead.",
447 448 449 450 451 452
   0, 0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0},
  {"batch", 'B',
   "Print results with a tab as separator, each row on new line. Doesn't use history file.", 0, 0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0},
  {"character-sets-dir", OPT_CHARSETS_DIR,
   "Directory where character sets are.", (gptr*) &charsets_dir,
   (gptr*) &charsets_dir, 0, GET_STR, REQUIRED_ARG, 0, 0, 0, 0, 0, 0},
453 454 455
  {"default-character-set", OPT_DEFAULT_CHARSET,
   "Set the default character set.", (gptr*) &default_charset,
   (gptr*) &default_charset, 0, GET_STR, REQUIRED_ARG, 0, 0, 0, 0, 0, 0},
456 457 458
  {"compress", 'C', "Use compression in server/client protocol.",
   (gptr*) &opt_compress, (gptr*) &opt_compress, 0, GET_BOOL, NO_ARG, 0, 0, 0,
   0, 0, 0},
bk@work.mysql.com's avatar
bk@work.mysql.com committed
459
#ifndef DBUG_OFF
460 461 462
  {"debug", '#', "Output debug log.", (gptr*) &default_dbug_option,
   (gptr*) &default_dbug_option, 0, GET_STR, OPT_ARG, 0, 0, 0, 0, 0, 0},
#endif
463
  {"database", 'D', "Database to use.", (gptr*) &current_db,
464
   (gptr*) &current_db, 0, GET_STR_ALLOC, REQUIRED_ARG, 0, 0, 0, 0, 0, 0},
465 466 467 468 469 470 471 472
  {"execute", 'e', "Execute command and quit. (Output like with --batch).", 0,
   0, 0, GET_STR, REQUIRED_ARG, 0, 0, 0, 0, 0, 0},
  {"vertical", 'E', "Print the output of a query (rows) vertically.",
   (gptr*) &vertical, (gptr*) &vertical, 0, GET_BOOL, NO_ARG, 0, 0, 0, 0, 0,
   0},
  {"force", 'f', "Continue even if we get an sql error.",
   (gptr*) &ignore_errors, (gptr*) &ignore_errors, 0, GET_BOOL, NO_ARG, 0, 0,
   0, 0, 0, 0},
473
  {"no-named-commands", 'g',
474
   "Named commands are disabled. Use \\* form only, or use named commands only in the beginning of a line ending with a semicolon (;) Since version 10.9 the client now starts with this option ENABLED by default! Disable with '-G'. Long format commands still work from the first line. WARNING: option deprecated; use --disable-named-commands instead.",
475 476
   0, 0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0},
  {"named-commands", 'G',
477
   "Enable named commands. Named commands mean this program's internal commands; see mysql> help . When enabled, the named commands can be used from any line of the query, otherwise only from the first line, before an enter. Disable with --disable-named-commands. This option is disabled by default.",
478 479
   (gptr*) &named_cmds, (gptr*) &named_cmds, 0, GET_BOOL, NO_ARG, 0, 0, 0, 0,
   0, 0},
480
  {"ignore-spaces", 'i', "Ignore space after function names.", 0, 0, 0,
481
   GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0},
jani@hynda.mysql.fi's avatar
merge  
jani@hynda.mysql.fi committed
482
  {"local-infile", OPT_LOCAL_INFILE, "Enable/disable LOAD DATA LOCAL INFILE.",
483 484
   (gptr*) &opt_local_infile,
   (gptr*) &opt_local_infile, 0, GET_BOOL, OPT_ARG, 0, 0, 0, 0, 0, 0},
485 486
  {"no-beep", 'b', "Turn off beep on error.", (gptr*) &opt_nobeep,
   (gptr*) &opt_nobeep, 0, GET_BOOL, NO_ARG, 0, 0, 0, 0, 0, 0}, 
487
  {"host", 'h', "Connect to host.", (gptr*) &current_host,
488
   (gptr*) &current_host, 0, GET_STR_ALLOC, REQUIRED_ARG, 0, 0, 0, 0, 0, 0},
489 490 491 492 493 494
  {"html", 'H', "Produce HTML output.", (gptr*) &opt_html, (gptr*) &opt_html,
   0, GET_BOOL, NO_ARG, 0, 0, 0, 0, 0, 0},
  {"xml", 'X', "Produce XML output", (gptr*) &opt_xml, (gptr*) &opt_xml, 0,
   GET_BOOL, NO_ARG, 0, 0, 0, 0, 0, 0},
  {"line-numbers", OPT_LINE_NUMBERS, "Write line numbers for errors.",
   (gptr*) &line_numbers, (gptr*) &line_numbers, 0, GET_BOOL,
495
   NO_ARG, 1, 0, 0, 0, 0, 0},  
496
  {"skip-line-numbers", 'L', "Don't write line number for errors. WARNING: -L is deprecated, use long version of this option instead.", 0, 0, 0, GET_NO_ARG,
497
   NO_ARG, 0, 0, 0, 0, 0, 0},
monty@mashka.mysql.fi's avatar
monty@mashka.mysql.fi committed
498
#ifdef USE_POPEN
499
  {"no-pager", OPT_NOPAGER,
500
   "Disable pager and print to stdout. See interactive help (\\h) also. WARNING: option deprecated; use --disable-pager instead.",
501
   0, 0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0},
bk@work.mysql.com's avatar
bk@work.mysql.com committed
502
#endif
503
  {"no-tee", OPT_NOTEE, "Disable outfile. See interactive help (\\h) also. WARNING: option deprecated; use --disable-tee instead", 0, 0, 0, GET_NO_ARG,
504 505 506 507 508
   NO_ARG, 0, 0, 0, 0, 0, 0},
  {"unbuffered", 'n', "Flush buffer after each query.", (gptr*) &unbuffered,
   (gptr*) &unbuffered, 0, GET_BOOL, NO_ARG, 0, 0, 0, 0, 0, 0},
  {"column-names", OPT_COLUMN_NAMES, "Write column names in results.",
   (gptr*) &column_names, (gptr*) &column_names, 0, GET_BOOL,
509
   NO_ARG, 1, 0, 0, 0, 0, 0},
510
  {"skip-column-names", 'N',
511
   "Don't write column names in results. WARNING: -N is deprecated, use long version of this options instead.",
512 513
   0, 0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0},
  {"set-variable", 'O',
514
   "Change the value of a variable. Please note that this option is deprecated; you can set variables directly with --variable-name=value.",
515 516 517 518
   0, 0, 0, GET_STR, REQUIRED_ARG, 0, 0, 0, 0, 0, 0},
  {"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},
monty@mashka.mysql.fi's avatar
monty@mashka.mysql.fi committed
519
#ifdef USE_POPEN
520 521 522
  {"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.",
   0, 0, 0, GET_STR, OPT_ARG, 0, 0, 0, 0, 0, 0},
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
523
#endif
524 525 526
  {"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},
bk@work.mysql.com's avatar
bk@work.mysql.com committed
527
#ifdef __WIN__
528 529
  {"pipe", 'W', "Use named pipes to connect to server.", 0, 0, 0, GET_NO_ARG,
   NO_ARG, 0, 0, 0, 0, 0, 0},
bk@work.mysql.com's avatar
bk@work.mysql.com committed
530
#endif
531 532 533
  {"port", 'P', "Port number to use for connection.", (gptr*) &opt_mysql_port,
   (gptr*) &opt_mysql_port, 0, GET_UINT, REQUIRED_ARG, MYSQL_PORT, 0, 0, 0, 0,
   0},
534
  {"prompt", OPT_PROMPT, "Set the mysql prompt to this value.",
535
   (gptr*) &current_prompt, (gptr*) &current_prompt, 0, GET_STR_ALLOC,
536
   REQUIRED_ARG, 0, 0, 0, 0, 0, 0},
537 538 539 540 541 542 543 544 545
  {"quick", 'q',
   "Don't cache result, print it row by row. This may slow down the server if the output is suspended. Doesn't use history file. ",
   (gptr*) &quick, (gptr*) &quick, 0, GET_BOOL, NO_ARG, 0, 0, 0, 0, 0, 0},
  {"raw", 'r', "Write fields without conversion. Used with --batch",
   (gptr*) &opt_raw_data, (gptr*) &opt_raw_data, 0, GET_BOOL, NO_ARG, 0, 0, 0,
   0, 0, 0},
  {"silent", 's', "Be more silent.", 0, 0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0,
   0, 0},
  {"socket", 'S', "Socket file to use for connection.",
546
   (gptr*) &opt_mysql_unix_port, (gptr*) &opt_mysql_unix_port, 0, GET_STR_ALLOC,
547
   REQUIRED_ARG, 0, 0, 0, 0, 0, 0},
bk@work.mysql.com's avatar
bk@work.mysql.com committed
548
#include "sslopt-longopts.h"
549 550 551 552 553 554 555
  {"table", 't', "Output in table format.", (gptr*) &output_tables,
   (gptr*) &output_tables, 0, GET_BOOL, NO_ARG, 0, 0, 0, 0, 0, 0},
  {"debug-info", 'T', "Print some debug info at exit.", (gptr*) &info_flag,
   (gptr*) &info_flag, 0, GET_BOOL, NO_ARG, 0, 0, 0, 0, 0, 0},
  {"tee", OPT_TEE,
   "Append everything into outfile. See interactive help (\\h) also. Does not work in batch mode.",
   0, 0, 0, GET_STR, REQUIRED_ARG, 0, 0, 0, 0, 0, 0},
bk@work.mysql.com's avatar
bk@work.mysql.com committed
556
#ifndef DONT_ALLOW_USER_CHANGE
557
  {"user", 'u', "User for login if not current user.", (gptr*) &current_user,
558
   (gptr*) &current_user, 0, GET_STR_ALLOC, REQUIRED_ARG, 0, 0, 0, 0, 0, 0},
bk@work.mysql.com's avatar
bk@work.mysql.com committed
559
#endif
560 561 562
  {"safe-updates", 'U', "Only allow UPDATE and DELETE that uses keys.",
   (gptr*) &safe_updates, (gptr*) &safe_updates, 0, GET_BOOL, OPT_ARG, 0, 0,
   0, 0, 0, 0},
563 564 565
  {"i-am-a-dummy", 'U', "Synonym for option --safe-updates, -U.",
   (gptr*) &safe_updates, (gptr*) &safe_updates, 0, GET_BOOL, OPT_ARG, 0, 0,
   0, 0, 0, 0},
566 567 568 569 570 571 572
  {"verbose", 'v', "Write more. (-v -v -v gives the table output format)", 0,
   0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0},
  {"version", 'V', "Output version information and exit.", 0, 0, 0,
   GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0},
  {"wait", 'w', "Wait and retry if connection is down.", 0, 0, 0, GET_NO_ARG,
   NO_ARG, 0, 0, 0, 0, 0, 0},
  {"connect_timeout", OPT_CONNECT_TIMEOUT, "", (gptr*) &opt_connect_timeout,
573
   (gptr*) &opt_connect_timeout, 0, GET_ULONG, REQUIRED_ARG, 0, 0, 3600*12, 0,
574 575
   0, 1},
  {"max_allowed_packet", OPT_MAX_ALLOWED_PACKET, "",
576
   (gptr*) &max_allowed_packet, (gptr*) &max_allowed_packet, 0, GET_ULONG,
577 578
   REQUIRED_ARG, 16 *1024L*1024L, 4096, (longlong) 2*1024L*1024L*1024L,
   MALLOC_OVERHEAD, 1024, 0},
579
  {"net_buffer_length", OPT_NET_BUFFER_LENGTH, "",
580
   (gptr*) &net_buffer_length, (gptr*) &net_buffer_length, 0, GET_ULONG,
581 582
   REQUIRED_ARG, 16384, 1024, 512*1024*1024L, MALLOC_OVERHEAD, 1024, 0},
  {"select_limit", OPT_SELECT_LIMIT, "", (gptr*) &select_limit,
583
   (gptr*) &select_limit, 0, GET_ULONG, REQUIRED_ARG, 1000L, 1, ~0L, 0, 1, 0},
584
  {"max_join_size", OPT_MAX_JOIN_SIZE, "", (gptr*) &max_join_size,
585
   (gptr*) &max_join_size, 0, GET_ULONG, REQUIRED_ARG, 1000000L, 1, ~0L, 0, 1,
586 587
   0},
  { 0, 0, 0, 0, 0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0}
bk@work.mysql.com's avatar
bk@work.mysql.com committed
588 589 590 591 592
};


static void usage(int version)
{
monty@mysql.com's avatar
monty@mysql.com committed
593 594 595 596
  /* Divert all help information on NetWare to logger screen. */
#ifdef __NETWARE__
#define printf	consoleprintf
#endif
597 598
  printf("%s  Ver %s Distrib %s, for %s (%s)\n",
	 my_progname, VER, MYSQL_SERVER_VERSION, SYSTEM_TYPE, MACHINE_TYPE);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
599 600
  if (version)
    return;
jani@hynda.mysql.fi's avatar
merge  
jani@hynda.mysql.fi committed
601
  printf("\
602
Copyright (C) 2002 MySQL AB\n\
jani@hynda.mysql.fi's avatar
merge  
jani@hynda.mysql.fi committed
603 604
This software comes with ABSOLUTELY NO WARRANTY. This is free software,\n\
and you are welcome to modify and redistribute it under the GPL license\n");
bk@work.mysql.com's avatar
bk@work.mysql.com committed
605
  printf("Usage: %s [OPTIONS] [database]\n", my_progname);
606
  my_print_help(my_long_options);
607
  print_defaults("my", load_default_groups);
608
  my_print_variables(my_long_options);
monty@mysql.com's avatar
monty@mysql.com committed
609 610 611 612
  NETWARE_SET_SCREEN_MODE(1);
#ifdef __NETWARE__
#undef printf
#endif
bk@work.mysql.com's avatar
bk@work.mysql.com committed
613 614
}

monty@mysql.com's avatar
monty@mysql.com committed
615

616 617 618
static my_bool
get_one_option(int optid, const struct my_option *opt __attribute__((unused)),
	       char *argument)
bk@work.mysql.com's avatar
bk@work.mysql.com committed
619
{
620
  switch(optid) {
621 622 623 624 625 626 627 628 629 630
  case OPT_CHARSETS_DIR:
    strmov(mysql_charsets_dir, argument);
    charsets_dir = mysql_charsets_dir;
    break;
  case OPT_LOCAL_INFILE:
    using_opt_local_infile=1;
    break;
  case OPT_TEE:
    if (argument == disabled_my_option)
    {
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
631 632
      if (opt_outfile)
	end_tee();
633 634
    }
    else
monty@mashka.mysql.fi's avatar
monty@mashka.mysql.fi committed
635
      init_tee(argument);
636 637
    break;
  case OPT_NOTEE:
638
    printf("WARNING: option deprecated; use --disable-tee instead.\n");
639 640 641 642
    if (opt_outfile)
      end_tee();
    break;
  case OPT_PAGER:
643 644
    if (argument == disabled_my_option)
      opt_nopager= 1;
645
    else
646 647 648 649 650 651 652 653
    {
      opt_nopager= 0;
      if (argument)
	strmov(pager, argument);
      else
	strmov(pager, default_pager);
      strmov(default_pager, pager);
    }
654 655
    break;
  case OPT_NOPAGER:
656
    printf("WARNING: option deprecated; use --disable-pager instead.\n");
657 658 659 660 661 662 663 664 665 666 667 668 669 670 671 672 673 674 675 676 677 678 679 680 681 682 683 684 685 686 687 688 689 690 691 692 693 694 695 696 697 698 699 700 701 702 703 704 705 706 707 708 709 710 711 712 713 714 715 716 717 718
    opt_nopager= 1;
    break;
  case 'A':
    rehash= 0;
    break;
  case 'N':
    column_names= 0;
    break;
  case 'e':
    status.batch= 1;
    status.add_to_history= 0;
    batch_readline_end(status.line_buff);	// If multiple -e
    if (!(status.line_buff= batch_readline_command(argument)))
      return 1;
    ignore_errors= 0;
    break;
  case 'o':
    if (argument == disabled_my_option)
      one_database= 0;
    else
      one_database= skip_updates= 1;
    break;
  case 'p':
    if (argument == disabled_my_option)
      argument= (char*) "";			// Don't require password
    if (argument)
    {
      char *start= argument;
      my_free(opt_password, MYF(MY_ALLOW_ZERO_PTR));
      opt_password= my_strdup(argument, MYF(MY_FAE));
      while (*argument) *argument++= 'x';		// Destroy argument
      if (*start)
	start[1]=0 ;
    }
    else
      tty_password= 1;
    break;
  case '#':
    DBUG_PUSH(argument ? argument : default_dbug_option);
    info_flag= 1;
    break;
  case 's':
    if (argument == disabled_my_option)
      opt_silent= 0;
    else
      opt_silent++;
    break;
  case 'v':
    if (argument == disabled_my_option)
      verbose= 0;
    else
      verbose++;
    break;
  case 'B':
    if (!status.batch)
    {
      status.batch= 1;
      status.add_to_history= 0;
      opt_silent++;				// more silent
    }
    break;
  case 'W':
bk@work.mysql.com's avatar
bk@work.mysql.com committed
719
#ifdef __WIN__
720
    my_free(opt_mysql_unix_port, MYF(MY_ALLOW_ZERO_PTR));
721
    opt_mysql_unix_port= my_strdup(MYSQL_NAMEDPIPE, MYF(0));
bk@work.mysql.com's avatar
bk@work.mysql.com committed
722
#endif
723
    break;
724
#include <sslopt-case.h>
725 726 727 728 729 730 731
  case 'V':
    usage(1);
    exit(0);
  case 'I':
  case '?':
    usage(0);
    exit(0);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
732
  }
733 734 735 736 737 738 739 740 741 742 743 744 745 746 747 748 749 750 751 752 753 754 755 756
  return 0;
}


static int get_options(int argc, char **argv)
{
  char *tmp, *pagpoint;
  int ho_error;

  tmp= (char *) getenv("MYSQL_HOST");
  if (tmp)
    current_host= my_strdup(tmp, MYF(MY_WME));

  pagpoint= getenv("PAGER");
  if (!((char*) (pagpoint)))
  {
    strmov(pager, "stdout");
    opt_nopager= 1;
  }
  else
    strmov(pager, pagpoint);
  strmov(default_pager, pager);

  if ((ho_error=handle_options(&argc, &argv, my_long_options, get_one_option)))
757
    exit(ho_error);
758

jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
759 760 761 762
  if (status.batch) /* disable pager and outfile in this case */
  {
    strmov(default_pager, "stdout");
    strmov(pager, "stdout");
763 764
    opt_nopager= 1;
    opt_outfile= 0;
765
    connect_flag= 0; /* Not in interactive mode */
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
766
  }
bk@work.mysql.com's avatar
bk@work.mysql.com committed
767 768 769 770 771 772 773 774 775 776 777 778
  if (default_charset)
  {
    if (set_default_charset_by_name(default_charset, MYF(MY_WME)))
      exit(1);
  }
  if (argc > 1)
  {
    usage(0);
    exit(1);
  }
  if (argc == 1)
  {
779
    skip_updates= 0;
780 781
    my_free(current_db, MYF(MY_ALLOW_ZERO_PTR));
    current_db= my_strdup(*argv, MYF(MY_WME));
bk@work.mysql.com's avatar
bk@work.mysql.com committed
782 783
  }
  if (tty_password)
784
    opt_password= get_tty_password(NullS);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
785 786 787 788 789
  return(0);
}

static int read_lines(bool execute_commands)
{
monty@mashka.mysql.fi's avatar
monty@mashka.mysql.fi committed
790
#if defined( __WIN__) || defined(OS2) || defined(__NETWARE__)
bk@work.mysql.com's avatar
bk@work.mysql.com committed
791 792 793 794 795 796 797 798 799 800 801 802 803 804 805 806 807 808
  char linebuffer[254];
#endif
  char	*line;
  char	in_string=0;
  ulong line_number=0;
  COMMANDS *com;
  status.exit_status=1;

  for (;;)
  {
    if (status.batch || !execute_commands)
    {
      line=batch_readline(status.line_buff);
      line_number++;
      if (!glob_buffer.length())
	status.query_start_line=line_number;
    }
    else
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
809
    {
monty@mashka.mysql.fi's avatar
monty@mashka.mysql.fi committed
810 811 812
      char *prompt= (char*) (glob_buffer.is_empty() ? construct_prompt() :
			     !in_string ? "    -> " :
			     in_string == '\'' ?
813 814 815
			     "    '> " : (in_string == '`' ?
			     "    `> " :
			     "    \"> "));
816 817
      if (opt_outfile && glob_buffer.is_empty())
	fflush(OUTFILE);
monty@mashka.mysql.fi's avatar
monty@mashka.mysql.fi committed
818 819 820 821 822 823

#if defined( __WIN__) || defined(OS2) || defined(__NETWARE__)
      tee_fputs(prompt, stdout);
#ifdef __NETWARE__
      line=fgets(linebuffer, sizeof(linebuffer)-1, stdin);
      /* Remove the '\n' */
monty@mysql.com's avatar
monty@mysql.com committed
824
      if (line)
825
      {
monty@mashka.mysql.fi's avatar
monty@mashka.mysql.fi committed
826
        char *p = strrchr(line, '\n');
827 828
        if (p != NULL)
          *p = '\0';
829
      }
monty@mashka.mysql.fi's avatar
monty@mashka.mysql.fi committed
830 831 832 833 834 835 836 837 838 839
#else
      linebuffer[0]= (char) sizeof(linebuffer);
      line= _cgets(linebuffer);
#endif /* __NETWARE__ */
#else
      if (opt_outfile)
	fputs(prompt, OUTFILE);
      line= readline(prompt);
#endif /* defined( __WIN__) || defined(OS2) || defined(__NETWARE__) */

monty@mysql.com's avatar
monty@mysql.com committed
840 841 842 843 844
      /*
        When Ctrl+d or Ctrl+z is pressed, the line may be NULL on some OS
        which may cause coredump.
      */
      if (opt_outfile && line)
845
	fprintf(OUTFILE, "%s\n", line);
846
    }
bk@work.mysql.com's avatar
bk@work.mysql.com committed
847 848 849 850 851 852 853 854
    if (!line)					// End of file
    {
      status.exit_status=0;
      break;
    }
    if (!in_string && (line[0] == '#' ||
		       (line[0] == '-' && line[1] == '-') ||
		       line[0] == 0))
monty@donna.mysql.com's avatar
monty@donna.mysql.com committed
855
      continue;					// Skip comment lines
bk@work.mysql.com's avatar
bk@work.mysql.com committed
856

857 858 859 860
    /*
      Check if line is a mysql command line
      (We want to allow help, print and clear anywhere at line start
    */
861
    if (execute_commands && (named_cmds || glob_buffer.is_empty()) 
monty@donna.mysql.com's avatar
monty@donna.mysql.com committed
862
	&& !in_string && (com=find_command(line,0)))
bk@work.mysql.com's avatar
bk@work.mysql.com committed
863 864 865 866 867 868 869 870 871 872 873 874 875 876 877 878 879 880 881 882 883 884 885 886 887 888 889 890 891 892 893 894 895 896 897 898 899 900 901 902 903 904 905 906 907 908 909 910 911 912 913 914 915 916 917
    {
      if ((*com->func)(&glob_buffer,line) > 0)
	break;
      if (glob_buffer.is_empty())		// If buffer was emptied
	in_string=0;
#ifdef HAVE_READLINE
      if (status.add_to_history)
	add_history(line);
#endif
      continue;
    }
    if (add_line(glob_buffer,line,&in_string))
      break;
  }
  /* if in batch mode, send last query even if it doesn't end with \g or go */

  if ((status.batch || !execute_commands) && !status.exit_status)
  {
    remove_cntrl(glob_buffer);
    if (!glob_buffer.is_empty())
    {
      status.exit_status=1;
      if (com_go(&glob_buffer,line) <= 0)
	status.exit_status=0;
    }
  }
  return status.exit_status;
}


static COMMANDS *find_command (char *name,char cmd_char)
{
  uint len;
  char *end;

  if (!name)
  {
    len=0;
    end=0;
  }
  else
  {
    while (isspace(*name))
      name++;
    if (strchr(name,';') || strstr(name,"\\g"))
      return ((COMMANDS *) 0);
    if ((end=strcont(name," \t")))
    {
      len=(uint) (end - name);
      while (isspace(*end))
	end++;
      if (!*end)
	end=0;					// no arguments to function
    }
    else
918
      len=(uint) strlen(name);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
919 920 921 922 923 924 925 926 927 928 929 930 931 932 933 934 935 936 937 938
  }

  for (uint i= 0; commands[i].name; i++)
  {
    if (commands[i].func &&
	((name && !my_casecmp(name,commands[i].name,len) &&
	  !commands[i].name[len] &&
	  (!end || (end && commands[i].takes_params))) ||
	 !name && commands[i].cmd_char == cmd_char))
      return (&commands[i]);
  }
  return ((COMMANDS *) 0);
}


static bool add_line(String &buffer,char *line,char *in_string)
{
  uchar inchar;
  char buff[80],*pos,*out;
  COMMANDS *com;
939
  my_bool in_comment= 0;
bk@work.mysql.com's avatar
bk@work.mysql.com committed
940 941 942 943 944 945 946 947

  if (!line[0] && buffer.is_empty())
    return 0;
#ifdef HAVE_READLINE
  if (status.add_to_history && line[0])
    add_history(line);
#endif
#ifdef USE_MB
948
  char *strend=line+(uint) strlen(line);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
949 950 951 952 953 954 955 956 957 958 959 960 961 962 963 964 965 966 967 968
#endif

  for (pos=out=line ; (inchar= (uchar) *pos) ; pos++)
  {
    if (isspace(inchar) && out == line && buffer.is_empty())
      continue;
#ifdef USE_MB
    int l;
    if (use_mb(default_charset_info) &&
        (l = my_ismbchar(default_charset_info, pos, strend))) {
	while (l--)
	    *out++ = *pos++;
	pos--;
	continue;
    }
#endif
    if (inchar == '\\')
    {					// mSQL or postgreSQL style command ?
      if (!(inchar = (uchar) *++pos))
	break;				// readline adds one '\'
969
      if (*in_string || inchar == 'N')	// \N is short for NULL
bk@work.mysql.com's avatar
bk@work.mysql.com committed
970 971 972 973 974 975 976 977 978 979 980 981 982 983 984 985 986 987 988 989 990 991 992 993 994 995 996 997 998
      {					// Don't allow commands in string
	*out++='\\';
	*out++= (char) inchar;
	continue;
      }
      if ((com=find_command(NullS,(char) inchar)))
      {
	const String tmp(line,(uint) (out-line));
	buffer.append(tmp);
	if ((*com->func)(&buffer,pos-1) > 0)
	  return 1;				// Quit
	if (com->takes_params)
	{
	  for (pos++ ; *pos && *pos != ';' ; pos++) ;	// Remove parameters
	  if (!*pos)
	    pos--;
	}
	out=line;
      }
      else
      {
	sprintf(buff,"Unknown command '\\%c'.",inchar);
	if (put_info(buff,INFO_ERROR) > 0)
	  return 1;
	*out++='\\';
	*out++=(char) inchar;
	continue;
      }
    }
999
    else if (inchar == ';' && !*in_string && !in_comment)
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1000 1001 1002 1003 1004 1005 1006 1007 1008 1009 1010 1011 1012 1013 1014 1015 1016 1017 1018 1019 1020 1021 1022 1023 1024 1025 1026
    {						// ';' is end of command
      if (out != line)
	buffer.append(line,(uint) (out-line));	// Add this line
      if ((com=find_command(buffer.c_ptr(),0)))
      {
	if ((*com->func)(&buffer,buffer.c_ptr()) > 0)
	  return 1;				// Quit
      }
      else
      {
	int error=com_go(&buffer,0);
	if (error)
	{
	  return error < 0 ? 0 : 1;		// < 0 is not fatal
	}
      }
      buffer.length(0);
      out=line;
    }
    else if (!*in_string && (inchar == '#' ||
			     inchar == '-' && pos[1] == '-' &&
			     isspace(pos[2])))
      break;					// comment to end of line
    else
    {						// Add found char to buffer
      if (inchar == *in_string)
	*in_string=0;
1027
      else if (!in_comment && !*in_string && (inchar == '\'' || inchar == '"' || inchar == '`'))
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1028 1029
	*in_string=(char) inchar;
      *out++ = (char) inchar;
1030 1031 1032 1033 1034 1035 1036
      if (inchar == '*' && !*in_string)
      {
	if (pos != line && pos[-1] == '/')
	  in_comment= 1;
	else if (in_comment && pos[1] == '/')
	  in_comment= 0;
      }
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1037 1038 1039 1040 1041 1042 1043 1044 1045 1046 1047 1048 1049 1050
    }
  }
  if (out != line || !buffer.is_empty())
  {
    *out++='\n';
    uint length=(uint) (out-line);
    if (buffer.length() + length >= buffer.alloced_length())
      buffer.realloc(buffer.length()+length+IO_SIZE);
    if (buffer.append(line,length))
      return 1;
  }
  return 0;
}

1051 1052 1053
/*****************************************************************
	    Interface to Readline Completion
******************************************************************/
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1054 1055 1056 1057 1058 1059

#ifdef HAVE_READLINE

static char *new_command_generator(char *text, int);
static char **new_mysql_completion (char *text, int start, int end);

1060 1061 1062 1063 1064
/*
  Tell the GNU Readline library how to complete.  We want to try to complete
  on command names if this is the first word in the line, or on filenames
  if not.
*/
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1065 1066 1067 1068 1069 1070 1071 1072 1073 1074 1075 1076 1077 1078 1079 1080 1081 1082

char **no_completion (char *text __attribute__ ((unused)),
		      char *word __attribute__ ((unused)))
{
  return 0;					/* No filename completion */
}

static void initialize_readline (char *name)
{
  /* Allow conditional parsing of the ~/.inputrc file. */
  rl_readline_name = name;

  /* Tell the completer that we want a crack first. */
  /* rl_attempted_completion_function = (CPPFunction *)mysql_completion;*/
  rl_attempted_completion_function = (CPPFunction *) new_mysql_completion;
  rl_completion_entry_function=(Function *) no_completion;
}

1083 1084 1085 1086 1087 1088
/*
  Attempt to complete on the contents of TEXT.  START and END show the
  region of TEXT that contains the word to complete.  We can use the
  entire line in case we want to do some simple parsing.  Return the
  array of matches, or NULL if there aren't any.
*/
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1089 1090 1091 1092 1093 1094 1095 1096 1097 1098 1099 1100 1101 1102 1103 1104 1105 1106 1107

static char **new_mysql_completion (char *text,
				    int start __attribute__((unused)),
				    int end __attribute__((unused)))
{
  if (!status.batch && !quick)
    return completion_matches(text, (CPFunction*) new_command_generator);
  else
    return (char**) 0;
}

static char *new_command_generator(char *text,int state)
{
  static int textlen;
  char *ptr;
  static Bucket *b;
  static entry *e;
  static uint i;

1108
  if (!state)
1109
    textlen=(uint) strlen(text);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1110

1111 1112 1113 1114
  if (textlen>0)
  {						/* lookup in the hash */
    if (!state)
    {
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1115 1116
      uint len;

1117
      b = find_all_matches(&ht,text,(uint) strlen(text),&len);
1118
      if (!b)
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1119 1120 1121 1122
	return NullS;
      e = b->pData;
    }

1123 1124
    if (e)
    {
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1125 1126 1127 1128
      ptr= strdup(e->str);
      e = e->pNext;
      return ptr;
    }
1129 1130 1131
  }
  else
  { /* traverse the entire hash, ugly but works */
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1132

1133 1134
    if (!state)
    {
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1135
      /* find the first used bucket */
1136 1137 1138 1139
      for (i=0 ; i < ht.nTableSize ; i++)
      {
	if (ht.arBuckets[i])
	{
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1140 1141 1142 1143 1144 1145 1146
	  b = ht.arBuckets[i];
	  e = b->pData;
	  break;
	}
      }
    }
    ptr= NullS;
1147 1148 1149
    while (e && !ptr)
    {					/* find valid entry in bucket */
      if ((uint) strlen(e->str) == b->nKeyLength)
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1150 1151 1152
	ptr = strdup(e->str);
      /* find the next used entry */
      e = e->pNext;
1153 1154
      if (!e)
      { /* find the next used bucket */
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1155
	b = b->pNext;
1156 1157 1158 1159 1160 1161
	if (!b)
	{
	  for (i++ ; i<ht.nTableSize; i++)
	  {
	    if (ht.arBuckets[i])
	    {
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1162 1163 1164 1165 1166 1167
	      b = ht.arBuckets[i];
	      e = b->pData;
	      break;
	    }
	  }
	}
1168 1169
	else
	  e = b->pData;
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1170 1171
      }
    }
1172
    if (ptr)
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1173 1174 1175 1176 1177 1178 1179 1180
      return ptr;
  }
  return NullS;
}


/* Build up the completion hash */

1181
static void build_completion_hash(bool rehash, bool write_info)
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1182 1183
{
  COMMANDS *cmd=commands;
1184 1185
  MYSQL_RES *databases=0,*tables=0;
  MYSQL_RES *fields;
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1186 1187 1188 1189 1190 1191 1192
  static char ***field_names= 0;
  MYSQL_ROW database_row,table_row;
  MYSQL_FIELD *sql_field;
  char buf[NAME_LEN*2+2];		 // table name plus field name plus 2
  int i,j,num_fields;
  DBUG_ENTER("build_completion_hash");

1193
  if (status.batch || quick || !current_db)
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1194 1195 1196 1197 1198 1199 1200 1201 1202 1203 1204 1205 1206
    DBUG_VOID_RETURN;			// We don't need completion in batches

  if (tables)
  {
    mysql_free_result(tables);
    tables=0;
  }

  /* hash SQL commands */
  while (cmd->name) {
    add_word(&ht,(char*) cmd->name);
    cmd++;
  }
1207
  if (!rehash)
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1208 1209
    DBUG_VOID_RETURN;

1210 1211 1212 1213 1214 1215
  /* Free old used memory */
  if (field_names)
    field_names=0;
  completion_hash_clean(&ht);
  free_root(&hash_mem_root,MYF(0));

bk@work.mysql.com's avatar
bk@work.mysql.com committed
1216 1217 1218
  /* hash MySQL functions (to be implemented) */

  /* hash all database names */
1219 1220
  if (mysql_query(&mysql,"show databases") == 0)
  {
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1221 1222 1223 1224 1225
    if (!(databases = mysql_store_result(&mysql)))
      put_info(mysql_error(&mysql),INFO_INFO);
    else
    {
      while ((database_row=mysql_fetch_row(databases)))
1226 1227 1228 1229 1230 1231
      {
	char *str=strdup_root(&hash_mem_root, (char*) database_row[0]);
	if (str)
	  add_word(&ht,(char*) str);
      }
      mysql_free_result(databases);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1232 1233 1234 1235 1236 1237 1238 1239 1240 1241 1242
    }
  }
  /* hash all table names */
  if (mysql_query(&mysql,"show tables")==0)
  {
    if (!(tables = mysql_store_result(&mysql)))
      put_info(mysql_error(&mysql),INFO_INFO);
    else
    {
      if (mysql_num_rows(tables) > 0 && !opt_silent && write_info)
      {
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1243
	tee_fprintf(stdout, "\
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1244 1245 1246 1247 1248
Reading table information for completion of table and column names\n\
You can turn off this feature to get a quicker startup with -A\n\n");
      }
      while ((table_row=mysql_fetch_row(tables)))
      {
1249 1250 1251 1252
	char *str=strdup_root(&hash_mem_root, (char*) table_row[0]);
	if (str &&
	    !completion_hash_exists(&ht,(char*) str, (uint) strlen(str)))
	  add_word(&ht,str);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1253 1254 1255 1256 1257
      }
    }
  }

  /* hash all field names, both with the table prefix and without it */
1258 1259
  if (!tables)					/* no tables */
  {
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1260 1261 1262
    DBUG_VOID_RETURN;
  }
  mysql_data_seek(tables,0);
1263 1264 1265 1266
  if (!(field_names= (char ***) alloc_root(&hash_mem_root,sizeof(char **) *
					   (uint) (mysql_num_rows(tables)+1))))
  {
    mysql_free_result(tables);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1267
    DBUG_VOID_RETURN;
1268
  }
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1269 1270 1271 1272 1273 1274
  i=0;
  while ((table_row=mysql_fetch_row(tables)))
  {
    if ((fields=mysql_list_fields(&mysql,(const char*) table_row[0],NullS)))
    {
      num_fields=mysql_num_fields(fields);
1275 1276 1277 1278
      if (!(field_names[i] = (char **) alloc_root(&hash_mem_root,
						  sizeof(char *) *
						  (num_fields*2+1))))
	break;
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1279 1280 1281 1282 1283
      field_names[i][num_fields*2]='\0';
      j=0;
      while ((sql_field=mysql_fetch_field(fields)))
      {
	sprintf(buf,"%s.%s",table_row[0],sql_field->name);
1284
	field_names[i][j] = strdup_root(&hash_mem_root,buf);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1285
	add_word(&ht,field_names[i][j]);
1286 1287
	field_names[i][num_fields+j] = strdup_root(&hash_mem_root,
						   sql_field->name);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1288
	if (!completion_hash_exists(&ht,field_names[i][num_fields+j],
1289
				    (uint) strlen(field_names[i][num_fields+j])))
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1290 1291 1292
	  add_word(&ht,field_names[i][num_fields+j]);
	j++;
      }
1293
      mysql_free_result(fields);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1294 1295
    }
    else
1296
    {
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1297 1298
      tee_fprintf(stdout,
		  "Didn't find any fields in table '%s'\n",table_row[0]);
1299 1300
      field_names[i]=0;
    }
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1301 1302
    i++;
  }
1303
  mysql_free_result(tables);
1304
  field_names[i]=0;				// End pointer
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1305 1306 1307 1308 1309 1310 1311
  DBUG_VOID_RETURN;
}

	/* for gnu readline */

#ifndef HAVE_INDEX
extern "C" {
1312
extern char *index(const char *,int c),*rindex(const char *,int);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1313

1314
char *index(const char *s,int c)
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1315 1316 1317 1318 1319 1320 1321 1322
{
  for (;;)
  {
     if (*s == (char) c) return (char*) s;
     if (!*s++) return NullS;
  }
}

1323
char *rindex(const char *s,int c)
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1324 1325 1326 1327 1328 1329 1330 1331 1332 1333 1334
{
  reg3 char *t;

  t = NullS;
  do if (*s == (char) c) t = (char*) s; while (*s++);
  return (char*) t;
}
}
#endif
#endif /* HAVE_READLINE */

1335

bk@work.mysql.com's avatar
bk@work.mysql.com committed
1336 1337 1338 1339 1340 1341
static int reconnect(void)
{
  if (!status.batch)
  {
    put_info("No connection. Trying to reconnect...",INFO_INFO);
    (void) com_connect((String *) 0, 0);
1342 1343
    if (rehash)
      com_rehash(NULL, NULL);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1344 1345 1346 1347 1348 1349 1350 1351 1352 1353 1354 1355 1356 1357 1358 1359 1360
  }
  if (!connected)
    return put_info("Can't connect to the server\n",INFO_ERROR);
  return 0;
}


/***************************************************************************
 The different commands
***************************************************************************/

static int
com_help (String *buffer __attribute__((unused)),
	  char *line __attribute__((unused)))
{
  reg1 int i;

1361 1362 1363 1364
  put_info("\nFor the complete MySQL Manual online visit:\n   http://www.mysql.com/documentation\n", INFO_INFO);
  put_info("For info on technical support from MySQL developers visit:\n   http://www.mysql.com/support\n", INFO_INFO);
  put_info("For info on MySQL books, utilities, consultants, etc. visit:\n   http://www.mysql.com/portal\n", INFO_INFO);
  put_info("List of all MySQL commands:", INFO_INFO);
1365
  if (!named_cmds)
1366 1367
    put_info("   (Commands must appear first on line and end with ';')\n",
	     INFO_INFO);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1368 1369 1370
  for (i = 0; commands[i].name; i++)
  {
    if (commands[i].func)
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1371 1372
      tee_fprintf(stdout, "%s\t(\\%c)\t%s\n", commands[i].name,
		  commands[i].cmd_char, commands[i].doc);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1373 1374
  }
  if (connected)
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1375
    tee_fprintf(stdout,
1376
		"\nConnection id: %lu  (Can be used with mysqladmin kill)\n\n",
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1377
		mysql_thread_id(&mysql));
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1378
  else
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1379
    tee_fprintf(stdout, "Not connected!  Reconnect with 'connect'!\n\n");
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1380 1381 1382 1383 1384 1385 1386 1387 1388 1389 1390 1391 1392 1393
  return 0;
}


	/* ARGSUSED */
static int
com_clear(String *buffer,char *line __attribute__((unused)))
{
  buffer->length(0);
  return 0;
}


/*
1394 1395 1396 1397
  Execute command
  Returns: 0  if ok
          -1 if not fatal error
	  1  if fatal error
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1398 1399 1400 1401 1402 1403 1404 1405 1406 1407 1408 1409 1410 1411 1412 1413 1414
*/


static int
com_go(String *buffer,char *line __attribute__((unused)))
{
  char		buff[160],time_buff[32];
  MYSQL_RES	*result;
  ulong		timer;
  uint		error=0;

  if (!status.batch)
  {
    old_buffer= *buffer;			// Save for edit command
    old_buffer.copy();
  }

1415
  /* Remove garbage for nicer messages */
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1416 1417 1418 1419 1420 1421 1422 1423 1424 1425 1426 1427 1428 1429 1430 1431 1432 1433 1434 1435 1436 1437 1438 1439 1440 1441 1442 1443 1444 1445 1446
  LINT_INIT(buff[0]);
  remove_cntrl(*buffer);

  if (buffer->is_empty())
  {
    if (status.batch)				// Ignore empty quries
      return 0;
    return put_info("No query specified\n",INFO_ERROR);

  }
  if (!connected && reconnect())
  {
    buffer->length(0);				// Remove query on error
    return status.batch ? 1 : -1;		// Fatal error
  }
  if (verbose)
    (void) com_print(buffer,0);

  if (skip_updates &&
      (buffer->length() < 4 || my_sortcmp(buffer->ptr(),"SET ",4)))
  {
    (void) put_info("Ignoring query to other database",INFO_INFO);
    return 0;
  }

  timer=start_timer();
  for (uint retry=0;; retry++)
  {
    if (!mysql_real_query(&mysql,buffer->ptr(),buffer->length()))
      break;
    error=put_info(mysql_error(&mysql),INFO_ERROR, mysql_errno(&mysql));
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1447 1448
    if (mysql_errno(&mysql) != CR_SERVER_GONE_ERROR || retry > 1 
	|| status.batch)
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1449 1450 1451 1452 1453 1454 1455 1456 1457 1458 1459 1460 1461 1462 1463 1464 1465 1466 1467 1468 1469 1470 1471 1472 1473 1474 1475 1476 1477 1478 1479 1480 1481 1482 1483 1484 1485 1486 1487 1488 1489 1490 1491
    {
      buffer->length(0);			// Remove query on error
      return error;
    }
    if (reconnect())
    {
      buffer->length(0);			// Remove query on error
      return error;
    }
  }
  error=0;
  buffer->length(0);

  if (quick)
  {
    if (!(result=mysql_use_result(&mysql)) && mysql_field_count(&mysql))
    {
      return put_info(mysql_error(&mysql),INFO_ERROR,mysql_errno(&mysql));
    }
  }
  else
  {
    if (!(result=mysql_store_result(&mysql)))
    {
      if (mysql_error(&mysql)[0])
      {
	return put_info(mysql_error(&mysql),INFO_ERROR,mysql_errno(&mysql));
      }
    }
  }

  if (verbose >= 3 || !opt_silent)
    mysql_end_timer(timer,time_buff);
  else
    time_buff[0]=0;
  if (result)
  {
    if (!mysql_num_rows(result) && ! quick)
    {
      sprintf(buff,"Empty set%s",time_buff);
    }
    else
    {
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1492
      init_pager();
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1493 1494
      if (opt_html)
	print_table_data_html(result);
1495 1496
      else if (opt_xml)
	print_table_data_xml(result);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1497 1498 1499 1500 1501 1502 1503 1504 1505 1506
      else if (vertical)
	print_table_data_vertically(result);
      else if (opt_silent && verbose <= 2 && !output_tables)
	print_tab_data(result);
      else
	print_table_data(result);
      sprintf(buff,"%ld %s in set%s",
	      (long) mysql_num_rows(result),
	      (long) mysql_num_rows(result) == 1 ? "row" : "rows",
	      time_buff);
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1507
      end_pager();
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1508 1509 1510 1511 1512 1513 1514 1515 1516 1517 1518 1519 1520 1521 1522 1523 1524 1525 1526 1527 1528 1529
    }
  }
  else if (mysql_affected_rows(&mysql) == ~(ulonglong) 0)
    sprintf(buff,"Query OK%s",time_buff);
  else
    sprintf(buff,"Query OK, %ld %s affected%s",
	    (long) mysql_affected_rows(&mysql),
	    (long) mysql_affected_rows(&mysql) == 1 ? "row" : "rows",
	    time_buff);
  put_info(buff,INFO_RESULT);
  if (mysql_info(&mysql))
    put_info(mysql_info(&mysql),INFO_RESULT);
  put_info("",INFO_RESULT);			// Empty row

  if (result && !mysql_eof(result))	/* Something wrong when using quick */
    error=put_info(mysql_error(&mysql),INFO_ERROR,mysql_errno(&mysql));
  else if (unbuffered)
    fflush(stdout);
  mysql_free_result(result);
  return error;				/* New command follows */
}

jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1530 1531 1532

static void init_pager()
{
monty@mashka.mysql.fi's avatar
monty@mashka.mysql.fi committed
1533
#ifdef USE_POPEN
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1534 1535 1536 1537 1538 1539 1540 1541 1542 1543 1544 1545 1546 1547 1548
  if (!opt_nopager)
  {
    if (!(PAGER= popen(pager, "w")))
    {
      tee_fprintf(stdout, "popen() failed! defaulting PAGER to stdout!\n");
      PAGER= stdout;
    }
  }
  else
#endif
    PAGER= stdout;
}

static void end_pager()
{
monty@mashka.mysql.fi's avatar
monty@mashka.mysql.fi committed
1549
#ifdef USE_POPEN
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1550 1551 1552 1553 1554
  if (!opt_nopager)
    pclose(PAGER);
#endif
}

1555

monty@mashka.mysql.fi's avatar
monty@mashka.mysql.fi committed
1556
static void init_tee(const char *file_name)
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1557
{
1558
  FILE* new_outfile;
1559
  if (opt_outfile)
1560
    end_tee();
monty@mashka.mysql.fi's avatar
monty@mashka.mysql.fi committed
1561 1562 1563 1564 1565
  if (!(new_outfile= my_fopen(file_name, O_APPEND | O_WRONLY, MYF(MY_WME))))
  {
    tee_fprintf(stdout, "Error logging to file '%s'\n", file_name);
    return;
  }
1566
  OUTFILE = new_outfile;
monty@mashka.mysql.fi's avatar
monty@mashka.mysql.fi committed
1567 1568 1569 1570
  strmake(outfile, file_name, FN_REFLEN-1);
  tee_fprintf(stdout, "Logging to file '%s'\n", file_name);
  opt_outfile= 1;
  return;
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1571 1572
}

1573

jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1574 1575 1576
static void end_tee()
{
  my_fclose(OUTFILE, MYF(0));
monty@mashka.mysql.fi's avatar
monty@mashka.mysql.fi committed
1577
  OUTFILE= 0;
1578
  opt_outfile= 0;
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1579 1580 1581
  return;
}

bk@work.mysql.com's avatar
bk@work.mysql.com committed
1582 1583 1584 1585 1586 1587 1588 1589 1590 1591 1592
static int
com_ego(String *buffer,char *line)
{
  int result;
  bool oldvertical=vertical;
  vertical=1;
  result=com_go(buffer,line);
  vertical=oldvertical;
  return result;
}

1593 1594 1595 1596 1597 1598
static void
print_field_types(MYSQL_RES *result)
{
  MYSQL_FIELD	*field;  
  while ((field = mysql_fetch_field(result)))
  {
1599
    tee_fprintf(PAGER,"Name:       '%s'\nTable:      '%s'\nType:       %d\nLength:     %d\nMax length: %d\nIs_null:    %d\nFlags:      %d\nDecimals:   %d\n\n",
1600 1601 1602
		field->name,
		field->table ? "" : field->table,
		(int) field->type,
1603 1604
		field->length, field->max_length,
		!IS_NOT_NULL(field->flags),
1605 1606 1607 1608 1609
		field->flags, field->decimals);
  }
  tee_puts("", PAGER);
}

bk@work.mysql.com's avatar
bk@work.mysql.com committed
1610 1611 1612 1613 1614 1615 1616 1617 1618 1619

static void
print_table_data(MYSQL_RES *result)
{
  String separator(256);
  MYSQL_ROW	cur;
  MYSQL_FIELD	*field;
  bool		*num_flag;

  num_flag=(bool*) my_alloca(sizeof(bool)*mysql_num_fields(result));
1620 1621 1622 1623 1624
  if (info_flag)
  {
    print_field_types(result);
    mysql_field_seek(result,0);
  }
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1625 1626 1627
  separator.copy("+",1);
  while ((field = mysql_fetch_field(result)))
  {
1628
    uint length= column_names ? (uint) strlen(field->name) : 0;
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1629 1630 1631 1632 1633 1634 1635 1636 1637 1638
    if (quick)
      length=max(length,field->length);
    else
      length=max(length,field->max_length);
    if (length < 4 && !IS_NOT_NULL(field->flags))
      length=4;					// Room for "NULL"
    field->max_length=length+1;
    separator.fill(separator.length()+length+2,'-');
    separator.append('+');
  }
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1639
  tee_puts(separator.c_ptr(), PAGER);
1640
  if (column_names)
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1641 1642
  {
    mysql_field_seek(result,0);
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1643
    (void) tee_fputs("|", PAGER);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1644 1645
    for (uint off=0; (field = mysql_fetch_field(result)) ; off++)
    {
monty@donna.mysql.com's avatar
monty@donna.mysql.com committed
1646 1647
      tee_fprintf(PAGER, " %-*s|",min(field->max_length,MAX_COLUMN_LENGTH),
		  field->name);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1648 1649
      num_flag[off]= IS_NUM(field->type);
    }
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1650 1651
    (void) tee_fputs("\n", PAGER);
    tee_puts(separator.c_ptr(), PAGER);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1652 1653
  }

1654
  while ((cur= mysql_fetch_row(result)))
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1655
  {
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1656
    (void) tee_fputs("|", PAGER);
1657 1658
    mysql_field_seek(result, 0);
    for (uint off= 0; off < mysql_num_fields(result); off++)
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1659
    {
1660 1661 1662
      const char *str= cur[off] ? cur[off] : "NULL";
      field= mysql_fetch_field(result);
      uint length= field->max_length;
monty@donna.mysql.com's avatar
monty@donna.mysql.com committed
1663 1664
      if (length > MAX_COLUMN_LENGTH)
      {
1665 1666
	tee_fputs(str, PAGER);
	tee_fputs(" |", PAGER);
monty@donna.mysql.com's avatar
monty@donna.mysql.com committed
1667 1668
      }
      else
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1669
      tee_fprintf(PAGER, num_flag[off] ? "%*s |" : " %-*s|",
monty@donna.mysql.com's avatar
monty@donna.mysql.com committed
1670
		  length, str);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1671
    }
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1672
    (void) tee_fputs("\n", PAGER);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1673
  }
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1674
  tee_puts(separator.c_ptr(), PAGER);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1675 1676 1677
  my_afree((gptr) num_flag);
}

monty@mashka.mysql.fi's avatar
monty@mashka.mysql.fi committed
1678

bk@work.mysql.com's avatar
bk@work.mysql.com committed
1679 1680 1681
static void
print_table_data_html(MYSQL_RES *result)
{
monty@mashka.mysql.fi's avatar
monty@mashka.mysql.fi committed
1682 1683
  MYSQL_ROW	cur;
  MYSQL_FIELD	*field;
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1684 1685

  mysql_field_seek(result,0);
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1686
  (void) tee_fputs("<TABLE BORDER=1><TR>", PAGER);
1687
  if (column_names)
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1688 1689 1690
  {
    while((field = mysql_fetch_field(result)))
    {
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1691 1692 1693
      tee_fprintf(PAGER, "<TH>%s</TH>", (field->name ? 
					 (field->name[0] ? field->name : 
					  " &nbsp; ") : "NULL"));
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1694
    }
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1695
    (void) tee_fputs("</TR>", PAGER);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1696 1697 1698
  }
  while ((cur = mysql_fetch_row(result)))
  {
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1699
    (void) tee_fputs("<TR>", PAGER);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1700 1701 1702
    for (uint i=0; i < mysql_num_fields(result); i++)
    {
      ulong *lengths=mysql_fetch_lengths(result);
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1703
      (void) tee_fputs("<TD>", PAGER);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1704
      safe_put_field(cur[i],lengths[i]);
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1705
      (void) tee_fputs("</TD>", PAGER);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1706
    }
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1707
    (void) tee_fputs("</TR>", PAGER);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1708
  }
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1709
  (void) tee_fputs("</TABLE>", PAGER);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1710 1711 1712
}


1713 1714 1715 1716 1717 1718 1719 1720
static void
print_table_data_xml(MYSQL_RES *result)
{
  MYSQL_ROW   cur;
  MYSQL_FIELD *fields;

  mysql_field_seek(result,0);

1721
  tee_fputs("<?xml version=\"1.0\"?>\n\n<resultset statement=\"", PAGER);
jani@hynda.mysql.fi's avatar
merge  
jani@hynda.mysql.fi committed
1722
  xmlencode_print(glob_buffer.ptr(), strlen(glob_buffer.ptr()));
1723
  tee_fputs("\">", PAGER);
1724 1725 1726 1727 1728 1729 1730 1731 1732 1733 1734

  fields = mysql_fetch_fields(result);
  while ((cur = mysql_fetch_row(result)))
  {
    (void) tee_fputs("\n  <row>\n", PAGER);
    for (uint i=0; i < mysql_num_fields(result); i++)
    {
      ulong *lengths=mysql_fetch_lengths(result);
      tee_fprintf(PAGER, "\t<%s>", (fields[i].name ?
				  (fields[i].name[0] ? fields[i].name :
				   " &nbsp; ") : "NULL"));
1735
      xmlencode_print(cur[i], lengths[i]);
1736 1737 1738 1739 1740 1741 1742 1743 1744
      tee_fprintf(PAGER, "</%s>\n", (fields[i].name ?
				     (fields[i].name[0] ? fields[i].name :
				      " &nbsp; ") : "NULL"));
    }
    (void) tee_fputs("  </row>\n", PAGER);
  }
  (void) tee_fputs("</resultset>\n", PAGER);
}

bk@work.mysql.com's avatar
bk@work.mysql.com committed
1745 1746 1747 1748 1749 1750 1751 1752 1753 1754

static void
print_table_data_vertically(MYSQL_RES *result)
{
  MYSQL_ROW	cur;
  uint		max_length=0;
  MYSQL_FIELD	*field;

  while ((field = mysql_fetch_field(result)))
  {
1755
    uint length=(uint) strlen(field->name);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1756 1757 1758 1759 1760 1761 1762 1763 1764
    if (length > max_length)
      max_length= length;
    field->max_length=length;
  }

  mysql_field_seek(result,0);
  for (uint row_count=1; (cur= mysql_fetch_row(result)); row_count++)
  {
    mysql_field_seek(result,0);
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1765 1766
    tee_fprintf(PAGER, 
		"*************************** %d. row ***************************\n", row_count);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1767 1768 1769
    for (uint off=0; off < mysql_num_fields(result); off++)
    {
      field= mysql_fetch_field(result);
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1770 1771
      tee_fprintf(PAGER, "%*s: ",(int) max_length,field->name);
      tee_fprintf(PAGER, "%s\n",cur[off] ? (char*) cur[off] : "NULL");
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1772 1773 1774 1775
    }
  }
}

1776

1777
static const char
1778 1779
*array_value(const char **array, char key)
{
1780
  int x;
1781 1782 1783
  for (x= 0; array[x]; x+= 2)
    if (*array[x] == key)
      return array[x + 1];
1784 1785 1786
  return 0;
}

1787

1788
static void
1789
xmlencode_print(const char *src, uint length)
1790
{
1791 1792 1793
  if (!src)
    tee_fputs("NULL", PAGER);
  else
1794
  {
1795 1796 1797 1798 1799 1800 1801 1802 1803
    for (const char *p = src; *p && length; *p++, length--)
    {
      const char *t;
      if ((t = array_value(xmlmeta, *p)))
	tee_fputs(t, PAGER);
      else
	tee_putc(*p, PAGER);
    }
  }
1804
}
monty@hundin.mysql.fi's avatar
monty@hundin.mysql.fi committed
1805

bk@work.mysql.com's avatar
bk@work.mysql.com committed
1806 1807 1808 1809 1810

static void
safe_put_field(const char *pos,ulong length)
{
  if (!pos)
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1811
    tee_fputs("NULL", PAGER);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1812 1813 1814
  else
  {
    if (opt_raw_data)
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1815
      tee_fputs(pos, PAGER);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1816 1817 1818 1819 1820 1821 1822
    else for (const char *end=pos+length ; pos != end ; pos++)
    {
#ifdef USE_MB
      int l;
      if (use_mb(default_charset_info) &&
          (l = my_ismbchar(default_charset_info, pos, end))) {
	  while (l--)
1823
	    tee_putc(*pos++, PAGER);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1824 1825 1826 1827 1828
	  pos--;
	  continue;
      }
#endif
      if (!*pos)
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1829
	tee_fputs("\\0", PAGER); // This makes everything hard
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1830
      else if (*pos == '\t')
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1831
	tee_fputs("\\t", PAGER); // This would destroy tab format
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1832
      else if (*pos == '\n')
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1833
	tee_fputs("\\n", PAGER); // This too
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1834
      else if (*pos == '\\')
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1835
	tee_fputs("\\\\", PAGER);
1836
	else
1837
	tee_putc(*pos, PAGER);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1838 1839 1840 1841 1842 1843 1844 1845 1846 1847 1848 1849
    }
  }
}


static void
print_tab_data(MYSQL_RES *result)
{
  MYSQL_ROW	cur;
  MYSQL_FIELD	*field;
  ulong		*lengths;

1850
  if (opt_silent < 2 && column_names)
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1851 1852 1853 1854 1855
  {
    int first=0;
    while ((field = mysql_fetch_field(result)))
    {
      if (first++)
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1856 1857
	(void) tee_fputs("\t", PAGER);
      (void) tee_fputs(field->name, PAGER);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1858
    }
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1859
    (void) tee_fputs("\n", PAGER);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1860 1861 1862 1863 1864 1865 1866
  }
  while ((cur = mysql_fetch_row(result)))
  {
    lengths=mysql_fetch_lengths(result);
    safe_put_field(cur[0],lengths[0]);
    for (uint off=1 ; off < mysql_num_fields(result); off++)
    {
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1867
      (void) tee_fputs("\t", PAGER);
1868
      safe_put_field(cur[off], lengths[off]);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1869
    }
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1870
    (void) tee_fputs("\n", PAGER);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1871 1872 1873
  }
}

jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1874 1875 1876 1877 1878 1879 1880 1881 1882 1883 1884 1885 1886
static int
com_tee(String *buffer, char *line __attribute__((unused)))
{
  char file_name[FN_REFLEN], *end, *param;

  if (status.batch)
    return 0;
  while (isspace(*line))
    line++;
  if (!(param = strchr(line, ' '))) // if outfile wasn't given, use the default
  {
    if (!strlen(outfile))
    {
1887
      printf("No previous outfile available, you must give a filename!\n");
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1888 1889
      return 0;
    }
1890 1891 1892 1893 1894 1895 1896
    else if (opt_outfile)
    {
      tee_fprintf(stdout, "Currently logging to file '%s'\n", outfile);
      return 0;
    }
    else
      param = outfile;			//resume using the old outfile
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1897
  }
1898 1899 1900 1901 1902 1903 1904 1905 1906

  /* eliminate the spaces before the parameters */
  while (isspace(*param))
    param++;
  end= strmake(file_name, param, sizeof(file_name) - 1);
  /* remove end space from command line */
  while (end > file_name && (isspace(end[-1]) || iscntrl(end[-1])))
    end--;
  end[0]= 0;
1907
  if (end == file_name)
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1908 1909 1910 1911
  {
    printf("No outfile specified!\n");
    return 0;
  }
monty@mashka.mysql.fi's avatar
monty@mashka.mysql.fi committed
1912
  init_tee(file_name);
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1913 1914 1915
  return 0;
}

1916

jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1917 1918 1919 1920 1921 1922 1923 1924 1925 1926
static int
com_notee(String *buffer __attribute__((unused)),
	  char *line __attribute__((unused)))
{
  if (opt_outfile)
    end_tee();
  tee_fprintf(stdout, "Outfile disabled.\n");
  return 0;
}

1927
/*
1928
  Sorry, this command is not available in Windows.
1929 1930
*/

monty@mashka.mysql.fi's avatar
monty@mashka.mysql.fi committed
1931
#ifdef USE_POPEN
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1932 1933 1934 1935 1936 1937 1938 1939 1940 1941
static int
com_pager(String *buffer, char *line __attribute__((unused)))
{
  char pager_name[FN_REFLEN], *end, *param;

  if (status.batch)
    return 0;
  /* Skip space from file name */
  while (isspace(*line))
    line++;
monty@mashka.mysql.fi's avatar
monty@mashka.mysql.fi committed
1942
  if (!(param= strchr(line, ' '))) // if pager was not given, use the default
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1943
  {
monty@mashka.mysql.fi's avatar
monty@mashka.mysql.fi committed
1944
    if (!default_pager[0])
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1945
    {
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1946
      tee_fprintf(stdout, "Default pager wasn't set, using stdout.\n");
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1947 1948 1949 1950 1951 1952 1953 1954 1955 1956 1957 1958 1959 1960 1961 1962
      opt_nopager=1;
      strmov(pager, "stdout");
      PAGER= stdout;
      return 0;
    }
    strmov(pager, default_pager);
  }
  else
  {
    while (isspace(*param))
      param++;
    end=strmake(pager_name, param, sizeof(pager_name)-1);
    while (end > pager_name && (isspace(end[-1]) || iscntrl(end[-1])))
      end--;
    end[0]=0;
    strmov(pager, pager_name);
1963
    strmov(default_pager, pager_name);
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1964 1965 1966 1967 1968 1969
  }
  opt_nopager=0;
  tee_fprintf(stdout, "PAGER set to %s\n", pager);
  return 0;
}

1970

jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1971 1972 1973 1974 1975 1976 1977 1978 1979
static int
com_nopager(String *buffer __attribute__((unused)),
	    char *line __attribute__((unused)))
{
  strmov(pager, "stdout");
  opt_nopager=1;
  tee_fprintf(stdout, "PAGER set to stdout\n");
  return 0;
}
1980
#endif
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
1981

bk@work.mysql.com's avatar
bk@work.mysql.com committed
1982

1983
/*
1984
  Sorry, you can't send the result to an editor in Win32
1985 1986
*/

monty@mashka.mysql.fi's avatar
monty@mashka.mysql.fi committed
1987
#ifdef USE_POPEN
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1988 1989 1990
static int
com_edit(String *buffer,char *line __attribute__((unused)))
{
1991
  char	filename[FN_REFLEN],buff[160];
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1992 1993 1994
  int	fd,tmp;
  const char *editor;

1995 1996
  if ((fd=create_temp_file(filename,NullS,"sql", O_CREAT | O_WRONLY,
			   MYF(MY_WME))) < 0)
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1997 1998 1999 2000 2001 2002 2003 2004 2005 2006 2007 2008 2009 2010 2011 2012 2013 2014 2015 2016 2017 2018 2019 2020 2021 2022 2023 2024 2025
    goto err;
  if (buffer->is_empty() && !old_buffer.is_empty())
    (void) my_write(fd,(byte*) old_buffer.ptr(),old_buffer.length(),
		    MYF(MY_WME));
  else
    (void) my_write(fd,(byte*) buffer->ptr(),buffer->length(),MYF(MY_WME));
  (void) my_close(fd,MYF(0));

  if (!(editor = (char *)getenv("EDITOR")) &&
      !(editor = (char *)getenv("VISUAL")))
    editor = "vi";
  strxmov(buff,editor," ",filename,NullS);
  (void) system(buff);

  MY_STAT stat_arg;
  if (!my_stat(filename,&stat_arg,MYF(MY_WME)))
    goto err;
  if ((fd = my_open(filename,O_RDONLY, MYF(MY_WME))) < 0)
    goto err;
  (void) buffer->alloc((uint) stat_arg.st_size);
  if ((tmp=read(fd,(char*) buffer->ptr(),buffer->alloced_length())) >= 0L)
    buffer->length((uint) tmp);
  else
    buffer->length(0);
  (void) my_close(fd,MYF(0));
  (void) my_delete(filename,MYF(MY_WME));
err:
  return 0;
}
2026 2027
#endif

bk@work.mysql.com's avatar
bk@work.mysql.com committed
2028 2029 2030 2031 2032 2033 2034

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

static int
com_quit(String *buffer __attribute__((unused)),
	 char *line __attribute__((unused)))
{
monty@mysql.com's avatar
monty@mysql.com committed
2035 2036
  /* let the screen auto close on a normal shutdown */
  NETWARE_SET_SCREEN_MODE(SCR_AUTOCLOSE_ON_EXIT);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2037 2038 2039 2040 2041 2042 2043 2044 2045
  status.exit_status=0;
  return 1;
}

static int
com_rehash(String *buffer __attribute__((unused)),
	 char *line __attribute__((unused)))
{
#ifdef HAVE_READLINE
2046
  build_completion_hash(1, 0);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2047 2048 2049 2050
#endif
  return 0;
}

2051

monty@mashka.mysql.fi's avatar
monty@mashka.mysql.fi committed
2052
#ifdef USE_POPEN
2053 2054 2055 2056
static int
com_shell(String *buffer, char *line __attribute__((unused)))
{
  char *shell_cmd;
2057 2058 2059 2060

  /* Skip space from line begin */
  while (isspace(*line))
    line++;
2061 2062 2063 2064 2065
  if (!(shell_cmd = strchr(line, ' ')))
  {
    put_info("Usage: \\! shell-command", INFO_ERROR);
    return -1;
  }
2066 2067 2068 2069 2070
  /*
    The output of the shell command does not
    get directed to the pager or the outfile
  */
  if (system(shell_cmd) == -1)
2071 2072 2073 2074 2075 2076 2077 2078 2079
  {
    put_info(strerror(errno), INFO_ERROR, errno);
    return -1;
  }
  return 0;
}
#endif


bk@work.mysql.com's avatar
bk@work.mysql.com committed
2080 2081 2082
static int
com_print(String *buffer,char *line __attribute__((unused)))
{
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
2083 2084
  tee_puts("--------------", stdout);
  (void) tee_fputs(buffer->c_ptr(), stdout);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2085
  if (!buffer->length() || (*buffer)[buffer->length()-1] != '\n')
2086
    tee_putc('\n', stdout);
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
2087
  tee_puts("--------------\n", stdout);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2088 2089 2090 2091 2092 2093 2094 2095
  return 0;					/* If empty buffer */
}

	/* ARGSUSED */
static int
com_connect(String *buffer, char *line)
{
  char *tmp,buff[256];
2096
  bool save_rehash= rehash;
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2097 2098 2099 2100 2101 2102 2103 2104 2105
  int error;

  if (buffer)
  {
    while (isspace(*line))
      line++;
    strnmov(buff,line,sizeof(buff)-1);		// Don't destroy history
    if (buff[0] == '\\')			// Short command
      buff[1]=' ';
2106
    tmp=(char *) strtok(buff," \t");		// Skip connect command
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2107 2108 2109 2110 2111 2112 2113 2114 2115 2116 2117
    if (tmp && (tmp=(char *) strtok(NullS," \t;")))
    {
      my_free(current_db,MYF(MY_ALLOW_ZERO_PTR));
      current_db=my_strdup(tmp,MYF(MY_WME));
      if ((tmp=(char *) strtok(NullS," \t;")))
      {
	my_free(current_host,MYF(MY_ALLOW_ZERO_PTR));
	current_host=my_strdup(tmp,MYF(MY_WME));
      }
    }
    else
2118
      rehash= 0;				// Quick re-connect
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2119 2120 2121
    buffer->length(0);				// command used
  }
  else
2122
    rehash= 0;
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2123
  error=sql_connect(current_host,current_db,current_user,opt_password,0);
2124
  rehash= save_rehash;
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2125 2126 2127

  if (connected)
  {
2128
    sprintf(buff,"Connection id:    %lu",mysql_thread_id(&mysql));
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2129 2130
    put_info(buff,INFO_INFO);
    sprintf(buff,"Current database: %s\n",
2131
	    current_db ? current_db : "*** NONE ***");
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2132 2133 2134 2135 2136 2137 2138 2139 2140 2141 2142 2143 2144 2145 2146 2147 2148
    put_info(buff,INFO_INFO);
  }
  return error;
}


static int com_source(String *buffer, char *line)
{
  char source_name[FN_REFLEN], *end, *param;
  LINE_BUFFER *line_buff;
  int error;
  STATUS old_status;
  FILE *sql_file;

  /* Skip space from file name */
  while (isspace(*line))
    line++;
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
2149 2150 2151
  if (!(param = strchr(line, ' ')))		// Skip command name
    return put_info("Usage: \\. <filename> | source <filename>", 
		    INFO_ERROR, 0);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2152 2153 2154 2155 2156 2157
  while (isspace(*param))
    param++;
  end=strmake(source_name,param,sizeof(source_name)-1);
  while (end > source_name && (isspace(end[-1]) || iscntrl(end[-1])))
    end--;
  end[0]=0;
monty@donna.mysql.com's avatar
monty@donna.mysql.com committed
2158
  unpack_filename(source_name,source_name);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2159
  /* open file name */
monty@donna.mysql.com's avatar
monty@donna.mysql.com committed
2160
  if (!(sql_file = my_fopen(source_name, O_RDONLY | O_BINARY,MYF(0))))
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2161 2162 2163 2164 2165 2166 2167 2168 2169 2170 2171 2172 2173 2174 2175 2176 2177 2178 2179 2180 2181 2182 2183 2184 2185 2186 2187 2188 2189 2190 2191 2192 2193 2194 2195 2196 2197 2198 2199 2200
  {
    char buff[FN_REFLEN+60];
    sprintf(buff,"Failed to open file '%s', error: %d", source_name,errno);
    return put_info(buff, INFO_ERROR, 0);
  }

  if (!(line_buff=batch_readline_init(max_allowed_packet+512,sql_file)))
  {
    my_fclose(sql_file,MYF(0));
    return put_info("Can't initialize batch_readline", INFO_ERROR, 0);
  }

  /* Save old status */
  old_status=status;
  bfill((char*) &status,sizeof(status),(char) 0);

  status.batch=old_status.batch;		// Run in batch mode
  status.line_buff=line_buff;
  status.file_name=source_name;
  glob_buffer.length(0);			// Empty command buffer
  error=read_lines(0);				// Read lines from file
  status=old_status;				// Continue as before
  my_fclose(sql_file,MYF(0));
  batch_readline_end(line_buff);
  return error;
}


	/* ARGSUSED */
static int
com_use(String *buffer __attribute__((unused)), char *line)
{
  char *tmp;
  char buff[256];

  while (isspace(*line))
    line++;
  strnmov(buff,line,sizeof(buff)-1);		// Don't destroy history
  if (buff[0] == '\\')				// Short command
    buff[1]=' ';
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
2201
  tmp=(char *) strtok(buff," \t;");		// Skip connect command
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2202 2203 2204 2205 2206 2207 2208 2209
  if (!tmp || !(tmp=(char *) strtok(NullS," \t;")))
  {
    put_info("USE must be followed by a database name",INFO_ERROR);
    return 0;
  }
  if (!current_db || cmp_database(current_db,tmp))
  {
    if (one_database)
2210
      skip_updates= 1;
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2211 2212 2213 2214 2215 2216 2217 2218 2219 2220 2221 2222 2223 2224 2225 2226 2227 2228
    else
    {
      /*
	reconnect once if connection is down or if connection was found to
	be down during query
      */
      if (!connected && reconnect())
	return status.batch ? 1 : -1;			// Fatal error
      if (mysql_select_db(&mysql,tmp))
      {
	if (mysql_errno(&mysql) != CR_SERVER_GONE_ERROR)
	  return put_info(mysql_error(&mysql),INFO_ERROR,mysql_errno(&mysql));

	if (reconnect())
	  return status.batch ? 1 : -1;			// Fatal error
	if (mysql_select_db(&mysql,tmp))
	  return put_info(mysql_error(&mysql),INFO_ERROR,mysql_errno(&mysql));
      }
2229 2230
      my_free(current_db,MYF(MY_ALLOW_ZERO_PTR));
      current_db=my_strdup(tmp,MYF(MY_WME));
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2231
#ifdef HAVE_READLINE
2232
      build_completion_hash(rehash, 1);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2233 2234 2235 2236
#endif
    }
  }
  else
2237
    skip_updates= 0;
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2238 2239 2240 2241 2242 2243 2244 2245 2246
  put_info("Database changed",INFO_INFO);
  return 0;
}


static int
sql_real_connect(char *host,char *database,char *user,char *password,
		 uint silent)
{
monty@mysql.com's avatar
monty@mysql.com committed
2247 2248 2249 2250 2251
  if (connected)
  {
    connected= 0;
    mysql_close(&mysql);
  }
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2252
  mysql_init(&mysql);
monty@donna.mysql.com's avatar
monty@donna.mysql.com committed
2253
  if (opt_connect_timeout)
2254 2255
  {
    uint timeout=opt_connect_timeout;
monty@donna.mysql.com's avatar
monty@donna.mysql.com committed
2256
    mysql_options(&mysql,MYSQL_OPT_CONNECT_TIMEOUT,
2257 2258
		  (char*) &timeout);
  }
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2259 2260
  if (opt_compress)
    mysql_options(&mysql,MYSQL_OPT_COMPRESS,NullS);
jani@hynda.mysql.fi's avatar
merge  
jani@hynda.mysql.fi committed
2261 2262
  if (using_opt_local_infile)
    mysql_options(&mysql,MYSQL_OPT_LOCAL_INFILE, (char*) &opt_local_infile);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2263 2264 2265
#ifdef HAVE_OPENSSL
  if (opt_use_ssl)
    mysql_ssl_set(&mysql, opt_ssl_key, opt_ssl_cert, opt_ssl_ca,
2266
		  opt_ssl_capath, opt_ssl_cipher);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2267 2268 2269 2270 2271 2272 2273 2274 2275
#endif
  if (safe_updates)
  {
    char init_command[100];
    sprintf(init_command,
	    "SET SQL_SAFE_UPDATES=1,SQL_SELECT_LIMIT=%lu,SQL_MAX_JOIN_SIZE=%lu",
	    select_limit,max_join_size);
    mysql_options(&mysql, MYSQL_INIT_COMMAND, init_command);
  }
2276 2277
  if (!mysql_real_connect(&mysql, host, user, password,
			  database, opt_mysql_port, opt_mysql_unix_port,
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2278 2279 2280 2281 2282 2283 2284 2285 2286 2287 2288 2289 2290 2291 2292
			  connect_flag))
  {
    if (!silent ||
	(mysql_errno(&mysql) != CR_CONN_HOST_ERROR &&
	 mysql_errno(&mysql) != CR_CONNECTION_ERROR))
    {
      put_info(mysql_error(&mysql),INFO_ERROR,mysql_errno(&mysql));
      (void) fflush(stdout);
      return ignore_errors ? -1 : 1;		// Abort
    }
    return -1;					// Retryable
  }
  connected=1;
  mysql.reconnect=info_flag ? 1 : 0; // We want to know if this happens
#ifdef HAVE_READLINE
2293
  build_completion_hash(rehash, 1);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2294 2295 2296 2297 2298 2299 2300 2301 2302 2303 2304 2305 2306 2307 2308 2309 2310
#endif
  return 0;
}


static int
sql_connect(char *host,char *database,char *user,char *password,uint silent)
{
  bool message=0;
  uint count=0;
  int error;
  for (;;)
  {
    if ((error=sql_real_connect(host,database,user,password,wait_flag)) >= 0)
    {
      if (count)
      {
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
2311
	tee_fputs("\n", stderr);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2312 2313 2314 2315 2316 2317 2318 2319 2320
	(void) fflush(stderr);
      }
      return error;
    }
    if (!wait_flag)
      return ignore_errors ? -1 : 1;
    if (!message && !silent)
    {
      message=1;
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
2321
      tee_fputs("Waiting",stderr); (void) fflush(stderr);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2322
    }
2323
    (void) sleep(wait_time);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2324 2325 2326 2327 2328 2329 2330 2331 2332 2333 2334 2335 2336 2337
    if (!silent)
    {
      putc('.',stderr); (void) fflush(stderr);
      count++;
    }
  }
}



static int
com_status(String *buffer __attribute__((unused)),
	   char *line __attribute__((unused)))
{
jani@hynda.mysql.fi's avatar
merge  
jani@hynda.mysql.fi committed
2338
  const char *status;
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
2339
  tee_puts("--------------", stdout);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2340 2341 2342 2343 2344
  usage(1);					/* Print version */
  if (connected)
  {
    MYSQL_RES *result;
    LINT_INIT(result);
2345
    tee_fprintf(stdout, "\nConnection id:\t\t%lu\n",mysql_thread_id(&mysql));
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2346 2347 2348 2349
    if (!mysql_query(&mysql,"select DATABASE(),USER()") &&
	(result=mysql_use_result(&mysql)))
    {
      MYSQL_ROW cur=mysql_fetch_row(result);
2350
      tee_fprintf(stdout, "Current database:\t%s\n", cur[0] ? cur[0] : "");
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
2351
      tee_fprintf(stdout, "Current user:\t\t%s\n",cur[1]);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2352 2353
      (void) mysql_fetch_row(result);		// Read eof
    }
2354
#ifdef HAVE_OPENSSL
2355 2356
    if (mysql.net.vio && mysql.net.vio->ssl_arg &&
	SSL_get_cipher((SSL*) mysql.net.vio->ssl_arg))
2357
      tee_fprintf(stdout, "SSL:\t\t\tCipher in use is %s\n",
2358
		  SSL_get_cipher((SSL*) mysql.net.vio->ssl_arg));
2359 2360
    else
#endif /* HAVE_OPENSSL */
2361
      tee_puts("SSL:\t\t\tNot in use", stdout);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2362 2363 2364 2365
  }
  else
  {
    vidattr(A_BOLD);
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
2366
    tee_fprintf(stdout, "\nNo connection\n");
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2367 2368 2369 2370 2371 2372
    vidattr(A_NORMAL);
    return 0;
  }
  if (skip_updates)
  {
    vidattr(A_BOLD);
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
2373
    tee_fprintf(stdout, "\nAll updates ignored to this database\n");
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2374 2375
    vidattr(A_NORMAL);
  }
monty@mashka.mysql.fi's avatar
monty@mashka.mysql.fi committed
2376
#ifdef USE_POPEN
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
2377
  tee_fprintf(stdout, "Current pager:\t\t%s\n", pager);
2378
  tee_fprintf(stdout, "Using outfile:\t\t'%s'\n", opt_outfile ? outfile : "");
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
2379 2380 2381 2382
#endif
  tee_fprintf(stdout, "Server version:\t\t%s\n", mysql_get_server_info(&mysql));
  tee_fprintf(stdout, "Protocol version:\t%d\n", mysql_get_proto_info(&mysql));
  tee_fprintf(stdout, "Connection:\t\t%s\n", mysql_get_host_info(&mysql));
2383 2384 2385
  tee_fprintf(stdout, "Client characterset:\t%s\n",
	      default_charset_info->name);
  tee_fprintf(stdout, "Server characterset:\t%s\n", mysql.charset->name);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2386
  if (strstr(mysql_get_host_info(&mysql),"TCP/IP") || ! mysql.unix_socket)
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
2387
    tee_fprintf(stdout, "TCP port:\t\t%d\n", mysql.port);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2388
  else
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
2389
    tee_fprintf(stdout, "UNIX socket:\t\t%s\n", mysql.unix_socket);
2390 2391 2392
  if (mysql.net.compress)
    tee_fprintf(stdout, "Protocol:\t\tCompressed\n");

bk@work.mysql.com's avatar
bk@work.mysql.com committed
2393 2394 2395
  if ((status=mysql_stat(&mysql)) && !mysql_error(&mysql)[0])
  {
    ulong sec;
2396 2397 2398 2399
    char buff[40];
    const char *pos= strchr(status,' ');
    /* print label */
    tee_fprintf(stdout, "%.*s\t\t\t", (int) (pos-status), status);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2400 2401 2402
    if ((status=str2int(pos,10,0,LONG_MAX,(long*) &sec)))
    {
      nice_time((double) sec,buff,0);
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
2403
      tee_puts(buff, stdout);			/* print nice time */
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2404 2405 2406 2407
      while (*status == ' ') status++;		/* to next info */
    }
    if (status)
    {
2408
      tee_putc('\n', stdout);
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
2409
      tee_puts(status, stdout);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2410 2411 2412 2413 2414
    }
  }
  if (safe_updates)
  {
    vidattr(A_BOLD);
jcole@tetra.spaceapes.com's avatar
jcole@tetra.spaceapes.com committed
2415
    tee_fprintf(stdout, "\nNote that you are running in safe_update_mode:\n");
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2416
    vidattr(A_NORMAL);
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
2417
    tee_fprintf(stdout, "\
jcole@tetra.spaceapes.com's avatar
jcole@tetra.spaceapes.com committed
2418 2419 2420
UPDATEs and DELETEs that don't use a key in the WHERE clause are not allowed.\n\
(One can force an UPDATE/DELETE by adding LIMIT # at the end of the command.)\n\
SELECT has an automatic 'LIMIT %lu' if LIMIT is not used.\n\
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2421
Max number of examined row combination in a join is set to: %lu\n\n",
jcole@tetra.spaceapes.com's avatar
jcole@tetra.spaceapes.com committed
2422
select_limit, max_join_size);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2423
  }
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
2424
  tee_puts("--------------\n", stdout);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2425 2426 2427 2428 2429 2430 2431
  return 0;
}


static int
put_info(const char *str,INFO_TYPE info_type,uint error)
{
2432
  FILE *file= (info_type == INFO_ERROR ? stderr : stdout);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2433
  static int inited=0;
monty@hundin.mysql.fi's avatar
monty@hundin.mysql.fi committed
2434

bk@work.mysql.com's avatar
bk@work.mysql.com committed
2435 2436 2437 2438
  if (status.batch)
  {
    if (info_type == INFO_ERROR)
    {
2439 2440
      (void) fflush(file);
      fprintf(file,"ERROR");
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2441
      if (error)
2442
	(void) fprintf(file," %d",error);
2443
      if (status.query_start_line && line_numbers)
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2444
      {
2445
	(void) fprintf(file," at line %lu",status.query_start_line);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2446
	if (status.file_name)
2447
	  (void) fprintf(file," in file: '%s'", status.file_name);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2448
      }
2449 2450
      (void) fprintf(file,": %s\n",str);
      (void) fflush(file);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2451 2452 2453 2454
      if (!ignore_errors)
	return 1;
    }
    else if (info_type == INFO_RESULT && verbose > 1)
2455
      tee_puts(str, file);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2456
    if (unbuffered)
2457
      fflush(file);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2458 2459 2460 2461 2462 2463 2464 2465 2466 2467 2468 2469 2470
    return info_type == INFO_ERROR ? -1 : 0;
  }
  if (!opt_silent || info_type == INFO_ERROR)
  {
    if (!inited)
    {
      inited=1;
#ifdef HAVE_SETUPTERM
      (void) setupterm((char *)0, 1, (int *) 0);
#endif
    }
    if (info_type == INFO_ERROR)
    {
2471
      if (!opt_nobeep)
jani@hynda.mysql.fi's avatar
merge  
jani@hynda.mysql.fi committed
2472
	putchar('\007');		      	/* This should make a bell */
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2473 2474
      vidattr(A_STANDOUT);
      if (error)
2475
        (void) tee_fprintf(file, "ERROR %d: ", error);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2476
      else
2477
        tee_puts("ERROR: ", file);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2478 2479 2480
    }
    else
      vidattr(A_BOLD);
2481
    (void) tee_puts(str, file);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2482 2483 2484
    vidattr(A_NORMAL);
  }
  if (unbuffered)
2485
    fflush(file);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2486 2487 2488
  return info_type == INFO_ERROR ? -1 : 0;
}

jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
2489

bk@work.mysql.com's avatar
bk@work.mysql.com committed
2490 2491 2492 2493 2494 2495 2496 2497 2498 2499
static void remove_cntrl(String &buffer)
{
  char *start,*end;
  end=(start=(char*) buffer.ptr())+buffer.length();
  while (start < end && !isgraph(end[-1]))
    end--;
  buffer.length((uint) (end-start));
}


jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
2500 2501 2502 2503
void tee_fprintf(FILE *file, const char *fmt, ...)
{
  va_list args;

monty@mysql.com's avatar
monty@mysql.com committed
2504
  NETWARE_YIELD;
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
2505
  va_start(args, fmt);
monty@donna.mysql.com's avatar
monty@donna.mysql.com committed
2506
  (void) vfprintf(file, fmt, args);
monty@hundin.mysql.fi's avatar
monty@hundin.mysql.fi committed
2507 2508 2509
#ifdef OS2
  fflush( file);
#endif
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
2510
  if (opt_outfile)
monty@donna.mysql.com's avatar
monty@donna.mysql.com committed
2511
    (void) vfprintf(OUTFILE, fmt, args);
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
2512 2513 2514 2515 2516 2517
  va_end(args);
}


void tee_fputs(const char *s, FILE *file)
{
monty@mysql.com's avatar
monty@mysql.com committed
2518
  NETWARE_YIELD;
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
2519
  fputs(s, file);
monty@hundin.mysql.fi's avatar
monty@hundin.mysql.fi committed
2520 2521 2522
#ifdef OS2
  fflush( file);
#endif
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
2523 2524 2525 2526 2527 2528 2529
  if (opt_outfile)
    fputs(s, OUTFILE);
}


void tee_puts(const char *s, FILE *file)
{
monty@mysql.com's avatar
monty@mysql.com committed
2530
  NETWARE_YIELD;
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
2531 2532
  fputs(s, file);
  fputs("\n", file);
monty@hundin.mysql.fi's avatar
monty@hundin.mysql.fi committed
2533 2534 2535
#ifdef OS2
  fflush( file);
#endif
jani@prima.mysql.com's avatar
jani@prima.mysql.com committed
2536 2537 2538 2539 2540 2541 2542
  if (opt_outfile)
  {
    fputs(s, OUTFILE);
    fputs("\n", OUTFILE);
  }
}

2543 2544 2545
void tee_putc(int c, FILE *file)
{
  putc(c, file);
monty@hundin.mysql.fi's avatar
monty@hundin.mysql.fi committed
2546 2547 2548
#ifdef OS2
  fflush( file);
#endif
2549 2550 2551 2552
  if (opt_outfile)
    putc(c, OUTFILE);
}

monty@mashka.mysql.fi's avatar
monty@mashka.mysql.fi committed
2553
#if defined( __WIN__) || defined( OS2) || defined(__NETWARE__)
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2554 2555 2556
#include <time.h>
#else
#include <sys/times.h>
2557
#ifdef _SC_CLK_TCK				// For mit-pthreads
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2558 2559 2560
#undef CLOCKS_PER_SEC
#define CLOCKS_PER_SEC (sysconf(_SC_CLK_TCK))
#endif
2561
#endif
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2562 2563 2564

static ulong start_timer(void)
{
monty@mashka.mysql.fi's avatar
monty@mashka.mysql.fi committed
2565
#if defined( __WIN__) || defined( OS2) || defined(__NETWARE__)
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2566 2567 2568 2569 2570 2571 2572 2573 2574 2575 2576 2577 2578 2579 2580 2581 2582 2583 2584 2585 2586 2587 2588 2589 2590 2591 2592 2593 2594 2595 2596 2597 2598 2599 2600 2601 2602 2603 2604 2605 2606 2607 2608 2609 2610 2611 2612 2613 2614 2615 2616 2617 2618 2619
 return clock();
#else
  struct tms tms_tmp;
  return times(&tms_tmp);
#endif
}


static void nice_time(double sec,char *buff,bool part_second)
{
  ulong tmp;
  if (sec >= 3600.0*24)
  {
    tmp=(ulong) floor(sec/(3600.0*24));
    sec-=3600.0*24*tmp;
    buff=int2str((long) tmp,buff,10);
    buff=strmov(buff,tmp > 1 ? " days " : " day ");
  }
  if (sec >= 3600.0)
  {
    tmp=(ulong) floor(sec/3600.0);
    sec-=3600.0*tmp;
    buff=int2str((long) tmp,buff,10);
    buff=strmov(buff,tmp > 1 ? " hours " : " hour ");
  }
  if (sec >= 60.0)
  {
    tmp=(ulong) floor(sec/60.0);
    sec-=60.0*tmp;
    buff=int2str((long) tmp,buff,10);
    buff=strmov(buff," min ");
  }
  if (part_second)
    sprintf(buff,"%.2f sec",sec);
  else
    sprintf(buff,"%d sec",(int) sec);
}


static void end_timer(ulong start_time,char *buff)
{
  nice_time((double) (start_timer() - start_time) /
	    CLOCKS_PER_SEC,buff,1);
}


static void mysql_end_timer(ulong start_time,char *buff)
{
  buff[0]=' ';
  buff[1]='(';
  end_timer(start_time,buff+2);
  strmov(strend(buff),")");
}

2620 2621
static const char* construct_prompt()
{
2622 2623
  processed_prompt.free();			// Erase the old prompt
  time_t  lclock = time(NULL);			// Get the date struct
jani@hynda.mysql.fi's avatar
merge  
jani@hynda.mysql.fi committed
2624
  struct tm *t = localtime(&lclock);
2625 2626

  /* parse thru the settings for the prompt */
2627 2628 2629
  for (char *c = current_prompt; *c ; *c++)
  {
    if (*c != PROMPT_CHAR)
jani@hynda.mysql.fi's avatar
merge  
jani@hynda.mysql.fi committed
2630
	processed_prompt.append(*c);
2631 2632
    else
    {
jani@hynda.mysql.fi's avatar
merge  
jani@hynda.mysql.fi committed
2633 2634
      switch (*++c) {
      case '\0':
2635
	c--;			// stop it from going beyond if ends with %
jani@hynda.mysql.fi's avatar
merge  
jani@hynda.mysql.fi committed
2636 2637 2638 2639 2640
	break;
      case 'c':
	add_int_to_prompt(++prompt_counter);
	break;
      case 'v':
2641 2642 2643 2644
	if (connected)
	  processed_prompt.append(mysql_get_server_info(&mysql));
	else
	  processed_prompt.append("not_connected");
jani@hynda.mysql.fi's avatar
merge  
jani@hynda.mysql.fi committed
2645 2646 2647 2648 2649 2650
	break;
      case 'd':
	processed_prompt.append(current_db ? current_db : "(none)");
	break;
      case 'h':
      {
2651 2652
	const char *prompt;
	prompt= connected ? mysql_get_host_info(&mysql) : "not_connected";
jani@hynda.mysql.fi's avatar
merge  
jani@hynda.mysql.fi committed
2653 2654 2655 2656 2657 2658 2659 2660 2661 2662
	if (strstr(prompt, "Localhost"))
	  processed_prompt.append("localhost");
	else
	{
	  const char *end=strcend(prompt,' ');
	  processed_prompt.append(prompt, (uint) (end-prompt));
	}
	break;
      }
      case 'p':
2663 2664 2665 2666 2667 2668 2669
	if (!connected)
	{
	  processed_prompt.append("not_connected");
	  break;
	}
	if (strstr(mysql_get_host_info(&mysql),"TCP/IP") || !
	    mysql.unix_socket)
jani@hynda.mysql.fi's avatar
merge  
jani@hynda.mysql.fi committed
2670 2671
	  add_int_to_prompt(mysql.port);
	else
2672 2673 2674 2675
	{
	  char *pos=strrchr(mysql.unix_socket,'/');
	  processed_prompt.append(pos ? pos+1 : mysql.unix_socket);
	}
jani@hynda.mysql.fi's avatar
merge  
jani@hynda.mysql.fi committed
2676 2677 2678 2679 2680 2681 2682 2683 2684 2685 2686 2687 2688 2689 2690 2691 2692 2693 2694 2695 2696 2697
	break;
      case 'U':
	if (!full_username)
	  init_username();
	processed_prompt.append(full_username);
	break;
      case 'u':
	if (!full_username)
	  init_username();
	processed_prompt.append(part_username);
	break;
      case PROMPT_CHAR:
	processed_prompt.append(PROMPT_CHAR);
	break;
      case 'n':
	processed_prompt.append('\n');
	break;
      case ' ':
      case '_':
	processed_prompt.append(' ');
	break;
      case 'R':
2698 2699
	if (t->tm_hour < 10)
	  processed_prompt.append('0');
jani@hynda.mysql.fi's avatar
merge  
jani@hynda.mysql.fi committed
2700 2701 2702 2703 2704 2705 2706
	add_int_to_prompt(t->tm_hour);
	break;
      case 'r':
	int getHour;
	getHour = t->tm_hour % 12;
	if (getHour == 0)
	  getHour=12;
2707 2708
	if (getHour < 10)
	  processed_prompt.append('0');
jani@hynda.mysql.fi's avatar
merge  
jani@hynda.mysql.fi committed
2709 2710 2711 2712 2713 2714 2715 2716 2717 2718 2719 2720 2721 2722 2723 2724 2725 2726 2727 2728 2729 2730 2731 2732 2733
	add_int_to_prompt(getHour);
	break;
      case 'm':
	if (t->tm_min < 10)
	  processed_prompt.append('0');
	add_int_to_prompt(t->tm_min);
	break;
      case 'y':
	int getYear;
	getYear = t->tm_year % 100;
	if (getYear < 10)
	  processed_prompt.append('0');
	add_int_to_prompt(getYear);
	break;
      case 'Y':
	add_int_to_prompt(t->tm_year+1900);
	break;
      case 'D':
	char* dateTime;
	time_t lclock;
	lclock = time(NULL);
	dateTime = ctime(&lclock);
	processed_prompt.append(strtok(dateTime,"\n"));
	break;
      case 's':
2734 2735
	if (t->tm_sec < 10)
	  processed_prompt.append('0');
jani@hynda.mysql.fi's avatar
merge  
jani@hynda.mysql.fi committed
2736 2737 2738 2739 2740 2741 2742 2743 2744 2745 2746 2747 2748 2749 2750 2751 2752 2753 2754 2755 2756 2757 2758 2759 2760 2761 2762 2763 2764 2765 2766 2767 2768 2769 2770
	add_int_to_prompt(t->tm_sec);
	break;
      case 'w':
	processed_prompt.append(day_names[t->tm_wday]);
	break;
      case 'P':
	processed_prompt.append(t->tm_hour < 12 ? "am" : "pm");
	break;
      case 'o':
	add_int_to_prompt(t->tm_mon+1);
	break;
      case 'O':
	processed_prompt.append(month_names[t->tm_mon]);
	break;
      case '\'':
	processed_prompt.append("'");
	break;
      case '"':
	processed_prompt.append('"');
	break;
      case 'S':
	processed_prompt.append(';');
	break;
      case 't':
	processed_prompt.append('\t');
	break;
      default:
	processed_prompt.append(c);
      }
    }
  }
  processed_prompt.append('\0');
  return processed_prompt.ptr();
}

2771 2772 2773

static void add_int_to_prompt(int toadd)
{
jani@hynda.mysql.fi's avatar
merge  
jani@hynda.mysql.fi committed
2774 2775 2776 2777 2778
  char buffer[16];
  int10_to_str(toadd,buffer,10);
  processed_prompt.append(buffer);
}

2779 2780
static void init_username()
{
jani@hynda.mysql.fi's avatar
merge  
jani@hynda.mysql.fi committed
2781 2782 2783 2784 2785 2786 2787
  my_free(full_username,MYF(MY_ALLOW_ZERO_PTR));
  my_free(part_username,MYF(MY_ALLOW_ZERO_PTR));

  MYSQL_RES *result;
  LINT_INIT(result);
  if (!mysql_query(&mysql,"select USER()") &&
      (result=mysql_use_result(&mysql)))
2788 2789 2790 2791 2792 2793
  {
    MYSQL_ROW cur=mysql_fetch_row(result);
    full_username=my_strdup(cur[0],MYF(MY_WME));
    part_username=my_strdup(strtok(cur[0],"@"),MYF(MY_WME));
    (void) mysql_fetch_row(result);		// Read eof
  }
jani@hynda.mysql.fi's avatar
merge  
jani@hynda.mysql.fi committed
2794 2795
}

2796 2797 2798
static int com_prompt(String *buffer, char *line)
{
  char *ptr=strchr(line, ' ');
jani@hynda.mysql.fi's avatar
merge  
jani@hynda.mysql.fi committed
2799 2800
  prompt_counter = 0;
  my_free(current_prompt,MYF(MY_ALLOW_ZERO_PTR));
2801 2802
  current_prompt=my_strdup(ptr ? ptr+1 : default_prompt,MYF(MY_WME));
  if (!ptr)
jani@hynda.mysql.fi's avatar
merge  
jani@hynda.mysql.fi committed
2803 2804 2805 2806 2807 2808
    tee_fprintf(stdout, "Returning to default PROMPT of %s\n", default_prompt);
  else
    tee_fprintf(stdout, "PROMPT set to '%s'\n", current_prompt);
  return 0;
}

2809
#ifndef EMBEDDED_LIBRARY
bk@work.mysql.com's avatar
bk@work.mysql.com committed
2810 2811 2812 2813 2814 2815 2816 2817 2818 2819 2820
/* Keep sql_string library happy */

gptr sql_alloc(unsigned int Size)
{
  return my_malloc(Size,MYF(MY_WME));
}

void sql_element_free(void *ptr)
{
  my_free((gptr) ptr,MYF(0));
}
2821
#endif /* EMBEDDED_LIBRARY */