mysqladmin.c 33 KB
Newer Older
unknown's avatar
unknown committed
1
/* Copyright (C) 2000-2004 MySQL AB
unknown's avatar
unknown committed
2

unknown's avatar
unknown 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.
unknown's avatar
unknown committed
7

unknown's avatar
unknown 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.
unknown's avatar
unknown committed
12

unknown's avatar
unknown committed
13 14 15 16 17 18 19
   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 */

/* maintaince of mysql databases */


unknown's avatar
unknown committed
20
#include "client_priv.h"
unknown's avatar
unknown committed
21 22 23 24
#include <signal.h>
#ifdef THREAD
#include <my_pthread.h>				/* because of signal()	*/
#endif
unknown's avatar
unknown committed
25
#include <sys/stat.h>
26
#include <mysql.h>
unknown's avatar
unknown committed
27

28
#define ADMIN_VERSION "8.41"
unknown's avatar
unknown committed
29
#define MAX_MYSQL_VAR 256
unknown's avatar
unknown committed
30
#define SHUTDOWN_DEF_TIMEOUT 3600		/* Wait for shutdown */
unknown's avatar
unknown committed
31 32
#define MAX_TRUNC_LENGTH 3

33
char *host= NULL, *user= 0, *opt_password= 0;
unknown's avatar
unknown committed
34 35 36 37
char truncated_var_names[MAX_MYSQL_VAR][MAX_TRUNC_LENGTH];
char ex_var_names[MAX_MYSQL_VAR][FN_REFLEN];
ulonglong last_values[MAX_MYSQL_VAR];
static int interval=0;
unknown's avatar
unknown committed
38
static my_bool option_force=0,interrupted=0,new_line=0,
39 40
               opt_compress=0, opt_relative=0, opt_verbose=0, opt_vertical=0,
               tty_password=0;
unknown's avatar
unknown committed
41 42
static uint tcp_port = 0, option_wait = 0, option_silent=0, nr_iterations,
            opt_count_iterations= 0;
unknown's avatar
unknown committed
43
static ulong opt_connect_timeout, opt_shutdown_timeout;
unknown's avatar
unknown committed
44 45
static my_string unix_port=0;

46 47 48 49 50
#ifdef HAVE_SMEM
static char *shared_memory_base_name=0;
#endif
static uint opt_protocol=0;

51 52 53 54 55 56
/*
  When using extended-status relatively, ex_val_max_len is the estimated
  maximum length for any relative value printed by extended-status. The
  idea is to try to keep the length of output as short as possible.
*/

unknown's avatar
unknown committed
57 58 59 60
static uint ex_val_max_len[MAX_MYSQL_VAR];
static my_bool ex_status_printed = 0; /* First output is not relative. */
static uint ex_var_count, max_var_length, max_val_length;

61
#include <sslopt-vars.h>
unknown's avatar
unknown committed
62 63 64

static void print_version(void);
static void usage(void);
65
static my_bool sql_connect(MYSQL *mysql, uint wait);
66
static int execute_commands(MYSQL *mysql,int argc, char **argv);
unknown's avatar
unknown committed
67 68 69 70 71 72 73 74 75 76 77 78
static int drop_db(MYSQL *mysql,const char *db);
static sig_handler endprog(int signal_number);
static void nice_time(ulong sec,char *buff);
static void print_header(MYSQL_RES *result);
static void print_top(MYSQL_RES *result);
static void print_row(MYSQL_RES *result,MYSQL_ROW cur, uint row);
static void print_relative_row(MYSQL_RES *result, MYSQL_ROW cur, uint row);
static void print_relative_row_vert(MYSQL_RES *result, MYSQL_ROW cur, uint row);
static void print_relative_header();
static void print_relative_line();
static void truncate_names();
static my_bool get_pidfile(MYSQL *mysql, char *pidfile);
unknown's avatar
unknown committed
79 80
static my_bool wait_pidfile(char *pidfile, time_t last_modified,
			    struct stat *pidfile_status);
unknown's avatar
unknown committed
81 82 83 84 85 86
static void store_values(MYSQL_RES *result);

/*
  The order of commands must be the same as command_names,
  except ADMIN_ERROR
*/
87 88
enum commands {
  ADMIN_ERROR,
89
  ADMIN_CREATE,           ADMIN_DROP,            ADMIN_SHUTDOWN,
90 91 92 93 94 95
  ADMIN_RELOAD,           ADMIN_REFRESH,         ADMIN_VER,
  ADMIN_PROCESSLIST,      ADMIN_STATUS,          ADMIN_KILL,
  ADMIN_DEBUG,            ADMIN_VARIABLES,       ADMIN_FLUSH_LOGS,
  ADMIN_FLUSH_HOSTS,      ADMIN_FLUSH_TABLES,    ADMIN_PASSWORD,
  ADMIN_PING,             ADMIN_EXTENDED_STATUS, ADMIN_FLUSH_STATUS,
  ADMIN_FLUSH_PRIVILEGES, ADMIN_START_SLAVE,     ADMIN_STOP_SLAVE,
96
  ADMIN_FLUSH_THREADS,    ADMIN_OLD_PASSWORD
unknown's avatar
unknown committed
97
};
98 99 100 101 102 103 104
static const char *command_names[]= {
  "create",               "drop",                "shutdown",
  "reload",               "refresh",             "version",
  "processlist",          "status",              "kill",
  "debug",                "variables",           "flush-logs",
  "flush-hosts",          "flush-tables",        "password",
  "ping",                 "extended-status",     "flush-status",
105 106
  "flush-privileges",     "start-slave",         "stop-slave",
  "flush-threads","old-password",
107 108 109
  NullS
};

unknown's avatar
unknown committed
110 111 112
static TYPELIB command_typelib=
{ array_elements(command_names)-1,"commands", command_names};

