MySQL DBA如何"土土"地利用源码解决没有遇到过的错误？

MySQL error code 1615 (ER_NEED_REPREPARE): Prepared statement needs to be re-prepared

Prepared_statement::execute_loop() -- try to execute
a statement, reprepare in case of validation error, and try
again until MAX_REPREPARE_ATTEMPTS has been reached.
mysql_{sql_}stmt_execute() are changed to invoke this
method instead of plain execute().
Prepared_statement::reprepare() -- reprepare a prepared
statement, called from execute_loop() in case of ER_NEED_REPREPARE
error.

 if ((sql_command_flags[lex->sql_command] & CF_REEXECUTION_FRAGILE) &&
      error && !thd->is_fatal_error && !thd->killed &&
      // reprepare观察者发现invalidated，尝试MAX_REPREPARE_ATTEMPTS后报错ER_NEED_REPREPARE
      reprepare_observer.is_invalidated() &&
      reprepare_attempt++ < MAX_REPREPARE_ATTEMPTS)
  {
    DBUG_ASSERT(thd->get_stmt_da()->mysql_errno() == ER_NEED_REPREPARE);
    thd->clear_error();
    error= reprepare();
    if (! error)                                /* Success */
      goto reexecute;
  }

/**
Reprepare_observer观察者是用来观察某个表从上一次执行后的版本变化
这里的"table"可以是MySQL表、临时表、视图或者information schema的表
当我们执行prepared SQL进行打开表并加锁的时候，必须要确认表没有发生改变(DML除外)。因为如果从上次prepare后表发生了改变，那么解析树可能就失效了，例如它可能包含了基于表metadata的优化。
  @sa check_and_update_table_version() 获取版本跟踪算法
*/
class Reprepare_observer
{
public:
  /**
  检查meatadata是否有变化
  */
  bool report_error(THD *thd);
  bool is_invalidated() const { return m_invalidated; }
  void reset_reprepare_observer() { m_invalidated= FALSE; }
private:
  bool m_invalidated;
};

check_and_update_table_version() for details of the
  version tracking algorithm

/**
这里需要比较table definition cache中的元数据版本和之前prepare生成的parse tree中的node进行版本对比

*/
static bool
check_and_update_table_version(THD *thd,
                               TABLE_LIST *tables, TABLE_SHARE *table_share)
{
   // 如果table_id != prepare时的table id，抛出错误，如果是prepare时期，虽然也不匹配，但是这个时候并没有观察者，也就不会抛出错误，但是到execute时，已经有了观察者，这个时候不匹配的话，就会抛出错误了
  if (! tables->is_table_ref_id_equal(table_share))
  {
    Reprepare_observer *reprepare_observer= thd->get_reprepare_observer();
    if (reprepare_observer &&
        reprepare_observer->report_error(thd))
    {
      /*
        版本不匹配，抛出错误，返回TRUE
      */
      DBUG_ASSERT(thd->is_error());
      return TRUE;
    }
    /* 根据table definition cache中的table id更新，总是维护最新的 */
    tables->set_table_ref_id(table_share);
  }
  DBUG_EXECUTE_IF("reprepare_each_statement", return inject_reprepare(thd););
  return FALSE;
}

static Table_id last_table_id;
void assign_new_table_id(TABLE_SHARE *share)
{
  DBUG_ENTER("assign_new_table_id");
  /* Preconditions */
  DBUG_ASSERT(share != NULL);
  mysql_mutex_assert_owner(&LOCK_open);
  DBUG_EXECUTE_IF("dbug_table_map_id_500", last_table_id= 500;);
  DBUG_EXECUTE_IF("dbug_table_map_id_4B_UINT_MAX+501",
                  last_table_id= 501ULL + UINT_MAX;);
  DBUG_EXECUTE_IF("dbug_table_map_id_6B_UINT_MAX",
                  last_table_id= (~0ULL >> 16););
  share->table_map_id= last_table_id++;
  DBUG_PRINT("info", ("table_id=%llu", share->table_map_id.id()));
  DBUG_VOID_RETURN;
}

prepare:reprepare_attempt=0 MAX_REPREPARE_ATTEMPTS=3 :
execute:
     如果table table被重置过了那么 reprepare_attempt +=1
     loop：
        重新准备 reprepare
        再次 execute
        如果table table被重置过了继续循环 reprepare_attempt +=1,如果reprepare_attempt>=MAX_REPREPARE_ATTEMPTS 这报错
        否则正常退出循环，正常执行
     end loop