← Back to branch summary

~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to sql/rpl_utility.cc

Merged from trunk.

Show diffs side-by-side

added added

removed removed

Lines of Context:
sql/rpl_utility.cc
 
1
/* Copyright (C) 2006 MySQL AB
 
2
 
 
3
   This program is free software; you can redistribute it and/or modify
 
4
   it under the terms of the GNU General Public License as published by
 
5
   the Free Software Foundation; version 2 of the License.
 
6
 
 
7
   This program is distributed in the hope that it will be useful,
 
8
   but WITHOUT ANY WARRANTY; without even the implied warranty of
 
9
   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 
10
   GNU General Public License for more details.
 
11
 
 
12
   You should have received a copy of the GNU General Public License
 
13
   along with this program; if not, write to the Free Software
 
14
   Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA */
 
15
 
 
16
#include "rpl_utility.h"
 
17
#include "rpl_rli.h"
 
18
 
 
19
/*********************************************************************
 
20
 *                   table_def member definitions                    *
 
21
 *********************************************************************/
 
22
 
 
23
/*
 
24
  This function returns the field size in raw bytes based on the type
 
25
  and the encoded field data from the master's raw data.
 
26
*/
 
27
uint32 table_def::calc_field_size(uint col, uchar *master_data) const
 
28
{
 
29
  uint32 length= 0;
 
30
 
 
31
  switch (type(col)) {
 
32
  case MYSQL_TYPE_NEWDECIMAL:
 
33
    length= my_decimal_get_binary_size(m_field_metadata[col] >> 8, 
 
34
                                       m_field_metadata[col] & 0xff);
 
35
    break;
 
36
  case MYSQL_TYPE_FLOAT:
 
37
  case MYSQL_TYPE_DOUBLE:
 
38
    length= m_field_metadata[col];
 
39
    break;
 
40
  /*
 
41
    The cases for SET and ENUM are include for completeness, however
 
42
    both are mapped to type MYSQL_TYPE_STRING and their real types
 
43
    are encoded in the field metadata.
 
44
  */
 
45
  case MYSQL_TYPE_SET:
 
46
  case MYSQL_TYPE_ENUM:
 
47
  case MYSQL_TYPE_STRING:
 
48
  {
 
49
    uchar type= m_field_metadata[col] >> 8U;
 
50
    if ((type == MYSQL_TYPE_SET) || (type == MYSQL_TYPE_ENUM))
 
51
      length= m_field_metadata[col] & 0x00ff;
 
52
    else
 
53
    {
 
54
      /*
 
55
        We are reading the actual size from the master_data record
 
56
        because this field has the actual lengh stored in the first
 
57
        byte.
 
58
      */
 
59
      length= (uint) *master_data + 1;
 
60
      DBUG_ASSERT(length != 0);
 
61
    }
 
62
    break;
 
63
  }
 
64
  case MYSQL_TYPE_YEAR:
 
65
  case MYSQL_TYPE_TINY:
 
66
    length= 1;
 
67
    break;
 
68
  case MYSQL_TYPE_SHORT:
 
69
    length= 2;
 
70
    break;
 
71
  case MYSQL_TYPE_LONG:
 
72
    length= 4;
 
73
    break;
 
74
  case MYSQL_TYPE_LONGLONG:
 
75
    length= 8;
 
76
    break;
 
77
  case MYSQL_TYPE_NULL:
 
78
    length= 0;
 
79
    break;
 
80
  case MYSQL_TYPE_NEWDATE:
 
81
    length= 3;
 
82
    break;
 
83
  case MYSQL_TYPE_DATE:
 
84
  case MYSQL_TYPE_TIME:
 
85
    length= 3;
 
86
    break;
 
87
  case MYSQL_TYPE_TIMESTAMP:
 
88
    length= 4;
 
89
    break;
 
90
  case MYSQL_TYPE_DATETIME:
 
91
    length= 8;
 
92
    break;
 
93
  case MYSQL_TYPE_VARCHAR:
 
94
  {
 
95
    length= m_field_metadata[col] > 255 ? 2 : 1; // c&p of Field_varstring::data_length()
 
96
    DBUG_ASSERT(uint2korr(master_data) > 0);
 
97
    length+= length == 1 ? (uint32) *master_data : uint2korr(master_data);
 
98
    break;
 
99
  }
 
100
  case MYSQL_TYPE_TINY_BLOB:
 
101
  case MYSQL_TYPE_MEDIUM_BLOB:
 
102
  case MYSQL_TYPE_LONG_BLOB:
 
103
  case MYSQL_TYPE_BLOB:
 
104
  {
 
105
    /*
 
106
      Compute the length of the data. We cannot use get_length() here
 
107
      since it is dependent on the specific table (and also checks the
 
108
      packlength using the internal 'table' pointer) and replication
 
109
      is using a fixed format for storing data in the binlog.
 
110
    */
 
111
    switch (m_field_metadata[col]) {
 
112
    case 1:
 
113
      length= *master_data;
 
114
      break;
 
115
    case 2:
 
116
      length= uint2korr(master_data);
 
117
      break;
 
118
    case 3:
 
119
      length= uint3korr(master_data);
 
120
      break;
 
121
    case 4:
 
122
      length= uint4korr(master_data);
 
123
      break;
 
124
    default:
 
125
      DBUG_ASSERT(0);           // Should not come here
 
126
      break;
 
127
    }
 
128
 
 
129
    length+= m_field_metadata[col];
 
130
    break;
 
131
  }
 
132
  default:
 
133
    length= ~(uint32) 0;
 
134
  }
 
135
  return length;
 
136
}
 
