Function update_statistics_for_table

sql/sql_statistics.cc:2908–2995

*/

int update_statistics_for_table(THD *thd, TABLE *table)
{
  TABLE_LIST tables[STATISTICS_TABLES];
  uint i;
  int err;
  enum_binlog_format save_binlog_format;
  int rc= 0;
  TABLE *stat_table;
  DBUG_ENTER("update_statistics_for_table");

  DEBUG_SYNC(thd, "statistics_update_start");

  start_new_trans new_trans(thd);

  if (open_stat_tables(thd, tables, TRUE))
  {
    new_trans.restore_old_transaction();
    DBUG_RETURN(0);
  }
   
  /*
    Ensure that no one is reading statistics while we are writing them
    This ensures that statistics is always read consistently
  */
  mysql_mutex_lock(&table->s->LOCK_statistics);

  save_binlog_format= thd->set_current_stmt_binlog_format_stmt();

  char statbuf[sizeof(Index_stat)];
  static_assert(sizeof(statbuf) >= sizeof(Table_stat), "");
  static_assert(sizeof(statbuf) >= sizeof(Column_stat), "");

  /* Update the statistical table table_stats */
  stat_table= tables[TABLE_STAT].table;
  Table_stat &table_stat= *new(statbuf) Table_stat(stat_table, table);
  restore_record(stat_table, s->default_values);
  table_stat.set_key_fields();
  err= table_stat.update_stat();
  if (err)
    rc= 1;

  /* Update the statistical table column_stats */
  stat_table= tables[COLUMN_STAT].table;
  Column_stat &column_stat= *new(statbuf) Column_stat(stat_table, table);
  for (Field **field_ptr= table->field; *field_ptr; field_ptr++)
  {
    Field *table_field= *field_ptr;
    if (!table_field->collected_stats)
      continue;
    restore_record(stat_table, s->default_values);
    column_stat.set_key_fields(table_field);
    err= column_stat.update_stat();
    if (err && !rc)
      rc= 1;
  }

  /* Update the statistical table index_stats */
  stat_table= tables[INDEX_STAT].table;