113 114
static struct my_option my_long_options[] =
{
unknown's avatar
unknown committed
115
  {"count", 'c',
116
   "Number of iterations to make. This works with -i (--sleep) only.",
unknown's avatar
unknown committed
117 118
   (gptr*) &nr_iterations, (gptr*) &nr_iterations, 0, GET_UINT,
   REQUIRED_ARG, 0, 0, 0, 0, 0, 0},
119
  {"debug", '#', "Output debug log. Often this is 'd:t:o,filename'.",
120 121 122 123 124
   0, 0, 0, GET_STR, OPT_ARG, 0, 0, 0, 0, 0, 0},
  {"force", 'f',
   "Don't ask for confirmation on drop database; with multiple commands, continue even if an error occurs.",
   (gptr*) &option_force, (gptr*) &option_force, 0, GET_BOOL, NO_ARG, 0, 0,
   0, 0, 0, 0},
125
  {"compress", 'C', "Use compression in server/client protocol.",
126 127 128 129 130 131 132
   (gptr*) &opt_compress, (gptr*) &opt_compress, 0, GET_BOOL, 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},
  {"help", '?', "Display this help and exit.", 0, 0, 0, GET_NO_ARG,
   NO_ARG, 0, 0, 0, 0, 0, 0},
133
  {"host", 'h', "Connect to host.", (gptr*) &host, (gptr*) &host, 0, GET_STR,
134 135 136 137
   REQUIRED_ARG, 0, 0, 0, 0, 0, 0},
  {"password", 'p',
   "Password to use when connecting to server. If password is not given it's asked from the tty.",
   0, 0, 0, GET_STR, OPT_ARG, 0, 0, 0, 0, 0, 0},
unknown's avatar
unknown committed
138
#ifdef __WIN__
139 140
  {"pipe", 'W', "Use named pipes to connect to server.", 0, 0, 0, GET_NO_ARG,
   NO_ARG, 0, 0, 0, 0, 0, 0},
unknown's avatar
unknown committed
141
#endif
142
  {"port", 'P', "Port number to use for connection.", (gptr*) &tcp_port,
unknown's avatar
unknown committed
143
   (gptr*) &tcp_port, 0, GET_UINT, REQUIRED_ARG, MYSQL_PORT, 0, 0, 0, 0, 0},
144
  {"protocol", OPT_MYSQL_PROTOCOL, "The protocol of connection (tcp,socket,pipe,memory).",
145
    0, 0, 0, GET_STR,  REQUIRED_ARG, 0, 0, 0, 0, 0, 0},
146 147 148 149 150
  {"relative", 'r',
   "Show difference between current and previous values when used with -i. Currently works only with extended-status.",
   (gptr*) &opt_relative, (gptr*) &opt_relative, 0, GET_BOOL, NO_ARG, 0, 0, 0,
  0, 0, 0},
  {"set-variable", 'O',
unknown's avatar
unknown committed
151
   "Change the value of a variable. Please note that this option is deprecated; you can set variables directly with --variable-name=value.",
152
   0, 0, 0, GET_STR, REQUIRED_ARG, 0, 0, 0, 0, 0, 0},
153
#ifdef HAVE_SMEM
154
  {"shared-memory-base-name", OPT_SHARED_MEMORY_BASE_NAME,
155
   "Base name of shared memory.", (gptr*) &shared_memory_base_name, (gptr*) &shared_memory_base_name,
156 157
   0, GET_STR_ALLOC, REQUIRED_ARG, 0, 0, 0, 0, 0, 0},
#endif
158
  {"silent", 's', "Silently exit if one can't connect to server.",
159 160
   0, 0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0},
  {"socket", 'S', "Socket file to use for connection.",
161 162
   (gptr*) &unix_port, (gptr*) &unix_port, 0, GET_STR, REQUIRED_ARG, 0, 0, 0,
   0, 0, 0},
163
  {"sleep", 'i', "Execute commands again and again with a sleep between.",
164 165
   (gptr*) &interval, (gptr*) &interval, 0, GET_INT, REQUIRED_ARG, 0, 0, 0, 0,
   0, 0},
166
#include <sslopt-longopts.h>
unknown's avatar
unknown committed
167
#ifndef DONT_ALLOW_USER_CHANGE
168
  {"user", 'u', "User for login if not current user.", (gptr*) &user,
169
   (gptr*) &user, 0, GET_STR_ALLOC, REQUIRED_ARG, 0, 0, 0, 0, 0, 0},
unknown's avatar
unknown committed
170
#endif
171 172
  {"verbose", 'v', "Write more information.", (gptr*) &opt_verbose,
   (gptr*) &opt_verbose, 0, GET_BOOL, NO_ARG, 0, 0, 0, 0, 0, 0},
173
  {"version", 'V', "Output version information and exit.", 0, 0, 0, GET_NO_ARG,
174
   NO_ARG, 0, 0, 0, 0, 0, 0},
175
  {"vertical", 'E',
176 177 178
   "Print output vertically. Is similar to --relative, but prints output vertically.",
   (gptr*) &opt_vertical, (gptr*) &opt_vertical, 0, GET_BOOL, NO_ARG, 0, 0, 0,
   0, 0, 0},
179
  {"wait", 'w', "Wait and retry if connection is down.", 0, 0, 0, GET_UINT,
180
   OPT_ARG, 0, 0, 0, 0, 0, 0},
181
  {"connect_timeout", OPT_CONNECT_TIMEOUT, "", (gptr*) &opt_connect_timeout,
182
   (gptr*) &opt_connect_timeout, 0, GET_ULONG, REQUIRED_ARG, 3600*12, 0,
183 184
   3600*12, 0, 1, 0},
  {"shutdown_timeout", OPT_SHUTDOWN_TIMEOUT, "", (gptr*) &opt_shutdown_timeout,
185
   (gptr*) &opt_shutdown_timeout, 0, GET_ULONG, REQUIRED_ARG,
186 187
   SHUTDOWN_DEF_TIMEOUT, 0, 3600*12, 0, 1, 0},
  { 0, 0, 0, 0, 0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0}
unknown's avatar
unknown committed
188 189
};

190

unknown's avatar
unknown committed
191 192
static const char *load_default_groups[]= { "mysqladmin","client",0 };

193 194 195
static my_bool
get_one_option(int optid, const struct my_option *opt __attribute__((unused)),
	       char *argument)
unknown's avatar
unknown committed
196
{
197 198 199
  int error = 0;

  switch(optid) {
unknown's avatar
unknown committed
200 201 202
  case 'c':
    opt_count_iterations= 1;
    break;
203 204 205 206 207 208 209 210 211
  case 'p':
    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;				/* Cut length of argument */
212
      tty_password= 0;
213 214 215 216 217 218 219 220
    }
    else
      tty_password=1;
    break;
  case 's':
    option_silent++;
    break;
  case 'W':
unknown's avatar
unknown committed
221
#ifdef __WIN__
222
    opt_protocol = MYSQL_PROTOCOL_PIPE;
unknown's avatar
unknown committed
223
#endif
224 225 226 227
    break;
  case '#':
    DBUG_PUSH(argument ? argument : "d:t:o,/tmp/mysqladmin.trace");
    break;
228
#include <sslopt-case.h>
229 230 231 232 233 234 235 236 237 238 239 240 241 242 243 244 245 246
  case 'V':
    print_version();
    exit(0);
    break;
  case 'w':
    if (argument)
    {
      if ((option_wait=atoi(argument)) <= 0)
	option_wait=1;
    }
    else
      option_wait= ~0;
    break;
  case '?':
  case 'I':					/* Info */
    error++;
    break;
  case OPT_CHARSETS_DIR:
unknown's avatar
unknown committed
247
#if MYSQL_VERSION_ID > 32300
248
    charsets_dir = argument;
unknown's avatar
unknown committed
249
#endif
250
    break;
251 252
  case OPT_MYSQL_PROTOCOL:
  {
253
    if ((opt_protocol= find_type(argument, &sql_protocol_typelib,0)) <= 0)
254 255 256 257 258 259
    {
      fprintf(stderr, "Unknown option to protocol: %s\n", argument);
      exit(1);
    }
    break;
  }
unknown's avatar
unknown committed
260
  }
