4 #define INTERNAL_SUPPRESS_PROTOBUF_FIELD_DEPRECATION
5 #include "transaction.pb.h"
9 #include <google/protobuf/stubs/common.h>
10 #include <google/protobuf/stubs/once.h>
11 #include <google/protobuf/io/coded_stream.h>
12 #include <google/protobuf/wire_format_lite_inl.h>
13 #include <google/protobuf/descriptor.h>
14 #include <google/protobuf/generated_message_reflection.h>
15 #include <google/protobuf/reflection_ops.h>
16 #include <google/protobuf/wire_format.h>
24 const ::google::protobuf::Descriptor* FieldMetadata_descriptor_ = NULL;
25 const ::google::protobuf::internal::GeneratedMessageReflection*
26 FieldMetadata_reflection_ = NULL;
27 const ::google::protobuf::Descriptor* TableMetadata_descriptor_ = NULL;
28 const ::google::protobuf::internal::GeneratedMessageReflection*
29 TableMetadata_reflection_ = NULL;
30 const ::google::protobuf::Descriptor* TransactionContext_descriptor_ = NULL;
31 const ::google::protobuf::internal::GeneratedMessageReflection*
32 TransactionContext_reflection_ = NULL;
33 const ::google::protobuf::Descriptor* InsertRecord_descriptor_ = NULL;
34 const ::google::protobuf::internal::GeneratedMessageReflection*
35 InsertRecord_reflection_ = NULL;
36 const ::google::protobuf::Descriptor* InsertHeader_descriptor_ = NULL;
37 const ::google::protobuf::internal::GeneratedMessageReflection*
38 InsertHeader_reflection_ = NULL;
39 const ::google::protobuf::Descriptor* InsertData_descriptor_ = NULL;
40 const ::google::protobuf::internal::GeneratedMessageReflection*
41 InsertData_reflection_ = NULL;
42 const ::google::protobuf::Descriptor* UpdateRecord_descriptor_ = NULL;
43 const ::google::protobuf::internal::GeneratedMessageReflection*
44 UpdateRecord_reflection_ = NULL;
45 const ::google::protobuf::Descriptor* UpdateHeader_descriptor_ = NULL;
46 const ::google::protobuf::internal::GeneratedMessageReflection*
47 UpdateHeader_reflection_ = NULL;
48 const ::google::protobuf::Descriptor* UpdateData_descriptor_ = NULL;
49 const ::google::protobuf::internal::GeneratedMessageReflection*
50 UpdateData_reflection_ = NULL;
51 const ::google::protobuf::Descriptor* DeleteRecord_descriptor_ = NULL;
52 const ::google::protobuf::internal::GeneratedMessageReflection*
53 DeleteRecord_reflection_ = NULL;
54 const ::google::protobuf::Descriptor* DeleteHeader_descriptor_ = NULL;
55 const ::google::protobuf::internal::GeneratedMessageReflection*
56 DeleteHeader_reflection_ = NULL;
57 const ::google::protobuf::Descriptor* DeleteData_descriptor_ = NULL;
58 const ::google::protobuf::internal::GeneratedMessageReflection*
59 DeleteData_reflection_ = NULL;
60 const ::google::protobuf::Descriptor* TruncateTableStatement_descriptor_ = NULL;
61 const ::google::protobuf::internal::GeneratedMessageReflection*
62 TruncateTableStatement_reflection_ = NULL;
63 const ::google::protobuf::Descriptor* CreateSchemaStatement_descriptor_ = NULL;
64 const ::google::protobuf::internal::GeneratedMessageReflection*
65 CreateSchemaStatement_reflection_ = NULL;
66 const ::google::protobuf::Descriptor* AlterSchemaStatement_descriptor_ = NULL;
67 const ::google::protobuf::internal::GeneratedMessageReflection*
68 AlterSchemaStatement_reflection_ = NULL;
69 const ::google::protobuf::Descriptor* DropSchemaStatement_descriptor_ = NULL;
70 const ::google::protobuf::internal::GeneratedMessageReflection*
71 DropSchemaStatement_reflection_ = NULL;
72 const ::google::protobuf::Descriptor* CreateTableStatement_descriptor_ = NULL;
73 const ::google::protobuf::internal::GeneratedMessageReflection*
74 CreateTableStatement_reflection_ = NULL;
75 const ::google::protobuf::Descriptor* AlterTableStatement_descriptor_ = NULL;
76 const ::google::protobuf::internal::GeneratedMessageReflection*
77 AlterTableStatement_reflection_ = NULL;
78 const ::google::protobuf::Descriptor* DropTableStatement_descriptor_ = NULL;
79 const ::google::protobuf::internal::GeneratedMessageReflection*
80 DropTableStatement_reflection_ = NULL;
81 const ::google::protobuf::Descriptor* SetVariableStatement_descriptor_ = NULL;
82 const ::google::protobuf::internal::GeneratedMessageReflection*
83 SetVariableStatement_reflection_ = NULL;
84 const ::google::protobuf::Descriptor* Statement_descriptor_ = NULL;
85 const ::google::protobuf::internal::GeneratedMessageReflection*
86 Statement_reflection_ = NULL;
87 const ::google::protobuf::EnumDescriptor* Statement_Type_descriptor_ = NULL;
88 const ::google::protobuf::Descriptor* Transaction_descriptor_ = NULL;
89 const ::google::protobuf::internal::GeneratedMessageReflection*
90 Transaction_reflection_ = NULL;
95 void protobuf_AssignDesc_transaction_2eproto() {
96 protobuf_AddDesc_transaction_2eproto();
97 const ::google::protobuf::FileDescriptor* file =
98 ::google::protobuf::DescriptorPool::generated_pool()->FindFileByName(
100 GOOGLE_CHECK(file != NULL);
101 FieldMetadata_descriptor_ = file->message_type(0);
102 static const int FieldMetadata_offsets_[2] = {
103 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(FieldMetadata, type_),
104 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(FieldMetadata, name_),
106 FieldMetadata_reflection_ =
107 new ::google::protobuf::internal::GeneratedMessageReflection(
108 FieldMetadata_descriptor_,
109 FieldMetadata::default_instance_,
110 FieldMetadata_offsets_,
111 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(FieldMetadata, _has_bits_[0]),
112 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(FieldMetadata, _unknown_fields_),
114 ::google::protobuf::DescriptorPool::generated_pool(),
115 ::google::protobuf::MessageFactory::generated_factory(),
116 sizeof(FieldMetadata));
117 TableMetadata_descriptor_ = file->message_type(1);
118 static const int TableMetadata_offsets_[3] = {
119 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(TableMetadata, schema_name_),
120 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(TableMetadata, table_name_),
121 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(TableMetadata, catalog_name_),
123 TableMetadata_reflection_ =
124 new ::google::protobuf::internal::GeneratedMessageReflection(
125 TableMetadata_descriptor_,
126 TableMetadata::default_instance_,
127 TableMetadata_offsets_,
128 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(TableMetadata, _has_bits_[0]),
129 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(TableMetadata, _unknown_fields_),
131 ::google::protobuf::DescriptorPool::generated_pool(),
132 ::google::protobuf::MessageFactory::generated_factory(),
133 sizeof(TableMetadata));
134 TransactionContext_descriptor_ = file->message_type(2);
135 static const int TransactionContext_offsets_[4] = {
136 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(TransactionContext, server_id_),
137 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(TransactionContext, transaction_id_),
138 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(TransactionContext, start_timestamp_),
139 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(TransactionContext, end_timestamp_),
141 TransactionContext_reflection_ =
142 new ::google::protobuf::internal::GeneratedMessageReflection(
143 TransactionContext_descriptor_,
144 TransactionContext::default_instance_,
145 TransactionContext_offsets_,
146 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(TransactionContext, _has_bits_[0]),
147 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(TransactionContext, _unknown_fields_),
149 ::google::protobuf::DescriptorPool::generated_pool(),
150 ::google::protobuf::MessageFactory::generated_factory(),
151 sizeof(TransactionContext));
152 InsertRecord_descriptor_ = file->message_type(3);
153 static const int InsertRecord_offsets_[2] = {
154 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(InsertRecord, insert_value_),
155 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(InsertRecord, is_null_),
157 InsertRecord_reflection_ =
158 new ::google::protobuf::internal::GeneratedMessageReflection(
159 InsertRecord_descriptor_,
160 InsertRecord::default_instance_,
161 InsertRecord_offsets_,
162 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(InsertRecord, _has_bits_[0]),
163 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(InsertRecord, _unknown_fields_),
165 ::google::protobuf::DescriptorPool::generated_pool(),
166 ::google::protobuf::MessageFactory::generated_factory(),
167 sizeof(InsertRecord));
168 InsertHeader_descriptor_ = file->message_type(4);
169 static const int InsertHeader_offsets_[2] = {
170 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(InsertHeader, table_metadata_),
171 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(InsertHeader, field_metadata_),
173 InsertHeader_reflection_ =
174 new ::google::protobuf::internal::GeneratedMessageReflection(
175 InsertHeader_descriptor_,
176 InsertHeader::default_instance_,
177 InsertHeader_offsets_,
178 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(InsertHeader, _has_bits_[0]),
179 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(InsertHeader, _unknown_fields_),
181 ::google::protobuf::DescriptorPool::generated_pool(),
182 ::google::protobuf::MessageFactory::generated_factory(),
183 sizeof(InsertHeader));
184 InsertData_descriptor_ = file->message_type(5);
185 static const int InsertData_offsets_[3] = {
186 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(InsertData, segment_id_),
187 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(InsertData, end_segment_),
188 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(InsertData, record_),
190 InsertData_reflection_ =
191 new ::google::protobuf::internal::GeneratedMessageReflection(
192 InsertData_descriptor_,
193 InsertData::default_instance_,
195 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(InsertData, _has_bits_[0]),
196 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(InsertData, _unknown_fields_),
198 ::google::protobuf::DescriptorPool::generated_pool(),
199 ::google::protobuf::MessageFactory::generated_factory(),
201 UpdateRecord_descriptor_ = file->message_type(6);
202 static const int UpdateRecord_offsets_[4] = {
203 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(UpdateRecord, key_value_),
204 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(UpdateRecord, after_value_),
205 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(UpdateRecord, before_value_),
206 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(UpdateRecord, is_null_),
208 UpdateRecord_reflection_ =
209 new ::google::protobuf::internal::GeneratedMessageReflection(
210 UpdateRecord_descriptor_,
211 UpdateRecord::default_instance_,
212 UpdateRecord_offsets_,
213 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(UpdateRecord, _has_bits_[0]),
214 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(UpdateRecord, _unknown_fields_),
216 ::google::protobuf::DescriptorPool::generated_pool(),
217 ::google::protobuf::MessageFactory::generated_factory(),
218 sizeof(UpdateRecord));
219 UpdateHeader_descriptor_ = file->message_type(7);
220 static const int UpdateHeader_offsets_[3] = {
221 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(UpdateHeader, table_metadata_),
222 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(UpdateHeader, key_field_metadata_),
223 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(UpdateHeader, set_field_metadata_),
225 UpdateHeader_reflection_ =
226 new ::google::protobuf::internal::GeneratedMessageReflection(
227 UpdateHeader_descriptor_,
228 UpdateHeader::default_instance_,
229 UpdateHeader_offsets_,
230 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(UpdateHeader, _has_bits_[0]),
231 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(UpdateHeader, _unknown_fields_),
233 ::google::protobuf::DescriptorPool::generated_pool(),
234 ::google::protobuf::MessageFactory::generated_factory(),
235 sizeof(UpdateHeader));
236 UpdateData_descriptor_ = file->message_type(8);
237 static const int UpdateData_offsets_[3] = {
238 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(UpdateData, segment_id_),
239 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(UpdateData, end_segment_),
240 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(UpdateData, record_),
242 UpdateData_reflection_ =
243 new ::google::protobuf::internal::GeneratedMessageReflection(
244 UpdateData_descriptor_,
245 UpdateData::default_instance_,
247 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(UpdateData, _has_bits_[0]),
248 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(UpdateData, _unknown_fields_),
250 ::google::protobuf::DescriptorPool::generated_pool(),
251 ::google::protobuf::MessageFactory::generated_factory(),
253 DeleteRecord_descriptor_ = file->message_type(9);
254 static const int DeleteRecord_offsets_[1] = {
255 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DeleteRecord, key_value_),
257 DeleteRecord_reflection_ =
258 new ::google::protobuf::internal::GeneratedMessageReflection(
259 DeleteRecord_descriptor_,
260 DeleteRecord::default_instance_,
261 DeleteRecord_offsets_,
262 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DeleteRecord, _has_bits_[0]),
263 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DeleteRecord, _unknown_fields_),
265 ::google::protobuf::DescriptorPool::generated_pool(),
266 ::google::protobuf::MessageFactory::generated_factory(),
267 sizeof(DeleteRecord));
268 DeleteHeader_descriptor_ = file->message_type(10);
269 static const int DeleteHeader_offsets_[2] = {
270 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DeleteHeader, table_metadata_),
271 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DeleteHeader, key_field_metadata_),
273 DeleteHeader_reflection_ =
274 new ::google::protobuf::internal::GeneratedMessageReflection(
275 DeleteHeader_descriptor_,
276 DeleteHeader::default_instance_,
277 DeleteHeader_offsets_,
278 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DeleteHeader, _has_bits_[0]),
279 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DeleteHeader, _unknown_fields_),
281 ::google::protobuf::DescriptorPool::generated_pool(),
282 ::google::protobuf::MessageFactory::generated_factory(),
283 sizeof(DeleteHeader));
284 DeleteData_descriptor_ = file->message_type(11);
285 static const int DeleteData_offsets_[3] = {
286 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DeleteData, segment_id_),
287 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DeleteData, end_segment_),
288 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DeleteData, record_),
290 DeleteData_reflection_ =
291 new ::google::protobuf::internal::GeneratedMessageReflection(
292 DeleteData_descriptor_,
293 DeleteData::default_instance_,
295 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DeleteData, _has_bits_[0]),
296 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DeleteData, _unknown_fields_),
298 ::google::protobuf::DescriptorPool::generated_pool(),
299 ::google::protobuf::MessageFactory::generated_factory(),
301 TruncateTableStatement_descriptor_ = file->message_type(12);
302 static const int TruncateTableStatement_offsets_[1] = {
303 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(TruncateTableStatement, table_metadata_),
305 TruncateTableStatement_reflection_ =
306 new ::google::protobuf::internal::GeneratedMessageReflection(
307 TruncateTableStatement_descriptor_,
308 TruncateTableStatement::default_instance_,
309 TruncateTableStatement_offsets_,
310 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(TruncateTableStatement, _has_bits_[0]),
311 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(TruncateTableStatement, _unknown_fields_),
313 ::google::protobuf::DescriptorPool::generated_pool(),
314 ::google::protobuf::MessageFactory::generated_factory(),
315 sizeof(TruncateTableStatement));
316 CreateSchemaStatement_descriptor_ = file->message_type(13);
317 static const int CreateSchemaStatement_offsets_[1] = {
318 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(CreateSchemaStatement, schema_),
320 CreateSchemaStatement_reflection_ =
321 new ::google::protobuf::internal::GeneratedMessageReflection(
322 CreateSchemaStatement_descriptor_,
323 CreateSchemaStatement::default_instance_,
324 CreateSchemaStatement_offsets_,
325 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(CreateSchemaStatement, _has_bits_[0]),
326 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(CreateSchemaStatement, _unknown_fields_),
328 ::google::protobuf::DescriptorPool::generated_pool(),
329 ::google::protobuf::MessageFactory::generated_factory(),
330 sizeof(CreateSchemaStatement));
331 AlterSchemaStatement_descriptor_ = file->message_type(14);
332 static const int AlterSchemaStatement_offsets_[2] = {
333 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(AlterSchemaStatement, before_),
334 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(AlterSchemaStatement, after_),
336 AlterSchemaStatement_reflection_ =
337 new ::google::protobuf::internal::GeneratedMessageReflection(
338 AlterSchemaStatement_descriptor_,
339 AlterSchemaStatement::default_instance_,
340 AlterSchemaStatement_offsets_,
341 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(AlterSchemaStatement, _has_bits_[0]),
342 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(AlterSchemaStatement, _unknown_fields_),
344 ::google::protobuf::DescriptorPool::generated_pool(),
345 ::google::protobuf::MessageFactory::generated_factory(),
346 sizeof(AlterSchemaStatement));
347 DropSchemaStatement_descriptor_ = file->message_type(15);
348 static const int DropSchemaStatement_offsets_[2] = {
349 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DropSchemaStatement, schema_name_),
350 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DropSchemaStatement, catalog_name_),
352 DropSchemaStatement_reflection_ =
353 new ::google::protobuf::internal::GeneratedMessageReflection(
354 DropSchemaStatement_descriptor_,
355 DropSchemaStatement::default_instance_,
356 DropSchemaStatement_offsets_,
357 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DropSchemaStatement, _has_bits_[0]),
358 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DropSchemaStatement, _unknown_fields_),
360 ::google::protobuf::DescriptorPool::generated_pool(),
361 ::google::protobuf::MessageFactory::generated_factory(),
362 sizeof(DropSchemaStatement));
363 CreateTableStatement_descriptor_ = file->message_type(16);
364 static const int CreateTableStatement_offsets_[1] = {
365 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(CreateTableStatement, table_),
367 CreateTableStatement_reflection_ =
368 new ::google::protobuf::internal::GeneratedMessageReflection(
369 CreateTableStatement_descriptor_,
370 CreateTableStatement::default_instance_,
371 CreateTableStatement_offsets_,
372 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(CreateTableStatement, _has_bits_[0]),
373 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(CreateTableStatement, _unknown_fields_),
375 ::google::protobuf::DescriptorPool::generated_pool(),
376 ::google::protobuf::MessageFactory::generated_factory(),
377 sizeof(CreateTableStatement));
378 AlterTableStatement_descriptor_ = file->message_type(17);
379 static const int AlterTableStatement_offsets_[2] = {
380 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(AlterTableStatement, before_),
381 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(AlterTableStatement, after_),
383 AlterTableStatement_reflection_ =
384 new ::google::protobuf::internal::GeneratedMessageReflection(
385 AlterTableStatement_descriptor_,
386 AlterTableStatement::default_instance_,
387 AlterTableStatement_offsets_,
388 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(AlterTableStatement, _has_bits_[0]),
389 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(AlterTableStatement, _unknown_fields_),
391 ::google::protobuf::DescriptorPool::generated_pool(),
392 ::google::protobuf::MessageFactory::generated_factory(),
393 sizeof(AlterTableStatement));
394 DropTableStatement_descriptor_ = file->message_type(18);
395 static const int DropTableStatement_offsets_[2] = {
396 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DropTableStatement, table_metadata_),
397 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DropTableStatement, if_exists_clause_),
399 DropTableStatement_reflection_ =
400 new ::google::protobuf::internal::GeneratedMessageReflection(
401 DropTableStatement_descriptor_,
402 DropTableStatement::default_instance_,
403 DropTableStatement_offsets_,
404 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DropTableStatement, _has_bits_[0]),
405 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DropTableStatement, _unknown_fields_),
407 ::google::protobuf::DescriptorPool::generated_pool(),
408 ::google::protobuf::MessageFactory::generated_factory(),
409 sizeof(DropTableStatement));
410 SetVariableStatement_descriptor_ = file->message_type(19);
411 static const int SetVariableStatement_offsets_[2] = {
412 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(SetVariableStatement, variable_metadata_),
413 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(SetVariableStatement, variable_value_),
415 SetVariableStatement_reflection_ =
416 new ::google::protobuf::internal::GeneratedMessageReflection(
417 SetVariableStatement_descriptor_,
418 SetVariableStatement::default_instance_,
419 SetVariableStatement_offsets_,
420 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(SetVariableStatement, _has_bits_[0]),
421 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(SetVariableStatement, _unknown_fields_),
423 ::google::protobuf::DescriptorPool::generated_pool(),
424 ::google::protobuf::MessageFactory::generated_factory(),
425 sizeof(SetVariableStatement));
426 Statement_descriptor_ = file->message_type(20);
427 static const int Statement_offsets_[19] = {
428 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(
Statement, type_),
429 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(
Statement, start_timestamp_),
430 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(
Statement, end_timestamp_),
431 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(
Statement, sql_),
432 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(
Statement, insert_header_),
433 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(
Statement, insert_data_),
434 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(
Statement, update_header_),
435 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(
Statement, update_data_),
436 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(
Statement, delete_header_),
437 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(
Statement, delete_data_),
438 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(
Statement, truncate_table_statement_),
439 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(
Statement, create_schema_statement_),
440 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(
Statement, drop_schema_statement_),
441 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(
Statement, alter_schema_statement_),
442 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(
Statement, create_table_statement_),
443 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(
Statement, alter_table_statement_),
444 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(
Statement, drop_table_statement_),
445 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(
Statement, set_variable_statement_),
446 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(
Statement, raw_sql_schema_),
448 Statement_reflection_ =
449 new ::google::protobuf::internal::GeneratedMessageReflection(
450 Statement_descriptor_,
451 Statement::default_instance_,
453 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(
Statement, _has_bits_[0]),
454 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(
Statement, _unknown_fields_),
456 ::google::protobuf::DescriptorPool::generated_pool(),
457 ::google::protobuf::MessageFactory::generated_factory(),
459 Statement_Type_descriptor_ = Statement_descriptor_->enum_type(0);
460 Transaction_descriptor_ = file->message_type(21);
461 static const int Transaction_offsets_[5] = {
462 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(Transaction, transaction_context_),
463 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(Transaction, statement_),
464 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(Transaction, event_),
465 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(Transaction, segment_id_),
466 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(Transaction, end_segment_),
468 Transaction_reflection_ =
469 new ::google::protobuf::internal::GeneratedMessageReflection(
470 Transaction_descriptor_,
471 Transaction::default_instance_,
472 Transaction_offsets_,
473 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(Transaction, _has_bits_[0]),
474 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(Transaction, _unknown_fields_),
476 ::google::protobuf::DescriptorPool::generated_pool(),
477 ::google::protobuf::MessageFactory::generated_factory(),
478 sizeof(Transaction));
483 GOOGLE_PROTOBUF_DECLARE_ONCE(protobuf_AssignDescriptors_once_);
484 inline void protobuf_AssignDescriptorsOnce() {
485 ::google::protobuf::GoogleOnceInit(&protobuf_AssignDescriptors_once_,
486 &protobuf_AssignDesc_transaction_2eproto);
489 void protobuf_RegisterTypes(const ::std::string&) {
490 protobuf_AssignDescriptorsOnce();
491 ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
492 FieldMetadata_descriptor_, &FieldMetadata::default_instance());
493 ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
494 TableMetadata_descriptor_, &TableMetadata::default_instance());
495 ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
496 TransactionContext_descriptor_, &TransactionContext::default_instance());
497 ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
498 InsertRecord_descriptor_, &InsertRecord::default_instance());
499 ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
500 InsertHeader_descriptor_, &InsertHeader::default_instance());
501 ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
502 InsertData_descriptor_, &InsertData::default_instance());
503 ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
504 UpdateRecord_descriptor_, &UpdateRecord::default_instance());
505 ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
506 UpdateHeader_descriptor_, &UpdateHeader::default_instance());
507 ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
508 UpdateData_descriptor_, &UpdateData::default_instance());
509 ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
510 DeleteRecord_descriptor_, &DeleteRecord::default_instance());
511 ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
512 DeleteHeader_descriptor_, &DeleteHeader::default_instance());
513 ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
514 DeleteData_descriptor_, &DeleteData::default_instance());
515 ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
516 TruncateTableStatement_descriptor_, &TruncateTableStatement::default_instance());
517 ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
518 CreateSchemaStatement_descriptor_, &CreateSchemaStatement::default_instance());
519 ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
520 AlterSchemaStatement_descriptor_, &AlterSchemaStatement::default_instance());
521 ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
522 DropSchemaStatement_descriptor_, &DropSchemaStatement::default_instance());
523 ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
524 CreateTableStatement_descriptor_, &CreateTableStatement::default_instance());
525 ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
526 AlterTableStatement_descriptor_, &AlterTableStatement::default_instance());
527 ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
528 DropTableStatement_descriptor_, &DropTableStatement::default_instance());
529 ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
530 SetVariableStatement_descriptor_, &SetVariableStatement::default_instance());
531 ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
532 Statement_descriptor_, &Statement::default_instance());
533 ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
534 Transaction_descriptor_, &Transaction::default_instance());
539 void protobuf_ShutdownFile_transaction_2eproto() {
540 delete FieldMetadata::default_instance_;
541 delete FieldMetadata_reflection_;
542 delete TableMetadata::default_instance_;
543 delete TableMetadata_reflection_;
544 delete TransactionContext::default_instance_;
545 delete TransactionContext_reflection_;
546 delete InsertRecord::default_instance_;
547 delete InsertRecord_reflection_;
548 delete InsertHeader::default_instance_;
549 delete InsertHeader_reflection_;
550 delete InsertData::default_instance_;
551 delete InsertData_reflection_;
552 delete UpdateRecord::default_instance_;
553 delete UpdateRecord_reflection_;
554 delete UpdateHeader::default_instance_;
555 delete UpdateHeader_reflection_;
556 delete UpdateData::default_instance_;
557 delete UpdateData_reflection_;
558 delete DeleteRecord::default_instance_;
559 delete DeleteRecord_reflection_;
560 delete DeleteHeader::default_instance_;
561 delete DeleteHeader_reflection_;
562 delete DeleteData::default_instance_;
563 delete DeleteData_reflection_;
564 delete TruncateTableStatement::default_instance_;
565 delete TruncateTableStatement_reflection_;
566 delete CreateSchemaStatement::default_instance_;
567 delete CreateSchemaStatement_reflection_;
568 delete AlterSchemaStatement::default_instance_;
569 delete AlterSchemaStatement_reflection_;
570 delete DropSchemaStatement::default_instance_;
571 delete DropSchemaStatement_reflection_;
572 delete CreateTableStatement::default_instance_;
573 delete CreateTableStatement_reflection_;
574 delete AlterTableStatement::default_instance_;
575 delete AlterTableStatement_reflection_;
576 delete DropTableStatement::default_instance_;
577 delete DropTableStatement_reflection_;
578 delete SetVariableStatement::default_instance_;
579 delete SetVariableStatement_reflection_;
580 delete Statement::default_instance_;
581 delete Statement_reflection_;
582 delete Transaction::default_instance_;
583 delete Transaction_reflection_;
586 void protobuf_AddDesc_transaction_2eproto() {
587 static bool already_here =
false;
588 if (already_here)
return;
590 GOOGLE_PROTOBUF_VERIFY_VERSION;
592 ::drizzled::message::protobuf_AddDesc_table_2eproto();
593 ::drizzled::message::protobuf_AddDesc_schema_2eproto();
594 ::drizzled::message::protobuf_AddDesc_event_2eproto();
595 ::google::protobuf::DescriptorPool::InternalAddGeneratedFile(
596 "\n\021transaction.proto\022\020drizzled.message\032\013t"
597 "able.proto\032\014schema.proto\032\013event.proto\"T\n"
598 "\rFieldMetadata\0225\n\004type\030\001 \002(\0162\'.drizzled."
599 "message.Table.Field.FieldType\022\014\n\004name\030\002 "
600 "\002(\t\"N\n\rTableMetadata\022\023\n\013schema_name\030\001 \002("
601 "\t\022\022\n\ntable_name\030\002 \002(\t\022\024\n\014catalog_name\030\003 "
602 "\001(\t\"o\n\022TransactionContext\022\021\n\tserver_id\030\001"
603 " \002(\r\022\026\n\016transaction_id\030\002 \002(\004\022\027\n\017start_ti"
604 "mestamp\030\003 \002(\004\022\025\n\rend_timestamp\030\004 \002(\004\"5\n\014"
605 "InsertRecord\022\024\n\014insert_value\030\001 \003(\014\022\017\n\007is"
606 "_null\030\002 \003(\010\"\200\001\n\014InsertHeader\0227\n\016table_me"
607 "tadata\030\001 \002(\0132\037.drizzled.message.TableMet"
608 "adata\0227\n\016field_metadata\030\002 \003(\0132\037.drizzled"
609 ".message.FieldMetadata\"e\n\nInsertData\022\022\n\n"
610 "segment_id\030\001 \002(\r\022\023\n\013end_segment\030\002 \002(\010\022.\n"
611 "\006record\030\003 \003(\0132\036.drizzled.message.InsertR"
612 "ecord\"]\n\014UpdateRecord\022\021\n\tkey_value\030\001 \003(\014"
613 "\022\023\n\013after_value\030\002 \003(\014\022\024\n\014before_value\030\003 "
614 "\003(\014\022\017\n\007is_null\030\004 \003(\010\"\301\001\n\014UpdateHeader\0227\n"
615 "\016table_metadata\030\001 \002(\0132\037.drizzled.message"
616 ".TableMetadata\022;\n\022key_field_metadata\030\002 \003"
617 "(\0132\037.drizzled.message.FieldMetadata\022;\n\022s"
618 "et_field_metadata\030\003 \003(\0132\037.drizzled.messa"
619 "ge.FieldMetadata\"e\n\nUpdateData\022\022\n\nsegmen"
620 "t_id\030\001 \002(\r\022\023\n\013end_segment\030\002 \002(\010\022.\n\006recor"
621 "d\030\003 \003(\0132\036.drizzled.message.UpdateRecord\""
622 "!\n\014DeleteRecord\022\021\n\tkey_value\030\001 \003(\014\"\204\001\n\014D"
623 "eleteHeader\0227\n\016table_metadata\030\001 \002(\0132\037.dr"
624 "izzled.message.TableMetadata\022;\n\022key_fiel"
625 "d_metadata\030\002 \003(\0132\037.drizzled.message.Fiel"
626 "dMetadata\"e\n\nDeleteData\022\022\n\nsegment_id\030\001 "
627 "\002(\r\022\023\n\013end_segment\030\002 \002(\010\022.\n\006record\030\003 \003(\013"
628 "2\036.drizzled.message.DeleteRecord\"Q\n\026Trun"
629 "cateTableStatement\0227\n\016table_metadata\030\001 \002"
630 "(\0132\037.drizzled.message.TableMetadata\"A\n\025C"
631 "reateSchemaStatement\022(\n\006schema\030\001 \002(\0132\030.d"
632 "rizzled.message.Schema\"i\n\024AlterSchemaSta"
633 "tement\022(\n\006before\030\001 \002(\0132\030.drizzled.messag"
634 "e.Schema\022\'\n\005after\030\002 \002(\0132\030.drizzled.messa"
635 "ge.Schema\"@\n\023DropSchemaStatement\022\023\n\013sche"
636 "ma_name\030\001 \002(\t\022\024\n\014catalog_name\030\002 \001(\t\">\n\024C"
637 "reateTableStatement\022&\n\005table\030\001 \002(\0132\027.dri"
638 "zzled.message.Table\"f\n\023AlterTableStateme"
639 "nt\022\'\n\006before\030\001 \002(\0132\027.drizzled.message.Ta"
640 "ble\022&\n\005after\030\002 \002(\0132\027.drizzled.message.Ta"
641 "ble\"g\n\022DropTableStatement\0227\n\016table_metad"
642 "ata\030\001 \002(\0132\037.drizzled.message.TableMetada"
643 "ta\022\030\n\020if_exists_clause\030\002 \001(\010\"j\n\024SetVaria"
644 "bleStatement\022:\n\021variable_metadata\030\001 \002(\0132"
645 "\037.drizzled.message.FieldMetadata\022\026\n\016vari"
646 "able_value\030\002 \002(\014\"\373\t\n\tStatement\022.\n\004type\030\001"
647 " \002(\0162 .drizzled.message.Statement.Type\022\027"
648 "\n\017start_timestamp\030\002 \002(\004\022\025\n\rend_timestamp"
649 "\030\003 \002(\004\022\013\n\003sql\030\004 \001(\t\0225\n\rinsert_header\030\005 \001"
650 "(\0132\036.drizzled.message.InsertHeader\0221\n\013in"
651 "sert_data\030\006 \001(\0132\034.drizzled.message.Inser"
652 "tData\0225\n\rupdate_header\030\007 \001(\0132\036.drizzled."
653 "message.UpdateHeader\0221\n\013update_data\030\010 \001("
654 "\0132\034.drizzled.message.UpdateData\0225\n\rdelet"
655 "e_header\030\t \001(\0132\036.drizzled.message.Delete"
656 "Header\0221\n\013delete_data\030\n \001(\0132\034.drizzled.m"
657 "essage.DeleteData\022J\n\030truncate_table_stat"
658 "ement\030\013 \001(\0132(.drizzled.message.TruncateT"
659 "ableStatement\022H\n\027create_schema_statement"
660 "\030\014 \001(\0132\'.drizzled.message.CreateSchemaSt"
661 "atement\022D\n\025drop_schema_statement\030\r \001(\0132%"
662 ".drizzled.message.DropSchemaStatement\022F\n"
663 "\026alter_schema_statement\030\016 \001(\0132&.drizzled"
664 ".message.AlterSchemaStatement\022F\n\026create_"
665 "table_statement\030\017 \001(\0132&.drizzled.message"
666 ".CreateTableStatement\022D\n\025alter_table_sta"
667 "tement\030\020 \001(\0132%.drizzled.message.AlterTab"
668 "leStatement\022B\n\024drop_table_statement\030\021 \001("
669 "\0132$.drizzled.message.DropTableStatement\022"
670 "F\n\026set_variable_statement\030\022 \001(\0132&.drizzl"
671 "ed.message.SetVariableStatement\022\026\n\016raw_s"
672 "ql_schema\030\023 \001(\t\"\354\001\n\004Type\022\014\n\010ROLLBACK\020\000\022\n"
673 "\n\006INSERT\020\001\022\n\n\006DELETE\020\002\022\n\n\006UPDATE\020\003\022\022\n\016TR"
674 "UNCATE_TABLE\020\004\022\021\n\rCREATE_SCHEMA\020\005\022\020\n\014ALT"
675 "ER_SCHEMA\020\006\022\017\n\013DROP_SCHEMA\020\007\022\020\n\014CREATE_T"
676 "ABLE\020\010\022\017\n\013ALTER_TABLE\020\t\022\016\n\nDROP_TABLE\020\n\022"
677 "\026\n\022ROLLBACK_STATEMENT\020\013\022\020\n\014SET_VARIABLE\020"
678 "b\022\013\n\007RAW_SQL\020c\"\321\001\n\013Transaction\022A\n\023transa"
679 "ction_context\030\001 \002(\0132$.drizzled.message.T"
680 "ransactionContext\022.\n\tstatement\030\002 \003(\0132\033.d"
681 "rizzled.message.Statement\022&\n\005event\030\003 \001(\013"
682 "2\027.drizzled.message.Event\022\022\n\nsegment_id\030"
683 "\004 \001(\r\022\023\n\013end_segment\030\005 \001(\010B,\n\024org.drizzl"
684 "e.messagesB\022TransactionMessageH\001", 3552);
685 ::google::protobuf::MessageFactory::InternalRegisterGeneratedFile(
686 "transaction.proto", &protobuf_RegisterTypes);
687 FieldMetadata::default_instance_ =
new FieldMetadata();
688 TableMetadata::default_instance_ =
new TableMetadata();
689 TransactionContext::default_instance_ =
new TransactionContext();
690 InsertRecord::default_instance_ =
new InsertRecord();
691 InsertHeader::default_instance_ =
new InsertHeader();
692 InsertData::default_instance_ =
new InsertData();
693 UpdateRecord::default_instance_ =
new UpdateRecord();
694 UpdateHeader::default_instance_ =
new UpdateHeader();
695 UpdateData::default_instance_ =
new UpdateData();
696 DeleteRecord::default_instance_ =
new DeleteRecord();
697 DeleteHeader::default_instance_ =
new DeleteHeader();
698 DeleteData::default_instance_ =
new DeleteData();
699 TruncateTableStatement::default_instance_ =
new TruncateTableStatement();
700 CreateSchemaStatement::default_instance_ =
new CreateSchemaStatement();
701 AlterSchemaStatement::default_instance_ =
new AlterSchemaStatement();
702 DropSchemaStatement::default_instance_ =
new DropSchemaStatement();
703 CreateTableStatement::default_instance_ =
new CreateTableStatement();
704 AlterTableStatement::default_instance_ =
new AlterTableStatement();
705 DropTableStatement::default_instance_ =
new DropTableStatement();
706 SetVariableStatement::default_instance_ =
new SetVariableStatement();
707 Statement::default_instance_ =
new Statement();
708 Transaction::default_instance_ =
new Transaction();
709 FieldMetadata::default_instance_->InitAsDefaultInstance();
710 TableMetadata::default_instance_->InitAsDefaultInstance();
711 TransactionContext::default_instance_->InitAsDefaultInstance();
712 InsertRecord::default_instance_->InitAsDefaultInstance();
713 InsertHeader::default_instance_->InitAsDefaultInstance();
714 InsertData::default_instance_->InitAsDefaultInstance();
715 UpdateRecord::default_instance_->InitAsDefaultInstance();
716 UpdateHeader::default_instance_->InitAsDefaultInstance();
717 UpdateData::default_instance_->InitAsDefaultInstance();
718 DeleteRecord::default_instance_->InitAsDefaultInstance();
719 DeleteHeader::default_instance_->InitAsDefaultInstance();
720 DeleteData::default_instance_->InitAsDefaultInstance();
721 TruncateTableStatement::default_instance_->InitAsDefaultInstance();
722 CreateSchemaStatement::default_instance_->InitAsDefaultInstance();
723 AlterSchemaStatement::default_instance_->InitAsDefaultInstance();
724 DropSchemaStatement::default_instance_->InitAsDefaultInstance();
725 CreateTableStatement::default_instance_->InitAsDefaultInstance();
726 AlterTableStatement::default_instance_->InitAsDefaultInstance();
727 DropTableStatement::default_instance_->InitAsDefaultInstance();
728 SetVariableStatement::default_instance_->InitAsDefaultInstance();
729 Statement::default_instance_->InitAsDefaultInstance();
730 Transaction::default_instance_->InitAsDefaultInstance();
731 ::google::protobuf::internal::OnShutdown(&protobuf_ShutdownFile_transaction_2eproto);
737 protobuf_AddDesc_transaction_2eproto();
739 } static_descriptor_initializer_transaction_2eproto_;
744 const int FieldMetadata::kTypeFieldNumber;
745 const int FieldMetadata::kNameFieldNumber;
748 FieldMetadata::FieldMetadata()
749 : ::
google::protobuf::Message() {
754 void FieldMetadata::InitAsDefaultInstance() {
757 FieldMetadata::FieldMetadata(
const FieldMetadata& from)
758 : ::
google::protobuf::Message() {
764 void FieldMetadata::SharedCtor() {
765 ::google::protobuf::internal::GetEmptyString();
768 name_ =
const_cast< ::std::string*
>(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
769 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
772 FieldMetadata::~FieldMetadata() {
777 void FieldMetadata::SharedDtor() {
778 if (name_ != &::google::protobuf::internal::GetEmptyStringAlreadyInited()) {
781 if (
this != default_instance_) {
785 void FieldMetadata::SetCachedSize(
int size)
const {
786 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
787 _cached_size_ = size;
788 GOOGLE_SAFE_CONCURRENT_WRITES_END();
790 const ::google::protobuf::Descriptor* FieldMetadata::descriptor() {
791 protobuf_AssignDescriptorsOnce();
792 return FieldMetadata_descriptor_;
795 const FieldMetadata& FieldMetadata::default_instance() {
796 if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto();
797 return *default_instance_;
800 FieldMetadata* FieldMetadata::default_instance_ = NULL;
802 FieldMetadata* FieldMetadata::New()
const {
803 return new FieldMetadata;
806 void FieldMetadata::Clear() {
807 if (_has_bits_[0 / 32] & 3) {
810 if (name_ != &::google::protobuf::internal::GetEmptyStringAlreadyInited()) {
815 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
816 mutable_unknown_fields()->Clear();
819 bool FieldMetadata::MergePartialFromCodedStream(
820 ::google::protobuf::io::CodedInputStream* input) {
821 #define DO_(EXPRESSION) if (!(EXPRESSION)) goto failure
822 ::google::protobuf::uint32 tag;
825 ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoff(127);
827 if (!p.second)
goto handle_unusual;
828 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
833 DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
834 int, ::google::protobuf::internal::WireFormatLite::TYPE_ENUM>(
836 if (::drizzled::message::Table_Field_FieldType_IsValid(value)) {
837 set_type(static_cast< ::drizzled::message::Table_Field_FieldType >(value));
839 mutable_unknown_fields()->AddVarint(1, value);
844 if (input->ExpectTag(18))
goto parse_name;
852 DO_(::google::protobuf::internal::WireFormatLite::ReadString(
853 input, this->mutable_name()));
854 ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField(
855 this->name().data(), this->name().length(),
856 ::google::protobuf::internal::WireFormat::PARSE,
861 if (input->ExpectAtEnd())
goto success;
868 ::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
869 ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
872 DO_(::google::protobuf::internal::WireFormat::SkipField(
873 input, tag, mutable_unknown_fields()));
887 void FieldMetadata::SerializeWithCachedSizes(
888 ::google::protobuf::io::CodedOutputStream* output)
const {
892 ::google::protobuf::internal::WireFormatLite::WriteEnum(
893 1, this->type(), output);
898 ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField(
899 this->name().data(), this->name().length(),
900 ::google::protobuf::internal::WireFormat::SERIALIZE,
902 ::google::protobuf::internal::WireFormatLite::WriteStringMaybeAliased(
903 2, this->name(), output);
906 if (!unknown_fields().empty()) {
907 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
908 unknown_fields(), output);
913 ::google::protobuf::uint8* FieldMetadata::SerializeWithCachedSizesToArray(
914 ::google::protobuf::uint8* target)
const {
918 target = ::google::protobuf::internal::WireFormatLite::WriteEnumToArray(
919 1, this->type(), target);
924 ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField(
925 this->name().data(), this->name().length(),
926 ::google::protobuf::internal::WireFormat::SERIALIZE,
929 ::google::protobuf::internal::WireFormatLite::WriteStringToArray(
930 2, this->name(), target);
933 if (!unknown_fields().empty()) {
934 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
935 unknown_fields(), target);
941 int FieldMetadata::ByteSize()
const {
944 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
948 ::google::protobuf::internal::WireFormatLite::EnumSize(this->type());
954 ::google::protobuf::internal::WireFormatLite::StringSize(
959 if (!unknown_fields().empty()) {
961 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
964 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
965 _cached_size_ = total_size;
966 GOOGLE_SAFE_CONCURRENT_WRITES_END();
970 void FieldMetadata::MergeFrom(const ::google::protobuf::Message& from) {
971 GOOGLE_CHECK_NE(&from,
this);
972 const FieldMetadata* source =
973 ::google::protobuf::internal::dynamic_cast_if_available<const FieldMetadata*>(
975 if (source == NULL) {
976 ::google::protobuf::internal::ReflectionOps::Merge(from,
this);
982 void FieldMetadata::MergeFrom(
const FieldMetadata& from) {
983 GOOGLE_CHECK_NE(&from,
this);
984 if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
985 if (from.has_type()) {
986 set_type(from.type());
988 if (from.has_name()) {
989 set_name(from.name());
992 mutable_unknown_fields()->MergeFrom(from.unknown_fields());
995 void FieldMetadata::CopyFrom(const ::google::protobuf::Message& from) {
996 if (&from ==
this)
return;
1001 void FieldMetadata::CopyFrom(
const FieldMetadata& from) {
1002 if (&from ==
this)
return;
1007 bool FieldMetadata::IsInitialized()
const {
1008 if ((_has_bits_[0] & 0x00000003) != 0x00000003)
return false;
1013 void FieldMetadata::Swap(FieldMetadata* other) {
1014 if (other !=
this) {
1015 std::swap(type_, other->type_);
1016 std::swap(name_, other->name_);
1017 std::swap(_has_bits_[0], other->_has_bits_[0]);
1018 _unknown_fields_.Swap(&other->_unknown_fields_);
1019 std::swap(_cached_size_, other->_cached_size_);
1023 ::google::protobuf::Metadata FieldMetadata::GetMetadata()
const {
1024 protobuf_AssignDescriptorsOnce();
1025 ::google::protobuf::Metadata metadata;
1026 metadata.descriptor = FieldMetadata_descriptor_;
1027 metadata.reflection = FieldMetadata_reflection_;
1035 const int TableMetadata::kSchemaNameFieldNumber;
1036 const int TableMetadata::kTableNameFieldNumber;
1037 const int TableMetadata::kCatalogNameFieldNumber;
1040 TableMetadata::TableMetadata()
1041 : ::
google::protobuf::Message() {
1046 void TableMetadata::InitAsDefaultInstance() {
1049 TableMetadata::TableMetadata(
const TableMetadata& from)
1050 : ::
google::protobuf::Message() {
1056 void TableMetadata::SharedCtor() {
1057 ::google::protobuf::internal::GetEmptyString();
1059 schema_name_ =
const_cast< ::std::string*
>(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
1060 table_name_ =
const_cast< ::std::string*
>(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
1061 catalog_name_ =
const_cast< ::std::string*
>(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
1062 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
1065 TableMetadata::~TableMetadata() {
1070 void TableMetadata::SharedDtor() {
1071 if (schema_name_ != &::google::protobuf::internal::GetEmptyStringAlreadyInited()) {
1072 delete schema_name_;
1074 if (table_name_ != &::google::protobuf::internal::GetEmptyStringAlreadyInited()) {
1077 if (catalog_name_ != &::google::protobuf::internal::GetEmptyStringAlreadyInited()) {
1078 delete catalog_name_;
1080 if (
this != default_instance_) {
1084 void TableMetadata::SetCachedSize(
int size)
const {
1085 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
1086 _cached_size_ = size;
1087 GOOGLE_SAFE_CONCURRENT_WRITES_END();
1089 const ::google::protobuf::Descriptor* TableMetadata::descriptor() {
1090 protobuf_AssignDescriptorsOnce();
1091 return TableMetadata_descriptor_;
1094 const TableMetadata& TableMetadata::default_instance() {
1095 if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto();
1096 return *default_instance_;
1099 TableMetadata* TableMetadata::default_instance_ = NULL;
1101 TableMetadata* TableMetadata::New()
const {
1102 return new TableMetadata;
1105 void TableMetadata::Clear() {
1106 if (_has_bits_[0 / 32] & 7) {
1107 if (has_schema_name()) {
1108 if (schema_name_ != &::google::protobuf::internal::GetEmptyStringAlreadyInited()) {
1109 schema_name_->clear();
1112 if (has_table_name()) {
1113 if (table_name_ != &::google::protobuf::internal::GetEmptyStringAlreadyInited()) {
1114 table_name_->clear();
1117 if (has_catalog_name()) {
1118 if (catalog_name_ != &::google::protobuf::internal::GetEmptyStringAlreadyInited()) {
1119 catalog_name_->clear();
1123 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
1124 mutable_unknown_fields()->Clear();
1127 bool TableMetadata::MergePartialFromCodedStream(
1128 ::google::protobuf::io::CodedInputStream* input) {
1129 #define DO_(EXPRESSION) if (!(EXPRESSION)) goto failure
1130 ::google::protobuf::uint32 tag;
1133 ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoff(127);
1135 if (!p.second)
goto handle_unusual;
1136 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
1140 DO_(::google::protobuf::internal::WireFormatLite::ReadString(
1141 input, this->mutable_schema_name()));
1142 ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField(
1143 this->schema_name().data(), this->schema_name().length(),
1144 ::google::protobuf::internal::WireFormat::PARSE,
1147 goto handle_unusual;
1149 if (input->ExpectTag(18))
goto parse_table_name;
1157 DO_(::google::protobuf::internal::WireFormatLite::ReadString(
1158 input, this->mutable_table_name()));
1159 ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField(
1160 this->table_name().data(), this->table_name().length(),
1161 ::google::protobuf::internal::WireFormat::PARSE,
1164 goto handle_unusual;
1166 if (input->ExpectTag(26))
goto parse_catalog_name;
1174 DO_(::google::protobuf::internal::WireFormatLite::ReadString(
1175 input, this->mutable_catalog_name()));
1176 ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField(
1177 this->catalog_name().data(), this->catalog_name().length(),
1178 ::google::protobuf::internal::WireFormat::PARSE,
1181 goto handle_unusual;
1183 if (input->ExpectAtEnd())
goto success;
1190 ::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
1191 ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
1194 DO_(::google::protobuf::internal::WireFormat::SkipField(
1195 input, tag, mutable_unknown_fields()));
1209 void TableMetadata::SerializeWithCachedSizes(
1210 ::google::protobuf::io::CodedOutputStream* output)
const {
1213 if (has_schema_name()) {
1214 ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField(
1215 this->schema_name().data(), this->schema_name().length(),
1216 ::google::protobuf::internal::WireFormat::SERIALIZE,
1218 ::google::protobuf::internal::WireFormatLite::WriteStringMaybeAliased(
1219 1, this->schema_name(), output);
1223 if (has_table_name()) {
1224 ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField(
1225 this->table_name().data(), this->table_name().length(),
1226 ::google::protobuf::internal::WireFormat::SERIALIZE,
1228 ::google::protobuf::internal::WireFormatLite::WriteStringMaybeAliased(
1229 2, this->table_name(), output);
1233 if (has_catalog_name()) {
1234 ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField(
1235 this->catalog_name().data(), this->catalog_name().length(),
1236 ::google::protobuf::internal::WireFormat::SERIALIZE,
1238 ::google::protobuf::internal::WireFormatLite::WriteStringMaybeAliased(
1239 3, this->catalog_name(), output);
1242 if (!unknown_fields().empty()) {
1243 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
1244 unknown_fields(), output);
1249 ::google::protobuf::uint8* TableMetadata::SerializeWithCachedSizesToArray(
1250 ::google::protobuf::uint8* target)
const {
1253 if (has_schema_name()) {
1254 ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField(
1255 this->schema_name().data(), this->schema_name().length(),
1256 ::google::protobuf::internal::WireFormat::SERIALIZE,
1259 ::google::protobuf::internal::WireFormatLite::WriteStringToArray(
1260 1, this->schema_name(), target);
1264 if (has_table_name()) {
1265 ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField(
1266 this->table_name().data(), this->table_name().length(),
1267 ::google::protobuf::internal::WireFormat::SERIALIZE,
1270 ::google::protobuf::internal::WireFormatLite::WriteStringToArray(
1271 2, this->table_name(), target);
1275 if (has_catalog_name()) {
1276 ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField(
1277 this->catalog_name().data(), this->catalog_name().length(),
1278 ::google::protobuf::internal::WireFormat::SERIALIZE,
1281 ::google::protobuf::internal::WireFormatLite::WriteStringToArray(
1282 3, this->catalog_name(), target);
1285 if (!unknown_fields().empty()) {
1286 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
1287 unknown_fields(), target);
1293 int TableMetadata::ByteSize()
const {
1296 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
1298 if (has_schema_name()) {
1300 ::google::protobuf::internal::WireFormatLite::StringSize(
1301 this->schema_name());
1305 if (has_table_name()) {
1307 ::google::protobuf::internal::WireFormatLite::StringSize(
1308 this->table_name());
1312 if (has_catalog_name()) {
1314 ::google::protobuf::internal::WireFormatLite::StringSize(
1315 this->catalog_name());
1319 if (!unknown_fields().empty()) {
1321 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
1324 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
1325 _cached_size_ = total_size;
1326 GOOGLE_SAFE_CONCURRENT_WRITES_END();
1330 void TableMetadata::MergeFrom(const ::google::protobuf::Message& from) {
1331 GOOGLE_CHECK_NE(&from,
this);
1332 const TableMetadata* source =
1333 ::google::protobuf::internal::dynamic_cast_if_available<const TableMetadata*>(
1335 if (source == NULL) {
1336 ::google::protobuf::internal::ReflectionOps::Merge(from,
this);
1342 void TableMetadata::MergeFrom(
const TableMetadata& from) {
1343 GOOGLE_CHECK_NE(&from,
this);
1344 if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
1345 if (from.has_schema_name()) {
1346 set_schema_name(from.schema_name());
1348 if (from.has_table_name()) {
1349 set_table_name(from.table_name());
1351 if (from.has_catalog_name()) {
1352 set_catalog_name(from.catalog_name());
1355 mutable_unknown_fields()->MergeFrom(from.unknown_fields());
1358 void TableMetadata::CopyFrom(const ::google::protobuf::Message& from) {
1359 if (&from ==
this)
return;
1364 void TableMetadata::CopyFrom(
const TableMetadata& from) {
1365 if (&from ==
this)
return;
1370 bool TableMetadata::IsInitialized()
const {
1371 if ((_has_bits_[0] & 0x00000003) != 0x00000003)
return false;
1376 void TableMetadata::Swap(TableMetadata* other) {
1377 if (other !=
this) {
1378 std::swap(schema_name_, other->schema_name_);
1379 std::swap(table_name_, other->table_name_);
1380 std::swap(catalog_name_, other->catalog_name_);
1381 std::swap(_has_bits_[0], other->_has_bits_[0]);
1382 _unknown_fields_.Swap(&other->_unknown_fields_);
1383 std::swap(_cached_size_, other->_cached_size_);
1387 ::google::protobuf::Metadata TableMetadata::GetMetadata()
const {
1388 protobuf_AssignDescriptorsOnce();
1389 ::google::protobuf::Metadata metadata;
1390 metadata.descriptor = TableMetadata_descriptor_;
1391 metadata.reflection = TableMetadata_reflection_;
1399 const int TransactionContext::kServerIdFieldNumber;
1400 const int TransactionContext::kTransactionIdFieldNumber;
1401 const int TransactionContext::kStartTimestampFieldNumber;
1402 const int TransactionContext::kEndTimestampFieldNumber;
1405 TransactionContext::TransactionContext()
1406 : ::
google::protobuf::Message() {
1411 void TransactionContext::InitAsDefaultInstance() {
1414 TransactionContext::TransactionContext(
const TransactionContext& from)
1415 : ::
google::protobuf::Message() {
1421 void TransactionContext::SharedCtor() {
1424 transaction_id_ = GOOGLE_ULONGLONG(0);
1425 start_timestamp_ = GOOGLE_ULONGLONG(0);
1426 end_timestamp_ = GOOGLE_ULONGLONG(0);
1427 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
1430 TransactionContext::~TransactionContext() {
1435 void TransactionContext::SharedDtor() {
1436 if (
this != default_instance_) {
1440 void TransactionContext::SetCachedSize(
int size)
const {
1441 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
1442 _cached_size_ = size;
1443 GOOGLE_SAFE_CONCURRENT_WRITES_END();
1445 const ::google::protobuf::Descriptor* TransactionContext::descriptor() {
1446 protobuf_AssignDescriptorsOnce();
1447 return TransactionContext_descriptor_;
1450 const TransactionContext& TransactionContext::default_instance() {
1451 if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto();
1452 return *default_instance_;
1455 TransactionContext* TransactionContext::default_instance_ = NULL;
1457 TransactionContext* TransactionContext::New()
const {
1458 return new TransactionContext;
1461 void TransactionContext::Clear() {
1462 #define OFFSET_OF_FIELD_(f) (reinterpret_cast<char*>( \
1463 &reinterpret_cast<TransactionContext*>(16)->f) - \
1464 reinterpret_cast<char*>(16))
1466 #define ZR_(first, last) do { \
1467 size_t f = OFFSET_OF_FIELD_(first); \
1468 size_t n = OFFSET_OF_FIELD_(last) - f + sizeof(last); \
1469 ::memset(&first, 0, n); \
1472 ZR_(transaction_id_, server_id_);
1474 #undef OFFSET_OF_FIELD_
1477 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
1478 mutable_unknown_fields()->Clear();
1481 bool TransactionContext::MergePartialFromCodedStream(
1482 ::google::protobuf::io::CodedInputStream* input) {
1483 #define DO_(EXPRESSION) if (!(EXPRESSION)) goto failure
1484 ::google::protobuf::uint32 tag;
1487 ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoff(127);
1489 if (!p.second)
goto handle_unusual;
1490 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
1494 DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
1495 ::google::protobuf::uint32, ::google::protobuf::internal::WireFormatLite::TYPE_UINT32>(
1496 input, &server_id_)));
1497 set_has_server_id();
1499 goto handle_unusual;
1501 if (input->ExpectTag(16))
goto parse_transaction_id;
1508 parse_transaction_id:
1509 DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
1510 ::google::protobuf::uint64, ::google::protobuf::internal::WireFormatLite::TYPE_UINT64>(
1511 input, &transaction_id_)));
1512 set_has_transaction_id();
1514 goto handle_unusual;
1516 if (input->ExpectTag(24))
goto parse_start_timestamp;
1523 parse_start_timestamp:
1524 DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
1525 ::google::protobuf::uint64, ::google::protobuf::internal::WireFormatLite::TYPE_UINT64>(
1526 input, &start_timestamp_)));
1527 set_has_start_timestamp();
1529 goto handle_unusual;
1531 if (input->ExpectTag(32))
goto parse_end_timestamp;
1538 parse_end_timestamp:
1539 DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
1540 ::google::protobuf::uint64, ::google::protobuf::internal::WireFormatLite::TYPE_UINT64>(
1541 input, &end_timestamp_)));
1542 set_has_end_timestamp();
1544 goto handle_unusual;
1546 if (input->ExpectAtEnd())
goto success;
1553 ::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
1554 ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
1557 DO_(::google::protobuf::internal::WireFormat::SkipField(
1558 input, tag, mutable_unknown_fields()));
1572 void TransactionContext::SerializeWithCachedSizes(
1573 ::google::protobuf::io::CodedOutputStream* output)
const {
1576 if (has_server_id()) {
1577 ::google::protobuf::internal::WireFormatLite::WriteUInt32(1, this->server_id(), output);
1581 if (has_transaction_id()) {
1582 ::google::protobuf::internal::WireFormatLite::WriteUInt64(2, this->transaction_id(), output);
1586 if (has_start_timestamp()) {
1587 ::google::protobuf::internal::WireFormatLite::WriteUInt64(3, this->start_timestamp(), output);
1591 if (has_end_timestamp()) {
1592 ::google::protobuf::internal::WireFormatLite::WriteUInt64(4, this->end_timestamp(), output);
1595 if (!unknown_fields().empty()) {
1596 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
1597 unknown_fields(), output);
1602 ::google::protobuf::uint8* TransactionContext::SerializeWithCachedSizesToArray(
1603 ::google::protobuf::uint8* target)
const {
1606 if (has_server_id()) {
1607 target = ::google::protobuf::internal::WireFormatLite::WriteUInt32ToArray(1, this->server_id(), target);
1611 if (has_transaction_id()) {
1612 target = ::google::protobuf::internal::WireFormatLite::WriteUInt64ToArray(2, this->transaction_id(), target);
1616 if (has_start_timestamp()) {
1617 target = ::google::protobuf::internal::WireFormatLite::WriteUInt64ToArray(3, this->start_timestamp(), target);
1621 if (has_end_timestamp()) {
1622 target = ::google::protobuf::internal::WireFormatLite::WriteUInt64ToArray(4, this->end_timestamp(), target);
1625 if (!unknown_fields().empty()) {
1626 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
1627 unknown_fields(), target);
1633 int TransactionContext::ByteSize()
const {
1636 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
1638 if (has_server_id()) {
1640 ::google::protobuf::internal::WireFormatLite::UInt32Size(
1645 if (has_transaction_id()) {
1647 ::google::protobuf::internal::WireFormatLite::UInt64Size(
1648 this->transaction_id());
1652 if (has_start_timestamp()) {
1654 ::google::protobuf::internal::WireFormatLite::UInt64Size(
1655 this->start_timestamp());
1659 if (has_end_timestamp()) {
1661 ::google::protobuf::internal::WireFormatLite::UInt64Size(
1662 this->end_timestamp());
1666 if (!unknown_fields().empty()) {
1668 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
1671 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
1672 _cached_size_ = total_size;
1673 GOOGLE_SAFE_CONCURRENT_WRITES_END();
1677 void TransactionContext::MergeFrom(const ::google::protobuf::Message& from) {
1678 GOOGLE_CHECK_NE(&from,
this);
1679 const TransactionContext* source =
1680 ::google::protobuf::internal::dynamic_cast_if_available<const TransactionContext*>(
1682 if (source == NULL) {
1683 ::google::protobuf::internal::ReflectionOps::Merge(from,
this);
1689 void TransactionContext::MergeFrom(
const TransactionContext& from) {
1690 GOOGLE_CHECK_NE(&from,
this);
1691 if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
1692 if (from.has_server_id()) {
1693 set_server_id(from.server_id());
1695 if (from.has_transaction_id()) {
1696 set_transaction_id(from.transaction_id());
1698 if (from.has_start_timestamp()) {
1699 set_start_timestamp(from.start_timestamp());
1701 if (from.has_end_timestamp()) {
1702 set_end_timestamp(from.end_timestamp());
1705 mutable_unknown_fields()->MergeFrom(from.unknown_fields());
1708 void TransactionContext::CopyFrom(const ::google::protobuf::Message& from) {
1709 if (&from ==
this)
return;
1714 void TransactionContext::CopyFrom(
const TransactionContext& from) {
1715 if (&from ==
this)
return;
1720 bool TransactionContext::IsInitialized()
const {
1721 if ((_has_bits_[0] & 0x0000000f) != 0x0000000f)
return false;
1726 void TransactionContext::Swap(TransactionContext* other) {
1727 if (other !=
this) {
1728 std::swap(server_id_, other->server_id_);
1729 std::swap(transaction_id_, other->transaction_id_);
1730 std::swap(start_timestamp_, other->start_timestamp_);
1731 std::swap(end_timestamp_, other->end_timestamp_);
1732 std::swap(_has_bits_[0], other->_has_bits_[0]);
1733 _unknown_fields_.Swap(&other->_unknown_fields_);
1734 std::swap(_cached_size_, other->_cached_size_);
1738 ::google::protobuf::Metadata TransactionContext::GetMetadata()
const {
1739 protobuf_AssignDescriptorsOnce();
1740 ::google::protobuf::Metadata metadata;
1741 metadata.descriptor = TransactionContext_descriptor_;
1742 metadata.reflection = TransactionContext_reflection_;
1750 const int InsertRecord::kInsertValueFieldNumber;
1751 const int InsertRecord::kIsNullFieldNumber;
1754 InsertRecord::InsertRecord()
1755 : ::
google::protobuf::Message() {
1760 void InsertRecord::InitAsDefaultInstance() {
1763 InsertRecord::InsertRecord(
const InsertRecord& from)
1764 : ::
google::protobuf::Message() {
1770 void InsertRecord::SharedCtor() {
1771 ::google::protobuf::internal::GetEmptyString();
1773 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
1776 InsertRecord::~InsertRecord() {
1781 void InsertRecord::SharedDtor() {
1782 if (
this != default_instance_) {
1786 void InsertRecord::SetCachedSize(
int size)
const {
1787 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
1788 _cached_size_ = size;
1789 GOOGLE_SAFE_CONCURRENT_WRITES_END();
1791 const ::google::protobuf::Descriptor* InsertRecord::descriptor() {
1792 protobuf_AssignDescriptorsOnce();
1793 return InsertRecord_descriptor_;
1796 const InsertRecord& InsertRecord::default_instance() {
1797 if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto();
1798 return *default_instance_;
1801 InsertRecord* InsertRecord::default_instance_ = NULL;
1803 InsertRecord* InsertRecord::New()
const {
1804 return new InsertRecord;
1807 void InsertRecord::Clear() {
1808 insert_value_.Clear();
1810 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
1811 mutable_unknown_fields()->Clear();
1814 bool InsertRecord::MergePartialFromCodedStream(
1815 ::google::protobuf::io::CodedInputStream* input) {
1816 #define DO_(EXPRESSION) if (!(EXPRESSION)) goto failure
1817 ::google::protobuf::uint32 tag;
1820 ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoff(127);
1822 if (!p.second)
goto handle_unusual;
1823 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
1828 DO_(::google::protobuf::internal::WireFormatLite::ReadBytes(
1829 input, this->add_insert_value()));
1831 goto handle_unusual;
1833 if (input->ExpectTag(10))
goto parse_insert_value;
1834 if (input->ExpectTag(16))
goto parse_is_null;
1842 DO_((::google::protobuf::internal::WireFormatLite::ReadRepeatedPrimitive<
1843 bool, ::google::protobuf::internal::WireFormatLite::TYPE_BOOL>(
1844 1, 16, input, this->mutable_is_null())));
1845 }
else if (tag == 18) {
1846 DO_((::google::protobuf::internal::WireFormatLite::ReadPackedPrimitiveNoInline<
1847 bool, ::google::protobuf::internal::WireFormatLite::TYPE_BOOL>(
1848 input, this->mutable_is_null())));
1850 goto handle_unusual;
1852 if (input->ExpectTag(16))
goto parse_is_null;
1853 if (input->ExpectAtEnd())
goto success;
1860 ::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
1861 ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
1864 DO_(::google::protobuf::internal::WireFormat::SkipField(
1865 input, tag, mutable_unknown_fields()));
1879 void InsertRecord::SerializeWithCachedSizes(
1880 ::google::protobuf::io::CodedOutputStream* output)
const {
1883 for (
int i = 0; i < this->insert_value_size(); i++) {
1884 ::google::protobuf::internal::WireFormatLite::WriteBytes(
1885 1, this->insert_value(i), output);
1889 for (
int i = 0; i < this->is_null_size(); i++) {
1890 ::google::protobuf::internal::WireFormatLite::WriteBool(
1891 2, this->is_null(i), output);
1894 if (!unknown_fields().empty()) {
1895 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
1896 unknown_fields(), output);
1901 ::google::protobuf::uint8* InsertRecord::SerializeWithCachedSizesToArray(
1902 ::google::protobuf::uint8* target)
const {
1905 for (
int i = 0; i < this->insert_value_size(); i++) {
1906 target = ::google::protobuf::internal::WireFormatLite::
1907 WriteBytesToArray(1, this->insert_value(i), target);
1911 for (
int i = 0; i < this->is_null_size(); i++) {
1912 target = ::google::protobuf::internal::WireFormatLite::
1913 WriteBoolToArray(2, this->is_null(i), target);
1916 if (!unknown_fields().empty()) {
1917 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
1918 unknown_fields(), target);
1924 int InsertRecord::ByteSize()
const {
1928 total_size += 1 * this->insert_value_size();
1929 for (
int i = 0; i < this->insert_value_size(); i++) {
1930 total_size += ::google::protobuf::internal::WireFormatLite::BytesSize(
1931 this->insert_value(i));
1937 data_size = 1 * this->is_null_size();
1938 total_size += 1 * this->is_null_size() + data_size;
1941 if (!unknown_fields().empty()) {
1943 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
1946 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
1947 _cached_size_ = total_size;
1948 GOOGLE_SAFE_CONCURRENT_WRITES_END();
1952 void InsertRecord::MergeFrom(const ::google::protobuf::Message& from) {
1953 GOOGLE_CHECK_NE(&from,
this);
1954 const InsertRecord* source =
1955 ::google::protobuf::internal::dynamic_cast_if_available<const InsertRecord*>(
1957 if (source == NULL) {
1958 ::google::protobuf::internal::ReflectionOps::Merge(from,
this);
1964 void InsertRecord::MergeFrom(
const InsertRecord& from) {
1965 GOOGLE_CHECK_NE(&from,
this);
1966 insert_value_.MergeFrom(from.insert_value_);
1967 is_null_.MergeFrom(from.is_null_);
1968 mutable_unknown_fields()->MergeFrom(from.unknown_fields());
1971 void InsertRecord::CopyFrom(const ::google::protobuf::Message& from) {
1972 if (&from ==
this)
return;
1977 void InsertRecord::CopyFrom(
const InsertRecord& from) {
1978 if (&from ==
this)
return;
1983 bool InsertRecord::IsInitialized()
const {
1988 void InsertRecord::Swap(InsertRecord* other) {
1989 if (other !=
this) {
1990 insert_value_.Swap(&other->insert_value_);
1991 is_null_.Swap(&other->is_null_);
1992 std::swap(_has_bits_[0], other->_has_bits_[0]);
1993 _unknown_fields_.Swap(&other->_unknown_fields_);
1994 std::swap(_cached_size_, other->_cached_size_);
1998 ::google::protobuf::Metadata InsertRecord::GetMetadata()
const {
1999 protobuf_AssignDescriptorsOnce();
2000 ::google::protobuf::Metadata metadata;
2001 metadata.descriptor = InsertRecord_descriptor_;
2002 metadata.reflection = InsertRecord_reflection_;
2010 const int InsertHeader::kTableMetadataFieldNumber;
2011 const int InsertHeader::kFieldMetadataFieldNumber;
2014 InsertHeader::InsertHeader()
2015 : ::
google::protobuf::Message() {
2020 void InsertHeader::InitAsDefaultInstance() {
2024 InsertHeader::InsertHeader(
const InsertHeader& from)
2025 : ::
google::protobuf::Message() {
2031 void InsertHeader::SharedCtor() {
2033 table_metadata_ = NULL;
2034 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
2037 InsertHeader::~InsertHeader() {
2042 void InsertHeader::SharedDtor() {
2043 if (
this != default_instance_) {
2044 delete table_metadata_;
2048 void InsertHeader::SetCachedSize(
int size)
const {
2049 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
2050 _cached_size_ = size;
2051 GOOGLE_SAFE_CONCURRENT_WRITES_END();
2053 const ::google::protobuf::Descriptor* InsertHeader::descriptor() {
2054 protobuf_AssignDescriptorsOnce();
2055 return InsertHeader_descriptor_;
2058 const InsertHeader& InsertHeader::default_instance() {
2059 if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto();
2060 return *default_instance_;
2063 InsertHeader* InsertHeader::default_instance_ = NULL;
2065 InsertHeader* InsertHeader::New()
const {
2066 return new InsertHeader;
2069 void InsertHeader::Clear() {
2070 if (has_table_metadata()) {
2071 if (table_metadata_ != NULL) table_metadata_->::drizzled::message::TableMetadata::Clear();
2073 field_metadata_.Clear();
2074 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
2075 mutable_unknown_fields()->Clear();
2078 bool InsertHeader::MergePartialFromCodedStream(
2079 ::google::protobuf::io::CodedInputStream* input) {
2080 #define DO_(EXPRESSION) if (!(EXPRESSION)) goto failure
2081 ::google::protobuf::uint32 tag;
2084 ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoff(127);
2086 if (!p.second)
goto handle_unusual;
2087 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
2091 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
2092 input, mutable_table_metadata()));
2094 goto handle_unusual;
2096 if (input->ExpectTag(18))
goto parse_field_metadata;
2103 parse_field_metadata:
2104 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
2105 input, add_field_metadata()));
2107 goto handle_unusual;
2109 if (input->ExpectTag(18))
goto parse_field_metadata;
2110 if (input->ExpectAtEnd())
goto success;
2117 ::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
2118 ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
2121 DO_(::google::protobuf::internal::WireFormat::SkipField(
2122 input, tag, mutable_unknown_fields()));
2136 void InsertHeader::SerializeWithCachedSizes(
2137 ::google::protobuf::io::CodedOutputStream* output)
const {
2140 if (has_table_metadata()) {
2141 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
2142 1, this->table_metadata(), output);
2146 for (
int i = 0; i < this->field_metadata_size(); i++) {
2147 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
2148 2, this->field_metadata(i), output);
2151 if (!unknown_fields().empty()) {
2152 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
2153 unknown_fields(), output);
2158 ::google::protobuf::uint8* InsertHeader::SerializeWithCachedSizesToArray(
2159 ::google::protobuf::uint8* target)
const {
2162 if (has_table_metadata()) {
2163 target = ::google::protobuf::internal::WireFormatLite::
2164 WriteMessageNoVirtualToArray(
2165 1, this->table_metadata(), target);
2169 for (
int i = 0; i < this->field_metadata_size(); i++) {
2170 target = ::google::protobuf::internal::WireFormatLite::
2171 WriteMessageNoVirtualToArray(
2172 2, this->field_metadata(i), target);
2175 if (!unknown_fields().empty()) {
2176 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
2177 unknown_fields(), target);
2183 int InsertHeader::ByteSize()
const {
2186 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
2188 if (has_table_metadata()) {
2190 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
2191 this->table_metadata());
2196 total_size += 1 * this->field_metadata_size();
2197 for (
int i = 0; i < this->field_metadata_size(); i++) {
2199 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
2200 this->field_metadata(i));
2203 if (!unknown_fields().empty()) {
2205 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
2208 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
2209 _cached_size_ = total_size;
2210 GOOGLE_SAFE_CONCURRENT_WRITES_END();
2214 void InsertHeader::MergeFrom(const ::google::protobuf::Message& from) {
2215 GOOGLE_CHECK_NE(&from,
this);
2216 const InsertHeader* source =
2217 ::google::protobuf::internal::dynamic_cast_if_available<const InsertHeader*>(
2219 if (source == NULL) {
2220 ::google::protobuf::internal::ReflectionOps::Merge(from,
this);
2226 void InsertHeader::MergeFrom(
const InsertHeader& from) {
2227 GOOGLE_CHECK_NE(&from,
this);
2228 field_metadata_.MergeFrom(from.field_metadata_);
2229 if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
2230 if (from.has_table_metadata()) {
2231 mutable_table_metadata()->::drizzled::message::TableMetadata::MergeFrom(from.table_metadata());
2234 mutable_unknown_fields()->MergeFrom(from.unknown_fields());
2237 void InsertHeader::CopyFrom(const ::google::protobuf::Message& from) {
2238 if (&from ==
this)
return;
2243 void InsertHeader::CopyFrom(
const InsertHeader& from) {
2244 if (&from ==
this)
return;
2249 bool InsertHeader::IsInitialized()
const {
2250 if ((_has_bits_[0] & 0x00000001) != 0x00000001)
return false;
2252 if (has_table_metadata()) {
2253 if (!this->table_metadata().IsInitialized())
return false;
2255 if (!::google::protobuf::internal::AllAreInitialized(this->field_metadata()))
return false;
2259 void InsertHeader::Swap(InsertHeader* other) {
2260 if (other !=
this) {
2261 std::swap(table_metadata_, other->table_metadata_);
2262 field_metadata_.Swap(&other->field_metadata_);
2263 std::swap(_has_bits_[0], other->_has_bits_[0]);
2264 _unknown_fields_.Swap(&other->_unknown_fields_);
2265 std::swap(_cached_size_, other->_cached_size_);
2269 ::google::protobuf::Metadata InsertHeader::GetMetadata()
const {
2270 protobuf_AssignDescriptorsOnce();
2271 ::google::protobuf::Metadata metadata;
2272 metadata.descriptor = InsertHeader_descriptor_;
2273 metadata.reflection = InsertHeader_reflection_;
2281 const int InsertData::kSegmentIdFieldNumber;
2282 const int InsertData::kEndSegmentFieldNumber;
2283 const int InsertData::kRecordFieldNumber;
2286 InsertData::InsertData()
2287 : ::
google::protobuf::Message() {
2292 void InsertData::InitAsDefaultInstance() {
2295 InsertData::InsertData(
const InsertData& from)
2296 : ::
google::protobuf::Message() {
2302 void InsertData::SharedCtor() {
2305 end_segment_ =
false;
2306 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
2309 InsertData::~InsertData() {
2314 void InsertData::SharedDtor() {
2315 if (
this != default_instance_) {
2319 void InsertData::SetCachedSize(
int size)
const {
2320 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
2321 _cached_size_ = size;
2322 GOOGLE_SAFE_CONCURRENT_WRITES_END();
2324 const ::google::protobuf::Descriptor* InsertData::descriptor() {
2325 protobuf_AssignDescriptorsOnce();
2326 return InsertData_descriptor_;
2329 const InsertData& InsertData::default_instance() {
2330 if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto();
2331 return *default_instance_;
2334 InsertData* InsertData::default_instance_ = NULL;
2336 InsertData* InsertData::New()
const {
2337 return new InsertData;
2340 void InsertData::Clear() {
2341 #define OFFSET_OF_FIELD_(f) (reinterpret_cast<char*>( \
2342 &reinterpret_cast<InsertData*>(16)->f) - \
2343 reinterpret_cast<char*>(16))
2345 #define ZR_(first, last) do { \
2346 size_t f = OFFSET_OF_FIELD_(first); \
2347 size_t n = OFFSET_OF_FIELD_(last) - f + sizeof(last); \
2348 ::memset(&first, 0, n); \
2351 ZR_(segment_id_, end_segment_);
2353 #undef OFFSET_OF_FIELD_
2357 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
2358 mutable_unknown_fields()->Clear();
2361 bool InsertData::MergePartialFromCodedStream(
2362 ::google::protobuf::io::CodedInputStream* input) {
2363 #define DO_(EXPRESSION) if (!(EXPRESSION)) goto failure
2364 ::google::protobuf::uint32 tag;
2367 ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoff(127);
2369 if (!p.second)
goto handle_unusual;
2370 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
2374 DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
2375 ::google::protobuf::uint32, ::google::protobuf::internal::WireFormatLite::TYPE_UINT32>(
2376 input, &segment_id_)));
2377 set_has_segment_id();
2379 goto handle_unusual;
2381 if (input->ExpectTag(16))
goto parse_end_segment;
2389 DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
2390 bool, ::google::protobuf::internal::WireFormatLite::TYPE_BOOL>(
2391 input, &end_segment_)));
2392 set_has_end_segment();
2394 goto handle_unusual;
2396 if (input->ExpectTag(26))
goto parse_record;
2404 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
2405 input, add_record()));
2407 goto handle_unusual;
2409 if (input->ExpectTag(26))
goto parse_record;
2410 if (input->ExpectAtEnd())
goto success;
2417 ::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
2418 ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
2421 DO_(::google::protobuf::internal::WireFormat::SkipField(
2422 input, tag, mutable_unknown_fields()));
2436 void InsertData::SerializeWithCachedSizes(
2437 ::google::protobuf::io::CodedOutputStream* output)
const {
2440 if (has_segment_id()) {
2441 ::google::protobuf::internal::WireFormatLite::WriteUInt32(1, this->segment_id(), output);
2445 if (has_end_segment()) {
2446 ::google::protobuf::internal::WireFormatLite::WriteBool(2, this->end_segment(), output);
2450 for (
int i = 0; i < this->record_size(); i++) {
2451 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
2452 3, this->record(i), output);
2455 if (!unknown_fields().empty()) {
2456 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
2457 unknown_fields(), output);
2462 ::google::protobuf::uint8* InsertData::SerializeWithCachedSizesToArray(
2463 ::google::protobuf::uint8* target)
const {
2466 if (has_segment_id()) {
2467 target = ::google::protobuf::internal::WireFormatLite::WriteUInt32ToArray(1, this->segment_id(), target);
2471 if (has_end_segment()) {
2472 target = ::google::protobuf::internal::WireFormatLite::WriteBoolToArray(2, this->end_segment(), target);
2476 for (
int i = 0; i < this->record_size(); i++) {
2477 target = ::google::protobuf::internal::WireFormatLite::
2478 WriteMessageNoVirtualToArray(
2479 3, this->record(i), target);
2482 if (!unknown_fields().empty()) {
2483 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
2484 unknown_fields(), target);
2490 int InsertData::ByteSize()
const {
2493 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
2495 if (has_segment_id()) {
2497 ::google::protobuf::internal::WireFormatLite::UInt32Size(
2498 this->segment_id());
2502 if (has_end_segment()) {
2503 total_size += 1 + 1;
2508 total_size += 1 * this->record_size();
2509 for (
int i = 0; i < this->record_size(); i++) {
2511 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
2515 if (!unknown_fields().empty()) {
2517 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
2520 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
2521 _cached_size_ = total_size;
2522 GOOGLE_SAFE_CONCURRENT_WRITES_END();
2526 void InsertData::MergeFrom(const ::google::protobuf::Message& from) {
2527 GOOGLE_CHECK_NE(&from,
this);
2528 const InsertData* source =
2529 ::google::protobuf::internal::dynamic_cast_if_available<const InsertData*>(
2531 if (source == NULL) {
2532 ::google::protobuf::internal::ReflectionOps::Merge(from,
this);
2538 void InsertData::MergeFrom(
const InsertData& from) {
2539 GOOGLE_CHECK_NE(&from,
this);
2540 record_.MergeFrom(from.record_);
2541 if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
2542 if (from.has_segment_id()) {
2543 set_segment_id(from.segment_id());
2545 if (from.has_end_segment()) {
2546 set_end_segment(from.end_segment());
2549 mutable_unknown_fields()->MergeFrom(from.unknown_fields());
2552 void InsertData::CopyFrom(const ::google::protobuf::Message& from) {
2553 if (&from ==
this)
return;
2558 void InsertData::CopyFrom(
const InsertData& from) {
2559 if (&from ==
this)
return;
2564 bool InsertData::IsInitialized()
const {
2565 if ((_has_bits_[0] & 0x00000003) != 0x00000003)
return false;
2570 void InsertData::Swap(InsertData* other) {
2571 if (other !=
this) {
2572 std::swap(segment_id_, other->segment_id_);
2573 std::swap(end_segment_, other->end_segment_);
2574 record_.Swap(&other->record_);
2575 std::swap(_has_bits_[0], other->_has_bits_[0]);
2576 _unknown_fields_.Swap(&other->_unknown_fields_);
2577 std::swap(_cached_size_, other->_cached_size_);
2581 ::google::protobuf::Metadata InsertData::GetMetadata()
const {
2582 protobuf_AssignDescriptorsOnce();
2583 ::google::protobuf::Metadata metadata;
2584 metadata.descriptor = InsertData_descriptor_;
2585 metadata.reflection = InsertData_reflection_;
2593 const int UpdateRecord::kKeyValueFieldNumber;
2594 const int UpdateRecord::kAfterValueFieldNumber;
2595 const int UpdateRecord::kBeforeValueFieldNumber;
2596 const int UpdateRecord::kIsNullFieldNumber;
2599 UpdateRecord::UpdateRecord()
2600 : ::
google::protobuf::Message() {
2605 void UpdateRecord::InitAsDefaultInstance() {
2608 UpdateRecord::UpdateRecord(
const UpdateRecord& from)
2609 : ::
google::protobuf::Message() {
2615 void UpdateRecord::SharedCtor() {
2616 ::google::protobuf::internal::GetEmptyString();
2618 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
2621 UpdateRecord::~UpdateRecord() {
2626 void UpdateRecord::SharedDtor() {
2627 if (
this != default_instance_) {
2631 void UpdateRecord::SetCachedSize(
int size)
const {
2632 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
2633 _cached_size_ = size;
2634 GOOGLE_SAFE_CONCURRENT_WRITES_END();
2636 const ::google::protobuf::Descriptor* UpdateRecord::descriptor() {
2637 protobuf_AssignDescriptorsOnce();
2638 return UpdateRecord_descriptor_;
2641 const UpdateRecord& UpdateRecord::default_instance() {
2642 if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto();
2643 return *default_instance_;
2646 UpdateRecord* UpdateRecord::default_instance_ = NULL;
2648 UpdateRecord* UpdateRecord::New()
const {
2649 return new UpdateRecord;
2652 void UpdateRecord::Clear() {
2654 after_value_.Clear();
2655 before_value_.Clear();
2657 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
2658 mutable_unknown_fields()->Clear();
2661 bool UpdateRecord::MergePartialFromCodedStream(
2662 ::google::protobuf::io::CodedInputStream* input) {
2663 #define DO_(EXPRESSION) if (!(EXPRESSION)) goto failure
2664 ::google::protobuf::uint32 tag;
2667 ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoff(127);
2669 if (!p.second)
goto handle_unusual;
2670 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
2675 DO_(::google::protobuf::internal::WireFormatLite::ReadBytes(
2676 input, this->add_key_value()));
2678 goto handle_unusual;
2680 if (input->ExpectTag(10))
goto parse_key_value;
2681 if (input->ExpectTag(18))
goto parse_after_value;
2689 DO_(::google::protobuf::internal::WireFormatLite::ReadBytes(
2690 input, this->add_after_value()));
2692 goto handle_unusual;
2694 if (input->ExpectTag(18))
goto parse_after_value;
2695 if (input->ExpectTag(26))
goto parse_before_value;
2703 DO_(::google::protobuf::internal::WireFormatLite::ReadBytes(
2704 input, this->add_before_value()));
2706 goto handle_unusual;
2708 if (input->ExpectTag(26))
goto parse_before_value;
2709 if (input->ExpectTag(32))
goto parse_is_null;
2717 DO_((::google::protobuf::internal::WireFormatLite::ReadRepeatedPrimitive<
2718 bool, ::google::protobuf::internal::WireFormatLite::TYPE_BOOL>(
2719 1, 32, input, this->mutable_is_null())));
2720 }
else if (tag == 34) {
2721 DO_((::google::protobuf::internal::WireFormatLite::ReadPackedPrimitiveNoInline<
2722 bool, ::google::protobuf::internal::WireFormatLite::TYPE_BOOL>(
2723 input, this->mutable_is_null())));
2725 goto handle_unusual;
2727 if (input->ExpectTag(32))
goto parse_is_null;
2728 if (input->ExpectAtEnd())
goto success;
2735 ::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
2736 ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
2739 DO_(::google::protobuf::internal::WireFormat::SkipField(
2740 input, tag, mutable_unknown_fields()));
2754 void UpdateRecord::SerializeWithCachedSizes(
2755 ::google::protobuf::io::CodedOutputStream* output)
const {
2758 for (
int i = 0; i < this->key_value_size(); i++) {
2759 ::google::protobuf::internal::WireFormatLite::WriteBytes(
2760 1, this->key_value(i), output);
2764 for (
int i = 0; i < this->after_value_size(); i++) {
2765 ::google::protobuf::internal::WireFormatLite::WriteBytes(
2766 2, this->after_value(i), output);
2770 for (
int i = 0; i < this->before_value_size(); i++) {
2771 ::google::protobuf::internal::WireFormatLite::WriteBytes(
2772 3, this->before_value(i), output);
2776 for (
int i = 0; i < this->is_null_size(); i++) {
2777 ::google::protobuf::internal::WireFormatLite::WriteBool(
2778 4, this->is_null(i), output);
2781 if (!unknown_fields().empty()) {
2782 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
2783 unknown_fields(), output);
2788 ::google::protobuf::uint8* UpdateRecord::SerializeWithCachedSizesToArray(
2789 ::google::protobuf::uint8* target)
const {
2792 for (
int i = 0; i < this->key_value_size(); i++) {
2793 target = ::google::protobuf::internal::WireFormatLite::
2794 WriteBytesToArray(1, this->key_value(i), target);
2798 for (
int i = 0; i < this->after_value_size(); i++) {
2799 target = ::google::protobuf::internal::WireFormatLite::
2800 WriteBytesToArray(2, this->after_value(i), target);
2804 for (
int i = 0; i < this->before_value_size(); i++) {
2805 target = ::google::protobuf::internal::WireFormatLite::
2806 WriteBytesToArray(3, this->before_value(i), target);
2810 for (
int i = 0; i < this->is_null_size(); i++) {
2811 target = ::google::protobuf::internal::WireFormatLite::
2812 WriteBoolToArray(4, this->is_null(i), target);
2815 if (!unknown_fields().empty()) {
2816 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
2817 unknown_fields(), target);
2823 int UpdateRecord::ByteSize()
const {
2827 total_size += 1 * this->key_value_size();
2828 for (
int i = 0; i < this->key_value_size(); i++) {
2829 total_size += ::google::protobuf::internal::WireFormatLite::BytesSize(
2830 this->key_value(i));
2834 total_size += 1 * this->after_value_size();
2835 for (
int i = 0; i < this->after_value_size(); i++) {
2836 total_size += ::google::protobuf::internal::WireFormatLite::BytesSize(
2837 this->after_value(i));
2841 total_size += 1 * this->before_value_size();
2842 for (
int i = 0; i < this->before_value_size(); i++) {
2843 total_size += ::google::protobuf::internal::WireFormatLite::BytesSize(
2844 this->before_value(i));
2850 data_size = 1 * this->is_null_size();
2851 total_size += 1 * this->is_null_size() + data_size;
2854 if (!unknown_fields().empty()) {
2856 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
2859 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
2860 _cached_size_ = total_size;
2861 GOOGLE_SAFE_CONCURRENT_WRITES_END();
2865 void UpdateRecord::MergeFrom(const ::google::protobuf::Message& from) {
2866 GOOGLE_CHECK_NE(&from,
this);
2867 const UpdateRecord* source =
2868 ::google::protobuf::internal::dynamic_cast_if_available<const UpdateRecord*>(
2870 if (source == NULL) {
2871 ::google::protobuf::internal::ReflectionOps::Merge(from,
this);
2877 void UpdateRecord::MergeFrom(
const UpdateRecord& from) {
2878 GOOGLE_CHECK_NE(&from,
this);
2879 key_value_.MergeFrom(from.key_value_);
2880 after_value_.MergeFrom(from.after_value_);
2881 before_value_.MergeFrom(from.before_value_);
2882 is_null_.MergeFrom(from.is_null_);
2883 mutable_unknown_fields()->MergeFrom(from.unknown_fields());
2886 void UpdateRecord::CopyFrom(const ::google::protobuf::Message& from) {
2887 if (&from ==
this)
return;
2892 void UpdateRecord::CopyFrom(
const UpdateRecord& from) {
2893 if (&from ==
this)
return;
2898 bool UpdateRecord::IsInitialized()
const {
2903 void UpdateRecord::Swap(UpdateRecord* other) {
2904 if (other !=
this) {
2905 key_value_.Swap(&other->key_value_);
2906 after_value_.Swap(&other->after_value_);
2907 before_value_.Swap(&other->before_value_);
2908 is_null_.Swap(&other->is_null_);
2909 std::swap(_has_bits_[0], other->_has_bits_[0]);
2910 _unknown_fields_.Swap(&other->_unknown_fields_);
2911 std::swap(_cached_size_, other->_cached_size_);
2915 ::google::protobuf::Metadata UpdateRecord::GetMetadata()
const {
2916 protobuf_AssignDescriptorsOnce();
2917 ::google::protobuf::Metadata metadata;
2918 metadata.descriptor = UpdateRecord_descriptor_;
2919 metadata.reflection = UpdateRecord_reflection_;
2927 const int UpdateHeader::kTableMetadataFieldNumber;
2928 const int UpdateHeader::kKeyFieldMetadataFieldNumber;
2929 const int UpdateHeader::kSetFieldMetadataFieldNumber;
2932 UpdateHeader::UpdateHeader()
2933 : ::
google::protobuf::Message() {
2938 void UpdateHeader::InitAsDefaultInstance() {
2942 UpdateHeader::UpdateHeader(
const UpdateHeader& from)
2943 : ::
google::protobuf::Message() {
2949 void UpdateHeader::SharedCtor() {
2951 table_metadata_ = NULL;
2952 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
2955 UpdateHeader::~UpdateHeader() {
2960 void UpdateHeader::SharedDtor() {
2961 if (
this != default_instance_) {
2962 delete table_metadata_;
2966 void UpdateHeader::SetCachedSize(
int size)
const {
2967 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
2968 _cached_size_ = size;
2969 GOOGLE_SAFE_CONCURRENT_WRITES_END();
2971 const ::google::protobuf::Descriptor* UpdateHeader::descriptor() {
2972 protobuf_AssignDescriptorsOnce();
2973 return UpdateHeader_descriptor_;
2976 const UpdateHeader& UpdateHeader::default_instance() {
2977 if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto();
2978 return *default_instance_;
2981 UpdateHeader* UpdateHeader::default_instance_ = NULL;
2983 UpdateHeader* UpdateHeader::New()
const {
2984 return new UpdateHeader;
2987 void UpdateHeader::Clear() {
2988 if (has_table_metadata()) {
2989 if (table_metadata_ != NULL) table_metadata_->::drizzled::message::TableMetadata::Clear();
2991 key_field_metadata_.Clear();
2992 set_field_metadata_.Clear();
2993 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
2994 mutable_unknown_fields()->Clear();
2997 bool UpdateHeader::MergePartialFromCodedStream(
2998 ::google::protobuf::io::CodedInputStream* input) {
2999 #define DO_(EXPRESSION) if (!(EXPRESSION)) goto failure
3000 ::google::protobuf::uint32 tag;
3003 ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoff(127);
3005 if (!p.second)
goto handle_unusual;
3006 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
3010 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
3011 input, mutable_table_metadata()));
3013 goto handle_unusual;
3015 if (input->ExpectTag(18))
goto parse_key_field_metadata;
3022 parse_key_field_metadata:
3023 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
3024 input, add_key_field_metadata()));
3026 goto handle_unusual;
3028 if (input->ExpectTag(18))
goto parse_key_field_metadata;
3029 if (input->ExpectTag(26))
goto parse_set_field_metadata;
3036 parse_set_field_metadata:
3037 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
3038 input, add_set_field_metadata()));
3040 goto handle_unusual;
3042 if (input->ExpectTag(26))
goto parse_set_field_metadata;
3043 if (input->ExpectAtEnd())
goto success;
3050 ::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
3051 ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
3054 DO_(::google::protobuf::internal::WireFormat::SkipField(
3055 input, tag, mutable_unknown_fields()));
3069 void UpdateHeader::SerializeWithCachedSizes(
3070 ::google::protobuf::io::CodedOutputStream* output)
const {
3073 if (has_table_metadata()) {
3074 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
3075 1, this->table_metadata(), output);
3079 for (
int i = 0; i < this->key_field_metadata_size(); i++) {
3080 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
3081 2, this->key_field_metadata(i), output);
3085 for (
int i = 0; i < this->set_field_metadata_size(); i++) {
3086 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
3087 3, this->set_field_metadata(i), output);
3090 if (!unknown_fields().empty()) {
3091 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
3092 unknown_fields(), output);
3097 ::google::protobuf::uint8* UpdateHeader::SerializeWithCachedSizesToArray(
3098 ::google::protobuf::uint8* target)
const {
3101 if (has_table_metadata()) {
3102 target = ::google::protobuf::internal::WireFormatLite::
3103 WriteMessageNoVirtualToArray(
3104 1, this->table_metadata(), target);
3108 for (
int i = 0; i < this->key_field_metadata_size(); i++) {
3109 target = ::google::protobuf::internal::WireFormatLite::
3110 WriteMessageNoVirtualToArray(
3111 2, this->key_field_metadata(i), target);
3115 for (
int i = 0; i < this->set_field_metadata_size(); i++) {
3116 target = ::google::protobuf::internal::WireFormatLite::
3117 WriteMessageNoVirtualToArray(
3118 3, this->set_field_metadata(i), target);
3121 if (!unknown_fields().empty()) {
3122 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
3123 unknown_fields(), target);
3129 int UpdateHeader::ByteSize()
const {
3132 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
3134 if (has_table_metadata()) {
3136 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
3137 this->table_metadata());
3142 total_size += 1 * this->key_field_metadata_size();
3143 for (
int i = 0; i < this->key_field_metadata_size(); i++) {
3145 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
3146 this->key_field_metadata(i));
3150 total_size += 1 * this->set_field_metadata_size();
3151 for (
int i = 0; i < this->set_field_metadata_size(); i++) {
3153 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
3154 this->set_field_metadata(i));
3157 if (!unknown_fields().empty()) {
3159 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
3162 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
3163 _cached_size_ = total_size;
3164 GOOGLE_SAFE_CONCURRENT_WRITES_END();
3168 void UpdateHeader::MergeFrom(const ::google::protobuf::Message& from) {
3169 GOOGLE_CHECK_NE(&from,
this);
3170 const UpdateHeader* source =
3171 ::google::protobuf::internal::dynamic_cast_if_available<const UpdateHeader*>(
3173 if (source == NULL) {
3174 ::google::protobuf::internal::ReflectionOps::Merge(from,
this);
3180 void UpdateHeader::MergeFrom(
const UpdateHeader& from) {
3181 GOOGLE_CHECK_NE(&from,
this);
3182 key_field_metadata_.MergeFrom(from.key_field_metadata_);
3183 set_field_metadata_.MergeFrom(from.set_field_metadata_);
3184 if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
3185 if (from.has_table_metadata()) {
3186 mutable_table_metadata()->::drizzled::message::TableMetadata::MergeFrom(from.table_metadata());
3189 mutable_unknown_fields()->MergeFrom(from.unknown_fields());
3192 void UpdateHeader::CopyFrom(const ::google::protobuf::Message& from) {
3193 if (&from ==
this)
return;
3198 void UpdateHeader::CopyFrom(
const UpdateHeader& from) {
3199 if (&from ==
this)
return;
3204 bool UpdateHeader::IsInitialized()
const {
3205 if ((_has_bits_[0] & 0x00000001) != 0x00000001)
return false;
3207 if (has_table_metadata()) {
3208 if (!this->table_metadata().IsInitialized())
return false;
3210 if (!::google::protobuf::internal::AllAreInitialized(this->key_field_metadata()))
return false;
3211 if (!::google::protobuf::internal::AllAreInitialized(this->set_field_metadata()))
return false;
3215 void UpdateHeader::Swap(UpdateHeader* other) {
3216 if (other !=
this) {
3217 std::swap(table_metadata_, other->table_metadata_);
3218 key_field_metadata_.Swap(&other->key_field_metadata_);
3219 set_field_metadata_.Swap(&other->set_field_metadata_);
3220 std::swap(_has_bits_[0], other->_has_bits_[0]);
3221 _unknown_fields_.Swap(&other->_unknown_fields_);
3222 std::swap(_cached_size_, other->_cached_size_);
3226 ::google::protobuf::Metadata UpdateHeader::GetMetadata()
const {
3227 protobuf_AssignDescriptorsOnce();
3228 ::google::protobuf::Metadata metadata;
3229 metadata.descriptor = UpdateHeader_descriptor_;
3230 metadata.reflection = UpdateHeader_reflection_;
3238 const int UpdateData::kSegmentIdFieldNumber;
3239 const int UpdateData::kEndSegmentFieldNumber;
3240 const int UpdateData::kRecordFieldNumber;
3243 UpdateData::UpdateData()
3244 : ::
google::protobuf::Message() {
3249 void UpdateData::InitAsDefaultInstance() {
3252 UpdateData::UpdateData(
const UpdateData& from)
3253 : ::
google::protobuf::Message() {
3259 void UpdateData::SharedCtor() {
3262 end_segment_ =
false;
3263 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
3266 UpdateData::~UpdateData() {
3271 void UpdateData::SharedDtor() {
3272 if (
this != default_instance_) {
3276 void UpdateData::SetCachedSize(
int size)
const {
3277 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
3278 _cached_size_ = size;
3279 GOOGLE_SAFE_CONCURRENT_WRITES_END();
3281 const ::google::protobuf::Descriptor* UpdateData::descriptor() {
3282 protobuf_AssignDescriptorsOnce();
3283 return UpdateData_descriptor_;
3286 const UpdateData& UpdateData::default_instance() {
3287 if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto();
3288 return *default_instance_;
3291 UpdateData* UpdateData::default_instance_ = NULL;
3293 UpdateData* UpdateData::New()
const {
3294 return new UpdateData;
3297 void UpdateData::Clear() {
3298 #define OFFSET_OF_FIELD_(f) (reinterpret_cast<char*>( \
3299 &reinterpret_cast<UpdateData*>(16)->f) - \
3300 reinterpret_cast<char*>(16))
3302 #define ZR_(first, last) do { \
3303 size_t f = OFFSET_OF_FIELD_(first); \
3304 size_t n = OFFSET_OF_FIELD_(last) - f + sizeof(last); \
3305 ::memset(&first, 0, n); \
3308 ZR_(segment_id_, end_segment_);
3310 #undef OFFSET_OF_FIELD_
3314 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
3315 mutable_unknown_fields()->Clear();
3318 bool UpdateData::MergePartialFromCodedStream(
3319 ::google::protobuf::io::CodedInputStream* input) {
3320 #define DO_(EXPRESSION) if (!(EXPRESSION)) goto failure
3321 ::google::protobuf::uint32 tag;
3324 ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoff(127);
3326 if (!p.second)
goto handle_unusual;
3327 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
3331 DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
3332 ::google::protobuf::uint32, ::google::protobuf::internal::WireFormatLite::TYPE_UINT32>(
3333 input, &segment_id_)));
3334 set_has_segment_id();
3336 goto handle_unusual;
3338 if (input->ExpectTag(16))
goto parse_end_segment;
3346 DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
3347 bool, ::google::protobuf::internal::WireFormatLite::TYPE_BOOL>(
3348 input, &end_segment_)));
3349 set_has_end_segment();
3351 goto handle_unusual;
3353 if (input->ExpectTag(26))
goto parse_record;
3361 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
3362 input, add_record()));
3364 goto handle_unusual;
3366 if (input->ExpectTag(26))
goto parse_record;
3367 if (input->ExpectAtEnd())
goto success;
3374 ::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
3375 ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
3378 DO_(::google::protobuf::internal::WireFormat::SkipField(
3379 input, tag, mutable_unknown_fields()));
3393 void UpdateData::SerializeWithCachedSizes(
3394 ::google::protobuf::io::CodedOutputStream* output)
const {
3397 if (has_segment_id()) {
3398 ::google::protobuf::internal::WireFormatLite::WriteUInt32(1, this->segment_id(), output);
3402 if (has_end_segment()) {
3403 ::google::protobuf::internal::WireFormatLite::WriteBool(2, this->end_segment(), output);
3407 for (
int i = 0; i < this->record_size(); i++) {
3408 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
3409 3, this->record(i), output);
3412 if (!unknown_fields().empty()) {
3413 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
3414 unknown_fields(), output);
3419 ::google::protobuf::uint8* UpdateData::SerializeWithCachedSizesToArray(
3420 ::google::protobuf::uint8* target)
const {
3423 if (has_segment_id()) {
3424 target = ::google::protobuf::internal::WireFormatLite::WriteUInt32ToArray(1, this->segment_id(), target);
3428 if (has_end_segment()) {
3429 target = ::google::protobuf::internal::WireFormatLite::WriteBoolToArray(2, this->end_segment(), target);
3433 for (
int i = 0; i < this->record_size(); i++) {
3434 target = ::google::protobuf::internal::WireFormatLite::
3435 WriteMessageNoVirtualToArray(
3436 3, this->record(i), target);
3439 if (!unknown_fields().empty()) {
3440 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
3441 unknown_fields(), target);
3447 int UpdateData::ByteSize()
const {
3450 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
3452 if (has_segment_id()) {
3454 ::google::protobuf::internal::WireFormatLite::UInt32Size(
3455 this->segment_id());
3459 if (has_end_segment()) {
3460 total_size += 1 + 1;
3465 total_size += 1 * this->record_size();
3466 for (
int i = 0; i < this->record_size(); i++) {
3468 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
3472 if (!unknown_fields().empty()) {
3474 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
3477 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
3478 _cached_size_ = total_size;
3479 GOOGLE_SAFE_CONCURRENT_WRITES_END();
3483 void UpdateData::MergeFrom(const ::google::protobuf::Message& from) {
3484 GOOGLE_CHECK_NE(&from,
this);
3485 const UpdateData* source =
3486 ::google::protobuf::internal::dynamic_cast_if_available<const UpdateData*>(
3488 if (source == NULL) {
3489 ::google::protobuf::internal::ReflectionOps::Merge(from,
this);
3495 void UpdateData::MergeFrom(
const UpdateData& from) {
3496 GOOGLE_CHECK_NE(&from,
this);
3497 record_.MergeFrom(from.record_);
3498 if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
3499 if (from.has_segment_id()) {
3500 set_segment_id(from.segment_id());
3502 if (from.has_end_segment()) {
3503 set_end_segment(from.end_segment());
3506 mutable_unknown_fields()->MergeFrom(from.unknown_fields());
3509 void UpdateData::CopyFrom(const ::google::protobuf::Message& from) {
3510 if (&from ==
this)
return;
3515 void UpdateData::CopyFrom(
const UpdateData& from) {
3516 if (&from ==
this)
return;
3521 bool UpdateData::IsInitialized()
const {
3522 if ((_has_bits_[0] & 0x00000003) != 0x00000003)
return false;
3527 void UpdateData::Swap(UpdateData* other) {
3528 if (other !=
this) {
3529 std::swap(segment_id_, other->segment_id_);
3530 std::swap(end_segment_, other->end_segment_);
3531 record_.Swap(&other->record_);
3532 std::swap(_has_bits_[0], other->_has_bits_[0]);
3533 _unknown_fields_.Swap(&other->_unknown_fields_);
3534 std::swap(_cached_size_, other->_cached_size_);
3538 ::google::protobuf::Metadata UpdateData::GetMetadata()
const {
3539 protobuf_AssignDescriptorsOnce();
3540 ::google::protobuf::Metadata metadata;
3541 metadata.descriptor = UpdateData_descriptor_;
3542 metadata.reflection = UpdateData_reflection_;
3550 const int DeleteRecord::kKeyValueFieldNumber;
3553 DeleteRecord::DeleteRecord()
3554 : ::
google::protobuf::Message() {
3559 void DeleteRecord::InitAsDefaultInstance() {
3562 DeleteRecord::DeleteRecord(
const DeleteRecord& from)
3563 : ::
google::protobuf::Message() {
3569 void DeleteRecord::SharedCtor() {
3570 ::google::protobuf::internal::GetEmptyString();
3572 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
3575 DeleteRecord::~DeleteRecord() {
3580 void DeleteRecord::SharedDtor() {
3581 if (
this != default_instance_) {
3585 void DeleteRecord::SetCachedSize(
int size)
const {
3586 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
3587 _cached_size_ = size;
3588 GOOGLE_SAFE_CONCURRENT_WRITES_END();
3590 const ::google::protobuf::Descriptor* DeleteRecord::descriptor() {
3591 protobuf_AssignDescriptorsOnce();
3592 return DeleteRecord_descriptor_;
3595 const DeleteRecord& DeleteRecord::default_instance() {
3596 if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto();
3597 return *default_instance_;
3600 DeleteRecord* DeleteRecord::default_instance_ = NULL;
3602 DeleteRecord* DeleteRecord::New()
const {
3603 return new DeleteRecord;
3606 void DeleteRecord::Clear() {
3608 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
3609 mutable_unknown_fields()->Clear();
3612 bool DeleteRecord::MergePartialFromCodedStream(
3613 ::google::protobuf::io::CodedInputStream* input) {
3614 #define DO_(EXPRESSION) if (!(EXPRESSION)) goto failure
3615 ::google::protobuf::uint32 tag;
3618 ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoff(127);
3620 if (!p.second)
goto handle_unusual;
3621 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
3626 DO_(::google::protobuf::internal::WireFormatLite::ReadBytes(
3627 input, this->add_key_value()));
3629 goto handle_unusual;
3631 if (input->ExpectTag(10))
goto parse_key_value;
3632 if (input->ExpectAtEnd())
goto success;
3639 ::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
3640 ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
3643 DO_(::google::protobuf::internal::WireFormat::SkipField(
3644 input, tag, mutable_unknown_fields()));
3658 void DeleteRecord::SerializeWithCachedSizes(
3659 ::google::protobuf::io::CodedOutputStream* output)
const {
3662 for (
int i = 0; i < this->key_value_size(); i++) {
3663 ::google::protobuf::internal::WireFormatLite::WriteBytes(
3664 1, this->key_value(i), output);
3667 if (!unknown_fields().empty()) {
3668 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
3669 unknown_fields(), output);
3674 ::google::protobuf::uint8* DeleteRecord::SerializeWithCachedSizesToArray(
3675 ::google::protobuf::uint8* target)
const {
3678 for (
int i = 0; i < this->key_value_size(); i++) {
3679 target = ::google::protobuf::internal::WireFormatLite::
3680 WriteBytesToArray(1, this->key_value(i), target);
3683 if (!unknown_fields().empty()) {
3684 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
3685 unknown_fields(), target);
3691 int DeleteRecord::ByteSize()
const {
3695 total_size += 1 * this->key_value_size();
3696 for (
int i = 0; i < this->key_value_size(); i++) {
3697 total_size += ::google::protobuf::internal::WireFormatLite::BytesSize(
3698 this->key_value(i));
3701 if (!unknown_fields().empty()) {
3703 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
3706 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
3707 _cached_size_ = total_size;
3708 GOOGLE_SAFE_CONCURRENT_WRITES_END();
3712 void DeleteRecord::MergeFrom(const ::google::protobuf::Message& from) {
3713 GOOGLE_CHECK_NE(&from,
this);
3714 const DeleteRecord* source =
3715 ::google::protobuf::internal::dynamic_cast_if_available<const DeleteRecord*>(
3717 if (source == NULL) {
3718 ::google::protobuf::internal::ReflectionOps::Merge(from,
this);
3724 void DeleteRecord::MergeFrom(
const DeleteRecord& from) {
3725 GOOGLE_CHECK_NE(&from,
this);
3726 key_value_.MergeFrom(from.key_value_);
3727 mutable_unknown_fields()->MergeFrom(from.unknown_fields());
3730 void DeleteRecord::CopyFrom(const ::google::protobuf::Message& from) {
3731 if (&from ==
this)
return;
3736 void DeleteRecord::CopyFrom(
const DeleteRecord& from) {
3737 if (&from ==
this)
return;
3742 bool DeleteRecord::IsInitialized()
const {
3747 void DeleteRecord::Swap(DeleteRecord* other) {
3748 if (other !=
this) {
3749 key_value_.Swap(&other->key_value_);
3750 std::swap(_has_bits_[0], other->_has_bits_[0]);
3751 _unknown_fields_.Swap(&other->_unknown_fields_);
3752 std::swap(_cached_size_, other->_cached_size_);
3756 ::google::protobuf::Metadata DeleteRecord::GetMetadata()
const {
3757 protobuf_AssignDescriptorsOnce();
3758 ::google::protobuf::Metadata metadata;
3759 metadata.descriptor = DeleteRecord_descriptor_;
3760 metadata.reflection = DeleteRecord_reflection_;
3768 const int DeleteHeader::kTableMetadataFieldNumber;
3769 const int DeleteHeader::kKeyFieldMetadataFieldNumber;
3772 DeleteHeader::DeleteHeader()
3773 : ::
google::protobuf::Message() {
3778 void DeleteHeader::InitAsDefaultInstance() {
3782 DeleteHeader::DeleteHeader(
const DeleteHeader& from)
3783 : ::
google::protobuf::Message() {
3789 void DeleteHeader::SharedCtor() {
3791 table_metadata_ = NULL;
3792 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
3795 DeleteHeader::~DeleteHeader() {
3800 void DeleteHeader::SharedDtor() {
3801 if (
this != default_instance_) {
3802 delete table_metadata_;
3806 void DeleteHeader::SetCachedSize(
int size)
const {
3807 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
3808 _cached_size_ = size;
3809 GOOGLE_SAFE_CONCURRENT_WRITES_END();
3811 const ::google::protobuf::Descriptor* DeleteHeader::descriptor() {
3812 protobuf_AssignDescriptorsOnce();
3813 return DeleteHeader_descriptor_;
3816 const DeleteHeader& DeleteHeader::default_instance() {
3817 if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto();
3818 return *default_instance_;
3821 DeleteHeader* DeleteHeader::default_instance_ = NULL;
3823 DeleteHeader* DeleteHeader::New()
const {
3824 return new DeleteHeader;
3827 void DeleteHeader::Clear() {
3828 if (has_table_metadata()) {
3829 if (table_metadata_ != NULL) table_metadata_->::drizzled::message::TableMetadata::Clear();
3831 key_field_metadata_.Clear();
3832 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
3833 mutable_unknown_fields()->Clear();
3836 bool DeleteHeader::MergePartialFromCodedStream(
3837 ::google::protobuf::io::CodedInputStream* input) {
3838 #define DO_(EXPRESSION) if (!(EXPRESSION)) goto failure
3839 ::google::protobuf::uint32 tag;
3842 ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoff(127);
3844 if (!p.second)
goto handle_unusual;
3845 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
3849 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
3850 input, mutable_table_metadata()));
3852 goto handle_unusual;
3854 if (input->ExpectTag(18))
goto parse_key_field_metadata;
3861 parse_key_field_metadata:
3862 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
3863 input, add_key_field_metadata()));
3865 goto handle_unusual;
3867 if (input->ExpectTag(18))
goto parse_key_field_metadata;
3868 if (input->ExpectAtEnd())
goto success;
3875 ::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
3876 ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
3879 DO_(::google::protobuf::internal::WireFormat::SkipField(
3880 input, tag, mutable_unknown_fields()));
3894 void DeleteHeader::SerializeWithCachedSizes(
3895 ::google::protobuf::io::CodedOutputStream* output)
const {
3898 if (has_table_metadata()) {
3899 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
3900 1, this->table_metadata(), output);
3904 for (
int i = 0; i < this->key_field_metadata_size(); i++) {
3905 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
3906 2, this->key_field_metadata(i), output);
3909 if (!unknown_fields().empty()) {
3910 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
3911 unknown_fields(), output);
3916 ::google::protobuf::uint8* DeleteHeader::SerializeWithCachedSizesToArray(
3917 ::google::protobuf::uint8* target)
const {
3920 if (has_table_metadata()) {
3921 target = ::google::protobuf::internal::WireFormatLite::
3922 WriteMessageNoVirtualToArray(
3923 1, this->table_metadata(), target);
3927 for (
int i = 0; i < this->key_field_metadata_size(); i++) {
3928 target = ::google::protobuf::internal::WireFormatLite::
3929 WriteMessageNoVirtualToArray(
3930 2, this->key_field_metadata(i), target);
3933 if (!unknown_fields().empty()) {
3934 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
3935 unknown_fields(), target);
3941 int DeleteHeader::ByteSize()
const {
3944 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
3946 if (has_table_metadata()) {
3948 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
3949 this->table_metadata());
3954 total_size += 1 * this->key_field_metadata_size();
3955 for (
int i = 0; i < this->key_field_metadata_size(); i++) {
3957 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
3958 this->key_field_metadata(i));
3961 if (!unknown_fields().empty()) {
3963 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
3966 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
3967 _cached_size_ = total_size;
3968 GOOGLE_SAFE_CONCURRENT_WRITES_END();
3972 void DeleteHeader::MergeFrom(const ::google::protobuf::Message& from) {
3973 GOOGLE_CHECK_NE(&from,
this);
3974 const DeleteHeader* source =
3975 ::google::protobuf::internal::dynamic_cast_if_available<const DeleteHeader*>(
3977 if (source == NULL) {
3978 ::google::protobuf::internal::ReflectionOps::Merge(from,
this);
3984 void DeleteHeader::MergeFrom(
const DeleteHeader& from) {
3985 GOOGLE_CHECK_NE(&from,
this);
3986 key_field_metadata_.MergeFrom(from.key_field_metadata_);
3987 if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
3988 if (from.has_table_metadata()) {
3989 mutable_table_metadata()->::drizzled::message::TableMetadata::MergeFrom(from.table_metadata());
3992 mutable_unknown_fields()->MergeFrom(from.unknown_fields());
3995 void DeleteHeader::CopyFrom(const ::google::protobuf::Message& from) {
3996 if (&from ==
this)
return;
4001 void DeleteHeader::CopyFrom(
const DeleteHeader& from) {
4002 if (&from ==
this)
return;
4007 bool DeleteHeader::IsInitialized()
const {
4008 if ((_has_bits_[0] & 0x00000001) != 0x00000001)
return false;
4010 if (has_table_metadata()) {
4011 if (!this->table_metadata().IsInitialized())
return false;
4013 if (!::google::protobuf::internal::AllAreInitialized(this->key_field_metadata()))
return false;
4017 void DeleteHeader::Swap(DeleteHeader* other) {
4018 if (other !=
this) {
4019 std::swap(table_metadata_, other->table_metadata_);
4020 key_field_metadata_.Swap(&other->key_field_metadata_);
4021 std::swap(_has_bits_[0], other->_has_bits_[0]);
4022 _unknown_fields_.Swap(&other->_unknown_fields_);
4023 std::swap(_cached_size_, other->_cached_size_);
4027 ::google::protobuf::Metadata DeleteHeader::GetMetadata()
const {
4028 protobuf_AssignDescriptorsOnce();
4029 ::google::protobuf::Metadata metadata;
4030 metadata.descriptor = DeleteHeader_descriptor_;
4031 metadata.reflection = DeleteHeader_reflection_;
4039 const int DeleteData::kSegmentIdFieldNumber;
4040 const int DeleteData::kEndSegmentFieldNumber;
4041 const int DeleteData::kRecordFieldNumber;
4044 DeleteData::DeleteData()
4045 : ::
google::protobuf::Message() {
4050 void DeleteData::InitAsDefaultInstance() {
4053 DeleteData::DeleteData(
const DeleteData& from)
4054 : ::
google::protobuf::Message() {
4060 void DeleteData::SharedCtor() {
4063 end_segment_ =
false;
4064 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
4067 DeleteData::~DeleteData() {
4072 void DeleteData::SharedDtor() {
4073 if (
this != default_instance_) {
4077 void DeleteData::SetCachedSize(
int size)
const {
4078 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
4079 _cached_size_ = size;
4080 GOOGLE_SAFE_CONCURRENT_WRITES_END();
4082 const ::google::protobuf::Descriptor* DeleteData::descriptor() {
4083 protobuf_AssignDescriptorsOnce();
4084 return DeleteData_descriptor_;
4087 const DeleteData& DeleteData::default_instance() {
4088 if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto();
4089 return *default_instance_;
4092 DeleteData* DeleteData::default_instance_ = NULL;
4094 DeleteData* DeleteData::New()
const {
4095 return new DeleteData;
4098 void DeleteData::Clear() {
4099 #define OFFSET_OF_FIELD_(f) (reinterpret_cast<char*>( \
4100 &reinterpret_cast<DeleteData*>(16)->f) - \
4101 reinterpret_cast<char*>(16))
4103 #define ZR_(first, last) do { \
4104 size_t f = OFFSET_OF_FIELD_(first); \
4105 size_t n = OFFSET_OF_FIELD_(last) - f + sizeof(last); \
4106 ::memset(&first, 0, n); \
4109 ZR_(segment_id_, end_segment_);
4111 #undef OFFSET_OF_FIELD_
4115 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
4116 mutable_unknown_fields()->Clear();
4119 bool DeleteData::MergePartialFromCodedStream(
4120 ::google::protobuf::io::CodedInputStream* input) {
4121 #define DO_(EXPRESSION) if (!(EXPRESSION)) goto failure
4122 ::google::protobuf::uint32 tag;
4125 ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoff(127);
4127 if (!p.second)
goto handle_unusual;
4128 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
4132 DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
4133 ::google::protobuf::uint32, ::google::protobuf::internal::WireFormatLite::TYPE_UINT32>(
4134 input, &segment_id_)));
4135 set_has_segment_id();
4137 goto handle_unusual;
4139 if (input->ExpectTag(16))
goto parse_end_segment;
4147 DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
4148 bool, ::google::protobuf::internal::WireFormatLite::TYPE_BOOL>(
4149 input, &end_segment_)));
4150 set_has_end_segment();
4152 goto handle_unusual;
4154 if (input->ExpectTag(26))
goto parse_record;
4162 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
4163 input, add_record()));
4165 goto handle_unusual;
4167 if (input->ExpectTag(26))
goto parse_record;
4168 if (input->ExpectAtEnd())
goto success;
4175 ::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
4176 ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
4179 DO_(::google::protobuf::internal::WireFormat::SkipField(
4180 input, tag, mutable_unknown_fields()));
4194 void DeleteData::SerializeWithCachedSizes(
4195 ::google::protobuf::io::CodedOutputStream* output)
const {
4198 if (has_segment_id()) {
4199 ::google::protobuf::internal::WireFormatLite::WriteUInt32(1, this->segment_id(), output);
4203 if (has_end_segment()) {
4204 ::google::protobuf::internal::WireFormatLite::WriteBool(2, this->end_segment(), output);
4208 for (
int i = 0; i < this->record_size(); i++) {
4209 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
4210 3, this->record(i), output);
4213 if (!unknown_fields().empty()) {
4214 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
4215 unknown_fields(), output);
4220 ::google::protobuf::uint8* DeleteData::SerializeWithCachedSizesToArray(
4221 ::google::protobuf::uint8* target)
const {
4224 if (has_segment_id()) {
4225 target = ::google::protobuf::internal::WireFormatLite::WriteUInt32ToArray(1, this->segment_id(), target);
4229 if (has_end_segment()) {
4230 target = ::google::protobuf::internal::WireFormatLite::WriteBoolToArray(2, this->end_segment(), target);
4234 for (
int i = 0; i < this->record_size(); i++) {
4235 target = ::google::protobuf::internal::WireFormatLite::
4236 WriteMessageNoVirtualToArray(
4237 3, this->record(i), target);
4240 if (!unknown_fields().empty()) {
4241 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
4242 unknown_fields(), target);
4248 int DeleteData::ByteSize()
const {
4251 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
4253 if (has_segment_id()) {
4255 ::google::protobuf::internal::WireFormatLite::UInt32Size(
4256 this->segment_id());
4260 if (has_end_segment()) {
4261 total_size += 1 + 1;
4266 total_size += 1 * this->record_size();
4267 for (
int i = 0; i < this->record_size(); i++) {
4269 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
4273 if (!unknown_fields().empty()) {
4275 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
4278 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
4279 _cached_size_ = total_size;
4280 GOOGLE_SAFE_CONCURRENT_WRITES_END();
4284 void DeleteData::MergeFrom(const ::google::protobuf::Message& from) {
4285 GOOGLE_CHECK_NE(&from,
this);
4286 const DeleteData* source =
4287 ::google::protobuf::internal::dynamic_cast_if_available<const DeleteData*>(
4289 if (source == NULL) {
4290 ::google::protobuf::internal::ReflectionOps::Merge(from,
this);
4296 void DeleteData::MergeFrom(
const DeleteData& from) {
4297 GOOGLE_CHECK_NE(&from,
this);
4298 record_.MergeFrom(from.record_);
4299 if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
4300 if (from.has_segment_id()) {
4301 set_segment_id(from.segment_id());
4303 if (from.has_end_segment()) {
4304 set_end_segment(from.end_segment());
4307 mutable_unknown_fields()->MergeFrom(from.unknown_fields());
4310 void DeleteData::CopyFrom(const ::google::protobuf::Message& from) {
4311 if (&from ==
this)
return;
4316 void DeleteData::CopyFrom(
const DeleteData& from) {
4317 if (&from ==
this)
return;
4322 bool DeleteData::IsInitialized()
const {
4323 if ((_has_bits_[0] & 0x00000003) != 0x00000003)
return false;
4328 void DeleteData::Swap(DeleteData* other) {
4329 if (other !=
this) {
4330 std::swap(segment_id_, other->segment_id_);
4331 std::swap(end_segment_, other->end_segment_);
4332 record_.Swap(&other->record_);
4333 std::swap(_has_bits_[0], other->_has_bits_[0]);
4334 _unknown_fields_.Swap(&other->_unknown_fields_);
4335 std::swap(_cached_size_, other->_cached_size_);
4339 ::google::protobuf::Metadata DeleteData::GetMetadata()
const {
4340 protobuf_AssignDescriptorsOnce();
4341 ::google::protobuf::Metadata metadata;
4342 metadata.descriptor = DeleteData_descriptor_;
4343 metadata.reflection = DeleteData_reflection_;
4351 const int TruncateTableStatement::kTableMetadataFieldNumber;
4354 TruncateTableStatement::TruncateTableStatement()
4355 : ::
google::protobuf::Message() {
4360 void TruncateTableStatement::InitAsDefaultInstance() {
4364 TruncateTableStatement::TruncateTableStatement(
const TruncateTableStatement& from)
4365 : ::
google::protobuf::Message() {
4371 void TruncateTableStatement::SharedCtor() {
4373 table_metadata_ = NULL;
4374 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
4377 TruncateTableStatement::~TruncateTableStatement() {
4382 void TruncateTableStatement::SharedDtor() {
4383 if (
this != default_instance_) {
4384 delete table_metadata_;
4388 void TruncateTableStatement::SetCachedSize(
int size)
const {
4389 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
4390 _cached_size_ = size;
4391 GOOGLE_SAFE_CONCURRENT_WRITES_END();
4393 const ::google::protobuf::Descriptor* TruncateTableStatement::descriptor() {
4394 protobuf_AssignDescriptorsOnce();
4395 return TruncateTableStatement_descriptor_;
4398 const TruncateTableStatement& TruncateTableStatement::default_instance() {
4399 if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto();
4400 return *default_instance_;
4403 TruncateTableStatement* TruncateTableStatement::default_instance_ = NULL;
4405 TruncateTableStatement* TruncateTableStatement::New()
const {
4406 return new TruncateTableStatement;
4409 void TruncateTableStatement::Clear() {
4410 if (has_table_metadata()) {
4411 if (table_metadata_ != NULL) table_metadata_->::drizzled::message::TableMetadata::Clear();
4413 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
4414 mutable_unknown_fields()->Clear();
4417 bool TruncateTableStatement::MergePartialFromCodedStream(
4418 ::google::protobuf::io::CodedInputStream* input) {
4419 #define DO_(EXPRESSION) if (!(EXPRESSION)) goto failure
4420 ::google::protobuf::uint32 tag;
4423 ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoff(127);
4425 if (!p.second)
goto handle_unusual;
4426 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
4430 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
4431 input, mutable_table_metadata()));
4433 goto handle_unusual;
4435 if (input->ExpectAtEnd())
goto success;
4442 ::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
4443 ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
4446 DO_(::google::protobuf::internal::WireFormat::SkipField(
4447 input, tag, mutable_unknown_fields()));
4461 void TruncateTableStatement::SerializeWithCachedSizes(
4462 ::google::protobuf::io::CodedOutputStream* output)
const {
4465 if (has_table_metadata()) {
4466 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
4467 1, this->table_metadata(), output);
4470 if (!unknown_fields().empty()) {
4471 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
4472 unknown_fields(), output);
4477 ::google::protobuf::uint8* TruncateTableStatement::SerializeWithCachedSizesToArray(
4478 ::google::protobuf::uint8* target)
const {
4481 if (has_table_metadata()) {
4482 target = ::google::protobuf::internal::WireFormatLite::
4483 WriteMessageNoVirtualToArray(
4484 1, this->table_metadata(), target);
4487 if (!unknown_fields().empty()) {
4488 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
4489 unknown_fields(), target);
4495 int TruncateTableStatement::ByteSize()
const {
4498 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
4500 if (has_table_metadata()) {
4502 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
4503 this->table_metadata());
4507 if (!unknown_fields().empty()) {
4509 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
4512 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
4513 _cached_size_ = total_size;
4514 GOOGLE_SAFE_CONCURRENT_WRITES_END();
4518 void TruncateTableStatement::MergeFrom(const ::google::protobuf::Message& from) {
4519 GOOGLE_CHECK_NE(&from,
this);
4520 const TruncateTableStatement* source =
4521 ::google::protobuf::internal::dynamic_cast_if_available<const TruncateTableStatement*>(
4523 if (source == NULL) {
4524 ::google::protobuf::internal::ReflectionOps::Merge(from,
this);
4530 void TruncateTableStatement::MergeFrom(
const TruncateTableStatement& from) {
4531 GOOGLE_CHECK_NE(&from,
this);
4532 if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
4533 if (from.has_table_metadata()) {
4534 mutable_table_metadata()->::drizzled::message::TableMetadata::MergeFrom(from.table_metadata());
4537 mutable_unknown_fields()->MergeFrom(from.unknown_fields());
4540 void TruncateTableStatement::CopyFrom(const ::google::protobuf::Message& from) {
4541 if (&from ==
this)
return;
4546 void TruncateTableStatement::CopyFrom(
const TruncateTableStatement& from) {
4547 if (&from ==
this)
return;
4552 bool TruncateTableStatement::IsInitialized()
const {
4553 if ((_has_bits_[0] & 0x00000001) != 0x00000001)
return false;
4555 if (has_table_metadata()) {
4556 if (!this->table_metadata().IsInitialized())
return false;
4561 void TruncateTableStatement::Swap(TruncateTableStatement* other) {
4562 if (other !=
this) {
4563 std::swap(table_metadata_, other->table_metadata_);
4564 std::swap(_has_bits_[0], other->_has_bits_[0]);
4565 _unknown_fields_.Swap(&other->_unknown_fields_);
4566 std::swap(_cached_size_, other->_cached_size_);
4570 ::google::protobuf::Metadata TruncateTableStatement::GetMetadata()
const {
4571 protobuf_AssignDescriptorsOnce();
4572 ::google::protobuf::Metadata metadata;
4573 metadata.descriptor = TruncateTableStatement_descriptor_;
4574 metadata.reflection = TruncateTableStatement_reflection_;
4582 const int CreateSchemaStatement::kSchemaFieldNumber;
4585 CreateSchemaStatement::CreateSchemaStatement()
4586 : ::
google::protobuf::Message() {
4591 void CreateSchemaStatement::InitAsDefaultInstance() {
4595 CreateSchemaStatement::CreateSchemaStatement(
const CreateSchemaStatement& from)
4596 : ::
google::protobuf::Message() {
4602 void CreateSchemaStatement::SharedCtor() {
4605 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
4608 CreateSchemaStatement::~CreateSchemaStatement() {
4613 void CreateSchemaStatement::SharedDtor() {
4614 if (
this != default_instance_) {
4619 void CreateSchemaStatement::SetCachedSize(
int size)
const {
4620 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
4621 _cached_size_ = size;
4622 GOOGLE_SAFE_CONCURRENT_WRITES_END();
4624 const ::google::protobuf::Descriptor* CreateSchemaStatement::descriptor() {
4625 protobuf_AssignDescriptorsOnce();
4626 return CreateSchemaStatement_descriptor_;
4629 const CreateSchemaStatement& CreateSchemaStatement::default_instance() {
4630 if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto();
4631 return *default_instance_;
4634 CreateSchemaStatement* CreateSchemaStatement::default_instance_ = NULL;
4636 CreateSchemaStatement* CreateSchemaStatement::New()
const {
4637 return new CreateSchemaStatement;
4640 void CreateSchemaStatement::Clear() {
4642 if (schema_ != NULL) schema_->::drizzled::message::Schema::Clear();
4644 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
4645 mutable_unknown_fields()->Clear();
4648 bool CreateSchemaStatement::MergePartialFromCodedStream(
4649 ::google::protobuf::io::CodedInputStream* input) {
4650 #define DO_(EXPRESSION) if (!(EXPRESSION)) goto failure
4651 ::google::protobuf::uint32 tag;
4654 ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoff(127);
4656 if (!p.second)
goto handle_unusual;
4657 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
4661 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
4662 input, mutable_schema()));
4664 goto handle_unusual;
4666 if (input->ExpectAtEnd())
goto success;
4673 ::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
4674 ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
4677 DO_(::google::protobuf::internal::WireFormat::SkipField(
4678 input, tag, mutable_unknown_fields()));
4692 void CreateSchemaStatement::SerializeWithCachedSizes(
4693 ::google::protobuf::io::CodedOutputStream* output)
const {
4697 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
4698 1, this->schema(), output);
4701 if (!unknown_fields().empty()) {
4702 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
4703 unknown_fields(), output);
4708 ::google::protobuf::uint8* CreateSchemaStatement::SerializeWithCachedSizesToArray(
4709 ::google::protobuf::uint8* target)
const {
4713 target = ::google::protobuf::internal::WireFormatLite::
4714 WriteMessageNoVirtualToArray(
4715 1, this->schema(), target);
4718 if (!unknown_fields().empty()) {
4719 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
4720 unknown_fields(), target);
4726 int CreateSchemaStatement::ByteSize()
const {
4729 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
4733 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
4738 if (!unknown_fields().empty()) {
4740 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
4743 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
4744 _cached_size_ = total_size;
4745 GOOGLE_SAFE_CONCURRENT_WRITES_END();
4749 void CreateSchemaStatement::MergeFrom(const ::google::protobuf::Message& from) {
4750 GOOGLE_CHECK_NE(&from,
this);
4751 const CreateSchemaStatement* source =
4752 ::google::protobuf::internal::dynamic_cast_if_available<const CreateSchemaStatement*>(
4754 if (source == NULL) {
4755 ::google::protobuf::internal::ReflectionOps::Merge(from,
this);
4761 void CreateSchemaStatement::MergeFrom(
const CreateSchemaStatement& from) {
4762 GOOGLE_CHECK_NE(&from,
this);
4763 if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
4764 if (from.has_schema()) {
4765 mutable_schema()->::drizzled::message::Schema::MergeFrom(from.schema());
4768 mutable_unknown_fields()->MergeFrom(from.unknown_fields());
4771 void CreateSchemaStatement::CopyFrom(const ::google::protobuf::Message& from) {
4772 if (&from ==
this)
return;
4777 void CreateSchemaStatement::CopyFrom(
const CreateSchemaStatement& from) {
4778 if (&from ==
this)
return;
4783 bool CreateSchemaStatement::IsInitialized()
const {
4784 if ((_has_bits_[0] & 0x00000001) != 0x00000001)
return false;
4787 if (!this->schema().IsInitialized())
return false;
4792 void CreateSchemaStatement::Swap(CreateSchemaStatement* other) {
4793 if (other !=
this) {
4794 std::swap(schema_, other->schema_);
4795 std::swap(_has_bits_[0], other->_has_bits_[0]);
4796 _unknown_fields_.Swap(&other->_unknown_fields_);
4797 std::swap(_cached_size_, other->_cached_size_);
4801 ::google::protobuf::Metadata CreateSchemaStatement::GetMetadata()
const {
4802 protobuf_AssignDescriptorsOnce();
4803 ::google::protobuf::Metadata metadata;
4804 metadata.descriptor = CreateSchemaStatement_descriptor_;
4805 metadata.reflection = CreateSchemaStatement_reflection_;
4813 const int AlterSchemaStatement::kBeforeFieldNumber;
4814 const int AlterSchemaStatement::kAfterFieldNumber;
4817 AlterSchemaStatement::AlterSchemaStatement()
4818 : ::
google::protobuf::Message() {
4823 void AlterSchemaStatement::InitAsDefaultInstance() {
4828 AlterSchemaStatement::AlterSchemaStatement(
const AlterSchemaStatement& from)
4829 : ::
google::protobuf::Message() {
4835 void AlterSchemaStatement::SharedCtor() {
4839 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
4842 AlterSchemaStatement::~AlterSchemaStatement() {
4847 void AlterSchemaStatement::SharedDtor() {
4848 if (
this != default_instance_) {
4854 void AlterSchemaStatement::SetCachedSize(
int size)
const {
4855 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
4856 _cached_size_ = size;
4857 GOOGLE_SAFE_CONCURRENT_WRITES_END();
4859 const ::google::protobuf::Descriptor* AlterSchemaStatement::descriptor() {
4860 protobuf_AssignDescriptorsOnce();
4861 return AlterSchemaStatement_descriptor_;
4864 const AlterSchemaStatement& AlterSchemaStatement::default_instance() {
4865 if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto();
4866 return *default_instance_;
4869 AlterSchemaStatement* AlterSchemaStatement::default_instance_ = NULL;
4871 AlterSchemaStatement* AlterSchemaStatement::New()
const {
4872 return new AlterSchemaStatement;
4875 void AlterSchemaStatement::Clear() {
4876 if (_has_bits_[0 / 32] & 3) {
4878 if (before_ != NULL) before_->::drizzled::message::Schema::Clear();
4881 if (after_ != NULL) after_->::drizzled::message::Schema::Clear();
4884 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
4885 mutable_unknown_fields()->Clear();
4888 bool AlterSchemaStatement::MergePartialFromCodedStream(
4889 ::google::protobuf::io::CodedInputStream* input) {
4890 #define DO_(EXPRESSION) if (!(EXPRESSION)) goto failure
4891 ::google::protobuf::uint32 tag;
4894 ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoff(127);
4896 if (!p.second)
goto handle_unusual;
4897 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
4901 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
4902 input, mutable_before()));
4904 goto handle_unusual;
4906 if (input->ExpectTag(18))
goto parse_after;
4914 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
4915 input, mutable_after()));
4917 goto handle_unusual;
4919 if (input->ExpectAtEnd())
goto success;
4926 ::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
4927 ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
4930 DO_(::google::protobuf::internal::WireFormat::SkipField(
4931 input, tag, mutable_unknown_fields()));
4945 void AlterSchemaStatement::SerializeWithCachedSizes(
4946 ::google::protobuf::io::CodedOutputStream* output)
const {
4950 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
4951 1, this->before(), output);
4956 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
4957 2, this->after(), output);
4960 if (!unknown_fields().empty()) {
4961 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
4962 unknown_fields(), output);
4967 ::google::protobuf::uint8* AlterSchemaStatement::SerializeWithCachedSizesToArray(
4968 ::google::protobuf::uint8* target)
const {
4972 target = ::google::protobuf::internal::WireFormatLite::
4973 WriteMessageNoVirtualToArray(
4974 1, this->before(), target);
4979 target = ::google::protobuf::internal::WireFormatLite::
4980 WriteMessageNoVirtualToArray(
4981 2, this->after(), target);
4984 if (!unknown_fields().empty()) {
4985 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
4986 unknown_fields(), target);
4992 int AlterSchemaStatement::ByteSize()
const {
4995 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
4999 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
5006 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
5011 if (!unknown_fields().empty()) {
5013 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
5016 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
5017 _cached_size_ = total_size;
5018 GOOGLE_SAFE_CONCURRENT_WRITES_END();
5022 void AlterSchemaStatement::MergeFrom(const ::google::protobuf::Message& from) {
5023 GOOGLE_CHECK_NE(&from,
this);
5024 const AlterSchemaStatement* source =
5025 ::google::protobuf::internal::dynamic_cast_if_available<const AlterSchemaStatement*>(
5027 if (source == NULL) {
5028 ::google::protobuf::internal::ReflectionOps::Merge(from,
this);
5034 void AlterSchemaStatement::MergeFrom(
const AlterSchemaStatement& from) {
5035 GOOGLE_CHECK_NE(&from,
this);
5036 if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
5037 if (from.has_before()) {
5038 mutable_before()->::drizzled::message::Schema::MergeFrom(from.before());
5040 if (from.has_after()) {
5041 mutable_after()->::drizzled::message::Schema::MergeFrom(from.after());
5044 mutable_unknown_fields()->MergeFrom(from.unknown_fields());
5047 void AlterSchemaStatement::CopyFrom(const ::google::protobuf::Message& from) {
5048 if (&from ==
this)
return;
5053 void AlterSchemaStatement::CopyFrom(
const AlterSchemaStatement& from) {
5054 if (&from ==
this)
return;
5059 bool AlterSchemaStatement::IsInitialized()
const {
5060 if ((_has_bits_[0] & 0x00000003) != 0x00000003)
return false;
5063 if (!this->before().IsInitialized())
return false;
5066 if (!this->after().IsInitialized())
return false;
5071 void AlterSchemaStatement::Swap(AlterSchemaStatement* other) {
5072 if (other !=
this) {
5073 std::swap(before_, other->before_);
5074 std::swap(after_, other->after_);
5075 std::swap(_has_bits_[0], other->_has_bits_[0]);
5076 _unknown_fields_.Swap(&other->_unknown_fields_);
5077 std::swap(_cached_size_, other->_cached_size_);
5081 ::google::protobuf::Metadata AlterSchemaStatement::GetMetadata()
const {
5082 protobuf_AssignDescriptorsOnce();
5083 ::google::protobuf::Metadata metadata;
5084 metadata.descriptor = AlterSchemaStatement_descriptor_;
5085 metadata.reflection = AlterSchemaStatement_reflection_;
5093 const int DropSchemaStatement::kSchemaNameFieldNumber;
5094 const int DropSchemaStatement::kCatalogNameFieldNumber;
5097 DropSchemaStatement::DropSchemaStatement()
5098 : ::
google::protobuf::Message() {
5103 void DropSchemaStatement::InitAsDefaultInstance() {
5106 DropSchemaStatement::DropSchemaStatement(
const DropSchemaStatement& from)
5107 : ::
google::protobuf::Message() {
5113 void DropSchemaStatement::SharedCtor() {
5114 ::google::protobuf::internal::GetEmptyString();
5116 schema_name_ =
const_cast< ::std::string*
>(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
5117 catalog_name_ =
const_cast< ::std::string*
>(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
5118 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
5121 DropSchemaStatement::~DropSchemaStatement() {
5126 void DropSchemaStatement::SharedDtor() {
5127 if (schema_name_ != &::google::protobuf::internal::GetEmptyStringAlreadyInited()) {
5128 delete schema_name_;
5130 if (catalog_name_ != &::google::protobuf::internal::GetEmptyStringAlreadyInited()) {
5131 delete catalog_name_;
5133 if (
this != default_instance_) {
5137 void DropSchemaStatement::SetCachedSize(
int size)
const {
5138 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
5139 _cached_size_ = size;
5140 GOOGLE_SAFE_CONCURRENT_WRITES_END();
5142 const ::google::protobuf::Descriptor* DropSchemaStatement::descriptor() {
5143 protobuf_AssignDescriptorsOnce();
5144 return DropSchemaStatement_descriptor_;
5147 const DropSchemaStatement& DropSchemaStatement::default_instance() {
5148 if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto();
5149 return *default_instance_;
5152 DropSchemaStatement* DropSchemaStatement::default_instance_ = NULL;
5154 DropSchemaStatement* DropSchemaStatement::New()
const {
5155 return new DropSchemaStatement;
5158 void DropSchemaStatement::Clear() {
5159 if (_has_bits_[0 / 32] & 3) {
5160 if (has_schema_name()) {
5161 if (schema_name_ != &::google::protobuf::internal::GetEmptyStringAlreadyInited()) {
5162 schema_name_->clear();
5165 if (has_catalog_name()) {
5166 if (catalog_name_ != &::google::protobuf::internal::GetEmptyStringAlreadyInited()) {
5167 catalog_name_->clear();
5171 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
5172 mutable_unknown_fields()->Clear();
5175 bool DropSchemaStatement::MergePartialFromCodedStream(
5176 ::google::protobuf::io::CodedInputStream* input) {
5177 #define DO_(EXPRESSION) if (!(EXPRESSION)) goto failure
5178 ::google::protobuf::uint32 tag;
5181 ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoff(127);
5183 if (!p.second)
goto handle_unusual;
5184 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
5188 DO_(::google::protobuf::internal::WireFormatLite::ReadString(
5189 input, this->mutable_schema_name()));
5190 ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField(
5191 this->schema_name().data(), this->schema_name().length(),
5192 ::google::protobuf::internal::WireFormat::PARSE,
5195 goto handle_unusual;
5197 if (input->ExpectTag(18))
goto parse_catalog_name;
5205 DO_(::google::protobuf::internal::WireFormatLite::ReadString(
5206 input, this->mutable_catalog_name()));
5207 ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField(
5208 this->catalog_name().data(), this->catalog_name().length(),
5209 ::google::protobuf::internal::WireFormat::PARSE,
5212 goto handle_unusual;
5214 if (input->ExpectAtEnd())
goto success;
5221 ::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
5222 ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
5225 DO_(::google::protobuf::internal::WireFormat::SkipField(
5226 input, tag, mutable_unknown_fields()));
5240 void DropSchemaStatement::SerializeWithCachedSizes(
5241 ::google::protobuf::io::CodedOutputStream* output)
const {
5244 if (has_schema_name()) {
5245 ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField(
5246 this->schema_name().data(), this->schema_name().length(),
5247 ::google::protobuf::internal::WireFormat::SERIALIZE,
5249 ::google::protobuf::internal::WireFormatLite::WriteStringMaybeAliased(
5250 1, this->schema_name(), output);
5254 if (has_catalog_name()) {
5255 ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField(
5256 this->catalog_name().data(), this->catalog_name().length(),
5257 ::google::protobuf::internal::WireFormat::SERIALIZE,
5259 ::google::protobuf::internal::WireFormatLite::WriteStringMaybeAliased(
5260 2, this->catalog_name(), output);
5263 if (!unknown_fields().empty()) {
5264 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
5265 unknown_fields(), output);
5270 ::google::protobuf::uint8* DropSchemaStatement::SerializeWithCachedSizesToArray(
5271 ::google::protobuf::uint8* target)
const {
5274 if (has_schema_name()) {
5275 ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField(
5276 this->schema_name().data(), this->schema_name().length(),
5277 ::google::protobuf::internal::WireFormat::SERIALIZE,
5280 ::google::protobuf::internal::WireFormatLite::WriteStringToArray(
5281 1, this->schema_name(), target);
5285 if (has_catalog_name()) {
5286 ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField(
5287 this->catalog_name().data(), this->catalog_name().length(),
5288 ::google::protobuf::internal::WireFormat::SERIALIZE,
5291 ::google::protobuf::internal::WireFormatLite::WriteStringToArray(
5292 2, this->catalog_name(), target);
5295 if (!unknown_fields().empty()) {
5296 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
5297 unknown_fields(), target);
5303 int DropSchemaStatement::ByteSize()
const {
5306 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
5308 if (has_schema_name()) {
5310 ::google::protobuf::internal::WireFormatLite::StringSize(
5311 this->schema_name());
5315 if (has_catalog_name()) {
5317 ::google::protobuf::internal::WireFormatLite::StringSize(
5318 this->catalog_name());
5322 if (!unknown_fields().empty()) {
5324 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
5327 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
5328 _cached_size_ = total_size;
5329 GOOGLE_SAFE_CONCURRENT_WRITES_END();
5333 void DropSchemaStatement::MergeFrom(const ::google::protobuf::Message& from) {
5334 GOOGLE_CHECK_NE(&from,
this);
5335 const DropSchemaStatement* source =
5336 ::google::protobuf::internal::dynamic_cast_if_available<const DropSchemaStatement*>(
5338 if (source == NULL) {
5339 ::google::protobuf::internal::ReflectionOps::Merge(from,
this);
5345 void DropSchemaStatement::MergeFrom(
const DropSchemaStatement& from) {
5346 GOOGLE_CHECK_NE(&from,
this);
5347 if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
5348 if (from.has_schema_name()) {
5349 set_schema_name(from.schema_name());
5351 if (from.has_catalog_name()) {
5352 set_catalog_name(from.catalog_name());
5355 mutable_unknown_fields()->MergeFrom(from.unknown_fields());
5358 void DropSchemaStatement::CopyFrom(const ::google::protobuf::Message& from) {
5359 if (&from ==
this)
return;
5364 void DropSchemaStatement::CopyFrom(
const DropSchemaStatement& from) {
5365 if (&from ==
this)
return;
5370 bool DropSchemaStatement::IsInitialized()
const {
5371 if ((_has_bits_[0] & 0x00000001) != 0x00000001)
return false;
5376 void DropSchemaStatement::Swap(DropSchemaStatement* other) {
5377 if (other !=
this) {
5378 std::swap(schema_name_, other->schema_name_);
5379 std::swap(catalog_name_, other->catalog_name_);
5380 std::swap(_has_bits_[0], other->_has_bits_[0]);
5381 _unknown_fields_.Swap(&other->_unknown_fields_);
5382 std::swap(_cached_size_, other->_cached_size_);
5386 ::google::protobuf::Metadata DropSchemaStatement::GetMetadata()
const {
5387 protobuf_AssignDescriptorsOnce();
5388 ::google::protobuf::Metadata metadata;
5389 metadata.descriptor = DropSchemaStatement_descriptor_;
5390 metadata.reflection = DropSchemaStatement_reflection_;
5398 const int CreateTableStatement::kTableFieldNumber;
5401 CreateTableStatement::CreateTableStatement()
5402 : ::
google::protobuf::Message() {
5407 void CreateTableStatement::InitAsDefaultInstance() {
5411 CreateTableStatement::CreateTableStatement(
const CreateTableStatement& from)
5412 : ::
google::protobuf::Message() {
5418 void CreateTableStatement::SharedCtor() {
5421 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
5424 CreateTableStatement::~CreateTableStatement() {
5429 void CreateTableStatement::SharedDtor() {
5430 if (
this != default_instance_) {
5435 void CreateTableStatement::SetCachedSize(
int size)
const {
5436 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
5437 _cached_size_ = size;
5438 GOOGLE_SAFE_CONCURRENT_WRITES_END();
5440 const ::google::protobuf::Descriptor* CreateTableStatement::descriptor() {
5441 protobuf_AssignDescriptorsOnce();
5442 return CreateTableStatement_descriptor_;
5445 const CreateTableStatement& CreateTableStatement::default_instance() {
5446 if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto();
5447 return *default_instance_;
5450 CreateTableStatement* CreateTableStatement::default_instance_ = NULL;
5452 CreateTableStatement* CreateTableStatement::New()
const {
5453 return new CreateTableStatement;
5456 void CreateTableStatement::Clear() {
5458 if (table_ != NULL) table_->::drizzled::message::Table::Clear();
5460 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
5461 mutable_unknown_fields()->Clear();
5464 bool CreateTableStatement::MergePartialFromCodedStream(
5465 ::google::protobuf::io::CodedInputStream* input) {
5466 #define DO_(EXPRESSION) if (!(EXPRESSION)) goto failure
5467 ::google::protobuf::uint32 tag;
5470 ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoff(127);
5472 if (!p.second)
goto handle_unusual;
5473 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
5477 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
5478 input, mutable_table()));
5480 goto handle_unusual;
5482 if (input->ExpectAtEnd())
goto success;
5489 ::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
5490 ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
5493 DO_(::google::protobuf::internal::WireFormat::SkipField(
5494 input, tag, mutable_unknown_fields()));
5508 void CreateTableStatement::SerializeWithCachedSizes(
5509 ::google::protobuf::io::CodedOutputStream* output)
const {
5513 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
5514 1, this->table(), output);
5517 if (!unknown_fields().empty()) {
5518 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
5519 unknown_fields(), output);
5524 ::google::protobuf::uint8* CreateTableStatement::SerializeWithCachedSizesToArray(
5525 ::google::protobuf::uint8* target)
const {
5529 target = ::google::protobuf::internal::WireFormatLite::
5530 WriteMessageNoVirtualToArray(
5531 1, this->table(), target);
5534 if (!unknown_fields().empty()) {
5535 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
5536 unknown_fields(), target);
5542 int CreateTableStatement::ByteSize()
const {
5545 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
5549 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
5554 if (!unknown_fields().empty()) {
5556 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
5559 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
5560 _cached_size_ = total_size;
5561 GOOGLE_SAFE_CONCURRENT_WRITES_END();
5565 void CreateTableStatement::MergeFrom(const ::google::protobuf::Message& from) {
5566 GOOGLE_CHECK_NE(&from,
this);
5567 const CreateTableStatement* source =
5568 ::google::protobuf::internal::dynamic_cast_if_available<const CreateTableStatement*>(
5570 if (source == NULL) {
5571 ::google::protobuf::internal::ReflectionOps::Merge(from,
this);
5577 void CreateTableStatement::MergeFrom(
const CreateTableStatement& from) {
5578 GOOGLE_CHECK_NE(&from,
this);
5579 if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
5580 if (from.has_table()) {
5581 mutable_table()->::drizzled::message::Table::MergeFrom(from.table());
5584 mutable_unknown_fields()->MergeFrom(from.unknown_fields());
5587 void CreateTableStatement::CopyFrom(const ::google::protobuf::Message& from) {
5588 if (&from ==
this)
return;
5593 void CreateTableStatement::CopyFrom(
const CreateTableStatement& from) {
5594 if (&from ==
this)
return;
5599 bool CreateTableStatement::IsInitialized()
const {
5600 if ((_has_bits_[0] & 0x00000001) != 0x00000001)
return false;
5603 if (!this->table().IsInitialized())
return false;
5608 void CreateTableStatement::Swap(CreateTableStatement* other) {
5609 if (other !=
this) {
5610 std::swap(table_, other->table_);
5611 std::swap(_has_bits_[0], other->_has_bits_[0]);
5612 _unknown_fields_.Swap(&other->_unknown_fields_);
5613 std::swap(_cached_size_, other->_cached_size_);
5617 ::google::protobuf::Metadata CreateTableStatement::GetMetadata()
const {
5618 protobuf_AssignDescriptorsOnce();
5619 ::google::protobuf::Metadata metadata;
5620 metadata.descriptor = CreateTableStatement_descriptor_;
5621 metadata.reflection = CreateTableStatement_reflection_;
5629 const int AlterTableStatement::kBeforeFieldNumber;
5630 const int AlterTableStatement::kAfterFieldNumber;
5633 AlterTableStatement::AlterTableStatement()
5634 : ::
google::protobuf::Message() {
5639 void AlterTableStatement::InitAsDefaultInstance() {
5644 AlterTableStatement::AlterTableStatement(
const AlterTableStatement& from)
5645 : ::
google::protobuf::Message() {
5651 void AlterTableStatement::SharedCtor() {
5655 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
5658 AlterTableStatement::~AlterTableStatement() {
5663 void AlterTableStatement::SharedDtor() {
5664 if (
this != default_instance_) {
5670 void AlterTableStatement::SetCachedSize(
int size)
const {
5671 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
5672 _cached_size_ = size;
5673 GOOGLE_SAFE_CONCURRENT_WRITES_END();
5675 const ::google::protobuf::Descriptor* AlterTableStatement::descriptor() {
5676 protobuf_AssignDescriptorsOnce();
5677 return AlterTableStatement_descriptor_;
5680 const AlterTableStatement& AlterTableStatement::default_instance() {
5681 if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto();
5682 return *default_instance_;
5685 AlterTableStatement* AlterTableStatement::default_instance_ = NULL;
5687 AlterTableStatement* AlterTableStatement::New()
const {
5688 return new AlterTableStatement;
5691 void AlterTableStatement::Clear() {
5692 if (_has_bits_[0 / 32] & 3) {
5694 if (before_ != NULL) before_->::drizzled::message::Table::Clear();
5697 if (after_ != NULL) after_->::drizzled::message::Table::Clear();
5700 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
5701 mutable_unknown_fields()->Clear();
5704 bool AlterTableStatement::MergePartialFromCodedStream(
5705 ::google::protobuf::io::CodedInputStream* input) {
5706 #define DO_(EXPRESSION) if (!(EXPRESSION)) goto failure
5707 ::google::protobuf::uint32 tag;
5710 ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoff(127);
5712 if (!p.second)
goto handle_unusual;
5713 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
5717 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
5718 input, mutable_before()));
5720 goto handle_unusual;
5722 if (input->ExpectTag(18))
goto parse_after;
5730 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
5731 input, mutable_after()));
5733 goto handle_unusual;
5735 if (input->ExpectAtEnd())
goto success;
5742 ::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
5743 ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
5746 DO_(::google::protobuf::internal::WireFormat::SkipField(
5747 input, tag, mutable_unknown_fields()));
5761 void AlterTableStatement::SerializeWithCachedSizes(
5762 ::google::protobuf::io::CodedOutputStream* output)
const {
5766 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
5767 1, this->before(), output);
5772 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
5773 2, this->after(), output);
5776 if (!unknown_fields().empty()) {
5777 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
5778 unknown_fields(), output);
5783 ::google::protobuf::uint8* AlterTableStatement::SerializeWithCachedSizesToArray(
5784 ::google::protobuf::uint8* target)
const {
5788 target = ::google::protobuf::internal::WireFormatLite::
5789 WriteMessageNoVirtualToArray(
5790 1, this->before(), target);
5795 target = ::google::protobuf::internal::WireFormatLite::
5796 WriteMessageNoVirtualToArray(
5797 2, this->after(), target);
5800 if (!unknown_fields().empty()) {
5801 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
5802 unknown_fields(), target);
5808 int AlterTableStatement::ByteSize()
const {
5811 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
5815 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
5822 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
5827 if (!unknown_fields().empty()) {
5829 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
5832 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
5833 _cached_size_ = total_size;
5834 GOOGLE_SAFE_CONCURRENT_WRITES_END();
5838 void AlterTableStatement::MergeFrom(const ::google::protobuf::Message& from) {
5839 GOOGLE_CHECK_NE(&from,
this);
5840 const AlterTableStatement* source =
5841 ::google::protobuf::internal::dynamic_cast_if_available<const AlterTableStatement*>(
5843 if (source == NULL) {
5844 ::google::protobuf::internal::ReflectionOps::Merge(from,
this);
5850 void AlterTableStatement::MergeFrom(
const AlterTableStatement& from) {
5851 GOOGLE_CHECK_NE(&from,
this);
5852 if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
5853 if (from.has_before()) {
5854 mutable_before()->::drizzled::message::Table::MergeFrom(from.before());
5856 if (from.has_after()) {
5857 mutable_after()->::drizzled::message::Table::MergeFrom(from.after());
5860 mutable_unknown_fields()->MergeFrom(from.unknown_fields());
5863 void AlterTableStatement::CopyFrom(const ::google::protobuf::Message& from) {
5864 if (&from ==
this)
return;
5869 void AlterTableStatement::CopyFrom(
const AlterTableStatement& from) {
5870 if (&from ==
this)
return;
5875 bool AlterTableStatement::IsInitialized()
const {
5876 if ((_has_bits_[0] & 0x00000003) != 0x00000003)
return false;
5879 if (!this->before().IsInitialized())
return false;
5882 if (!this->after().IsInitialized())
return false;
5887 void AlterTableStatement::Swap(AlterTableStatement* other) {
5888 if (other !=
this) {
5889 std::swap(before_, other->before_);
5890 std::swap(after_, other->after_);
5891 std::swap(_has_bits_[0], other->_has_bits_[0]);
5892 _unknown_fields_.Swap(&other->_unknown_fields_);
5893 std::swap(_cached_size_, other->_cached_size_);
5897 ::google::protobuf::Metadata AlterTableStatement::GetMetadata()
const {
5898 protobuf_AssignDescriptorsOnce();
5899 ::google::protobuf::Metadata metadata;
5900 metadata.descriptor = AlterTableStatement_descriptor_;
5901 metadata.reflection = AlterTableStatement_reflection_;
5909 const int DropTableStatement::kTableMetadataFieldNumber;
5910 const int DropTableStatement::kIfExistsClauseFieldNumber;
5913 DropTableStatement::DropTableStatement()
5914 : ::
google::protobuf::Message() {
5919 void DropTableStatement::InitAsDefaultInstance() {
5923 DropTableStatement::DropTableStatement(
const DropTableStatement& from)
5924 : ::
google::protobuf::Message() {
5930 void DropTableStatement::SharedCtor() {
5932 table_metadata_ = NULL;
5933 if_exists_clause_ =
false;
5934 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
5937 DropTableStatement::~DropTableStatement() {
5942 void DropTableStatement::SharedDtor() {
5943 if (
this != default_instance_) {
5944 delete table_metadata_;
5948 void DropTableStatement::SetCachedSize(
int size)
const {
5949 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
5950 _cached_size_ = size;
5951 GOOGLE_SAFE_CONCURRENT_WRITES_END();
5953 const ::google::protobuf::Descriptor* DropTableStatement::descriptor() {
5954 protobuf_AssignDescriptorsOnce();
5955 return DropTableStatement_descriptor_;
5958 const DropTableStatement& DropTableStatement::default_instance() {
5959 if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto();
5960 return *default_instance_;
5963 DropTableStatement* DropTableStatement::default_instance_ = NULL;
5965 DropTableStatement* DropTableStatement::New()
const {
5966 return new DropTableStatement;
5969 void DropTableStatement::Clear() {
5970 if (_has_bits_[0 / 32] & 3) {
5971 if (has_table_metadata()) {
5972 if (table_metadata_ != NULL) table_metadata_->::drizzled::message::TableMetadata::Clear();
5974 if_exists_clause_ =
false;
5976 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
5977 mutable_unknown_fields()->Clear();
5980 bool DropTableStatement::MergePartialFromCodedStream(
5981 ::google::protobuf::io::CodedInputStream* input) {
5982 #define DO_(EXPRESSION) if (!(EXPRESSION)) goto failure
5983 ::google::protobuf::uint32 tag;
5986 ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoff(127);
5988 if (!p.second)
goto handle_unusual;
5989 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
5993 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
5994 input, mutable_table_metadata()));
5996 goto handle_unusual;
5998 if (input->ExpectTag(16))
goto parse_if_exists_clause;
6005 parse_if_exists_clause:
6006 DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
6007 bool, ::google::protobuf::internal::WireFormatLite::TYPE_BOOL>(
6008 input, &if_exists_clause_)));
6009 set_has_if_exists_clause();
6011 goto handle_unusual;
6013 if (input->ExpectAtEnd())
goto success;
6020 ::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
6021 ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
6024 DO_(::google::protobuf::internal::WireFormat::SkipField(
6025 input, tag, mutable_unknown_fields()));
6039 void DropTableStatement::SerializeWithCachedSizes(
6040 ::google::protobuf::io::CodedOutputStream* output)
const {
6043 if (has_table_metadata()) {
6044 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
6045 1, this->table_metadata(), output);
6049 if (has_if_exists_clause()) {
6050 ::google::protobuf::internal::WireFormatLite::WriteBool(2, this->if_exists_clause(), output);
6053 if (!unknown_fields().empty()) {
6054 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
6055 unknown_fields(), output);
6060 ::google::protobuf::uint8* DropTableStatement::SerializeWithCachedSizesToArray(
6061 ::google::protobuf::uint8* target)
const {
6064 if (has_table_metadata()) {
6065 target = ::google::protobuf::internal::WireFormatLite::
6066 WriteMessageNoVirtualToArray(
6067 1, this->table_metadata(), target);
6071 if (has_if_exists_clause()) {
6072 target = ::google::protobuf::internal::WireFormatLite::WriteBoolToArray(2, this->if_exists_clause(), target);
6075 if (!unknown_fields().empty()) {
6076 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
6077 unknown_fields(), target);
6083 int DropTableStatement::ByteSize()
const {
6086 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
6088 if (has_table_metadata()) {
6090 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
6091 this->table_metadata());
6095 if (has_if_exists_clause()) {
6096 total_size += 1 + 1;
6100 if (!unknown_fields().empty()) {
6102 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
6105 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
6106 _cached_size_ = total_size;
6107 GOOGLE_SAFE_CONCURRENT_WRITES_END();
6111 void DropTableStatement::MergeFrom(const ::google::protobuf::Message& from) {
6112 GOOGLE_CHECK_NE(&from,
this);
6113 const DropTableStatement* source =
6114 ::google::protobuf::internal::dynamic_cast_if_available<const DropTableStatement*>(
6116 if (source == NULL) {
6117 ::google::protobuf::internal::ReflectionOps::Merge(from,
this);
6123 void DropTableStatement::MergeFrom(
const DropTableStatement& from) {
6124 GOOGLE_CHECK_NE(&from,
this);
6125 if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
6126 if (from.has_table_metadata()) {
6127 mutable_table_metadata()->::drizzled::message::TableMetadata::MergeFrom(from.table_metadata());
6129 if (from.has_if_exists_clause()) {
6130 set_if_exists_clause(from.if_exists_clause());
6133 mutable_unknown_fields()->MergeFrom(from.unknown_fields());
6136 void DropTableStatement::CopyFrom(const ::google::protobuf::Message& from) {
6137 if (&from ==
this)
return;
6142 void DropTableStatement::CopyFrom(
const DropTableStatement& from) {
6143 if (&from ==
this)
return;
6148 bool DropTableStatement::IsInitialized()
const {
6149 if ((_has_bits_[0] & 0x00000001) != 0x00000001)
return false;
6151 if (has_table_metadata()) {
6152 if (!this->table_metadata().IsInitialized())
return false;
6157 void DropTableStatement::Swap(DropTableStatement* other) {
6158 if (other !=
this) {
6159 std::swap(table_metadata_, other->table_metadata_);
6160 std::swap(if_exists_clause_, other->if_exists_clause_);
6161 std::swap(_has_bits_[0], other->_has_bits_[0]);
6162 _unknown_fields_.Swap(&other->_unknown_fields_);
6163 std::swap(_cached_size_, other->_cached_size_);
6167 ::google::protobuf::Metadata DropTableStatement::GetMetadata()
const {
6168 protobuf_AssignDescriptorsOnce();
6169 ::google::protobuf::Metadata metadata;
6170 metadata.descriptor = DropTableStatement_descriptor_;
6171 metadata.reflection = DropTableStatement_reflection_;
6179 const int SetVariableStatement::kVariableMetadataFieldNumber;
6180 const int SetVariableStatement::kVariableValueFieldNumber;
6183 SetVariableStatement::SetVariableStatement()
6184 : ::
google::protobuf::Message() {
6189 void SetVariableStatement::InitAsDefaultInstance() {
6193 SetVariableStatement::SetVariableStatement(
const SetVariableStatement& from)
6194 : ::
google::protobuf::Message() {
6200 void SetVariableStatement::SharedCtor() {
6201 ::google::protobuf::internal::GetEmptyString();
6203 variable_metadata_ = NULL;
6204 variable_value_ =
const_cast< ::std::string*
>(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
6205 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
6208 SetVariableStatement::~SetVariableStatement() {
6213 void SetVariableStatement::SharedDtor() {
6214 if (variable_value_ != &::google::protobuf::internal::GetEmptyStringAlreadyInited()) {
6215 delete variable_value_;
6217 if (
this != default_instance_) {
6218 delete variable_metadata_;
6222 void SetVariableStatement::SetCachedSize(
int size)
const {
6223 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
6224 _cached_size_ = size;
6225 GOOGLE_SAFE_CONCURRENT_WRITES_END();
6227 const ::google::protobuf::Descriptor* SetVariableStatement::descriptor() {
6228 protobuf_AssignDescriptorsOnce();
6229 return SetVariableStatement_descriptor_;
6232 const SetVariableStatement& SetVariableStatement::default_instance() {
6233 if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto();
6234 return *default_instance_;
6237 SetVariableStatement* SetVariableStatement::default_instance_ = NULL;
6239 SetVariableStatement* SetVariableStatement::New()
const {
6240 return new SetVariableStatement;
6243 void SetVariableStatement::Clear() {
6244 if (_has_bits_[0 / 32] & 3) {
6245 if (has_variable_metadata()) {
6246 if (variable_metadata_ != NULL) variable_metadata_->::drizzled::message::FieldMetadata::Clear();
6248 if (has_variable_value()) {
6249 if (variable_value_ != &::google::protobuf::internal::GetEmptyStringAlreadyInited()) {
6250 variable_value_->clear();
6254 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
6255 mutable_unknown_fields()->Clear();
6258 bool SetVariableStatement::MergePartialFromCodedStream(
6259 ::google::protobuf::io::CodedInputStream* input) {
6260 #define DO_(EXPRESSION) if (!(EXPRESSION)) goto failure
6261 ::google::protobuf::uint32 tag;
6264 ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoff(127);
6266 if (!p.second)
goto handle_unusual;
6267 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
6271 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
6272 input, mutable_variable_metadata()));
6274 goto handle_unusual;
6276 if (input->ExpectTag(18))
goto parse_variable_value;
6283 parse_variable_value:
6284 DO_(::google::protobuf::internal::WireFormatLite::ReadBytes(
6285 input, this->mutable_variable_value()));
6287 goto handle_unusual;
6289 if (input->ExpectAtEnd())
goto success;
6296 ::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
6297 ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
6300 DO_(::google::protobuf::internal::WireFormat::SkipField(
6301 input, tag, mutable_unknown_fields()));
6315 void SetVariableStatement::SerializeWithCachedSizes(
6316 ::google::protobuf::io::CodedOutputStream* output)
const {
6319 if (has_variable_metadata()) {
6320 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
6321 1, this->variable_metadata(), output);
6325 if (has_variable_value()) {
6326 ::google::protobuf::internal::WireFormatLite::WriteBytesMaybeAliased(
6327 2, this->variable_value(), output);
6330 if (!unknown_fields().empty()) {
6331 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
6332 unknown_fields(), output);
6337 ::google::protobuf::uint8* SetVariableStatement::SerializeWithCachedSizesToArray(
6338 ::google::protobuf::uint8* target)
const {
6341 if (has_variable_metadata()) {
6342 target = ::google::protobuf::internal::WireFormatLite::
6343 WriteMessageNoVirtualToArray(
6344 1, this->variable_metadata(), target);
6348 if (has_variable_value()) {
6350 ::google::protobuf::internal::WireFormatLite::WriteBytesToArray(
6351 2, this->variable_value(), target);
6354 if (!unknown_fields().empty()) {
6355 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
6356 unknown_fields(), target);
6362 int SetVariableStatement::ByteSize()
const {
6365 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
6367 if (has_variable_metadata()) {
6369 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
6370 this->variable_metadata());
6374 if (has_variable_value()) {
6376 ::google::protobuf::internal::WireFormatLite::BytesSize(
6377 this->variable_value());
6381 if (!unknown_fields().empty()) {
6383 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
6386 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
6387 _cached_size_ = total_size;
6388 GOOGLE_SAFE_CONCURRENT_WRITES_END();
6392 void SetVariableStatement::MergeFrom(const ::google::protobuf::Message& from) {
6393 GOOGLE_CHECK_NE(&from,
this);
6394 const SetVariableStatement* source =
6395 ::google::protobuf::internal::dynamic_cast_if_available<const SetVariableStatement*>(
6397 if (source == NULL) {
6398 ::google::protobuf::internal::ReflectionOps::Merge(from,
this);
6404 void SetVariableStatement::MergeFrom(
const SetVariableStatement& from) {
6405 GOOGLE_CHECK_NE(&from,
this);
6406 if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
6407 if (from.has_variable_metadata()) {
6408 mutable_variable_metadata()->::drizzled::message::FieldMetadata::MergeFrom(from.variable_metadata());
6410 if (from.has_variable_value()) {
6411 set_variable_value(from.variable_value());
6414 mutable_unknown_fields()->MergeFrom(from.unknown_fields());
6417 void SetVariableStatement::CopyFrom(const ::google::protobuf::Message& from) {
6418 if (&from ==
this)
return;
6423 void SetVariableStatement::CopyFrom(
const SetVariableStatement& from) {
6424 if (&from ==
this)
return;
6429 bool SetVariableStatement::IsInitialized()
const {
6430 if ((_has_bits_[0] & 0x00000003) != 0x00000003)
return false;
6432 if (has_variable_metadata()) {
6433 if (!this->variable_metadata().IsInitialized())
return false;
6438 void SetVariableStatement::Swap(SetVariableStatement* other) {
6439 if (other !=
this) {
6440 std::swap(variable_metadata_, other->variable_metadata_);
6441 std::swap(variable_value_, other->variable_value_);
6442 std::swap(_has_bits_[0], other->_has_bits_[0]);
6443 _unknown_fields_.Swap(&other->_unknown_fields_);
6444 std::swap(_cached_size_, other->_cached_size_);
6448 ::google::protobuf::Metadata SetVariableStatement::GetMetadata()
const {
6449 protobuf_AssignDescriptorsOnce();
6450 ::google::protobuf::Metadata metadata;
6451 metadata.descriptor = SetVariableStatement_descriptor_;
6452 metadata.reflection = SetVariableStatement_reflection_;
6459 const ::google::protobuf::EnumDescriptor* Statement_Type_descriptor() {
6460 protobuf_AssignDescriptorsOnce();
6461 return Statement_Type_descriptor_;
6463 bool Statement_Type_IsValid(
int value) {
6486 const Statement_Type Statement::ROLLBACK;
6487 const Statement_Type Statement::INSERT;
6488 const Statement_Type Statement::DELETE;
6489 const Statement_Type Statement::UPDATE;
6490 const Statement_Type Statement::TRUNCATE_TABLE;
6491 const Statement_Type Statement::CREATE_SCHEMA;
6492 const Statement_Type Statement::ALTER_SCHEMA;
6493 const Statement_Type Statement::DROP_SCHEMA;
6494 const Statement_Type Statement::CREATE_TABLE;
6495 const Statement_Type Statement::ALTER_TABLE;
6496 const Statement_Type Statement::DROP_TABLE;
6497 const Statement_Type Statement::ROLLBACK_STATEMENT;
6498 const Statement_Type Statement::SET_VARIABLE;
6499 const Statement_Type Statement::RAW_SQL;
6500 const Statement_Type Statement::Type_MIN;
6501 const Statement_Type Statement::Type_MAX;
6502 const int Statement::Type_ARRAYSIZE;
6505 const int Statement::kTypeFieldNumber;
6506 const int Statement::kStartTimestampFieldNumber;
6507 const int Statement::kEndTimestampFieldNumber;
6508 const int Statement::kSqlFieldNumber;
6509 const int Statement::kInsertHeaderFieldNumber;
6510 const int Statement::kInsertDataFieldNumber;
6511 const int Statement::kUpdateHeaderFieldNumber;
6512 const int Statement::kUpdateDataFieldNumber;
6513 const int Statement::kDeleteHeaderFieldNumber;
6514 const int Statement::kDeleteDataFieldNumber;
6515 const int Statement::kTruncateTableStatementFieldNumber;
6516 const int Statement::kCreateSchemaStatementFieldNumber;
6517 const int Statement::kDropSchemaStatementFieldNumber;
6518 const int Statement::kAlterSchemaStatementFieldNumber;
6519 const int Statement::kCreateTableStatementFieldNumber;
6520 const int Statement::kAlterTableStatementFieldNumber;
6521 const int Statement::kDropTableStatementFieldNumber;
6522 const int Statement::kSetVariableStatementFieldNumber;
6523 const int Statement::kRawSqlSchemaFieldNumber;
6526 Statement::Statement()
6527 : ::
google::protobuf::Message() {
6532 void Statement::InitAsDefaultInstance() {
6549 Statement::Statement(
const Statement& from)
6550 : ::
google::protobuf::Message() {
6556 void Statement::SharedCtor() {
6557 ::google::protobuf::internal::GetEmptyString();
6560 start_timestamp_ = GOOGLE_ULONGLONG(0);
6561 end_timestamp_ = GOOGLE_ULONGLONG(0);
6562 sql_ =
const_cast< ::std::string*
>(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
6563 insert_header_ = NULL;
6564 insert_data_ = NULL;
6565 update_header_ = NULL;
6566 update_data_ = NULL;
6567 delete_header_ = NULL;
6568 delete_data_ = NULL;
6569 truncate_table_statement_ = NULL;
6570 create_schema_statement_ = NULL;
6571 drop_schema_statement_ = NULL;
6572 alter_schema_statement_ = NULL;
6573 create_table_statement_ = NULL;
6574 alter_table_statement_ = NULL;
6575 drop_table_statement_ = NULL;
6576 set_variable_statement_ = NULL;
6577 raw_sql_schema_ =
const_cast< ::std::string*
>(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
6578 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
6581 Statement::~Statement() {
6586 void Statement::SharedDtor() {
6587 if (sql_ != &::google::protobuf::internal::GetEmptyStringAlreadyInited()) {
6590 if (raw_sql_schema_ != &::google::protobuf::internal::GetEmptyStringAlreadyInited()) {
6591 delete raw_sql_schema_;
6593 if (
this != default_instance_) {
6594 delete insert_header_;
6595 delete insert_data_;
6596 delete update_header_;
6597 delete update_data_;
6598 delete delete_header_;
6599 delete delete_data_;
6600 delete truncate_table_statement_;
6601 delete create_schema_statement_;
6602 delete drop_schema_statement_;
6603 delete alter_schema_statement_;
6604 delete create_table_statement_;
6605 delete alter_table_statement_;
6606 delete drop_table_statement_;
6607 delete set_variable_statement_;
6611 void Statement::SetCachedSize(
int size)
const {
6612 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
6613 _cached_size_ = size;
6614 GOOGLE_SAFE_CONCURRENT_WRITES_END();
6616 const ::google::protobuf::Descriptor* Statement::descriptor() {
6617 protobuf_AssignDescriptorsOnce();
6618 return Statement_descriptor_;
6621 const Statement& Statement::default_instance() {
6622 if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto();
6623 return *default_instance_;
6626 Statement* Statement::default_instance_ = NULL;
6632 void Statement::Clear() {
6633 #define OFFSET_OF_FIELD_(f) (reinterpret_cast<char*>( \
6634 &reinterpret_cast<Statement*>(16)->f) - \
6635 reinterpret_cast<char*>(16))
6637 #define ZR_(first, last) do { \
6638 size_t f = OFFSET_OF_FIELD_(first); \
6639 size_t n = OFFSET_OF_FIELD_(last) - f + sizeof(last); \
6640 ::memset(&first, 0, n); \
6643 if (_has_bits_[0 / 32] & 255) {
6644 ZR_(start_timestamp_, end_timestamp_);
6647 if (sql_ != &::google::protobuf::internal::GetEmptyStringAlreadyInited()) {
6651 if (has_insert_header()) {
6652 if (insert_header_ != NULL) insert_header_->::drizzled::message::InsertHeader::Clear();
6654 if (has_insert_data()) {
6655 if (insert_data_ != NULL) insert_data_->::drizzled::message::InsertData::Clear();
6657 if (has_update_header()) {
6658 if (update_header_ != NULL) update_header_->::drizzled::message::UpdateHeader::Clear();
6660 if (has_update_data()) {
6661 if (update_data_ != NULL) update_data_->::drizzled::message::UpdateData::Clear();
6664 if (_has_bits_[8 / 32] & 65280) {
6665 if (has_delete_header()) {
6666 if (delete_header_ != NULL) delete_header_->::drizzled::message::DeleteHeader::Clear();
6668 if (has_delete_data()) {
6669 if (delete_data_ != NULL) delete_data_->::drizzled::message::DeleteData::Clear();
6671 if (has_truncate_table_statement()) {
6672 if (truncate_table_statement_ != NULL) truncate_table_statement_->::drizzled::message::TruncateTableStatement::Clear();
6674 if (has_create_schema_statement()) {
6675 if (create_schema_statement_ != NULL) create_schema_statement_->::drizzled::message::CreateSchemaStatement::Clear();
6677 if (has_drop_schema_statement()) {
6678 if (drop_schema_statement_ != NULL) drop_schema_statement_->::drizzled::message::DropSchemaStatement::Clear();
6680 if (has_alter_schema_statement()) {
6681 if (alter_schema_statement_ != NULL) alter_schema_statement_->::drizzled::message::AlterSchemaStatement::Clear();
6683 if (has_create_table_statement()) {
6684 if (create_table_statement_ != NULL) create_table_statement_->::drizzled::message::CreateTableStatement::Clear();
6686 if (has_alter_table_statement()) {
6687 if (alter_table_statement_ != NULL) alter_table_statement_->::drizzled::message::AlterTableStatement::Clear();
6690 if (_has_bits_[16 / 32] & 458752) {
6691 if (has_drop_table_statement()) {
6692 if (drop_table_statement_ != NULL) drop_table_statement_->::drizzled::message::DropTableStatement::Clear();
6694 if (has_set_variable_statement()) {
6695 if (set_variable_statement_ != NULL) set_variable_statement_->::drizzled::message::SetVariableStatement::Clear();
6697 if (has_raw_sql_schema()) {
6698 if (raw_sql_schema_ != &::google::protobuf::internal::GetEmptyStringAlreadyInited()) {
6699 raw_sql_schema_->clear();
6704 #undef OFFSET_OF_FIELD_
6707 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
6708 mutable_unknown_fields()->Clear();
6711 bool Statement::MergePartialFromCodedStream(
6712 ::google::protobuf::io::CodedInputStream* input) {
6713 #define DO_(EXPRESSION) if (!(EXPRESSION)) goto failure
6714 ::google::protobuf::uint32 tag;
6717 ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoff(16383);
6719 if (!p.second)
goto handle_unusual;
6720 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
6725 DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
6726 int, ::google::protobuf::internal::WireFormatLite::TYPE_ENUM>(
6728 if (::drizzled::message::Statement_Type_IsValid(value)) {
6729 set_type(static_cast< ::drizzled::message::Statement_Type >(value));
6731 mutable_unknown_fields()->AddVarint(1, value);
6734 goto handle_unusual;
6736 if (input->ExpectTag(16))
goto parse_start_timestamp;
6743 parse_start_timestamp:
6744 DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
6745 ::google::protobuf::uint64, ::google::protobuf::internal::WireFormatLite::TYPE_UINT64>(
6746 input, &start_timestamp_)));
6747 set_has_start_timestamp();
6749 goto handle_unusual;
6751 if (input->ExpectTag(24))
goto parse_end_timestamp;
6758 parse_end_timestamp:
6759 DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
6760 ::google::protobuf::uint64, ::google::protobuf::internal::WireFormatLite::TYPE_UINT64>(
6761 input, &end_timestamp_)));
6762 set_has_end_timestamp();
6764 goto handle_unusual;
6766 if (input->ExpectTag(34))
goto parse_sql;
6774 DO_(::google::protobuf::internal::WireFormatLite::ReadString(
6775 input, this->mutable_sql()));
6776 ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField(
6777 this->sql().data(), this->sql().length(),
6778 ::google::protobuf::internal::WireFormat::PARSE,
6781 goto handle_unusual;
6783 if (input->ExpectTag(42))
goto parse_insert_header;
6790 parse_insert_header:
6791 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
6792 input, mutable_insert_header()));
6794 goto handle_unusual;
6796 if (input->ExpectTag(50))
goto parse_insert_data;
6804 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
6805 input, mutable_insert_data()));
6807 goto handle_unusual;
6809 if (input->ExpectTag(58))
goto parse_update_header;
6816 parse_update_header:
6817 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
6818 input, mutable_update_header()));
6820 goto handle_unusual;
6822 if (input->ExpectTag(66))
goto parse_update_data;
6830 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
6831 input, mutable_update_data()));
6833 goto handle_unusual;
6835 if (input->ExpectTag(74))
goto parse_delete_header;
6842 parse_delete_header:
6843 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
6844 input, mutable_delete_header()));
6846 goto handle_unusual;
6848 if (input->ExpectTag(82))
goto parse_delete_data;
6856 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
6857 input, mutable_delete_data()));
6859 goto handle_unusual;
6861 if (input->ExpectTag(90))
goto parse_truncate_table_statement;
6868 parse_truncate_table_statement:
6869 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
6870 input, mutable_truncate_table_statement()));
6872 goto handle_unusual;
6874 if (input->ExpectTag(98))
goto parse_create_schema_statement;
6881 parse_create_schema_statement:
6882 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
6883 input, mutable_create_schema_statement()));
6885 goto handle_unusual;
6887 if (input->ExpectTag(106))
goto parse_drop_schema_statement;
6894 parse_drop_schema_statement:
6895 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
6896 input, mutable_drop_schema_statement()));
6898 goto handle_unusual;
6900 if (input->ExpectTag(114))
goto parse_alter_schema_statement;
6907 parse_alter_schema_statement:
6908 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
6909 input, mutable_alter_schema_statement()));
6911 goto handle_unusual;
6913 if (input->ExpectTag(122))
goto parse_create_table_statement;
6920 parse_create_table_statement:
6921 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
6922 input, mutable_create_table_statement()));
6924 goto handle_unusual;
6926 if (input->ExpectTag(130))
goto parse_alter_table_statement;
6933 parse_alter_table_statement:
6934 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
6935 input, mutable_alter_table_statement()));
6937 goto handle_unusual;
6939 if (input->ExpectTag(138))
goto parse_drop_table_statement;
6946 parse_drop_table_statement:
6947 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
6948 input, mutable_drop_table_statement()));
6950 goto handle_unusual;
6952 if (input->ExpectTag(146))
goto parse_set_variable_statement;
6959 parse_set_variable_statement:
6960 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
6961 input, mutable_set_variable_statement()));
6963 goto handle_unusual;
6965 if (input->ExpectTag(154))
goto parse_raw_sql_schema;
6972 parse_raw_sql_schema:
6973 DO_(::google::protobuf::internal::WireFormatLite::ReadString(
6974 input, this->mutable_raw_sql_schema()));
6975 ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField(
6976 this->raw_sql_schema().data(), this->raw_sql_schema().length(),
6977 ::google::protobuf::internal::WireFormat::PARSE,
6980 goto handle_unusual;
6982 if (input->ExpectAtEnd())
goto success;
6989 ::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
6990 ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
6993 DO_(::google::protobuf::internal::WireFormat::SkipField(
6994 input, tag, mutable_unknown_fields()));
7008 void Statement::SerializeWithCachedSizes(
7009 ::google::protobuf::io::CodedOutputStream* output)
const {
7013 ::google::protobuf::internal::WireFormatLite::WriteEnum(
7014 1, this->type(), output);
7018 if (has_start_timestamp()) {
7019 ::google::protobuf::internal::WireFormatLite::WriteUInt64(2, this->start_timestamp(), output);
7023 if (has_end_timestamp()) {
7024 ::google::protobuf::internal::WireFormatLite::WriteUInt64(3, this->end_timestamp(), output);
7029 ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField(
7030 this->sql().data(), this->sql().length(),
7031 ::google::protobuf::internal::WireFormat::SERIALIZE,
7033 ::google::protobuf::internal::WireFormatLite::WriteStringMaybeAliased(
7034 4, this->sql(), output);
7038 if (has_insert_header()) {
7039 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
7040 5, this->insert_header(), output);
7044 if (has_insert_data()) {
7045 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
7046 6, this->insert_data(), output);
7050 if (has_update_header()) {
7051 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
7052 7, this->update_header(), output);
7056 if (has_update_data()) {
7057 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
7058 8, this->update_data(), output);
7062 if (has_delete_header()) {
7063 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
7064 9, this->delete_header(), output);
7068 if (has_delete_data()) {
7069 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
7070 10, this->delete_data(), output);
7074 if (has_truncate_table_statement()) {
7075 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
7076 11, this->truncate_table_statement(), output);
7080 if (has_create_schema_statement()) {
7081 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
7082 12, this->create_schema_statement(), output);
7086 if (has_drop_schema_statement()) {
7087 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
7088 13, this->drop_schema_statement(), output);
7092 if (has_alter_schema_statement()) {
7093 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
7094 14, this->alter_schema_statement(), output);
7098 if (has_create_table_statement()) {
7099 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
7100 15, this->create_table_statement(), output);
7104 if (has_alter_table_statement()) {
7105 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
7106 16, this->alter_table_statement(), output);
7110 if (has_drop_table_statement()) {
7111 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
7112 17, this->drop_table_statement(), output);
7116 if (has_set_variable_statement()) {
7117 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
7118 18, this->set_variable_statement(), output);
7122 if (has_raw_sql_schema()) {
7123 ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField(
7124 this->raw_sql_schema().data(), this->raw_sql_schema().length(),
7125 ::google::protobuf::internal::WireFormat::SERIALIZE,
7127 ::google::protobuf::internal::WireFormatLite::WriteStringMaybeAliased(
7128 19, this->raw_sql_schema(), output);
7131 if (!unknown_fields().empty()) {
7132 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
7133 unknown_fields(), output);
7138 ::google::protobuf::uint8* Statement::SerializeWithCachedSizesToArray(
7139 ::google::protobuf::uint8* target)
const {
7143 target = ::google::protobuf::internal::WireFormatLite::WriteEnumToArray(
7144 1, this->type(), target);
7148 if (has_start_timestamp()) {
7149 target = ::google::protobuf::internal::WireFormatLite::WriteUInt64ToArray(2, this->start_timestamp(), target);
7153 if (has_end_timestamp()) {
7154 target = ::google::protobuf::internal::WireFormatLite::WriteUInt64ToArray(3, this->end_timestamp(), target);
7159 ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField(
7160 this->sql().data(), this->sql().length(),
7161 ::google::protobuf::internal::WireFormat::SERIALIZE,
7164 ::google::protobuf::internal::WireFormatLite::WriteStringToArray(
7165 4, this->sql(), target);
7169 if (has_insert_header()) {
7170 target = ::google::protobuf::internal::WireFormatLite::
7171 WriteMessageNoVirtualToArray(
7172 5, this->insert_header(), target);
7176 if (has_insert_data()) {
7177 target = ::google::protobuf::internal::WireFormatLite::
7178 WriteMessageNoVirtualToArray(
7179 6, this->insert_data(), target);
7183 if (has_update_header()) {
7184 target = ::google::protobuf::internal::WireFormatLite::
7185 WriteMessageNoVirtualToArray(
7186 7, this->update_header(), target);
7190 if (has_update_data()) {
7191 target = ::google::protobuf::internal::WireFormatLite::
7192 WriteMessageNoVirtualToArray(
7193 8, this->update_data(), target);
7197 if (has_delete_header()) {
7198 target = ::google::protobuf::internal::WireFormatLite::
7199 WriteMessageNoVirtualToArray(
7200 9, this->delete_header(), target);
7204 if (has_delete_data()) {
7205 target = ::google::protobuf::internal::WireFormatLite::
7206 WriteMessageNoVirtualToArray(
7207 10, this->delete_data(), target);
7211 if (has_truncate_table_statement()) {
7212 target = ::google::protobuf::internal::WireFormatLite::
7213 WriteMessageNoVirtualToArray(
7214 11, this->truncate_table_statement(), target);
7218 if (has_create_schema_statement()) {
7219 target = ::google::protobuf::internal::WireFormatLite::
7220 WriteMessageNoVirtualToArray(
7221 12, this->create_schema_statement(), target);
7225 if (has_drop_schema_statement()) {
7226 target = ::google::protobuf::internal::WireFormatLite::
7227 WriteMessageNoVirtualToArray(
7228 13, this->drop_schema_statement(), target);
7232 if (has_alter_schema_statement()) {
7233 target = ::google::protobuf::internal::WireFormatLite::
7234 WriteMessageNoVirtualToArray(
7235 14, this->alter_schema_statement(), target);
7239 if (has_create_table_statement()) {
7240 target = ::google::protobuf::internal::WireFormatLite::
7241 WriteMessageNoVirtualToArray(
7242 15, this->create_table_statement(), target);
7246 if (has_alter_table_statement()) {
7247 target = ::google::protobuf::internal::WireFormatLite::
7248 WriteMessageNoVirtualToArray(
7249 16, this->alter_table_statement(), target);
7253 if (has_drop_table_statement()) {
7254 target = ::google::protobuf::internal::WireFormatLite::
7255 WriteMessageNoVirtualToArray(
7256 17, this->drop_table_statement(), target);
7260 if (has_set_variable_statement()) {
7261 target = ::google::protobuf::internal::WireFormatLite::
7262 WriteMessageNoVirtualToArray(
7263 18, this->set_variable_statement(), target);
7267 if (has_raw_sql_schema()) {
7268 ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField(
7269 this->raw_sql_schema().data(), this->raw_sql_schema().length(),
7270 ::google::protobuf::internal::WireFormat::SERIALIZE,
7273 ::google::protobuf::internal::WireFormatLite::WriteStringToArray(
7274 19, this->raw_sql_schema(), target);
7277 if (!unknown_fields().empty()) {
7278 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
7279 unknown_fields(), target);
7285 int Statement::ByteSize()
const {
7288 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
7292 ::google::protobuf::internal::WireFormatLite::EnumSize(this->type());
7296 if (has_start_timestamp()) {
7298 ::google::protobuf::internal::WireFormatLite::UInt64Size(
7299 this->start_timestamp());
7303 if (has_end_timestamp()) {
7305 ::google::protobuf::internal::WireFormatLite::UInt64Size(
7306 this->end_timestamp());
7312 ::google::protobuf::internal::WireFormatLite::StringSize(
7317 if (has_insert_header()) {
7319 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
7320 this->insert_header());
7324 if (has_insert_data()) {
7326 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
7327 this->insert_data());
7331 if (has_update_header()) {
7333 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
7334 this->update_header());
7338 if (has_update_data()) {
7340 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
7341 this->update_data());
7345 if (_has_bits_[8 / 32] & (0xffu << (8 % 32))) {
7347 if (has_delete_header()) {
7349 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
7350 this->delete_header());
7354 if (has_delete_data()) {
7356 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
7357 this->delete_data());
7361 if (has_truncate_table_statement()) {
7363 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
7364 this->truncate_table_statement());
7368 if (has_create_schema_statement()) {
7370 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
7371 this->create_schema_statement());
7375 if (has_drop_schema_statement()) {
7377 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
7378 this->drop_schema_statement());
7382 if (has_alter_schema_statement()) {
7384 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
7385 this->alter_schema_statement());
7389 if (has_create_table_statement()) {
7391 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
7392 this->create_table_statement());
7396 if (has_alter_table_statement()) {
7398 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
7399 this->alter_table_statement());
7403 if (_has_bits_[16 / 32] & (0xffu << (16 % 32))) {
7405 if (has_drop_table_statement()) {
7407 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
7408 this->drop_table_statement());
7412 if (has_set_variable_statement()) {
7414 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
7415 this->set_variable_statement());
7419 if (has_raw_sql_schema()) {
7421 ::google::protobuf::internal::WireFormatLite::StringSize(
7422 this->raw_sql_schema());
7426 if (!unknown_fields().empty()) {
7428 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
7431 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
7432 _cached_size_ = total_size;
7433 GOOGLE_SAFE_CONCURRENT_WRITES_END();
7437 void Statement::MergeFrom(const ::google::protobuf::Message& from) {
7438 GOOGLE_CHECK_NE(&from,
this);
7440 ::google::protobuf::internal::dynamic_cast_if_available<const Statement*>(
7442 if (source == NULL) {
7443 ::google::protobuf::internal::ReflectionOps::Merge(from,
this);
7449 void Statement::MergeFrom(
const Statement& from) {
7450 GOOGLE_CHECK_NE(&from,
this);
7451 if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
7452 if (from.has_type()) {
7453 set_type(from.type());
7455 if (from.has_start_timestamp()) {
7456 set_start_timestamp(from.start_timestamp());
7458 if (from.has_end_timestamp()) {
7459 set_end_timestamp(from.end_timestamp());
7461 if (from.has_sql()) {
7462 set_sql(from.sql());
7464 if (from.has_insert_header()) {
7465 mutable_insert_header()->::drizzled::message::InsertHeader::MergeFrom(from.insert_header());
7467 if (from.has_insert_data()) {
7468 mutable_insert_data()->::drizzled::message::InsertData::MergeFrom(from.insert_data());
7470 if (from.has_update_header()) {
7471 mutable_update_header()->::drizzled::message::UpdateHeader::MergeFrom(from.update_header());
7473 if (from.has_update_data()) {
7474 mutable_update_data()->::drizzled::message::UpdateData::MergeFrom(from.update_data());
7477 if (from._has_bits_[8 / 32] & (0xffu << (8 % 32))) {
7478 if (from.has_delete_header()) {
7479 mutable_delete_header()->::drizzled::message::DeleteHeader::MergeFrom(from.delete_header());
7481 if (from.has_delete_data()) {
7482 mutable_delete_data()->::drizzled::message::DeleteData::MergeFrom(from.delete_data());
7484 if (from.has_truncate_table_statement()) {
7485 mutable_truncate_table_statement()->::drizzled::message::TruncateTableStatement::MergeFrom(from.truncate_table_statement());
7487 if (from.has_create_schema_statement()) {
7488 mutable_create_schema_statement()->::drizzled::message::CreateSchemaStatement::MergeFrom(from.create_schema_statement());
7490 if (from.has_drop_schema_statement()) {
7491 mutable_drop_schema_statement()->::drizzled::message::DropSchemaStatement::MergeFrom(from.drop_schema_statement());
7493 if (from.has_alter_schema_statement()) {
7494 mutable_alter_schema_statement()->::drizzled::message::AlterSchemaStatement::MergeFrom(from.alter_schema_statement());
7496 if (from.has_create_table_statement()) {
7497 mutable_create_table_statement()->::drizzled::message::CreateTableStatement::MergeFrom(from.create_table_statement());
7499 if (from.has_alter_table_statement()) {
7500 mutable_alter_table_statement()->::drizzled::message::AlterTableStatement::MergeFrom(from.alter_table_statement());
7503 if (from._has_bits_[16 / 32] & (0xffu << (16 % 32))) {
7504 if (from.has_drop_table_statement()) {
7505 mutable_drop_table_statement()->::drizzled::message::DropTableStatement::MergeFrom(from.drop_table_statement());
7507 if (from.has_set_variable_statement()) {
7508 mutable_set_variable_statement()->::drizzled::message::SetVariableStatement::MergeFrom(from.set_variable_statement());
7510 if (from.has_raw_sql_schema()) {
7511 set_raw_sql_schema(from.raw_sql_schema());
7514 mutable_unknown_fields()->MergeFrom(from.unknown_fields());
7517 void Statement::CopyFrom(const ::google::protobuf::Message& from) {
7518 if (&from ==
this)
return;
7523 void Statement::CopyFrom(
const Statement& from) {
7524 if (&from ==
this)
return;
7529 bool Statement::IsInitialized()
const {
7530 if ((_has_bits_[0] & 0x00000007) != 0x00000007)
return false;
7532 if (has_insert_header()) {
7533 if (!this->insert_header().IsInitialized())
return false;
7535 if (has_insert_data()) {
7536 if (!this->insert_data().IsInitialized())
return false;
7538 if (has_update_header()) {
7539 if (!this->update_header().IsInitialized())
return false;
7541 if (has_update_data()) {
7542 if (!this->update_data().IsInitialized())
return false;
7544 if (has_delete_header()) {
7545 if (!this->delete_header().IsInitialized())
return false;
7547 if (has_delete_data()) {
7548 if (!this->delete_data().IsInitialized())
return false;
7550 if (has_truncate_table_statement()) {
7551 if (!this->truncate_table_statement().IsInitialized())
return false;
7553 if (has_create_schema_statement()) {
7554 if (!this->create_schema_statement().IsInitialized())
return false;
7556 if (has_drop_schema_statement()) {
7557 if (!this->drop_schema_statement().IsInitialized())
return false;
7559 if (has_alter_schema_statement()) {
7560 if (!this->alter_schema_statement().IsInitialized())
return false;
7562 if (has_create_table_statement()) {
7563 if (!this->create_table_statement().IsInitialized())
return false;
7565 if (has_alter_table_statement()) {
7566 if (!this->alter_table_statement().IsInitialized())
return false;
7568 if (has_drop_table_statement()) {
7569 if (!this->drop_table_statement().IsInitialized())
return false;
7571 if (has_set_variable_statement()) {
7572 if (!this->set_variable_statement().IsInitialized())
return false;
7577 void Statement::Swap(
Statement* other) {
7578 if (other !=
this) {
7579 std::swap(type_, other->type_);
7580 std::swap(start_timestamp_, other->start_timestamp_);
7581 std::swap(end_timestamp_, other->end_timestamp_);
7582 std::swap(sql_, other->sql_);
7583 std::swap(insert_header_, other->insert_header_);
7584 std::swap(insert_data_, other->insert_data_);
7585 std::swap(update_header_, other->update_header_);
7586 std::swap(update_data_, other->update_data_);
7587 std::swap(delete_header_, other->delete_header_);
7588 std::swap(delete_data_, other->delete_data_);
7589 std::swap(truncate_table_statement_, other->truncate_table_statement_);
7590 std::swap(create_schema_statement_, other->create_schema_statement_);
7591 std::swap(drop_schema_statement_, other->drop_schema_statement_);
7592 std::swap(alter_schema_statement_, other->alter_schema_statement_);
7593 std::swap(create_table_statement_, other->create_table_statement_);
7594 std::swap(alter_table_statement_, other->alter_table_statement_);
7595 std::swap(drop_table_statement_, other->drop_table_statement_);
7596 std::swap(set_variable_statement_, other->set_variable_statement_);
7597 std::swap(raw_sql_schema_, other->raw_sql_schema_);
7598 std::swap(_has_bits_[0], other->_has_bits_[0]);
7599 _unknown_fields_.Swap(&other->_unknown_fields_);
7600 std::swap(_cached_size_, other->_cached_size_);
7604 ::google::protobuf::Metadata Statement::GetMetadata()
const {
7605 protobuf_AssignDescriptorsOnce();
7606 ::google::protobuf::Metadata metadata;
7607 metadata.descriptor = Statement_descriptor_;
7608 metadata.reflection = Statement_reflection_;
7616 const int Transaction::kTransactionContextFieldNumber;
7617 const int Transaction::kStatementFieldNumber;
7618 const int Transaction::kEventFieldNumber;
7619 const int Transaction::kSegmentIdFieldNumber;
7620 const int Transaction::kEndSegmentFieldNumber;
7623 Transaction::Transaction()
7624 : ::
google::protobuf::Message() {
7629 void Transaction::InitAsDefaultInstance() {
7634 Transaction::Transaction(
const Transaction& from)
7635 : ::
google::protobuf::Message() {
7641 void Transaction::SharedCtor() {
7643 transaction_context_ = NULL;
7646 end_segment_ =
false;
7647 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
7650 Transaction::~Transaction() {
7655 void Transaction::SharedDtor() {
7656 if (
this != default_instance_) {
7657 delete transaction_context_;
7662 void Transaction::SetCachedSize(
int size)
const {
7663 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
7664 _cached_size_ = size;
7665 GOOGLE_SAFE_CONCURRENT_WRITES_END();
7667 const ::google::protobuf::Descriptor* Transaction::descriptor() {
7668 protobuf_AssignDescriptorsOnce();
7669 return Transaction_descriptor_;
7672 const Transaction& Transaction::default_instance() {
7673 if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto();
7674 return *default_instance_;
7677 Transaction* Transaction::default_instance_ = NULL;
7679 Transaction* Transaction::New()
const {
7680 return new Transaction;
7683 void Transaction::Clear() {
7684 #define OFFSET_OF_FIELD_(f) (reinterpret_cast<char*>( \
7685 &reinterpret_cast<Transaction*>(16)->f) - \
7686 reinterpret_cast<char*>(16))
7688 #define ZR_(first, last) do { \
7689 size_t f = OFFSET_OF_FIELD_(first); \
7690 size_t n = OFFSET_OF_FIELD_(last) - f + sizeof(last); \
7691 ::memset(&first, 0, n); \
7694 if (_has_bits_[0 / 32] & 29) {
7695 ZR_(segment_id_, end_segment_);
7696 if (has_transaction_context()) {
7697 if (transaction_context_ != NULL) transaction_context_->::drizzled::message::TransactionContext::Clear();
7700 if (event_ != NULL) event_->::drizzled::message::Event::Clear();
7704 #undef OFFSET_OF_FIELD_
7708 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
7709 mutable_unknown_fields()->Clear();
7712 bool Transaction::MergePartialFromCodedStream(
7713 ::google::protobuf::io::CodedInputStream* input) {
7714 #define DO_(EXPRESSION) if (!(EXPRESSION)) goto failure
7715 ::google::protobuf::uint32 tag;
7718 ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoff(127);
7720 if (!p.second)
goto handle_unusual;
7721 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
7725 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
7726 input, mutable_transaction_context()));
7728 goto handle_unusual;
7730 if (input->ExpectTag(18))
goto parse_statement;
7738 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
7739 input, add_statement()));
7741 goto handle_unusual;
7743 if (input->ExpectTag(18))
goto parse_statement;
7744 if (input->ExpectTag(26))
goto parse_event;
7752 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
7753 input, mutable_event()));
7755 goto handle_unusual;
7757 if (input->ExpectTag(32))
goto parse_segment_id;
7765 DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
7766 ::google::protobuf::uint32, ::google::protobuf::internal::WireFormatLite::TYPE_UINT32>(
7767 input, &segment_id_)));
7768 set_has_segment_id();
7770 goto handle_unusual;
7772 if (input->ExpectTag(40))
goto parse_end_segment;
7780 DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
7781 bool, ::google::protobuf::internal::WireFormatLite::TYPE_BOOL>(
7782 input, &end_segment_)));
7783 set_has_end_segment();
7785 goto handle_unusual;
7787 if (input->ExpectAtEnd())
goto success;
7794 ::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
7795 ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
7798 DO_(::google::protobuf::internal::WireFormat::SkipField(
7799 input, tag, mutable_unknown_fields()));
7813 void Transaction::SerializeWithCachedSizes(
7814 ::google::protobuf::io::CodedOutputStream* output)
const {
7817 if (has_transaction_context()) {
7818 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
7819 1, this->transaction_context(), output);
7823 for (
int i = 0; i < this->statement_size(); i++) {
7824 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
7825 2, this->statement(i), output);
7830 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
7831 3, this->event(), output);
7835 if (has_segment_id()) {
7836 ::google::protobuf::internal::WireFormatLite::WriteUInt32(4, this->segment_id(), output);
7840 if (has_end_segment()) {
7841 ::google::protobuf::internal::WireFormatLite::WriteBool(5, this->end_segment(), output);
7844 if (!unknown_fields().empty()) {
7845 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
7846 unknown_fields(), output);
7851 ::google::protobuf::uint8* Transaction::SerializeWithCachedSizesToArray(
7852 ::google::protobuf::uint8* target)
const {
7855 if (has_transaction_context()) {
7856 target = ::google::protobuf::internal::WireFormatLite::
7857 WriteMessageNoVirtualToArray(
7858 1, this->transaction_context(), target);
7862 for (
int i = 0; i < this->statement_size(); i++) {
7863 target = ::google::protobuf::internal::WireFormatLite::
7864 WriteMessageNoVirtualToArray(
7865 2, this->statement(i), target);
7870 target = ::google::protobuf::internal::WireFormatLite::
7871 WriteMessageNoVirtualToArray(
7872 3, this->event(), target);
7876 if (has_segment_id()) {
7877 target = ::google::protobuf::internal::WireFormatLite::WriteUInt32ToArray(4, this->segment_id(), target);
7881 if (has_end_segment()) {
7882 target = ::google::protobuf::internal::WireFormatLite::WriteBoolToArray(5, this->end_segment(), target);
7885 if (!unknown_fields().empty()) {
7886 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
7887 unknown_fields(), target);
7893 int Transaction::ByteSize()
const {
7896 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
7898 if (has_transaction_context()) {
7900 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
7901 this->transaction_context());
7907 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
7912 if (has_segment_id()) {
7914 ::google::protobuf::internal::WireFormatLite::UInt32Size(
7915 this->segment_id());
7919 if (has_end_segment()) {
7920 total_size += 1 + 1;
7925 total_size += 1 * this->statement_size();
7926 for (
int i = 0; i < this->statement_size(); i++) {
7928 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
7929 this->statement(i));
7932 if (!unknown_fields().empty()) {
7934 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
7937 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
7938 _cached_size_ = total_size;
7939 GOOGLE_SAFE_CONCURRENT_WRITES_END();
7943 void Transaction::MergeFrom(const ::google::protobuf::Message& from) {
7944 GOOGLE_CHECK_NE(&from,
this);
7945 const Transaction* source =
7946 ::google::protobuf::internal::dynamic_cast_if_available<const Transaction*>(
7948 if (source == NULL) {
7949 ::google::protobuf::internal::ReflectionOps::Merge(from,
this);
7955 void Transaction::MergeFrom(
const Transaction& from) {
7956 GOOGLE_CHECK_NE(&from,
this);
7957 statement_.MergeFrom(from.statement_);
7958 if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
7959 if (from.has_transaction_context()) {
7960 mutable_transaction_context()->::drizzled::message::TransactionContext::MergeFrom(from.transaction_context());
7962 if (from.has_event()) {
7963 mutable_event()->::drizzled::message::Event::MergeFrom(from.event());
7965 if (from.has_segment_id()) {
7966 set_segment_id(from.segment_id());
7968 if (from.has_end_segment()) {
7969 set_end_segment(from.end_segment());
7972 mutable_unknown_fields()->MergeFrom(from.unknown_fields());
7975 void Transaction::CopyFrom(const ::google::protobuf::Message& from) {
7976 if (&from ==
this)
return;
7981 void Transaction::CopyFrom(
const Transaction& from) {
7982 if (&from ==
this)
return;
7987 bool Transaction::IsInitialized()
const {
7988 if ((_has_bits_[0] & 0x00000001) != 0x00000001)
return false;
7990 if (has_transaction_context()) {
7991 if (!this->transaction_context().IsInitialized())
return false;
7993 if (!::google::protobuf::internal::AllAreInitialized(this->statement()))
return false;
7995 if (!this->event().IsInitialized())
return false;
8000 void Transaction::Swap(Transaction* other) {
8001 if (other !=
this) {
8002 std::swap(transaction_context_, other->transaction_context_);
8003 statement_.Swap(&other->statement_);
8004 std::swap(event_, other->event_);
8005 std::swap(segment_id_, other->segment_id_);
8006 std::swap(end_segment_, other->end_segment_);
8007 std::swap(_has_bits_[0], other->_has_bits_[0]);
8008 _unknown_fields_.Swap(&other->_unknown_fields_);
8009 std::swap(_cached_size_, other->_cached_size_);
8013 ::google::protobuf::Metadata Transaction::GetMetadata()
const {
8014 protobuf_AssignDescriptorsOnce();
8015 ::google::protobuf::Metadata metadata;
8016 metadata.descriptor = Transaction_descriptor_;
8017 metadata.reflection = Transaction_reflection_;
TODO: Rename this file - func.h is stupid.
static bool parse_sql(Session *session, Lex_input_stream *lip)