137
 
 
138
/*
 
139
  Is the definition compatible with a table?
 
140
 
 
141
*/
 
142
int
 
143
table_def::compatible_with(Relay_log_info const *rli_arg, TABLE *table)
 
144
  const
 
145
{
 
146
  /*
 
147
    We only check the initial columns for the tables.
 
148
  */
 
149
  uint const cols_to_check= min(table->s->fields, size());
 
150
  int error= 0;
 
151
  Relay_log_info const *rli= const_cast<Relay_log_info*>(rli_arg);
 
152
 
 
153
  TABLE_SHARE const *const tsh= table->s;
 
154
 
 
155
  for (uint col= 0 ; col < cols_to_check ; ++col)
 
156
  {
 
157
    if (table->field[col]->type() != type(col))
 
158
    {
 
159
      DBUG_ASSERT(col < size() && col < tsh->fields);
 
160
      DBUG_ASSERT(tsh->db.str && tsh->table_name.str);
 
161
      error= 1;
 
162
      char buf[256];
 
163
      snprintf(buf, sizeof(buf), "Column %d type mismatch - "
 
164
                "received type %d, %s.%s has type %d",
 
165
                col, type(col), tsh->db.str, tsh->table_name.str,
 
166
                table->field[col]->type());
 
167
      rli->report(ERROR_LEVEL, ER_BINLOG_ROW_WRONG_TABLE_DEF,
 
168
                  ER(ER_BINLOG_ROW_WRONG_TABLE_DEF), buf);
 
169
    }
 
170
    /*
 
171
      Check the slave's field size against that of the master.
 
172
    */
 
173
    if (!error && 
 
174
        !table->field[col]->compatible_field_size(field_metadata(col)))
 
175
    {
 
176
      error= 1;
 
177
      char buf[256];
 
178
      snprintf(buf, sizeof(buf), "Column %d size mismatch - "
 
179
               "master has size %d, %s.%s on slave has size %d."
 
180
               " Master's column size should be <= the slave's "
 
181
               "column size.", col,
 
182
               table->field[col]->pack_length_from_metadata(
 
183
                                    m_field_metadata[col]),
 
184
               tsh->db.str, tsh->table_name.str, 
 
185
               table->field[col]->row_pack_length());
 
186
      rli->report(ERROR_LEVEL, ER_BINLOG_ROW_WRONG_TABLE_DEF,
 
187
                  ER(ER_BINLOG_ROW_WRONG_TABLE_DEF), buf);
 
188
    }
 
189
  }
 
190
 
 
191
  return error;
 
192
}