261
  if (error)
unknown's avatar
unknown committed
262 263 264 265
  {
    usage();
    exit(1);
  }
266 267 268 269 270 271
  return 0;
}


int main(int argc,char *argv[])
{
272
  int error= 0, ho_error;
273
  MYSQL mysql;
274 275
  char **commands, **save_argv;

276 277 278
  MY_INIT(argv[0]);
  mysql_init(&mysql);
  load_defaults("my",load_default_groups,&argc,&argv);
279
  save_argv = argv;				/* Save for free_defaults */
280
  if ((ho_error=handle_options(&argc, &argv, my_long_options, get_one_option)))
281 282
  {
    free_defaults(save_argv);
283
    exit(ho_error);
284
  }
285

286 287 288 289 290 291
  if (argc == 0)
  {
    usage();
    exit(1);
  }
  commands = argv;
unknown's avatar
unknown committed
292
  if (tty_password)
293
    opt_password = get_tty_password(NullS);
unknown's avatar
unknown committed
294 295 296 297 298 299

  VOID(signal(SIGINT,endprog));			/* Here if abort */
  VOID(signal(SIGTERM,endprog));		/* Here if abort */

  if (opt_compress)
    mysql_options(&mysql,MYSQL_OPT_COMPRESS,NullS);
300 301 302 303 304
  if (opt_connect_timeout)
  {
    uint tmp=opt_connect_timeout;
    mysql_options(&mysql,MYSQL_OPT_CONNECT_TIMEOUT, (char*) &tmp);
  }
unknown's avatar
unknown committed
305 306 307
#ifdef HAVE_OPENSSL
  if (opt_use_ssl)
    mysql_ssl_set(&mysql, opt_ssl_key, opt_ssl_cert, opt_ssl_ca,
308
		  opt_ssl_capath, opt_ssl_cipher);
unknown's avatar
unknown committed
309
#endif
310 311 312 313 314
  if (opt_protocol)
    mysql_options(&mysql,MYSQL_OPT_PROTOCOL,(char*)&opt_protocol);
#ifdef HAVE_SMEM
  if (shared_memory_base_name)
    mysql_options(&mysql,MYSQL_SHARED_MEMORY_BASE_NAME,shared_memory_base_name);
315
#endif
316
  if (sql_connect(&mysql, option_wait))
317 318 319 320 321 322 323 324 325 326 327 328 329 330 331 332 333
  {
    unsigned int err= mysql_errno(&mysql);
    if (err >= CR_MIN_ERROR && err <= CR_MAX_ERROR)
      error= 1;
    else
    {
      /* Return 0 if all commands are PING */
      for (; argc > 0; argv++, argc--)
      {
        if (find_type(argv[0], &command_typelib, 2) != ADMIN_PING)
        {
          error= 1;
          break;
        }
      }
    }
  }
unknown's avatar
unknown committed
334 335
  else
  {
unknown's avatar
unknown committed
336
    while (!interrupted && (!opt_count_iterations || nr_iterations))
unknown's avatar
unknown committed
337 338
    {
      new_line = 0;
339
      if ((error=execute_commands(&mysql,argc,commands)))
unknown's avatar
unknown committed
340
      {
341 342 343
	if (error > 0)
	  break;				/* Wrong command error */
	if (!option_force)
unknown's avatar
unknown committed
344
	{
345 346 347
	  if (option_wait && !interrupted)
	  {
	    mysql_close(&mysql);
348
	    if (!sql_connect(&mysql, option_wait))
349 350 351 352 353 354 355
	    {
	      sleep(1);				/* Don't retry too rapidly */
	      continue;				/* Retry */
	    }
	  }
	  error=1;
	  break;
unknown's avatar
unknown committed
356 357 358 359 360 361 362
	}
      }
      if (interval)
      {
	sleep(interval);
	if (new_line)
	  puts("");
unknown's avatar
unknown committed
363 364
	if (opt_count_iterations)
	  nr_iterations--;
unknown's avatar
unknown committed
365 366 367 368 369 370
      }
      else
	break;
    }
    mysql_close(&mysql);
  }
371
  my_free(opt_password,MYF(MY_ALLOW_ZERO_PTR));
unknown's avatar
unknown committed
372
  my_free(user,MYF(MY_ALLOW_ZERO_PTR));
373 374 375
#ifdef HAVE_SMEM
  my_free(shared_memory_base_name,MYF(MY_ALLOW_ZERO_PTR));
#endif
376
  free_defaults(save_argv);
unknown's avatar
unknown committed
377
  my_end(0);
378
  exit(error ? 1 : 0);
unknown's avatar
unknown committed
379 380 381 382 383 384 385 386 387 388
  return 0;
}


static sig_handler endprog(int signal_number __attribute__((unused)))
{
  interrupted=1;
}


