开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 数据库系统 > MySQL数据库 > 查看源码
mysql.cc
资源名称：mysql-3.23.35.tar.gz　[点击查看]
上传用户：tsgydb
上传日期：2007-04-14
资源大小：10674k
文件大小：63k
源码类别：

MySQL数据库

开发平台：

Visual C++

mysql.cc：源码内容
  1. /* Copyright (C) 2000 MySQL AB & MySQL Finland AB & TCX DataKonsult AB
  2.    
  3.    This program is free software; you can redistribute it and/or modify
  4.    it under the terms of the GNU General Public License as published by
  5.    the Free Software Foundation; either version 2 of the License, or
  6.    (at your option) any later version.
  7.    
  8.    This program is distributed in the hope that it will be useful,
  9.    but WITHOUT ANY WARRANTY; without even the implied warranty of
  10.    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  11.    GNU General Public License for more details.
  12.    
  13.    You should have received a copy of the GNU General Public License
  14.    along with this program; if not, write to the Free Software
  15.    Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */
  17. /* mysql command tool
  18.  * Commands compatible with mSQL by David J. Hughes
  19.  *
  20.  * Written by:
  21.  *   Michael 'Monty' Widenius
  22.  *   Andi Gutmans  <andi@zend.com>
  23.  *   Zeev Suraski <zeev@zend.com>
  24.  *   Jani Tolonen <jani@mysql.com>
  25.  *
  26.  **/
  28. #include <global.h>
  29. #include <my_sys.h> 
  30. #include <m_string.h>
  31. #include <m_ctype.h>
  32. #include "mysql.h"
  33. #include "errmsg.h"
  34. #include <my_dir.h>
  35. #ifndef __GNU_LIBRARY__
  36. #define __GNU_LIBRARY__       // Skip warnings in getopt.h
  37. #endif
  38. #include <getopt.h>
  39. #include "my_readline.h"
  40. #include <signal.h>
  42. const char *VER="11.13";
  44. /* Don't try to make a nice table if the data is too big */
  45. #define MAX_COLUMN_LENGTH      1024
  47. gptr sql_alloc(unsigned size);      // Don't use mysqld alloc for these
  48. void sql_element_free(void *ptr);
  49. #include "sql_string.h"
  51. extern "C" {
  52. #if defined(HAVE_CURSES_H) && defined(HAVE_TERM_H)
  53. #include <curses.h>
  54. #include <term.h>
  55. #else
  56. #if defined(HAVE_TERMIOS_H)
  57. #include <termios.h>
  58. #include <unistd.h>
  59. #elif defined(HAVE_TERMBITS_H)
  60. #include <termbits.h>
  61. #elif defined(HAVE_ASM_TERMBITS_H) && (!defined __GLIBC__ || !(__GLIBC__ > 2 || __GLIBC__ == 2 && __GLIBC_MINOR__ > 0))
  62. #include <asm/termbits.h> // Standard linux
  63. #endif
  64. #undef VOID
  65. #if defined(HAVE_TERMCAP_H)
  66. #include <termcap.h>
  67. #else
  68. #ifdef HAVE_CURSES_H
  69. #include <curses.h>
  70. #endif
  71. #undef SYSV // hack to avoid syntax error
  72. #ifdef HAVE_TERM_H
  73. #include <term.h>
  74. #endif
  75. #endif
  76. #endif
  78. #undef bcmp // Fix problem with new readline
  79. #undef bzero
  80. #ifdef __WIN__
  81. #include <conio.h>
  82. #else
  83. #include <readline/readline.h>
  84. #define HAVE_READLINE
  85. #endif
  86.   //int vidattr(long unsigned int attrs); // Was missing in sun curses
  87. }
  89. #if !defined(HAVE_VIDATTR)
  90. #undef vidattr
  91. #define vidattr(A) {} // Can't get this to work
  92. #endif
  94. #ifdef __WIN__
  95. #define cmp_database(A,B) my_strcasecmp((A),(B))
  96. #else
  97. #define cmp_database(A,B) strcmp((A),(B))
  98. #endif
  100. #include "completion_hash.h"
  102. typedef struct st_status
  103. {
  104.   int exit_status;
  105.   ulong query_start_line;
  106.   char *file_name;
  107.   LINE_BUFFER *line_buff;
  108.   bool batch,add_to_history;
  109. } STATUS;
  112. static HashTable ht;
  114. enum enum_info_type { INFO_INFO,INFO_ERROR,INFO_RESULT};
  115. typedef enum enum_info_type INFO_TYPE;
  117. static MYSQL mysql; /* The connection */
  118. static bool info_flag=0,ignore_errors=0,wait_flag=0,quick=0,
  119.     connected=0,opt_raw_data=0,unbuffered=0,output_tables=0,
  120.     no_rehash=0,skip_updates=0,safe_updates=0,one_database=0,
  121.     opt_compress=0,
  122.     vertical=0,skip_line_numbers=0,skip_column_names=0,opt_html=0,
  123.     opt_nopager=1, opt_outfile=0, no_named_cmds=1;
  124. static uint verbose=0,opt_silent=0,opt_mysql_port=0;
  125. static my_string opt_mysql_unix_port=0;
  126. static int connect_flag=CLIENT_INTERACTIVE;
  127. static char *current_host,*current_db,*current_user=0,*opt_password=0,
  128.             *default_charset;
  129. static char *histfile;
  130. static String glob_buffer,old_buffer;
  131. static int wait_time = 5;
  132. static STATUS status;
  133. static ulong select_limit,max_join_size,opt_connect_timeout=0;
  134. static char default_pager[FN_REFLEN];
  135. char pager[FN_REFLEN], outfile[FN_REFLEN];
  136. FILE *PAGER, *OUTFILE;
  138. #include "sslopt-vars.h"
  140. #ifndef DBUG_OFF
  141. const char *default_dbug_option="d:t:o,/tmp/mysql.trace";
  142. #endif
  144. void tee_fprintf(FILE *file, const char *fmt, ...);
  145. void tee_fputs(const char *s, FILE *file);
  146. void tee_puts(const char *s, FILE *file);
  147. void tee_putc(int c, FILE *file);
  148. /* The names of functions that actually do the manipulation. */
  149. static int get_options(int argc,char **argv);
  150. static int com_quit(String *str,char*),
  151.    com_go(String *str,char*), com_ego(String *str,char*),
  152.    com_print(String *str,char*),
  153.    com_help(String *str,char*), com_clear(String *str,char*),
  154.    com_connect(String *str,char*), com_status(String *str,char*),
  155.    com_use(String *str,char*), com_source(String *str, char*),
  156.    com_rehash(String *str, char*), com_tee(String *str, char*),
  157.            com_notee(String *str, char*);
  159. #ifndef __WIN__
  160. static int com_nopager(String *str, char*), com_pager(String *str, char*),
  161.    com_edit(String *str,char*);
  162. #endif
  164. static int read_lines(bool execute_commands);
  165. static int sql_connect(char *host,char *database,char *user,char *password,
  166.        uint silent);
  167. static int put_info(const char *str,INFO_TYPE info,uint error=0);
  168. static void safe_put_field(const char *pos,ulong length);
  169. static void init_pager();
  170. static void end_pager();
  171. static void init_tee();
  172. static void end_tee();
  174. /* A structure which contains information on the commands this program
  175.    can understand. */
  177. typedef struct {
  178.   const char *name; /* User printable name of the function. */
  179.   char cmd_char; /* msql command character */
  180.   int (*func)(String *str,char *); /* Function to call to do the job. */
  181.   bool takes_params; /* Max parameters for command */
  182.   const char *doc; /* Documentation for this function.  */
  183. } COMMANDS;
  185. static COMMANDS commands[] = {
  186.   { "help",   'h', com_help,   0, "Display this help." },
  187.   { "?",      '?', com_help,   0, "Synonym for `help'." },
  188.   { "clear",  'c', com_clear,  0, "Clear command."},
  189.   { "connect",'r', com_connect,1,
  190.     "Reconnect to the server. Optional arguments are db and host." },
  191. #ifndef __WIN__
  192.   { "edit",   'e', com_edit,   0, "Edit command with $EDITOR."},
  193. #endif
  194.   { "ego",    'G', com_ego,    0,
  195.     "Send command to mysql server, display result vertically."},
  196.   { "exit",   'q', com_quit,   0, "Exit mysql. Same as quit."},
  197.   { "go",     'g', com_go,     0, "Send command to mysql server." },
  198. #ifndef __WIN__
  199.   { "nopager",'n', com_nopager,0, "Disable pager, print to stdout." },
  200. #endif
  201.   { "notee",  't', com_notee,  0, "Don't write into outfile." },
  202. #ifndef __WIN__
  203.   { "pager",  'P', com_pager,  1, 
  204.     "Set PAGER [to_pager]. Print the query results via PAGER." },
  205. #endif
  206.   { "print",  'p', com_print,  0, "Print current command." },
  207.   { "quit",   'q', com_quit,   0, "Quit mysql." },
  208.   { "rehash", '#', com_rehash, 0, "Rebuild completion hash." },
  209.   { "source", '.', com_source, 1,
  210.     "Execute a SQL script file. Takes a file name as an argument."},
  211.   { "status", 's', com_status, 0, "Get status information from the server."},
  212.   { "tee",    'T', com_tee,    1, 
  213.     "Set outfile [to_outfile]. Append everything into given outfile." },
  214.   { "use",    'u', com_use,    1,
  215.     "Use another database. Takes database name as argument." },
  217.   /* Get bash-like expansion for some commands */
  218.   { "create table",     0, 0, 0, ""},
  219.   { "create database",  0, 0, 0, ""},
  220.   { "drop",             0, 0, 0, ""},
  221.   { "select",           0, 0, 0, ""},
  222.   { "insert",           0, 0, 0, ""},
  223.   { "replace",          0, 0, 0, ""},
  224.   { "update",           0, 0, 0, ""},
  225.   { "delete",           0, 0, 0, ""},
  226.   { "explain",          0, 0, 0, ""},
  227.   { "show databases",   0, 0, 0, ""},
  228.   { "show fields from", 0, 0, 0, ""},
  229.   { "show keys from",   0, 0, 0, ""},
  230.   { "show tables",      0, 0, 0, ""},
  231.   { "load data from",   0, 0, 0, ""},
  232.   { "alter table",      0, 0, 0, ""},
  233.   { "set option",       0, 0, 0, ""},
  234.   { "lock tables",      0, 0, 0, ""},
  235.   { "unlock tables",    0, 0, 0, ""},
  236.   { (char *)NULL,       0, 0, 0, ""}
  237. };
  239. static const char *load_default_groups[]= { "mysql","client",0 };
  241. #ifdef HAVE_READLINE
  242. extern "C" void add_history(char *command); /* From readline directory */
  243. extern "C" int read_history(char *command);
  244. extern "C" int write_history(char *command);
  245. static void initialize_readline (char *name);
  246. #endif
  248. static COMMANDS *find_command (char *name,char cmd_name);
  249. static bool add_line(String &buffer,char *line,char *in_string);
  250. static void remove_cntrl(String &buffer);
  251. static void print_table_data(MYSQL_RES *result);
  252. static void print_table_data_html(MYSQL_RES *result);
  253. static void print_tab_data(MYSQL_RES *result);
  254. static void print_table_data_vertically(MYSQL_RES *result);
  255. static ulong start_timer(void);
  256. static void end_timer(ulong start_time,char *buff);
  257. static void mysql_end_timer(ulong start_time,char *buff);
  258. static void nice_time(double sec,char *buff,bool part_second);
  259. static sig_handler mysql_end(int sig);
  262. int main(int argc,char *argv[])
  263. {
  264.   char buff[80];
  266.   MY_INIT(argv[0]);
  267.   DBUG_ENTER("main");
  268.   DBUG_PROCESS(argv[0]);
  270.   strmov(outfile, "");   // no (default) outfile, unless given at least once
  271.   strmov(pager, "stdout"); // the default, if --pager wasn't given
  272.   if (!isatty(0) || !isatty(1))
  273.   {
  274.     status.batch=1; opt_silent=1;
  275.     ignore_errors=0;
  276.   }
  277.   else
  278.     status.add_to_history=1;
  279.   status.exit_status=1;
  280.   load_defaults("my",load_default_groups,&argc,&argv);
  281.   if (get_options(argc,(char **) argv))
  282.   {
  283.     my_end(0);
  284.     exit(1);
  285.   }
  286.   free_defaults(argv);
  287.   if (status.batch && !status.line_buff &&
  288.       !(status.line_buff=batch_readline_init(max_allowed_packet+512,stdin)))
  289.     exit(1);
  290.   glob_buffer.realloc(512);
  291.   completion_hash_init(&ht,50);
  292.   if (sql_connect(current_host,current_db,current_user,opt_password,
  293.   opt_silent))
  294.   {
  295.     quick=1; // Avoid history
  296.     status.exit_status=1;
  297.     mysql_end(-1);
  298.   }
  299.   if (!status.batch)
  300.     ignore_errors=1; // Don't abort monitor
  301.   signal(SIGINT, mysql_end); // Catch SIGINT to clean up
  303.   /*
  304.   **  Run in interactive mode like the ingres/postgres monitor
  305.   */
  307.   put_info("Welcome to the MySQL monitor.  Commands end with ; or \g.",
  308.    INFO_INFO);
  309.   sprintf((char*) glob_buffer.ptr(),
  310.   "Your MySQL connection id is %ld to server version: %sn",
  311.   mysql_thread_id(&mysql),mysql_get_server_info(&mysql));
  312.   put_info((char*) glob_buffer.ptr(),INFO_INFO);
  314. #ifdef HAVE_READLINE
  315.   initialize_readline(my_progname);
  316.   if (!status.batch && !quick && !opt_html)
  317.   {
  318.     /*read-history from file, default ~/.mysql_history*/
  319.     if (getenv("MYSQL_HISTFILE"))
  320.       histfile=my_strdup(getenv("MYSQL_HISTFILE"),MYF(MY_WME));
  321.     else if (getenv("HOME"))
  322.     {
  323.       histfile=(char*) my_malloc((uint) strlen(getenv("HOME"))
  324.  + (uint) strlen("/.mysql_history")+2,
  325.  MYF(MY_WME));
  326.       if (histfile)
  327. sprintf(histfile,"%s/.mysql_history",getenv("HOME"));
  328.     }
  329.     if (histfile)
  330.     {
  331.       if (verbose)
  332. tee_fprintf(stdout, "Reading history-file %sn",histfile);
  333.       read_history(histfile);
  334.     }
  335.   }
  336. #endif
  337.   sprintf(buff, 
  338.   "Type 'help;' or '\h' for help. Type '\c' to clear the buffern");
  339.   put_info(buff,INFO_INFO);
  340.   status.exit_status=read_lines(1); // read lines and execute them
  341.   if (opt_outfile)
  342.     end_tee();
  343.   mysql_end(0);
  344. #ifndef _lint
  345.   DBUG_RETURN(0); // Keep compiler happy
  346. #endif
  347. }
  349. sig_handler mysql_end(int sig)
  350. {
  351.   if (connected)
  352.     mysql_close(&mysql);
  353. #ifdef HAVE_READLINE
  354.   if (!status.batch && !quick && ! opt_html)
  355.   {
  356.     /* write-history */
  357.     if (verbose)
  358.       tee_fprintf(stdout, "Writing history-file %sn",histfile);
  359.     write_history(histfile);
  360.   }
  361.   batch_readline_end(status.line_buff);
  362.   completion_hash_free(&ht);
  363. #endif
  364.   if (sig >= 0)
  365.     put_info(sig ? "Aborted" : "Bye", INFO_RESULT);
  366.   glob_buffer.free();
  367.   old_buffer.free();
  368.   my_free(opt_password,MYF(MY_ALLOW_ZERO_PTR));
  369.   my_free(opt_mysql_unix_port,MYF(MY_ALLOW_ZERO_PTR));
  370.   my_free(histfile,MYF(MY_ALLOW_ZERO_PTR));
  371.   my_free(current_db,MYF(MY_ALLOW_ZERO_PTR));
  372.   my_free(current_host,MYF(MY_ALLOW_ZERO_PTR));
  373.   my_free(current_user,MYF(MY_ALLOW_ZERO_PTR));
  374.   my_end(info_flag ? MY_CHECK_ERROR | MY_GIVE_INFO : 0);
  375.   exit(status.exit_status);
  376. }
  378. enum options {OPT_CHARSETS_DIR=256, OPT_DEFAULT_CHARSET,
  379.       OPT_PAGER, OPT_NOPAGER, OPT_TEE, OPT_NOTEE} ;
  382. static struct option long_options[] =
  383. {
  384.   {"i-am-a-dummy",  optional_argument,    0, 'U'},
  385.   {"batch",     no_argument,    0, 'B'},
  386.   {"character-sets-dir",required_argument, 0, OPT_CHARSETS_DIR},
  387.   {"compress",     no_argument,    0, 'C'},
  388. #ifndef DBUG_OFF
  389.   {"debug",     optional_argument,    0, '#'},
  390. #endif
  391.   {"database",     required_argument,     0, 'D'},
  392.   {"debug-info",    no_argument,    0, 'T'},
  393.   {"default-character-set", required_argument,0, OPT_DEFAULT_CHARSET},
  394.   {"enable-named-commands", no_argument,   0, 'G'},
  395.   {"execute",     required_argument,    0, 'e'},
  396.   {"force",     no_argument,    0, 'f'},
  397.   {"help",     no_argument,    0, '?'},
  398.   {"html",     no_argument,    0, 'H'},
  399.   {"host",     required_argument,    0, 'h'},
  400.   {"ignore-spaces", no_argument,    0, 'i'},
  401.   {"no-auto-rehash",no_argument,    0, 'A'},
  402.   {"no-named-commands", no_argument,       0, 'g'},
  403.   {"no-tee",        no_argument,           0, OPT_NOTEE},
  404. #ifndef __WIN__
  405.   {"no-pager",      no_argument,           0, OPT_NOPAGER},
  406.   {"nopager",       no_argument,           0, OPT_NOPAGER},  /* we are kind */
  407.   {"pager",         optional_argument,     0, OPT_PAGER},
  408. #endif
  409.   {"notee",         no_argument,           0, OPT_NOTEE},    /* we are kind */
  410.   {"tee",           required_argument,     0, OPT_TEE},
  411.   {"one-database",  no_argument,    0, 'o'},
  412.   {"password",     optional_argument,    0, 'p'},
  413. #ifdef __WIN__
  414.   {"pipe",     no_argument,    0, 'W'},
  415. #endif
  416.   {"port",     required_argument,    0, 'P'},
  417.   {"quick",     no_argument,    0, 'q'},
  418.   {"set-variable",  required_argument,    0, 'O'},
  419.   {"raw",     no_argument,    0, 'r'},
  420.   {"safe-updates",  optional_argument,    0, 'U'},
  421.   {"silent",     no_argument,    0, 's'},
  422.   {"skip-column-names",no_argument,    0, 'N'},
  423.   {"skip-line-numbers",no_argument,    0, 'L'},
  424.   {"socket",     required_argument,    0, 'S'},
  425. #include "sslopt-longopts.h"
  426.   {"table",     no_argument,    0, 't'},
  427. #ifndef DONT_ALLOW_USER_CHANGE
  428.   {"user",     required_argument,    0, 'u'},
  429. #endif
  430.   {"unbuffered",    no_argument,    0, 'n'},
  431.   {"verbose",     no_argument,    0, 'v'},
  432.   {"version",     no_argument,    0, 'V'},
  433.   {"vertical",     no_argument,    0, 'E'},
  434.   {"wait",     optional_argument,    0, 'w'},
  435.   {0, 0, 0, 0}
  436. };
  439. CHANGEABLE_VAR changeable_vars[] = {
  440.   { "connect_timeout", (long*) &opt_connect_timeout, 0, 0, 3600*12, 0, 1},
  441.   { "max_allowed_packet", (long*) &max_allowed_packet,16*1024L*1024L,4096,
  442.     24*1024L*1024L, MALLOC_OVERHEAD,1024},
  443.   { "net_buffer_length",(long*) &net_buffer_length,16384,1024,24*1024*1024L,
  444.     MALLOC_OVERHEAD,1024},
  445.   { "select_limit", (long*) &select_limit, 1000L, 1, ~0L, 0, 1},
  446.   { "max_join_size", (long*) &max_join_size, 1000000L, 1, ~0L, 0, 1},
  447.   { 0, 0, 0, 0, 0, 0, 0}
  448. };
  451. static void usage(int version)
  452. {
  453.   printf("%s  Ver %s Distrib %s, for %s (%s)n",
  454.  my_progname, VER, MYSQL_SERVER_VERSION, SYSTEM_TYPE, MACHINE_TYPE);
  455.   if (version)
  456.     return;
  457.   puts("Copyright (C) 2000 MySQL AB & MySQL Finland AB & TCX DataKonsult AB");
  458.   puts("This software comes with ABSOLUTELY NO WARRANTY. This is free software,nand you are welcome to modify and redistribute it under the GPL licensen");
  459.   printf("Usage: %s [OPTIONS] [database]n", my_progname);
  460.   printf("n
  461.   -?, --help Display this help and exit.n
  462.   -A, --no-auto-rehash  No automatic rehashing. One has to use 'rehash' ton
  463. get table and field completion. This gives a quickern
  464. start of mysql and disables rehashing on reconnect.n
  465.   -B, --batch Print results with a tab as separator, each row onn
  466. a new line. Doesn't use history file.n
  467.   --character-sets-dir=...n
  468.                         Directory where character sets are located.n
  469.   -C, --compress Use compression in server/client protocol.n");
  470. #ifndef DBUG_OFF
  471.   printf("
  472.   -#, --debug[=...]     Debug log. Default is '%s'.n",default_dbug_option);
  473. #endif
  474.   printf("
  475.   -D, --database=.. Database to use.n
  476.   --default-character-set=...n
  477.                         Set the default character set.n
  478.   -e, --execute=...     Execute command and quit. (Output like with --batch)n
  479.   -E, --vertical        Print the output of a query (rows) vertically.n
  480.   -f, --force           Continue even if we get an sql error.n
  481.   -g, --no-named-commandsn
  482. Named commands are disabled. Use \* form only, orn
  483.                         use named commands only in the beginning of a linen
  484.                         ending with a semicolon (;) Since version 10.9 then
  485.                         client now starts with this option ENABLED byn
  486.                         default! Disable with '-G'. Long format commandsn
  487.                         still work from the first line.n
  488.   -G, --enable-named-commandsn
  489.                         Named commands are enabled. Opposite to -g.n
  490.   -i, --ignore-space Ignore space after function names.n
  491.   -h, --host=... Connect to host.n
  492.   -H, --html Produce HTML output.n
  493.   -L, --skip-line-numbersn
  494.                         Don't write line number for errors.n");
  495. #ifndef __WIN__
  496.   printf("
  497.   --no-pager            Disable pager and print to stdout. See interactiven
  498.                         help (\h) also.n");
  499. #endif
  500.   printf("
  501.   --no-tee              Disable outfile. See interactive help (\h) also.n
  502.   -n, --unbuffered Flush buffer after each query.n
  503.   -N, --skip-column-namesn
  504.                         Don't write column names in results.n
  505.   -O, --set-variable var=optionn
  506. Give a variable an value. --help lists variables.n
  507.   -o, --one-database Only update the default database. This is usefuln
  508. for skipping updates to other database in the updaten
  509. log.n");
  510. #ifndef __WIN__
  511.   printf("
  512.   --pager[=...]         Pager to use to display results. If you don't supplyn
  513.                         an option the default pager is taken from your ENVn
  514.                         variable PAGER (%s).n
  515.                         Valid pagers are less, more, cat [> filename], etc.n
  516.                         See interactive help (\h) also. This option doesn
  517.                         not work in batch mode.n", getenv("PAGER") ? getenv("PAGER") : "");
  518. #endif
  519.   printf("
  520.   -p[password], --password[=...]n
  521. Password to use when connecting to servern
  522. If password is not given it's asked from the tty.n");
  523. #ifdef __WIN__
  524.   puts("  -W, --pipe Use named pipes to connect to server");
  525. #endif
  526.   printf("n
  527.   -P, --port=... Port number to use for connection.n
  528.   -q, --quick Don't cache result, print it row by row. This mayn
  529. slow down the server if the output is suspended.n
  530. Doesn't use history file.n
  531.   -r, --raw Write fields without conversion. Used with --batchn
  532.   -s, --silent Be more silent.n
  533.   -S  --socket=... Socket file to use for connection.n");
  534. #include "sslopt-usage.h"
  535.   printf("
  536.   -t, --table Output in table format.n
  537.   -T, --debug-info Print some debug info at exit.n
  538.   --tee=...             Append everything into outfile. See interactive helpn
  539.                         (\h) also. Does not work in batch mode.n");
  540. #ifndef DONT_ALLOW_USER_CHANGE
  541.   printf("
  542.   -u, --user=# User for login if not current user.n");
  543. #endif
  544.   printf("
  545.   -U, --safe-updates[=#], --i-am-a-dummy[=#]n
  546.         Only allow UPDATE and DELETE that uses keys.n
  547.   -v, --verbose Write more. (-v -v -v gives the table output format)n
  548.   -V, --version Output version information and exit.n
  549.   -w, --wait Wait and retry if connection is down.n");
  550.   print_defaults("my",load_default_groups);
  552.   printf("nPossible variables for option --set-variable (-O) are:n");
  553.   for (uint i=0 ; changeable_vars[i].name ; i++)
  554.     printf("%-20s  current value: %lun",
  555.    changeable_vars[i].name,
  556.    (ulong) *changeable_vars[i].varptr);
  557. }
  560. static int get_options(int argc, char **argv)
  561. {
  562.   int c,option_index=0;
  563.   bool tty_password=0;
  565.   set_all_changeable_vars(changeable_vars);
  566.   while ((c=getopt_long(argc,argv,
  567. "?ABCD:LfgGHinNoqrstTU::vVw::WEe:h:O:P:S:u:#::p::",
  568. long_options, &option_index)) != EOF)
  569.   {
  570.     switch(c) {
  571.     case OPT_DEFAULT_CHARSET:
  572.       default_charset= optarg;
  573.       break;
  574.     case OPT_CHARSETS_DIR:
  575.       charsets_dir= optarg;
  576.       break;
  577.     case OPT_TEE:
  578.       if (!opt_outfile && strlen(optarg))
  579.       {
  580. strmov(outfile, optarg);
  581. opt_outfile=1;
  582. init_tee();
  583.       }
  584.       break;
  585.     case OPT_NOTEE:
  586.       if (opt_outfile)
  587. end_tee();
  588.       opt_outfile=0;
  589.       break;
  590.     case OPT_PAGER:
  591.       opt_nopager=0;
  592.       if (optarg)
  593. strmov(pager, optarg);
  594.       else
  595. strmov(pager, (char*) getenv("PAGER"));
  596.       strmov(default_pager, pager);
  597.       break;
  598.     case OPT_NOPAGER:
  599.       opt_nopager=1;
  600.       break;
  601.     case 'D':
  602.       my_free(current_db,MYF(MY_ALLOW_ZERO_PTR));      
  603.       current_db=my_strdup(optarg,MYF(MY_WME));
  604.       break;
  605.     case 'e':
  606.       status.batch=1;
  607.       status.add_to_history=0;
  608.       batch_readline_end(status.line_buff); // If multiple -e
  609.       if (!(status.line_buff=batch_readline_command(optarg)))
  610. return 1;
  611.       ignore_errors=0;
  612.       break;
  613.     case 'f':
  614.       ignore_errors=1;
  615.       break;
  616.     case 'h':
  617.       my_free(current_host,MYF(MY_ALLOW_ZERO_PTR));
  618.       current_host=my_strdup(optarg,MYF(MY_WME));
  619.       break;
  620. #ifndef DONT_ALLOW_USER_CHANGE
  621.     case 'u':
  622.       my_free(current_user,MYF(MY_ALLOW_ZERO_PTR));
  623.       current_user= my_strdup(optarg,MYF(MY_WME));
  624.       break;
  625. #endif
  626.     case 'U':
  627.       if (!optarg)
  628. safe_updates=1;
  629.       else
  630. safe_updates=atoi(optarg) != 0;
  631.       break;
  632.     case 'o':
  633.       one_database=skip_updates=1;
  634.       break;
  635.     case 'O':
  636.       if (set_changeable_var(optarg, changeable_vars))
  637.       {
  638. usage(0);
  639. return(1);
  640.       }
  641.       break;
  642.     case 'p':
  643.       if (optarg)
  644.       {
  645. char *start=optarg;
  646. my_free(opt_password,MYF(MY_ALLOW_ZERO_PTR));
  647. opt_password=my_strdup(optarg,MYF(MY_FAE));
  648. while (*optarg) *optarg++= 'x'; // Destroy argument
  649. if (*start)
  650.   start[1]=0;
  651.       }
  652.       else
  653. tty_password=1;
  654.       break;
  655.     case 't':
  656.       output_tables=1;
  657.       break;
  658.     case 'r':
  659.       opt_raw_data=1;
  660.       break;
  661.     case '#':
  662.       DBUG_PUSH(optarg ? optarg : default_dbug_option);
  663.       info_flag=1;
  664.       break;
  665.     case 'q': quick=1; break;
  666.     case 's': opt_silent++; break;
  667.     case 'T': info_flag=1; break;
  668.     case 'n': unbuffered=1; break;
  669.     case 'v': verbose++; break;
  670.     case 'E': vertical=1; break;
  671.     case 'w':
  672.       wait_flag=1;
  673.       if(optarg) wait_time = atoi(optarg) ;
  674.       break;
  675.     case 'A': no_rehash=1; break;
  676.     case 'G': no_named_cmds=0; break;
  677.     case 'g': no_named_cmds=1; break;
  678.     case 'H': opt_html=1; break;
  679.     case 'i': connect_flag|= CLIENT_IGNORE_SPACE; break;
  680.     case 'B':
  681.       if (!status.batch)
  682.       {
  683. status.batch=1;
  684. status.add_to_history=0;
  685. opt_silent++; // more silent
  686.       }
  687.       break;
  688.     case 'C':
  689.       opt_compress=1;
  690.       break;
  691.     case 'L':
  692.       skip_line_numbers=1;
  693.       break;
  694.     case 'N':
  695.       skip_column_names=1;
  696.       break;
  697.     case 'P':
  698.       opt_mysql_port= (unsigned int) atoi(optarg);
  699.       break;
  700.     case 'S':
  701.       my_free(opt_mysql_unix_port,MYF(MY_ALLOW_ZERO_PTR));
  702.       opt_mysql_unix_port= my_strdup(optarg,MYF(0));
  703.       break;
  704.     case 'W':
  705. #ifdef __WIN__
  706.       opt_mysql_unix_port=my_strdup(MYSQL_NAMEDPIPE,MYF(0));
  707. #endif
  708.       break;
  709.     case 'V': usage(1); exit(0);
  710.     case 'I':
  711.     case '?':
  712.       usage(0);
  713.       exit(0);
  714. #include "sslopt-case.h"
  715.     default:
  716.       tee_fprintf(stderr,"illegal option: -%cn",opterr);
  717.       usage(0);
  718.       exit(1);
  719.     }
  720.   }
  721.   if (status.batch) /* disable pager and outfile in this case */
  722.   {
  723.     strmov(default_pager, "stdout");
  724.     strmov(pager, "stdout");
  725.     opt_nopager=1;
  726.     opt_outfile=0;
  727.   }
  728.   if (default_charset)
  729.   {
  730.     if (set_default_charset_by_name(default_charset, MYF(MY_WME)))
  731.       exit(1);
  732.   }
  733.   argc-=optind;
  734.   argv+=optind;
  735.   if (argc > 1)
  736.   {
  737.     usage(0);
  738.     exit(1);
  739.   }
  740.   if (argc == 1)
  741.   {
  742.     my_free(current_db,MYF(MY_ALLOW_ZERO_PTR));
  743.     current_db= my_strdup(*argv,MYF(MY_WME));
  744.   }
  745.   if (!current_host)
  746.   { /* If we don't have a hostname have a look at MYSQL_HOST */
  747.     char *tmp=(char *) getenv("MYSQL_HOST");
  748.     if (tmp)
  749.       current_host = my_strdup(tmp,MYF(MY_WME));
  750.   }
  751.   if (tty_password)
  752.     opt_password=get_tty_password(NullS);
  753.   return(0);
  754. }
  757. static int read_lines(bool execute_commands)
  758. {
  759. #ifdef __WIN__
  760.   char linebuffer[254];
  761. #endif
  762.   char *line;
  763.   char in_string=0;
  764.   ulong line_number=0;
  765.   COMMANDS *com;
  766.   status.exit_status=1;
  768.   for (;;)
  769.   {
  770.     if (status.batch || !execute_commands)
  771.     {
  772.       line=batch_readline(status.line_buff);
  773.       line_number++;
  774.       if (!glob_buffer.length())
  775. status.query_start_line=line_number;
  776.     }
  777.     else
  778.     {
  779. #ifdef __WIN__
  780.       if (opt_outfile && glob_buffer.is_empty())
  781. fflush(OUTFILE);
  782.       tee_fputs(glob_buffer.is_empty() ? "mysql> " :
  783. !in_string ? "    -> " :
  784. in_string == ''' ?
  785. "    '> " : "    "> ",stdout);
  786.       linebuffer[0]=(char) sizeof(linebuffer);
  787.       line=_cgets(linebuffer);
  788. #else
  789.       if (opt_outfile)
  790.       {
  791. if (glob_buffer.is_empty())
  792.   fflush(OUTFILE);
  793. fputs(glob_buffer.is_empty() ? "mysql> " :
  794.       !in_string ? "    -> " :
  795.       in_string == ''' ?
  796.       "    '> " : "    "> ", OUTFILE);
  797.       }
  798.       line=readline((char*) (glob_buffer.is_empty() ? "mysql> " :
  799.      !in_string ? "    -> " :
  800.      in_string == ''' ?
  801.      "    '> " : "    "> "));
  802. #endif
  803.       if (opt_outfile)
  804. fprintf(OUTFILE, "%sn", line);
  805.     }
  806.     if (!line) // End of file
  807.     {
  808.       status.exit_status=0;
  809.       break;
  810.     }
  811.     if (!in_string && (line[0] == '#' ||
  812.        (line[0] == '-' && line[1] == '-') ||
  813.        line[0] == 0))
  814.       continue; // Skip comment lines
  816.     /* Check if line is a mysql command line */
  817.     /* (We want to allow help, print and clear anywhere at line start */
  818.     if (execute_commands && (!no_named_cmds || glob_buffer.is_empty()) 
  819. && !in_string && (com=find_command(line,0)))
  820.     {
  821.       if ((*com->func)(&glob_buffer,line) > 0)
  822. break;
  823.       if (glob_buffer.is_empty()) // If buffer was emptied
  824. in_string=0;
  825. #ifdef HAVE_READLINE
  826.       if (status.add_to_history)
  827. add_history(line);
  828. #endif
  829.       continue;
  830.     }
  831.     if (add_line(glob_buffer,line,&in_string))
  832.       break;
  833.   }
  834.   /* if in batch mode, send last query even if it doesn't end with g or go */
  836.   if ((status.batch || !execute_commands) && !status.exit_status)
  837.   {
  838.     remove_cntrl(glob_buffer);
  839.     if (!glob_buffer.is_empty())
  840.     {
  841.       status.exit_status=1;
  842.       if (com_go(&glob_buffer,line) <= 0)
  843. status.exit_status=0;
  844.     }
  845.   }
  846.   return status.exit_status;
  847. }
  850. static COMMANDS *find_command (char *name,char cmd_char)
  851. {
  852.   uint len;
  853.   char *end;
  855.   if (!name)
  856.   {
  857.     len=0;
  858.     end=0;
  859.   }
  860.   else
  861.   {
  862.     while (isspace(*name))
  863.       name++;
  864.     if (strchr(name,';') || strstr(name,"\g"))
  865.       return ((COMMANDS *) 0);
  866.     if ((end=strcont(name," t")))
  867.     {
  868.       len=(uint) (end - name);
  869.       while (isspace(*end))
  870. end++;
  871.       if (!*end)
  872. end=0; // no arguments to function
  873.     }
  874.     else
  875.       len=(uint) strlen(name);
  876.   }
  878.   for (uint i= 0; commands[i].name; i++)
  879.   {
  880.     if (commands[i].func &&
  881. ((name && !my_casecmp(name,commands[i].name,len) &&
  882.   !commands[i].name[len] &&
  883.   (!end || (end && commands[i].takes_params))) ||
  884.  !name && commands[i].cmd_char == cmd_char))
  885.       return (&commands[i]);
  886.   }
  887.   return ((COMMANDS *) 0);
  888. }
  891. static bool add_line(String &buffer,char *line,char *in_string)
  892. {
  893.   uchar inchar;
  894.   char buff[80],*pos,*out;
  895.   COMMANDS *com;
  897.   if (!line[0] && buffer.is_empty())
  898.     return 0;
  899. #ifdef HAVE_READLINE
  900.   if (status.add_to_history && line[0])
  901.     add_history(line);
  902. #endif
  903. #ifdef USE_MB
  904.   char *strend=line+(uint) strlen(line);
  905. #endif
  907.   for (pos=out=line ; (inchar= (uchar) *pos) ; pos++)
  908.   {
  909.     if (isspace(inchar) && out == line && buffer.is_empty())
  910.       continue;
  911. #ifdef USE_MB
  912.     int l;
  913.     if (use_mb(default_charset_info) &&
  914.         (l = my_ismbchar(default_charset_info, pos, strend))) {
  915. while (l--)
  916.     *out++ = *pos++;
  917. pos--;
  918. continue;
  919.     }
  920. #endif
  921.     if (inchar == '\')
  922.     { // mSQL or postgreSQL style command ?
  923.       if (!(inchar = (uchar) *++pos))
  924. break; // readline adds one ''
  925.       if (*in_string || inchar == 'N')
  926.       { // Don't allow commands in string
  927. *out++='\';
  928. *out++= (char) inchar;
  929. continue;
  930.       }
  931.       if ((com=find_command(NullS,(char) inchar)))
  932.       {
  933. const String tmp(line,(uint) (out-line));
  934. buffer.append(tmp);
  935. if ((*com->func)(&buffer,pos-1) > 0)
  936.   return 1; // Quit
  937. if (com->takes_params)
  938. {
  939.   for (pos++ ; *pos && *pos != ';' ; pos++) ; // Remove parameters
  940.   if (!*pos)
  941.     pos--;
  942. }
  943. out=line;
  944.       }
  945.       else
  946.       {
  947. sprintf(buff,"Unknown command '\%c'.",inchar);
  948. if (put_info(buff,INFO_ERROR) > 0)
  949.   return 1;
  950. *out++='\';
  951. *out++=(char) inchar;
  952. continue;
  953.       }
  954.     }
  955.     else if (inchar == ';' && !*in_string)
  956.     { // ';' is end of command
  957.       if (out != line)
  958. buffer.append(line,(uint) (out-line)); // Add this line
  959.       if ((com=find_command(buffer.c_ptr(),0)))
  960.       {
  961. if ((*com->func)(&buffer,buffer.c_ptr()) > 0)
  962.   return 1; // Quit
  963.       }
  964.       else
  965.       {
  966. int error=com_go(&buffer,0);
  967. if (error)
  968. {
  969.   return error < 0 ? 0 : 1; // < 0 is not fatal
  970. }
  971.       }
  972.       buffer.length(0);
  973.       out=line;
  974.     }
  975.     else if (!*in_string && (inchar == '#' ||
  976.      inchar == '-' && pos[1] == '-' &&
  977.      isspace(pos[2])))
  978.       break; // comment to end of line
  979.     else
  980.     { // Add found char to buffer
  981.       if (inchar == *in_string)
  982. *in_string=0;
  983.       else if (!*in_string && (inchar == ''' || inchar == '"'))
  984. *in_string=(char) inchar;
  985.       *out++ = (char) inchar;
  986.     }
  987.   }
  988.   if (out != line || !buffer.is_empty())
  989.   {
  990.     *out++='n';
  991.     uint length=(uint) (out-line);
  992.     if (buffer.length() + length >= buffer.alloced_length())
  993.       buffer.realloc(buffer.length()+length+IO_SIZE);
  994.     if (buffer.append(line,length))
  995.       return 1;
  996.   }
  997.   return 0;
  998. }
  1000. /* **************************************************************** */
  1001. /*     */
  1002. /*     Interface to Readline Completion     */
  1003. /*     */
  1004. /* **************************************************************** */
  1006. #ifdef HAVE_READLINE
  1008. static char *new_command_generator(char *text, int);
  1009. static char **new_mysql_completion (char *text, int start, int end);
  1011. /* Tell the GNU Readline library how to complete.  We want to try to complete
  1012.    on command names if this is the first word in the line, or on filenames
  1013.    if not. */
  1015. char **no_completion (char *text __attribute__ ((unused)),
  1016.       char *word __attribute__ ((unused)))
  1017. {
  1018.   return 0; /* No filename completion */
  1019. }
  1021. static void initialize_readline (char *name)
  1022. {
  1023.   /* Allow conditional parsing of the ~/.inputrc file. */
  1024.   rl_readline_name = name;
  1026.   /* Tell the completer that we want a crack first. */
  1027.   /* rl_attempted_completion_function = (CPPFunction *)mysql_completion;*/
  1028.   rl_attempted_completion_function = (CPPFunction *) new_mysql_completion;
  1029.   rl_completion_entry_function=(Function *) no_completion;
  1030. }
  1032. /* Attempt to complete on the contents of TEXT.  START and END show the
  1033.    region of TEXT that contains the word to complete.  We can use the
  1034.    entire line in case we want to do some simple parsing.  Return the
  1035.    array of matches, or NULL if there aren't any. */
  1038. static char **new_mysql_completion (char *text,
  1039.     int start __attribute__((unused)),
  1040.     int end __attribute__((unused)))
  1041. {
  1042.   if (!status.batch && !quick)
  1043.     return completion_matches(text, (CPFunction*) new_command_generator);
  1044.   else
  1045.     return (char**) 0;
  1046. }
  1048. static char *new_command_generator(char *text,int state)
  1049. {
  1050.   static int textlen;
  1051.   char *ptr;
  1052.   static Bucket *b;
  1053.   static entry *e;
  1054.   static uint i;
  1056.   if (!state) {
  1057.     textlen=(uint) strlen(text);
  1058.   }
  1060.   if (textlen>0) { /* lookup in the hash */
  1061.     if (!state) {
  1062.       uint len;
  1064.       b = find_all_matches(&ht,text,(uint) strlen(text),&len);
  1065.       if (!b) {
  1066. return NullS;
  1067.       }
  1068.       e = b->pData;
  1069.     }
  1071.     while (e) {
  1072.       ptr= strdup(e->str);
  1073.       e = e->pNext;
  1074.       return ptr;
  1075.     }
  1076.   } else { /* traverse the entire hash, ugly but works */
  1078.     if (!state) {
  1079.       i=0;
  1080.       /* find the first used bucket */
  1081.       while (i<ht.nTableSize) {
  1082. if (ht.arBuckets[i]) {
  1083.   b = ht.arBuckets[i];
  1084.   e = b->pData;
  1085.   break;
  1086. }
  1087. i++;
  1088.       }
  1089.     }
  1090.     ptr= NullS;
  1091.     while (e && !ptr) { /* find valid entry in bucket */
  1092.       if ((uint) strlen(e->str)==b->nKeyLength) {
  1093. ptr = strdup(e->str);
  1094.       }
  1095.       /* find the next used entry */
  1096.       e = e->pNext;
  1097.       if (!e) { /* find the next used bucket */
  1098. b = b->pNext;
  1099. if (!b) {
  1100.   i++;
  1101.   while (i<ht.nTableSize) {
  1102.     if (ht.arBuckets[i]) {
  1103.       b = ht.arBuckets[i];
  1104.       e = b->pData;
  1105.       break;
  1106.     }
  1107.     i++;
  1108.   }
  1109. } else {
  1110.   e = b->pData;
  1111. }
  1112.       }
  1113.     }
  1114.     if (ptr) {
  1115.       return ptr;
  1116.     }
  1117.   }
  1118.   return NullS;
  1119. }
  1122. /* Build up the completion hash */
  1124. static void build_completion_hash(bool skip_rehash,bool write_info)
  1125. {
  1126.   COMMANDS *cmd=commands;
  1127.   static MYSQL_RES *databases=0,*tables=0,*fields;
  1128.   static char ***field_names= 0;
  1129.   MYSQL_ROW database_row,table_row;
  1130.   MYSQL_FIELD *sql_field;
  1131.   char buf[NAME_LEN*2+2];  // table name plus field name plus 2
  1132.   int i,j,num_fields;
  1133.   DBUG_ENTER("build_completion_hash");
  1135.   if (status.batch || quick || !current_db)
  1136.     DBUG_VOID_RETURN; // We don't need completion in batches
  1138.   completion_hash_clean(&ht);
  1139.   if (tables)
  1140.   {
  1141.     mysql_free_result(tables);
  1142.     tables=0;
  1143.   }
  1144.   if (databases) {
  1145.     mysql_free_result(databases);
  1146.     databases=0;
  1147.   }
  1149.   /* hash SQL commands */
  1150.   while (cmd->name) {
  1151.     add_word(&ht,(char*) cmd->name);
  1152.     cmd++;
  1153.   }
  1154.   if (skip_rehash)
  1155.     DBUG_VOID_RETURN;
  1157.   /* hash MySQL functions (to be implemented) */
  1159.   /* hash all database names */
  1160.   if (mysql_query(&mysql,"show databases")==0) {
  1161.     if (!(databases = mysql_store_result(&mysql)))
  1162.       put_info(mysql_error(&mysql),INFO_INFO);
  1163.     else
  1164.     {
  1165.       while ((database_row=mysql_fetch_row(databases)))
  1166. add_word(&ht,(char*) database_row[0]);
  1167.     }
  1168.   }
  1169.   /* hash all table names */
  1170.   if (mysql_query(&mysql,"show tables")==0)
  1171.   {
  1172.     if (!(tables = mysql_store_result(&mysql)))
  1173.       put_info(mysql_error(&mysql),INFO_INFO);
  1174.     else
  1175.     {
  1176.       if (mysql_num_rows(tables) > 0 && !opt_silent && write_info)
  1177.       {
  1178. tee_fprintf(stdout, "
  1179. Reading table information for completion of table and column namesn
  1180. You can turn off this feature to get a quicker startup with -Ann");
  1181.       }
  1182.       while ((table_row=mysql_fetch_row(tables)))
  1183.       {
  1184. if (!completion_hash_exists(&ht,(char*) table_row[0],
  1185.     (uint) strlen((const char*) table_row[0])))
  1186.   add_word(&ht,table_row[0]);
  1187.       }
  1188.     }
  1189.   }
  1190.   if (field_names) {
  1191.     for (i=0; field_names[i]; i++) {
  1192.       for (j=0; field_names[i][j]; j++) {
  1193. my_free(field_names[i][j],MYF(0));
  1194.       }
  1195.       my_free((gptr) field_names[i],MYF(0));
  1196.     }
  1197.     my_free((gptr) field_names,MYF(0));
  1198.   }
  1199.   field_names=0;
  1201.   /* hash all field names, both with the table prefix and without it */
  1202.   if (!tables) /* no tables */
  1203.   {
  1204.     DBUG_VOID_RETURN;
  1205.   }
  1206.   mysql_data_seek(tables,0);
  1207.   field_names = (char ***) my_malloc(sizeof(char **) *
  1208.      (uint) (mysql_num_rows(tables)+1),
  1209.      MYF(MY_WME));
  1210.   if (!field_names)
  1211.     DBUG_VOID_RETURN;
  1212.   i=0;
  1213.   while ((table_row=mysql_fetch_row(tables)))
  1214.   {
  1215.     if ((fields=mysql_list_fields(&mysql,(const char*) table_row[0],NullS)))
  1216.     {
  1217.       num_fields=mysql_num_fields(fields);
  1218.       field_names[i] = (char **) my_malloc(sizeof(char *)*(num_fields*2+1),
  1219.    MYF(0));
  1220.       if (!field_names[i])
  1221.       {
  1222. continue;
  1223.       }
  1224.       field_names[i][num_fields*2]='';
  1225.       j=0;
  1226.       while ((sql_field=mysql_fetch_field(fields)))
  1227.       {
  1228. sprintf(buf,"%s.%s",table_row[0],sql_field->name);
  1229. field_names[i][j] = my_strdup(buf,MYF(0));
  1230. add_word(&ht,field_names[i][j]);
  1231. field_names[i][num_fields+j] = my_strdup(sql_field->name,MYF(0));
  1232. if (!completion_hash_exists(&ht,field_names[i][num_fields+j],
  1233.     (uint) strlen(field_names[i][num_fields+j])))
  1234.   add_word(&ht,field_names[i][num_fields+j]);
  1235. j++;
  1236.       }
  1237.     }
  1238.     else
  1239.     {
  1240.       tee_fprintf(stdout,
  1241.   "Didn't find any fields in table '%s'n",table_row[0]);
  1242.       field_names[i]=0;
  1243.     }
  1244.     i++;
  1245.   }
  1246.   field_names[i]=0; // End pointer
  1247.   DBUG_VOID_RETURN;
  1248. }
  1251. /* for gnu readline */
  1253. #ifndef HAVE_INDEX
  1254. #ifdef __cplusplus
  1255. extern "C" {
  1256. #endif
  1257. extern char *index(const char *,pchar c),*rindex(const char *,pchar);
  1259. char *index(const char *s,pchar c)
  1260. {
  1261.   for (;;)
  1262.   {
  1263.      if (*s == (char) c) return (char*) s;
  1264.      if (!*s++) return NullS;
  1265.   }
  1266. }
  1268. char *rindex(const char *s,pchar c)
  1269. {
  1270.   reg3 char *t;
  1272.   t = NullS;
  1273.   do if (*s == (char) c) t = (char*) s; while (*s++);
  1274.   return (char*) t;
  1275. }
  1276. #ifdef __cplusplus
  1277. }
  1278. #endif
  1279. #endif
  1280. #endif /* HAVE_READLINE */
  1282. static int reconnect(void)
  1283. {
  1284.   if (!status.batch)
  1285.   {
  1286.     put_info("No connection. Trying to reconnect...",INFO_INFO);
  1287.     (void) com_connect((String *) 0, 0);
  1288.     if(!no_rehash) com_rehash(NULL, NULL);
  1289.   }
  1290.   if (!connected)
  1291.     return put_info("Can't connect to the servern",INFO_ERROR);
  1292.   return 0;
  1293. }
  1296. /***************************************************************************
  1297.  The different commands
  1298. ***************************************************************************/
  1300. static int
  1301. com_help (String *buffer __attribute__((unused)),
  1302.   char *line __attribute__((unused)))
  1303. {
  1304.   reg1 int i;
  1306.   put_info("nMySQL commands:",INFO_INFO);
  1307.   if (no_named_cmds)
  1308.     put_info("Note that all text commands must be first on line and end with ';'",INFO_INFO);
  1309.   for (i = 0; commands[i].name; i++)
  1310.   {
  1311.     if (commands[i].func)
  1312.       tee_fprintf(stdout, "%st(\%c)t%sn", commands[i].name,
  1313.   commands[i].cmd_char, commands[i].doc);
  1314.   }
  1315.   if (connected)
  1316.     tee_fprintf(stdout,
  1317. "nConnection id: %ld  (Can be used with mysqladmin kill)nn",
  1318. mysql_thread_id(&mysql));
  1319.   else
  1320.     tee_fprintf(stdout, "Not connected!  Reconnect with 'connect'!nn");
  1321.   return 0;
  1322. }
  1325. /* ARGSUSED */
  1326. static int
  1327. com_clear(String *buffer,char *line __attribute__((unused)))
  1328. {
  1329.   buffer->length(0);
  1330.   return 0;
  1331. }
  1334. /*
  1335. ** Execute command
  1336. ** Returns: 0  if ok
  1337. **     -1 if not fatal error
  1338. **     1  if fatal error
  1339. */
  1342. static int
  1343. com_go(String *buffer,char *line __attribute__((unused)))
  1344. {
  1345.   char buff[160],time_buff[32];
  1346.   MYSQL_RES *result;
  1347.   ulong timer;
  1348.   uint error=0;
  1350.   if (!status.batch)
  1351.   {
  1352.     old_buffer= *buffer; // Save for edit command
  1353.     old_buffer.copy();
  1354.   }
  1356. /* Remove garbage for nicer messages */
  1357.   LINT_INIT(buff[0]);
  1358.   remove_cntrl(*buffer);
  1360.   if (buffer->is_empty())
  1361.   {
  1362.     if (status.batch) // Ignore empty quries
  1363.       return 0;
  1364.     return put_info("No query specifiedn",INFO_ERROR);
  1366.   }
  1367.   if (!connected && reconnect())
  1368.   {
  1369.     buffer->length(0); // Remove query on error
  1370.     return status.batch ? 1 : -1; // Fatal error
  1371.   }
  1372.   if (verbose)
  1373.     (void) com_print(buffer,0);
  1375.   if (skip_updates &&
  1376.       (buffer->length() < 4 || my_sortcmp(buffer->ptr(),"SET ",4)))
  1377.   {
  1378.     (void) put_info("Ignoring query to other database",INFO_INFO);
  1379.     return 0;
  1380.   }
  1382.   timer=start_timer();
  1383.   for (uint retry=0;; retry++)
  1384.   {
  1385.     if (!mysql_real_query(&mysql,buffer->ptr(),buffer->length()))
  1386.       break;
  1387.     error=put_info(mysql_error(&mysql),INFO_ERROR, mysql_errno(&mysql));
  1388.     if (mysql_errno(&mysql) != CR_SERVER_GONE_ERROR || retry > 1 
  1389. || status.batch)
  1390.     {
  1391.       buffer->length(0); // Remove query on error
  1392.       return error;
  1393.     }
  1394.     if (reconnect())
  1395.     {
  1396.       buffer->length(0); // Remove query on error
  1397.       return error;
  1398.     }
  1399.   }
  1400.   error=0;
  1401.   buffer->length(0);
  1403.   if (quick)
  1404.   {
  1405.     if (!(result=mysql_use_result(&mysql)) && mysql_field_count(&mysql))
  1406.     {
  1407.       return put_info(mysql_error(&mysql),INFO_ERROR,mysql_errno(&mysql));
  1408.     }
  1409.   }
  1410.   else
  1411.   {
  1412.     if (!(result=mysql_store_result(&mysql)))
  1413.     {
  1414.       if (mysql_error(&mysql)[0])
  1415.       {
  1416. return put_info(mysql_error(&mysql),INFO_ERROR,mysql_errno(&mysql));
  1417.       }
  1418.     }
  1419.   }
  1421.   if (verbose >= 3 || !opt_silent)
  1422.     mysql_end_timer(timer,time_buff);
  1423.   else
  1424.     time_buff[0]=0;
  1425.   if (result)
  1426.   {
  1427.     if (!mysql_num_rows(result) && ! quick)
  1428.     {
  1429.       sprintf(buff,"Empty set%s",time_buff);
  1430.     }
  1431.     else
  1432.     {
  1433.       init_pager();
  1434.       if (opt_html)
  1435. print_table_data_html(result);
  1436.       else if (vertical)
  1437. print_table_data_vertically(result);
  1438.       else if (opt_silent && verbose <= 2 && !output_tables)
  1439. print_tab_data(result);
  1440.       else
  1441. print_table_data(result);
  1442.       sprintf(buff,"%ld %s in set%s",
  1443.       (long) mysql_num_rows(result),
  1444.       (long) mysql_num_rows(result) == 1 ? "row" : "rows",
  1445.       time_buff);
  1446.       end_pager();
  1447.     }
  1448.   }
  1449.   else if (mysql_affected_rows(&mysql) == ~(ulonglong) 0)
  1450.     sprintf(buff,"Query OK%s",time_buff);
  1451.   else
  1452.     sprintf(buff,"Query OK, %ld %s affected%s",
  1453.     (long) mysql_affected_rows(&mysql),
  1454.     (long) mysql_affected_rows(&mysql) == 1 ? "row" : "rows",
  1455.     time_buff);
  1456.   put_info(buff,INFO_RESULT);
  1457.   if (mysql_info(&mysql))
  1458.     put_info(mysql_info(&mysql),INFO_RESULT);
  1459.   put_info("",INFO_RESULT); // Empty row
  1461.   if (result && !mysql_eof(result)) /* Something wrong when using quick */
  1462.     error=put_info(mysql_error(&mysql),INFO_ERROR,mysql_errno(&mysql));
  1463.   else if (unbuffered)
  1464.     fflush(stdout);
  1465.   mysql_free_result(result);
  1466.   return error; /* New command follows */
  1467. }
  1470. static void init_pager()
  1471. {
  1472. #ifndef __WIN__
  1473.   if (!opt_nopager)
  1474.   {
  1475.     if (!(PAGER= popen(pager, "w")))
  1476.     {
  1477.       tee_fprintf(stdout, "popen() failed! defaulting PAGER to stdout!n");
  1478.       PAGER= stdout;
  1479.     }
  1480.   }
  1481.   else
  1482. #endif
  1483.     PAGER= stdout;
  1484. }
  1486. static void end_pager()
  1487. {
  1488. #ifndef __WIN__
  1489.   if (!opt_nopager)
  1490.     pclose(PAGER);
  1491. #endif
  1492. }
  1494. static void init_tee()
  1495. {
  1496.   if (!(OUTFILE= my_fopen(outfile, O_APPEND | O_WRONLY, MYF(MY_WME))))
  1497.   {
  1498.     opt_outfile=0;
  1499.     init_pager();
  1500.     return;
  1501.   }
  1502. }
  1504. static void end_tee()
  1505. {
  1506.   my_fclose(OUTFILE, MYF(0));
  1507.   return;
  1508. }
  1510. static int
  1511. com_ego(String *buffer,char *line)
  1512. {
  1513.   int result;
  1514.   bool oldvertical=vertical;
  1515.   vertical=1;
  1516.   result=com_go(buffer,line);
  1517.   vertical=oldvertical;
  1518.   return result;
  1519. }
  1521. static void
  1522. print_field_types(MYSQL_RES *result)
  1523. {
  1524.   MYSQL_FIELD *field;  
  1525.   while ((field = mysql_fetch_field(result)))
  1526.   {
  1527.     tee_fprintf(PAGER,"%s '%s' %d %d %d %d %dn",
  1528. field->name,
  1529. field->table ? "" : field->table,
  1530. (int) field->type,
  1531. field->length, field->max_length, 
  1532. field->flags, field->decimals);
  1533.   }
  1534.   tee_puts("", PAGER);
  1535. }
  1538. static void
  1539. print_table_data(MYSQL_RES *result)
  1540. {
  1541.   String separator(256);
  1542.   MYSQL_ROW cur;
  1543.   MYSQL_FIELD *field;
  1544.   bool *num_flag;
  1546.   num_flag=(bool*) my_alloca(sizeof(bool)*mysql_num_fields(result));
  1547.   if (info_flag)
  1548.   {
  1549.     print_field_types(result);
  1550.     mysql_field_seek(result,0);
  1551.   }
  1552.   separator.copy("+",1);
  1553.   while ((field = mysql_fetch_field(result)))
  1554.   {
  1555.     uint length=skip_column_names ? 0 : (uint) strlen(field->name);
  1556.     if (quick)
  1557.       length=max(length,field->length);
  1558.     else
  1559.       length=max(length,field->max_length);
  1560.     if (length < 4 && !IS_NOT_NULL(field->flags))
  1561.       length=4; // Room for "NULL"
  1562.     field->max_length=length+1;
  1563.     separator.fill(separator.length()+length+2,'-');
  1564.     separator.append('+');
  1565.   }
  1566.   tee_puts(separator.c_ptr(), PAGER);
  1567.   if (!skip_column_names)
  1568.   {
  1569.     mysql_field_seek(result,0);
  1570.     (void) tee_fputs("|", PAGER);
  1571.     for (uint off=0; (field = mysql_fetch_field(result)) ; off++)
  1572.     {
  1573.       tee_fprintf(PAGER, " %-*s|",min(field->max_length,MAX_COLUMN_LENGTH),
  1574.   field->name);
  1575.       num_flag[off]= IS_NUM(field->type);
  1576.     }
  1577.     (void) tee_fputs("n", PAGER);
  1578.     tee_puts(separator.c_ptr(), PAGER);
  1579.   }
  1581.   while ((cur = mysql_fetch_row(result)))
  1582.   {
  1583.     (void) tee_fputs("|", PAGER);
  1584.     mysql_field_seek(result,0);
  1585.     for (uint off=0 ; off < mysql_num_fields(result); off++)
  1586.     {
  1587.       const char *str=cur[off] ? cur[off] : "NULL";
  1588.       field = mysql_fetch_field(result);
  1589.       uint length=field->max_length;
  1590.       if (length > MAX_COLUMN_LENGTH)
  1591.       {
  1592. tee_fputs(str,PAGER); tee_fputs(" |",PAGER);
  1593.       }
  1594.       else
  1595.       tee_fprintf(PAGER, num_flag[off] ? "%*s |" : " %-*s|",
  1596.   length, str);
  1597.     }
  1598.     (void) tee_fputs("n", PAGER);
  1599.   }
  1600.   tee_puts(separator.c_ptr(), PAGER);
  1601.   my_afree((gptr) num_flag);
  1602. }
  1604. static void
  1605. print_table_data_html(MYSQL_RES *result)
  1606. {
  1607.   MYSQL_ROW   cur;
  1608.   MYSQL_FIELD *field;
  1610.   mysql_field_seek(result,0);
  1611.   (void) tee_fputs("<TABLE BORDER=1><TR>", PAGER);
  1612.   if (!skip_column_names)
  1613.   {
  1614.     while((field = mysql_fetch_field(result)))
  1615.     {
  1616.       tee_fprintf(PAGER, "<TH>%s</TH>", (field->name ? 
  1617.  (field->name[0] ? field->name : 
  1618.   " &nbsp; ") : "NULL"));
  1619.     }
  1620.     (void) tee_fputs("</TR>", PAGER);
  1621.   }
  1622.   while ((cur = mysql_fetch_row(result)))
  1623.   {
  1624.     (void) tee_fputs("<TR>", PAGER);
  1625.     for (uint i=0; i < mysql_num_fields(result); i++)
  1626.     {
  1627.       ulong *lengths=mysql_fetch_lengths(result);
  1628.       (void) tee_fputs("<TD>", PAGER);
  1629.       safe_put_field(cur[i],lengths[i]);
  1630.       (void) tee_fputs("</TD>", PAGER);
  1631.     }
  1632.     (void) tee_fputs("</TR>", PAGER);
  1633.   }
  1634.   (void) tee_fputs("</TABLE>", PAGER);
  1635. }
  1639. static void
  1640. print_table_data_vertically(MYSQL_RES *result)
  1641. {
  1642.   MYSQL_ROW cur;
  1643.   uint max_length=0;
  1644.   MYSQL_FIELD *field;
  1646.   while ((field = mysql_fetch_field(result)))
  1647.   {
  1648.     uint length=(uint) strlen(field->name);
  1649.     if (length > max_length)
  1650.       max_length= length;
  1651.     field->max_length=length;
  1652.   }
  1654.   mysql_field_seek(result,0);
  1655.   for (uint row_count=1; (cur= mysql_fetch_row(result)); row_count++)
  1656.   {
  1657.     mysql_field_seek(result,0);
  1658.     tee_fprintf(PAGER, 
  1659. "*************************** %d. row ***************************n", row_count);
  1660.     for (uint off=0; off < mysql_num_fields(result); off++)
  1661.     {
  1662.       field= mysql_fetch_field(result);
  1663.       tee_fprintf(PAGER, "%*s: ",(int) max_length,field->name);
  1664.       tee_fprintf(PAGER, "%sn",cur[off] ? (char*) cur[off] : "NULL");
  1665.     }
  1666.   }
  1667. }
  1670. static void
  1671. safe_put_field(const char *pos,ulong length)
  1672. {
  1673.   if (!pos)
  1674.     tee_fputs("NULL", PAGER);
  1675.   else
  1676.   {
  1677.     if (opt_raw_data)
  1678.       tee_fputs(pos, PAGER);
  1679.     else for (const char *end=pos+length ; pos != end ; pos++)
  1680.     {
  1681. #ifdef USE_MB
  1682.       int l;
  1683.       if (use_mb(default_charset_info) &&
  1684.           (l = my_ismbchar(default_charset_info, pos, end))) {
  1685.   while (l--)
  1686.     tee_putc(*pos++, PAGER);
  1687.   pos--;
  1688.   continue;
  1689.       }
  1690. #endif
  1691.       if (!*pos)
  1692. tee_fputs("\0", PAGER); // This makes everything hard
  1693.       else if (*pos == 't')
  1694. tee_fputs("\t", PAGER); // This would destroy tab format
  1695.       else if (*pos == 'n')
  1696. tee_fputs("\n", PAGER); // This too
  1697.       else if (*pos == '\')
  1698. tee_fputs("\\", PAGER);
  1699.       else
  1700. tee_putc(*pos, PAGER);
  1701.     }
  1702.   }
  1703. }
  1706. static void
  1707. print_tab_data(MYSQL_RES *result)
  1708. {
  1709.   MYSQL_ROW cur;
  1710.   MYSQL_FIELD *field;
  1711.   ulong *lengths;
  1713.   if (opt_silent < 2 && !skip_column_names)
  1714.   {
  1715.     int first=0;
  1716.     while ((field = mysql_fetch_field(result)))
  1717.     {
  1718.       if (first++)
  1719. (void) tee_fputs("t", PAGER);
  1720.       (void) tee_fputs(field->name, PAGER);
  1721.     }
  1722.     (void) tee_fputs("n", PAGER);
  1723.   }
  1724.   while ((cur = mysql_fetch_row(result)))
  1725.   {
  1726.     lengths=mysql_fetch_lengths(result);
  1727.     safe_put_field(cur[0],lengths[0]);
  1728.     for (uint off=1 ; off < mysql_num_fields(result); off++)
  1729.     {
  1730.       (void) tee_fputs("t", PAGER);
  1731.       safe_put_field(cur[off],lengths[off]);
  1732.     }
  1733.     (void) tee_fputs("n", PAGER);
  1734.   }
  1735. }
  1737. static int
  1738. com_tee(String *buffer, char *line __attribute__((unused)))
  1739. {
  1740.   char file_name[FN_REFLEN], *end, *param;
  1742.   if (status.batch)
  1743.     return 0;
  1744.   while (isspace(*line))
  1745.     line++;
  1746.   if (!(param = strchr(line, ' '))) // if outfile wasn't given, use the default
  1747.   {
  1748.     if (!strlen(outfile))
  1749.     {
  1750.       printf("No previous outfile available, you must give the filename!n");
  1751.       opt_outfile=0;
  1752.       return 0;
  1753.     }
  1754.   }
  1755.   else
  1756.   {
  1757.     while (isspace(*param))
  1758.       param++;
  1759.     end=strmake(file_name, param, sizeof(file_name)-1);
  1760.     while (end > file_name && (isspace(end[-1]) || iscntrl(end[-1])))
  1761.       end--;
  1762.     end[0]=0;
  1763.     strmov(outfile, file_name);
  1764.   }
  1765.   if (!strlen(outfile))
  1766.   {
  1767.     printf("No outfile specified!n");
  1768.     return 0;
  1769.   }
  1770.   if (!opt_outfile)
  1771.   {
  1772.     init_tee();
  1773.     opt_outfile=1;
  1774.   }
  1775.   tee_fprintf(stdout, "Logging to file '%s'n", outfile);
  1776.   return 0;
  1777. }
  1779. static int
  1780. com_notee(String *buffer __attribute__((unused)),
  1781.   char *line __attribute__((unused)))
  1782. {
  1783.   if (opt_outfile)
  1784.     end_tee();
  1785.   opt_outfile=0;
  1786.   tee_fprintf(stdout, "Outfile disabled.n");
  1787.   return 0;
  1788. }
  1790. /*
  1791. ** Sorry, this command is not available in Windows.
  1792. */
  1794. #ifndef __WIN__
  1795. static int
  1796. com_pager(String *buffer, char *line __attribute__((unused)))
  1797. {
  1798.   char pager_name[FN_REFLEN], *end, *param;
  1800.   if (status.batch)
  1801.     return 0;
  1802.   /* Skip space from file name */
  1803.   while (isspace(*line))
  1804.     line++;
  1805.   if (!(param = strchr(line, ' '))) // if pager was not given, use the default
  1806.   {
  1807.     if (!strlen(default_pager))
  1808.     {
  1809.       tee_fprintf(stdout, "Default pager wasn't set, using stdout.n");
  1810.       opt_nopager=1;
  1811.       strmov(pager, "stdout");
  1812.       PAGER= stdout;
  1813.       return 0;
  1814.     }
  1815.     strmov(pager, default_pager);
  1816.   }
  1817.   else
  1818.   {
  1819.     while (isspace(*param))
  1820.       param++;
  1821.     end=strmake(pager_name, param, sizeof(pager_name)-1);
  1822.     while (end > pager_name && (isspace(end[-1]) || iscntrl(end[-1])))
  1823.       end--;
  1824.     end[0]=0;
  1825.     strmov(pager, pager_name);
  1826.   }
  1827.   opt_nopager=0;
  1828.   tee_fprintf(stdout, "PAGER set to %sn", pager);
  1829.   return 0;
  1830. }
  1833. static int
  1834. com_nopager(String *buffer __attribute__((unused)),
  1835.     char *line __attribute__((unused)))
  1836. {
  1837.   strmov(pager, "stdout");
  1838.   opt_nopager=1;
  1839.   tee_fprintf(stdout, "PAGER set to stdoutn");
  1840.   return 0;
  1841. }
  1842. #endif
  1845. /*
  1846. ** Sorry, you can't send the result to an editor in Win32
  1847. */
  1849. #ifndef __WIN__
  1850. static int
  1851. com_edit(String *buffer,char *line __attribute__((unused)))
  1852. {
  1853.   char filename[FN_REFLEN],buff[160];
  1854.   int fd,tmp;
  1855.   const char *editor;
  1857.   if ((fd=create_temp_file(filename,NullS,"sql", O_CREAT | O_WRONLY,
  1858.    MYF(MY_WME))) < 0)
  1859.     goto err;
  1860.   if (buffer->is_empty() && !old_buffer.is_empty())
  1861.     (void) my_write(fd,(byte*) old_buffer.ptr(),old_buffer.length(),
  1862.     MYF(MY_WME));
  1863.   else
  1864.     (void) my_write(fd,(byte*) buffer->ptr(),buffer->length(),MYF(MY_WME));
  1865.   (void) my_close(fd,MYF(0));
  1867.   if (!(editor = (char *)getenv("EDITOR")) &&
  1868.       !(editor = (char *)getenv("VISUAL")))
  1869.     editor = "vi";
  1870.   strxmov(buff,editor," ",filename,NullS);
  1871.   (void) system(buff);
  1873.   MY_STAT stat_arg;
  1874.   if (!my_stat(filename,&stat_arg,MYF(MY_WME)))
  1875.     goto err;
  1876.   if ((fd = my_open(filename,O_RDONLY, MYF(MY_WME))) < 0)
  1877.     goto err;
  1878.   (void) buffer->alloc((uint) stat_arg.st_size);
  1879.   if ((tmp=read(fd,(char*) buffer->ptr(),buffer->alloced_length())) >= 0L)
  1880.     buffer->length((uint) tmp);
  1881.   else
  1882.     buffer->length(0);
  1883.   (void) my_close(fd,MYF(0));
  1884.   (void) my_delete(filename,MYF(MY_WME));
  1885. err:
  1886.   return 0;
  1887. }
  1888. #endif
  1891. /* If arg is given, exit without errors. This happens on command 'quit' */
  1893. static int
  1894. com_quit(String *buffer __attribute__((unused)),
  1895.  char *line __attribute__((unused)))
  1896. {
  1897.   status.exit_status=0;
  1898.   return 1;
  1899. }
  1901. static int
  1902. com_rehash(String *buffer __attribute__((unused)),
  1903.  char *line __attribute__((unused)))
  1904. {
  1905. #ifdef HAVE_READLINE
  1906.   build_completion_hash(0,0);
  1907. #endif
  1908.   return 0;
  1909. }
  1911. static int
  1912. com_print(String *buffer,char *line __attribute__((unused)))
  1913. {
  1914.   tee_puts("--------------", stdout);
  1915.   (void) tee_fputs(buffer->c_ptr(), stdout);
  1916.   if (!buffer->length() || (*buffer)[buffer->length()-1] != 'n')
  1917.     tee_putc('n', stdout);
  1918.   tee_puts("--------------n", stdout);
  1919.   return 0; /* If empty buffer */
  1920. }
  1922. /* ARGSUSED */
  1923. static int
  1924. com_connect(String *buffer, char *line)
  1925. {
  1926.   char *tmp,buff[256];
  1927.   bool save_rehash=no_rehash;
  1928.   int error;
  1930.   if (buffer)
  1931.   {
  1932.     while (isspace(*line))
  1933.       line++;
  1934.     strnmov(buff,line,sizeof(buff)-1); // Don't destroy history
  1935.     if (buff[0] == '\') // Short command
  1936.       buff[1]=' ';
  1937.     tmp=(char *) strtok(buff," t"); // Skip connect command
  1938.     if (tmp && (tmp=(char *) strtok(NullS," t;")))
  1939.     {
  1940.       my_free(current_db,MYF(MY_ALLOW_ZERO_PTR));
  1941.       current_db=my_strdup(tmp,MYF(MY_WME));
  1942.       if ((tmp=(char *) strtok(NullS," t;")))
  1943.       {
  1944. my_free(current_host,MYF(MY_ALLOW_ZERO_PTR));
  1945. current_host=my_strdup(tmp,MYF(MY_WME));
  1946.       }
  1947.     }
  1948.     else
  1949.       no_rehash=1; // Quick re-connect
  1950.     buffer->length(0); // command used
  1951.   }
  1952.   else
  1953.     no_rehash=1;
  1954.   error=sql_connect(current_host,current_db,current_user,opt_password,0);
  1955.   no_rehash=save_rehash;
  1957.   if (connected)
  1958.   {
  1959.     sprintf(buff,"Connection id:    %ld",mysql_thread_id(&mysql));
  1960.     put_info(buff,INFO_INFO);
  1961.     sprintf(buff,"Current database: %sn",
  1962.     current_db ? current_db : "*** NONE ***");
  1963.     put_info(buff,INFO_INFO);
  1964.   }
  1965.   return error;
  1966. }
  1969. static int com_source(String *buffer, char *line)
  1970. {
  1971.   char source_name[FN_REFLEN], *end, *param;
  1972.   LINE_BUFFER *line_buff;
  1973.   int error;
  1974.   STATUS old_status;
  1975.   FILE *sql_file;
  1977.   /* Skip space from file name */
  1978.   while (isspace(*line))
  1979.     line++;
  1980.   if (!(param = strchr(line, ' '))) // Skip command name
  1981.     return put_info("Usage: \. <filename> | source <filename>", 
  1982.     INFO_ERROR, 0);
  1983.   while (isspace(*param))
  1984.     param++;
  1985.   end=strmake(source_name,param,sizeof(source_name)-1);
  1986.   while (end > source_name && (isspace(end[-1]) || iscntrl(end[-1])))
  1987.     end--;
  1988.   end[0]=0;
  1989.   unpack_filename(source_name,source_name);
  1990.   /* open file name */
  1991.   if (!(sql_file = my_fopen(source_name, O_RDONLY | O_BINARY,MYF(0))))
  1992.   {
  1993.     char buff[FN_REFLEN+60];
  1994.     sprintf(buff,"Failed to open file '%s', error: %d", source_name,errno);
  1995.     return put_info(buff, INFO_ERROR, 0);
  1996.   }
  1998.   if (!(line_buff=batch_readline_init(max_allowed_packet+512,sql_file)))
  1999.   {
  2000.     my_fclose(sql_file,MYF(0));
  2001.     return put_info("Can't initialize batch_readline", INFO_ERROR, 0);
  2002.   }
  2004.   /* Save old status */
  2005.   old_status=status;
  2006.   bfill((char*) &status,sizeof(status),(char) 0);
  2008.   status.batch=old_status.batch; // Run in batch mode
  2009.   status.line_buff=line_buff;
  2010.   status.file_name=source_name;
  2011.   glob_buffer.length(0); // Empty command buffer
  2012.   error=read_lines(0); // Read lines from file
  2013.   status=old_status; // Continue as before
  2014.   my_fclose(sql_file,MYF(0));
  2015.   batch_readline_end(line_buff);
  2016.   return error;
  2017. }
  2020. /* ARGSUSED */
  2021. static int
  2022. com_use(String *buffer __attribute__((unused)), char *line)
  2023. {
  2024.   char *tmp;
  2025.   char buff[256];
  2027.   while (isspace(*line))
  2028.     line++;
  2029.   strnmov(buff,line,sizeof(buff)-1); // Don't destroy history
  2030.   if (buff[0] == '\') // Short command
  2031.     buff[1]=' ';
  2032.   tmp=(char *) strtok(buff," t;"); // Skip connect command
  2033.   if (!tmp || !(tmp=(char *) strtok(NullS," t;")))
  2034.   {
  2035.     put_info("USE must be followed by a database name",INFO_ERROR);
  2036.     return 0;
  2037.   }
  2038.   if (!current_db || cmp_database(current_db,tmp))
  2039.   {
  2040.     if (one_database)
  2041.       skip_updates=1;
  2042.     else
  2043.     {
  2044.       /*
  2045. reconnect once if connection is down or if connection was found to
  2046. be down during query
  2047.       */
  2048.       if (!connected && reconnect())
  2049. return status.batch ? 1 : -1; // Fatal error
  2050.       if (mysql_select_db(&mysql,tmp))
  2051.       {
  2052. if (mysql_errno(&mysql) != CR_SERVER_GONE_ERROR)
  2053.   return put_info(mysql_error(&mysql),INFO_ERROR,mysql_errno(&mysql));
  2055. if (reconnect())
  2056.   return status.batch ? 1 : -1; // Fatal error
  2057. if (mysql_select_db(&mysql,tmp))
  2058.   return put_info(mysql_error(&mysql),INFO_ERROR,mysql_errno(&mysql));
  2059.       }
  2060.       my_free(current_db,MYF(MY_ALLOW_ZERO_PTR));
  2061.       current_db=my_strdup(tmp,MYF(MY_WME));
  2062. #ifdef HAVE_READLINE
  2063.       build_completion_hash(no_rehash,1);
  2064. #endif
  2065.     }
  2066.   }
  2067.   else
  2068.     skip_updates=0;
  2069.   put_info("Database changed",INFO_INFO);
  2070.   return 0;
  2071. }
  2074. static int
  2075. sql_real_connect(char *host,char *database,char *user,char *password,
  2076.  uint silent)
  2077. {
  2078.   if (connected)
  2079.   { /* if old is open, close it first */
  2080.     mysql_close(&mysql);
  2081.     connected= 0;
  2082.   }
  2083.   mysql_init(&mysql);
  2084.   if (opt_connect_timeout)
  2085.   {
  2086.     uint timeout=opt_connect_timeout;
  2087.     mysql_options(&mysql,MYSQL_OPT_CONNECT_TIMEOUT,
  2088.   (char*) &timeout);
  2089.   }
  2090.   if (opt_compress)
  2091.     mysql_options(&mysql,MYSQL_OPT_COMPRESS,NullS);
  2092. #ifdef HAVE_OPENSSL
  2093.   if (opt_use_ssl)
  2094.     mysql_ssl_set(&mysql, opt_ssl_key, opt_ssl_cert, opt_ssl_ca,
  2095.   opt_ssl_capath);
  2096. #endif
  2097.   if (safe_updates)
  2098.   {
  2099.     char init_command[100];
  2100.     sprintf(init_command,
  2101.     "SET SQL_SAFE_UPDATES=1,SQL_SELECT_LIMIT=%lu,SQL_MAX_JOIN_SIZE=%lu",
  2102.     select_limit,max_join_size);
  2103.     mysql_options(&mysql, MYSQL_INIT_COMMAND, init_command);
  2104.   }
  2105.   if (!mysql_real_connect(&mysql,host,user,password,
  2106.   database,opt_mysql_port,opt_mysql_unix_port,
  2107.   connect_flag))
  2108.   {
  2109.     if (!silent ||
  2110. (mysql_errno(&mysql) != CR_CONN_HOST_ERROR &&
  2111.  mysql_errno(&mysql) != CR_CONNECTION_ERROR))
  2112.     {
  2113.       put_info(mysql_error(&mysql),INFO_ERROR,mysql_errno(&mysql));
  2114.       (void) fflush(stdout);
  2115.       return ignore_errors ? -1 : 1; // Abort
  2116.     }
  2117.     return -1; // Retryable
  2118.   }
  2119.   connected=1;
  2120.   mysql.reconnect=info_flag ? 1 : 0; // We want to know if this happens
  2121. #ifdef HAVE_READLINE
  2122.   build_completion_hash(no_rehash,1);
  2123. #endif
  2124.   return 0;
  2125. }
  2128. static int
  2129. sql_connect(char *host,char *database,char *user,char *password,uint silent)
  2130. {
  2131.   bool message=0;
  2132.   uint count=0;
  2133.   int error;
  2134.   for (;;)
  2135.   {
  2136.     if ((error=sql_real_connect(host,database,user,password,wait_flag)) >= 0)
  2137.     {
  2138.       if (count)
  2139.       {
  2140. tee_fputs("n", stderr);
  2141. (void) fflush(stderr);
  2142.       }
  2143.       return error;
  2144.     }
  2145.     if (!wait_flag)
  2146.       return ignore_errors ? -1 : 1;
  2147.     if (!message && !silent)
  2148.     {
  2149.       message=1;
  2150.       tee_fputs("Waiting",stderr); (void) fflush(stderr);
  2151.     }
  2152.     (void) sleep(wait_time);
  2153.     if (!silent)
  2154.     {
  2155.       putc('.',stderr); (void) fflush(stderr);
  2156.       count++;
  2157.     }
  2158.   }
  2159. }
  2163. static int
  2164. com_status(String *buffer __attribute__((unused)),
  2165.    char *line __attribute__((unused)))
  2166. {
  2167.   char *status;
  2168.   tee_puts("--------------", stdout);
  2169.   usage(1); /* Print version */
  2170.   if (connected)
  2171.   {
  2172.     MYSQL_RES *result;
  2173.     LINT_INIT(result);
  2174.     tee_fprintf(stdout, "nConnection id:tt%ldn",mysql_thread_id(&mysql));
  2175.     if (!mysql_query(&mysql,"select DATABASE(),USER()") &&
  2176. (result=mysql_use_result(&mysql)))
  2177.     {
  2178.       MYSQL_ROW cur=mysql_fetch_row(result);
  2179.       tee_fprintf(stdout, "Current database:t%sn",cur[0]);
  2180.       tee_fprintf(stdout, "Current user:tt%sn",cur[1]);
  2181.       (void) mysql_fetch_row(result); // Read eof
  2182.     }
  2183.   }
  2184.   else
  2185.   {
  2186.     vidattr(A_BOLD);
  2187.     tee_fprintf(stdout, "nNo connectionn");
  2188.     vidattr(A_NORMAL);
  2189.     return 0;
  2190.   }
  2191.   if (skip_updates)
  2192.   {
  2193.     vidattr(A_BOLD);
  2194.     tee_fprintf(stdout, "nAll updates ignored to this databasen");
  2195.     vidattr(A_NORMAL);
  2196.   }
  2197. #ifndef __WIN__
  2198.   tee_fprintf(stdout, "Current pager:tt%sn", pager);
  2199.   tee_fprintf(stdout, "Using outfile:tt'%s'n", opt_outfile ? outfile : "");
  2200. #endif
  2201.   tee_fprintf(stdout, "Server version:tt%sn", mysql_get_server_info(&mysql));
  2202.   tee_fprintf(stdout, "Protocol version:t%dn", mysql_get_proto_info(&mysql));
  2203.   tee_fprintf(stdout, "Connection:tt%sn", mysql_get_host_info(&mysql));
  2204.   tee_fprintf(stdout, "Client characterset:t%sn",
  2205.       default_charset_info->name);
  2206.   tee_fprintf(stdout, "Server characterset:t%sn", mysql.charset->name);
  2207.   if (strstr(mysql_get_host_info(&mysql),"TCP/IP") || ! mysql.unix_socket)
  2208.     tee_fprintf(stdout, "TCP port:tt%dn", mysql.port);
  2209.   else
  2210.     tee_fprintf(stdout, "UNIX socket:tt%sn", mysql.unix_socket);
  2211.   if (mysql.net.compress)
  2212.     tee_fprintf(stdout, "Protocol:ttCompressedn");
  2214.   if ((status=mysql_stat(&mysql)) && !mysql_error(&mysql)[0])
  2215.   {
  2216.     char *pos,buff[40];
  2217.     ulong sec;
  2218.     pos=strchr(status,' ');
  2219.     *pos++=0;
  2220.     tee_fprintf(stdout, "%sttt", status); /* print label */
  2221.     if ((status=str2int(pos,10,0,LONG_MAX,(long*) &sec)))
  2222.     {
  2223.       nice_time((double) sec,buff,0);
  2224.       tee_puts(buff, stdout); /* print nice time */
  2225.       while (*status == ' ') status++; /* to next info */
  2226.     }
  2227.     if (status)
  2228.     {
  2229.       tee_putc('n', stdout);
  2230.       tee_puts(status, stdout);
  2231.     }
  2232.   }
  2233.   if (safe_updates)
  2234.   {
  2235.     vidattr(A_BOLD);
  2236.     tee_fprintf(stdout, "nNote that you are running in safe_update_mode:n");
  2237.     vidattr(A_NORMAL);
  2238.     tee_fprintf(stdout, "
  2239. UPDATEs and DELETEs that don't use a key in the WHERE clause are not allowed.n
  2240. (One can force an UPDATE/DELETE by adding LIMIT # at the end of the command.)n
  2241. SELECT has an automatic 'LIMIT %lu' if LIMIT is not used.n
  2242. Max number of examined row combination in a join is set to: %lunn",
  2243. select_limit, max_join_size);
  2244.   }
  2245.   tee_puts("--------------n", stdout);
  2246.   return 0;
  2247. }
  2250. static int
  2251. put_info(const char *str,INFO_TYPE info_type,uint error)
  2252. {
  2253.   static int inited=0;
  2254.   
  2255.   if (status.batch)
  2256.   {
  2257.     if (info_type == INFO_ERROR)
  2258.     {
  2259.       (void) fflush(stdout);
  2260.       fprintf(stderr,"ERROR");
  2261.       if (error)
  2262. (void) fprintf(stderr," %d",error);
  2263.       if (status.query_start_line && ! skip_line_numbers)
  2264.       {
  2265. (void) fprintf(stderr," at line %lu",status.query_start_line);
  2266. if (status.file_name)
  2267.   (void) fprintf(stderr," in file: '%s'", status.file_name);
  2268.       }
  2269.       (void) fprintf(stderr,": %sn",str);
  2270.       (void) fflush(stderr);
  2271.       if (!ignore_errors)
  2272. return 1;
  2273.     }
  2274.     else if (info_type == INFO_RESULT && verbose > 1)
  2275.       tee_puts(str, stdout);
  2276.     if (unbuffered)
  2277.       fflush(stdout);
  2278.     return info_type == INFO_ERROR ? -1 : 0;
  2279.   }
  2280.   if (!opt_silent || info_type == INFO_ERROR)
  2281.   {
  2282.     if (!inited)
  2283.     {
  2284.       inited=1;
  2285. #ifdef HAVE_SETUPTERM
  2286.       (void) setupterm((char *)0, 1, (int *) 0);
  2287. #endif
  2288.     }
  2289.     if (info_type == INFO_ERROR)
  2290.     {
  2291.       putchar('07'); /* This should make a bell */
  2292.       vidattr(A_STANDOUT);
  2293.       if (error)
  2294.         (void) tee_fprintf(stderr, "ERROR %d: ", error);
  2295.       else
  2296.         tee_puts("ERROR: ", stdout);
  2297.     }
  2298.     else
  2299.       vidattr(A_BOLD);
  2300.     (void) tee_puts(str, stdout);
  2301.     vidattr(A_NORMAL);
  2302.   }
  2303.   if (unbuffered)
  2304.     fflush(stdout);
  2305.   return info_type == INFO_ERROR ? -1 : 0;
  2306. }
  2309. static void remove_cntrl(String &buffer)
  2310. {
  2311.   char *start,*end;
  2312.   end=(start=(char*) buffer.ptr())+buffer.length();
  2313.   while (start < end && !isgraph(end[-1]))
  2314.     end--;
  2315.   buffer.length((uint) (end-start));
  2316. }
  2319. void tee_fprintf(FILE *file, const char *fmt, ...)
  2320. {
  2321.   va_list args;
  2323.   va_start(args, fmt);
  2324.   (void) vfprintf(file, fmt, args);
  2325.   if (opt_outfile)
  2326.     (void) vfprintf(OUTFILE, fmt, args);
  2327.   va_end(args);
  2328. }
  2331. void tee_fputs(const char *s, FILE *file)
  2332. {
  2333.   fputs(s, file);
  2334.   if (opt_outfile)
  2335.     fputs(s, OUTFILE);
  2336. }
  2339. void tee_puts(const char *s, FILE *file)
  2340. {
  2341.   fputs(s, file);
  2342.   fputs("n", file);
  2343.   if (opt_outfile)
  2344.   {
  2345.     fputs(s, OUTFILE);
  2346.     fputs("n", OUTFILE);
  2347.   }
  2348. }
  2350. void tee_putc(int c, FILE *file)
  2351. {
  2352.   putc(c, file);
  2353.   if (opt_outfile)
  2354.     putc(c, OUTFILE);
  2355. }
  2357. #ifdef __WIN__
  2358. #include <time.h>
  2359. #else
  2360. #include <sys/times.h>
  2361. #undef CLOCKS_PER_SEC
  2362. #define CLOCKS_PER_SEC (sysconf(_SC_CLK_TCK))
  2363. #endif
  2365. static ulong start_timer(void)
  2366. {
  2367. #ifdef __WIN__
  2368.  return clock();
  2369. #else
  2370.   struct tms tms_tmp;
  2371.   return times(&tms_tmp);
  2372. #endif
  2373. }
  2376. static void nice_time(double sec,char *buff,bool part_second)
  2377. {
  2378.   ulong tmp;
  2379.   if (sec >= 3600.0*24)
  2380.   {
  2381.     tmp=(ulong) floor(sec/(3600.0*24));
  2382.     sec-=3600.0*24*tmp;
  2383.     buff=int2str((long) tmp,buff,10);
  2384.     buff=strmov(buff,tmp > 1 ? " days " : " day ");
  2385.   }
  2386.   if (sec >= 3600.0)
  2387.   {
  2388.     tmp=(ulong) floor(sec/3600.0);
  2389.     sec-=3600.0*tmp;
  2390.     buff=int2str((long) tmp,buff,10);
  2391.     buff=strmov(buff,tmp > 1 ? " hours " : " hour ");
  2392.   }
  2393.   if (sec >= 60.0)
  2394.   {
  2395.     tmp=(ulong) floor(sec/60.0);
  2396.     sec-=60.0*tmp;
  2397.     buff=int2str((long) tmp,buff,10);
  2398.     buff=strmov(buff," min ");
  2399.   }
  2400.   if (part_second)
  2401.     sprintf(buff,"%.2f sec",sec);
  2402.   else
  2403.     sprintf(buff,"%d sec",(int) sec);
  2404. }
  2407. static void end_timer(ulong start_time,char *buff)
  2408. {
  2409.   nice_time((double) (start_timer() - start_time) /
  2410.     CLOCKS_PER_SEC,buff,1);
  2411. }
  2414. static void mysql_end_timer(ulong start_time,char *buff)
  2415. {
  2416.   buff[0]=' ';
  2417.   buff[1]='(';
  2418.   end_timer(start_time,buff+2);
  2419.   strmov(strend(buff),")");
  2420. }
  2422. /* Keep sql_string library happy */
  2424. gptr sql_alloc(unsigned int Size)
  2425. {
  2426.   return my_malloc(Size,MYF(MY_WME));
  2427. }
  2429. void sql_element_free(void *ptr)
  2430. {
  2431.   my_free((gptr) ptr,MYF(0));
  2432. }