| Quellcodebibliothek Statistik Leitseite products/Sources/formale Sprachen/C/MariaDB/storage/maria/ (MariaDB Server Version 8.1-8.4©) Datei vom 1.9.2026 mit Größe 79 kB |
|
Quelle aria_chk.c Sprache: C |
|||||||||||||||
|
/* Copyright (C) 2006-2003 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; version 2 of the License. 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., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1335 USA */ /* Describe, check and repair of MARIA tables */ #define VER "1.3" #include "ma_fulltext.h" #include <myisamchk.h> #include <my_bit.h> #include <m_ctype.h> #include <my_getopt.h> #include <my_check_opt.h> #include <my_handler_errors.h> /* Remove next line if you want aria_chk to produce a stack trace */ #undef HAVE_BACKTRACE #include <my_stacktrace.h> #include <welcome_copyright_notice.h> static uint decode_bits; static char **default_argv; static const char *load_default_groups[]= { "aria_chk", 0 }; static const char *set_collation_name, *opt_tmpdir, *opt_log_dir; static const char *default_log_dir; static CHARSET_INFO *set_collation; static int stopwords_inited= 0; static MY_TMPDIR maria_chk_tmpdir; static my_bool opt_transaction_logging, opt_debug; static my_bool opt_ignore_control_file, opt_require_control_file; static my_bool opt_warning_for_wrong_transid, opt_update_state; static my_bool have_control_file= 0; static const char *type_names[]= { "impossible","char","binary", "short", "long", "float", "double","number","unsigned short", "unsigned long","longlong","ulonglong","int24", "uint24","int8","varchar", "varbin", "varchar2", "varbin2", "bit", "?","?" }; static const char *prefix_packed_txt="packed ", *bin_packed_txt="prefix ", *diff_txt="stripped ", *null_txt="NULL", *blob_txt="BLOB "; static const char *field_pack[]= { "","no endspace", "no prespace", "no zeros", "blob", "constant", "table-lockup", "always zero","varchar","unique-hash","?","?" }; static const char *record_formats[]= { "Fixed length", "Packed", "Compressed", "Block", "No data", "?", "?" }; static const char *bitmap_description[]= { "Empty page", "Part filled head page","Part filled head page", "Part filled head page", "Full head page", "Part filled tail page","Part filled tail page", "Full tail or blob page" }; static const char *maria_stats_method_str="nulls_unequal"; static char default_open_errmsg[]= "%d when opening Aria table '%s'"; static char default_close_errmsg[]= "%d when closing Aria table '%s'"; static void get_options(int *argc,char * * *argv); static void usage(void); static int maria_chk(HA_CHECK *param, char *filename); static void descript(HA_CHECK *param, register MARIA_HA *info, char *name); static int maria_sort_records(HA_CHECK *param, register MARIA_HA *info, char *name, uint sort_key, my_bool write_info, my_bool update_index); static int sort_record_index(MARIA_SORT_PARAM *sort_param, MARIA_PAGE *page, uint sortkey, File new_file, my_bool update_index); static my_bool write_log_record(HA_CHECK *param); ATTRIBUTE_NORETURN static void my_exit(int exit_code); HA_CHECK check_param; /* Register handler error messages for usage with my_error() NOTES This is safe to call multiple times as my_error_register() will ignore calls to register already registered error numbers. */ static const char **get_handler_error_messages(int e __attribute__((unused))) { return handler_error_messages; } /* Free memory and exit */ static void my_exit(int exit_code) { free_tmpdir(&maria_chk_tmpdir); free_defaults(default_argv); my_error_unregister(HA_ERR_FIRST, HA_ERR_FIRST+ array_elements(handler_error_messages)-1); my_end(check_param.testflag & T_INFO ? MY_CHECK_ERROR | MY_GIVE_INFO : MY_CHECK_ERROR); exit(exit_code); } /* Main program */ int main(int argc, char **argv) { int error; MY_INIT(argv[0]); my_setup_stacktrace(); default_log_dir= opt_log_dir= maria_data_root= "."; maria_chk_init(&check_param); check_param.opt_lock_memory= 1; /* Lock memory if possible */ check_param.using_global_keycache = 0; get_options(&argc,(char***) &argv); maria_quick_table_bits=decode_bits; error=0; maria_init(); my_error_register(get_handler_error_messages, HA_ERR_FIRST, HA_ERR_FIRST+ array_elements(handler_error_messages)-1); maria_block_size= 0; /* Use block size from control file */ if (!opt_ignore_control_file) { if ((ma_control_file_open(FALSE, opt_require_control_file || !(check_param.testflag & T_SILENT), TRUE, control_file_open_flags))) { if (opt_require_control_file || (opt_transaction_logging && (check_param.testflag & T_REP_ANY))) { error= 1; goto end; } } else have_control_file= 1; } if (!have_control_file) opt_warning_for_wrong_transid= 0; /* If we are doing a repair, user may want to store this repair into the log so that the log has a complete history and can be used to replay. */ if (opt_transaction_logging && (check_param.testflag & T_REP_ANY)) { if (init_pagecache(maria_log_pagecache, TRANSLOG_PAGECACHE_SIZE, 0, 0, TRANSLOG_PAGE_SIZE, 0, MY_WME) == 0 || translog_init(opt_log_dir, TRANSLOG_FILE_SIZE, 0, 0, maria_log_pagecache, TRANSLOG_DEFAULT_FLAGS, 0)) { _ma_check_print_error(&check_param, "Can't initialize transaction logging. Run " "recovery with switch --skip-transaction-log"); error= 1; goto end; } } while (--argc >= 0) { int new_error=maria_chk(&check_param, *(argv++)); if ((check_param.testflag & T_REP_ANY) != T_REP) check_param.testflag&= ~T_REP; fflush(stdout); fflush(stderr); if (check_param.wrong_trd_printed && (check_param.testflag & T_FORCE_CREATE) && !(check_param.error_printed | check_param.warning_printed)) { /* Only wrong create_trd. Run zerofill */ ulonglong old_testflag= check_param.testflag; check_param.testflag= T_ZEROFILL; error|= maria_chk(&check_param, argv[-1]); check_param.testflag= old_testflag; check_param.error_printed= 0; check_param.warning_printed= 0; fflush(stdout); fflush(stderr); } if ((check_param.error_printed | check_param.warning_printed) && (check_param.testflag & T_FORCE_CREATE) && (!(check_param.testflag & (T_REP | T_REP_BY_SORT | T_SORT_RECORDS | T_SORT_INDEX)))) { ulonglong old_testflag=check_param.testflag; if (!(check_param.testflag & T_REP)) check_param.testflag|= T_REP_BY_SORT; check_param.testflag&= ~T_EXTEND; /* Not needed */ error|=maria_chk(&check_param, argv[-1]); check_param.testflag= old_testflag; fflush(stdout); fflush(stderr); } error|=new_error; if (argc && (!(check_param.testflag & T_SILENT) || check_param.testflag & T_INFO)) { puts("\n---------\n"); fflush(stdout); } } end: if (check_param.total_files > 1) { /* Only if descript */ char buff[22],buff2[22]; if (!(check_param.testflag & T_SILENT) || check_param.testflag & T_INFO) puts("\n---------"); printf("\nTotal of all %d Aria-files:\nData records: %9s Deleted blocks: %9s\n",check_par llstr(check_param.total_deleted,buff2)); } maria_end(); my_exit(error); } /* main */ enum options_mc { OPT_CHARSETS_DIR=256, OPT_SET_COLLATION,OPT_START_CHECK_POS, OPT_CORRECT_CHECKSUM, OPT_CREATE_MISSING_KEYS, OPT_PAGE_BUFFER_SIZE, OPT_KEY_CACHE_BLOCK_SIZE, OPT_MARIA_BLOCK_SIZE, OPT_READ_BUFFER_SIZE, OPT_WRITE_BUFFER_SIZE, OPT_SORT_BUFFER_SIZE, OPT_SORT_KEY_BLOCKS, OPT_DECODE_BITS, OPT_FT_MIN_WORD_LEN, OPT_FT_MAX_WORD_LEN, OPT_FT_STOPWORD_FILE, OPT_MAX_RECORD_LENGTH, OPT_AUTO_CLOSE, OPT_STATS_METHOD, OPT_TRANSACTION_LOG, OPT_ZEROFILL_KEEP_LSN, OPT_REQUIRE_CONTROL_FILE, OPT_IGNORE_CONTROL_FILE, OPT_LOG_DIR, OPT_WARNING_FOR_WRONG_TRANSID,OPT_ACTIVE_KEYS }; static struct my_option my_long_options[] = { {"analyze", 'a', "Analyze distribution of keys. Will make some joins in MySQL faster. You can check the calculat 0, 0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0}, #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 {"block-search", 'b', "No help available.", 0, 0, 0, GET_ULONG, REQUIRED_ARG, 0, 0, 0, 0, 0, 0}, {"backup", 'B', "Make a backup of the .MAD file as 'filename-time.BAK'.", 0, 0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0}, {"character-sets-dir", OPT_CHARSETS_DIR, "Directory where character sets are.", (char**) &charsets_dir, 0, 0, GET_STR, REQUIRED_ARG, 0, 0, 0, 0, 0, 0}, {"check", 'c', "Check table for errors.", 0, 0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0}, {"check-only-changed", 'C', "Check only tables that have changed since last check. It also applies to other requested actio 0, 0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0}, {"correct-checksum", OPT_CORRECT_CHECKSUM, "Correct checksum information for table.", 0, 0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0}, {"create-missing-keys", OPT_CREATE_MISSING_KEYS, "Create missing keys. This assumes that the data file is correct and that " "the the number of rows stored in the index file is correct. Enables " "--quick", 0, 0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0}, #ifndef DBUG_OFF {"debug", '#', "Output debug log. Often this is 'd:t:o,filename'.", 0, 0, 0, GET_STR, OPT_ARG, 0, 0, 0, 0, 0, 0}, #endif {"description", 'd', "Prints some information about table.", 0, 0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0}, {"data-file-length", 'D', "Max length of data file (when recreating data-file when it's full).", &check_param.max_data_file_length, &check_param.max_data_file_length, 0, GET_LL, REQUIRED_ARG, 0, 0, 0, 0, 0, 0}, {"extend-check", 'e', "If used when checking a table, ensure that the table is 100 percent consistent, which will take 0, 0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0}, {"fast", 'F', "Check only tables that haven't been closed properly. It also applies to other requested actio 0, 0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0}, {"force", 'f', "Restart with -r if there are any errors in the table. States will be updated as with --update-st 0, 0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0}, {"HELP", 'H', "Print all argument options sorted alphabetically and exit.", 0, 0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0}, {"help", '?', "Print all options by groups and exit. See also --HELP", 0, 0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0}, {"information", 'i', "Print statistics information about table that is checked.", 0, 0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0}, { "ignore-control-file", OPT_IGNORE_CONTROL_FILE, "Ignore the control file", (uchar**)&opt_ignore_control_file, 0, 0, GET_BOOL, NO_ARG, 0, 0, 0, 0, 0, 0}, {"keys-used", 'k', "Tell Aria to update only some specific keys. # is a bit mask of which keys to use. This can be used t &check_param.keys_in_use, &check_param.keys_in_use, 0, GET_ULL, REQUIRED_ARG, -1, 0, 0, 0, 0, 0}, {"keys-active", OPT_ACTIVE_KEYS, "Threat all not listed keys as disabled. If used with repair, the keys " "will be disabled permanently. The argument is a list of key numbers, " "starting from 1, separated by ','. " "keys-active and keys-used are two ways to do the same thing", 0, 0, 0, GET_STR, REQUIRED_ARG, 0, 0, 0, 0, 0, 0}, {"datadir", 'h', "Path for control file (and logs if --logdir not used).", (char**) &maria_data_root, 0, 0, GET_STR, REQUIRED_ARG, 0, 0, 0, 0, 0, 0}, {"logdir", OPT_LOG_DIR, "Path for log files.", (char**) &opt_log_dir, 0, 0, GET_STR, REQUIRED_ARG, 0, 0, 0, 0, 0, 0}, {"max-record-length", OPT_MAX_RECORD_LENGTH, "Skip rows bigger than this if aria_chk can't allocate memory to hold it", &check_param.max_record_length, &check_param.max_record_length, 0, GET_ULL, REQUIRED_ARG, LONGLONG_MAX, 0, LONGLONG_MAX, 0, 0, 0}, {"medium-check", 'm', "Faster than extend-check, but only finds 99.99% of all errors. Should be good enough for most c 0, 0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0}, {"quick", 'q', "Faster repair by not modifying the data file.", 0, 0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0}, {"read-only", 'T', "Don't mark table as checked.", 0, 0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0}, {"recover", 'r', "Can fix almost anything except unique keys that aren't unique.", 0, 0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0}, {"parallel-recover", 'p', "Same as '-r' but creates all the keys in parallel.", 0, 0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0}, {"safe-recover", 'o', "Uses old recovery method; Slower than '-r' but can handle a couple of cases where '-r' reports t 0, 0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0}, {"sort-recover", 'n', "Force recovering with sorting even if the temporary file was very big.", 0, 0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0}, { "require-control-file", OPT_REQUIRE_CONTROL_FILE, "Abort if cannot find control file", (uchar**)&opt_require_control_file, 0, 0, GET_BOOL, NO_ARG, 0, 0, 0, 0, 0, 0}, #ifdef DEBUG {"start-check-pos", OPT_START_CHECK_POS, "No help available.", 0, 0, 0, GET_ULL, REQUIRED_ARG, 0, 0, 0, 0, 0, 0}, #endif {"set-auto-increment", 'A', "Force auto_increment to start at this or higher value. If no value is given, then sets the next a &check_param.auto_increment_value, &check_param.auto_increment_value, 0, GET_ULL, OPT_ARG, 0, 0, 0, 0, 0, 0}, {"set-collation", OPT_SET_COLLATION, "Change the collation used by the index", (char**) &set_collation_name, 0, 0, GET_STR, REQUIRED_ARG, 0, 0, 0, 0, 0, 0}, {"silent", 's', "Only print errors. One can use two -s to make aria_chk very silent.", 0, 0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0}, {"sort-index", 'S', "Sort index blocks. This speeds up 'read-next' in applications.", 0, 0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0}, {"sort-records", 'R', "Sort records according to an index. This makes your data much more localized and may speed up th &check_param.opt_sort_key, &check_param.opt_sort_key, 0, GET_UINT, REQUIRED_ARG, 0, 0, 0, 0, 0, 0}, {"tmpdir", 't', "Path for temporary files.", (char**) &opt_tmpdir, 0, 0, GET_STR, REQUIRED_ARG, 0, 0, 0, 0, 0, 0}, {"transaction-log", OPT_TRANSACTION_LOG, "Log repair command to transaction log", &opt_transaction_logging, &opt_transaction_logging, 0, GET_BOOL, NO_ARG, 0, 0, 0, 0, 0, 0}, {"update-state", 'U', "Mark tables as crashed if any errors were found and clean if check " "didn't find any errors but table was marked as 'not clean' before. This " "allows one to get rid of warnings like 'table not properly closed'. " "If table was updated, update also the timestamp for when check was made. " "This option is on by default!", &opt_update_state, &opt_update_state, 0, GET_BOOL, NO_ARG, 1, 0, 0, 0, 0, 0}, {"unpack", 'u', "Unpack file packed with aria_pack.", 0, 0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0}, {"verbose", 'v', "Print more information. This can be used with --description and --check. Use many -v for more v 0, 0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0}, {"version", 'V', "Print version and exit.", 0, 0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0}, {"wait", 'w', "Wait if table is locked.", 0, 0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0}, {"warning-for-wrong-transaction-id", OPT_WARNING_FOR_WRONG_TRANSID, "Give a warning if we find a transaction id in the table that is bigger" "than what exists in the control file. Use --skip-... to disable warning", &opt_warning_for_wrong_transid, &opt_warning_for_wrong_transid, 0, GET_BOOL, NO_ARG, 1, 0, 0, 0, 0, 0}, { "page_buffer_size", OPT_PAGE_BUFFER_SIZE, "Size of page buffer. Used by --safe-repair", &check_param.use_buffers, &check_param.use_buffers, 0, GET_ULONG, REQUIRED_ARG, PAGE_BUFFER_INIT, 1024L*1024L, SIZE_T_MAX, 0, (long) IO_SIZE, 0}, { "read_buffer_size", OPT_READ_BUFFER_SIZE, "Read buffer size for sequential reads during scanning", &check_param.read_buffer_length, &check_param.read_buffer_length, 0, GET_ULONG, REQUIRED_ARG, (long) READ_BUFFER_INIT, (long) MALLOC_OVERHEAD, ~0ULL, 0, (long) 1L, 0}, { "write_buffer_size", OPT_WRITE_BUFFER_SIZE, "Write buffer size for sequential writes during repair of fixed size or dynamic size rows", &check_param.write_buffer_length, &check_param.write_buffer_length, 0, GET_ULONG, REQUIRED_ARG, (long) READ_BUFFER_INIT, (long) MALLOC_OVERHEAD, ~0UL, 0, (long) 1L, 0}, { "sort_buffer_size", OPT_SORT_BUFFER_SIZE, "Size of sort buffer. Used by --recover", &check_param.orig_sort_buffer_length, &check_param.orig_sort_buffer_length, 0, GET_ULL, REQUIRED_ARG, SORT_BUFFER_INIT, MARIA_MIN_SORT_MEMORY, SIZE_T_MAX/10, 0, 1L, 0}, { "sort_key_blocks", OPT_SORT_KEY_BLOCKS, "Internal buffer for sorting keys; Don't touch :)", &check_param.sort_key_blocks, &check_param.sort_key_blocks, 0, GET_ULONG, REQUIRED_ARG, BUFFERS_WHEN_SORTING, 4L, 100L, 0L, 1L, 0}, { "decode_bits", OPT_DECODE_BITS, "", &decode_bits, &decode_bits, 0, GET_UINT, REQUIRED_ARG, 9L, 4L, 17L, 0L, 1L, 0}, { "ft_min_word_len", OPT_FT_MIN_WORD_LEN, "", &ft_min_word_len, &ft_min_word_len, 0, GET_ULONG, REQUIRED_ARG, 4, 1, HA_FT_MAXCHARLEN, 0, 1, 0}, { "ft_max_word_len", OPT_FT_MAX_WORD_LEN, "", &ft_max_word_len, &ft_max_word_len, 0, GET_ULONG, REQUIRED_ARG, HA_FT_MAXCHARLEN, 10, HA_FT_MAXCHARLEN, 0, 1, 0}, { "aria_ft_stopword_file", OPT_FT_STOPWORD_FILE, "Use stopwords from this file instead of built-in list.", (char**) &ft_stopword_file, (char**) &ft_stopword_file, 0, GET_STR, REQUIRED_ARG, 0, 0, 0, 0, 0, 0}, { "stats_method", OPT_STATS_METHOD, "Specifies how index statistics collection code should treat NULLs. " "Possible values of name are \"nulls_unequal\" (default behavior for MySQL 4.1/5.0), " "\"nulls_equal\" (emulate 4.0 behavior), and \"nulls_ignored\".", (char**) &maria_stats_method_str, (char**) &maria_stats_method_str, 0, GET_STR, REQUIRED_ARG, 0, 0, 0, 0, 0, 0}, { "zerofill", 'z', "Fill empty space in data and index files with zeroes. This makes the data file movable between d 0, 0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0}, { "zerofill-keep-lsn", OPT_ZEROFILL_KEEP_LSN, "Like --zerofill but does not zero out LSN of data/index pages;" " used only for testing and debugging", 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} }; static void usage(void) { print_version(); puts("By Monty, for your professional use"); puts("This software comes with NO WARRANTY: see the PUBLIC for details.\n"); puts("Description, check and repair of Aria tables."); puts("Used without options all tables on the command will be checked for errors"); printf("Usage: %s [OPTIONS] tables[.MAI]\n", my_progname_short); printf("\nGlobal options:\n"); #ifndef DBUG_OFF printf("\ -#, --debug=... Output debug log. Often this is 'd:t:o,filename'.\n"); #endif printf("\ -H, --HELP Print all argument options sorted alphabetically.\n\ -?, --help Print all options by groups\n\ --datadir=path Path for control file (and logs if --logdir not used)\n\ --logdir=path Path for log files\n\ --ignore-control-file Don't open the control file. Only use this if you\n\ are sure the tables are not in use by another\n\ program!\n\ --require-control-file Abort if we can't find/read the aria_log_control\n\ file\n\ -s, --silent Only print errors. One can use two -s to make\n\ maria_chk very silent.\n\ -t, --tmpdir=path Path for temporary files. Multiple paths can be\n\ specified, separated by "); #if defined( _WIN32) printf("semicolon (;)"); #else printf("colon (:)"); #endif printf(", they will be used\n\ in a round-robin fashion.\n\ -v, --verbose Print more information. This can be used with\n\ --description and --check. Use many -v for more verbosity.\n\ -V, --version Print version and exit.\n\ -w, --wait Wait if table is locked.\n\n"); #ifdef DEBUG puts(" --start-check-pos=# Start reading file at given offset.\n"); #endif puts("Check options (check is the default action for aria_chk):\n\ -c, --check Check table for errors.\n\ -e, --extend-check Check the table VERY thoroughly. Only use this in\n\ extreme cases as aria_chk should normally be able to\n\ find out if the table is ok even without this switch.\n\ -F, --fast Check only tables that haven't been closed properly.\n\ -C, --check-only-changed\n\ Check only tables that have changed since last check.\n\ -f, --force Restart with '-r' if there are any errors in the table.\n\ States will be updated as with '--update-state'.\n\ -i, --information Print statistics information about table that is checked.\n\ -m, --medium-check Faster than extend-check, but only finds 99.99% of\n\ all errors. Should be good enough for most cases.\n\ -T, --read-only Don't mark table as checked.\n\ -U, --update-state Mark tables as crashed if any errors were found and\n\ clean if check didn't find any errors but table was\n\ marked as 'not clean' before. This allows one to get\n\ rid of warnings like 'table not properly closed'. If\n\ table was updated, update also the timestamp for when\n\ the check was made. This option is on by default!\n\ Use --skip-update-state to disable.\n\ --warning-for-wrong-transaction-id\n\ Give a warning if we find a transaction id in the table that is bigger\n\ than what exists in the control file. Use --skip-... to disable warning\n\ "); puts("\ Recover (repair)/ options (When using '--recover' or '--safe-recover'):\n\ -B, --backup Make a backup of the .MAD file as 'filename-time.BAK'.\n\ --correct-checksum Correct checksum information for table.\n\ -D, --data-file-length=# Max length of data file (when recreating data\n\ file when it's full).\n\ --create-missing-keys\n\ Create missing keys. This assumes that the data\n\ file is correct and that the number of rows stored\n\ in the index file is correct. Enables --quick.\n\ -e, --extend-check Try to recover every possible row from the data file\n\ Normally this will also find a lot of garbage rows;\n\ Don't use this option if you are not totally desperate.\n\ -f, --force Overwrite old temporary files. Add another --force to\n\ avoid 'sort_buffer_size is too small' errors.\n\ In this case we will attempt to do the repair with the\n\ given sort_buffer_size and dynamically allocate\n\ as many management buffers as needed.\n\ -k, --keys-used=# Tell Aria to update only some specific keys. # is a\n\ bit mask of which keys to use. This can be used to\n\ get faster inserts.\n\ --keys-active\n\ Treat all not listed keys as disabled. If used with repair, the keys\n\ will be disabled permanently. The argument is a list of key numbers,\n\ starting from 1, separated by ','\n\ keys-active and keys-used are two ways to do the same thing\n\ --max-record-length=#\n\ Skip rows bigger than this if aria_chk can't allocate\n\ memory to hold it.\n\ -r, --recover Can fix almost anything except unique keys that aren't\n\ unique.\n\ -n, --sort-recover Forces recovering with sorting even if the temporary\n\ file would be very big.\n\ -p, --parallel-recover\n\ Uses the same technique as '-r' and '-n', but creates\n\ all the keys in parallel, in different threads."); puts("\ -o, --safe-recover Uses old recovery method; Slower than '-r' but can\n \ handle a couple of cases where '-r' reports that it\n\ can't fix the data file.\n\ --transaction-log Log repair command to transaction log. This is needed\n\ if one wants to use the aria_read_log to repeat the \n\ repair\n\ --character-sets-dir=...\n\ Directory where character sets are.\n\ --set-collation=name\n\ Change the collation used by the index.\n\ -q, --quick Faster repair by not modifying the data file.\n\ One can give a second '-q' to force aria_chk to\n\ modify the original datafile in case of duplicate keys.\n\ NOTE: Tables where the data file is corrupted can't be\n\ fixed with this option.\n\ -u, --unpack Unpack file packed with ariapack.\n\ "); puts("Other actions:\n\ -a, --analyze Analyze distribution of keys. Will make some joins in\n\ MariaDB faster. You can check the calculated distribution\n\ by using '--description --verbose table_name'.\n\ --stats_method=name Specifies how index statistics collection code should\n\ treat NULLs. Possible values of name are \"nulls_unequal\"\n\ (default for 4.1/5.0), \"nulls_equal\" (emulate 4.0), and \n\ \"nulls_ignored\".\n\ -d, --description Prints some information about table.\n\ -A, --set-auto-increment[=value]\n\ Force auto_increment to start at this or higher value\n\ If no value is given, then sets the next auto_increment\n\ value to the highest used value for the auto key + 1.\n\ -S, --sort-index Sort index blocks. This speeds up 'read-next' in\n\ applications.\n\ -R, --sort-records=#\n\ Sort records according to an index. This makes your\n\ data much more localized and may speed up things\n\ (It may be VERY slow to do a sort the first time!).\n\ -b, --block-search=#\n\ Find a record, a block at given offset belongs to.\n\ -z, --zerofill Fill empty space in data and index files with zeroes.\n\ This makes the data file movable between different \n\ servers. It also fixes any wrong transaction or LSN\n\ numbers in the table after a crash or if someone\n\ removed the Aria log files.\n\ --zerofill-keep-lsn Like --zerofill but does not zero out LSN of\n\ data/index pages."); puts("Variables:\n\ --page_buffer_size=# Size of page buffer. Used by --safe-repair\n\ --read_buffer_size=# Read buffer size for sequential reads during scanning\n\ --sort_buffer_size=# Size of sort buffer. Used by --recover\n\ --sort_key_blocks=# Internal buffer for sorting keys; Don't touch :)\n\ --write_buffer_size=# Write buffer size for sequential writes during repair"); print_defaults("my", load_default_groups); my_print_variables(my_long_options); } const char *maria_stats_method_names[] = {"nulls_unequal", "nulls_equal", "nulls_ignored", NullS}; TYPELIB maria_stats_method_typelib= CREATE_TYPELIB_FOR(maria_stats_method_names); /* Read options */ static my_bool get_one_option(const struct my_option *opt, const char *argument, const char *filename __attribute__((unused))) { switch (opt->id) { #ifdef __NETWARE__ case OPT_AUTO_CLOSE: setscreenmode(SCR_AUTOCLOSE_ON_EXIT); break; #endif case 'a': if (argument == disabled_my_option) check_param.testflag&= ~T_STATISTICS; else check_param.testflag|= T_STATISTICS; break; case 'A': if (argument) check_param.auto_increment_value= strtoull(argument, NULL, 0); else check_param.auto_increment_value= 0; /* Set to max used value */ check_param.testflag|= T_AUTO_INC; break; case 'b': check_param.search_after_block= strtoul(argument, NULL, 10); break; case 'B': if (argument == disabled_my_option) check_param.testflag&= ~T_BACKUP_DATA; else check_param.testflag|= T_BACKUP_DATA; break; case 'c': if (argument == disabled_my_option) check_param.testflag&= ~T_CHECK; else check_param.testflag|= T_CHECK; break; case 'C': if (argument == disabled_my_option) check_param.testflag&= ~(T_CHECK | T_CHECK_ONLY_CHANGED); else check_param.testflag|= T_CHECK | T_CHECK_ONLY_CHANGED; break; case 'D': check_param.max_data_file_length=strtoll(argument, NULL, 10); break; case 's': /* silent */ if (argument == disabled_my_option) check_param.testflag&= ~(T_SILENT | T_VERY_SILENT); else { if (check_param.testflag & T_SILENT) check_param.testflag|= T_VERY_SILENT; check_param.testflag|= T_SILENT; check_param.testflag&= ~T_WRITE_LOOP; } break; case 'w': if (argument == disabled_my_option) check_param.testflag&= ~T_WAIT_FOREVER; else check_param.testflag|= T_WAIT_FOREVER; break; case 'd': /* description if isam-file */ if (argument == disabled_my_option) check_param.testflag&= ~T_DESCRIPT; else check_param.testflag|= T_DESCRIPT; break; case 'e': /* extend check */ if (argument == disabled_my_option) check_param.testflag&= ~T_EXTEND; else check_param.testflag|= T_EXTEND; break; case 'i': if (argument == disabled_my_option) check_param.testflag&= ~T_INFO; else check_param.testflag|= T_INFO; break; case 'f': if (argument == disabled_my_option) { check_param.tmpfile_createflag= O_RDWR | O_TRUNC | O_EXCL; check_param.testflag&= ~(T_FORCE_CREATE | T_UPDATE_STATE | T_FORCE_SORT_MEMORY); } else { if (check_param.testflag & T_FORCE_CREATE) check_param.testflag= T_FORCE_SORT_MEMORY; check_param.tmpfile_createflag= O_RDWR | O_TRUNC; check_param.testflag|= T_FORCE_CREATE | T_UPDATE_STATE; } break; case 'F': if (argument == disabled_my_option) check_param.testflag&= ~T_FAST; else check_param.testflag|= T_FAST; break; case 'k': check_param.keys_in_use= (ulonglong) strtoll(argument, NULL, 10); break; case OPT_ACTIVE_KEYS: if (argument == disabled_my_option) check_param.keys_in_use= ~0LL; else { const char *start; char *end, *str_end= strend(argument); check_param.keys_in_use= 0; for (start= argument; *start ; start= end) { int error; longlong key; end= str_end; key= my_strtoll10(start, &end, &error); if (error || key > 64 || (*end && *end != ',')) { fprintf(stderr, "Wrong argument to active-keys. Expected a list of " "numbers like 1,2,3,4\n"); exit(1); /* Change to my_exit after merge */ } check_param.keys_in_use|= 1LL << (key-1); if (*end == ',') end++; } } break; case 'm': if (argument == disabled_my_option) check_param.testflag&= ~T_MEDIUM; else check_param.testflag|= T_MEDIUM; /* Medium check */ break; case 'r': /* Repair table */ check_param.testflag&= ~T_REP_ANY; if (argument != disabled_my_option) check_param.testflag|= T_REP_BY_SORT; break; case 'p': check_param.testflag&= ~T_REP_ANY; if (argument != disabled_my_option) check_param.testflag|= T_REP_PARALLEL; break; case 'o': check_param.testflag&= ~T_REP_ANY; check_param.force_sort= 0; if (argument != disabled_my_option) { check_param.testflag|= T_REP; my_disable_async_io= 1; /* More safety */ } break; case 'n': check_param.testflag&= ~T_REP_ANY; if (argument == disabled_my_option) check_param.force_sort= 0; else { check_param.testflag|= T_REP_BY_SORT; check_param.force_sort= 1; } break; case 'q': if (argument == disabled_my_option) check_param.testflag&= ~(T_QUICK | T_FORCE_UNIQUENESS); else { /* If T_QUICK was specified before, but not OPT_CREATE_MISSING_KEYS, then add T_FORCE_UNIQUENESS. */ check_param.testflag|= ((check_param.testflag & (T_QUICK | T_CREATE_MISSING_KEYS)) == T_QUICK ? T_FORCE_UNIQUENESS : T_QUICK); } break; case OPT_CREATE_MISSING_KEYS: if (argument == disabled_my_option) check_param.testflag&= ~(T_QUICK | T_CREATE_MISSING_KEYS); else { check_param.testflag|= T_QUICK | T_CREATE_MISSING_KEYS; /* Use repair by sort by default */ if (!(check_param.testflag & T_REP_ANY)) check_param.testflag|= T_REP_BY_SORT; } break; case 'u': if (argument == disabled_my_option) check_param.testflag&= ~T_UNPACK; else { check_param.testflag|= T_UNPACK; if (!(check_param.testflag & T_REP_ANY)) check_param.testflag|= T_REP_BY_SORT; } break; case 'v': /* Verbose */ if (argument == disabled_my_option) { check_param.testflag&= ~T_VERBOSE; check_param.verbose=0; } else { check_param.testflag|= T_VERBOSE; check_param.verbose++; } break; case 'R': /* Sort records */ if (argument == disabled_my_option) check_param.testflag&= ~T_SORT_RECORDS; else { check_param.testflag|= T_SORT_RECORDS; check_param.opt_sort_key= (uint) atoi(argument) - 1; if (check_param.opt_sort_key >= MARIA_MAX_KEY) { fprintf(stderr, "The value of the sort key is bigger than max key: %d.\n", MARIA_MAX_KEY); my_exit(1); } } break; case 'S': /* Sort index */ if (argument == disabled_my_option) check_param.testflag&= ~T_SORT_INDEX; else check_param.testflag|= T_SORT_INDEX; break; case 'T': if (argument == disabled_my_option) check_param.testflag&= ~T_READONLY; else check_param.testflag|= T_READONLY; break; case 'U': if (argument == disabled_my_option) check_param.testflag&= ~T_UPDATE_STATE; else check_param.testflag|= T_UPDATE_STATE; break; case '#': DBUG_SET_INITIAL(argument ? argument : "d:t:o,/tmp/aria_chk.trace"); opt_debug= 1; break; case 'V': print_version(); my_exit(0); case OPT_CORRECT_CHECKSUM: if (argument == disabled_my_option) check_param.testflag&= ~T_CALC_CHECKSUM; else check_param.testflag|= T_CALC_CHECKSUM; break; case OPT_STATS_METHOD: { int method; enum_handler_stats_method UNINIT_VAR(method_conv); maria_stats_method_str= argument; if ((method=find_type(argument, &maria_stats_method_typelib, 2)) <= 0) { fprintf(stderr, "Invalid value of stats_method: %s.\n", argument); my_exit(1); } switch (method-1) { case 0: method_conv= MI_STATS_METHOD_NULLS_EQUAL; break; case 1: method_conv= MI_STATS_METHOD_NULLS_NOT_EQUAL; break; case 2: method_conv= MI_STATS_METHOD_IGNORE_NULLS; break; default: abort(); /* Impossible */ } check_param.stats_method= method_conv; break; } #ifdef DEBUG /* Only useful if debugging */ case OPT_START_CHECK_POS: check_param.start_check_pos= strtoull(argument, NULL, 0); break; #endif case 'z': if (argument == disabled_my_option) check_param.testflag&= ~T_ZEROFILL; else check_param.testflag|= T_ZEROFILL; break; case OPT_ZEROFILL_KEEP_LSN: if (argument == disabled_my_option) check_param.testflag&= ~(T_ZEROFILL_KEEP_LSN | T_ZEROFILL); else check_param.testflag|= (T_ZEROFILL_KEEP_LSN | T_ZEROFILL); break; case 'H': my_print_help(my_long_options); my_print_variables(my_long_options); my_exit(0); case '?': usage(); my_exit(0); } return 0; } static void get_options(register int *argc,register char ***argv) { int ho_error; load_defaults_or_exit("my", load_default_groups, argc, argv); default_argv= *argv; check_param.testflag= T_UPDATE_STATE; if (isatty(fileno(stdout))) check_param.testflag|=T_WRITE_LOOP; if ((ho_error=handle_options(argc, argv, my_long_options, get_one_option))) my_exit(ho_error); /* If using repair, then update checksum if one uses --update-state */ if ((check_param.testflag & T_UPDATE_STATE) && (check_param.testflag & T_REP_ANY)) check_param.testflag|= T_CALC_CHECKSUM; if (*argc == 0) { usage(); my_exit(-1); } if ((check_param.testflag & T_UNPACK) && (check_param.testflag & (T_QUICK | T_SORT_RECORDS))) { fprintf(stderr, "%s: --unpack can't be used with --quick or --sort-records\n", my_progname_short); my_exit(1); } if ((check_param.testflag & T_READONLY) && (check_param.testflag & (T_REP_ANY | T_STATISTICS | T_AUTO_INC | T_SORT_RECORDS | T_SORT_INDEX | T_FORCE_CREATE))) { fprintf(stderr, "%s: Can't use --readonly when repairing or sorting\n", my_progname_short); my_exit(1); } if (!opt_debug) { DEBUGGER_OFF; /* Speed up things a bit */ } if (init_tmpdir(&maria_chk_tmpdir, opt_tmpdir)) my_exit(1); check_param.tmpdir=&maria_chk_tmpdir; if (set_collation_name) if (!(set_collation= get_charset_by_name(set_collation_name, MYF(MY_UTF8_IS_UTF8MB3 | MY_WME)))) my_exit(1); if (maria_data_root != default_log_dir && opt_log_dir == default_log_dir) { /* --datadir was used and --log-dir was not. Set log-dir to datadir */ opt_log_dir= maria_data_root; } /* If we are using zerofill, then we don't need to read the control file */ if ((check_param.testflag & (T_ZEROFILL_KEEP_LSN | T_ZEROFILL)) && !(check_param.testflag & ~(T_REP_ANY | T_SORT_RECORDS | T_SORT_INDEX | T_STATISTICS | opt_ignore_control_file= 1; return; } /* get options */ /** Check/repair table @return 0 table is ok @return 1 Got warning during check @return 2 Got error during check/repair. */ static int maria_chk(HA_CHECK *param, char *filename) { int error,lock_type,recreate; uint warning_printed_by_chk_status; my_bool rep_quick= MY_TEST(param->testflag & (T_QUICK | T_FORCE_UNIQUENESS)); my_bool born_transactional; MARIA_HA *info; File datafile; char llbuff[22],llbuff2[22]; my_bool state_updated=0; MARIA_SHARE *share; DBUG_ENTER("maria_chk"); param->out_flag= error= param->error_printed= recreate= 0; param->warning_printed= param->wrong_trd_printed= 0; datafile=0; param->isam_file_name=filename; /* For error messages */ warning_printed_by_chk_status= 0; if (!(info=maria_open(filename, (param->testflag & (T_DESCRIPT | T_READONLY)) ? O_RDONLY : O_RDWR, HA_OPEN_FOR_REPAIR | HA_OPEN_FORCE_MODE | ((param->testflag & T_QUICK) ? HA_OPEN_DATA_READONLY : 0) | ((param->testflag & T_WAIT_FOREVER) ? HA_OPEN_WAIT_IF_LOCKED : (param->testflag & T_DESCRIPT) ? HA_OPEN_IGNORE_IF_LOCKED : HA_OPEN_ABORT_IF_LOCKED), 0))) { /* Avoid twice printing of isam file name */ param->error_printed++; switch (my_errno) { case HA_ERR_CRASHED: _ma_check_print_error(param,"'%s' doesn't have a correct index definition. You need to rec break; case HA_ERR_NOT_A_TABLE: _ma_check_print_error(param,"'%s' is not a Aria table",filename); break; case HA_ERR_CRASHED_ON_USAGE: _ma_check_print_error(param,"'%s' is marked as crashed",filename); break; case HA_ERR_CRASHED_ON_REPAIR: _ma_check_print_error(param,"'%s' is marked as crashed after last repair",filename); break; case HA_ERR_OLD_FILE: _ma_check_print_error(param,"'%s' is a old type of Aria table", filename); break; case HA_ERR_NEW_FILE: _ma_check_print_error(param,"'%s' uses new features not supported by this version of the Ar break; case HA_ERR_END_OF_FILE: _ma_check_print_error(param,"Couldn't read complete header from '%s'", filename); break; case EAGAIN: _ma_check_print_error(param,"'%s' is locked. Use -w to wait until unlocked",filename); break; case ENOENT: _ma_check_print_error(param,"File '%s' doesn't exist",filename); break; case EACCES: _ma_check_print_error(param,"You don't have permission to use '%s'", filename); break; default: _ma_check_print_error(param,"%d when opening Aria table '%s'", my_errno,filename); break; } DBUG_RETURN(1); } share= info->s; share->tot_locks-= share->r_locks; share->r_locks=0; maria_block_size= share->base.block_size; if (share->data_file_type == BLOCK_RECORD || ((param->testflag & T_UNPACK) && share->state.header.org_data_file_type == BLOCK_RECORD)) { if (param->testflag & T_SORT_RECORDS) { _ma_check_print_error(param, "Record format used by '%s' is is not yet supported with sort-records", filename); param->error_printed= 0; error= 1; goto end2; } /* We can't do parallel repair with BLOCK_RECORD yet */ if (param->testflag & T_REP_PARALLEL) { param->testflag&= ~T_REP_PARALLEL; param->testflag|= T_REP_BY_SORT; } } if ((share->base.extra_options & MA_EXTRA_OPTIONS_ENCRYPTED) && !(param->testflag & T_DESCRIPT)) { _ma_check_print_warning(param, "Table %s is encrypted. Only --description (-d) " "option is supported", filename); param->warning_printed= 0; goto end2; } /* Skip the checking of the file if: We are using --fast and the table is closed properly We are using --check-only-changed-tables and the table hasn't changed */ if (param->testflag & (T_FAST | T_CHECK_ONLY_CHANGED)) { my_bool need_to_check= (maria_is_crashed(info) || share->state.open_count != 0); if ((param->testflag & (T_REP_ANY | T_SORT_RECORDS)) && ((share->state.changed & (STATE_CHANGED | STATE_CRASHED_FLAGS | STATE_IN_REPAIR) || !(param->testflag & T_CHECK_ONLY_CHANGED)))) need_to_check=1; if (info->s->base.keys && info->state->records) { if ((param->testflag & T_STATISTICS) && (share->state.changed & STATE_NOT_ANALYZED)) need_to_check=1; if ((param->testflag & T_SORT_INDEX) && (share->state.changed & STATE_NOT_SORTED_PAGES)) need_to_check=1; if ((param->testflag & T_REP_BY_SORT) && (share->state.changed & STATE_NOT_OPTIMIZED_KEYS)) need_to_check=1; } if ((param->testflag & T_CHECK_ONLY_CHANGED) && (share->state.changed & (STATE_CHANGED | STATE_CRASHED_FLAGS | STATE_IN_REPAIR))) need_to_check=1; if (!need_to_check) { if (!(param->testflag & T_SILENT) || param->testflag & T_INFO) printf("Aria file: %s is already checked\n",filename); if (maria_close(info)) { _ma_check_print_error(param,"%d when closing Aria table '%s'", my_errno,filename); DBUG_RETURN(1); } DBUG_RETURN(0); } } /* Don't allow disable of active auto_increment keys for repair */ if (share->base.auto_key && (share->state.key_map & (1LL << share->base.auto_key)) && param->testflag & (T_REP_ANY | T_SORT_RECORDS | T_SORT_INDEX)) check_param.keys_in_use|= (1LL << share->base.auto_key); if ((param->testflag & (T_REP_ANY | T_STATISTICS | T_SORT_RECORDS | T_SORT_INDEX)) && (((param->testflag & T_UNPACK) && share->data_file_type == COMPRESSED_RECORD) || mi_uint2korr(share->state.header.state_info_length) != MARIA_STATE_INFO_SIZE || mi_uint2korr(share->state.header.base_info_length) != MARIA_BASE_INFO_SIZE || maria_is_any_intersect_keys_active(param->keys_in_use, share->base.keys, ~share->state.key_map) || maria_test_if_almost_full(info) || info->s->state.header.file_version[3] != maria_file_magic[3] || (set_collation && set_collation->number != share->base.language))) { if (set_collation) param->language= set_collation->number; if (maria_recreate_table(param, &info,filename)) { fprintf(stderr, "Aria table '%s' is not fixed because of errors\n", filename); DBUG_RETURN(-1); } recreate=1; if (!(param->testflag & T_REP_ANY)) { param->testflag|=T_REP_BY_SORT; /* if only STATISTICS */ if (!(param->testflag & T_SILENT)) printf("- '%s' has old table-format. Recreating index\n",filename); rep_quick= 1; } share= info->s; share->tot_locks-= share->r_locks; share->r_locks=0; } if (param->testflag & T_DESCRIPT) { param->total_files++; param->total_records+=info->state->records; param->total_deleted+=info->state->del; descript(param, info, filename); maria_close(info); /* Should always succeed */ DBUG_RETURN(0); } if (!stopwords_inited++) ft_init_stopwords(); if (!(param->testflag & T_READONLY)) lock_type = F_WRLCK; /* table is changed */ else lock_type= F_RDLCK; if (info->lock_type == F_RDLCK) info->lock_type=F_UNLCK; /* Read only table */ if (_ma_readinfo(info,lock_type,0)) { _ma_check_print_error(param,"Can't lock indexfile of '%s', error: %d", filename,my_errno); param->error_printed=0; error= 1; goto end2; } /* _ma_readinfo() has locked the table. We mark the table as locked (without doing file locks) to be able to use functions that only works on locked tables (like row caching). */ maria_lock_database(info, F_EXTRA_LCK); datafile= info->dfile.file; if (multi_init_pagecache(&maria_pagecaches, 1, (size_t) param->use_buffers, 0, 0, maria_block_size, 0, MY_WME)) { _ma_check_print_error(param, "Can't initialize page cache with %lu memory", (ulong) param->use_buffers); error= 1; goto end2; } /* The pagecache is initialized. Update the table pagecaches pointers */ ma_change_pagecache(info); if (param->testflag & (T_REP_ANY | T_SORT_RECORDS | T_SORT_INDEX | T_ZEROFILL)) { /* Mark table as not transactional to avoid logging. Should not be needed, maria_repair and maria_zerofill do it already. */ _ma_tmp_disable_logging_for_table(info, FALSE); if (param->testflag & T_REP_ANY) { ulonglong tmp=share->state.key_map; maria_copy_keys_active(share->state.key_map, share->base.keys, param->keys_in_use); if (tmp != share->state.key_map) info->update|=HA_STATE_CHANGED; if (rep_quick && maria_chk_del(param, info, param->testflag & ~T_VERBOSE)) { if (param->testflag & T_FORCE_CREATE) { rep_quick=0; _ma_check_print_info(param,"Creating new data file\n"); } else { error=1; _ma_check_print_error(param, "Quick-recover aborted; Run recovery without switch 'q'"); } } } if (!error) { /* Unless this was only --zerofill-keep-lsn, old REDOs are not applicable, tell the server's Recovery to ignore them; we don't know what the log's end LSN is now, so we just let the server know that it will have to find and store it. This is the only case where create_rename_lsn can be a horizon and not a LSN. If this was only --zerofill-keep-lsn, the table can be used in Recovery and especially in this scenario: do a dirty-copy-based backup (snapshot-like), --zerofill-keep-lsn on the copies to achieve better compression, compress the copies with an external tool, and after a restore, Recovery still works (because pages and state still have their correct LSNs). */ if (share->base.born_transactional && ((param->testflag & (T_REP_ANY | T_SORT_RECORDS | T_SORT_INDEX | T_ZEROFILL | T_ZEROFILL_KEEP_LSN)) != (T_ZEROFILL | T_ZEROFILL_KEEP_LSN))) { share->state.create_rename_lsn= share->state.is_of_horizon= share->state.skip_redo_lsn= LSN_NEEDS_NEW_STATE_LSNS; share->state.create_trid= 0; } } if (!error && (param->testflag & T_REP_ANY)) { if ((param->testflag & (T_REP_BY_SORT | T_REP_PARALLEL)) && (maria_is_any_key_active(share->state.key_map) || (rep_quick && !param->keys_in_use && !recreate)) && maria_test_if_sort_rep(info, info->state->records, info->s->state.key_map, param->force_sort)) { if (param->testflag & T_REP_BY_SORT) error=maria_repair_by_sort(param,info,filename,rep_quick); else error=maria_repair_parallel(param,info,filename,rep_quick); state_updated=1; } else error=maria_repair(param, info,filename,rep_quick); } if (!error && (param->testflag & T_SORT_RECORDS)) { /* The data file is nowadays reopened in the repair code so we should soon remove the following reopen-code */ #ifndef TO_BE_REMOVED if (param->out_flag & O_NEW_DATA) { /* Change temp file to org file */ mysql_file_close(info->dfile.file, MYF(MY_WME)); /* Close new file */ error|=maria_change_to_newfile(filename,MARIA_NAME_DEXT,DATA_TMP_EXT, 0, MYF(0)); if (_ma_open_datafile(info, info->s)) error=1; param->out_flag&= ~O_NEW_DATA; /* We are using new datafile */ param->read_cache.file= info->dfile.file; } #endif if (! error) { uint key; /* We can't update the index in maria_sort_records if we have a prefix compressed or fulltext index */ my_bool update_index=1; for (key=0 ; key < share->base.keys; key++) if (share->keyinfo[key].flag & HA_BINARY_PACK_KEY || share->keyinfo[key].key_alg == HA_KEY_ALG_FULLTEXT) update_index=0; error=maria_sort_records(param,info,filename,param->opt_sort_key, /* what is the following parameter for ? */ (my_bool) !(param->testflag & T_REP), update_index); datafile= info->dfile.file; /* This is now locked */ if (!error && !update_index) { if (param->verbose) puts("Table had a compressed index; We must now recreate the index"); error=maria_repair_by_sort(param,info,filename,1); } } } if (!error && (param->testflag & T_SORT_INDEX)) error= maria_sort_index(param,info,filename); if (!error && (param->testflag & T_ZEROFILL)) error= maria_zerofill(param, info, filename); if (!error) { DBUG_PRINT("info", ("Resetting crashed state")); share->state.changed&= ~(STATE_CHANGED | STATE_CRASHED_FLAGS | STATE_IN_REPAIR); share->crash_error= 0; } else maria_mark_crashed(info); } else if ((param->testflag & T_CHECK) || !(param->testflag & T_AUTO_INC)) { if (!(param->testflag & T_VERY_SILENT) || param->testflag & T_INFO) printf("Checking Aria file: %s\n",filename); if (!(param->testflag & T_SILENT)) printf("Data records: %7s Deleted blocks: %7s\n", llstr(info->state->records,llbuff), llstr(info->state->del,llbuff2)); maria_chk_init_for_check(param, info); if (opt_warning_for_wrong_transid == 0) param->max_trid= ~ (ulonglong) 0; error= maria_chk_status(param,info); /* Forget warning printed by maria_chk_status if no problems found */ warning_printed_by_chk_status= param->warning_printed; param->warning_printed= 0; maria_intersect_keys_active(share->state.key_map, param->keys_in_use); error|= maria_chk_size(param,info); if (!error || !(param->testflag & (T_FAST | T_FORCE_CREATE))) error|=maria_chk_del(param, info,param->testflag); if ((!error || (!(param->testflag & (T_FAST | T_FORCE_CREATE)) && !param->start_check_pos))) { error|=maria_chk_key(param, info); if (!error && (param->testflag & (T_STATISTICS | T_AUTO_INC))) error=maria_update_state_info(param, info, ((param->testflag & T_STATISTICS) ? UPDATE_STAT : 0) | ((param->testflag & T_AUTO_INC) ? UPDATE_AUTO_INC : 0)); } if ((!rep_quick && !error) || !(param->testflag & (T_FAST | T_FORCE_CREATE))) { init_io_cache(¶m->read_cache,datafile, (uint) param->read_buffer_length, READ_CACHE, (param->start_check_pos ? param->start_check_pos : share->pack.header_length), 1, MYF(MY_WME)); maria_lock_memory(param); if ((info->s->data_file_type != STATIC_RECORD) || (param->testflag & (T_EXTEND | T_MEDIUM))) error|=maria_chk_data_link(param, info, MY_TEST(param->testflag & T_EXTEND)); end_io_cache(¶m->read_cache); } if (!error) { if (((share->state.changed & (STATE_CHANGED | STATE_CRASHED_FLAGS | STATE_IN_REPAIR)) || share->state.open_count != 0) && (param->testflag & T_UPDATE_STATE)) info->update|=HA_STATE_CHANGED | HA_STATE_ROW_CHANGED; DBUG_PRINT("info", ("Resetting crashed state")); share->state.changed&= ~(STATE_CHANGED | STATE_CRASHED_FLAGS | STATE_IN_REPAIR); share->crash_error= 0; } else if (!maria_is_crashed(info) && (param->testflag & T_UPDATE_STATE)) { /* Mark crashed */ maria_mark_crashed(info); info->update|=HA_STATE_CHANGED | HA_STATE_ROW_CHANGED; } } if ((param->testflag & T_AUTO_INC) || ((param->testflag & T_REP_ANY) && info->s->base.auto_key)) _ma_update_auto_increment_key(param, info, (my_bool) !MY_TEST(param->testflag & T_AUTO_INC)); if (info->update & HA_STATE_CHANGED && ! (param->testflag & T_READONLY)) { error|=maria_update_state_info(param, info, UPDATE_OPEN_COUNT | (((param->testflag & (T_REP_ANY | T_UPDATE_STATE)) ? UPDATE_TIME : 0) | (state_updated ? UPDATE_STAT : 0) | ((param->testflag & T_SORT_RECORDS) ? UPDATE_SORT : 0))); if (warning_printed_by_chk_status) _ma_check_print_info(param, "Aria table '%s' was ok. Status updated", filename); else if (!(param->testflag & T_SILENT)) printf("State updated\n"); warning_printed_by_chk_status= 0; } info->update&= ~HA_STATE_CHANGED; _ma_reenable_logging_for_table(info, FALSE); maria_lock_database(info, F_UNLCK); end2: born_transactional= share->base.born_transactional; if (maria_close(info)) { _ma_check_print_error(param, default_close_errmsg, my_errno, filename); DBUG_RETURN(1); } multi_end_pagecache(&maria_pagecaches); if (error == 0) { if (param->out_flag & O_NEW_DATA) error|=maria_change_to_newfile(filename,MARIA_NAME_DEXT,DATA_TMP_EXT, param->backup_time, ((param->testflag & T_BACKUP_DATA) ? MYF(MY_REDEL_MAKE_BACKUP) : MYF(0))); } if (opt_transaction_logging && born_transactional && !error && (param->testflag & (T_REP_ANY | T_SORT_RECORDS | T_SORT_INDEX | T_ZEROFILL))) error= write_log_record(param); if (param->not_visible_rows_found && (param->testflag & T_VERBOSE)) { char buff[22]; printf("Max transaction id found: %s\n", llstr(param->max_found_trid, buff)); } fflush(stdout); fflush(stderr); if (param->error_printed) { error= 2; if (param->testflag & (T_REP_ANY | T_SORT_RECORDS | T_SORT_INDEX)) { fprintf(stderr, "Aria table '%s' is not fixed because of errors\n", filename); if (param->testflag & T_REP_ANY) fprintf(stderr, "Try fixing it by using the --safe-recover (-o), " "the --force (-f) option or by not using the --quick (-q) " "flag\n"); } else if (!(param->testflag & T_FORCE_CREATE)) fprintf(stderr, "Aria table '%s' is corrupted\nFix it using switch " "\"-r\" or \"-o\"\n", filename); } else if ((param->warning_printed || warning_printed_by_chk_status) && ! (param->testflag & (T_REP_ANY | T_SORT_RECORDS | T_SORT_INDEX | T_FORCE_CREATE))) { if (!error) error= 1; (void) fprintf(stderr, "Aria table '%s' is usable but should be fixed\n", filename); } (void) fflush(stderr); DBUG_RETURN(error); } /* maria_chk */ /* Write info about table */ static void descript(HA_CHECK *param, register MARIA_HA *info, char *name) { uint key,keyseg_nr,field; reg3 MARIA_KEYDEF *keyinfo; reg2 HA_KEYSEG *keyseg; reg4 const char *text; char buff[200],length[10],*pos,*end; enum en_fieldtype type; MARIA_SHARE *share= info->s; char llbuff[22],llbuff2[22]; DBUG_ENTER("descript"); if (param->testflag & T_VERY_SILENT) { longlong checksum= info->state->checksum; if (!(share->options & (HA_OPTION_CHECKSUM | HA_OPTION_COMPRESS_RECORD))) checksum= 0; printf("%s %s %s\n", name, llstr(info->state->records,llbuff), llstr(checksum, llbuff2)); DBUG_VOID_RETURN; } printf("Aria file: %s\n",name); printf("Record format: %s\n", record_formats[share->data_file_type]); printf("Crashsafe: %s\n", share->base.born_transactional ? "yes" : "no"); printf("Character set: %s (%d)\n", get_charset_name(share->base.language), (int) share->base.language); if (param->testflag & T_VERBOSE) { if (share->base.extra_options & MA_EXTRA_OPTIONS_ENCRYPTED) printf("Encrypted: yes\n"); printf("File-version: %d\n", (int) share->state.header.file_version[3]); if (share->state.create_time) { get_date(buff,sizeof(buff),1,share->state.create_time); printf("Creation time: %s\n",buff); } if (share->state.check_time) { get_date(buff,sizeof(buff),1,share->state.check_time); printf("Check/recover time: %s\n",buff); } if (share->base.born_transactional) { printf("LSNs: create_rename " LSN_FMT "," " state_horizon " LSN_FMT ", skip_redo " LSN_FMT "\n", LSN_IN_PARTS(share->state.create_rename_lsn), LSN_IN_PARTS(share->state.is_of_horizon), LSN_IN_PARTS(share->state.skip_redo_lsn)); printf("create_trid: %s\n", llstr(share->state.create_trid, llbuff)); } compile_time_assert((MY_UUID_STRING_LENGTH + 1) <= sizeof(buff)); buff[MY_UUID_STRING_LENGTH]= 0; my_uuid2str(share->base.uuid, buff, 1); printf("UUID: %s\n", buff); if (ma_control_file_inited() && memcmp(share->base.uuid, maria_uuid, MY_UUID_SIZE)) printf("Warning: File UUID not match control file UUID! " "File is probably moved\n" "It will be updated to new system on first usage if zerofill is " "not done\n"); pos=buff; if (share->state.changed & STATE_CRASHED) strmov(buff, share->state.changed & STATE_CRASHED_ON_REPAIR ? "crashed on repair" : "crashed"); else if (have_control_file && (share->state.changed & (STATE_MOVED | STATE_NOT_ZEROFILLED)) == (STATE_MOVED | STATE_NOT_ZEROFILLED)) strmov(buff, "moved from another system. Use --zerofill to fix it"); else { if (share->state.open_count) pos=strmov(pos,"open,"); if (share->state.changed & STATE_CHANGED) pos=strmov(pos,"changed,"); else pos=strmov(pos,"checked,"); if (!(share->state.changed & STATE_NOT_ANALYZED)) pos=strmov(pos,"analyzed,"); if (!(share->state.changed & STATE_NOT_OPTIMIZED_KEYS)) pos=strmov(pos,"optimized keys,"); if (!(share->state.changed & STATE_NOT_SORTED_PAGES)) pos=strmov(pos,"sorted index pages,"); if (!(share->state.changed & STATE_NOT_ZEROFILLED)) pos=strmov(pos,"zerofilled,"); if (test_all_bits(share->state.changed, (STATE_NOT_ZEROFILLED | STATE_HAS_LSN))) pos=strmov(pos,"has_lsn,"); if (!(share->state.changed & STATE_NOT_MOVABLE)) pos=strmov(pos,"movable,"); if (have_control_file && (share->state.changed & STATE_MOVED)) pos=strmov(pos,"moved,"); pos[-1]=0; /* Remove extra ',' */ } printf("Status: %s\n",buff); if (share->options & (HA_OPTION_CHECKSUM | HA_OPTION_COMPRESS_RECORD)) printf("Checksum: %26s\n",llstr(info->state->checksum,llbuff)); ; if (share->options & HA_OPTION_DELAY_KEY_WRITE) printf("Keys are only flushed at close\n"); if (share->options & HA_OPTION_PAGE_CHECKSUM) printf("Page checksums are used\n"); if (share->base.auto_key) { printf("Auto increment key: %16d Last value: %18s\n", share->base.auto_key, llstr(share->state.auto_increment,llbuff)); } } printf("Data records: %16s Deleted blocks: %18s\n", llstr(info->state->records,llbuff),llstr(info->state->del,llbuff2)); if (param->testflag & T_SILENT) DBUG_VOID_RETURN; /* This is enough */ if (param->testflag & T_VERBOSE) { #ifdef USE_RELOC printf("Init-relocation: %16s\n",llstr(share->base.reloc,llbuff)); #endif printf("Datafile parts: %16s Deleted data: %18s\n", llstr(share->state.split,llbuff), llstr(info->state->empty,llbuff2)); printf("Datafile pointer (bytes): %11d Keyfile pointer (bytes): %13d\n", share->rec_reflength,share->base.key_reflength); printf("Datafile length: %16s Keyfile length: %18s\n", llstr(info->state->data_file_length,llbuff), llstr(info->state->key_file_length,llbuff2)); if (info->s->base.reloc == 1L && info->s->base.records == 1L) puts("This is a one-record table"); else { if (share->base.max_data_file_length != HA_OFFSET_ERROR || share->base.max_key_file_length != HA_OFFSET_ERROR) printf("Max datafile length: %16s Max keyfile length: %18s\n", ullstr(share->base.max_data_file_length,llbuff), ullstr(share->base.max_key_file_length,llbuff2)); } } printf("Block_size: %16d\n",(int) share->block_size); printf("Recordlength: %16d\n",(int) share->base.pack_reclength); if (! maria_is_all_keys_active(share->state.key_map, share->base.keys)) { longlong2str(share->state.key_map,buff,2); printf("Using only keys '%s' of %d possibly keys\n", buff, share->base.keys); } puts("\nTable description:"); printf("Key Start Len Index Type"); if (param->testflag & T_VERBOSE) printf(" Rec/key Root Blocksize"); putchar('\n'); for (key=keyseg_nr=0, keyinfo= &share->keyinfo[0] ; key < share->base.keys; key++,keyinfo++) { keyseg=keyinfo->seg; if (keyinfo->flag & HA_NOSAME) text="unique "; else if (keyinfo->key_alg == HA_KEY_ALG_FULLTEXT) text="fulltext "; else text="multip."; pos=buff; if (keyseg->flag & HA_REVERSE_SORT) *pos++ = '-'; pos=strmov(pos,type_names[keyseg->type]); *pos++ = ' '; *pos=0; if (keyinfo->flag & HA_PACK_KEY) pos=strmov(pos,prefix_packed_txt); if (keyinfo->flag & HA_BINARY_PACK_KEY) pos=strmov(pos,bin_packed_txt); if (keyseg->flag & HA_SPACE_PACK) pos=strmov(pos,diff_txt); if (keyseg->flag & HA_BLOB_PART) pos=strmov(pos,blob_txt); if (keyseg->flag & HA_NULL_PART) pos=strmov(pos,null_txt); *pos=0; printf("%-4d%-6ld%-3d %-9s%-23s", key+1,(long) keyseg->start+1,keyseg->length,text,buff); if (share->state.key_root[key] != HA_OFFSET_ERROR) llstr(share->state.key_root[key],buff); else buff[0]=0; if (param->testflag & T_VERBOSE) printf("%9.0f %12s %10d", share->state.rec_per_key_part[keyseg_nr++], buff,keyinfo->block_length); putchar('\n'); while ((++keyseg)->type != HA_KEYTYPE_END) { pos=buff; if (keyseg->flag & HA_REVERSE_SORT) *pos++ = '-'; pos=strmov(pos,type_names[keyseg->type]); *pos++= ' '; if (keyseg->flag & HA_SPACE_PACK) pos=strmov(pos,diff_txt); if (keyseg->flag & HA_BLOB_PART) pos=strmov(pos,blob_txt); if (keyseg->flag & HA_NULL_PART) pos=strmov(pos,null_txt); *pos=0; printf(" %-6ld%-3d %-21s", (long) keyseg->start+1,keyseg->length,buff); if (param->testflag & T_VERBOSE) printf("%11.0f", share->state.rec_per_key_part[keyseg_nr++]); putchar('\n'); } keyseg++; } if (share->state.header.uniques) { MARIA_UNIQUEDEF *uniqueinfo; puts("\nUnique Key Start Len Nullpos Nullbit Type"); for (key=0,uniqueinfo= &share->uniqueinfo[0] ; key < share->state.header.uniques; key++, uniqueinfo++) { my_bool new_row=0; char null_bit[8],null_pos[8]; printf("%-8d%-5d",key+1,uniqueinfo->key+1); for (keyseg=uniqueinfo->seg ; keyseg->type != HA_KEYTYPE_END ; keyseg++) { if (new_row) fputs(" ",stdout); null_bit[0]=null_pos[0]=0; if (keyseg->null_bit) { my_snprintf(null_bit, sizeof(null_bit), "%d", keyseg->null_bit); my_snprintf(null_pos, sizeof(null_pos), "%ld", (long) keyseg->null_pos+1); } printf("%-7ld%-5d%-9s%-10s%-30s\n", (long) keyseg->start+1,keyseg->length, null_pos,null_bit, type_names[keyseg->type]); new_row=1; } } } if (param->verbose > 1) { char null_bit[8],null_pos[8]; printf("\nField Start Length Nullpos Nullbit Type"); if (share->options & HA_OPTION_COMPRESS_RECORD) printf(" Huff tree Bits"); putchar('\n'); for (field=0 ; field < share->base.fields ; field++) { if (share->options & HA_OPTION_COMPRESS_RECORD) type=share->columndef[field].base_type; else type=(enum en_fieldtype) share->columndef[field].type; end= strmov(buff, field_pack[type]); if (end != buff) { *(end++)=','; *(end++)=' '; } if (share->options & HA_OPTION_COMPRESS_RECORD) { if (share->columndef[field].pack_type & PACK_TYPE_SELECTED) end=strmov(end,"not_always, "); if (share->columndef[field].pack_type & PACK_TYPE_SPACE_FIELDS) end=strmov(end,"no empty, "); if (share->columndef[field].pack_type & PACK_TYPE_ZERO_FILL) { snprintf(end, buff + sizeof(buff) - end, "zerofill(%d), ",share->columndef[field].space_ end=strend(end); } } if (end != buff) end[-2]= 0; int10_to_str((long) share->columndef[field].length,length,10); null_bit[0]=null_pos[0]=0; if (share->columndef[field].null_bit) { snprintf(null_bit, sizeof(null_bit), "%d",share->columndef[field].null_bit); snprintf(null_pos, sizeof(null_pos), "%d",share->columndef[field].null_pos+1); } printf("%-6d%-6u%-7s%-8s%-8s%-35s",field+1, (uint) share->columndef[field].offset+1, length, null_pos, null_bit, buff); if (share->options & HA_OPTION_COMPRESS_RECORD) { if (share->columndef[field].huff_tree) printf("%3d %2d", (uint) (share->columndef[field].huff_tree-share->decode_trees)+1, share->columndef[field].huff_tree->quick_table_bits); } putchar('\n'); } if (share->data_file_type == BLOCK_RECORD) { uint i; puts("\nBitmap Data size Description"); for (i=0 ; i <= 7 ; i++) printf("%u %5u %s\n", i, share->bitmap.sizes[i], bitmap_description[i]); } } DBUG_VOID_RETURN; } /* describe */ /* Sort records according to one key */ static int maria_sort_records(HA_CHECK *param, register MARIA_HA *info, char *name, uint sort_key, my_bool write_info, my_bool update_index) { int got_error; uint key; MARIA_KEYDEF *keyinfo; File new_file; uchar *temp_buff; ha_rows old_record_count; MARIA_SHARE *share= info->s; char llbuff[22],llbuff2[22]; MARIA_SORT_INFO sort_info; MARIA_SORT_PARAM sort_param; MARIA_PAGE page; DBUG_ENTER("sort_records"); bzero((char*)&sort_info,sizeof(sort_info)); bzero((char*)&sort_param,sizeof(sort_param)); sort_param.sort_info=&sort_info; sort_info.param=param; keyinfo= &share->keyinfo[sort_key]; got_error=1; temp_buff=0; new_file= -1; if (! maria_is_key_active(share->state.key_map, sort_key)) { _ma_check_print_warning(param, "Can't sort table '%s' on key %d; No such key", name,sort_key+1); param->error_printed=0; DBUG_RETURN(0); /* Nothing to do */ } if (keyinfo->key_alg == HA_KEY_ALG_FULLTEXT) { _ma_check_print_warning(param,"Can't sort table '%s' on FULLTEXT key %d", name,sort_key+1); param->error_printed=0; DBUG_RETURN(0); /* Nothing to do */ } if (keyinfo->flag & HA_BINARY_PACK_KEY) { _ma_check_print_warning(param, "Can't sort table '%s' on a key with prefix " "packing %d", name,sort_key+1); param->error_printed=0; DBUG_RETURN(0); } if (share->data_file_type == COMPRESSED_RECORD) { _ma_check_print_warning(param,"Can't sort read-only table '%s'", name); param->error_printed=0; DBUG_RETURN(0); /* Nothing to do */ } if (!(param->testflag & T_SILENT)) { printf("- Sorting records for Aria table '%s'\n",name); if (write_info) printf("Data records: %9s Deleted: %9s\n", llstr(info->state->records,llbuff), llstr(info->state->del,llbuff2)); } if (share->state.key_root[sort_key] == HA_OFFSET_ERROR) DBUG_RETURN(0); /* Nothing to do */ if (init_io_cache(&info->rec_cache,-1,(uint) param->write_buffer_length, WRITE_CACHE,share->pack.header_length,1, MYF(MY_WME | MY_WAIT_IF_FULL))) goto err; info->opt_flag|=WRITE_CACHE_USED; if (!(temp_buff=(uchar*) my_alloca((uint) keyinfo->block_length))) { _ma_check_print_error(param,"Not enough memory for key block"); goto err; } if (!(sort_param.record= (uchar*) my_malloc(PSI_INSTRUMENT_ME, (uint) share->base.default_rec_buff_size, MYF(0)))) { _ma_check_print_error(param,"Not enough memory for record"); goto err; } fn_format(param->temp_filename,name,"", MARIA_NAME_DEXT,2+4+32); new_file= mysql_file_create(key_file_tmp, fn_format(param->temp_filename, param->temp_filename, "", DATA_TMP_EXT, MY_REPLACE_EXT | MY_UNPACK_FILENAME), 0, param->tmpfile_createflag, MYF(0)); if (new_file < 0) { _ma_check_print_error(param,"Can't create new tempfile: '%s'", param->temp_filename); goto err; } if (share->pack.header_length) if (maria_filecopy(param, new_file, info->dfile.file, 0L, share->pack.header_length, "datafile-header")) goto err; info->rec_cache.file=new_file; /* Use this file for cacheing*/ maria_lock_memory(param); for (key=0 ; key < share->base.keys ; key++) share->keyinfo[key].flag|= HA_SORT_ALLOWS_SAME; if (mysql_file_pread(share->kfile.file, temp_buff, (uint) keyinfo->block_length, share->state.key_root[sort_key], MYF(MY_NABP+MY_WME))) { _ma_check_print_error(param, "Can't read indexpage from filepos: %s", llstr(share->state.key_root[sort_key], llbuff)); goto err; } /* Setup param for _ma_sort_write_record */ sort_info.info=info; sort_info.new_data_file_type=share->data_file_type; sort_param.fix_datafile=1; sort_param.master=1; sort_param.filepos=share->pack.header_length; old_record_count=info->state->records; info->state->records=0; if (sort_info.new_data_file_type != COMPRESSED_RECORD) info->state->checksum=0; _ma_page_setup(&page, info, keyinfo, share->state.key_root[sort_key], temp_buff); if (sort_record_index(&sort_param, &page, sort_key,new_file,update_index) || maria_write_data_suffix(&sort_info,1) || flush_io_cache(&info->rec_cache)) goto err; if (info->state->records != old_record_count) { _ma_check_print_error(param,"found %s of %s records", llstr(info->state->records,llbuff), llstr(old_record_count,llbuff2)); goto err; } mysql_file_close(info->dfile.file, MYF(MY_WME)); param->out_flag|=O_NEW_DATA; /* Data in new file */ info->dfile.file= new_file; /* Use new datafile */ _ma_set_data_pagecache_callbacks(&info->dfile, info->s); info->state->del=0; info->state->empty=0; share->state.dellink= HA_OFFSET_ERROR; info->state->data_file_length=sort_param.filepos; share->state.split=info->state->records; /* Only hole records */ share->state.version=(ulong) time((time_t*) 0); info->update= (short) (HA_STATE_CHANGED | HA_STATE_ROW_CHANGED); if (param->testflag & T_WRITE_LOOP) { fputs(" \r",stdout); fflush(stdout); } got_error=0; err: if (got_error && new_file >= 0) { end_io_cache(&info->rec_cache); (void) mysql_file_close(new_file,MYF(MY_WME)); (void) mysql_file_delete(key_file_tmp, param->temp_filename, MYF(MY_WME)); } if (temp_buff) { my_afree(temp_buff); } my_free(sort_param.record); info->opt_flag&= ~(READ_CACHE_USED | WRITE_CACHE_USED); end_io_cache(&info->rec_cache); my_free(sort_info.buff); sort_info.buff=0; share->state.sortkey=sort_key; DBUG_RETURN(got_error); } /* sort_records */ /* Sort records recursive using one index */ static int sort_record_index(MARIA_SORT_PARAM *sort_param, MARIA_PAGE *ma_page, uint sort_key, File new_file,my_bool update_index) { MARIA_HA *info= ma_page->info; MARIA_SHARE *share= info->s; uint page_flag, nod_flag,used_length; my_bool buff_alloced; uchar *temp_buff,*keypos,*endpos; my_off_t next_page,rec_pos; uchar *lastkey; char llbuff[22]; MARIA_SORT_INFO *sort_info= sort_param->sort_info; HA_CHECK *param=sort_info->param; MARIA_KEY tmp_key; MARIA_PAGE new_page; const MARIA_KEYDEF *keyinfo= ma_page->keyinfo; DBUG_ENTER("sort_record_index"); temp_buff=0; page_flag= ma_page->flag; nod_flag= ma_page->node; tmp_key.keyinfo= (MARIA_KEYDEF*) keyinfo; alloc_on_stack(*info->stack_end_ptr, lastkey, buff_alloced, (nod_flag ? keyinfo->block_length : 0) + ALIGN_SIZE(keyinfo->max_store_length)); if (!lastkey) { _ma_check_print_error(param,"Not Enough memory"); DBUG_RETURN(-1); } if (nod_flag) temp_buff= lastkey + ALIGN_SIZE(keyinfo->max_store_length); tmp_key.data= lastkey; used_length= ma_page->size; keypos= ma_page->buff + share->keypage_header + nod_flag; endpos= ma_page->buff + used_length; for ( ;; ) { if (nod_flag) { next_page= _ma_kpos(nod_flag, keypos); if (mysql_file_pread(share->kfile.file, temp_buff, (uint) tmp_key.keyinfo->block_length, next_page, MYF(MY_NABP+MY_WME))) { _ma_check_print_error(param,"Can't read keys from filepos: %s", llstr(next_page,llbuff)); goto err; } _ma_page_setup(&new_page, info, ma_page->keyinfo, next_page, temp_buff); if (sort_record_index(sort_param, &new_page, sort_key, new_file, update_index)) goto err; } if (keypos >= endpos || !(*keyinfo->get_key)(&tmp_key, page_flag, nod_flag, &keypos)) break; rec_pos= _ma_row_pos_from_key(&tmp_key); if ((*share->read_record)(info,sort_param->record,rec_pos)) { _ma_check_print_error(param,"%d when reading datafile",my_errno); goto err; } if (rec_pos != sort_param->filepos && update_index) { _ma_dpointer(share, keypos - nod_flag - tmp_key.ref_length, sort_param->filepos); if (maria_movepoint(info,sort_param->record,rec_pos,sort_param->filepos, sort_key)) { _ma_check_print_error(param,"%d when updating key-pointers",my_errno); goto err; } } if (_ma_sort_write_record(sort_param)) goto err; } /* Clear end of block to get better compression if the table is backuped */ bzero(ma_page->buff + used_length, keyinfo->block_length - used_length); if (my_pwrite(share->kfile.file, ma_page->buff, (uint)keyinfo->block_length, ma_page->pos, param->myf_rw)) { _ma_check_print_error(param,"%d when updating keyblock",my_errno); goto err; } stack_alloc_free(lastkey, buff_alloced); DBUG_RETURN(0); err: stack_alloc_free(lastkey, buff_alloced); DBUG_RETURN(1); } /* sort_record_index */ static my_bool write_log_record(HA_CHECK *param) { /* Now that all operations including O_NEW_DATA|INDEX are successfully done, we can write a log record. */ MARIA_HA *info= maria_open(param->isam_file_name, O_RDWR, 0, 0); if (info == NULL) _ma_check_print_error(param, default_open_errmsg, my_errno, param->isam_file_name); else { if (write_log_record_for_repair(param, info)) _ma_check_print_error(param, "%d when writing log record for" " Aria table '%s'", my_errno, param->isam_file_name); else if (maria_close(info)) _ma_check_print_error(param, default_close_errmsg, my_errno, param->isam_file_name); else return FALSE; } return TRUE; } #include "ma_check_standalone.h"
¤ Dauer der Verarbeitung: 0.37 Sekunden (vorverarbeitet am 2026-10-08) ¤*© Formatika GbR, Deutschland |
|
||||||||||||||
2026-10-09