389
static my_bool sql_connect(MYSQL *mysql, uint wait)
unknown's avatar
unknown committed
390 391 392 393 394
{
  my_bool info=0;

  for (;;)
  {
395 396
    if (mysql_real_connect(mysql,host,user,opt_password,NullS,tcp_port,
			   unix_port, 0))
unknown's avatar
unknown committed
397 398 399 400 401 402 403 404
    {
      if (info)
      {
	fputs("\n",stderr);
	(void) fflush(stderr);
      }
      return 0;
    }
unknown's avatar
unknown committed
405

unknown's avatar
unknown committed
406 407 408 409 410
    if (!wait)
    {
      if (!option_silent)
      {
	if (!host)
411
	  host= (char*) LOCAL_HOST;
unknown's avatar
unknown committed
412 413 414 415 416 417 418 419 420 421 422 423 424 425 426 427 428 429 430 431 432 433 434 435
	my_printf_error(0,"connect to server at '%s' failed\nerror: '%s'",
			MYF(ME_BELL), host, mysql_error(mysql));
	if (mysql_errno(mysql) == CR_CONNECTION_ERROR)
	{
	  fprintf(stderr,
		  "Check that mysqld is running and that the socket: '%s' exists!\n",
		  unix_port ? unix_port : mysql_unix_port);
	}
	else if (mysql_errno(mysql) == CR_CONN_HOST_ERROR ||
		 mysql_errno(mysql) == CR_UNKNOWN_HOST)
	{
	  fprintf(stderr,"Check that mysqld is running on %s",host);
	  fprintf(stderr," and that the port is %d.\n",
		  tcp_port ? tcp_port: mysql_port);
	  fprintf(stderr,"You can check this by doing 'telnet %s %d'\n",
		  host, tcp_port ? tcp_port: mysql_port);
	}
      }
      return 1;
    }
    if (wait != (uint) ~0)
      wait--;				/* One less retry */
    if ((mysql_errno(mysql) != CR_CONN_HOST_ERROR) &&
	(mysql_errno(mysql) != CR_CONNECTION_ERROR))
436
    {
unknown's avatar
unknown committed
437 438 439 440
      fprintf(stderr,"Got error: %s\n", mysql_error(mysql));
      if (!option_force)
	return 1;
    }
unknown's avatar
unknown committed
441
    else if (!option_silent)
unknown's avatar
unknown committed
442
    {
unknown's avatar
unknown committed
443 444 445 446 447 448 449 450
      if (!info)
      {
	info=1;
	fputs("Waiting for MySQL server to answer",stderr);
	(void) fflush(stderr);
      }
      else
      {
451
	putc('.',stderr);
unknown's avatar
unknown committed
452 453
	(void) fflush(stderr);
      }
unknown's avatar
unknown committed
454
    }
unknown's avatar
unknown committed
455
    sleep(5);
unknown's avatar
unknown committed
456 457 458
  }
}

unknown's avatar
unknown committed
459

460 461 462 463 464 465
/*
  Execute a command.
  Return 0 on ok
	 -1 on retryable error
	 1 on fatal error
*/
unknown's avatar
unknown committed
466

