mirror of
https://github.com/MariaDB/server.git
synced 2025-01-22 14:54:20 +01:00
85a590a26c
Moved .progress files into the log directory Moved 'cluster' database tables into the MySQL database, to not have 'cluster' beeing a reserved database name Fixed bug where mysqld got a core dump when trying to use a table created by MySQL 3.23 Fixed some compiler warnings Fixed small memory leak in libmysql Note that this doesn't changeset doesn't include the new mysqldump.c code required to run some tests. This will be added when I merge 5.0 to 5.1 client/client_priv.h: Added OPT_DEBUG_INFO and OPT_COLUMN_TYPES client/mysql.cc: Split --debug-info into --debug-info and --column-type-info client/mysql_upgrade.c: Give only error info at end if using --debug-info client/mysqladmin.cc: Added --debug-info to detect memory leaks in mysqltest client/mysqlbinlog.cc: Added --debug-info to detect memory leaks in mysqltest client/mysqlcheck.c: Added --debug-info to detect memory leaks in mysqltest client/mysqlimport.c: Added --debug-info to detect memory leaks in mysqltest client/mysqlshow.c: Added --debug-info to detect memory leaks in mysqltest client/mysqltest.c: Added --debug-info to detect memory leaks in mysqltest Added option --logdir to force .progress files in a specific directory libmysql/libmysql.c: Fixed memory leak mysql-test/include/ndb_setup_slave.inc: Moved cluster tables under 'mysql' mysql-test/include/query_cache.inc: Added more tests for query cache mysql-test/lib/init_db.sql: Move cluster.binlog_index -> mysql.binlog_index mysql-test/lib/mtr_report.pl: Find memory leaks mysql-test/mysql-test-run-shell.sh: Added --debug-info to programs to detect memory leaks mysql-test/mysql-test-run.pl: Added --debug-info to programs to detect memory leaks Force log files to var/log cluster tables moved under 'mysql' mysql-test/r/cache_innodb.result: New query cache test with innodb mysql-test/r/connect.result: binlog_index is now in mysql mysql-test/r/drop.result: Removed 'cluster' database mysql-test/r/information_schema.result: Removed 'cluster' database mysql-test/r/mysqlcheck.result: cluster.binlog_index -> mysql.binlog_index mysql-test/r/ndb_binlog_basic.result: cluster.binlog_index -> mysql.binlog_index mysql-test/r/ndb_binlog_ddl_multi.result: cluster -> mysql mysql-test/r/ndb_binlog_discover.result: cluster -> mysql mysql-test/r/ndb_binlog_multi.result: cluster -> mysql mysql-test/r/ndb_restore_compat.result: cluster -> mysql mysql-test/r/ps_1general.result: Removed cluster database mysql-test/r/rpl_create_database.result: Removed cluster database mysql-test/r/rpl_load_from_master.result: Removed cluster database mysql-test/r/rpl_loaddata_m.result: Removed cluster database mysql-test/r/rpl_ndb_bank.result: cluster -> mysql mysql-test/r/rpl_ndb_dd_advance.result: cluster -> mysql mysql-test/r/rpl_ndb_dd_basic.result: cluster -> mysql mysql-test/r/rpl_ndb_idempotent.result: cluster -> mysql mysql-test/r/rpl_ndb_log.result: cluster -> mysql mysql-test/r/rpl_ndb_multi.result: cluster -> mysql mysql-test/r/rpl_ndb_sync.result: cluster -> mysql mysql-test/r/rpl_row_basic_11bugs.result: Removed cluster database mysql-test/r/rpl_truncate_7ndb.result: Position have changed mysql-test/r/rpl_truncate_7ndb_2.result: cluster -> mysql mysql-test/r/schema.result: Removed cluster database mysql-test/r/show_check.result: Removed cluster database mysql-test/r/system_mysql_db.result: binlog_index moved under mysql mysql-test/r/upgrade.result: More tests mysql-test/t/information_schema.test: cluster -> mysql mysql-test/t/mysqldump.test: More test to detect memory leaks mysql-test/t/ndb_binlog_basic.test: cluster -> mysql mysql-test/t/ndb_binlog_multi.test: cluster -> mysql mysql-test/t/ndb_restore_compat.test: cluster -> mysql mysql-test/t/rpl_ndb_bank.test: cluster -> mysql mysql-test/t/rpl_ndb_dd_advance.test: cluster -> mysql mysql-test/t/rpl_ndb_idempotent.test: cluster -> mysql mysql-test/t/rpl_ndb_multi.test: cluster -> mysql mysql-test/t/rpl_ndb_sync.test: cluster -> mysql mysql-test/t/system_mysql_db_fix.test: Drop also binlog_index mysql-test/t/upgrade.test: Check that tables created with 3.23 works mysys/my_error.c: Remove all registered errors (to avoid memory leaks) mysys/my_init.c: call my_error_unregister_all() to avoid some possible memory leaks mysys/mysys_priv.h: Added prototype scripts/mysql_create_system_tables.sh: cluster -> mysql scripts/mysql_fix_privilege_tables.sql: Changed -- to # Create binlog_index table if it dosesn't exist sql/field.cc: Made offset() inline sql/field.h: Changed prototype of offset() to not make it depending on TABLE structure sql/field_conv.cc: Removed some usage of current_thd sql/ha_ndbcluster_tables.h: cluster -> mysql sql/item_sum.cc: Usage of new 'offset' parameters sql/key.cc: Changed 'find_ref_key' to not be dependent on field->table (This fixed a crash when using a table created in MySQL 3.23) sql/mysql_priv.h: Changed find_ref_key() to not use field->table sql/mysqld.cc: Fix that plugin_init() works properly on bootstrap (Previously we got warnings from plugin_init) sql/sql_class.cc: new 'field->offset()' sql/sql_select.cc: New field->offset() sql/table.cc: We don't need field->table to be set in find_ref_key() or find_field() anymore. storage/archive/ha_archive.cc: New field->offset() storage/federated/ha_federated.cc: New field->offset() storage/innobase/handler/ha_innodb.cc: Fixed compiler warnings storage/myisam/ha_myisam.cc: Fixed compiler warnings (Wrong paramter to sprintf()) New field->offset() storage/myisam/ha_myisam.h: Fixed wrong type of table_flags storage/ndb/tools/restore/Restore.cpp: Fixed compiler warning mysql-test/r/1st.result: New BitKeeper file ``mysql-test/r/1st.result'' mysql-test/std_data/old_table-323.frm: New BitKeeper file ``mysql-test/std_data/old_table-323.frm'' mysql-test/t/1st.test: New BitKeeper file ``mysql-test/t/1st.test''
889 lines
24 KiB
C
889 lines
24 KiB
C
/* Copyright (C) 2000 MySQL AB
|
|
|
|
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.
|
|
|
|
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.
|
|
|
|
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 */
|
|
|
|
/* Show databases, tables or columns */
|
|
|
|
#define SHOW_VERSION "9.6"
|
|
|
|
#include "client_priv.h"
|
|
#include <my_sys.h>
|
|
#include <m_string.h>
|
|
#include <mysql.h>
|
|
#include <mysqld_error.h>
|
|
#include <signal.h>
|
|
#include <stdarg.h>
|
|
#include <sslopt-vars.h>
|
|
|
|
static my_string host=0,opt_password=0,user=0;
|
|
static my_bool opt_show_keys= 0, opt_compress= 0, opt_count=0, opt_status= 0;
|
|
static my_bool tty_password= 0, opt_table_type= 0, info_flag= 0;
|
|
static uint opt_verbose=0;
|
|
static char *default_charset= (char*) MYSQL_DEFAULT_CHARSET_NAME;
|
|
|
|
#ifdef HAVE_SMEM
|
|
static char *shared_memory_base_name=0;
|
|
#endif
|
|
static uint opt_protocol=0;
|
|
|
|
static void get_options(int *argc,char ***argv);
|
|
static uint opt_mysql_port=0;
|
|
static int list_dbs(MYSQL *mysql,const char *wild);
|
|
static int list_tables(MYSQL *mysql,const char *db,const char *table);
|
|
static int list_table_status(MYSQL *mysql,const char *db,const char *table);
|
|
static int list_fields(MYSQL *mysql,const char *db,const char *table,
|
|
const char *field);
|
|
static void print_header(const char *header,uint head_length,...);
|
|
static void print_row(const char *header,uint head_length,...);
|
|
static void print_trailer(uint length,...);
|
|
static void print_res_header(MYSQL_RES *result);
|
|
static void print_res_top(MYSQL_RES *result);
|
|
static void print_res_row(MYSQL_RES *result,MYSQL_ROW cur);
|
|
|
|
static const char *load_default_groups[]= { "mysqlshow","client",0 };
|
|
static my_string opt_mysql_unix_port=0;
|
|
|
|
int main(int argc, char **argv)
|
|
{
|
|
int error;
|
|
my_bool first_argument_uses_wildcards=0;
|
|
char *wild;
|
|
MYSQL mysql;
|
|
MY_INIT(argv[0]);
|
|
load_defaults("my",load_default_groups,&argc,&argv);
|
|
get_options(&argc,&argv);
|
|
|
|
wild=0;
|
|
if (argc)
|
|
{
|
|
char *pos= argv[argc-1], *to;
|
|
for (to= pos ; *pos ; pos++, to++)
|
|
{
|
|
switch (*pos) {
|
|
case '*':
|
|
*pos= '%';
|
|
first_argument_uses_wildcards= 1;
|
|
break;
|
|
case '?':
|
|
*pos= '_';
|
|
first_argument_uses_wildcards= 1;
|
|
break;
|
|
case '%':
|
|
case '_':
|
|
first_argument_uses_wildcards= 1;
|
|
break;
|
|
case '\\':
|
|
pos++;
|
|
default: break;
|
|
}
|
|
*to= *pos;
|
|
}
|
|
*to= *pos; /* just to copy a '\0' if '\\' was used */
|
|
}
|
|
if (first_argument_uses_wildcards)
|
|
wild= argv[--argc];
|
|
else if (argc == 3) /* We only want one field */
|
|
wild= argv[--argc];
|
|
|
|
if (argc > 2)
|
|
{
|
|
fprintf(stderr,"%s: Too many arguments\n",my_progname);
|
|
exit(1);
|
|
}
|
|
mysql_init(&mysql);
|
|
if (opt_compress)
|
|
mysql_options(&mysql,MYSQL_OPT_COMPRESS,NullS);
|
|
#ifdef HAVE_OPENSSL
|
|
if (opt_use_ssl)
|
|
mysql_ssl_set(&mysql, opt_ssl_key, opt_ssl_cert, opt_ssl_ca,
|
|
opt_ssl_capath, opt_ssl_cipher);
|
|
mysql_options(&mysql,MYSQL_OPT_SSL_VERIFY_SERVER_CERT,
|
|
(char*)&opt_ssl_verify_server_cert);
|
|
#endif
|
|
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);
|
|
#endif
|
|
mysql_options(&mysql, MYSQL_SET_CHARSET_NAME, default_charset);
|
|
|
|
if (!(mysql_real_connect(&mysql,host,user,opt_password,
|
|
(first_argument_uses_wildcards) ? "" : argv[0],opt_mysql_port,opt_mysql_unix_port,
|
|
0)))
|
|
{
|
|
fprintf(stderr,"%s: %s\n",my_progname,mysql_error(&mysql));
|
|
exit(1);
|
|
}
|
|
mysql.reconnect= 1;
|
|
|
|
switch (argc) {
|
|
case 0: error=list_dbs(&mysql,wild); break;
|
|
case 1:
|
|
if (opt_status)
|
|
error=list_table_status(&mysql,argv[0],wild);
|
|
else
|
|
error=list_tables(&mysql,argv[0],wild);
|
|
break;
|
|
default:
|
|
if (opt_status && ! wild)
|
|
error=list_table_status(&mysql,argv[0],argv[1]);
|
|
else
|
|
error=list_fields(&mysql,argv[0],argv[1],wild);
|
|
break;
|
|
}
|
|
mysql_close(&mysql); /* Close & free connection */
|
|
if (opt_password)
|
|
my_free(opt_password,MYF(0));
|
|
#ifdef HAVE_SMEM
|
|
my_free(shared_memory_base_name,MYF(MY_ALLOW_ZERO_PTR));
|
|
#endif
|
|
my_end(info_flag ? MY_CHECK_ERROR : 0);
|
|
exit(error ? 1 : 0);
|
|
return 0; /* No compiler warnings */
|
|
}
|
|
|
|
static struct my_option my_long_options[] =
|
|
{
|
|
#ifdef __NETWARE__
|
|
{"autoclose", OPT_AUTO_CLOSE, "Auto close the screen on exit for Netware.",
|
|
0, 0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0},
|
|
#endif
|
|
{"character-sets-dir", 'c', "Directory where character sets are.",
|
|
(gptr*) &charsets_dir, (gptr*) &charsets_dir, 0, GET_STR, REQUIRED_ARG, 0,
|
|
0, 0, 0, 0, 0},
|
|
{"default-character-set", OPT_DEFAULT_CHARSET,
|
|
"Set the default character set.", (gptr*) &default_charset,
|
|
(gptr*) &default_charset, 0, GET_STR, REQUIRED_ARG, 0, 0, 0, 0, 0, 0},
|
|
{"count", OPT_COUNT,
|
|
"Show number of rows per table (may be slow for not MyISAM tables)",
|
|
(gptr*) &opt_count, (gptr*) &opt_count, 0, GET_BOOL, NO_ARG, 0, 0, 0,
|
|
0, 0, 0},
|
|
{"compress", 'C', "Use compression in server/client protocol.",
|
|
(gptr*) &opt_compress, (gptr*) &opt_compress, 0, GET_BOOL, NO_ARG, 0, 0, 0,
|
|
0, 0, 0},
|
|
{"debug", '#', "Output debug log. Often this is 'd:t:o,filename'.",
|
|
0, 0, 0, GET_STR, OPT_ARG, 0, 0, 0, 0, 0, 0},
|
|
{"debug-info", OPT_DEBUG_INFO, "Print some debug info at exit.", (gptr*) &info_flag,
|
|
(gptr*) &info_flag, 0, GET_BOOL, NO_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},
|
|
{"host", 'h', "Connect to host.", (gptr*) &host, (gptr*) &host, 0, GET_STR,
|
|
REQUIRED_ARG, 0, 0, 0, 0, 0, 0},
|
|
{"status", 'i', "Shows a lot of extra information about each table.",
|
|
(gptr*) &opt_status, (gptr*) &opt_status, 0, GET_BOOL, NO_ARG, 0, 0, 0, 0,
|
|
0, 0},
|
|
{"keys", 'k', "Show keys for table.", (gptr*) &opt_show_keys,
|
|
(gptr*) &opt_show_keys, 0, GET_BOOL, NO_ARG, 0, 0, 0, 0, 0, 0},
|
|
{"password", 'p',
|
|
"Password to use when connecting to server. If password is not given it's asked from the tty.",
|
|
0, 0, 0, GET_STR, OPT_ARG, 0, 0, 0, 0, 0, 0},
|
|
{"port", 'P', "Port number to use for connection.", (gptr*) &opt_mysql_port,
|
|
(gptr*) &opt_mysql_port, 0, GET_UINT, REQUIRED_ARG, 0, 0, 0, 0, 0,
|
|
0},
|
|
#ifdef __WIN__
|
|
{"pipe", 'W', "Use named pipes to connect to server.", 0, 0, 0, GET_NO_ARG,
|
|
NO_ARG, 0, 0, 0, 0, 0, 0},
|
|
#endif
|
|
{"protocol", OPT_MYSQL_PROTOCOL, "The protocol of connection (tcp,socket,pipe,memory).",
|
|
0, 0, 0, GET_STR, REQUIRED_ARG, 0, 0, 0, 0, 0, 0},
|
|
#ifdef HAVE_SMEM
|
|
{"shared-memory-base-name", OPT_SHARED_MEMORY_BASE_NAME,
|
|
"Base name of shared memory.", (gptr*) &shared_memory_base_name, (gptr*) &shared_memory_base_name,
|
|
0, GET_STR_ALLOC, REQUIRED_ARG, 0, 0, 0, 0, 0, 0},
|
|
#endif
|
|
{"show-table-type", 't', "Show table type column.",
|
|
(gptr*) &opt_table_type, (gptr*) &opt_table_type, 0, GET_BOOL,
|
|
NO_ARG, 0, 0, 0, 0, 0, 0},
|
|
{"socket", 'S', "Socket file to use for connection.",
|
|
(gptr*) &opt_mysql_unix_port, (gptr*) &opt_mysql_unix_port, 0, GET_STR,
|
|
REQUIRED_ARG, 0, 0, 0, 0, 0, 0},
|
|
#include <sslopt-longopts.h>
|
|
#ifndef DONT_ALLOW_USER_CHANGE
|
|
{"user", 'u', "User for login if not current user.", (gptr*) &user,
|
|
(gptr*) &user, 0, GET_STR, REQUIRED_ARG, 0, 0, 0, 0, 0, 0},
|
|
#endif
|
|
{"verbose", 'v',
|
|
"More verbose output; You can use this multiple times to get even more verbose output.",
|
|
0, 0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0},
|
|
{"version", 'V', "Output version information and exit.", 0, 0, 0, GET_NO_ARG,
|
|
NO_ARG, 0, 0, 0, 0, 0, 0},
|
|
{0, 0, 0, 0, 0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0}
|
|
};
|
|
|
|
|
|
#include <help_start.h>
|
|
|
|
static void print_version(void)
|
|
{
|
|
printf("%s Ver %s Distrib %s, for %s (%s)\n",my_progname,SHOW_VERSION,
|
|
MYSQL_SERVER_VERSION,SYSTEM_TYPE,MACHINE_TYPE);
|
|
NETWARE_SET_SCREEN_MODE(1);
|
|
}
|
|
|
|
|
|
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");
|
|
puts("Shows the structure of a mysql database (databases,tables and columns)\n");
|
|
printf("Usage: %s [OPTIONS] [database [table [column]]]\n",my_progname);
|
|
puts("\n\
|
|
If last argument contains a shell or SQL wildcard (*,?,% or _) then only\n\
|
|
what\'s matched by the wildcard is shown.\n\
|
|
If no database is given then all matching databases are shown.\n\
|
|
If no table is given then all matching tables in database are shown\n\
|
|
If no column is given then all matching columns and columntypes in table\n\
|
|
are shown");
|
|
print_defaults("my",load_default_groups);
|
|
my_print_help(my_long_options);
|
|
my_print_variables(my_long_options);
|
|
}
|
|
|
|
#include <help_end.h>
|
|
|
|
static my_bool
|
|
get_one_option(int optid, const struct my_option *opt __attribute__((unused)),
|
|
char *argument)
|
|
{
|
|
switch(optid) {
|
|
#ifdef __NETWARE__
|
|
case OPT_AUTO_CLOSE:
|
|
setscreenmode(SCR_AUTOCLOSE_ON_EXIT);
|
|
break;
|
|
#endif
|
|
case 'v':
|
|
opt_verbose++;
|
|
break;
|
|
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 */
|
|
tty_password= 0;
|
|
}
|
|
else
|
|
tty_password=1;
|
|
break;
|
|
case 'W':
|
|
#ifdef __WIN__
|
|
opt_protocol = MYSQL_PROTOCOL_PIPE;
|
|
#endif
|
|
break;
|
|
case OPT_MYSQL_PROTOCOL:
|
|
{
|
|
if ((opt_protocol= find_type(argument, &sql_protocol_typelib,0)) <= 0)
|
|
{
|
|
fprintf(stderr, "Unknown option to protocol: %s\n", argument);
|
|
exit(1);
|
|
}
|
|
break;
|
|
}
|
|
case '#':
|
|
DBUG_PUSH(argument ? argument : "d:t:o");
|
|
break;
|
|
#include <sslopt-case.h>
|
|
case 'V':
|
|
print_version();
|
|
exit(0);
|
|
break;
|
|
case '?':
|
|
case 'I': /* Info */
|
|
usage();
|
|
exit(0);
|
|
}
|
|
return 0;
|
|
}
|
|
|
|
|
|
static void
|
|
get_options(int *argc,char ***argv)
|
|
{
|
|
int ho_error;
|
|
|
|
if ((ho_error=handle_options(argc, argv, my_long_options, get_one_option)))
|
|
exit(ho_error);
|
|
|
|
if (tty_password)
|
|
opt_password=get_tty_password(NullS);
|
|
if (opt_count)
|
|
{
|
|
/*
|
|
We need to set verbose to 2 as we need to change the output to include
|
|
the number-of-rows column
|
|
*/
|
|
opt_verbose= 2;
|
|
}
|
|
return;
|
|
}
|
|
|
|
|
|
static int
|
|
list_dbs(MYSQL *mysql,const char *wild)
|
|
{
|
|
const char *header;
|
|
uint length, counter = 0;
|
|
ulong rowcount = 0L;
|
|
char tables[NAME_LEN+1], rows[NAME_LEN+1];
|
|
char query[255];
|
|
MYSQL_FIELD *field;
|
|
MYSQL_RES *result;
|
|
MYSQL_ROW row= NULL, rrow;
|
|
|
|
if (!(result=mysql_list_dbs(mysql,wild)))
|
|
{
|
|
fprintf(stderr,"%s: Cannot list databases: %s\n",my_progname,
|
|
mysql_error(mysql));
|
|
return 1;
|
|
}
|
|
|
|
/*
|
|
If a wildcard was used, but there was only one row and it's name is an
|
|
exact match, we'll assume they really wanted to see the contents of that
|
|
database. This is because it is fairly common for database names to
|
|
contain the underscore (_), like INFORMATION_SCHEMA.
|
|
*/
|
|
if (wild && mysql_num_rows(result) == 1)
|
|
{
|
|
row= mysql_fetch_row(result);
|
|
if (!my_strcasecmp(&my_charset_latin1, row[0], wild))
|
|
{
|
|
mysql_free_result(result);
|
|
if (opt_status)
|
|
return list_table_status(mysql, wild, NULL);
|
|
else
|
|
return list_tables(mysql, wild, NULL);
|
|
}
|
|
}
|
|
|
|
if (wild)
|
|
printf("Wildcard: %s\n",wild);
|
|
|
|
header="Databases";
|
|
length=(uint) strlen(header);
|
|
field=mysql_fetch_field(result);
|
|
if (length < field->max_length)
|
|
length=field->max_length;
|
|
|
|
if (!opt_verbose)
|
|
print_header(header,length,NullS);
|
|
else if (opt_verbose == 1)
|
|
print_header(header,length,"Tables",6,NullS);
|
|
else
|
|
print_header(header,length,"Tables",6,"Total Rows",12,NullS);
|
|
|
|
/* The first row may have already been read up above. */
|
|
while (row || (row= mysql_fetch_row(result)))
|
|
{
|
|
counter++;
|
|
|
|
if (opt_verbose)
|
|
{
|
|
if (!(mysql_select_db(mysql,row[0])))
|
|
{
|
|
MYSQL_RES *tresult = mysql_list_tables(mysql,(char*)NULL);
|
|
if (mysql_affected_rows(mysql) > 0)
|
|
{
|
|
sprintf(tables,"%6lu",(ulong) mysql_affected_rows(mysql));
|
|
rowcount = 0;
|
|
if (opt_verbose > 1)
|
|
{
|
|
/* Print the count of tables and rows for each database */
|
|
MYSQL_ROW trow;
|
|
while ((trow = mysql_fetch_row(tresult)))
|
|
{
|
|
sprintf(query,"SELECT COUNT(*) FROM `%s`",trow[0]);
|
|
if (!(mysql_query(mysql,query)))
|
|
{
|
|
MYSQL_RES *rresult;
|
|
if ((rresult = mysql_store_result(mysql)))
|
|
{
|
|
rrow = mysql_fetch_row(rresult);
|
|
rowcount += (ulong) strtoull(rrow[0], (char**) 0, 10);
|
|
mysql_free_result(rresult);
|
|
}
|
|
}
|
|
}
|
|
sprintf(rows,"%12lu",rowcount);
|
|
}
|
|
}
|
|
else
|
|
{
|
|
sprintf(tables,"%6d",0);
|
|
sprintf(rows,"%12d",0);
|
|
}
|
|
mysql_free_result(tresult);
|
|
}
|
|
else
|
|
{
|
|
strmov(tables,"N/A");
|
|
strmov(rows,"N/A");
|
|
}
|
|
}
|
|
|
|
if (!opt_verbose)
|
|
print_row(row[0],length,0);
|
|
else if (opt_verbose == 1)
|
|
print_row(row[0],length,tables,6,NullS);
|
|
else
|
|
print_row(row[0],length,tables,6,rows,12,NullS);
|
|
|
|
row= NULL;
|
|
}
|
|
|
|
print_trailer(length,
|
|
(opt_verbose > 0 ? 6 : 0),
|
|
(opt_verbose > 1 ? 12 :0),
|
|
0);
|
|
|
|
if (counter && opt_verbose)
|
|
printf("%u row%s in set.\n",counter,(counter > 1) ? "s" : "");
|
|
mysql_free_result(result);
|
|
return 0;
|
|
}
|
|
|
|
|
|
static int
|
|
list_tables(MYSQL *mysql,const char *db,const char *table)
|
|
{
|
|
const char *header;
|
|
uint head_length, counter = 0;
|
|
char query[255], rows[NAME_LEN], fields[16];
|
|
MYSQL_FIELD *field;
|
|
MYSQL_RES *result;
|
|
MYSQL_ROW row, rrow;
|
|
|
|
if (mysql_select_db(mysql,db))
|
|
{
|
|
fprintf(stderr,"%s: Cannot connect to db %s: %s\n",my_progname,db,
|
|
mysql_error(mysql));
|
|
return 1;
|
|
}
|
|
if (table)
|
|
{
|
|
/*
|
|
We just hijack the 'rows' variable for a bit to store the escaped
|
|
table name
|
|
*/
|
|
mysql_real_escape_string(mysql, rows, table, (unsigned long)strlen(table));
|
|
my_snprintf(query, sizeof(query), "show%s tables like '%s'",
|
|
opt_table_type ? " full" : "", rows);
|
|
}
|
|
else
|
|
my_snprintf(query, sizeof(query), "show%s tables",
|
|
opt_table_type ? " full" : "");
|
|
if (mysql_query(mysql, query) || !(result= mysql_store_result(mysql)))
|
|
{
|
|
fprintf(stderr,"%s: Cannot list tables in %s: %s\n",my_progname,db,
|
|
mysql_error(mysql));
|
|
exit(1);
|
|
}
|
|
printf("Database: %s",db);
|
|
if (table)
|
|
printf(" Wildcard: %s",table);
|
|
putchar('\n');
|
|
|
|
header="Tables";
|
|
head_length=(uint) strlen(header);
|
|
field=mysql_fetch_field(result);
|
|
if (head_length < field->max_length)
|
|
head_length=field->max_length;
|
|
|
|
if (opt_table_type)
|
|
{
|
|
if (!opt_verbose)
|
|
print_header(header,head_length,"table_type",10,NullS);
|
|
else if (opt_verbose == 1)
|
|
print_header(header,head_length,"table_type",10,"Columns",8,NullS);
|
|
else
|
|
{
|
|
print_header(header,head_length,"table_type",10,"Columns",8,
|
|
"Total Rows",10,NullS);
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!opt_verbose)
|
|
print_header(header,head_length,NullS);
|
|
else if (opt_verbose == 1)
|
|
print_header(header,head_length,"Columns",8,NullS);
|
|
else
|
|
print_header(header,head_length,"Columns",8, "Total Rows",10,NullS);
|
|
}
|
|
|
|
while ((row = mysql_fetch_row(result)))
|
|
{
|
|
counter++;
|
|
if (opt_verbose > 0)
|
|
{
|
|
if (!(mysql_select_db(mysql,db)))
|
|
{
|
|
MYSQL_RES *rresult = mysql_list_fields(mysql,row[0],NULL);
|
|
ulong rowcount=0L;
|
|
if (!rresult)
|
|
{
|
|
strmov(fields,"N/A");
|
|
strmov(rows,"N/A");
|
|
}
|
|
else
|
|
{
|
|
sprintf(fields,"%8u",(uint) mysql_num_fields(rresult));
|
|
mysql_free_result(rresult);
|
|
|
|
if (opt_verbose > 1)
|
|
{
|
|
/* Print the count of rows for each table */
|
|
sprintf(query,"SELECT COUNT(*) FROM `%s`",row[0]);
|
|
if (!(mysql_query(mysql,query)))
|
|
{
|
|
if ((rresult = mysql_store_result(mysql)))
|
|
{
|
|
rrow = mysql_fetch_row(rresult);
|
|
rowcount += (unsigned long) strtoull(rrow[0], (char**) 0, 10);
|
|
mysql_free_result(rresult);
|
|
}
|
|
sprintf(rows,"%10lu",rowcount);
|
|
}
|
|
else
|
|
sprintf(rows,"%10d",0);
|
|
}
|
|
}
|
|
}
|
|
else
|
|
{
|
|
strmov(fields,"N/A");
|
|
strmov(rows,"N/A");
|
|
}
|
|
}
|
|
if (opt_table_type)
|
|
{
|
|
if (!opt_verbose)
|
|
print_row(row[0],head_length,row[1],10,NullS);
|
|
else if (opt_verbose == 1)
|
|
print_row(row[0],head_length,row[1],10,fields,8,NullS);
|
|
else
|
|
print_row(row[0],head_length,row[1],10,fields,8,rows,10,NullS);
|
|
}
|
|
else
|
|
{
|
|
if (!opt_verbose)
|
|
print_row(row[0],head_length,NullS);
|
|
else if (opt_verbose == 1)
|
|
print_row(row[0],head_length, fields,8, NullS);
|
|
else
|
|
print_row(row[0],head_length, fields,8, rows,10, NullS);
|
|
}
|
|
}
|
|
|
|
print_trailer(head_length,
|
|
(opt_table_type ? 10 : opt_verbose > 0 ? 8 : 0),
|
|
(opt_table_type ? (opt_verbose > 0 ? 8 : 0)
|
|
: (opt_verbose > 1 ? 10 :0)),
|
|
!opt_table_type ? 0 : opt_verbose > 1 ? 10 :0,
|
|
0);
|
|
|
|
if (counter && opt_verbose)
|
|
printf("%u row%s in set.\n\n",counter,(counter > 1) ? "s" : "");
|
|
|
|
mysql_free_result(result);
|
|
return 0;
|
|
}
|
|
|
|
|
|
static int
|
|
list_table_status(MYSQL *mysql,const char *db,const char *wild)
|
|
{
|
|
char query[1024],*end;
|
|
MYSQL_RES *result;
|
|
MYSQL_ROW row;
|
|
|
|
end=strxmov(query,"show table status from `",db,"`",NullS);
|
|
if (wild && wild[0])
|
|
strxmov(end," like '",wild,"'",NullS);
|
|
if (mysql_query(mysql,query) || !(result=mysql_store_result(mysql)))
|
|
{
|
|
fprintf(stderr,"%s: Cannot get status for db: %s, table: %s: %s\n",
|
|
my_progname,db,wild ? wild : "",mysql_error(mysql));
|
|
if (mysql_errno(mysql) == ER_PARSE_ERROR)
|
|
fprintf(stderr,"This error probably means that your MySQL server doesn't support the\n\'show table status' command.\n");
|
|
return 1;
|
|
}
|
|
|
|
printf("Database: %s",db);
|
|
if (wild)
|
|
printf(" Wildcard: %s",wild);
|
|
putchar('\n');
|
|
|
|
print_res_header(result);
|
|
while ((row=mysql_fetch_row(result)))
|
|
print_res_row(result,row);
|
|
print_res_top(result);
|
|
mysql_free_result(result);
|
|
return 0;
|
|
}
|
|
|
|
/*
|
|
list fields uses field interface as an example of how to parse
|
|
a MYSQL FIELD
|
|
*/
|
|
|
|
static int
|
|
list_fields(MYSQL *mysql,const char *db,const char *table,
|
|
const char *wild)
|
|
{
|
|
char query[1024],*end;
|
|
MYSQL_RES *result;
|
|
MYSQL_ROW row;
|
|
ulong rows;
|
|
LINT_INIT(rows);
|
|
|
|
if (mysql_select_db(mysql,db))
|
|
{
|
|
fprintf(stderr,"%s: Cannot connect to db: %s: %s\n",my_progname,db,
|
|
mysql_error(mysql));
|
|
return 1;
|
|
}
|
|
|
|
if (opt_count)
|
|
{
|
|
sprintf(query,"select count(*) from `%s`", table);
|
|
if (mysql_query(mysql,query) || !(result=mysql_store_result(mysql)))
|
|
{
|
|
fprintf(stderr,"%s: Cannot get record count for db: %s, table: %s: %s\n",
|
|
my_progname,db,table,mysql_error(mysql));
|
|
return 1;
|
|
}
|
|
row= mysql_fetch_row(result);
|
|
rows= (ulong) strtoull(row[0], (char**) 0, 10);
|
|
mysql_free_result(result);
|
|
}
|
|
|
|
end=strmov(strmov(strmov(query,"show /*!32332 FULL */ columns from `"),table),"`");
|
|
if (wild && wild[0])
|
|
strxmov(end," like '",wild,"'",NullS);
|
|
if (mysql_query(mysql,query) || !(result=mysql_store_result(mysql)))
|
|
{
|
|
fprintf(stderr,"%s: Cannot list columns in db: %s, table: %s: %s\n",
|
|
my_progname,db,table,mysql_error(mysql));
|
|
return 1;
|
|
}
|
|
|
|
printf("Database: %s Table: %s", db, table);
|
|
if (opt_count)
|
|
printf(" Rows: %lu", rows);
|
|
if (wild && wild[0])
|
|
printf(" Wildcard: %s",wild);
|
|
putchar('\n');
|
|
|
|
print_res_header(result);
|
|
while ((row=mysql_fetch_row(result)))
|
|
print_res_row(result,row);
|
|
print_res_top(result);
|
|
if (opt_show_keys)
|
|
{
|
|
end=strmov(strmov(strmov(query,"show keys from `"),table),"`");
|
|
if (mysql_query(mysql,query) || !(result=mysql_store_result(mysql)))
|
|
{
|
|
fprintf(stderr,"%s: Cannot list keys in db: %s, table: %s: %s\n",
|
|
my_progname,db,table,mysql_error(mysql));
|
|
return 1;
|
|
}
|
|
if (mysql_num_rows(result))
|
|
{
|
|
print_res_header(result);
|
|
while ((row=mysql_fetch_row(result)))
|
|
print_res_row(result,row);
|
|
print_res_top(result);
|
|
}
|
|
else
|
|
puts("Table has no keys");
|
|
}
|
|
mysql_free_result(result);
|
|
return 0;
|
|
}
|
|
|
|
|
|
/*****************************************************************************
|
|
General functions to print a nice ascii-table from data
|
|
*****************************************************************************/
|
|
|
|
static void
|
|
print_header(const char *header,uint head_length,...)
|
|
{
|
|
va_list args;
|
|
uint length,i,str_length,pre_space;
|
|
const char *field;
|
|
|
|
va_start(args,head_length);
|
|
putchar('+');
|
|
field=header; length=head_length;
|
|
for (;;)
|
|
{
|
|
for (i=0 ; i < length+2 ; i++)
|
|
putchar('-');
|
|
putchar('+');
|
|
if (!(field=va_arg(args,my_string)))
|
|
break;
|
|
length=va_arg(args,uint);
|
|
}
|
|
va_end(args);
|
|
putchar('\n');
|
|
|
|
va_start(args,head_length);
|
|
field=header; length=head_length;
|
|
putchar('|');
|
|
for (;;)
|
|
{
|
|
str_length=(uint) strlen(field);
|
|
if (str_length > length)
|
|
str_length=length+1;
|
|
pre_space=(uint) (((int) length-(int) str_length)/2)+1;
|
|
for (i=0 ; i < pre_space ; i++)
|
|
putchar(' ');
|
|
for (i = 0 ; i < str_length ; i++)
|
|
putchar(field[i]);
|
|
length=length+2-str_length-pre_space;
|
|
for (i=0 ; i < length ; i++)
|
|
putchar(' ');
|
|
putchar('|');
|
|
if (!(field=va_arg(args,my_string)))
|
|
break;
|
|
length=va_arg(args,uint);
|
|
}
|
|
va_end(args);
|
|
putchar('\n');
|
|
|
|
va_start(args,head_length);
|
|
putchar('+');
|
|
field=header; length=head_length;
|
|
for (;;)
|
|
{
|
|
for (i=0 ; i < length+2 ; i++)
|
|
putchar('-');
|
|
putchar('+');
|
|
if (!(field=va_arg(args,my_string)))
|
|
break;
|
|
length=va_arg(args,uint);
|
|
}
|
|
va_end(args);
|
|
putchar('\n');
|
|
}
|
|
|
|
|
|
static void
|
|
print_row(const char *header,uint head_length,...)
|
|
{
|
|
va_list args;
|
|
const char *field;
|
|
uint i,length,field_length;
|
|
|
|
va_start(args,head_length);
|
|
field=header; length=head_length;
|
|
for (;;)
|
|
{
|
|
putchar('|');
|
|
putchar(' ');
|
|
fputs(field,stdout);
|
|
field_length=(uint) strlen(field);
|
|
for (i=field_length ; i <= length ; i++)
|
|
putchar(' ');
|
|
if (!(field=va_arg(args,my_string)))
|
|
break;
|
|
length=va_arg(args,uint);
|
|
}
|
|
va_end(args);
|
|
putchar('|');
|
|
putchar('\n');
|
|
}
|
|
|
|
|
|
static void
|
|
print_trailer(uint head_length,...)
|
|
{
|
|
va_list args;
|
|
uint length,i;
|
|
|
|
va_start(args,head_length);
|
|
length=head_length;
|
|
putchar('+');
|
|
for (;;)
|
|
{
|
|
for (i=0 ; i < length+2 ; i++)
|
|
putchar('-');
|
|
putchar('+');
|
|
if (!(length=va_arg(args,uint)))
|
|
break;
|
|
}
|
|
va_end(args);
|
|
putchar('\n');
|
|
}
|
|
|
|
|
|
static void print_res_header(MYSQL_RES *result)
|
|
{
|
|
MYSQL_FIELD *field;
|
|
|
|
print_res_top(result);
|
|
mysql_field_seek(result,0);
|
|
putchar('|');
|
|
while ((field = mysql_fetch_field(result)))
|
|
{
|
|
printf(" %-*s|",(int) field->max_length+1,field->name);
|
|
}
|
|
putchar('\n');
|
|
print_res_top(result);
|
|
}
|
|
|
|
|
|
static void print_res_top(MYSQL_RES *result)
|
|
{
|
|
uint i,length;
|
|
MYSQL_FIELD *field;
|
|
|
|
putchar('+');
|
|
mysql_field_seek(result,0);
|
|
while((field = mysql_fetch_field(result)))
|
|
{
|
|
if ((length=(uint) strlen(field->name)) > field->max_length)
|
|
field->max_length=length;
|
|
else
|
|
length=field->max_length;
|
|
for (i=length+2 ; i--> 0 ; )
|
|
putchar('-');
|
|
putchar('+');
|
|
}
|
|
putchar('\n');
|
|
}
|
|
|
|
|
|
static void print_res_row(MYSQL_RES *result,MYSQL_ROW cur)
|
|
{
|
|
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');
|
|
}
|