diff options
Diffstat (limited to 'sql/log_event.cc')
| -rw-r--r-- | sql/log_event.cc | 158 |
1 files changed, 1 insertions, 157 deletions
diff --git a/sql/log_event.cc b/sql/log_event.cc index d484ef55e5e..b67629a2c08 100644 --- a/sql/log_event.cc +++ b/sql/log_event.cc @@ -26,6 +26,7 @@ #include "rpl_mi.h" #include "rpl_filter.h" #include "rpl_utility.h" +#include "rpl_record.h" #include <my_dir.h> #endif /* MYSQL_CLIENT */ #include <base64.h> @@ -5811,163 +5812,6 @@ int Rows_log_event::do_add_row_data(byte *const row_data, #endif #if !defined(MYSQL_CLIENT) && defined(HAVE_REPLICATION) -/* - Unpack a row into table->record[0]. - - SYNOPSIS - unpack_row() - rli Relay log info - table Table to unpack into - colcnt Number of columns to read from record - row Packed row data - cols Pointer to columns data to fill in - row_end Pointer to variable that will hold the value of the - one-after-end position for the row - master_reclength - Pointer to variable that will be set to the length of the - record on the master side - rw_set Pointer to bitmap that holds either the read_set or the - write_set of the table - - DESCRIPTION - - The function will always unpack into the table->record[0] - record. This is because there are too many dependencies on - where the various member functions of Field and subclasses - expect to write. - - The row is assumed to only consist of the fields for which the - bitset represented by 'arr' and 'bits'; the other parts of the - record are left alone. - - At most 'colcnt' columns are read: if the table is larger than - that, the remaining fields are not filled in. - - RETURN VALUE - - Error code, or zero if no error. The following error codes can - be returned: - - ER_NO_DEFAULT_FOR_FIELD - Returned if one of the fields existing on the slave but not on - the master does not have a default value (and isn't nullable) - */ -static int -unpack_row(RELAY_LOG_INFO const *rli, - TABLE *table, uint const colcnt, - char const *const row_data, MY_BITMAP const *cols, - char const **const row_end, ulong *const master_reclength, - MY_BITMAP* const rw_set, Log_event_type const event_type) -{ - DBUG_ENTER("unpack_row"); - DBUG_ASSERT(row_data); - my_size_t const master_null_byte_count= (bitmap_bits_set(cols) + 7) / 8; - int error= 0; - - char const *null_ptr= row_data; - char const *pack_ptr= row_data + master_null_byte_count; - - bitmap_clear_all(rw_set); - - empty_record(table); - - Field **const begin_ptr = table->field; - Field **field_ptr; - Field **const end_ptr= begin_ptr + colcnt; - - DBUG_ASSERT(null_ptr < row_data + master_null_byte_count); - - // Mask to mask out the correct bit among the null bits - unsigned int null_mask= 1U; - // The "current" null bits - unsigned int null_bits= *null_ptr++; - for (field_ptr= begin_ptr ; field_ptr < end_ptr ; ++field_ptr) - { - Field *const f= *field_ptr; - - /* - No need to bother about columns that does not exist: they have - gotten default values when being emptied above. - */ - if (bitmap_is_set(cols, field_ptr - begin_ptr)) - { - if ((null_mask & 0xFF) == 0) - { - DBUG_ASSERT(null_ptr < row_data + master_null_byte_count); - null_mask= 1U; - null_bits= *null_ptr++; - } - - DBUG_ASSERT(null_mask & 0xFF); // One of the 8 LSB should be set - - /* Field...::unpack() cannot return 0 */ - DBUG_ASSERT(pack_ptr != NULL); - - if ((null_bits & null_mask) && f->maybe_null()) - f->set_null(); - else - { - f->set_notnull(); - - /* - We only unpack the field if it was non-null - */ - pack_ptr= f->unpack(f->ptr, pack_ptr); - } - - bitmap_set_bit(rw_set, f->field_index); - null_mask <<= 1; - } - } - - /* - We should now have read all the null bytes, otherwise something is - really wrong. - */ - DBUG_ASSERT(null_ptr == row_data + master_null_byte_count); - - *row_end = pack_ptr; - if (master_reclength) - { - if (*field_ptr) - *master_reclength = (*field_ptr)->ptr - (char*) table->record[0]; - else - *master_reclength = table->s->reclength; - } - - /* - Set properties for remaining columns, if there are any. We let the - corresponding bit in the write_set be set, to write the value if - it was not there already. We iterate over all remaining columns, - even if there were an error, to get as many error messages as - possible. We are still able to return a pointer to the next row, - so redo that. - - This generation of error messages is only relevant when inserting - new rows. - */ - for ( ; *field_ptr ; ++field_ptr) - { - uint32 const mask= NOT_NULL_FLAG | NO_DEFAULT_VALUE_FLAG; - Field *const f= *field_ptr; - - if (event_type == WRITE_ROWS_EVENT && - ((*field_ptr)->flags & mask) == mask) - { - slave_print_msg(ERROR_LEVEL, rli, ER_NO_DEFAULT_FOR_FIELD, - "Field `%s` of table `%s`.`%s` " - "has no default value and cannot be NULL", - (*field_ptr)->field_name, table->s->db.str, - table->s->table_name.str); - error = ER_NO_DEFAULT_FOR_FIELD; - } - else - f->set_default(); - } - - DBUG_RETURN(error); -} - int Rows_log_event::do_apply_event(RELAY_LOG_INFO const *rli) { DBUG_ENTER("Rows_log_event::do_apply_event(st_relay_log_info*)"); |