467
static int execute_commands(MYSQL *mysql,int argc, char **argv)
unknown's avatar
unknown committed
468
{
unknown's avatar
unknown committed
469
  const char *status;
unknown's avatar
unknown committed
470 471 472 473 474 475 476
  /*
    MySQL documentation relies on the fact that mysqladmin will
    execute commands in the order specified, e.g.
    mysqladmin -u root flush-privileges password "newpassword"
    to reset a lost root password.
    If this behaviour is ever changed, Docs should be notified.
  */
477

478
  struct rand_struct rand_st;
479

unknown's avatar
unknown committed
480 481 482 483 484 485 486 487 488 489 490
  for (; argc > 0 ; argv++,argc--)
  {
    switch (find_type(argv[0],&command_typelib,2)) {
    case ADMIN_CREATE:
    {
      char buff[FN_REFLEN+20];
      if (argc < 2)
      {
	my_printf_error(0,"Too few arguments to create",MYF(ME_BELL));
	return 1;
      }
unknown's avatar
unknown committed
491
      sprintf(buff,"create database `%.*s`",FN_REFLEN,argv[1]);
unknown's avatar
unknown committed
492
      if (mysql_query(mysql,buff))
493
      {
unknown's avatar
unknown committed
494 495
	my_printf_error(0,"CREATE DATABASE failed; error: '%-.200s'",
			MYF(ME_BELL), mysql_error(mysql));
496
	return -1;
497
      }
unknown's avatar
unknown committed
498
      argc--; argv++;
unknown's avatar
unknown committed
499 500 501 502 503 504 505 506 507
      break;
    }
    case ADMIN_DROP:
    {
      if (argc < 2)
      {
	my_printf_error(0,"Too few arguments to drop",MYF(ME_BELL));
	return 1;
      }
508
      if (drop_db(mysql,argv[1]))
509
	return -1;
unknown's avatar
unknown committed
510
      argc--; argv++;
unknown's avatar
unknown committed
511 512 513 514 515
      break;
    }
    case ADMIN_SHUTDOWN:
    {
      char pidfile[FN_REFLEN];
516
      my_bool got_pidfile= 0;
517
      time_t last_modified= 0;
518 519
      struct stat pidfile_status;

520 521 522 523
      /*
	Only wait for pidfile on local connections
	If pidfile doesn't exist, continue without pid file checking
      */
524 525
      if (mysql->unix_socket && (got_pidfile= !get_pidfile(mysql, pidfile)) &&
	  !stat(pidfile, &pidfile_status))
526 527
	last_modified= pidfile_status.st_mtime;

528
      if (mysql_shutdown(mysql, SHUTDOWN_DEFAULT))
unknown's avatar
unknown committed
529 530 531
      {
	my_printf_error(0,"shutdown failed; error: '%s'",MYF(ME_BELL),
			mysql_error(mysql));
532
	return -1;
unknown's avatar
unknown committed
533 534 535 536 537 538
      }
      mysql_close(mysql);	/* Close connection to avoid error messages */
      if (got_pidfile)
      {
	if (opt_verbose)
	  printf("Shutdown signal sent to server;  Waiting for pid file to disappear\n");
539 540

	/* Wait until pid file is gone */
unknown's avatar
unknown committed
541 542
	if (wait_pidfile(pidfile, last_modified, &pidfile_status))
	  return -1;
unknown's avatar
unknown committed
543 544 545 546 547
      }
      break;
    }
    case ADMIN_FLUSH_PRIVILEGES:
    case ADMIN_RELOAD:
548
      if (mysql_query(mysql,"flush privileges"))
unknown's avatar
unknown committed
549 550 551
      {
	my_printf_error(0,"reload failed; error: '%s'",MYF(ME_BELL),
			mysql_error(mysql));
552
	return -1;
unknown's avatar
unknown committed
553 554 555 556 557
      }
      break;
    case ADMIN_REFRESH:
      if (mysql_refresh(mysql,
			(uint) ~(REFRESH_GRANT | REFRESH_STATUS |
558
				 REFRESH_READ_LOCK | REFRESH_SLAVE |
559
				 REFRESH_MASTER)))
unknown's avatar
unknown committed
560 561 562
      {
	my_printf_error(0,"refresh failed; error: '%s'",MYF(ME_BELL),
			mysql_error(mysql));
563
	return -1;
unknown's avatar
unknown committed
564 565 566
      }
      break;
    case ADMIN_FLUSH_THREADS:
567
      if (mysql_refresh(mysql,(uint) REFRESH_THREADS))
unknown's avatar
unknown committed
568 569 570
      {
	my_printf_error(0,"refresh failed; error: '%s'",MYF(ME_BELL),
			mysql_error(mysql));
571
	return -1;
unknown's avatar
unknown committed
572 573 574 575 576
      }
      break;
    case ADMIN_VER:
      new_line=1;
      print_version();
577 578
      puts("Copyright (C) 2000 MySQL AB & MySQL Finland AB & TCX DataKonsult AB");
      puts("This software comes with ABSOLUTELY NO WARRANTY. This is free software,\nand you are welcome to modify and redistribute it under the GPL license\n");
unknown's avatar
unknown committed
579 580 581 582 583 584 585 586 587 588 589 590 591 592 593 594 595 596 597 598 599 600 601 602 603 604 605 606 607 608 609 610 611 612 613 614
      printf("Server version\t\t%s\n", mysql_get_server_info(mysql));
      printf("Protocol version\t%d\n", mysql_get_proto_info(mysql));
      printf("Connection\t\t%s\n",mysql_get_host_info(mysql));
      if (mysql->unix_socket)
	printf("UNIX socket\t\t%s\n", mysql->unix_socket);
      else
	printf("TCP port\t\t%d\n", mysql->port);
      status=mysql_stat(mysql);
      {
	char *pos,buff[40];
	ulong sec;
	pos=strchr(status,' ');
	*pos++=0;
	printf("%s\t\t\t",status);			/* print label */
	if ((status=str2int(pos,10,0,LONG_MAX,(long*) &sec)))
	{
	  nice_time(sec,buff);
	  puts(buff);				/* print nice time */
	  while (*status == ' ') status++;	/* to next info */
	}
      }
      putc('\n',stdout);
      if (status)
	puts(status);
      break;
    case ADMIN_PROCESSLIST:
    {
      MYSQL_RES *result;
      MYSQL_ROW row;

      if (mysql_query(mysql, (opt_verbose ? "show full processlist" :
			      "show processlist")) ||
	  !(result = mysql_store_result(mysql)))
      {
	my_printf_error(0,"process list failed; error: '%s'",MYF(ME_BELL),
			mysql_error(mysql));
615
	return -1;
unknown's avatar
unknown committed
616 617 618 619 620 621 622 623 624 625 626 627 628 629 630 631 632 633 634 635 636 637 638 639 640 641 642 643 644 645 646 647 648 649 650 651 652 653
      }
      print_header(result);
      while ((row=mysql_fetch_row(result)))
	print_row(result,row,0);
      print_top(result);
      mysql_free_result(result);
      new_line=1;
      break;
    }
    case ADMIN_STATUS:
      status=mysql_stat(mysql);
      if (status)
	puts(status);
      break;
    case ADMIN_KILL:
      {
	uint error=0;
	char *pos;
	if (argc < 2)
	{
	  my_printf_error(0,"Too few arguments to 'kill'",MYF(ME_BELL));
	  return 1;
	}
	pos=argv[1];
	for (;;)
	{
	  if (mysql_kill(mysql,(ulong) atol(pos)))
	  {
	    my_printf_error(0,"kill failed on %ld; error: '%s'",MYF(ME_BELL),
			    atol(pos), mysql_error(mysql));
	    error=1;
	  }
	  if (!(pos=strchr(pos,',')))
	    break;
	  pos++;
	}
	argc--; argv++;
	if (error)
654
	  return -1;
unknown's avatar
unknown committed
655 656 657 658 659 660 661
	break;
      }
    case ADMIN_DEBUG:
      if (mysql_dump_debug_info(mysql))
      {
	my_printf_error(0,"debug failed; error: '%s'",MYF(ME_BELL),
			mysql_error(mysql));
662
	return -1;
unknown's avatar
unknown committed
663 664 665 666 667 668 669 670
      }
      break;
    case ADMIN_VARIABLES:
    {
      MYSQL_RES *res;
      MYSQL_ROW row;

      new_line=1;
unknown's avatar
unknown committed
671
      if (mysql_query(mysql,"show /*!40003 GLOBAL */ variables") ||
unknown's avatar
unknown committed
672 673 674 675
	  !(res=mysql_store_result(mysql)))
      {
	my_printf_error(0,"unable to show variables; error: '%s'",MYF(ME_BELL),
			mysql_error(mysql));
676
	return -1;
unknown's avatar
unknown committed
677 678 679 680 681 682 683 684 685 686 687 688 689
      }
      print_header(res);
      while ((row=mysql_fetch_row(res)))
	print_row(res,row,0);
      print_top(res);
      mysql_free_result(res);
      break;
    }
    case ADMIN_EXTENDED_STATUS:
    {
      MYSQL_RES *res;
      MYSQL_ROW row;
      uint rownr = 0;
690
      void (*func) (MYSQL_RES*, MYSQL_ROW, uint);
unknown's avatar
unknown committed
691 692 693 694 695 696 697

      new_line = 1;
      if (mysql_query(mysql, "show status") ||
	  !(res = mysql_store_result(mysql)))
      {
	my_printf_error(0, "unable to show status; error: '%s'", MYF(ME_BELL),
			mysql_error(mysql));
698
	return -1;
unknown's avatar
unknown committed
699 700 701 702 703 704 705 706 707 708 709 710 711 712 713 714 715 716 717 718 719 720 721 722 723 724 725 726 727 728 729 730 731 732 733 734 735 736
      }
      if (!opt_vertical)
	print_header(res);
      else
      {
	if (!ex_status_printed)
	{
	  store_values(res);
	  truncate_names();   /* Does some printing also */
	}
	else
	{
	  print_relative_line();
	  print_relative_header();
	  print_relative_line();
	}
      }

      /*      void (*func) (MYSQL_RES*, MYSQL_ROW, uint); */
      if (opt_relative && !opt_vertical)
	func = print_relative_row;
      else if (opt_vertical)
	func = print_relative_row_vert;
      else
	func = print_row;

      while ((row = mysql_fetch_row(res)))
	(*func)(res, row, rownr++);
      if (opt_vertical)
      {
	if (ex_status_printed)
	{
	  putchar('\n');
	  print_relative_line();
	}
      }
      else
	print_top(res);
unknown's avatar
unknown committed
737

unknown's avatar
unknown committed
738 739 740 741 742 743 744 745 746 747
      ex_status_printed = 1; /* From now on the output will be relative */
      mysql_free_result(res);
      break;
    }
    case ADMIN_FLUSH_LOGS:
    {
      if (mysql_refresh(mysql,REFRESH_LOG))
      {
	my_printf_error(0,"refresh failed; error: '%s'",MYF(ME_BELL),
			mysql_error(mysql));
748
	return -1;
unknown's avatar
unknown committed
749 750 751 752 753
      }
      break;
    }
    case ADMIN_FLUSH_HOSTS:
    {
754
      if (mysql_query(mysql,"flush hosts"))
unknown's avatar
unknown committed
755 756 757
      {
	my_printf_error(0,"refresh failed; error: '%s'",MYF(ME_BELL),
			mysql_error(mysql));
758
	return -1;
unknown's avatar
unknown committed
759 760 761 762 763
      }
      break;
    }
    case ADMIN_FLUSH_TABLES:
    {
764
      if (mysql_query(mysql,"flush tables"))
unknown's avatar
unknown committed
765 766 767
      {
	my_printf_error(0,"refresh failed; error: '%s'",MYF(ME_BELL),
			mysql_error(mysql));
768
	return -1;
unknown's avatar
unknown committed
769 770 771 772 773
      }
      break;
    }
    case ADMIN_FLUSH_STATUS:
    {
774
      if (mysql_query(mysql,"flush status"))
unknown's avatar
unknown committed
775 776 777
      {
	my_printf_error(0,"refresh failed; error: '%s'",MYF(ME_BELL),
			mysql_error(mysql));
778
	return -1;
unknown's avatar
unknown committed
779 780 781
      }
      break;
    }
782
    case ADMIN_OLD_PASSWORD:
unknown's avatar
unknown committed
783 784
    case ADMIN_PASSWORD:
    {
785 786 787
      char buff[128],crypted_pw[64];
      time_t start_time;
      /* Do initialization the same way as we do in mysqld */
788
      start_time=time((time_t*) 0);
789
      randominit(&rand_st,(ulong) start_time,(ulong) start_time/2);
790

791
      if (argc < 2)
unknown's avatar
unknown committed
792 793 794 795 796
      {
	my_printf_error(0,"Too few arguments to change password",MYF(ME_BELL));
	return 1;
      }
      if (argv[1][0])
797 798 799 800 801 802
      {
        if (find_type(argv[0], &command_typelib, 2) == ADMIN_OLD_PASSWORD)
          make_scrambled_password_323(crypted_pw, argv[1]);
        else
          make_scrambled_password(crypted_pw, argv[1]);
      }
unknown's avatar
unknown committed
803 804 805 806 807 808 809 810
      else
	crypted_pw[0]=0;			/* No password */
      sprintf(buff,"set password='%s',sql_log_off=0",crypted_pw);

      if (mysql_query(mysql,"set sql_log_off=1"))
      {
	my_printf_error(0, "Can't turn off logging; error: '%s'",
			MYF(ME_BELL),mysql_error(mysql));
811
	return -1;
unknown's avatar
unknown committed
812 813 814
      }
      if (mysql_query(mysql,buff))
      {
815 816 817 818 819 820 821 822
	if (mysql_errno(mysql)!=1290)
	{
	  my_printf_error(0,"unable to change password; error: '%s'",
			  MYF(ME_BELL),mysql_error(mysql));
	  return -1;
	}
	else
	{
823 824 825 826 827 828 829 830 831 832 833
	  /*
	    We don't try to execute 'update mysql.user set..'
	    because we can't perfectly find out the host
	   */
	  my_printf_error(0,"\n"
			  "You cannot use 'password' command as mysqld runs\n"
			  " with grant tables disabled (was started with"
			  " --skip-grant-tables).\n"
			  "Use: \"mysqladmin flush-privileges password '*'\""
			  " instead", MYF(ME_BELL));
	  return -1;
834
	}
unknown's avatar
unknown committed
835 836 837 838 839 840
      }
      argc--; argv++;
      break;
    }

    case ADMIN_START_SLAVE:
841
      if (mysql_query(mysql, "START SLAVE"))
unknown's avatar
unknown committed
842 843 844
      {
	my_printf_error(0, "Error starting slave: %s", MYF(ME_BELL),
			mysql_error(mysql));
845
	return -1;
unknown's avatar
unknown committed
846 847 848 849 850
      }
      else
	puts("Slave started");
      break;
    case ADMIN_STOP_SLAVE:
851
      if (mysql_query(mysql, "STOP SLAVE"))
unknown's avatar
unknown committed
852 853 854
      {
	  my_printf_error(0, "Error stopping slave: %s", MYF(ME_BELL),
			  mysql_error(mysql));
855
	  return -1;
unknown's avatar
unknown committed
856 857 858 859
      }
      else
	puts("Slave stopped");
      break;
unknown's avatar
unknown committed
860

unknown's avatar
unknown committed
861 862 863
    case ADMIN_PING:
      mysql->reconnect=0;	/* We want to know of reconnects */
      if (!mysql_ping(mysql))
unknown's avatar
unknown committed
864 865 866 867
      {
	if (option_silent < 2)
	  puts("mysqld is alive");
      }
unknown's avatar
unknown committed
868 869 870 871 872 873 874 875 876 877 878 879
      else
      {
	if (mysql_errno(mysql) == CR_SERVER_GONE_ERROR)
	{
	  mysql->reconnect=1;
	  if (!mysql_ping(mysql))
	    puts("connection was down, but mysqld is now alive");
	}
	else
	{
	  my_printf_error(0,"mysqld doesn't answer to ping, error: '%s'",
			  MYF(ME_BELL),mysql_error(mysql));
880
	  return -1;
unknown's avatar
unknown committed
881 882 883 884 885
	}
      }
      mysql->reconnect=1;	/* Automatic reconnect is default */
      break;
    default:
886
      my_printf_error(0,"Unknown command: '%-.60s'",MYF(ME_BELL),argv[0]);
unknown's avatar
unknown committed
887 888 889 890 891 892
      return 1;
    }
  }
  return 0;
}

