~drizzle-trunk/drizzle/development

  else

    return; /* No data modification occurred inside the transaction */

    }

  }

}

void ReplicationServices::updateRecord(Session *in_session,

                                       Table *in_table, 

                                       const unsigned char *old_record, 

                                       const unsigned char *new_record)

{

  if (! is_active)

    return;

 

  message::Statement &statement= getUpdateStatement(in_session, in_table, old_record, new_record);

 

  message::UpdateData *data= statement.mutable_update_data();

  data->set_segment_id(1);

  data->set_end_segment(true);

  message::UpdateRecord *record= data->add_record();

 

  Field *current_field;

  Field **table_fields= in_table->field;

  String *string_value= new (in_session->mem_root) String(ReplicationServices::DEFAULT_RECORD_SIZE);

  string_value->set_charset(system_charset_info);

 

  while ((current_field= *table_fields++) != NULL) 

  {

    /*

     * Here, we add the SET field values.  We used to do this in the setUpdateHeader() method, 

     * but then realized that an UPDATE statement could potentially have different values for

     * the SET field.  For instance, imagine this SQL scenario:

     *

     * CREATE TABLE t1 (id INT NOT NULL PRIMARY KEY, count INT NOT NULL);

     * INSERT INTO t1 (id, counter) VALUES (1,1),(2,2),(3,3);

     * UPDATE t1 SET counter = counter + 1 WHERE id IN (1,2);

     *

     * We will generate two UpdateRecord messages with different set_value byte arrays.

     *

     * The below really should be moved into the Field API and Record API.  But for now

     * we do this crazy pointer fiddling to figure out if the current field

     * has been updated in the supplied record raw byte pointers.

     */

    const unsigned char *old_ptr= (const unsigned char *) old_record + (ptrdiff_t) (current_field->ptr - in_table->record[0]); 

    const unsigned char *new_ptr= (const unsigned char *) new_record + (ptrdiff_t) (current_field->ptr - in_table->record[0]); 

 

    uint32_t field_length= current_field->pack_length(); /** @TODO This isn't always correct...check varchar diffs. */

 

    if (memcmp(old_ptr, new_ptr, field_length) != 0)

    {

      record->add_after_value(string_value->c_ptr());