Method create_conversion_table

sql/rpl_utility_server.cc:1194–1257

 */

TABLE *table_def::create_conversion_table(THD *thd, rpl_group_info *rgi,
                                          RPL_TABLE_LIST *table_list) const
{
  Virtual_conversion_table *conv_table;
  Relay_log_info *rli= rgi->rli;
  TABLE *target_table= table_list->table;
  uint const cols_to_create= MY_MIN(size(), target_table->s->fields);
  DBUG_ENTER("table_def::create_conversion_table");

  if (!(conv_table= new(thd) Virtual_conversion_table(thd)) ||
      conv_table->init(cols_to_create))
    goto err;

  /*
    Iterate through the number of columns logged on the master, and if
    skip any that are missing on the slave. Skipped columns are not
    added to the conv_table, as there is no column on the slave to use
    as the reference for the target_field.
  */
  for (uint col= 0 ; col < cols_to_create; col++)
  {
    Field *field;
    if (master_to_slave_error[col])
      continue;                                 // Slave does not have field
    const Type_handler *ha= field_type_handler(col);
    if (!ha)
    {
      /* This can happen as we have not checked all columns in the caller */
      master_to_slave_error[col]= SLAVE_FIELD_UNKNOWN_TYPE;
      continue;
    }

    field= target_table->field[master_to_slave_map[col]];
    if (conv_table->add(ha, field_metadata(col), field))
    {
      DBUG_PRINT("debug", ("binlog_type: %d, metadata: %04X, target_field: '%s'"
                           " make_conversion_table_field() failed",
                           binlog_type(col), field_metadata(col),
                           field->field_name.str));
      goto err;
    }
    /*
      We only use the conversion table for not null values
      This also avoids a bug in Virtual_conversion_table where the null
      pointer for created fields points to uninitialized memory.
    */
    conv_table->make_not_null();
  }

  conv_table->fix_field_count();
  if (conv_table->open())
    goto err; // Could not allocate record buffer?

  DBUG_RETURN(conv_table);

err:
  if (conv_table)
    delete conv_table;