unknown's avatar
unknown committed
893
#include <help_start.h>
unknown's avatar
unknown committed
894 895 896 897 898

static void print_version(void)
{
  printf("%s  Ver %s Distrib %s, for %s on %s\n",my_progname,ADMIN_VERSION,
	 MYSQL_SERVER_VERSION,SYSTEM_TYPE,MACHINE_TYPE);
unknown's avatar
unknown committed
899
  NETWARE_SET_SCREEN_MODE(1);
unknown's avatar
unknown committed
900 901 902 903 904 905 906 907
}


static void usage(void)
{
  print_version();
  puts("Copyright (C) 2000 MySQL AB & MySQL Finland AB & TCX DataKonsult AB");
  puts("This software comes with ABSOLUTELY NO WARRANTY. This is free software,\nand you are welcome to modify and redistribute it under the GPL license\n");
908
  puts("Administration program for the mysqld daemon.");
unknown's avatar
unknown committed
909
  printf("Usage: %s [OPTIONS] command command....\n", my_progname);
910 911
  my_print_help(my_long_options);
  my_print_variables(my_long_options);
unknown's avatar
unknown committed
912 913 914 915 916 917 918 919 920 921 922 923 924 925
  print_defaults("my",load_default_groups);
  puts("\nWhere command is a one or more of: (Commands may be shortened)\n\
  create databasename	Create a new database\n\
  drop databasename	Delete a database and all its tables\n\
  extended-status       Gives an extended status message from the server\n\
  flush-hosts           Flush all cached hosts\n\
  flush-logs            Flush all logs\n\
  flush-status		Clear status variables\n\
  flush-tables          Flush all tables\n\
  flush-threads         Flush the thread cache\n\
  flush-privileges      Reload grant tables (same as reload)\n\
  kill id,id,...	Kill mysql threads");
#if MYSQL_VERSION_ID >= 32200
  puts("\
926 927
  password new-password Change old password to new-password, MySQL 4.1 hashing.\n\
  old-password new-password Change old password to new-password in old format.\n");
unknown's avatar
unknown committed
928 929 930 931 932 933 934 935
#endif
  puts("\
  ping			Check if mysqld is alive\n\
  processlist		Show list of active threads in server\n\
  reload		Reload grant tables\n\
  refresh		Flush all tables and close and open logfiles\n\
  shutdown		Take server down\n\
  status		Gives a short status message from the server\n\
936 937
  start-slave		Start slave\n\
  stop-slave		Stop slave\n\
unknown's avatar
unknown committed
938 939 940 941
  variables             Prints variables available\n\
  version		Get version info from server");
}

unknown's avatar
unknown committed
942 943
#include <help_end.h>

unknown's avatar
unknown committed
944 945 946 947 948 949 950
static int drop_db(MYSQL *mysql, const char *db)
{
  char name_buff[FN_REFLEN+20], buf[10];
  if (!option_force)
  {
    puts("Dropping the database is potentially a very bad thing to do.");
    puts("Any data stored in the database will be destroyed.\n");
951 952
    printf("Do you really want to drop the '%s' database [y/N] ",db);
    fflush(stdout);
unknown's avatar
unknown committed
953 954 955 956 957 958 959
    VOID(fgets(buf,sizeof(buf)-1,stdin));
    if ((*buf != 'y') && (*buf != 'Y'))
    {
      puts("\nOK, aborting database drop!");
      return -1;
    }
  }
960
  sprintf(name_buff,"drop database `%.*s`",FN_REFLEN,db);
unknown's avatar
unknown committed
961 962
  if (mysql_query(mysql,name_buff))
  {
963
    my_printf_error(0,"DROP DATABASE %s failed;\nerror: '%s'",MYF(ME_BELL),
unknown's avatar
unknown committed
964 965 966 967 968 969 970 971 972 973 974 975 976 977 978 979
		    db,mysql_error(mysql));
    return 1;
  }
  printf("Database \"%s\" dropped\n",db);
  return 0;
}


static void nice_time(ulong sec,char *buff)
{
  ulong tmp;

  if (sec >= 3600L*24)
  {
    tmp=sec/(3600L*24);
    sec-=3600L*24*tmp;
980
    buff=int10_to_str(tmp, buff, 10);
unknown's avatar
unknown committed
981 982 983 984 985 986
    buff=strmov(buff,tmp > 1 ? " days " : " day ");
  }
  if (sec >= 3600L)
  {
    tmp=sec/3600L;
    sec-=3600L*tmp;
987
    buff=int10_to_str(tmp, buff, 10);
unknown's avatar
unknown committed
988 989 990 991 992 993
    buff=strmov(buff,tmp > 1 ? " hours " : " hour ");
  }
  if (sec >= 60)
  {
    tmp=sec/60;
    sec-=60*tmp;
994
    buff=int10_to_str(tmp, buff, 10);
unknown's avatar
unknown committed
995 996
    buff=strmov(buff," min ");
  }
997
  strmov(int10_to_str(sec, buff, 10)," sec");
unknown's avatar
unknown committed
998 999 1000 1001 1002 1003 1004 1005 1006 1007 1008 1009
}


static void print_header(MYSQL_RES *result)
{
  MYSQL_FIELD *field;

  print_top(result);
  mysql_field_seek(result,0);
  putchar('|');
  while ((field = mysql_fetch_field(result)))
  {
1010
    printf(" %-*s|",(int) field->max_length+1,field->name);
unknown's avatar
unknown committed
1011 1012 1013 1014 1015 1016 1017 1018 1019 1020 1021 1022 1023 1024 1025
  }
  putchar('\n');
  print_top(result);
}


static void print_top(MYSQL_RES *result)
{
  uint i,length;
  MYSQL_FIELD *field;

  putchar('+');
  mysql_field_seek(result,0);
  while((field = mysql_fetch_field(result)))
  {
unknown's avatar
unknown committed
1026
    if ((length=(uint) strlen(field->name)) > field->max_length)
unknown's avatar
unknown committed
1027 1028 1029 1030 1031 1032 1033 1034 1035 1036 1037 1038 1039 1040 1041 1042 1043 1044 1045 1046 1047 1048 1049 1050 1051 1052 1053 1054 1055 1056 1057 1058 1059 1060 1061 1062 1063 1064
      field->max_length=length;
    else
      length=field->max_length;
    for (i=length+2 ; i--> 0 ; )
      putchar('-');
    putchar('+');
  }
  putchar('\n');
}


/* 3.rd argument, uint row, is not in use. Don't remove! */
static void print_row(MYSQL_RES *result, MYSQL_ROW cur,
		      uint row __attribute__((unused)))
{
  uint i,length;
  MYSQL_FIELD *field;

  putchar('|');
  mysql_field_seek(result,0);
  for (i=0 ; i < mysql_num_fields(result); i++)
  {
    field = mysql_fetch_field(result);
    length=field->max_length;
    printf(" %-*s|",length+1,cur[i] ? (char*) cur[i] : "");
  }
  putchar('\n');
}


static void print_relative_row(MYSQL_RES *result, MYSQL_ROW cur, uint row)
{
  ulonglong tmp;
  char buff[22];
  MYSQL_FIELD *field;

  mysql_field_seek(result, 0);
  field = mysql_fetch_field(result);
1065
  printf("| %-*s|", (int) field->max_length + 1, cur[0]);
unknown's avatar
unknown committed
1066 1067

  field = mysql_fetch_field(result);
unknown's avatar
unknown committed
1068
  tmp = cur[1] ? strtoull(cur[1], NULL, 10) : (ulonglong) 0;
1069
  printf(" %-*s|\n", (int) field->max_length + 1,
unknown's avatar
unknown committed
1070 1071 1072 1073 1074 1075 1076 1077 1078 1079 1080 1081
	 llstr((tmp - last_values[row]), buff));
  last_values[row] = tmp;
}


static void print_relative_row_vert(MYSQL_RES *result __attribute__((unused)),
				    MYSQL_ROW cur,
				    uint row __attribute__((unused)))
{
  uint length;
  ulonglong tmp;
  char buff[22];
unknown's avatar
unknown committed
1082

unknown's avatar
unknown committed
1083 1084 1085
  if (!row)
    putchar('|');

unknown's avatar
unknown committed
1086
  tmp = cur[1] ? strtoull(cur[1], NULL, 10) : (ulonglong) 0;
1087
  printf(" %-*s|", ex_val_max_len[row] + 1,
unknown's avatar
unknown committed
1088 1089 1090
	 llstr((tmp - last_values[row]), buff));

  /* Find the minimum row length needed to output the relative value */
unknown's avatar
unknown committed
1091
  if ((length=(uint) strlen(buff) > ex_val_max_len[row]) && ex_status_printed)
unknown's avatar
unknown committed
1092 1093 1094 1095 1096 1097 1098 1099 1100 1101 1102 1103 1104 1105 1106 1107 1108 1109 1110 1111 1112 1113 1114 1115 1116 1117 1118 1119 1120 1121 1122 1123 1124 1125 1126 1127 1128 1129 1130 1131 1132 1133 1134 1135 1136 1137 1138 1139 1140 1141 1142 1143 1144 1145 1146 1147 1148 1149 1150 1151 1152 1153 1154 1155 1156 1157 1158 1159 1160
    ex_val_max_len[row] = length;
  last_values[row] = tmp;
}


static void store_values(MYSQL_RES *result)
{
  uint i;
  MYSQL_ROW row;
  MYSQL_FIELD *field;

  field = mysql_fetch_field(result);
  max_var_length = field->max_length;
  field = mysql_fetch_field(result);
  max_val_length = field->max_length;

  for (i = 0; (row = mysql_fetch_row(result)); i++)
  {
    strmov(ex_var_names[i], row[0]);
    last_values[i]=strtoull(row[1],NULL,10);
    ex_val_max_len[i]=2;		/* Default print width for values */
  }
  ex_var_count = i;
  return;
}


static void print_relative_header()
{
  uint i;

  putchar('|');
  for (i = 0; i < ex_var_count; i++)
    printf(" %-*s|", ex_val_max_len[i] + 1, truncated_var_names[i]);
  putchar('\n');
}


static void print_relative_line()
{
  uint i;

  putchar('+');
  for (i = 0; i < ex_var_count; i++)
  {
    uint j;
    for (j = 0; j < ex_val_max_len[i] + 2; j++)
      putchar('-');
    putchar('+');
  }
  putchar('\n');
}


static void truncate_names()
{
  uint i;
  char *ptr,top_line[MAX_TRUNC_LENGTH+4+NAME_LEN+22+1],buff[22];

  ptr=top_line;
  *ptr++='+';
  ptr=strfill(ptr,max_var_length+2,'-');
  *ptr++='+';
  ptr=strfill(ptr,MAX_TRUNC_LENGTH+2,'-');
  *ptr++='+';
  ptr=strfill(ptr,max_val_length+2,'-');
  *ptr++='+';
  *ptr=0;
  puts(top_line);
unknown's avatar
unknown committed
1161

unknown's avatar
unknown committed
1162 1163 1164 1165 1166 1167 1168 1169 1170 1171 1172 1173 1174 1175 1176 1177 1178 1179 1180 1181 1182 1183 1184 1185 1186 1187 1188 1189 1190 1191 1192 1193
  for (i = 0 ; i < ex_var_count; i++)
  {
    uint sfx=1,j;
    printf("| %-*s|", max_var_length + 1, ex_var_names[i]);
    ptr = ex_var_names[i];
    /* Make sure no two same truncated names will become */
    for (j = 0; j < i; j++)
      if (*truncated_var_names[j] == *ptr)
	sfx++;

    truncated_var_names[i][0]= *ptr;		/* Copy first var char */
    int10_to_str(sfx, truncated_var_names[i]+1,10);
    printf(" %-*s|", MAX_TRUNC_LENGTH + 1, truncated_var_names[i]);
    printf(" %-*s|\n", max_val_length + 1, llstr(last_values[i],buff));
  }
  puts(top_line);
  return;
}


static my_bool get_pidfile(MYSQL *mysql, char *pidfile)
{
  MYSQL_RES* result;

  if (mysql_query(mysql, "SHOW VARIABLES LIKE 'pid_file'"))
  {
    my_printf_error(0,"query failed; error: '%s'",MYF(ME_BELL),
		    mysql_error(mysql));
  }
  result = mysql_store_result(mysql);
  if (result)
  {
1194 1195 1196
    MYSQL_ROW row=mysql_fetch_row(result);
    if (row)
      strmov(pidfile, row[1]);
unknown's avatar
unknown committed
1197
    mysql_free_result(result);
1198
    return row == 0;				/* Error if row = 0 */
unknown's avatar
unknown committed
1199 1200 1201 1202
  }
  return 1;					/* Error */
}

unknown's avatar
unknown committed
1203 1204 1205
/*
  Return 1 if pid file didn't disappear or change
*/
unknown's avatar
unknown committed
1206

unknown's avatar
unknown committed
1207 1208
static my_bool wait_pidfile(char *pidfile, time_t last_modified,
			    struct stat *pidfile_status)
unknown's avatar
unknown committed
1209 1210
{
  char buff[FN_REFLEN];
unknown's avatar
unknown committed
1211 1212 1213
  int error= 1;
  uint count= 0;
  DBUG_ENTER("wait_pidfile");
unknown's avatar
unknown committed
1214

1215
  system_filename(buff, pidfile);
unknown's avatar
unknown committed
1216
  do
unknown's avatar
unknown committed
1217
  {
unknown's avatar
unknown committed
1218 1219 1220 1221 1222 1223 1224 1225 1226 1227 1228 1229 1230 1231 1232 1233 1234 1235 1236 1237 1238
    int fd;
    if ((fd= my_open(buff, O_RDONLY, MYF(0))) < 0)
    {
      error= 0;
      break;
    }
    (void) my_close(fd,MYF(0));
    if (last_modified && !stat(pidfile, pidfile_status))
    {
      if (last_modified != pidfile_status->st_mtime)
      {
	/* File changed;  Let's assume that mysqld did restart */
	if (opt_verbose)
	  printf("pid file '%s' changed while waiting for it to disappear!\nmysqld did probably restart\n",
		 buff);
	error= 0;
	break;
      }
    }
    if (count++ == opt_shutdown_timeout)
      break;
unknown's avatar
unknown committed
1239
    sleep(1);
unknown's avatar
unknown committed
1240 1241 1242
  } while (!interrupted);

  if (error)
unknown's avatar
unknown committed
1243
  {
unknown's avatar
unknown committed
1244
    DBUG_PRINT("warning",("Pid file didn't disappear"));
unknown's avatar
unknown committed
1245 1246 1247 1248
    fprintf(stderr,
	    "Warning;  Aborted waiting on pid file: '%s' after %d seconds\n",
	    buff, count-1);
  }
unknown's avatar
unknown committed
1249
  DBUG_RETURN(error);
unknown's avatar
unknown committed
1250
}