text: /* Copyright (c) 2010, 2013, Oracle and/or its affiliates. All rights reserved.
  
    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-1301, USA */
  
  /**
    @file storage/perfschema/table_esms_by_host_by_event_name.cc
    Table EVENTS_STATEMENTS_SUMMARY_BY_HOST_BY_EVENT_NAME (implementation).
  */
  
  #include "my_global.h"
  #include "my_pthread.h"
  #include "pfs_instr_class.h"
  #include "pfs_column_types.h"
  #include "pfs_column_values.h"
  #include "table_esms_by_host_by_event_name.h"
  #include "pfs_global.h"
  #include "pfs_account.h"
  #include "pfs_visitor.h"
  
  THR_LOCK table_esms_by_host_by_event_name::m_table_lock;
  
  static const TABLE_FIELD_TYPE field_types[]=
  {
    {
      { C_STRING_WITH_LEN("HOST") },
      { C_STRING_WITH_LEN("char(60)") },
      { NULL, 0}
    },
    {
      { C_STRING_WITH_LEN("EVENT_NAME") },
      { C_STRING_WITH_LEN("varchar(128)") },
      { NULL, 0}
    },
    {
      { C_STRING_WITH_LEN("COUNT_STAR") },
      { C_STRING_WITH_LEN("bigint(20)") },
      { NULL, 0}
    },
    {
      { C_STRING_WITH_LEN("SUM_TIMER_WAIT") },
      { C_STRING_WITH_LEN("bigint(20)") },
      { NULL, 0}
    },
    {
      { C_STRING_WITH_LEN("MIN_TIMER_WAIT") },
      { C_STRING_WITH_LEN("bigint(20)") },
      { NULL, 0}
    },
    {
      { C_STRING_WITH_LEN("AVG_TIMER_WAIT") },
      { C_STRING_WITH_LEN("bigint(20)") },
      { NULL, 0}
    },
    {
      { C_STRING_WITH_LEN("MAX_TIMER_WAIT") },
      { C_STRING_WITH_LEN("bigint(20)") },
      { NULL, 0}
    },
    {
      { C_STRING_WITH_LEN("SUM_LOCK_TIME") },
      { C_STRING_WITH_LEN("bigint(20)") },
      { NULL, 0}
    },
    {
      { C_STRING_WITH_LEN("SUM_ERRORS") },
      { C_STRING_WITH_LEN("bigint(20)") },
      { NULL, 0}
    },
    {
      { C_STRING_WITH_LEN("SUM_WARNINGS") },
      { C_STRING_WITH_LEN("bigint(20)") },
      { NULL, 0}
    },
    {
      { C_STRING_WITH_LEN("SUM_ROWS_AFFECTED") },
      { C_STRING_WITH_LEN("bigint(20)") },
      { NULL, 0}
    },
    {
      { C_STRING_WITH_LEN("SUM_ROWS_SENT") },
      { C_STRING_WITH_LEN("bigint(20)") },
      { NULL, 0}
    },
    {
      { C_STRING_WITH_LEN("SUM_ROWS_EXAMINED") },
      { C_STRING_WITH_LEN("bigint(20)") },
      { NULL, 0}
    },
    {
      { C_STRING_WITH_LEN("SUM_CREATED_TMP_DISK_TABLES") },
      { C_STRING_WITH_LEN("bigint(20)") },
      { NULL, 0}
    },
    {
      { C_STRING_WITH_LEN("SUM_CREATED_TMP_TABLES") },
      { C_STRING_WITH_LEN("bigint(20)") },
      { NULL, 0}
    },
    {
      { C_STRING_WITH_LEN("SUM_SELECT_FULL_JOIN") },
      { C_STRING_WITH_LEN("bigint(20)") },
      { NULL, 0}
    },
    {
      { C_STRING_WITH_LEN("SUM_SELECT_FULL_RANGE_JOIN") },
      { C_STRING_WITH_LEN("bigint(20)") },
      { NULL, 0}
    },
    {
      { C_STRING_WITH_LEN("SUM_SELECT_RANGE") },
      { C_STRING_WITH_LEN("bigint(20)") },
      { NULL, 0}
    },
    {
      { C_STRING_WITH_LEN("SUM_SELECT_RANGE_CHECK") },
      { C_STRING_WITH_LEN("bigint(20)") },
      { NULL, 0}
    },
    {
      { C_STRING_WITH_LEN("SUM_SELECT_SCAN") },
      { C_STRING_WITH_LEN("bigint(20)") },
      { NULL, 0}
    },
    {
      { C_STRING_WITH_LEN("SUM_SORT_MERGE_PASSES") },
      { C_STRING_WITH_LEN("bigint(20)") },
      { NULL, 0}
    },
    {
      { C_STRING_WITH_LEN("SUM_SORT_RANGE") },
      { C_STRING_WITH_LEN("bigint(20)") },
      { NULL, 0}
    },
    {
      { C_STRING_WITH_LEN("SUM_SORT_ROWS") },
      { C_STRING_WITH_LEN("bigint(20)") },
      { NULL, 0}
    },
    {
      { C_STRING_WITH_LEN("SUM_SORT_SCAN") },
      { C_STRING_WITH_LEN("bigint(20)") },
      { NULL, 0}
    },
    {
      { C_STRING_WITH_LEN("SUM_NO_INDEX_USED") },
      { C_STRING_WITH_LEN("bigint(20)") },
      { NULL, 0}
    },
    {
      { C_STRING_WITH_LEN("SUM_NO_GOOD_INDEX_USED") },
      { C_STRING_WITH_LEN("bigint(20)") },
      { NULL, 0}
    }
  };
  
  TABLE_FIELD_DEF
  table_esms_by_host_by_event_name::m_field_def=
  { 26, field_types };
  
  PFS_engine_table_share
  table_esms_by_host_by_event_name::m_share=
  {
    { C_STRING_WITH_LEN("events_statements_summary_by_host_by_event_name") },
    &pfs_truncatable_acl,
    table_esms_by_host_by_event_name::create,
    NULL, /* write_row */
    table_esms_by_host_by_event_name::delete_all_rows,
    NULL, /* get_row_count */
    1000, /* records */
    sizeof(pos_esms_by_host_by_event_name),
    &m_table_lock,
    &m_field_def,
    false /* checked */
  };
  
  PFS_engine_table*
  table_esms_by_host_by_event_name::create(void)
  {
    return new table_esms_by_host_by_event_name();
  }
  
  int
  table_esms_by_host_by_event_name::delete_all_rows(void)
  {
    reset_events_statements_by_thread();
    reset_events_statements_by_account();
    reset_events_statements_by_host();
    return 0;
  }
  
  table_esms_by_host_by_event_name::table_esms_by_host_by_event_name()
    : PFS_engine_table(&m_share, &m_pos),
      m_row_exists(false), m_pos(), m_next_pos()
  {}
  
  void table_esms_by_host_by_event_name::reset_position(void)
  {
    m_pos.reset();
    m_next_pos.reset();
  }
  
  int table_esms_by_host_by_event_name::rnd_init(bool scan)
  {
    m_normalizer= time_normalizer::get(statement_timer);
    return 0;
  }
  
  int table_esms_by_host_by_event_name::rnd_next(void)
  {
    PFS_host *host;
    PFS_statement_class *statement_class;
  
    for (m_pos.set_at(&m_next_pos);
         m_pos.has_more_host();
         m_pos.next_host())
    {
      host= &host_array[m_pos.m_index_1];
      if (host->m_lock.is_populated())
      {
        statement_class= find_statement_class(m_pos.m_index_2);
        if (statement_class)
        {
          make_row(host, statement_class);
          m_next_pos.set_after(&m_pos);
          return 0;
        }
      }
    }
  
    return HA_ERR_END_OF_FILE;
  }
  
  int
  table_esms_by_host_by_event_name::rnd_pos(const void *pos)
  {
    PFS_host *host;
    PFS_statement_class *statement_class;
  
    set_position(pos);
    DBUG_ASSERT(m_pos.m_index_1 < host_max);
  
    host= &host_array[m_pos.m_index_1];
    if (! host->m_lock.is_populated())
      return HA_ERR_RECORD_DELETED;
  
    statement_class= find_statement_class(m_pos.m_index_2);
    if (statement_class)
    {
      make_row(host, statement_class);
      return 0;
    }
  
    return HA_ERR_RECORD_DELETED;
  }
  
  void table_esms_by_host_by_event_name
  ::make_row(PFS_host *host, PFS_statement_class *klass)
  {
    pfs_lock lock;
    m_row_exists= false;
  
    if (klass->is_mutable())
      return;
  
    host->m_lock.begin_optimistic_lock(&lock);
  
    if (m_row.m_host.make_row(host))
      return;
  
    m_row.m_event_name.make_row(klass);
  
    PFS_connection_statement_visitor visitor(klass);
    PFS_connection_iterator::visit_host(host, true, true, & visitor);
  
    if (! host->m_lock.end_optimistic_lock(&lock))
      return;
  
    m_row_exists= true;
    m_row.m_stat.set(m_normalizer, & visitor.m_stat);
  }
  
  int table_esms_by_host_by_event_name
  ::read_row_values(TABLE *table, unsigned char *buf, Field **fields,
                    bool read_all)
  {
    Field *f;
  
    if (unlikely(! m_row_exists))
      return HA_ERR_RECORD_DELETED;
  
    /* Set the null bits */
    DBUG_ASSERT(table->s->null_bytes == 1);
    buf[0]= 0;
  
    for (; (f= *fields) ; fields++)
    {
      if (read_all || bitmap_is_set(table->read_set, f->field_index))
      {
        switch(f->field_index)
        {
        case 0: /* HOST */
          m_row.m_host.set_field(f);
          break;
        case 1: /* EVENT_NAME */
          m_row.m_event_name.set_field(f);
          break;
        default: /* 2, ... COUNT/SUM/MIN/AVG/MAX */
          m_row.m_stat.set_field(f->field_index - 2, f);
          break;
        }
      }
    }
  
    return 0;
  }
  
  