3 #define INTERNAL_SUPPRESS_PROTOBUF_FIELD_DEPRECATION
4 #include "transaction.pb.h"
8 #include <google/protobuf/stubs/once.h>
9 #include <google/protobuf/io/coded_stream.h>
10 #include <google/protobuf/wire_format_lite_inl.h>
11 #include <google/protobuf/descriptor.h>
12 #include <google/protobuf/reflection_ops.h>
13 #include <google/protobuf/wire_format.h>
21 const ::google::protobuf::Descriptor* FieldMetadata_descriptor_ = NULL;
22 const ::google::protobuf::internal::GeneratedMessageReflection*
23 FieldMetadata_reflection_ = NULL;
24 const ::google::protobuf::Descriptor* TableMetadata_descriptor_ = NULL;
25 const ::google::protobuf::internal::GeneratedMessageReflection*
26 TableMetadata_reflection_ = NULL;
27 const ::google::protobuf::Descriptor* TransactionContext_descriptor_ = NULL;
28 const ::google::protobuf::internal::GeneratedMessageReflection*
29 TransactionContext_reflection_ = NULL;
30 const ::google::protobuf::Descriptor* InsertRecord_descriptor_ = NULL;
31 const ::google::protobuf::internal::GeneratedMessageReflection*
32 InsertRecord_reflection_ = NULL;
33 const ::google::protobuf::Descriptor* InsertHeader_descriptor_ = NULL;
34 const ::google::protobuf::internal::GeneratedMessageReflection*
35 InsertHeader_reflection_ = NULL;
36 const ::google::protobuf::Descriptor* InsertData_descriptor_ = NULL;
37 const ::google::protobuf::internal::GeneratedMessageReflection*
38 InsertData_reflection_ = NULL;
39 const ::google::protobuf::Descriptor* UpdateRecord_descriptor_ = NULL;
40 const ::google::protobuf::internal::GeneratedMessageReflection*
41 UpdateRecord_reflection_ = NULL;
42 const ::google::protobuf::Descriptor* UpdateHeader_descriptor_ = NULL;
43 const ::google::protobuf::internal::GeneratedMessageReflection*
44 UpdateHeader_reflection_ = NULL;
45 const ::google::protobuf::Descriptor* UpdateData_descriptor_ = NULL;
46 const ::google::protobuf::internal::GeneratedMessageReflection*
47 UpdateData_reflection_ = NULL;
48 const ::google::protobuf::Descriptor* DeleteRecord_descriptor_ = NULL;
49 const ::google::protobuf::internal::GeneratedMessageReflection*
50 DeleteRecord_reflection_ = NULL;
51 const ::google::protobuf::Descriptor* DeleteHeader_descriptor_ = NULL;
52 const ::google::protobuf::internal::GeneratedMessageReflection*
53 DeleteHeader_reflection_ = NULL;
54 const ::google::protobuf::Descriptor* DeleteData_descriptor_ = NULL;
55 const ::google::protobuf::internal::GeneratedMessageReflection*
56 DeleteData_reflection_ = NULL;
57 const ::google::protobuf::Descriptor* TruncateTableStatement_descriptor_ = NULL;
58 const ::google::protobuf::internal::GeneratedMessageReflection*
59 TruncateTableStatement_reflection_ = NULL;
60 const ::google::protobuf::Descriptor* CreateSchemaStatement_descriptor_ = NULL;
61 const ::google::protobuf::internal::GeneratedMessageReflection*
62 CreateSchemaStatement_reflection_ = NULL;
63 const ::google::protobuf::Descriptor* AlterSchemaStatement_descriptor_ = NULL;
64 const ::google::protobuf::internal::GeneratedMessageReflection*
65 AlterSchemaStatement_reflection_ = NULL;
66 const ::google::protobuf::Descriptor* DropSchemaStatement_descriptor_ = NULL;
67 const ::google::protobuf::internal::GeneratedMessageReflection*
68 DropSchemaStatement_reflection_ = NULL;
69 const ::google::protobuf::Descriptor* CreateTableStatement_descriptor_ = NULL;
70 const ::google::protobuf::internal::GeneratedMessageReflection*
71 CreateTableStatement_reflection_ = NULL;
72 const ::google::protobuf::Descriptor* AlterTableStatement_descriptor_ = NULL;
73 const ::google::protobuf::internal::GeneratedMessageReflection*
74 AlterTableStatement_reflection_ = NULL;
75 const ::google::protobuf::Descriptor* DropTableStatement_descriptor_ = NULL;
76 const ::google::protobuf::internal::GeneratedMessageReflection*
77 DropTableStatement_reflection_ = NULL;
78 const ::google::protobuf::Descriptor* SetVariableStatement_descriptor_ = NULL;
79 const ::google::protobuf::internal::GeneratedMessageReflection*
80 SetVariableStatement_reflection_ = NULL;
81 const ::google::protobuf::Descriptor* Statement_descriptor_ = NULL;
82 const ::google::protobuf::internal::GeneratedMessageReflection*
83 Statement_reflection_ = NULL;
84 const ::google::protobuf::EnumDescriptor* Statement_Type_descriptor_ = NULL;
85 const ::google::protobuf::Descriptor* Transaction_descriptor_ = NULL;
86 const ::google::protobuf::internal::GeneratedMessageReflection*
87 Transaction_reflection_ = NULL;
92 void protobuf_AssignDesc_transaction_2eproto() {
93 protobuf_AddDesc_transaction_2eproto();
94 const ::google::protobuf::FileDescriptor* file =
95 ::google::protobuf::DescriptorPool::generated_pool()->FindFileByName(
97 GOOGLE_CHECK(file != NULL);
98 FieldMetadata_descriptor_ = file->message_type(0);
99 static const int FieldMetadata_offsets_[2] = {
100 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(FieldMetadata, type_),
101 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(FieldMetadata, name_),
103 FieldMetadata_reflection_ =
104 new ::google::protobuf::internal::GeneratedMessageReflection(
105 FieldMetadata_descriptor_,
106 FieldMetadata::default_instance_,
107 FieldMetadata_offsets_,
108 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(FieldMetadata, _has_bits_[0]),
109 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(FieldMetadata, _unknown_fields_),
111 ::google::protobuf::DescriptorPool::generated_pool(),
112 ::google::protobuf::MessageFactory::generated_factory(),
113 sizeof(FieldMetadata));
114 TableMetadata_descriptor_ = file->message_type(1);
115 static const int TableMetadata_offsets_[3] = {
116 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(TableMetadata, schema_name_),
117 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(TableMetadata, table_name_),
118 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(TableMetadata, catalog_name_),
120 TableMetadata_reflection_ =
121 new ::google::protobuf::internal::GeneratedMessageReflection(
122 TableMetadata_descriptor_,
123 TableMetadata::default_instance_,
124 TableMetadata_offsets_,
125 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(TableMetadata, _has_bits_[0]),
126 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(TableMetadata, _unknown_fields_),
128 ::google::protobuf::DescriptorPool::generated_pool(),
129 ::google::protobuf::MessageFactory::generated_factory(),
130 sizeof(TableMetadata));
131 TransactionContext_descriptor_ = file->message_type(2);
132 static const int TransactionContext_offsets_[4] = {
133 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(TransactionContext, server_id_),
134 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(TransactionContext, transaction_id_),
135 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(TransactionContext, start_timestamp_),
136 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(TransactionContext, end_timestamp_),
138 TransactionContext_reflection_ =
139 new ::google::protobuf::internal::GeneratedMessageReflection(
140 TransactionContext_descriptor_,
141 TransactionContext::default_instance_,
142 TransactionContext_offsets_,
143 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(TransactionContext, _has_bits_[0]),
144 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(TransactionContext, _unknown_fields_),
146 ::google::protobuf::DescriptorPool::generated_pool(),
147 ::google::protobuf::MessageFactory::generated_factory(),
148 sizeof(TransactionContext));
149 InsertRecord_descriptor_ = file->message_type(3);
150 static const int InsertRecord_offsets_[2] = {
151 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(InsertRecord, insert_value_),
152 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(InsertRecord, is_null_),
154 InsertRecord_reflection_ =
155 new ::google::protobuf::internal::GeneratedMessageReflection(
156 InsertRecord_descriptor_,
157 InsertRecord::default_instance_,
158 InsertRecord_offsets_,
159 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(InsertRecord, _has_bits_[0]),
160 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(InsertRecord, _unknown_fields_),
162 ::google::protobuf::DescriptorPool::generated_pool(),
163 ::google::protobuf::MessageFactory::generated_factory(),
164 sizeof(InsertRecord));
165 InsertHeader_descriptor_ = file->message_type(4);
166 static const int InsertHeader_offsets_[2] = {
167 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(InsertHeader, table_metadata_),
168 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(InsertHeader, field_metadata_),
170 InsertHeader_reflection_ =
171 new ::google::protobuf::internal::GeneratedMessageReflection(
172 InsertHeader_descriptor_,
173 InsertHeader::default_instance_,
174 InsertHeader_offsets_,
175 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(InsertHeader, _has_bits_[0]),
176 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(InsertHeader, _unknown_fields_),
178 ::google::protobuf::DescriptorPool::generated_pool(),
179 ::google::protobuf::MessageFactory::generated_factory(),
180 sizeof(InsertHeader));
181 InsertData_descriptor_ = file->message_type(5);
182 static const int InsertData_offsets_[3] = {
183 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(InsertData, segment_id_),
184 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(InsertData, end_segment_),
185 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(InsertData, record_),
187 InsertData_reflection_ =
188 new ::google::protobuf::internal::GeneratedMessageReflection(
189 InsertData_descriptor_,
190 InsertData::default_instance_,
192 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(InsertData, _has_bits_[0]),
193 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(InsertData, _unknown_fields_),
195 ::google::protobuf::DescriptorPool::generated_pool(),
196 ::google::protobuf::MessageFactory::generated_factory(),
198 UpdateRecord_descriptor_ = file->message_type(6);
199 static const int UpdateRecord_offsets_[4] = {
200 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(UpdateRecord, key_value_),
201 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(UpdateRecord, after_value_),
202 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(UpdateRecord, before_value_),
203 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(UpdateRecord, is_null_),
205 UpdateRecord_reflection_ =
206 new ::google::protobuf::internal::GeneratedMessageReflection(
207 UpdateRecord_descriptor_,
208 UpdateRecord::default_instance_,
209 UpdateRecord_offsets_,
210 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(UpdateRecord, _has_bits_[0]),
211 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(UpdateRecord, _unknown_fields_),
213 ::google::protobuf::DescriptorPool::generated_pool(),
214 ::google::protobuf::MessageFactory::generated_factory(),
215 sizeof(UpdateRecord));
216 UpdateHeader_descriptor_ = file->message_type(7);
217 static const int UpdateHeader_offsets_[3] = {
218 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(UpdateHeader, table_metadata_),
219 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(UpdateHeader, key_field_metadata_),
220 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(UpdateHeader, set_field_metadata_),
222 UpdateHeader_reflection_ =
223 new ::google::protobuf::internal::GeneratedMessageReflection(
224 UpdateHeader_descriptor_,
225 UpdateHeader::default_instance_,
226 UpdateHeader_offsets_,
227 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(UpdateHeader, _has_bits_[0]),
228 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(UpdateHeader, _unknown_fields_),
230 ::google::protobuf::DescriptorPool::generated_pool(),
231 ::google::protobuf::MessageFactory::generated_factory(),
232 sizeof(UpdateHeader));
233 UpdateData_descriptor_ = file->message_type(8);
234 static const int UpdateData_offsets_[3] = {
235 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(UpdateData, segment_id_),
236 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(UpdateData, end_segment_),
237 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(UpdateData, record_),
239 UpdateData_reflection_ =
240 new ::google::protobuf::internal::GeneratedMessageReflection(
241 UpdateData_descriptor_,
242 UpdateData::default_instance_,
244 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(UpdateData, _has_bits_[0]),
245 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(UpdateData, _unknown_fields_),
247 ::google::protobuf::DescriptorPool::generated_pool(),
248 ::google::protobuf::MessageFactory::generated_factory(),
250 DeleteRecord_descriptor_ = file->message_type(9);
251 static const int DeleteRecord_offsets_[1] = {
252 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DeleteRecord, key_value_),
254 DeleteRecord_reflection_ =
255 new ::google::protobuf::internal::GeneratedMessageReflection(
256 DeleteRecord_descriptor_,
257 DeleteRecord::default_instance_,
258 DeleteRecord_offsets_,
259 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DeleteRecord, _has_bits_[0]),
260 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DeleteRecord, _unknown_fields_),
262 ::google::protobuf::DescriptorPool::generated_pool(),
263 ::google::protobuf::MessageFactory::generated_factory(),
264 sizeof(DeleteRecord));
265 DeleteHeader_descriptor_ = file->message_type(10);
266 static const int DeleteHeader_offsets_[2] = {
267 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DeleteHeader, table_metadata_),
268 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DeleteHeader, key_field_metadata_),
270 DeleteHeader_reflection_ =
271 new ::google::protobuf::internal::GeneratedMessageReflection(
272 DeleteHeader_descriptor_,
273 DeleteHeader::default_instance_,
274 DeleteHeader_offsets_,
275 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DeleteHeader, _has_bits_[0]),
276 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DeleteHeader, _unknown_fields_),
278 ::google::protobuf::DescriptorPool::generated_pool(),
279 ::google::protobuf::MessageFactory::generated_factory(),
280 sizeof(DeleteHeader));
281 DeleteData_descriptor_ = file->message_type(11);
282 static const int DeleteData_offsets_[3] = {
283 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DeleteData, segment_id_),
284 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DeleteData, end_segment_),
285 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DeleteData, record_),
287 DeleteData_reflection_ =
288 new ::google::protobuf::internal::GeneratedMessageReflection(
289 DeleteData_descriptor_,
290 DeleteData::default_instance_,
292 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DeleteData, _has_bits_[0]),
293 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DeleteData, _unknown_fields_),
295 ::google::protobuf::DescriptorPool::generated_pool(),
296 ::google::protobuf::MessageFactory::generated_factory(),
298 TruncateTableStatement_descriptor_ = file->message_type(12);
299 static const int TruncateTableStatement_offsets_[1] = {
300 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(TruncateTableStatement, table_metadata_),
302 TruncateTableStatement_reflection_ =
303 new ::google::protobuf::internal::GeneratedMessageReflection(
304 TruncateTableStatement_descriptor_,
305 TruncateTableStatement::default_instance_,
306 TruncateTableStatement_offsets_,
307 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(TruncateTableStatement, _has_bits_[0]),
308 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(TruncateTableStatement, _unknown_fields_),
310 ::google::protobuf::DescriptorPool::generated_pool(),
311 ::google::protobuf::MessageFactory::generated_factory(),
312 sizeof(TruncateTableStatement));
313 CreateSchemaStatement_descriptor_ = file->message_type(13);
314 static const int CreateSchemaStatement_offsets_[1] = {
315 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(CreateSchemaStatement, schema_),
317 CreateSchemaStatement_reflection_ =
318 new ::google::protobuf::internal::GeneratedMessageReflection(
319 CreateSchemaStatement_descriptor_,
320 CreateSchemaStatement::default_instance_,
321 CreateSchemaStatement_offsets_,
322 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(CreateSchemaStatement, _has_bits_[0]),
323 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(CreateSchemaStatement, _unknown_fields_),
325 ::google::protobuf::DescriptorPool::generated_pool(),
326 ::google::protobuf::MessageFactory::generated_factory(),
327 sizeof(CreateSchemaStatement));
328 AlterSchemaStatement_descriptor_ = file->message_type(14);
329 static const int AlterSchemaStatement_offsets_[2] = {
330 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(AlterSchemaStatement, before_),
331 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(AlterSchemaStatement, after_),
333 AlterSchemaStatement_reflection_ =
334 new ::google::protobuf::internal::GeneratedMessageReflection(
335 AlterSchemaStatement_descriptor_,
336 AlterSchemaStatement::default_instance_,
337 AlterSchemaStatement_offsets_,
338 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(AlterSchemaStatement, _has_bits_[0]),
339 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(AlterSchemaStatement, _unknown_fields_),
341 ::google::protobuf::DescriptorPool::generated_pool(),
342 ::google::protobuf::MessageFactory::generated_factory(),
343 sizeof(AlterSchemaStatement));
344 DropSchemaStatement_descriptor_ = file->message_type(15);
345 static const int DropSchemaStatement_offsets_[2] = {
346 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DropSchemaStatement, schema_name_),
347 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DropSchemaStatement, catalog_name_),
349 DropSchemaStatement_reflection_ =
350 new ::google::protobuf::internal::GeneratedMessageReflection(
351 DropSchemaStatement_descriptor_,
352 DropSchemaStatement::default_instance_,
353 DropSchemaStatement_offsets_,
354 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DropSchemaStatement, _has_bits_[0]),
355 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DropSchemaStatement, _unknown_fields_),
357 ::google::protobuf::DescriptorPool::generated_pool(),
358 ::google::protobuf::MessageFactory::generated_factory(),
359 sizeof(DropSchemaStatement));
360 CreateTableStatement_descriptor_ = file->message_type(16);
361 static const int CreateTableStatement_offsets_[1] = {
362 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(CreateTableStatement, table_),
364 CreateTableStatement_reflection_ =
365 new ::google::protobuf::internal::GeneratedMessageReflection(
366 CreateTableStatement_descriptor_,
367 CreateTableStatement::default_instance_,
368 CreateTableStatement_offsets_,
369 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(CreateTableStatement, _has_bits_[0]),
370 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(CreateTableStatement, _unknown_fields_),
372 ::google::protobuf::DescriptorPool::generated_pool(),
373 ::google::protobuf::MessageFactory::generated_factory(),
374 sizeof(CreateTableStatement));
375 AlterTableStatement_descriptor_ = file->message_type(17);
376 static const int AlterTableStatement_offsets_[2] = {
377 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(AlterTableStatement, before_),
378 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(AlterTableStatement, after_),
380 AlterTableStatement_reflection_ =
381 new ::google::protobuf::internal::GeneratedMessageReflection(
382 AlterTableStatement_descriptor_,
383 AlterTableStatement::default_instance_,
384 AlterTableStatement_offsets_,
385 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(AlterTableStatement, _has_bits_[0]),
386 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(AlterTableStatement, _unknown_fields_),
388 ::google::protobuf::DescriptorPool::generated_pool(),
389 ::google::protobuf::MessageFactory::generated_factory(),
390 sizeof(AlterTableStatement));
391 DropTableStatement_descriptor_ = file->message_type(18);
392 static const int DropTableStatement_offsets_[2] = {
393 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DropTableStatement, table_metadata_),
394 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DropTableStatement, if_exists_clause_),
396 DropTableStatement_reflection_ =
397 new ::google::protobuf::internal::GeneratedMessageReflection(
398 DropTableStatement_descriptor_,
399 DropTableStatement::default_instance_,
400 DropTableStatement_offsets_,
401 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DropTableStatement, _has_bits_[0]),
402 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DropTableStatement, _unknown_fields_),
404 ::google::protobuf::DescriptorPool::generated_pool(),
405 ::google::protobuf::MessageFactory::generated_factory(),
406 sizeof(DropTableStatement));
407 SetVariableStatement_descriptor_ = file->message_type(19);
408 static const int SetVariableStatement_offsets_[2] = {
409 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(SetVariableStatement, variable_metadata_),
410 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(SetVariableStatement, variable_value_),
412 SetVariableStatement_reflection_ =
413 new ::google::protobuf::internal::GeneratedMessageReflection(
414 SetVariableStatement_descriptor_,
415 SetVariableStatement::default_instance_,
416 SetVariableStatement_offsets_,
417 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(SetVariableStatement, _has_bits_[0]),
418 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(SetVariableStatement, _unknown_fields_),
420 ::google::protobuf::DescriptorPool::generated_pool(),
421 ::google::protobuf::MessageFactory::generated_factory(),
422 sizeof(SetVariableStatement));
423 Statement_descriptor_ = file->message_type(20);
424 static const int Statement_offsets_[19] = {
425 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(
Statement, type_),
426 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(
Statement, start_timestamp_),
427 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(
Statement, end_timestamp_),
428 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(
Statement, sql_),
429 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(
Statement, insert_header_),
430 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(
Statement, insert_data_),
431 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(
Statement, update_header_),
432 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(
Statement, update_data_),
433 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(
Statement, delete_header_),
434 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(
Statement, delete_data_),
435 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(
Statement, truncate_table_statement_),
436 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(
Statement, create_schema_statement_),
437 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(
Statement, drop_schema_statement_),
438 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(
Statement, alter_schema_statement_),
439 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(
Statement, create_table_statement_),
440 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(
Statement, alter_table_statement_),
441 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(
Statement, drop_table_statement_),
442 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(
Statement, set_variable_statement_),
443 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(
Statement, raw_sql_schema_),
445 Statement_reflection_ =
446 new ::google::protobuf::internal::GeneratedMessageReflection(
447 Statement_descriptor_,
448 Statement::default_instance_,
450 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(
Statement, _has_bits_[0]),
451 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(
Statement, _unknown_fields_),
453 ::google::protobuf::DescriptorPool::generated_pool(),
454 ::google::protobuf::MessageFactory::generated_factory(),
456 Statement_Type_descriptor_ = Statement_descriptor_->enum_type(0);
457 Transaction_descriptor_ = file->message_type(21);
458 static const int Transaction_offsets_[5] = {
459 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(Transaction, transaction_context_),
460 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(Transaction, statement_),
461 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(Transaction, event_),
462 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(Transaction, segment_id_),
463 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(Transaction, end_segment_),
465 Transaction_reflection_ =
466 new ::google::protobuf::internal::GeneratedMessageReflection(
467 Transaction_descriptor_,
468 Transaction::default_instance_,
469 Transaction_offsets_,
470 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(Transaction, _has_bits_[0]),
471 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(Transaction, _unknown_fields_),
473 ::google::protobuf::DescriptorPool::generated_pool(),
474 ::google::protobuf::MessageFactory::generated_factory(),
475 sizeof(Transaction));
480 GOOGLE_PROTOBUF_DECLARE_ONCE(protobuf_AssignDescriptors_once_);
481 inline void protobuf_AssignDescriptorsOnce() {
482 ::google::protobuf::GoogleOnceInit(&protobuf_AssignDescriptors_once_,
483 &protobuf_AssignDesc_transaction_2eproto);
486 void protobuf_RegisterTypes(const ::std::string&) {
487 protobuf_AssignDescriptorsOnce();
488 ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
489 FieldMetadata_descriptor_, &FieldMetadata::default_instance());
490 ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
491 TableMetadata_descriptor_, &TableMetadata::default_instance());
492 ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
493 TransactionContext_descriptor_, &TransactionContext::default_instance());
494 ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
495 InsertRecord_descriptor_, &InsertRecord::default_instance());
496 ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
497 InsertHeader_descriptor_, &InsertHeader::default_instance());
498 ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
499 InsertData_descriptor_, &InsertData::default_instance());
500 ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
501 UpdateRecord_descriptor_, &UpdateRecord::default_instance());
502 ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
503 UpdateHeader_descriptor_, &UpdateHeader::default_instance());
504 ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
505 UpdateData_descriptor_, &UpdateData::default_instance());
506 ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
507 DeleteRecord_descriptor_, &DeleteRecord::default_instance());
508 ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
509 DeleteHeader_descriptor_, &DeleteHeader::default_instance());
510 ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
511 DeleteData_descriptor_, &DeleteData::default_instance());
512 ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
513 TruncateTableStatement_descriptor_, &TruncateTableStatement::default_instance());
514 ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
515 CreateSchemaStatement_descriptor_, &CreateSchemaStatement::default_instance());
516 ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
517 AlterSchemaStatement_descriptor_, &AlterSchemaStatement::default_instance());
518 ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
519 DropSchemaStatement_descriptor_, &DropSchemaStatement::default_instance());
520 ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
521 CreateTableStatement_descriptor_, &CreateTableStatement::default_instance());
522 ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
523 AlterTableStatement_descriptor_, &AlterTableStatement::default_instance());
524 ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
525 DropTableStatement_descriptor_, &DropTableStatement::default_instance());
526 ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
527 SetVariableStatement_descriptor_, &SetVariableStatement::default_instance());
528 ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
529 Statement_descriptor_, &Statement::default_instance());
530 ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
531 Transaction_descriptor_, &Transaction::default_instance());
536 void protobuf_ShutdownFile_transaction_2eproto() {
537 delete FieldMetadata::default_instance_;
538 delete FieldMetadata_reflection_;
539 delete TableMetadata::default_instance_;
540 delete TableMetadata_reflection_;
541 delete TransactionContext::default_instance_;
542 delete TransactionContext_reflection_;
543 delete InsertRecord::default_instance_;
544 delete InsertRecord_reflection_;
545 delete InsertHeader::default_instance_;
546 delete InsertHeader_reflection_;
547 delete InsertData::default_instance_;
548 delete InsertData_reflection_;
549 delete UpdateRecord::default_instance_;
550 delete UpdateRecord_reflection_;
551 delete UpdateHeader::default_instance_;
552 delete UpdateHeader_reflection_;
553 delete UpdateData::default_instance_;
554 delete UpdateData_reflection_;
555 delete DeleteRecord::default_instance_;
556 delete DeleteRecord_reflection_;
557 delete DeleteHeader::default_instance_;
558 delete DeleteHeader_reflection_;
559 delete DeleteData::default_instance_;
560 delete DeleteData_reflection_;
561 delete TruncateTableStatement::default_instance_;
562 delete TruncateTableStatement_reflection_;
563 delete CreateSchemaStatement::default_instance_;
564 delete CreateSchemaStatement_reflection_;
565 delete AlterSchemaStatement::default_instance_;
566 delete AlterSchemaStatement_reflection_;
567 delete DropSchemaStatement::default_instance_;
568 delete DropSchemaStatement_reflection_;
569 delete CreateTableStatement::default_instance_;
570 delete CreateTableStatement_reflection_;
571 delete AlterTableStatement::default_instance_;
572 delete AlterTableStatement_reflection_;
573 delete DropTableStatement::default_instance_;
574 delete DropTableStatement_reflection_;
575 delete SetVariableStatement::default_instance_;
576 delete SetVariableStatement_reflection_;
577 delete Statement::default_instance_;
578 delete Statement_reflection_;
579 delete Transaction::default_instance_;
580 delete Transaction_reflection_;
583 void protobuf_AddDesc_transaction_2eproto() {
584 static bool already_here =
false;
585 if (already_here)
return;
587 GOOGLE_PROTOBUF_VERIFY_VERSION;
589 ::drizzled::message::protobuf_AddDesc_table_2eproto();
590 ::drizzled::message::protobuf_AddDesc_schema_2eproto();
591 ::drizzled::message::protobuf_AddDesc_event_2eproto();
592 ::google::protobuf::DescriptorPool::InternalAddGeneratedFile(
593 "\n\021transaction.proto\022\020drizzled.message\032\013t"
594 "able.proto\032\014schema.proto\032\013event.proto\"T\n"
595 "\rFieldMetadata\0225\n\004type\030\001 \002(\0162\'.drizzled."
596 "message.Table.Field.FieldType\022\014\n\004name\030\002 "
597 "\002(\t\"N\n\rTableMetadata\022\023\n\013schema_name\030\001 \002("
598 "\t\022\022\n\ntable_name\030\002 \002(\t\022\024\n\014catalog_name\030\003 "
599 "\001(\t\"o\n\022TransactionContext\022\021\n\tserver_id\030\001"
600 " \002(\r\022\026\n\016transaction_id\030\002 \002(\004\022\027\n\017start_ti"
601 "mestamp\030\003 \002(\004\022\025\n\rend_timestamp\030\004 \002(\004\"5\n\014"
602 "InsertRecord\022\024\n\014insert_value\030\001 \003(\014\022\017\n\007is"
603 "_null\030\002 \003(\010\"\200\001\n\014InsertHeader\0227\n\016table_me"
604 "tadata\030\001 \002(\0132\037.drizzled.message.TableMet"
605 "adata\0227\n\016field_metadata\030\002 \003(\0132\037.drizzled"
606 ".message.FieldMetadata\"e\n\nInsertData\022\022\n\n"
607 "segment_id\030\001 \002(\r\022\023\n\013end_segment\030\002 \002(\010\022.\n"
608 "\006record\030\003 \003(\0132\036.drizzled.message.InsertR"
609 "ecord\"]\n\014UpdateRecord\022\021\n\tkey_value\030\001 \003(\014"
610 "\022\023\n\013after_value\030\002 \003(\014\022\024\n\014before_value\030\003 "
611 "\003(\014\022\017\n\007is_null\030\004 \003(\010\"\301\001\n\014UpdateHeader\0227\n"
612 "\016table_metadata\030\001 \002(\0132\037.drizzled.message"
613 ".TableMetadata\022;\n\022key_field_metadata\030\002 \003"
614 "(\0132\037.drizzled.message.FieldMetadata\022;\n\022s"
615 "et_field_metadata\030\003 \003(\0132\037.drizzled.messa"
616 "ge.FieldMetadata\"e\n\nUpdateData\022\022\n\nsegmen"
617 "t_id\030\001 \002(\r\022\023\n\013end_segment\030\002 \002(\010\022.\n\006recor"
618 "d\030\003 \003(\0132\036.drizzled.message.UpdateRecord\""
619 "!\n\014DeleteRecord\022\021\n\tkey_value\030\001 \003(\014\"\204\001\n\014D"
620 "eleteHeader\0227\n\016table_metadata\030\001 \002(\0132\037.dr"
621 "izzled.message.TableMetadata\022;\n\022key_fiel"
622 "d_metadata\030\002 \003(\0132\037.drizzled.message.Fiel"
623 "dMetadata\"e\n\nDeleteData\022\022\n\nsegment_id\030\001 "
624 "\002(\r\022\023\n\013end_segment\030\002 \002(\010\022.\n\006record\030\003 \003(\013"
625 "2\036.drizzled.message.DeleteRecord\"Q\n\026Trun"
626 "cateTableStatement\0227\n\016table_metadata\030\001 \002"
627 "(\0132\037.drizzled.message.TableMetadata\"A\n\025C"
628 "reateSchemaStatement\022(\n\006schema\030\001 \002(\0132\030.d"
629 "rizzled.message.Schema\"i\n\024AlterSchemaSta"
630 "tement\022(\n\006before\030\001 \002(\0132\030.drizzled.messag"
631 "e.Schema\022\'\n\005after\030\002 \002(\0132\030.drizzled.messa"
632 "ge.Schema\"@\n\023DropSchemaStatement\022\023\n\013sche"
633 "ma_name\030\001 \002(\t\022\024\n\014catalog_name\030\002 \001(\t\">\n\024C"
634 "reateTableStatement\022&\n\005table\030\001 \002(\0132\027.dri"
635 "zzled.message.Table\"f\n\023AlterTableStateme"
636 "nt\022\'\n\006before\030\001 \002(\0132\027.drizzled.message.Ta"
637 "ble\022&\n\005after\030\002 \002(\0132\027.drizzled.message.Ta"
638 "ble\"g\n\022DropTableStatement\0227\n\016table_metad"
639 "ata\030\001 \002(\0132\037.drizzled.message.TableMetada"
640 "ta\022\030\n\020if_exists_clause\030\002 \001(\010\"j\n\024SetVaria"
641 "bleStatement\022:\n\021variable_metadata\030\001 \002(\0132"
642 "\037.drizzled.message.FieldMetadata\022\026\n\016vari"
643 "able_value\030\002 \002(\014\"\373\t\n\tStatement\022.\n\004type\030\001"
644 " \002(\0162 .drizzled.message.Statement.Type\022\027"
645 "\n\017start_timestamp\030\002 \002(\004\022\025\n\rend_timestamp"
646 "\030\003 \002(\004\022\013\n\003sql\030\004 \001(\t\0225\n\rinsert_header\030\005 \001"
647 "(\0132\036.drizzled.message.InsertHeader\0221\n\013in"
648 "sert_data\030\006 \001(\0132\034.drizzled.message.Inser"
649 "tData\0225\n\rupdate_header\030\007 \001(\0132\036.drizzled."
650 "message.UpdateHeader\0221\n\013update_data\030\010 \001("
651 "\0132\034.drizzled.message.UpdateData\0225\n\rdelet"
652 "e_header\030\t \001(\0132\036.drizzled.message.Delete"
653 "Header\0221\n\013delete_data\030\n \001(\0132\034.drizzled.m"
654 "essage.DeleteData\022J\n\030truncate_table_stat"
655 "ement\030\013 \001(\0132(.drizzled.message.TruncateT"
656 "ableStatement\022H\n\027create_schema_statement"
657 "\030\014 \001(\0132\'.drizzled.message.CreateSchemaSt"
658 "atement\022D\n\025drop_schema_statement\030\r \001(\0132%"
659 ".drizzled.message.DropSchemaStatement\022F\n"
660 "\026alter_schema_statement\030\016 \001(\0132&.drizzled"
661 ".message.AlterSchemaStatement\022F\n\026create_"
662 "table_statement\030\017 \001(\0132&.drizzled.message"
663 ".CreateTableStatement\022D\n\025alter_table_sta"
664 "tement\030\020 \001(\0132%.drizzled.message.AlterTab"
665 "leStatement\022B\n\024drop_table_statement\030\021 \001("
666 "\0132$.drizzled.message.DropTableStatement\022"
667 "F\n\026set_variable_statement\030\022 \001(\0132&.drizzl"
668 "ed.message.SetVariableStatement\022\026\n\016raw_s"
669 "ql_schema\030\023 \001(\t\"\354\001\n\004Type\022\014\n\010ROLLBACK\020\000\022\n"
670 "\n\006INSERT\020\001\022\n\n\006DELETE\020\002\022\n\n\006UPDATE\020\003\022\022\n\016TR"
671 "UNCATE_TABLE\020\004\022\021\n\rCREATE_SCHEMA\020\005\022\020\n\014ALT"
672 "ER_SCHEMA\020\006\022\017\n\013DROP_SCHEMA\020\007\022\020\n\014CREATE_T"
673 "ABLE\020\010\022\017\n\013ALTER_TABLE\020\t\022\016\n\nDROP_TABLE\020\n\022"
674 "\026\n\022ROLLBACK_STATEMENT\020\013\022\020\n\014SET_VARIABLE\020"
675 "b\022\013\n\007RAW_SQL\020c\"\321\001\n\013Transaction\022A\n\023transa"
676 "ction_context\030\001 \002(\0132$.drizzled.message.T"
677 "ransactionContext\022.\n\tstatement\030\002 \003(\0132\033.d"
678 "rizzled.message.Statement\022&\n\005event\030\003 \001(\013"
679 "2\027.drizzled.message.Event\022\022\n\nsegment_id\030"
680 "\004 \001(\r\022\023\n\013end_segment\030\005 \001(\010B,\n\024org.drizzl"
681 "e.messagesB\022TransactionMessageH\001", 3552);
682 ::google::protobuf::MessageFactory::InternalRegisterGeneratedFile(
683 "transaction.proto", &protobuf_RegisterTypes);
684 FieldMetadata::default_instance_ =
new FieldMetadata();
685 TableMetadata::default_instance_ =
new TableMetadata();
686 TransactionContext::default_instance_ =
new TransactionContext();
687 InsertRecord::default_instance_ =
new InsertRecord();
688 InsertHeader::default_instance_ =
new InsertHeader();
689 InsertData::default_instance_ =
new InsertData();
690 UpdateRecord::default_instance_ =
new UpdateRecord();
691 UpdateHeader::default_instance_ =
new UpdateHeader();
692 UpdateData::default_instance_ =
new UpdateData();
693 DeleteRecord::default_instance_ =
new DeleteRecord();
694 DeleteHeader::default_instance_ =
new DeleteHeader();
695 DeleteData::default_instance_ =
new DeleteData();
696 TruncateTableStatement::default_instance_ =
new TruncateTableStatement();
697 CreateSchemaStatement::default_instance_ =
new CreateSchemaStatement();
698 AlterSchemaStatement::default_instance_ =
new AlterSchemaStatement();
699 DropSchemaStatement::default_instance_ =
new DropSchemaStatement();
700 CreateTableStatement::default_instance_ =
new CreateTableStatement();
701 AlterTableStatement::default_instance_ =
new AlterTableStatement();
702 DropTableStatement::default_instance_ =
new DropTableStatement();
703 SetVariableStatement::default_instance_ =
new SetVariableStatement();
704 Statement::default_instance_ =
new Statement();
705 Transaction::default_instance_ =
new Transaction();
706 FieldMetadata::default_instance_->InitAsDefaultInstance();
707 TableMetadata::default_instance_->InitAsDefaultInstance();
708 TransactionContext::default_instance_->InitAsDefaultInstance();
709 InsertRecord::default_instance_->InitAsDefaultInstance();
710 InsertHeader::default_instance_->InitAsDefaultInstance();
711 InsertData::default_instance_->InitAsDefaultInstance();
712 UpdateRecord::default_instance_->InitAsDefaultInstance();
713 UpdateHeader::default_instance_->InitAsDefaultInstance();
714 UpdateData::default_instance_->InitAsDefaultInstance();
715 DeleteRecord::default_instance_->InitAsDefaultInstance();
716 DeleteHeader::default_instance_->InitAsDefaultInstance();
717 DeleteData::default_instance_->InitAsDefaultInstance();
718 TruncateTableStatement::default_instance_->InitAsDefaultInstance();
719 CreateSchemaStatement::default_instance_->InitAsDefaultInstance();
720 AlterSchemaStatement::default_instance_->InitAsDefaultInstance();
721 DropSchemaStatement::default_instance_->InitAsDefaultInstance();
722 CreateTableStatement::default_instance_->InitAsDefaultInstance();
723 AlterTableStatement::default_instance_->InitAsDefaultInstance();
724 DropTableStatement::default_instance_->InitAsDefaultInstance();
725 SetVariableStatement::default_instance_->InitAsDefaultInstance();
726 Statement::default_instance_->InitAsDefaultInstance();
727 Transaction::default_instance_->InitAsDefaultInstance();
728 ::google::protobuf::internal::OnShutdown(&protobuf_ShutdownFile_transaction_2eproto);
734 protobuf_AddDesc_transaction_2eproto();
736 } static_descriptor_initializer_transaction_2eproto_;
742 const int FieldMetadata::kTypeFieldNumber;
743 const int FieldMetadata::kNameFieldNumber;
746 FieldMetadata::FieldMetadata()
747 : ::google::protobuf::Message() {
751 void FieldMetadata::InitAsDefaultInstance() {
754 FieldMetadata::FieldMetadata(
const FieldMetadata& from)
755 : ::google::protobuf::Message() {
760 void FieldMetadata::SharedCtor() {
763 name_ =
const_cast< ::std::string*
>(&::google::protobuf::internal::kEmptyString);
764 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
767 FieldMetadata::~FieldMetadata() {
771 void FieldMetadata::SharedDtor() {
772 if (name_ != &::google::protobuf::internal::kEmptyString) {
775 if (
this != default_instance_) {
779 void FieldMetadata::SetCachedSize(
int size)
const {
780 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
781 _cached_size_ = size;
782 GOOGLE_SAFE_CONCURRENT_WRITES_END();
784 const ::google::protobuf::Descriptor* FieldMetadata::descriptor() {
785 protobuf_AssignDescriptorsOnce();
786 return FieldMetadata_descriptor_;
789 const FieldMetadata& FieldMetadata::default_instance() {
790 if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto();
return *default_instance_;
793 FieldMetadata* FieldMetadata::default_instance_ = NULL;
795 FieldMetadata* FieldMetadata::New()
const {
796 return new FieldMetadata;
799 void FieldMetadata::Clear() {
800 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
803 if (name_ != &::google::protobuf::internal::kEmptyString) {
808 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
809 mutable_unknown_fields()->Clear();
812 bool FieldMetadata::MergePartialFromCodedStream(
813 ::google::protobuf::io::CodedInputStream* input) {
814 #define DO_(EXPRESSION) if (!(EXPRESSION)) return false
815 ::google::protobuf::uint32 tag;
816 while ((tag = input->ReadTag()) != 0) {
817 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
820 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
821 ::google::protobuf::internal::WireFormatLite::WIRETYPE_VARINT) {
823 DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
824 int, ::google::protobuf::internal::WireFormatLite::TYPE_ENUM>(
826 if (::drizzled::message::Table_Field_FieldType_IsValid(value)) {
827 set_type(static_cast< ::drizzled::message::Table_Field_FieldType >(value));
829 mutable_unknown_fields()->AddVarint(1, value);
832 goto handle_uninterpreted;
834 if (input->ExpectTag(18))
goto parse_name;
840 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
841 ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
843 DO_(::google::protobuf::internal::WireFormatLite::ReadString(
844 input, this->mutable_name()));
845 ::google::protobuf::internal::WireFormat::VerifyUTF8String(
846 this->name().data(), this->name().length(),
847 ::google::protobuf::internal::WireFormat::PARSE);
849 goto handle_uninterpreted;
851 if (input->ExpectAtEnd())
return true;
856 handle_uninterpreted:
857 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
858 ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
861 DO_(::google::protobuf::internal::WireFormat::SkipField(
862 input, tag, mutable_unknown_fields()));
871 void FieldMetadata::SerializeWithCachedSizes(
872 ::google::protobuf::io::CodedOutputStream* output)
const {
875 ::google::protobuf::internal::WireFormatLite::WriteEnum(
876 1, this->type(), output);
881 ::google::protobuf::internal::WireFormat::VerifyUTF8String(
882 this->name().data(), this->name().length(),
883 ::google::protobuf::internal::WireFormat::SERIALIZE);
884 ::google::protobuf::internal::WireFormatLite::WriteString(
885 2, this->name(), output);
888 if (!unknown_fields().empty()) {
889 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
890 unknown_fields(), output);
894 ::google::protobuf::uint8* FieldMetadata::SerializeWithCachedSizesToArray(
895 ::google::protobuf::uint8* target)
const {
898 target = ::google::protobuf::internal::WireFormatLite::WriteEnumToArray(
899 1, this->type(), target);
904 ::google::protobuf::internal::WireFormat::VerifyUTF8String(
905 this->name().data(), this->name().length(),
906 ::google::protobuf::internal::WireFormat::SERIALIZE);
908 ::google::protobuf::internal::WireFormatLite::WriteStringToArray(
909 2, this->name(), target);
912 if (!unknown_fields().empty()) {
913 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
914 unknown_fields(), target);
919 int FieldMetadata::ByteSize()
const {
922 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
926 ::google::protobuf::internal::WireFormatLite::EnumSize(this->type());
932 ::google::protobuf::internal::WireFormatLite::StringSize(
937 if (!unknown_fields().empty()) {
939 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
942 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
943 _cached_size_ = total_size;
944 GOOGLE_SAFE_CONCURRENT_WRITES_END();
948 void FieldMetadata::MergeFrom(const ::google::protobuf::Message& from) {
949 GOOGLE_CHECK_NE(&from,
this);
950 const FieldMetadata* source =
951 ::google::protobuf::internal::dynamic_cast_if_available<const FieldMetadata*>(
953 if (source == NULL) {
954 ::google::protobuf::internal::ReflectionOps::Merge(from,
this);
960 void FieldMetadata::MergeFrom(
const FieldMetadata& from) {
961 GOOGLE_CHECK_NE(&from,
this);
962 if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
963 if (from.has_type()) {
964 set_type(from.type());
966 if (from.has_name()) {
967 set_name(from.name());
970 mutable_unknown_fields()->MergeFrom(from.unknown_fields());
973 void FieldMetadata::CopyFrom(const ::google::protobuf::Message& from) {
974 if (&from ==
this)
return;
979 void FieldMetadata::CopyFrom(
const FieldMetadata& from) {
980 if (&from ==
this)
return;
985 bool FieldMetadata::IsInitialized()
const {
986 if ((_has_bits_[0] & 0x00000003) != 0x00000003)
return false;
991 void FieldMetadata::Swap(FieldMetadata* other) {
993 std::swap(type_, other->type_);
994 std::swap(name_, other->name_);
995 std::swap(_has_bits_[0], other->_has_bits_[0]);
996 _unknown_fields_.Swap(&other->_unknown_fields_);
997 std::swap(_cached_size_, other->_cached_size_);
1001 ::google::protobuf::Metadata FieldMetadata::GetMetadata()
const {
1002 protobuf_AssignDescriptorsOnce();
1003 ::google::protobuf::Metadata metadata;
1004 metadata.descriptor = FieldMetadata_descriptor_;
1005 metadata.reflection = FieldMetadata_reflection_;
1013 const int TableMetadata::kSchemaNameFieldNumber;
1014 const int TableMetadata::kTableNameFieldNumber;
1015 const int TableMetadata::kCatalogNameFieldNumber;
1018 TableMetadata::TableMetadata()
1019 : ::google::protobuf::Message() {
1023 void TableMetadata::InitAsDefaultInstance() {
1026 TableMetadata::TableMetadata(
const TableMetadata& from)
1027 : ::google::protobuf::Message() {
1032 void TableMetadata::SharedCtor() {
1034 schema_name_ =
const_cast< ::std::string*
>(&::google::protobuf::internal::kEmptyString);
1035 table_name_ =
const_cast< ::std::string*
>(&::google::protobuf::internal::kEmptyString);
1036 catalog_name_ =
const_cast< ::std::string*
>(&::google::protobuf::internal::kEmptyString);
1037 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
1040 TableMetadata::~TableMetadata() {
1044 void TableMetadata::SharedDtor() {
1045 if (schema_name_ != &::google::protobuf::internal::kEmptyString) {
1046 delete schema_name_;
1048 if (table_name_ != &::google::protobuf::internal::kEmptyString) {
1051 if (catalog_name_ != &::google::protobuf::internal::kEmptyString) {
1052 delete catalog_name_;
1054 if (
this != default_instance_) {
1058 void TableMetadata::SetCachedSize(
int size)
const {
1059 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
1060 _cached_size_ = size;
1061 GOOGLE_SAFE_CONCURRENT_WRITES_END();
1063 const ::google::protobuf::Descriptor* TableMetadata::descriptor() {
1064 protobuf_AssignDescriptorsOnce();
1065 return TableMetadata_descriptor_;
1068 const TableMetadata& TableMetadata::default_instance() {
1069 if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto();
return *default_instance_;
1072 TableMetadata* TableMetadata::default_instance_ = NULL;
1074 TableMetadata* TableMetadata::New()
const {
1075 return new TableMetadata;
1078 void TableMetadata::Clear() {
1079 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
1080 if (has_schema_name()) {
1081 if (schema_name_ != &::google::protobuf::internal::kEmptyString) {
1082 schema_name_->clear();
1085 if (has_table_name()) {
1086 if (table_name_ != &::google::protobuf::internal::kEmptyString) {
1087 table_name_->clear();
1090 if (has_catalog_name()) {
1091 if (catalog_name_ != &::google::protobuf::internal::kEmptyString) {
1092 catalog_name_->clear();
1096 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
1097 mutable_unknown_fields()->Clear();
1100 bool TableMetadata::MergePartialFromCodedStream(
1101 ::google::protobuf::io::CodedInputStream* input) {
1102 #define DO_(EXPRESSION) if (!(EXPRESSION)) return false
1103 ::google::protobuf::uint32 tag;
1104 while ((tag = input->ReadTag()) != 0) {
1105 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
1108 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
1109 ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
1110 DO_(::google::protobuf::internal::WireFormatLite::ReadString(
1111 input, this->mutable_schema_name()));
1112 ::google::protobuf::internal::WireFormat::VerifyUTF8String(
1113 this->schema_name().data(), this->schema_name().length(),
1114 ::google::protobuf::internal::WireFormat::PARSE);
1116 goto handle_uninterpreted;
1118 if (input->ExpectTag(18))
goto parse_table_name;
1124 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
1125 ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
1127 DO_(::google::protobuf::internal::WireFormatLite::ReadString(
1128 input, this->mutable_table_name()));
1129 ::google::protobuf::internal::WireFormat::VerifyUTF8String(
1130 this->table_name().data(), this->table_name().length(),
1131 ::google::protobuf::internal::WireFormat::PARSE);
1133 goto handle_uninterpreted;
1135 if (input->ExpectTag(26))
goto parse_catalog_name;
1141 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
1142 ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
1144 DO_(::google::protobuf::internal::WireFormatLite::ReadString(
1145 input, this->mutable_catalog_name()));
1146 ::google::protobuf::internal::WireFormat::VerifyUTF8String(
1147 this->catalog_name().data(), this->catalog_name().length(),
1148 ::google::protobuf::internal::WireFormat::PARSE);
1150 goto handle_uninterpreted;
1152 if (input->ExpectAtEnd())
return true;
1157 handle_uninterpreted:
1158 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
1159 ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
1162 DO_(::google::protobuf::internal::WireFormat::SkipField(
1163 input, tag, mutable_unknown_fields()));
1172 void TableMetadata::SerializeWithCachedSizes(
1173 ::google::protobuf::io::CodedOutputStream* output)
const {
1175 if (has_schema_name()) {
1176 ::google::protobuf::internal::WireFormat::VerifyUTF8String(
1177 this->schema_name().data(), this->schema_name().length(),
1178 ::google::protobuf::internal::WireFormat::SERIALIZE);
1179 ::google::protobuf::internal::WireFormatLite::WriteString(
1180 1, this->schema_name(), output);
1184 if (has_table_name()) {
1185 ::google::protobuf::internal::WireFormat::VerifyUTF8String(
1186 this->table_name().data(), this->table_name().length(),
1187 ::google::protobuf::internal::WireFormat::SERIALIZE);
1188 ::google::protobuf::internal::WireFormatLite::WriteString(
1189 2, this->table_name(), output);
1193 if (has_catalog_name()) {
1194 ::google::protobuf::internal::WireFormat::VerifyUTF8String(
1195 this->catalog_name().data(), this->catalog_name().length(),
1196 ::google::protobuf::internal::WireFormat::SERIALIZE);
1197 ::google::protobuf::internal::WireFormatLite::WriteString(
1198 3, this->catalog_name(), output);
1201 if (!unknown_fields().empty()) {
1202 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
1203 unknown_fields(), output);
1207 ::google::protobuf::uint8* TableMetadata::SerializeWithCachedSizesToArray(
1208 ::google::protobuf::uint8* target)
const {
1210 if (has_schema_name()) {
1211 ::google::protobuf::internal::WireFormat::VerifyUTF8String(
1212 this->schema_name().data(), this->schema_name().length(),
1213 ::google::protobuf::internal::WireFormat::SERIALIZE);
1215 ::google::protobuf::internal::WireFormatLite::WriteStringToArray(
1216 1, this->schema_name(), target);
1220 if (has_table_name()) {
1221 ::google::protobuf::internal::WireFormat::VerifyUTF8String(
1222 this->table_name().data(), this->table_name().length(),
1223 ::google::protobuf::internal::WireFormat::SERIALIZE);
1225 ::google::protobuf::internal::WireFormatLite::WriteStringToArray(
1226 2, this->table_name(), target);
1230 if (has_catalog_name()) {
1231 ::google::protobuf::internal::WireFormat::VerifyUTF8String(
1232 this->catalog_name().data(), this->catalog_name().length(),
1233 ::google::protobuf::internal::WireFormat::SERIALIZE);
1235 ::google::protobuf::internal::WireFormatLite::WriteStringToArray(
1236 3, this->catalog_name(), target);
1239 if (!unknown_fields().empty()) {
1240 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
1241 unknown_fields(), target);
1246 int TableMetadata::ByteSize()
const {
1249 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
1251 if (has_schema_name()) {
1253 ::google::protobuf::internal::WireFormatLite::StringSize(
1254 this->schema_name());
1258 if (has_table_name()) {
1260 ::google::protobuf::internal::WireFormatLite::StringSize(
1261 this->table_name());
1265 if (has_catalog_name()) {
1267 ::google::protobuf::internal::WireFormatLite::StringSize(
1268 this->catalog_name());
1272 if (!unknown_fields().empty()) {
1274 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
1277 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
1278 _cached_size_ = total_size;
1279 GOOGLE_SAFE_CONCURRENT_WRITES_END();
1283 void TableMetadata::MergeFrom(const ::google::protobuf::Message& from) {
1284 GOOGLE_CHECK_NE(&from,
this);
1285 const TableMetadata* source =
1286 ::google::protobuf::internal::dynamic_cast_if_available<const TableMetadata*>(
1288 if (source == NULL) {
1289 ::google::protobuf::internal::ReflectionOps::Merge(from,
this);
1295 void TableMetadata::MergeFrom(
const TableMetadata& from) {
1296 GOOGLE_CHECK_NE(&from,
this);
1297 if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
1298 if (from.has_schema_name()) {
1299 set_schema_name(from.schema_name());
1301 if (from.has_table_name()) {
1302 set_table_name(from.table_name());
1304 if (from.has_catalog_name()) {
1305 set_catalog_name(from.catalog_name());
1308 mutable_unknown_fields()->MergeFrom(from.unknown_fields());
1311 void TableMetadata::CopyFrom(const ::google::protobuf::Message& from) {
1312 if (&from ==
this)
return;
1317 void TableMetadata::CopyFrom(
const TableMetadata& from) {
1318 if (&from ==
this)
return;
1323 bool TableMetadata::IsInitialized()
const {
1324 if ((_has_bits_[0] & 0x00000003) != 0x00000003)
return false;
1329 void TableMetadata::Swap(TableMetadata* other) {
1330 if (other !=
this) {
1331 std::swap(schema_name_, other->schema_name_);
1332 std::swap(table_name_, other->table_name_);
1333 std::swap(catalog_name_, other->catalog_name_);
1334 std::swap(_has_bits_[0], other->_has_bits_[0]);
1335 _unknown_fields_.Swap(&other->_unknown_fields_);
1336 std::swap(_cached_size_, other->_cached_size_);
1340 ::google::protobuf::Metadata TableMetadata::GetMetadata()
const {
1341 protobuf_AssignDescriptorsOnce();
1342 ::google::protobuf::Metadata metadata;
1343 metadata.descriptor = TableMetadata_descriptor_;
1344 metadata.reflection = TableMetadata_reflection_;
1352 const int TransactionContext::kServerIdFieldNumber;
1353 const int TransactionContext::kTransactionIdFieldNumber;
1354 const int TransactionContext::kStartTimestampFieldNumber;
1355 const int TransactionContext::kEndTimestampFieldNumber;
1358 TransactionContext::TransactionContext()
1359 : ::google::protobuf::Message() {
1363 void TransactionContext::InitAsDefaultInstance() {
1366 TransactionContext::TransactionContext(
const TransactionContext& from)
1367 : ::google::protobuf::Message() {
1372 void TransactionContext::SharedCtor() {
1375 transaction_id_ = GOOGLE_ULONGLONG(0);
1376 start_timestamp_ = GOOGLE_ULONGLONG(0);
1377 end_timestamp_ = GOOGLE_ULONGLONG(0);
1378 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
1381 TransactionContext::~TransactionContext() {
1385 void TransactionContext::SharedDtor() {
1386 if (
this != default_instance_) {
1390 void TransactionContext::SetCachedSize(
int size)
const {
1391 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
1392 _cached_size_ = size;
1393 GOOGLE_SAFE_CONCURRENT_WRITES_END();
1395 const ::google::protobuf::Descriptor* TransactionContext::descriptor() {
1396 protobuf_AssignDescriptorsOnce();
1397 return TransactionContext_descriptor_;
1400 const TransactionContext& TransactionContext::default_instance() {
1401 if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto();
return *default_instance_;
1404 TransactionContext* TransactionContext::default_instance_ = NULL;
1406 TransactionContext* TransactionContext::New()
const {
1407 return new TransactionContext;
1410 void TransactionContext::Clear() {
1411 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
1413 transaction_id_ = GOOGLE_ULONGLONG(0);
1414 start_timestamp_ = GOOGLE_ULONGLONG(0);
1415 end_timestamp_ = GOOGLE_ULONGLONG(0);
1417 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
1418 mutable_unknown_fields()->Clear();
1421 bool TransactionContext::MergePartialFromCodedStream(
1422 ::google::protobuf::io::CodedInputStream* input) {
1423 #define DO_(EXPRESSION) if (!(EXPRESSION)) return false
1424 ::google::protobuf::uint32 tag;
1425 while ((tag = input->ReadTag()) != 0) {
1426 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
1429 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
1430 ::google::protobuf::internal::WireFormatLite::WIRETYPE_VARINT) {
1431 DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
1432 ::google::protobuf::uint32, ::google::protobuf::internal::WireFormatLite::TYPE_UINT32>(
1433 input, &server_id_)));
1434 set_has_server_id();
1436 goto handle_uninterpreted;
1438 if (input->ExpectTag(16))
goto parse_transaction_id;
1444 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
1445 ::google::protobuf::internal::WireFormatLite::WIRETYPE_VARINT) {
1446 parse_transaction_id:
1447 DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
1448 ::google::protobuf::uint64, ::google::protobuf::internal::WireFormatLite::TYPE_UINT64>(
1449 input, &transaction_id_)));
1450 set_has_transaction_id();
1452 goto handle_uninterpreted;
1454 if (input->ExpectTag(24))
goto parse_start_timestamp;
1460 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
1461 ::google::protobuf::internal::WireFormatLite::WIRETYPE_VARINT) {
1462 parse_start_timestamp:
1463 DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
1464 ::google::protobuf::uint64, ::google::protobuf::internal::WireFormatLite::TYPE_UINT64>(
1465 input, &start_timestamp_)));
1466 set_has_start_timestamp();
1468 goto handle_uninterpreted;
1470 if (input->ExpectTag(32))
goto parse_end_timestamp;
1476 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
1477 ::google::protobuf::internal::WireFormatLite::WIRETYPE_VARINT) {
1478 parse_end_timestamp:
1479 DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
1480 ::google::protobuf::uint64, ::google::protobuf::internal::WireFormatLite::TYPE_UINT64>(
1481 input, &end_timestamp_)));
1482 set_has_end_timestamp();
1484 goto handle_uninterpreted;
1486 if (input->ExpectAtEnd())
return true;
1491 handle_uninterpreted:
1492 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
1493 ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
1496 DO_(::google::protobuf::internal::WireFormat::SkipField(
1497 input, tag, mutable_unknown_fields()));
1506 void TransactionContext::SerializeWithCachedSizes(
1507 ::google::protobuf::io::CodedOutputStream* output)
const {
1509 if (has_server_id()) {
1510 ::google::protobuf::internal::WireFormatLite::WriteUInt32(1, this->server_id(), output);
1514 if (has_transaction_id()) {
1515 ::google::protobuf::internal::WireFormatLite::WriteUInt64(2, this->transaction_id(), output);
1519 if (has_start_timestamp()) {
1520 ::google::protobuf::internal::WireFormatLite::WriteUInt64(3, this->start_timestamp(), output);
1524 if (has_end_timestamp()) {
1525 ::google::protobuf::internal::WireFormatLite::WriteUInt64(4, this->end_timestamp(), output);
1528 if (!unknown_fields().empty()) {
1529 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
1530 unknown_fields(), output);
1534 ::google::protobuf::uint8* TransactionContext::SerializeWithCachedSizesToArray(
1535 ::google::protobuf::uint8* target)
const {
1537 if (has_server_id()) {
1538 target = ::google::protobuf::internal::WireFormatLite::WriteUInt32ToArray(1, this->server_id(), target);
1542 if (has_transaction_id()) {
1543 target = ::google::protobuf::internal::WireFormatLite::WriteUInt64ToArray(2, this->transaction_id(), target);
1547 if (has_start_timestamp()) {
1548 target = ::google::protobuf::internal::WireFormatLite::WriteUInt64ToArray(3, this->start_timestamp(), target);
1552 if (has_end_timestamp()) {
1553 target = ::google::protobuf::internal::WireFormatLite::WriteUInt64ToArray(4, this->end_timestamp(), target);
1556 if (!unknown_fields().empty()) {
1557 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
1558 unknown_fields(), target);
1563 int TransactionContext::ByteSize()
const {
1566 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
1568 if (has_server_id()) {
1570 ::google::protobuf::internal::WireFormatLite::UInt32Size(
1575 if (has_transaction_id()) {
1577 ::google::protobuf::internal::WireFormatLite::UInt64Size(
1578 this->transaction_id());
1582 if (has_start_timestamp()) {
1584 ::google::protobuf::internal::WireFormatLite::UInt64Size(
1585 this->start_timestamp());
1589 if (has_end_timestamp()) {
1591 ::google::protobuf::internal::WireFormatLite::UInt64Size(
1592 this->end_timestamp());
1596 if (!unknown_fields().empty()) {
1598 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
1601 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
1602 _cached_size_ = total_size;
1603 GOOGLE_SAFE_CONCURRENT_WRITES_END();
1607 void TransactionContext::MergeFrom(const ::google::protobuf::Message& from) {
1608 GOOGLE_CHECK_NE(&from,
this);
1609 const TransactionContext* source =
1610 ::google::protobuf::internal::dynamic_cast_if_available<const TransactionContext*>(
1612 if (source == NULL) {
1613 ::google::protobuf::internal::ReflectionOps::Merge(from,
this);
1619 void TransactionContext::MergeFrom(
const TransactionContext& from) {
1620 GOOGLE_CHECK_NE(&from,
this);
1621 if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
1622 if (from.has_server_id()) {
1623 set_server_id(from.server_id());
1625 if (from.has_transaction_id()) {
1626 set_transaction_id(from.transaction_id());
1628 if (from.has_start_timestamp()) {
1629 set_start_timestamp(from.start_timestamp());
1631 if (from.has_end_timestamp()) {
1632 set_end_timestamp(from.end_timestamp());
1635 mutable_unknown_fields()->MergeFrom(from.unknown_fields());
1638 void TransactionContext::CopyFrom(const ::google::protobuf::Message& from) {
1639 if (&from ==
this)
return;
1644 void TransactionContext::CopyFrom(
const TransactionContext& from) {
1645 if (&from ==
this)
return;
1650 bool TransactionContext::IsInitialized()
const {
1651 if ((_has_bits_[0] & 0x0000000f) != 0x0000000f)
return false;
1656 void TransactionContext::Swap(TransactionContext* other) {
1657 if (other !=
this) {
1658 std::swap(server_id_, other->server_id_);
1659 std::swap(transaction_id_, other->transaction_id_);
1660 std::swap(start_timestamp_, other->start_timestamp_);
1661 std::swap(end_timestamp_, other->end_timestamp_);
1662 std::swap(_has_bits_[0], other->_has_bits_[0]);
1663 _unknown_fields_.Swap(&other->_unknown_fields_);
1664 std::swap(_cached_size_, other->_cached_size_);
1668 ::google::protobuf::Metadata TransactionContext::GetMetadata()
const {
1669 protobuf_AssignDescriptorsOnce();
1670 ::google::protobuf::Metadata metadata;
1671 metadata.descriptor = TransactionContext_descriptor_;
1672 metadata.reflection = TransactionContext_reflection_;
1680 const int InsertRecord::kInsertValueFieldNumber;
1681 const int InsertRecord::kIsNullFieldNumber;
1684 InsertRecord::InsertRecord()
1685 : ::google::protobuf::Message() {
1689 void InsertRecord::InitAsDefaultInstance() {
1692 InsertRecord::InsertRecord(
const InsertRecord& from)
1693 : ::google::protobuf::Message() {
1698 void InsertRecord::SharedCtor() {
1700 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
1703 InsertRecord::~InsertRecord() {
1707 void InsertRecord::SharedDtor() {
1708 if (
this != default_instance_) {
1712 void InsertRecord::SetCachedSize(
int size)
const {
1713 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
1714 _cached_size_ = size;
1715 GOOGLE_SAFE_CONCURRENT_WRITES_END();
1717 const ::google::protobuf::Descriptor* InsertRecord::descriptor() {
1718 protobuf_AssignDescriptorsOnce();
1719 return InsertRecord_descriptor_;
1722 const InsertRecord& InsertRecord::default_instance() {
1723 if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto();
return *default_instance_;
1726 InsertRecord* InsertRecord::default_instance_ = NULL;
1728 InsertRecord* InsertRecord::New()
const {
1729 return new InsertRecord;
1732 void InsertRecord::Clear() {
1733 insert_value_.Clear();
1735 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
1736 mutable_unknown_fields()->Clear();
1739 bool InsertRecord::MergePartialFromCodedStream(
1740 ::google::protobuf::io::CodedInputStream* input) {
1741 #define DO_(EXPRESSION) if (!(EXPRESSION)) return false
1742 ::google::protobuf::uint32 tag;
1743 while ((tag = input->ReadTag()) != 0) {
1744 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
1747 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
1748 ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
1750 DO_(::google::protobuf::internal::WireFormatLite::ReadBytes(
1751 input, this->add_insert_value()));
1753 goto handle_uninterpreted;
1755 if (input->ExpectTag(10))
goto parse_insert_value;
1756 if (input->ExpectTag(16))
goto parse_is_null;
1762 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
1763 ::google::protobuf::internal::WireFormatLite::WIRETYPE_VARINT) {
1765 DO_((::google::protobuf::internal::WireFormatLite::ReadRepeatedPrimitive<
1766 bool, ::google::protobuf::internal::WireFormatLite::TYPE_BOOL>(
1767 1, 16, input, this->mutable_is_null())));
1768 }
else if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag)
1769 == ::google::protobuf::internal::WireFormatLite::
1770 WIRETYPE_LENGTH_DELIMITED) {
1771 DO_((::google::protobuf::internal::WireFormatLite::ReadPackedPrimitiveNoInline<
1772 bool, ::google::protobuf::internal::WireFormatLite::TYPE_BOOL>(
1773 input, this->mutable_is_null())));
1775 goto handle_uninterpreted;
1777 if (input->ExpectTag(16))
goto parse_is_null;
1778 if (input->ExpectAtEnd())
return true;
1783 handle_uninterpreted:
1784 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
1785 ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
1788 DO_(::google::protobuf::internal::WireFormat::SkipField(
1789 input, tag, mutable_unknown_fields()));
1798 void InsertRecord::SerializeWithCachedSizes(
1799 ::google::protobuf::io::CodedOutputStream* output)
const {
1801 for (
int i = 0; i < this->insert_value_size(); i++) {
1802 ::google::protobuf::internal::WireFormatLite::WriteBytes(
1803 1, this->insert_value(i), output);
1807 for (
int i = 0; i < this->is_null_size(); i++) {
1808 ::google::protobuf::internal::WireFormatLite::WriteBool(
1809 2, this->is_null(i), output);
1812 if (!unknown_fields().empty()) {
1813 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
1814 unknown_fields(), output);
1818 ::google::protobuf::uint8* InsertRecord::SerializeWithCachedSizesToArray(
1819 ::google::protobuf::uint8* target)
const {
1821 for (
int i = 0; i < this->insert_value_size(); i++) {
1822 target = ::google::protobuf::internal::WireFormatLite::
1823 WriteBytesToArray(1, this->insert_value(i), target);
1827 for (
int i = 0; i < this->is_null_size(); i++) {
1828 target = ::google::protobuf::internal::WireFormatLite::
1829 WriteBoolToArray(2, this->is_null(i), target);
1832 if (!unknown_fields().empty()) {
1833 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
1834 unknown_fields(), target);
1839 int InsertRecord::ByteSize()
const {
1843 total_size += 1 * this->insert_value_size();
1844 for (
int i = 0; i < this->insert_value_size(); i++) {
1845 total_size += ::google::protobuf::internal::WireFormatLite::BytesSize(
1846 this->insert_value(i));
1852 data_size = 1 * this->is_null_size();
1853 total_size += 1 * this->is_null_size() + data_size;
1856 if (!unknown_fields().empty()) {
1858 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
1861 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
1862 _cached_size_ = total_size;
1863 GOOGLE_SAFE_CONCURRENT_WRITES_END();
1867 void InsertRecord::MergeFrom(const ::google::protobuf::Message& from) {
1868 GOOGLE_CHECK_NE(&from,
this);
1869 const InsertRecord* source =
1870 ::google::protobuf::internal::dynamic_cast_if_available<const InsertRecord*>(
1872 if (source == NULL) {
1873 ::google::protobuf::internal::ReflectionOps::Merge(from,
this);
1879 void InsertRecord::MergeFrom(
const InsertRecord& from) {
1880 GOOGLE_CHECK_NE(&from,
this);
1881 insert_value_.MergeFrom(from.insert_value_);
1882 is_null_.MergeFrom(from.is_null_);
1883 mutable_unknown_fields()->MergeFrom(from.unknown_fields());
1886 void InsertRecord::CopyFrom(const ::google::protobuf::Message& from) {
1887 if (&from ==
this)
return;
1892 void InsertRecord::CopyFrom(
const InsertRecord& from) {
1893 if (&from ==
this)
return;
1898 bool InsertRecord::IsInitialized()
const {
1903 void InsertRecord::Swap(InsertRecord* other) {
1904 if (other !=
this) {
1905 insert_value_.Swap(&other->insert_value_);
1906 is_null_.Swap(&other->is_null_);
1907 std::swap(_has_bits_[0], other->_has_bits_[0]);
1908 _unknown_fields_.Swap(&other->_unknown_fields_);
1909 std::swap(_cached_size_, other->_cached_size_);
1913 ::google::protobuf::Metadata InsertRecord::GetMetadata()
const {
1914 protobuf_AssignDescriptorsOnce();
1915 ::google::protobuf::Metadata metadata;
1916 metadata.descriptor = InsertRecord_descriptor_;
1917 metadata.reflection = InsertRecord_reflection_;
1925 const int InsertHeader::kTableMetadataFieldNumber;
1926 const int InsertHeader::kFieldMetadataFieldNumber;
1929 InsertHeader::InsertHeader()
1930 : ::google::protobuf::Message() {
1934 void InsertHeader::InitAsDefaultInstance() {
1938 InsertHeader::InsertHeader(
const InsertHeader& from)
1939 : ::google::protobuf::Message() {
1944 void InsertHeader::SharedCtor() {
1946 table_metadata_ = NULL;
1947 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
1950 InsertHeader::~InsertHeader() {
1954 void InsertHeader::SharedDtor() {
1955 if (
this != default_instance_) {
1956 delete table_metadata_;
1960 void InsertHeader::SetCachedSize(
int size)
const {
1961 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
1962 _cached_size_ = size;
1963 GOOGLE_SAFE_CONCURRENT_WRITES_END();
1965 const ::google::protobuf::Descriptor* InsertHeader::descriptor() {
1966 protobuf_AssignDescriptorsOnce();
1967 return InsertHeader_descriptor_;
1970 const InsertHeader& InsertHeader::default_instance() {
1971 if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto();
return *default_instance_;
1974 InsertHeader* InsertHeader::default_instance_ = NULL;
1976 InsertHeader* InsertHeader::New()
const {
1977 return new InsertHeader;
1980 void InsertHeader::Clear() {
1981 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
1982 if (has_table_metadata()) {
1983 if (table_metadata_ != NULL) table_metadata_->::drizzled::message::TableMetadata::Clear();
1986 field_metadata_.Clear();
1987 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
1988 mutable_unknown_fields()->Clear();
1991 bool InsertHeader::MergePartialFromCodedStream(
1992 ::google::protobuf::io::CodedInputStream* input) {
1993 #define DO_(EXPRESSION) if (!(EXPRESSION)) return false
1994 ::google::protobuf::uint32 tag;
1995 while ((tag = input->ReadTag()) != 0) {
1996 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
1999 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
2000 ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
2001 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
2002 input, mutable_table_metadata()));
2004 goto handle_uninterpreted;
2006 if (input->ExpectTag(18))
goto parse_field_metadata;
2012 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
2013 ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
2014 parse_field_metadata:
2015 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
2016 input, add_field_metadata()));
2018 goto handle_uninterpreted;
2020 if (input->ExpectTag(18))
goto parse_field_metadata;
2021 if (input->ExpectAtEnd())
return true;
2026 handle_uninterpreted:
2027 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
2028 ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
2031 DO_(::google::protobuf::internal::WireFormat::SkipField(
2032 input, tag, mutable_unknown_fields()));
2041 void InsertHeader::SerializeWithCachedSizes(
2042 ::google::protobuf::io::CodedOutputStream* output)
const {
2044 if (has_table_metadata()) {
2045 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
2046 1, this->table_metadata(), output);
2050 for (
int i = 0; i < this->field_metadata_size(); i++) {
2051 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
2052 2, this->field_metadata(i), output);
2055 if (!unknown_fields().empty()) {
2056 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
2057 unknown_fields(), output);
2061 ::google::protobuf::uint8* InsertHeader::SerializeWithCachedSizesToArray(
2062 ::google::protobuf::uint8* target)
const {
2064 if (has_table_metadata()) {
2065 target = ::google::protobuf::internal::WireFormatLite::
2066 WriteMessageNoVirtualToArray(
2067 1, this->table_metadata(), target);
2071 for (
int i = 0; i < this->field_metadata_size(); i++) {
2072 target = ::google::protobuf::internal::WireFormatLite::
2073 WriteMessageNoVirtualToArray(
2074 2, this->field_metadata(i), target);
2077 if (!unknown_fields().empty()) {
2078 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
2079 unknown_fields(), target);
2084 int InsertHeader::ByteSize()
const {
2087 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
2089 if (has_table_metadata()) {
2091 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
2092 this->table_metadata());
2097 total_size += 1 * this->field_metadata_size();
2098 for (
int i = 0; i < this->field_metadata_size(); i++) {
2100 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
2101 this->field_metadata(i));
2104 if (!unknown_fields().empty()) {
2106 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
2109 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
2110 _cached_size_ = total_size;
2111 GOOGLE_SAFE_CONCURRENT_WRITES_END();
2115 void InsertHeader::MergeFrom(const ::google::protobuf::Message& from) {
2116 GOOGLE_CHECK_NE(&from,
this);
2117 const InsertHeader* source =
2118 ::google::protobuf::internal::dynamic_cast_if_available<const InsertHeader*>(
2120 if (source == NULL) {
2121 ::google::protobuf::internal::ReflectionOps::Merge(from,
this);
2127 void InsertHeader::MergeFrom(
const InsertHeader& from) {
2128 GOOGLE_CHECK_NE(&from,
this);
2129 field_metadata_.MergeFrom(from.field_metadata_);
2130 if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
2131 if (from.has_table_metadata()) {
2132 mutable_table_metadata()->::drizzled::message::TableMetadata::MergeFrom(from.table_metadata());
2135 mutable_unknown_fields()->MergeFrom(from.unknown_fields());
2138 void InsertHeader::CopyFrom(const ::google::protobuf::Message& from) {
2139 if (&from ==
this)
return;
2144 void InsertHeader::CopyFrom(
const InsertHeader& from) {
2145 if (&from ==
this)
return;
2150 bool InsertHeader::IsInitialized()
const {
2151 if ((_has_bits_[0] & 0x00000001) != 0x00000001)
return false;
2153 if (has_table_metadata()) {
2154 if (!this->table_metadata().IsInitialized())
return false;
2156 for (
int i = 0; i < field_metadata_size(); i++) {
2157 if (!this->field_metadata(i).IsInitialized())
return false;
2162 void InsertHeader::Swap(InsertHeader* other) {
2163 if (other !=
this) {
2164 std::swap(table_metadata_, other->table_metadata_);
2165 field_metadata_.Swap(&other->field_metadata_);
2166 std::swap(_has_bits_[0], other->_has_bits_[0]);
2167 _unknown_fields_.Swap(&other->_unknown_fields_);
2168 std::swap(_cached_size_, other->_cached_size_);
2172 ::google::protobuf::Metadata InsertHeader::GetMetadata()
const {
2173 protobuf_AssignDescriptorsOnce();
2174 ::google::protobuf::Metadata metadata;
2175 metadata.descriptor = InsertHeader_descriptor_;
2176 metadata.reflection = InsertHeader_reflection_;
2184 const int InsertData::kSegmentIdFieldNumber;
2185 const int InsertData::kEndSegmentFieldNumber;
2186 const int InsertData::kRecordFieldNumber;
2189 InsertData::InsertData()
2190 : ::google::protobuf::Message() {
2194 void InsertData::InitAsDefaultInstance() {
2197 InsertData::InsertData(
const InsertData& from)
2198 : ::google::protobuf::Message() {
2203 void InsertData::SharedCtor() {
2206 end_segment_ =
false;
2207 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
2210 InsertData::~InsertData() {
2214 void InsertData::SharedDtor() {
2215 if (
this != default_instance_) {
2219 void InsertData::SetCachedSize(
int size)
const {
2220 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
2221 _cached_size_ = size;
2222 GOOGLE_SAFE_CONCURRENT_WRITES_END();
2224 const ::google::protobuf::Descriptor* InsertData::descriptor() {
2225 protobuf_AssignDescriptorsOnce();
2226 return InsertData_descriptor_;
2229 const InsertData& InsertData::default_instance() {
2230 if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto();
return *default_instance_;
2233 InsertData* InsertData::default_instance_ = NULL;
2235 InsertData* InsertData::New()
const {
2236 return new InsertData;
2239 void InsertData::Clear() {
2240 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
2242 end_segment_ =
false;
2245 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
2246 mutable_unknown_fields()->Clear();
2249 bool InsertData::MergePartialFromCodedStream(
2250 ::google::protobuf::io::CodedInputStream* input) {
2251 #define DO_(EXPRESSION) if (!(EXPRESSION)) return false
2252 ::google::protobuf::uint32 tag;
2253 while ((tag = input->ReadTag()) != 0) {
2254 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
2257 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
2258 ::google::protobuf::internal::WireFormatLite::WIRETYPE_VARINT) {
2259 DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
2260 ::google::protobuf::uint32, ::google::protobuf::internal::WireFormatLite::TYPE_UINT32>(
2261 input, &segment_id_)));
2262 set_has_segment_id();
2264 goto handle_uninterpreted;
2266 if (input->ExpectTag(16))
goto parse_end_segment;
2272 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
2273 ::google::protobuf::internal::WireFormatLite::WIRETYPE_VARINT) {
2275 DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
2276 bool, ::google::protobuf::internal::WireFormatLite::TYPE_BOOL>(
2277 input, &end_segment_)));
2278 set_has_end_segment();
2280 goto handle_uninterpreted;
2282 if (input->ExpectTag(26))
goto parse_record;
2288 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
2289 ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
2291 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
2292 input, add_record()));
2294 goto handle_uninterpreted;
2296 if (input->ExpectTag(26))
goto parse_record;
2297 if (input->ExpectAtEnd())
return true;
2302 handle_uninterpreted:
2303 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
2304 ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
2307 DO_(::google::protobuf::internal::WireFormat::SkipField(
2308 input, tag, mutable_unknown_fields()));
2317 void InsertData::SerializeWithCachedSizes(
2318 ::google::protobuf::io::CodedOutputStream* output)
const {
2320 if (has_segment_id()) {
2321 ::google::protobuf::internal::WireFormatLite::WriteUInt32(1, this->segment_id(), output);
2325 if (has_end_segment()) {
2326 ::google::protobuf::internal::WireFormatLite::WriteBool(2, this->end_segment(), output);
2330 for (
int i = 0; i < this->record_size(); i++) {
2331 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
2332 3, this->record(i), output);
2335 if (!unknown_fields().empty()) {
2336 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
2337 unknown_fields(), output);
2341 ::google::protobuf::uint8* InsertData::SerializeWithCachedSizesToArray(
2342 ::google::protobuf::uint8* target)
const {
2344 if (has_segment_id()) {
2345 target = ::google::protobuf::internal::WireFormatLite::WriteUInt32ToArray(1, this->segment_id(), target);
2349 if (has_end_segment()) {
2350 target = ::google::protobuf::internal::WireFormatLite::WriteBoolToArray(2, this->end_segment(), target);
2354 for (
int i = 0; i < this->record_size(); i++) {
2355 target = ::google::protobuf::internal::WireFormatLite::
2356 WriteMessageNoVirtualToArray(
2357 3, this->record(i), target);
2360 if (!unknown_fields().empty()) {
2361 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
2362 unknown_fields(), target);
2367 int InsertData::ByteSize()
const {
2370 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
2372 if (has_segment_id()) {
2374 ::google::protobuf::internal::WireFormatLite::UInt32Size(
2375 this->segment_id());
2379 if (has_end_segment()) {
2380 total_size += 1 + 1;
2385 total_size += 1 * this->record_size();
2386 for (
int i = 0; i < this->record_size(); i++) {
2388 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
2392 if (!unknown_fields().empty()) {
2394 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
2397 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
2398 _cached_size_ = total_size;
2399 GOOGLE_SAFE_CONCURRENT_WRITES_END();
2403 void InsertData::MergeFrom(const ::google::protobuf::Message& from) {
2404 GOOGLE_CHECK_NE(&from,
this);
2405 const InsertData* source =
2406 ::google::protobuf::internal::dynamic_cast_if_available<const InsertData*>(
2408 if (source == NULL) {
2409 ::google::protobuf::internal::ReflectionOps::Merge(from,
this);
2415 void InsertData::MergeFrom(
const InsertData& from) {
2416 GOOGLE_CHECK_NE(&from,
this);
2417 record_.MergeFrom(from.record_);
2418 if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
2419 if (from.has_segment_id()) {
2420 set_segment_id(from.segment_id());
2422 if (from.has_end_segment()) {
2423 set_end_segment(from.end_segment());
2426 mutable_unknown_fields()->MergeFrom(from.unknown_fields());
2429 void InsertData::CopyFrom(const ::google::protobuf::Message& from) {
2430 if (&from ==
this)
return;
2435 void InsertData::CopyFrom(
const InsertData& from) {
2436 if (&from ==
this)
return;
2441 bool InsertData::IsInitialized()
const {
2442 if ((_has_bits_[0] & 0x00000003) != 0x00000003)
return false;
2447 void InsertData::Swap(InsertData* other) {
2448 if (other !=
this) {
2449 std::swap(segment_id_, other->segment_id_);
2450 std::swap(end_segment_, other->end_segment_);
2451 record_.Swap(&other->record_);
2452 std::swap(_has_bits_[0], other->_has_bits_[0]);
2453 _unknown_fields_.Swap(&other->_unknown_fields_);
2454 std::swap(_cached_size_, other->_cached_size_);
2458 ::google::protobuf::Metadata InsertData::GetMetadata()
const {
2459 protobuf_AssignDescriptorsOnce();
2460 ::google::protobuf::Metadata metadata;
2461 metadata.descriptor = InsertData_descriptor_;
2462 metadata.reflection = InsertData_reflection_;
2470 const int UpdateRecord::kKeyValueFieldNumber;
2471 const int UpdateRecord::kAfterValueFieldNumber;
2472 const int UpdateRecord::kBeforeValueFieldNumber;
2473 const int UpdateRecord::kIsNullFieldNumber;
2476 UpdateRecord::UpdateRecord()
2477 : ::google::protobuf::Message() {
2481 void UpdateRecord::InitAsDefaultInstance() {
2484 UpdateRecord::UpdateRecord(
const UpdateRecord& from)
2485 : ::google::protobuf::Message() {
2490 void UpdateRecord::SharedCtor() {
2492 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
2495 UpdateRecord::~UpdateRecord() {
2499 void UpdateRecord::SharedDtor() {
2500 if (
this != default_instance_) {
2504 void UpdateRecord::SetCachedSize(
int size)
const {
2505 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
2506 _cached_size_ = size;
2507 GOOGLE_SAFE_CONCURRENT_WRITES_END();
2509 const ::google::protobuf::Descriptor* UpdateRecord::descriptor() {
2510 protobuf_AssignDescriptorsOnce();
2511 return UpdateRecord_descriptor_;
2514 const UpdateRecord& UpdateRecord::default_instance() {
2515 if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto();
return *default_instance_;
2518 UpdateRecord* UpdateRecord::default_instance_ = NULL;
2520 UpdateRecord* UpdateRecord::New()
const {
2521 return new UpdateRecord;
2524 void UpdateRecord::Clear() {
2526 after_value_.Clear();
2527 before_value_.Clear();
2529 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
2530 mutable_unknown_fields()->Clear();
2533 bool UpdateRecord::MergePartialFromCodedStream(
2534 ::google::protobuf::io::CodedInputStream* input) {
2535 #define DO_(EXPRESSION) if (!(EXPRESSION)) return false
2536 ::google::protobuf::uint32 tag;
2537 while ((tag = input->ReadTag()) != 0) {
2538 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
2541 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
2542 ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
2544 DO_(::google::protobuf::internal::WireFormatLite::ReadBytes(
2545 input, this->add_key_value()));
2547 goto handle_uninterpreted;
2549 if (input->ExpectTag(10))
goto parse_key_value;
2550 if (input->ExpectTag(18))
goto parse_after_value;
2556 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
2557 ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
2559 DO_(::google::protobuf::internal::WireFormatLite::ReadBytes(
2560 input, this->add_after_value()));
2562 goto handle_uninterpreted;
2564 if (input->ExpectTag(18))
goto parse_after_value;
2565 if (input->ExpectTag(26))
goto parse_before_value;
2571 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
2572 ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
2574 DO_(::google::protobuf::internal::WireFormatLite::ReadBytes(
2575 input, this->add_before_value()));
2577 goto handle_uninterpreted;
2579 if (input->ExpectTag(26))
goto parse_before_value;
2580 if (input->ExpectTag(32))
goto parse_is_null;
2586 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
2587 ::google::protobuf::internal::WireFormatLite::WIRETYPE_VARINT) {
2589 DO_((::google::protobuf::internal::WireFormatLite::ReadRepeatedPrimitive<
2590 bool, ::google::protobuf::internal::WireFormatLite::TYPE_BOOL>(
2591 1, 32, input, this->mutable_is_null())));
2592 }
else if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag)
2593 == ::google::protobuf::internal::WireFormatLite::
2594 WIRETYPE_LENGTH_DELIMITED) {
2595 DO_((::google::protobuf::internal::WireFormatLite::ReadPackedPrimitiveNoInline<
2596 bool, ::google::protobuf::internal::WireFormatLite::TYPE_BOOL>(
2597 input, this->mutable_is_null())));
2599 goto handle_uninterpreted;
2601 if (input->ExpectTag(32))
goto parse_is_null;
2602 if (input->ExpectAtEnd())
return true;
2607 handle_uninterpreted:
2608 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
2609 ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
2612 DO_(::google::protobuf::internal::WireFormat::SkipField(
2613 input, tag, mutable_unknown_fields()));
2622 void UpdateRecord::SerializeWithCachedSizes(
2623 ::google::protobuf::io::CodedOutputStream* output)
const {
2625 for (
int i = 0; i < this->key_value_size(); i++) {
2626 ::google::protobuf::internal::WireFormatLite::WriteBytes(
2627 1, this->key_value(i), output);
2631 for (
int i = 0; i < this->after_value_size(); i++) {
2632 ::google::protobuf::internal::WireFormatLite::WriteBytes(
2633 2, this->after_value(i), output);
2637 for (
int i = 0; i < this->before_value_size(); i++) {
2638 ::google::protobuf::internal::WireFormatLite::WriteBytes(
2639 3, this->before_value(i), output);
2643 for (
int i = 0; i < this->is_null_size(); i++) {
2644 ::google::protobuf::internal::WireFormatLite::WriteBool(
2645 4, this->is_null(i), output);
2648 if (!unknown_fields().empty()) {
2649 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
2650 unknown_fields(), output);
2654 ::google::protobuf::uint8* UpdateRecord::SerializeWithCachedSizesToArray(
2655 ::google::protobuf::uint8* target)
const {
2657 for (
int i = 0; i < this->key_value_size(); i++) {
2658 target = ::google::protobuf::internal::WireFormatLite::
2659 WriteBytesToArray(1, this->key_value(i), target);
2663 for (
int i = 0; i < this->after_value_size(); i++) {
2664 target = ::google::protobuf::internal::WireFormatLite::
2665 WriteBytesToArray(2, this->after_value(i), target);
2669 for (
int i = 0; i < this->before_value_size(); i++) {
2670 target = ::google::protobuf::internal::WireFormatLite::
2671 WriteBytesToArray(3, this->before_value(i), target);
2675 for (
int i = 0; i < this->is_null_size(); i++) {
2676 target = ::google::protobuf::internal::WireFormatLite::
2677 WriteBoolToArray(4, this->is_null(i), target);
2680 if (!unknown_fields().empty()) {
2681 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
2682 unknown_fields(), target);
2687 int UpdateRecord::ByteSize()
const {
2691 total_size += 1 * this->key_value_size();
2692 for (
int i = 0; i < this->key_value_size(); i++) {
2693 total_size += ::google::protobuf::internal::WireFormatLite::BytesSize(
2694 this->key_value(i));
2698 total_size += 1 * this->after_value_size();
2699 for (
int i = 0; i < this->after_value_size(); i++) {
2700 total_size += ::google::protobuf::internal::WireFormatLite::BytesSize(
2701 this->after_value(i));
2705 total_size += 1 * this->before_value_size();
2706 for (
int i = 0; i < this->before_value_size(); i++) {
2707 total_size += ::google::protobuf::internal::WireFormatLite::BytesSize(
2708 this->before_value(i));
2714 data_size = 1 * this->is_null_size();
2715 total_size += 1 * this->is_null_size() + data_size;
2718 if (!unknown_fields().empty()) {
2720 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
2723 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
2724 _cached_size_ = total_size;
2725 GOOGLE_SAFE_CONCURRENT_WRITES_END();
2729 void UpdateRecord::MergeFrom(const ::google::protobuf::Message& from) {
2730 GOOGLE_CHECK_NE(&from,
this);
2731 const UpdateRecord* source =
2732 ::google::protobuf::internal::dynamic_cast_if_available<const UpdateRecord*>(
2734 if (source == NULL) {
2735 ::google::protobuf::internal::ReflectionOps::Merge(from,
this);
2741 void UpdateRecord::MergeFrom(
const UpdateRecord& from) {
2742 GOOGLE_CHECK_NE(&from,
this);
2743 key_value_.MergeFrom(from.key_value_);
2744 after_value_.MergeFrom(from.after_value_);
2745 before_value_.MergeFrom(from.before_value_);
2746 is_null_.MergeFrom(from.is_null_);
2747 mutable_unknown_fields()->MergeFrom(from.unknown_fields());
2750 void UpdateRecord::CopyFrom(const ::google::protobuf::Message& from) {
2751 if (&from ==
this)
return;
2756 void UpdateRecord::CopyFrom(
const UpdateRecord& from) {
2757 if (&from ==
this)
return;
2762 bool UpdateRecord::IsInitialized()
const {
2767 void UpdateRecord::Swap(UpdateRecord* other) {
2768 if (other !=
this) {
2769 key_value_.Swap(&other->key_value_);
2770 after_value_.Swap(&other->after_value_);
2771 before_value_.Swap(&other->before_value_);
2772 is_null_.Swap(&other->is_null_);
2773 std::swap(_has_bits_[0], other->_has_bits_[0]);
2774 _unknown_fields_.Swap(&other->_unknown_fields_);
2775 std::swap(_cached_size_, other->_cached_size_);
2779 ::google::protobuf::Metadata UpdateRecord::GetMetadata()
const {
2780 protobuf_AssignDescriptorsOnce();
2781 ::google::protobuf::Metadata metadata;
2782 metadata.descriptor = UpdateRecord_descriptor_;
2783 metadata.reflection = UpdateRecord_reflection_;
2791 const int UpdateHeader::kTableMetadataFieldNumber;
2792 const int UpdateHeader::kKeyFieldMetadataFieldNumber;
2793 const int UpdateHeader::kSetFieldMetadataFieldNumber;
2796 UpdateHeader::UpdateHeader()
2797 : ::google::protobuf::Message() {
2801 void UpdateHeader::InitAsDefaultInstance() {
2805 UpdateHeader::UpdateHeader(
const UpdateHeader& from)
2806 : ::google::protobuf::Message() {
2811 void UpdateHeader::SharedCtor() {
2813 table_metadata_ = NULL;
2814 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
2817 UpdateHeader::~UpdateHeader() {
2821 void UpdateHeader::SharedDtor() {
2822 if (
this != default_instance_) {
2823 delete table_metadata_;
2827 void UpdateHeader::SetCachedSize(
int size)
const {
2828 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
2829 _cached_size_ = size;
2830 GOOGLE_SAFE_CONCURRENT_WRITES_END();
2832 const ::google::protobuf::Descriptor* UpdateHeader::descriptor() {
2833 protobuf_AssignDescriptorsOnce();
2834 return UpdateHeader_descriptor_;
2837 const UpdateHeader& UpdateHeader::default_instance() {
2838 if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto();
return *default_instance_;
2841 UpdateHeader* UpdateHeader::default_instance_ = NULL;
2843 UpdateHeader* UpdateHeader::New()
const {
2844 return new UpdateHeader;
2847 void UpdateHeader::Clear() {
2848 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
2849 if (has_table_metadata()) {
2850 if (table_metadata_ != NULL) table_metadata_->::drizzled::message::TableMetadata::Clear();
2853 key_field_metadata_.Clear();
2854 set_field_metadata_.Clear();
2855 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
2856 mutable_unknown_fields()->Clear();
2859 bool UpdateHeader::MergePartialFromCodedStream(
2860 ::google::protobuf::io::CodedInputStream* input) {
2861 #define DO_(EXPRESSION) if (!(EXPRESSION)) return false
2862 ::google::protobuf::uint32 tag;
2863 while ((tag = input->ReadTag()) != 0) {
2864 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
2867 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
2868 ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
2869 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
2870 input, mutable_table_metadata()));
2872 goto handle_uninterpreted;
2874 if (input->ExpectTag(18))
goto parse_key_field_metadata;
2880 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
2881 ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
2882 parse_key_field_metadata:
2883 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
2884 input, add_key_field_metadata()));
2886 goto handle_uninterpreted;
2888 if (input->ExpectTag(18))
goto parse_key_field_metadata;
2889 if (input->ExpectTag(26))
goto parse_set_field_metadata;
2895 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
2896 ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
2897 parse_set_field_metadata:
2898 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
2899 input, add_set_field_metadata()));
2901 goto handle_uninterpreted;
2903 if (input->ExpectTag(26))
goto parse_set_field_metadata;
2904 if (input->ExpectAtEnd())
return true;
2909 handle_uninterpreted:
2910 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
2911 ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
2914 DO_(::google::protobuf::internal::WireFormat::SkipField(
2915 input, tag, mutable_unknown_fields()));
2924 void UpdateHeader::SerializeWithCachedSizes(
2925 ::google::protobuf::io::CodedOutputStream* output)
const {
2927 if (has_table_metadata()) {
2928 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
2929 1, this->table_metadata(), output);
2933 for (
int i = 0; i < this->key_field_metadata_size(); i++) {
2934 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
2935 2, this->key_field_metadata(i), output);
2939 for (
int i = 0; i < this->set_field_metadata_size(); i++) {
2940 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
2941 3, this->set_field_metadata(i), output);
2944 if (!unknown_fields().empty()) {
2945 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
2946 unknown_fields(), output);
2950 ::google::protobuf::uint8* UpdateHeader::SerializeWithCachedSizesToArray(
2951 ::google::protobuf::uint8* target)
const {
2953 if (has_table_metadata()) {
2954 target = ::google::protobuf::internal::WireFormatLite::
2955 WriteMessageNoVirtualToArray(
2956 1, this->table_metadata(), target);
2960 for (
int i = 0; i < this->key_field_metadata_size(); i++) {
2961 target = ::google::protobuf::internal::WireFormatLite::
2962 WriteMessageNoVirtualToArray(
2963 2, this->key_field_metadata(i), target);
2967 for (
int i = 0; i < this->set_field_metadata_size(); i++) {
2968 target = ::google::protobuf::internal::WireFormatLite::
2969 WriteMessageNoVirtualToArray(
2970 3, this->set_field_metadata(i), target);
2973 if (!unknown_fields().empty()) {
2974 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
2975 unknown_fields(), target);
2980 int UpdateHeader::ByteSize()
const {
2983 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
2985 if (has_table_metadata()) {
2987 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
2988 this->table_metadata());
2993 total_size += 1 * this->key_field_metadata_size();
2994 for (
int i = 0; i < this->key_field_metadata_size(); i++) {
2996 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
2997 this->key_field_metadata(i));
3001 total_size += 1 * this->set_field_metadata_size();
3002 for (
int i = 0; i < this->set_field_metadata_size(); i++) {
3004 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
3005 this->set_field_metadata(i));
3008 if (!unknown_fields().empty()) {
3010 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
3013 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
3014 _cached_size_ = total_size;
3015 GOOGLE_SAFE_CONCURRENT_WRITES_END();
3019 void UpdateHeader::MergeFrom(const ::google::protobuf::Message& from) {
3020 GOOGLE_CHECK_NE(&from,
this);
3021 const UpdateHeader* source =
3022 ::google::protobuf::internal::dynamic_cast_if_available<const UpdateHeader*>(
3024 if (source == NULL) {
3025 ::google::protobuf::internal::ReflectionOps::Merge(from,
this);
3031 void UpdateHeader::MergeFrom(
const UpdateHeader& from) {
3032 GOOGLE_CHECK_NE(&from,
this);
3033 key_field_metadata_.MergeFrom(from.key_field_metadata_);
3034 set_field_metadata_.MergeFrom(from.set_field_metadata_);
3035 if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
3036 if (from.has_table_metadata()) {
3037 mutable_table_metadata()->::drizzled::message::TableMetadata::MergeFrom(from.table_metadata());
3040 mutable_unknown_fields()->MergeFrom(from.unknown_fields());
3043 void UpdateHeader::CopyFrom(const ::google::protobuf::Message& from) {
3044 if (&from ==
this)
return;
3049 void UpdateHeader::CopyFrom(
const UpdateHeader& from) {
3050 if (&from ==
this)
return;
3055 bool UpdateHeader::IsInitialized()
const {
3056 if ((_has_bits_[0] & 0x00000001) != 0x00000001)
return false;
3058 if (has_table_metadata()) {
3059 if (!this->table_metadata().IsInitialized())
return false;
3061 for (
int i = 0; i < key_field_metadata_size(); i++) {
3062 if (!this->key_field_metadata(i).IsInitialized())
return false;
3064 for (
int i = 0; i < set_field_metadata_size(); i++) {
3065 if (!this->set_field_metadata(i).IsInitialized())
return false;
3070 void UpdateHeader::Swap(UpdateHeader* other) {
3071 if (other !=
this) {
3072 std::swap(table_metadata_, other->table_metadata_);
3073 key_field_metadata_.Swap(&other->key_field_metadata_);
3074 set_field_metadata_.Swap(&other->set_field_metadata_);
3075 std::swap(_has_bits_[0], other->_has_bits_[0]);
3076 _unknown_fields_.Swap(&other->_unknown_fields_);
3077 std::swap(_cached_size_, other->_cached_size_);
3081 ::google::protobuf::Metadata UpdateHeader::GetMetadata()
const {
3082 protobuf_AssignDescriptorsOnce();
3083 ::google::protobuf::Metadata metadata;
3084 metadata.descriptor = UpdateHeader_descriptor_;
3085 metadata.reflection = UpdateHeader_reflection_;
3093 const int UpdateData::kSegmentIdFieldNumber;
3094 const int UpdateData::kEndSegmentFieldNumber;
3095 const int UpdateData::kRecordFieldNumber;
3098 UpdateData::UpdateData()
3099 : ::google::protobuf::Message() {
3103 void UpdateData::InitAsDefaultInstance() {
3106 UpdateData::UpdateData(
const UpdateData& from)
3107 : ::google::protobuf::Message() {
3112 void UpdateData::SharedCtor() {
3115 end_segment_ =
false;
3116 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
3119 UpdateData::~UpdateData() {
3123 void UpdateData::SharedDtor() {
3124 if (
this != default_instance_) {
3128 void UpdateData::SetCachedSize(
int size)
const {
3129 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
3130 _cached_size_ = size;
3131 GOOGLE_SAFE_CONCURRENT_WRITES_END();
3133 const ::google::protobuf::Descriptor* UpdateData::descriptor() {
3134 protobuf_AssignDescriptorsOnce();
3135 return UpdateData_descriptor_;
3138 const UpdateData& UpdateData::default_instance() {
3139 if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto();
return *default_instance_;
3142 UpdateData* UpdateData::default_instance_ = NULL;
3144 UpdateData* UpdateData::New()
const {
3145 return new UpdateData;
3148 void UpdateData::Clear() {
3149 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
3151 end_segment_ =
false;
3154 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
3155 mutable_unknown_fields()->Clear();
3158 bool UpdateData::MergePartialFromCodedStream(
3159 ::google::protobuf::io::CodedInputStream* input) {
3160 #define DO_(EXPRESSION) if (!(EXPRESSION)) return false
3161 ::google::protobuf::uint32 tag;
3162 while ((tag = input->ReadTag()) != 0) {
3163 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
3166 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
3167 ::google::protobuf::internal::WireFormatLite::WIRETYPE_VARINT) {
3168 DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
3169 ::google::protobuf::uint32, ::google::protobuf::internal::WireFormatLite::TYPE_UINT32>(
3170 input, &segment_id_)));
3171 set_has_segment_id();
3173 goto handle_uninterpreted;
3175 if (input->ExpectTag(16))
goto parse_end_segment;
3181 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
3182 ::google::protobuf::internal::WireFormatLite::WIRETYPE_VARINT) {
3184 DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
3185 bool, ::google::protobuf::internal::WireFormatLite::TYPE_BOOL>(
3186 input, &end_segment_)));
3187 set_has_end_segment();
3189 goto handle_uninterpreted;
3191 if (input->ExpectTag(26))
goto parse_record;
3197 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
3198 ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
3200 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
3201 input, add_record()));
3203 goto handle_uninterpreted;
3205 if (input->ExpectTag(26))
goto parse_record;
3206 if (input->ExpectAtEnd())
return true;
3211 handle_uninterpreted:
3212 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
3213 ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
3216 DO_(::google::protobuf::internal::WireFormat::SkipField(
3217 input, tag, mutable_unknown_fields()));
3226 void UpdateData::SerializeWithCachedSizes(
3227 ::google::protobuf::io::CodedOutputStream* output)
const {
3229 if (has_segment_id()) {
3230 ::google::protobuf::internal::WireFormatLite::WriteUInt32(1, this->segment_id(), output);
3234 if (has_end_segment()) {
3235 ::google::protobuf::internal::WireFormatLite::WriteBool(2, this->end_segment(), output);
3239 for (
int i = 0; i < this->record_size(); i++) {
3240 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
3241 3, this->record(i), output);
3244 if (!unknown_fields().empty()) {
3245 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
3246 unknown_fields(), output);
3250 ::google::protobuf::uint8* UpdateData::SerializeWithCachedSizesToArray(
3251 ::google::protobuf::uint8* target)
const {
3253 if (has_segment_id()) {
3254 target = ::google::protobuf::internal::WireFormatLite::WriteUInt32ToArray(1, this->segment_id(), target);
3258 if (has_end_segment()) {
3259 target = ::google::protobuf::internal::WireFormatLite::WriteBoolToArray(2, this->end_segment(), target);
3263 for (
int i = 0; i < this->record_size(); i++) {
3264 target = ::google::protobuf::internal::WireFormatLite::
3265 WriteMessageNoVirtualToArray(
3266 3, this->record(i), target);
3269 if (!unknown_fields().empty()) {
3270 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
3271 unknown_fields(), target);
3276 int UpdateData::ByteSize()
const {
3279 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
3281 if (has_segment_id()) {
3283 ::google::protobuf::internal::WireFormatLite::UInt32Size(
3284 this->segment_id());
3288 if (has_end_segment()) {
3289 total_size += 1 + 1;
3294 total_size += 1 * this->record_size();
3295 for (
int i = 0; i < this->record_size(); i++) {
3297 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
3301 if (!unknown_fields().empty()) {
3303 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
3306 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
3307 _cached_size_ = total_size;
3308 GOOGLE_SAFE_CONCURRENT_WRITES_END();
3312 void UpdateData::MergeFrom(const ::google::protobuf::Message& from) {
3313 GOOGLE_CHECK_NE(&from,
this);
3314 const UpdateData* source =
3315 ::google::protobuf::internal::dynamic_cast_if_available<const UpdateData*>(
3317 if (source == NULL) {
3318 ::google::protobuf::internal::ReflectionOps::Merge(from,
this);
3324 void UpdateData::MergeFrom(
const UpdateData& from) {
3325 GOOGLE_CHECK_NE(&from,
this);
3326 record_.MergeFrom(from.record_);
3327 if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
3328 if (from.has_segment_id()) {
3329 set_segment_id(from.segment_id());
3331 if (from.has_end_segment()) {
3332 set_end_segment(from.end_segment());
3335 mutable_unknown_fields()->MergeFrom(from.unknown_fields());
3338 void UpdateData::CopyFrom(const ::google::protobuf::Message& from) {
3339 if (&from ==
this)
return;
3344 void UpdateData::CopyFrom(
const UpdateData& from) {
3345 if (&from ==
this)
return;
3350 bool UpdateData::IsInitialized()
const {
3351 if ((_has_bits_[0] & 0x00000003) != 0x00000003)
return false;
3356 void UpdateData::Swap(UpdateData* other) {
3357 if (other !=
this) {
3358 std::swap(segment_id_, other->segment_id_);
3359 std::swap(end_segment_, other->end_segment_);
3360 record_.Swap(&other->record_);
3361 std::swap(_has_bits_[0], other->_has_bits_[0]);
3362 _unknown_fields_.Swap(&other->_unknown_fields_);
3363 std::swap(_cached_size_, other->_cached_size_);
3367 ::google::protobuf::Metadata UpdateData::GetMetadata()
const {
3368 protobuf_AssignDescriptorsOnce();
3369 ::google::protobuf::Metadata metadata;
3370 metadata.descriptor = UpdateData_descriptor_;
3371 metadata.reflection = UpdateData_reflection_;
3379 const int DeleteRecord::kKeyValueFieldNumber;
3382 DeleteRecord::DeleteRecord()
3383 : ::google::protobuf::Message() {
3387 void DeleteRecord::InitAsDefaultInstance() {
3390 DeleteRecord::DeleteRecord(
const DeleteRecord& from)
3391 : ::google::protobuf::Message() {
3396 void DeleteRecord::SharedCtor() {
3398 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
3401 DeleteRecord::~DeleteRecord() {
3405 void DeleteRecord::SharedDtor() {
3406 if (
this != default_instance_) {
3410 void DeleteRecord::SetCachedSize(
int size)
const {
3411 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
3412 _cached_size_ = size;
3413 GOOGLE_SAFE_CONCURRENT_WRITES_END();
3415 const ::google::protobuf::Descriptor* DeleteRecord::descriptor() {
3416 protobuf_AssignDescriptorsOnce();
3417 return DeleteRecord_descriptor_;
3420 const DeleteRecord& DeleteRecord::default_instance() {
3421 if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto();
return *default_instance_;
3424 DeleteRecord* DeleteRecord::default_instance_ = NULL;
3426 DeleteRecord* DeleteRecord::New()
const {
3427 return new DeleteRecord;
3430 void DeleteRecord::Clear() {
3432 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
3433 mutable_unknown_fields()->Clear();
3436 bool DeleteRecord::MergePartialFromCodedStream(
3437 ::google::protobuf::io::CodedInputStream* input) {
3438 #define DO_(EXPRESSION) if (!(EXPRESSION)) return false
3439 ::google::protobuf::uint32 tag;
3440 while ((tag = input->ReadTag()) != 0) {
3441 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
3444 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
3445 ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
3447 DO_(::google::protobuf::internal::WireFormatLite::ReadBytes(
3448 input, this->add_key_value()));
3450 goto handle_uninterpreted;
3452 if (input->ExpectTag(10))
goto parse_key_value;
3453 if (input->ExpectAtEnd())
return true;
3458 handle_uninterpreted:
3459 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
3460 ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
3463 DO_(::google::protobuf::internal::WireFormat::SkipField(
3464 input, tag, mutable_unknown_fields()));
3473 void DeleteRecord::SerializeWithCachedSizes(
3474 ::google::protobuf::io::CodedOutputStream* output)
const {
3476 for (
int i = 0; i < this->key_value_size(); i++) {
3477 ::google::protobuf::internal::WireFormatLite::WriteBytes(
3478 1, this->key_value(i), output);
3481 if (!unknown_fields().empty()) {
3482 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
3483 unknown_fields(), output);
3487 ::google::protobuf::uint8* DeleteRecord::SerializeWithCachedSizesToArray(
3488 ::google::protobuf::uint8* target)
const {
3490 for (
int i = 0; i < this->key_value_size(); i++) {
3491 target = ::google::protobuf::internal::WireFormatLite::
3492 WriteBytesToArray(1, this->key_value(i), target);
3495 if (!unknown_fields().empty()) {
3496 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
3497 unknown_fields(), target);
3502 int DeleteRecord::ByteSize()
const {
3506 total_size += 1 * this->key_value_size();
3507 for (
int i = 0; i < this->key_value_size(); i++) {
3508 total_size += ::google::protobuf::internal::WireFormatLite::BytesSize(
3509 this->key_value(i));
3512 if (!unknown_fields().empty()) {
3514 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
3517 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
3518 _cached_size_ = total_size;
3519 GOOGLE_SAFE_CONCURRENT_WRITES_END();
3523 void DeleteRecord::MergeFrom(const ::google::protobuf::Message& from) {
3524 GOOGLE_CHECK_NE(&from,
this);
3525 const DeleteRecord* source =
3526 ::google::protobuf::internal::dynamic_cast_if_available<const DeleteRecord*>(
3528 if (source == NULL) {
3529 ::google::protobuf::internal::ReflectionOps::Merge(from,
this);
3535 void DeleteRecord::MergeFrom(
const DeleteRecord& from) {
3536 GOOGLE_CHECK_NE(&from,
this);
3537 key_value_.MergeFrom(from.key_value_);
3538 mutable_unknown_fields()->MergeFrom(from.unknown_fields());
3541 void DeleteRecord::CopyFrom(const ::google::protobuf::Message& from) {
3542 if (&from ==
this)
return;
3547 void DeleteRecord::CopyFrom(
const DeleteRecord& from) {
3548 if (&from ==
this)
return;
3553 bool DeleteRecord::IsInitialized()
const {
3558 void DeleteRecord::Swap(DeleteRecord* other) {
3559 if (other !=
this) {
3560 key_value_.Swap(&other->key_value_);
3561 std::swap(_has_bits_[0], other->_has_bits_[0]);
3562 _unknown_fields_.Swap(&other->_unknown_fields_);
3563 std::swap(_cached_size_, other->_cached_size_);
3567 ::google::protobuf::Metadata DeleteRecord::GetMetadata()
const {
3568 protobuf_AssignDescriptorsOnce();
3569 ::google::protobuf::Metadata metadata;
3570 metadata.descriptor = DeleteRecord_descriptor_;
3571 metadata.reflection = DeleteRecord_reflection_;
3579 const int DeleteHeader::kTableMetadataFieldNumber;
3580 const int DeleteHeader::kKeyFieldMetadataFieldNumber;
3583 DeleteHeader::DeleteHeader()
3584 : ::google::protobuf::Message() {
3588 void DeleteHeader::InitAsDefaultInstance() {
3592 DeleteHeader::DeleteHeader(
const DeleteHeader& from)
3593 : ::google::protobuf::Message() {
3598 void DeleteHeader::SharedCtor() {
3600 table_metadata_ = NULL;
3601 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
3604 DeleteHeader::~DeleteHeader() {
3608 void DeleteHeader::SharedDtor() {
3609 if (
this != default_instance_) {
3610 delete table_metadata_;
3614 void DeleteHeader::SetCachedSize(
int size)
const {
3615 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
3616 _cached_size_ = size;
3617 GOOGLE_SAFE_CONCURRENT_WRITES_END();
3619 const ::google::protobuf::Descriptor* DeleteHeader::descriptor() {
3620 protobuf_AssignDescriptorsOnce();
3621 return DeleteHeader_descriptor_;
3624 const DeleteHeader& DeleteHeader::default_instance() {
3625 if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto();
return *default_instance_;
3628 DeleteHeader* DeleteHeader::default_instance_ = NULL;
3630 DeleteHeader* DeleteHeader::New()
const {
3631 return new DeleteHeader;
3634 void DeleteHeader::Clear() {
3635 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
3636 if (has_table_metadata()) {
3637 if (table_metadata_ != NULL) table_metadata_->::drizzled::message::TableMetadata::Clear();
3640 key_field_metadata_.Clear();
3641 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
3642 mutable_unknown_fields()->Clear();
3645 bool DeleteHeader::MergePartialFromCodedStream(
3646 ::google::protobuf::io::CodedInputStream* input) {
3647 #define DO_(EXPRESSION) if (!(EXPRESSION)) return false
3648 ::google::protobuf::uint32 tag;
3649 while ((tag = input->ReadTag()) != 0) {
3650 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
3653 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
3654 ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
3655 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
3656 input, mutable_table_metadata()));
3658 goto handle_uninterpreted;
3660 if (input->ExpectTag(18))
goto parse_key_field_metadata;
3666 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
3667 ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
3668 parse_key_field_metadata:
3669 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
3670 input, add_key_field_metadata()));
3672 goto handle_uninterpreted;
3674 if (input->ExpectTag(18))
goto parse_key_field_metadata;
3675 if (input->ExpectAtEnd())
return true;
3680 handle_uninterpreted:
3681 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
3682 ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
3685 DO_(::google::protobuf::internal::WireFormat::SkipField(
3686 input, tag, mutable_unknown_fields()));
3695 void DeleteHeader::SerializeWithCachedSizes(
3696 ::google::protobuf::io::CodedOutputStream* output)
const {
3698 if (has_table_metadata()) {
3699 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
3700 1, this->table_metadata(), output);
3704 for (
int i = 0; i < this->key_field_metadata_size(); i++) {
3705 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
3706 2, this->key_field_metadata(i), output);
3709 if (!unknown_fields().empty()) {
3710 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
3711 unknown_fields(), output);
3715 ::google::protobuf::uint8* DeleteHeader::SerializeWithCachedSizesToArray(
3716 ::google::protobuf::uint8* target)
const {
3718 if (has_table_metadata()) {
3719 target = ::google::protobuf::internal::WireFormatLite::
3720 WriteMessageNoVirtualToArray(
3721 1, this->table_metadata(), target);
3725 for (
int i = 0; i < this->key_field_metadata_size(); i++) {
3726 target = ::google::protobuf::internal::WireFormatLite::
3727 WriteMessageNoVirtualToArray(
3728 2, this->key_field_metadata(i), target);
3731 if (!unknown_fields().empty()) {
3732 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
3733 unknown_fields(), target);
3738 int DeleteHeader::ByteSize()
const {
3741 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
3743 if (has_table_metadata()) {
3745 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
3746 this->table_metadata());
3751 total_size += 1 * this->key_field_metadata_size();
3752 for (
int i = 0; i < this->key_field_metadata_size(); i++) {
3754 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
3755 this->key_field_metadata(i));
3758 if (!unknown_fields().empty()) {
3760 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
3763 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
3764 _cached_size_ = total_size;
3765 GOOGLE_SAFE_CONCURRENT_WRITES_END();
3769 void DeleteHeader::MergeFrom(const ::google::protobuf::Message& from) {
3770 GOOGLE_CHECK_NE(&from,
this);
3771 const DeleteHeader* source =
3772 ::google::protobuf::internal::dynamic_cast_if_available<const DeleteHeader*>(
3774 if (source == NULL) {
3775 ::google::protobuf::internal::ReflectionOps::Merge(from,
this);
3781 void DeleteHeader::MergeFrom(
const DeleteHeader& from) {
3782 GOOGLE_CHECK_NE(&from,
this);
3783 key_field_metadata_.MergeFrom(from.key_field_metadata_);
3784 if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
3785 if (from.has_table_metadata()) {
3786 mutable_table_metadata()->::drizzled::message::TableMetadata::MergeFrom(from.table_metadata());
3789 mutable_unknown_fields()->MergeFrom(from.unknown_fields());
3792 void DeleteHeader::CopyFrom(const ::google::protobuf::Message& from) {
3793 if (&from ==
this)
return;
3798 void DeleteHeader::CopyFrom(
const DeleteHeader& from) {
3799 if (&from ==
this)
return;
3804 bool DeleteHeader::IsInitialized()
const {
3805 if ((_has_bits_[0] & 0x00000001) != 0x00000001)
return false;
3807 if (has_table_metadata()) {
3808 if (!this->table_metadata().IsInitialized())
return false;
3810 for (
int i = 0; i < key_field_metadata_size(); i++) {
3811 if (!this->key_field_metadata(i).IsInitialized())
return false;
3816 void DeleteHeader::Swap(DeleteHeader* other) {
3817 if (other !=
this) {
3818 std::swap(table_metadata_, other->table_metadata_);
3819 key_field_metadata_.Swap(&other->key_field_metadata_);
3820 std::swap(_has_bits_[0], other->_has_bits_[0]);
3821 _unknown_fields_.Swap(&other->_unknown_fields_);
3822 std::swap(_cached_size_, other->_cached_size_);
3826 ::google::protobuf::Metadata DeleteHeader::GetMetadata()
const {
3827 protobuf_AssignDescriptorsOnce();
3828 ::google::protobuf::Metadata metadata;
3829 metadata.descriptor = DeleteHeader_descriptor_;
3830 metadata.reflection = DeleteHeader_reflection_;
3838 const int DeleteData::kSegmentIdFieldNumber;
3839 const int DeleteData::kEndSegmentFieldNumber;
3840 const int DeleteData::kRecordFieldNumber;
3843 DeleteData::DeleteData()
3844 : ::google::protobuf::Message() {
3848 void DeleteData::InitAsDefaultInstance() {
3851 DeleteData::DeleteData(
const DeleteData& from)
3852 : ::google::protobuf::Message() {
3857 void DeleteData::SharedCtor() {
3860 end_segment_ =
false;
3861 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
3864 DeleteData::~DeleteData() {
3868 void DeleteData::SharedDtor() {
3869 if (
this != default_instance_) {
3873 void DeleteData::SetCachedSize(
int size)
const {
3874 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
3875 _cached_size_ = size;
3876 GOOGLE_SAFE_CONCURRENT_WRITES_END();
3878 const ::google::protobuf::Descriptor* DeleteData::descriptor() {
3879 protobuf_AssignDescriptorsOnce();
3880 return DeleteData_descriptor_;
3883 const DeleteData& DeleteData::default_instance() {
3884 if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto();
return *default_instance_;
3887 DeleteData* DeleteData::default_instance_ = NULL;
3889 DeleteData* DeleteData::New()
const {
3890 return new DeleteData;
3893 void DeleteData::Clear() {
3894 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
3896 end_segment_ =
false;
3899 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
3900 mutable_unknown_fields()->Clear();
3903 bool DeleteData::MergePartialFromCodedStream(
3904 ::google::protobuf::io::CodedInputStream* input) {
3905 #define DO_(EXPRESSION) if (!(EXPRESSION)) return false
3906 ::google::protobuf::uint32 tag;
3907 while ((tag = input->ReadTag()) != 0) {
3908 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
3911 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
3912 ::google::protobuf::internal::WireFormatLite::WIRETYPE_VARINT) {
3913 DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
3914 ::google::protobuf::uint32, ::google::protobuf::internal::WireFormatLite::TYPE_UINT32>(
3915 input, &segment_id_)));
3916 set_has_segment_id();
3918 goto handle_uninterpreted;
3920 if (input->ExpectTag(16))
goto parse_end_segment;
3926 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
3927 ::google::protobuf::internal::WireFormatLite::WIRETYPE_VARINT) {
3929 DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
3930 bool, ::google::protobuf::internal::WireFormatLite::TYPE_BOOL>(
3931 input, &end_segment_)));
3932 set_has_end_segment();
3934 goto handle_uninterpreted;
3936 if (input->ExpectTag(26))
goto parse_record;
3942 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
3943 ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
3945 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
3946 input, add_record()));
3948 goto handle_uninterpreted;
3950 if (input->ExpectTag(26))
goto parse_record;
3951 if (input->ExpectAtEnd())
return true;
3956 handle_uninterpreted:
3957 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
3958 ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
3961 DO_(::google::protobuf::internal::WireFormat::SkipField(
3962 input, tag, mutable_unknown_fields()));
3971 void DeleteData::SerializeWithCachedSizes(
3972 ::google::protobuf::io::CodedOutputStream* output)
const {
3974 if (has_segment_id()) {
3975 ::google::protobuf::internal::WireFormatLite::WriteUInt32(1, this->segment_id(), output);
3979 if (has_end_segment()) {
3980 ::google::protobuf::internal::WireFormatLite::WriteBool(2, this->end_segment(), output);
3984 for (
int i = 0; i < this->record_size(); i++) {
3985 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
3986 3, this->record(i), output);
3989 if (!unknown_fields().empty()) {
3990 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
3991 unknown_fields(), output);
3995 ::google::protobuf::uint8* DeleteData::SerializeWithCachedSizesToArray(
3996 ::google::protobuf::uint8* target)
const {
3998 if (has_segment_id()) {
3999 target = ::google::protobuf::internal::WireFormatLite::WriteUInt32ToArray(1, this->segment_id(), target);
4003 if (has_end_segment()) {
4004 target = ::google::protobuf::internal::WireFormatLite::WriteBoolToArray(2, this->end_segment(), target);
4008 for (
int i = 0; i < this->record_size(); i++) {
4009 target = ::google::protobuf::internal::WireFormatLite::
4010 WriteMessageNoVirtualToArray(
4011 3, this->record(i), target);
4014 if (!unknown_fields().empty()) {
4015 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
4016 unknown_fields(), target);
4021 int DeleteData::ByteSize()
const {
4024 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
4026 if (has_segment_id()) {
4028 ::google::protobuf::internal::WireFormatLite::UInt32Size(
4029 this->segment_id());
4033 if (has_end_segment()) {
4034 total_size += 1 + 1;
4039 total_size += 1 * this->record_size();
4040 for (
int i = 0; i < this->record_size(); i++) {
4042 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
4046 if (!unknown_fields().empty()) {
4048 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
4051 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
4052 _cached_size_ = total_size;
4053 GOOGLE_SAFE_CONCURRENT_WRITES_END();
4057 void DeleteData::MergeFrom(const ::google::protobuf::Message& from) {
4058 GOOGLE_CHECK_NE(&from,
this);
4059 const DeleteData* source =
4060 ::google::protobuf::internal::dynamic_cast_if_available<const DeleteData*>(
4062 if (source == NULL) {
4063 ::google::protobuf::internal::ReflectionOps::Merge(from,
this);
4069 void DeleteData::MergeFrom(
const DeleteData& from) {
4070 GOOGLE_CHECK_NE(&from,
this);
4071 record_.MergeFrom(from.record_);
4072 if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
4073 if (from.has_segment_id()) {
4074 set_segment_id(from.segment_id());
4076 if (from.has_end_segment()) {
4077 set_end_segment(from.end_segment());
4080 mutable_unknown_fields()->MergeFrom(from.unknown_fields());
4083 void DeleteData::CopyFrom(const ::google::protobuf::Message& from) {
4084 if (&from ==
this)
return;
4089 void DeleteData::CopyFrom(
const DeleteData& from) {
4090 if (&from ==
this)
return;
4095 bool DeleteData::IsInitialized()
const {
4096 if ((_has_bits_[0] & 0x00000003) != 0x00000003)
return false;
4101 void DeleteData::Swap(DeleteData* other) {
4102 if (other !=
this) {
4103 std::swap(segment_id_, other->segment_id_);
4104 std::swap(end_segment_, other->end_segment_);
4105 record_.Swap(&other->record_);
4106 std::swap(_has_bits_[0], other->_has_bits_[0]);
4107 _unknown_fields_.Swap(&other->_unknown_fields_);
4108 std::swap(_cached_size_, other->_cached_size_);
4112 ::google::protobuf::Metadata DeleteData::GetMetadata()
const {
4113 protobuf_AssignDescriptorsOnce();
4114 ::google::protobuf::Metadata metadata;
4115 metadata.descriptor = DeleteData_descriptor_;
4116 metadata.reflection = DeleteData_reflection_;
4124 const int TruncateTableStatement::kTableMetadataFieldNumber;
4127 TruncateTableStatement::TruncateTableStatement()
4128 : ::google::protobuf::Message() {
4132 void TruncateTableStatement::InitAsDefaultInstance() {
4136 TruncateTableStatement::TruncateTableStatement(
const TruncateTableStatement& from)
4137 : ::google::protobuf::Message() {
4142 void TruncateTableStatement::SharedCtor() {
4144 table_metadata_ = NULL;
4145 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
4148 TruncateTableStatement::~TruncateTableStatement() {
4152 void TruncateTableStatement::SharedDtor() {
4153 if (
this != default_instance_) {
4154 delete table_metadata_;
4158 void TruncateTableStatement::SetCachedSize(
int size)
const {
4159 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
4160 _cached_size_ = size;
4161 GOOGLE_SAFE_CONCURRENT_WRITES_END();
4163 const ::google::protobuf::Descriptor* TruncateTableStatement::descriptor() {
4164 protobuf_AssignDescriptorsOnce();
4165 return TruncateTableStatement_descriptor_;
4168 const TruncateTableStatement& TruncateTableStatement::default_instance() {
4169 if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto();
return *default_instance_;
4172 TruncateTableStatement* TruncateTableStatement::default_instance_ = NULL;
4174 TruncateTableStatement* TruncateTableStatement::New()
const {
4175 return new TruncateTableStatement;
4178 void TruncateTableStatement::Clear() {
4179 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
4180 if (has_table_metadata()) {
4181 if (table_metadata_ != NULL) table_metadata_->::drizzled::message::TableMetadata::Clear();
4184 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
4185 mutable_unknown_fields()->Clear();
4188 bool TruncateTableStatement::MergePartialFromCodedStream(
4189 ::google::protobuf::io::CodedInputStream* input) {
4190 #define DO_(EXPRESSION) if (!(EXPRESSION)) return false
4191 ::google::protobuf::uint32 tag;
4192 while ((tag = input->ReadTag()) != 0) {
4193 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
4196 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
4197 ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
4198 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
4199 input, mutable_table_metadata()));
4201 goto handle_uninterpreted;
4203 if (input->ExpectAtEnd())
return true;
4208 handle_uninterpreted:
4209 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
4210 ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
4213 DO_(::google::protobuf::internal::WireFormat::SkipField(
4214 input, tag, mutable_unknown_fields()));
4223 void TruncateTableStatement::SerializeWithCachedSizes(
4224 ::google::protobuf::io::CodedOutputStream* output)
const {
4226 if (has_table_metadata()) {
4227 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
4228 1, this->table_metadata(), output);
4231 if (!unknown_fields().empty()) {
4232 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
4233 unknown_fields(), output);
4237 ::google::protobuf::uint8* TruncateTableStatement::SerializeWithCachedSizesToArray(
4238 ::google::protobuf::uint8* target)
const {
4240 if (has_table_metadata()) {
4241 target = ::google::protobuf::internal::WireFormatLite::
4242 WriteMessageNoVirtualToArray(
4243 1, this->table_metadata(), target);
4246 if (!unknown_fields().empty()) {
4247 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
4248 unknown_fields(), target);
4253 int TruncateTableStatement::ByteSize()
const {
4256 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
4258 if (has_table_metadata()) {
4260 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
4261 this->table_metadata());
4265 if (!unknown_fields().empty()) {
4267 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
4270 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
4271 _cached_size_ = total_size;
4272 GOOGLE_SAFE_CONCURRENT_WRITES_END();
4276 void TruncateTableStatement::MergeFrom(const ::google::protobuf::Message& from) {
4277 GOOGLE_CHECK_NE(&from,
this);
4278 const TruncateTableStatement* source =
4279 ::google::protobuf::internal::dynamic_cast_if_available<const TruncateTableStatement*>(
4281 if (source == NULL) {
4282 ::google::protobuf::internal::ReflectionOps::Merge(from,
this);
4288 void TruncateTableStatement::MergeFrom(
const TruncateTableStatement& from) {
4289 GOOGLE_CHECK_NE(&from,
this);
4290 if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
4291 if (from.has_table_metadata()) {
4292 mutable_table_metadata()->::drizzled::message::TableMetadata::MergeFrom(from.table_metadata());
4295 mutable_unknown_fields()->MergeFrom(from.unknown_fields());
4298 void TruncateTableStatement::CopyFrom(const ::google::protobuf::Message& from) {
4299 if (&from ==
this)
return;
4304 void TruncateTableStatement::CopyFrom(
const TruncateTableStatement& from) {
4305 if (&from ==
this)
return;
4310 bool TruncateTableStatement::IsInitialized()
const {
4311 if ((_has_bits_[0] & 0x00000001) != 0x00000001)
return false;
4313 if (has_table_metadata()) {
4314 if (!this->table_metadata().IsInitialized())
return false;
4319 void TruncateTableStatement::Swap(TruncateTableStatement* other) {
4320 if (other !=
this) {
4321 std::swap(table_metadata_, other->table_metadata_);
4322 std::swap(_has_bits_[0], other->_has_bits_[0]);
4323 _unknown_fields_.Swap(&other->_unknown_fields_);
4324 std::swap(_cached_size_, other->_cached_size_);
4328 ::google::protobuf::Metadata TruncateTableStatement::GetMetadata()
const {
4329 protobuf_AssignDescriptorsOnce();
4330 ::google::protobuf::Metadata metadata;
4331 metadata.descriptor = TruncateTableStatement_descriptor_;
4332 metadata.reflection = TruncateTableStatement_reflection_;
4340 const int CreateSchemaStatement::kSchemaFieldNumber;
4343 CreateSchemaStatement::CreateSchemaStatement()
4344 : ::google::protobuf::Message() {
4348 void CreateSchemaStatement::InitAsDefaultInstance() {
4352 CreateSchemaStatement::CreateSchemaStatement(
const CreateSchemaStatement& from)
4353 : ::google::protobuf::Message() {
4358 void CreateSchemaStatement::SharedCtor() {
4361 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
4364 CreateSchemaStatement::~CreateSchemaStatement() {
4368 void CreateSchemaStatement::SharedDtor() {
4369 if (
this != default_instance_) {
4374 void CreateSchemaStatement::SetCachedSize(
int size)
const {
4375 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
4376 _cached_size_ = size;
4377 GOOGLE_SAFE_CONCURRENT_WRITES_END();
4379 const ::google::protobuf::Descriptor* CreateSchemaStatement::descriptor() {
4380 protobuf_AssignDescriptorsOnce();
4381 return CreateSchemaStatement_descriptor_;
4384 const CreateSchemaStatement& CreateSchemaStatement::default_instance() {
4385 if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto();
return *default_instance_;
4388 CreateSchemaStatement* CreateSchemaStatement::default_instance_ = NULL;
4390 CreateSchemaStatement* CreateSchemaStatement::New()
const {
4391 return new CreateSchemaStatement;
4394 void CreateSchemaStatement::Clear() {
4395 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
4397 if (schema_ != NULL) schema_->::drizzled::message::Schema::Clear();
4400 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
4401 mutable_unknown_fields()->Clear();
4404 bool CreateSchemaStatement::MergePartialFromCodedStream(
4405 ::google::protobuf::io::CodedInputStream* input) {
4406 #define DO_(EXPRESSION) if (!(EXPRESSION)) return false
4407 ::google::protobuf::uint32 tag;
4408 while ((tag = input->ReadTag()) != 0) {
4409 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
4412 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
4413 ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
4414 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
4415 input, mutable_schema()));
4417 goto handle_uninterpreted;
4419 if (input->ExpectAtEnd())
return true;
4424 handle_uninterpreted:
4425 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
4426 ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
4429 DO_(::google::protobuf::internal::WireFormat::SkipField(
4430 input, tag, mutable_unknown_fields()));
4439 void CreateSchemaStatement::SerializeWithCachedSizes(
4440 ::google::protobuf::io::CodedOutputStream* output)
const {
4443 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
4444 1, this->schema(), output);
4447 if (!unknown_fields().empty()) {
4448 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
4449 unknown_fields(), output);
4453 ::google::protobuf::uint8* CreateSchemaStatement::SerializeWithCachedSizesToArray(
4454 ::google::protobuf::uint8* target)
const {
4457 target = ::google::protobuf::internal::WireFormatLite::
4458 WriteMessageNoVirtualToArray(
4459 1, this->schema(), target);
4462 if (!unknown_fields().empty()) {
4463 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
4464 unknown_fields(), target);
4469 int CreateSchemaStatement::ByteSize()
const {
4472 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
4476 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
4481 if (!unknown_fields().empty()) {
4483 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
4486 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
4487 _cached_size_ = total_size;
4488 GOOGLE_SAFE_CONCURRENT_WRITES_END();
4492 void CreateSchemaStatement::MergeFrom(const ::google::protobuf::Message& from) {
4493 GOOGLE_CHECK_NE(&from,
this);
4494 const CreateSchemaStatement* source =
4495 ::google::protobuf::internal::dynamic_cast_if_available<const CreateSchemaStatement*>(
4497 if (source == NULL) {
4498 ::google::protobuf::internal::ReflectionOps::Merge(from,
this);
4504 void CreateSchemaStatement::MergeFrom(
const CreateSchemaStatement& from) {
4505 GOOGLE_CHECK_NE(&from,
this);
4506 if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
4507 if (from.has_schema()) {
4508 mutable_schema()->::drizzled::message::Schema::MergeFrom(from.schema());
4511 mutable_unknown_fields()->MergeFrom(from.unknown_fields());
4514 void CreateSchemaStatement::CopyFrom(const ::google::protobuf::Message& from) {
4515 if (&from ==
this)
return;
4520 void CreateSchemaStatement::CopyFrom(
const CreateSchemaStatement& from) {
4521 if (&from ==
this)
return;
4526 bool CreateSchemaStatement::IsInitialized()
const {
4527 if ((_has_bits_[0] & 0x00000001) != 0x00000001)
return false;
4530 if (!this->schema().IsInitialized())
return false;
4535 void CreateSchemaStatement::Swap(CreateSchemaStatement* other) {
4536 if (other !=
this) {
4537 std::swap(schema_, other->schema_);
4538 std::swap(_has_bits_[0], other->_has_bits_[0]);
4539 _unknown_fields_.Swap(&other->_unknown_fields_);
4540 std::swap(_cached_size_, other->_cached_size_);
4544 ::google::protobuf::Metadata CreateSchemaStatement::GetMetadata()
const {
4545 protobuf_AssignDescriptorsOnce();
4546 ::google::protobuf::Metadata metadata;
4547 metadata.descriptor = CreateSchemaStatement_descriptor_;
4548 metadata.reflection = CreateSchemaStatement_reflection_;
4556 const int AlterSchemaStatement::kBeforeFieldNumber;
4557 const int AlterSchemaStatement::kAfterFieldNumber;
4560 AlterSchemaStatement::AlterSchemaStatement()
4561 : ::google::protobuf::Message() {
4565 void AlterSchemaStatement::InitAsDefaultInstance() {
4570 AlterSchemaStatement::AlterSchemaStatement(
const AlterSchemaStatement& from)
4571 : ::google::protobuf::Message() {
4576 void AlterSchemaStatement::SharedCtor() {
4580 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
4583 AlterSchemaStatement::~AlterSchemaStatement() {
4587 void AlterSchemaStatement::SharedDtor() {
4588 if (
this != default_instance_) {
4594 void AlterSchemaStatement::SetCachedSize(
int size)
const {
4595 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
4596 _cached_size_ = size;
4597 GOOGLE_SAFE_CONCURRENT_WRITES_END();
4599 const ::google::protobuf::Descriptor* AlterSchemaStatement::descriptor() {
4600 protobuf_AssignDescriptorsOnce();
4601 return AlterSchemaStatement_descriptor_;
4604 const AlterSchemaStatement& AlterSchemaStatement::default_instance() {
4605 if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto();
return *default_instance_;
4608 AlterSchemaStatement* AlterSchemaStatement::default_instance_ = NULL;
4610 AlterSchemaStatement* AlterSchemaStatement::New()
const {
4611 return new AlterSchemaStatement;
4614 void AlterSchemaStatement::Clear() {
4615 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
4617 if (before_ != NULL) before_->::drizzled::message::Schema::Clear();
4620 if (after_ != NULL) after_->::drizzled::message::Schema::Clear();
4623 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
4624 mutable_unknown_fields()->Clear();
4627 bool AlterSchemaStatement::MergePartialFromCodedStream(
4628 ::google::protobuf::io::CodedInputStream* input) {
4629 #define DO_(EXPRESSION) if (!(EXPRESSION)) return false
4630 ::google::protobuf::uint32 tag;
4631 while ((tag = input->ReadTag()) != 0) {
4632 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
4635 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
4636 ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
4637 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
4638 input, mutable_before()));
4640 goto handle_uninterpreted;
4642 if (input->ExpectTag(18))
goto parse_after;
4648 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
4649 ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
4651 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
4652 input, mutable_after()));
4654 goto handle_uninterpreted;
4656 if (input->ExpectAtEnd())
return true;
4661 handle_uninterpreted:
4662 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
4663 ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
4666 DO_(::google::protobuf::internal::WireFormat::SkipField(
4667 input, tag, mutable_unknown_fields()));
4676 void AlterSchemaStatement::SerializeWithCachedSizes(
4677 ::google::protobuf::io::CodedOutputStream* output)
const {
4680 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
4681 1, this->before(), output);
4686 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
4687 2, this->after(), output);
4690 if (!unknown_fields().empty()) {
4691 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
4692 unknown_fields(), output);
4696 ::google::protobuf::uint8* AlterSchemaStatement::SerializeWithCachedSizesToArray(
4697 ::google::protobuf::uint8* target)
const {
4700 target = ::google::protobuf::internal::WireFormatLite::
4701 WriteMessageNoVirtualToArray(
4702 1, this->before(), target);
4707 target = ::google::protobuf::internal::WireFormatLite::
4708 WriteMessageNoVirtualToArray(
4709 2, this->after(), target);
4712 if (!unknown_fields().empty()) {
4713 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
4714 unknown_fields(), target);
4719 int AlterSchemaStatement::ByteSize()
const {
4722 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
4726 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
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 AlterSchemaStatement::MergeFrom(const ::google::protobuf::Message& from) {
4750 GOOGLE_CHECK_NE(&from,
this);
4751 const AlterSchemaStatement* source =
4752 ::google::protobuf::internal::dynamic_cast_if_available<const AlterSchemaStatement*>(
4754 if (source == NULL) {
4755 ::google::protobuf::internal::ReflectionOps::Merge(from,
this);
4761 void AlterSchemaStatement::MergeFrom(
const AlterSchemaStatement& from) {
4762 GOOGLE_CHECK_NE(&from,
this);
4763 if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
4764 if (from.has_before()) {
4765 mutable_before()->::drizzled::message::Schema::MergeFrom(from.before());
4767 if (from.has_after()) {
4768 mutable_after()->::drizzled::message::Schema::MergeFrom(from.after());
4771 mutable_unknown_fields()->MergeFrom(from.unknown_fields());
4774 void AlterSchemaStatement::CopyFrom(const ::google::protobuf::Message& from) {
4775 if (&from ==
this)
return;
4780 void AlterSchemaStatement::CopyFrom(
const AlterSchemaStatement& from) {
4781 if (&from ==
this)
return;
4786 bool AlterSchemaStatement::IsInitialized()
const {
4787 if ((_has_bits_[0] & 0x00000003) != 0x00000003)
return false;
4790 if (!this->before().IsInitialized())
return false;
4793 if (!this->after().IsInitialized())
return false;
4798 void AlterSchemaStatement::Swap(AlterSchemaStatement* other) {
4799 if (other !=
this) {
4800 std::swap(before_, other->before_);
4801 std::swap(after_, other->after_);
4802 std::swap(_has_bits_[0], other->_has_bits_[0]);
4803 _unknown_fields_.Swap(&other->_unknown_fields_);
4804 std::swap(_cached_size_, other->_cached_size_);
4808 ::google::protobuf::Metadata AlterSchemaStatement::GetMetadata()
const {
4809 protobuf_AssignDescriptorsOnce();
4810 ::google::protobuf::Metadata metadata;
4811 metadata.descriptor = AlterSchemaStatement_descriptor_;
4812 metadata.reflection = AlterSchemaStatement_reflection_;
4820 const int DropSchemaStatement::kSchemaNameFieldNumber;
4821 const int DropSchemaStatement::kCatalogNameFieldNumber;
4824 DropSchemaStatement::DropSchemaStatement()
4825 : ::google::protobuf::Message() {
4829 void DropSchemaStatement::InitAsDefaultInstance() {
4832 DropSchemaStatement::DropSchemaStatement(
const DropSchemaStatement& from)
4833 : ::google::protobuf::Message() {
4838 void DropSchemaStatement::SharedCtor() {
4840 schema_name_ =
const_cast< ::std::string*
>(&::google::protobuf::internal::kEmptyString);
4841 catalog_name_ =
const_cast< ::std::string*
>(&::google::protobuf::internal::kEmptyString);
4842 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
4845 DropSchemaStatement::~DropSchemaStatement() {
4849 void DropSchemaStatement::SharedDtor() {
4850 if (schema_name_ != &::google::protobuf::internal::kEmptyString) {
4851 delete schema_name_;
4853 if (catalog_name_ != &::google::protobuf::internal::kEmptyString) {
4854 delete catalog_name_;
4856 if (
this != default_instance_) {
4860 void DropSchemaStatement::SetCachedSize(
int size)
const {
4861 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
4862 _cached_size_ = size;
4863 GOOGLE_SAFE_CONCURRENT_WRITES_END();
4865 const ::google::protobuf::Descriptor* DropSchemaStatement::descriptor() {
4866 protobuf_AssignDescriptorsOnce();
4867 return DropSchemaStatement_descriptor_;
4870 const DropSchemaStatement& DropSchemaStatement::default_instance() {
4871 if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto();
return *default_instance_;
4874 DropSchemaStatement* DropSchemaStatement::default_instance_ = NULL;
4876 DropSchemaStatement* DropSchemaStatement::New()
const {
4877 return new DropSchemaStatement;
4880 void DropSchemaStatement::Clear() {
4881 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
4882 if (has_schema_name()) {
4883 if (schema_name_ != &::google::protobuf::internal::kEmptyString) {
4884 schema_name_->clear();
4887 if (has_catalog_name()) {
4888 if (catalog_name_ != &::google::protobuf::internal::kEmptyString) {
4889 catalog_name_->clear();
4893 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
4894 mutable_unknown_fields()->Clear();
4897 bool DropSchemaStatement::MergePartialFromCodedStream(
4898 ::google::protobuf::io::CodedInputStream* input) {
4899 #define DO_(EXPRESSION) if (!(EXPRESSION)) return false
4900 ::google::protobuf::uint32 tag;
4901 while ((tag = input->ReadTag()) != 0) {
4902 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
4905 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
4906 ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
4907 DO_(::google::protobuf::internal::WireFormatLite::ReadString(
4908 input, this->mutable_schema_name()));
4909 ::google::protobuf::internal::WireFormat::VerifyUTF8String(
4910 this->schema_name().data(), this->schema_name().length(),
4911 ::google::protobuf::internal::WireFormat::PARSE);
4913 goto handle_uninterpreted;
4915 if (input->ExpectTag(18))
goto parse_catalog_name;
4921 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
4922 ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
4924 DO_(::google::protobuf::internal::WireFormatLite::ReadString(
4925 input, this->mutable_catalog_name()));
4926 ::google::protobuf::internal::WireFormat::VerifyUTF8String(
4927 this->catalog_name().data(), this->catalog_name().length(),
4928 ::google::protobuf::internal::WireFormat::PARSE);
4930 goto handle_uninterpreted;
4932 if (input->ExpectAtEnd())
return true;
4937 handle_uninterpreted:
4938 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
4939 ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
4942 DO_(::google::protobuf::internal::WireFormat::SkipField(
4943 input, tag, mutable_unknown_fields()));
4952 void DropSchemaStatement::SerializeWithCachedSizes(
4953 ::google::protobuf::io::CodedOutputStream* output)
const {
4955 if (has_schema_name()) {
4956 ::google::protobuf::internal::WireFormat::VerifyUTF8String(
4957 this->schema_name().data(), this->schema_name().length(),
4958 ::google::protobuf::internal::WireFormat::SERIALIZE);
4959 ::google::protobuf::internal::WireFormatLite::WriteString(
4960 1, this->schema_name(), output);
4964 if (has_catalog_name()) {
4965 ::google::protobuf::internal::WireFormat::VerifyUTF8String(
4966 this->catalog_name().data(), this->catalog_name().length(),
4967 ::google::protobuf::internal::WireFormat::SERIALIZE);
4968 ::google::protobuf::internal::WireFormatLite::WriteString(
4969 2, this->catalog_name(), output);
4972 if (!unknown_fields().empty()) {
4973 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
4974 unknown_fields(), output);
4978 ::google::protobuf::uint8* DropSchemaStatement::SerializeWithCachedSizesToArray(
4979 ::google::protobuf::uint8* target)
const {
4981 if (has_schema_name()) {
4982 ::google::protobuf::internal::WireFormat::VerifyUTF8String(
4983 this->schema_name().data(), this->schema_name().length(),
4984 ::google::protobuf::internal::WireFormat::SERIALIZE);
4986 ::google::protobuf::internal::WireFormatLite::WriteStringToArray(
4987 1, this->schema_name(), target);
4991 if (has_catalog_name()) {
4992 ::google::protobuf::internal::WireFormat::VerifyUTF8String(
4993 this->catalog_name().data(), this->catalog_name().length(),
4994 ::google::protobuf::internal::WireFormat::SERIALIZE);
4996 ::google::protobuf::internal::WireFormatLite::WriteStringToArray(
4997 2, this->catalog_name(), target);
5000 if (!unknown_fields().empty()) {
5001 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
5002 unknown_fields(), target);
5007 int DropSchemaStatement::ByteSize()
const {
5010 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
5012 if (has_schema_name()) {
5014 ::google::protobuf::internal::WireFormatLite::StringSize(
5015 this->schema_name());
5019 if (has_catalog_name()) {
5021 ::google::protobuf::internal::WireFormatLite::StringSize(
5022 this->catalog_name());
5026 if (!unknown_fields().empty()) {
5028 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
5031 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
5032 _cached_size_ = total_size;
5033 GOOGLE_SAFE_CONCURRENT_WRITES_END();
5037 void DropSchemaStatement::MergeFrom(const ::google::protobuf::Message& from) {
5038 GOOGLE_CHECK_NE(&from,
this);
5039 const DropSchemaStatement* source =
5040 ::google::protobuf::internal::dynamic_cast_if_available<const DropSchemaStatement*>(
5042 if (source == NULL) {
5043 ::google::protobuf::internal::ReflectionOps::Merge(from,
this);
5049 void DropSchemaStatement::MergeFrom(
const DropSchemaStatement& from) {
5050 GOOGLE_CHECK_NE(&from,
this);
5051 if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
5052 if (from.has_schema_name()) {
5053 set_schema_name(from.schema_name());
5055 if (from.has_catalog_name()) {
5056 set_catalog_name(from.catalog_name());
5059 mutable_unknown_fields()->MergeFrom(from.unknown_fields());
5062 void DropSchemaStatement::CopyFrom(const ::google::protobuf::Message& from) {
5063 if (&from ==
this)
return;
5068 void DropSchemaStatement::CopyFrom(
const DropSchemaStatement& from) {
5069 if (&from ==
this)
return;
5074 bool DropSchemaStatement::IsInitialized()
const {
5075 if ((_has_bits_[0] & 0x00000001) != 0x00000001)
return false;
5080 void DropSchemaStatement::Swap(DropSchemaStatement* other) {
5081 if (other !=
this) {
5082 std::swap(schema_name_, other->schema_name_);
5083 std::swap(catalog_name_, other->catalog_name_);
5084 std::swap(_has_bits_[0], other->_has_bits_[0]);
5085 _unknown_fields_.Swap(&other->_unknown_fields_);
5086 std::swap(_cached_size_, other->_cached_size_);
5090 ::google::protobuf::Metadata DropSchemaStatement::GetMetadata()
const {
5091 protobuf_AssignDescriptorsOnce();
5092 ::google::protobuf::Metadata metadata;
5093 metadata.descriptor = DropSchemaStatement_descriptor_;
5094 metadata.reflection = DropSchemaStatement_reflection_;
5102 const int CreateTableStatement::kTableFieldNumber;
5105 CreateTableStatement::CreateTableStatement()
5106 : ::google::protobuf::Message() {
5110 void CreateTableStatement::InitAsDefaultInstance() {
5114 CreateTableStatement::CreateTableStatement(
const CreateTableStatement& from)
5115 : ::google::protobuf::Message() {
5120 void CreateTableStatement::SharedCtor() {
5123 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
5126 CreateTableStatement::~CreateTableStatement() {
5130 void CreateTableStatement::SharedDtor() {
5131 if (
this != default_instance_) {
5136 void CreateTableStatement::SetCachedSize(
int size)
const {
5137 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
5138 _cached_size_ = size;
5139 GOOGLE_SAFE_CONCURRENT_WRITES_END();
5141 const ::google::protobuf::Descriptor* CreateTableStatement::descriptor() {
5142 protobuf_AssignDescriptorsOnce();
5143 return CreateTableStatement_descriptor_;
5146 const CreateTableStatement& CreateTableStatement::default_instance() {
5147 if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto();
return *default_instance_;
5150 CreateTableStatement* CreateTableStatement::default_instance_ = NULL;
5152 CreateTableStatement* CreateTableStatement::New()
const {
5153 return new CreateTableStatement;
5156 void CreateTableStatement::Clear() {
5157 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
5159 if (table_ != NULL) table_->::drizzled::message::Table::Clear();
5162 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
5163 mutable_unknown_fields()->Clear();
5166 bool CreateTableStatement::MergePartialFromCodedStream(
5167 ::google::protobuf::io::CodedInputStream* input) {
5168 #define DO_(EXPRESSION) if (!(EXPRESSION)) return false
5169 ::google::protobuf::uint32 tag;
5170 while ((tag = input->ReadTag()) != 0) {
5171 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
5174 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
5175 ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
5176 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
5177 input, mutable_table()));
5179 goto handle_uninterpreted;
5181 if (input->ExpectAtEnd())
return true;
5186 handle_uninterpreted:
5187 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
5188 ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
5191 DO_(::google::protobuf::internal::WireFormat::SkipField(
5192 input, tag, mutable_unknown_fields()));
5201 void CreateTableStatement::SerializeWithCachedSizes(
5202 ::google::protobuf::io::CodedOutputStream* output)
const {
5205 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
5206 1, this->table(), output);
5209 if (!unknown_fields().empty()) {
5210 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
5211 unknown_fields(), output);
5215 ::google::protobuf::uint8* CreateTableStatement::SerializeWithCachedSizesToArray(
5216 ::google::protobuf::uint8* target)
const {
5219 target = ::google::protobuf::internal::WireFormatLite::
5220 WriteMessageNoVirtualToArray(
5221 1, this->table(), target);
5224 if (!unknown_fields().empty()) {
5225 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
5226 unknown_fields(), target);
5231 int CreateTableStatement::ByteSize()
const {
5234 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
5238 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
5243 if (!unknown_fields().empty()) {
5245 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
5248 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
5249 _cached_size_ = total_size;
5250 GOOGLE_SAFE_CONCURRENT_WRITES_END();
5254 void CreateTableStatement::MergeFrom(const ::google::protobuf::Message& from) {
5255 GOOGLE_CHECK_NE(&from,
this);
5256 const CreateTableStatement* source =
5257 ::google::protobuf::internal::dynamic_cast_if_available<const CreateTableStatement*>(
5259 if (source == NULL) {
5260 ::google::protobuf::internal::ReflectionOps::Merge(from,
this);
5266 void CreateTableStatement::MergeFrom(
const CreateTableStatement& from) {
5267 GOOGLE_CHECK_NE(&from,
this);
5268 if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
5269 if (from.has_table()) {
5270 mutable_table()->::drizzled::message::Table::MergeFrom(from.table());
5273 mutable_unknown_fields()->MergeFrom(from.unknown_fields());
5276 void CreateTableStatement::CopyFrom(const ::google::protobuf::Message& from) {
5277 if (&from ==
this)
return;
5282 void CreateTableStatement::CopyFrom(
const CreateTableStatement& from) {
5283 if (&from ==
this)
return;
5288 bool CreateTableStatement::IsInitialized()
const {
5289 if ((_has_bits_[0] & 0x00000001) != 0x00000001)
return false;
5292 if (!this->table().IsInitialized())
return false;
5297 void CreateTableStatement::Swap(CreateTableStatement* other) {
5298 if (other !=
this) {
5299 std::swap(table_, other->table_);
5300 std::swap(_has_bits_[0], other->_has_bits_[0]);
5301 _unknown_fields_.Swap(&other->_unknown_fields_);
5302 std::swap(_cached_size_, other->_cached_size_);
5306 ::google::protobuf::Metadata CreateTableStatement::GetMetadata()
const {
5307 protobuf_AssignDescriptorsOnce();
5308 ::google::protobuf::Metadata metadata;
5309 metadata.descriptor = CreateTableStatement_descriptor_;
5310 metadata.reflection = CreateTableStatement_reflection_;
5318 const int AlterTableStatement::kBeforeFieldNumber;
5319 const int AlterTableStatement::kAfterFieldNumber;
5322 AlterTableStatement::AlterTableStatement()
5323 : ::google::protobuf::Message() {
5327 void AlterTableStatement::InitAsDefaultInstance() {
5332 AlterTableStatement::AlterTableStatement(
const AlterTableStatement& from)
5333 : ::google::protobuf::Message() {
5338 void AlterTableStatement::SharedCtor() {
5342 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
5345 AlterTableStatement::~AlterTableStatement() {
5349 void AlterTableStatement::SharedDtor() {
5350 if (
this != default_instance_) {
5356 void AlterTableStatement::SetCachedSize(
int size)
const {
5357 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
5358 _cached_size_ = size;
5359 GOOGLE_SAFE_CONCURRENT_WRITES_END();
5361 const ::google::protobuf::Descriptor* AlterTableStatement::descriptor() {
5362 protobuf_AssignDescriptorsOnce();
5363 return AlterTableStatement_descriptor_;
5366 const AlterTableStatement& AlterTableStatement::default_instance() {
5367 if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto();
return *default_instance_;
5370 AlterTableStatement* AlterTableStatement::default_instance_ = NULL;
5372 AlterTableStatement* AlterTableStatement::New()
const {
5373 return new AlterTableStatement;
5376 void AlterTableStatement::Clear() {
5377 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
5379 if (before_ != NULL) before_->::drizzled::message::Table::Clear();
5382 if (after_ != NULL) after_->::drizzled::message::Table::Clear();
5385 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
5386 mutable_unknown_fields()->Clear();
5389 bool AlterTableStatement::MergePartialFromCodedStream(
5390 ::google::protobuf::io::CodedInputStream* input) {
5391 #define DO_(EXPRESSION) if (!(EXPRESSION)) return false
5392 ::google::protobuf::uint32 tag;
5393 while ((tag = input->ReadTag()) != 0) {
5394 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
5397 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
5398 ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
5399 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
5400 input, mutable_before()));
5402 goto handle_uninterpreted;
5404 if (input->ExpectTag(18))
goto parse_after;
5410 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
5411 ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
5413 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
5414 input, mutable_after()));
5416 goto handle_uninterpreted;
5418 if (input->ExpectAtEnd())
return true;
5423 handle_uninterpreted:
5424 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
5425 ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
5428 DO_(::google::protobuf::internal::WireFormat::SkipField(
5429 input, tag, mutable_unknown_fields()));
5438 void AlterTableStatement::SerializeWithCachedSizes(
5439 ::google::protobuf::io::CodedOutputStream* output)
const {
5442 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
5443 1, this->before(), output);
5448 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
5449 2, this->after(), output);
5452 if (!unknown_fields().empty()) {
5453 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
5454 unknown_fields(), output);
5458 ::google::protobuf::uint8* AlterTableStatement::SerializeWithCachedSizesToArray(
5459 ::google::protobuf::uint8* target)
const {
5462 target = ::google::protobuf::internal::WireFormatLite::
5463 WriteMessageNoVirtualToArray(
5464 1, this->before(), target);
5469 target = ::google::protobuf::internal::WireFormatLite::
5470 WriteMessageNoVirtualToArray(
5471 2, this->after(), target);
5474 if (!unknown_fields().empty()) {
5475 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
5476 unknown_fields(), target);
5481 int AlterTableStatement::ByteSize()
const {
5484 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
5488 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
5495 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
5500 if (!unknown_fields().empty()) {
5502 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
5505 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
5506 _cached_size_ = total_size;
5507 GOOGLE_SAFE_CONCURRENT_WRITES_END();
5511 void AlterTableStatement::MergeFrom(const ::google::protobuf::Message& from) {
5512 GOOGLE_CHECK_NE(&from,
this);
5513 const AlterTableStatement* source =
5514 ::google::protobuf::internal::dynamic_cast_if_available<const AlterTableStatement*>(
5516 if (source == NULL) {
5517 ::google::protobuf::internal::ReflectionOps::Merge(from,
this);
5523 void AlterTableStatement::MergeFrom(
const AlterTableStatement& from) {
5524 GOOGLE_CHECK_NE(&from,
this);
5525 if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
5526 if (from.has_before()) {
5527 mutable_before()->::drizzled::message::Table::MergeFrom(from.before());
5529 if (from.has_after()) {
5530 mutable_after()->::drizzled::message::Table::MergeFrom(from.after());
5533 mutable_unknown_fields()->MergeFrom(from.unknown_fields());
5536 void AlterTableStatement::CopyFrom(const ::google::protobuf::Message& from) {
5537 if (&from ==
this)
return;
5542 void AlterTableStatement::CopyFrom(
const AlterTableStatement& from) {
5543 if (&from ==
this)
return;
5548 bool AlterTableStatement::IsInitialized()
const {
5549 if ((_has_bits_[0] & 0x00000003) != 0x00000003)
return false;
5552 if (!this->before().IsInitialized())
return false;
5555 if (!this->after().IsInitialized())
return false;
5560 void AlterTableStatement::Swap(AlterTableStatement* other) {
5561 if (other !=
this) {
5562 std::swap(before_, other->before_);
5563 std::swap(after_, other->after_);
5564 std::swap(_has_bits_[0], other->_has_bits_[0]);
5565 _unknown_fields_.Swap(&other->_unknown_fields_);
5566 std::swap(_cached_size_, other->_cached_size_);
5570 ::google::protobuf::Metadata AlterTableStatement::GetMetadata()
const {
5571 protobuf_AssignDescriptorsOnce();
5572 ::google::protobuf::Metadata metadata;
5573 metadata.descriptor = AlterTableStatement_descriptor_;
5574 metadata.reflection = AlterTableStatement_reflection_;
5582 const int DropTableStatement::kTableMetadataFieldNumber;
5583 const int DropTableStatement::kIfExistsClauseFieldNumber;
5586 DropTableStatement::DropTableStatement()
5587 : ::google::protobuf::Message() {
5591 void DropTableStatement::InitAsDefaultInstance() {
5595 DropTableStatement::DropTableStatement(
const DropTableStatement& from)
5596 : ::google::protobuf::Message() {
5601 void DropTableStatement::SharedCtor() {
5603 table_metadata_ = NULL;
5604 if_exists_clause_ =
false;
5605 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
5608 DropTableStatement::~DropTableStatement() {
5612 void DropTableStatement::SharedDtor() {
5613 if (
this != default_instance_) {
5614 delete table_metadata_;
5618 void DropTableStatement::SetCachedSize(
int size)
const {
5619 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
5620 _cached_size_ = size;
5621 GOOGLE_SAFE_CONCURRENT_WRITES_END();
5623 const ::google::protobuf::Descriptor* DropTableStatement::descriptor() {
5624 protobuf_AssignDescriptorsOnce();
5625 return DropTableStatement_descriptor_;
5628 const DropTableStatement& DropTableStatement::default_instance() {
5629 if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto();
return *default_instance_;
5632 DropTableStatement* DropTableStatement::default_instance_ = NULL;
5634 DropTableStatement* DropTableStatement::New()
const {
5635 return new DropTableStatement;
5638 void DropTableStatement::Clear() {
5639 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
5640 if (has_table_metadata()) {
5641 if (table_metadata_ != NULL) table_metadata_->::drizzled::message::TableMetadata::Clear();
5643 if_exists_clause_ =
false;
5645 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
5646 mutable_unknown_fields()->Clear();
5649 bool DropTableStatement::MergePartialFromCodedStream(
5650 ::google::protobuf::io::CodedInputStream* input) {
5651 #define DO_(EXPRESSION) if (!(EXPRESSION)) return false
5652 ::google::protobuf::uint32 tag;
5653 while ((tag = input->ReadTag()) != 0) {
5654 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
5657 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
5658 ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
5659 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
5660 input, mutable_table_metadata()));
5662 goto handle_uninterpreted;
5664 if (input->ExpectTag(16))
goto parse_if_exists_clause;
5670 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
5671 ::google::protobuf::internal::WireFormatLite::WIRETYPE_VARINT) {
5672 parse_if_exists_clause:
5673 DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
5674 bool, ::google::protobuf::internal::WireFormatLite::TYPE_BOOL>(
5675 input, &if_exists_clause_)));
5676 set_has_if_exists_clause();
5678 goto handle_uninterpreted;
5680 if (input->ExpectAtEnd())
return true;
5685 handle_uninterpreted:
5686 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
5687 ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
5690 DO_(::google::protobuf::internal::WireFormat::SkipField(
5691 input, tag, mutable_unknown_fields()));
5700 void DropTableStatement::SerializeWithCachedSizes(
5701 ::google::protobuf::io::CodedOutputStream* output)
const {
5703 if (has_table_metadata()) {
5704 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
5705 1, this->table_metadata(), output);
5709 if (has_if_exists_clause()) {
5710 ::google::protobuf::internal::WireFormatLite::WriteBool(2, this->if_exists_clause(), output);
5713 if (!unknown_fields().empty()) {
5714 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
5715 unknown_fields(), output);
5719 ::google::protobuf::uint8* DropTableStatement::SerializeWithCachedSizesToArray(
5720 ::google::protobuf::uint8* target)
const {
5722 if (has_table_metadata()) {
5723 target = ::google::protobuf::internal::WireFormatLite::
5724 WriteMessageNoVirtualToArray(
5725 1, this->table_metadata(), target);
5729 if (has_if_exists_clause()) {
5730 target = ::google::protobuf::internal::WireFormatLite::WriteBoolToArray(2, this->if_exists_clause(), target);
5733 if (!unknown_fields().empty()) {
5734 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
5735 unknown_fields(), target);
5740 int DropTableStatement::ByteSize()
const {
5743 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
5745 if (has_table_metadata()) {
5747 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
5748 this->table_metadata());
5752 if (has_if_exists_clause()) {
5753 total_size += 1 + 1;
5757 if (!unknown_fields().empty()) {
5759 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
5762 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
5763 _cached_size_ = total_size;
5764 GOOGLE_SAFE_CONCURRENT_WRITES_END();
5768 void DropTableStatement::MergeFrom(const ::google::protobuf::Message& from) {
5769 GOOGLE_CHECK_NE(&from,
this);
5770 const DropTableStatement* source =
5771 ::google::protobuf::internal::dynamic_cast_if_available<const DropTableStatement*>(
5773 if (source == NULL) {
5774 ::google::protobuf::internal::ReflectionOps::Merge(from,
this);
5780 void DropTableStatement::MergeFrom(
const DropTableStatement& from) {
5781 GOOGLE_CHECK_NE(&from,
this);
5782 if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
5783 if (from.has_table_metadata()) {
5784 mutable_table_metadata()->::drizzled::message::TableMetadata::MergeFrom(from.table_metadata());
5786 if (from.has_if_exists_clause()) {
5787 set_if_exists_clause(from.if_exists_clause());
5790 mutable_unknown_fields()->MergeFrom(from.unknown_fields());
5793 void DropTableStatement::CopyFrom(const ::google::protobuf::Message& from) {
5794 if (&from ==
this)
return;
5799 void DropTableStatement::CopyFrom(
const DropTableStatement& from) {
5800 if (&from ==
this)
return;
5805 bool DropTableStatement::IsInitialized()
const {
5806 if ((_has_bits_[0] & 0x00000001) != 0x00000001)
return false;
5808 if (has_table_metadata()) {
5809 if (!this->table_metadata().IsInitialized())
return false;
5814 void DropTableStatement::Swap(DropTableStatement* other) {
5815 if (other !=
this) {
5816 std::swap(table_metadata_, other->table_metadata_);
5817 std::swap(if_exists_clause_, other->if_exists_clause_);
5818 std::swap(_has_bits_[0], other->_has_bits_[0]);
5819 _unknown_fields_.Swap(&other->_unknown_fields_);
5820 std::swap(_cached_size_, other->_cached_size_);
5824 ::google::protobuf::Metadata DropTableStatement::GetMetadata()
const {
5825 protobuf_AssignDescriptorsOnce();
5826 ::google::protobuf::Metadata metadata;
5827 metadata.descriptor = DropTableStatement_descriptor_;
5828 metadata.reflection = DropTableStatement_reflection_;
5836 const int SetVariableStatement::kVariableMetadataFieldNumber;
5837 const int SetVariableStatement::kVariableValueFieldNumber;
5840 SetVariableStatement::SetVariableStatement()
5841 : ::google::protobuf::Message() {
5845 void SetVariableStatement::InitAsDefaultInstance() {
5849 SetVariableStatement::SetVariableStatement(
const SetVariableStatement& from)
5850 : ::google::protobuf::Message() {
5855 void SetVariableStatement::SharedCtor() {
5857 variable_metadata_ = NULL;
5858 variable_value_ =
const_cast< ::std::string*
>(&::google::protobuf::internal::kEmptyString);
5859 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
5862 SetVariableStatement::~SetVariableStatement() {
5866 void SetVariableStatement::SharedDtor() {
5867 if (variable_value_ != &::google::protobuf::internal::kEmptyString) {
5868 delete variable_value_;
5870 if (
this != default_instance_) {
5871 delete variable_metadata_;
5875 void SetVariableStatement::SetCachedSize(
int size)
const {
5876 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
5877 _cached_size_ = size;
5878 GOOGLE_SAFE_CONCURRENT_WRITES_END();
5880 const ::google::protobuf::Descriptor* SetVariableStatement::descriptor() {
5881 protobuf_AssignDescriptorsOnce();
5882 return SetVariableStatement_descriptor_;
5885 const SetVariableStatement& SetVariableStatement::default_instance() {
5886 if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto();
return *default_instance_;
5889 SetVariableStatement* SetVariableStatement::default_instance_ = NULL;
5891 SetVariableStatement* SetVariableStatement::New()
const {
5892 return new SetVariableStatement;
5895 void SetVariableStatement::Clear() {
5896 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
5897 if (has_variable_metadata()) {
5898 if (variable_metadata_ != NULL) variable_metadata_->::drizzled::message::FieldMetadata::Clear();
5900 if (has_variable_value()) {
5901 if (variable_value_ != &::google::protobuf::internal::kEmptyString) {
5902 variable_value_->clear();
5906 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
5907 mutable_unknown_fields()->Clear();
5910 bool SetVariableStatement::MergePartialFromCodedStream(
5911 ::google::protobuf::io::CodedInputStream* input) {
5912 #define DO_(EXPRESSION) if (!(EXPRESSION)) return false
5913 ::google::protobuf::uint32 tag;
5914 while ((tag = input->ReadTag()) != 0) {
5915 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
5918 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
5919 ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
5920 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
5921 input, mutable_variable_metadata()));
5923 goto handle_uninterpreted;
5925 if (input->ExpectTag(18))
goto parse_variable_value;
5931 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
5932 ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
5933 parse_variable_value:
5934 DO_(::google::protobuf::internal::WireFormatLite::ReadBytes(
5935 input, this->mutable_variable_value()));
5937 goto handle_uninterpreted;
5939 if (input->ExpectAtEnd())
return true;
5944 handle_uninterpreted:
5945 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
5946 ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
5949 DO_(::google::protobuf::internal::WireFormat::SkipField(
5950 input, tag, mutable_unknown_fields()));
5959 void SetVariableStatement::SerializeWithCachedSizes(
5960 ::google::protobuf::io::CodedOutputStream* output)
const {
5962 if (has_variable_metadata()) {
5963 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
5964 1, this->variable_metadata(), output);
5968 if (has_variable_value()) {
5969 ::google::protobuf::internal::WireFormatLite::WriteBytes(
5970 2, this->variable_value(), output);
5973 if (!unknown_fields().empty()) {
5974 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
5975 unknown_fields(), output);
5979 ::google::protobuf::uint8* SetVariableStatement::SerializeWithCachedSizesToArray(
5980 ::google::protobuf::uint8* target)
const {
5982 if (has_variable_metadata()) {
5983 target = ::google::protobuf::internal::WireFormatLite::
5984 WriteMessageNoVirtualToArray(
5985 1, this->variable_metadata(), target);
5989 if (has_variable_value()) {
5991 ::google::protobuf::internal::WireFormatLite::WriteBytesToArray(
5992 2, this->variable_value(), target);
5995 if (!unknown_fields().empty()) {
5996 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
5997 unknown_fields(), target);
6002 int SetVariableStatement::ByteSize()
const {
6005 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
6007 if (has_variable_metadata()) {
6009 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
6010 this->variable_metadata());
6014 if (has_variable_value()) {
6016 ::google::protobuf::internal::WireFormatLite::BytesSize(
6017 this->variable_value());
6021 if (!unknown_fields().empty()) {
6023 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
6026 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
6027 _cached_size_ = total_size;
6028 GOOGLE_SAFE_CONCURRENT_WRITES_END();
6032 void SetVariableStatement::MergeFrom(const ::google::protobuf::Message& from) {
6033 GOOGLE_CHECK_NE(&from,
this);
6034 const SetVariableStatement* source =
6035 ::google::protobuf::internal::dynamic_cast_if_available<const SetVariableStatement*>(
6037 if (source == NULL) {
6038 ::google::protobuf::internal::ReflectionOps::Merge(from,
this);
6044 void SetVariableStatement::MergeFrom(
const SetVariableStatement& from) {
6045 GOOGLE_CHECK_NE(&from,
this);
6046 if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
6047 if (from.has_variable_metadata()) {
6048 mutable_variable_metadata()->::drizzled::message::FieldMetadata::MergeFrom(from.variable_metadata());
6050 if (from.has_variable_value()) {
6051 set_variable_value(from.variable_value());
6054 mutable_unknown_fields()->MergeFrom(from.unknown_fields());
6057 void SetVariableStatement::CopyFrom(const ::google::protobuf::Message& from) {
6058 if (&from ==
this)
return;
6063 void SetVariableStatement::CopyFrom(
const SetVariableStatement& from) {
6064 if (&from ==
this)
return;
6069 bool SetVariableStatement::IsInitialized()
const {
6070 if ((_has_bits_[0] & 0x00000003) != 0x00000003)
return false;
6072 if (has_variable_metadata()) {
6073 if (!this->variable_metadata().IsInitialized())
return false;
6078 void SetVariableStatement::Swap(SetVariableStatement* other) {
6079 if (other !=
this) {
6080 std::swap(variable_metadata_, other->variable_metadata_);
6081 std::swap(variable_value_, other->variable_value_);
6082 std::swap(_has_bits_[0], other->_has_bits_[0]);
6083 _unknown_fields_.Swap(&other->_unknown_fields_);
6084 std::swap(_cached_size_, other->_cached_size_);
6088 ::google::protobuf::Metadata SetVariableStatement::GetMetadata()
const {
6089 protobuf_AssignDescriptorsOnce();
6090 ::google::protobuf::Metadata metadata;
6091 metadata.descriptor = SetVariableStatement_descriptor_;
6092 metadata.reflection = SetVariableStatement_reflection_;
6099 const ::google::protobuf::EnumDescriptor* Statement_Type_descriptor() {
6100 protobuf_AssignDescriptorsOnce();
6101 return Statement_Type_descriptor_;
6103 bool Statement_Type_IsValid(
int value) {
6126 const Statement_Type Statement::ROLLBACK;
6127 const Statement_Type Statement::INSERT;
6128 const Statement_Type Statement::DELETE;
6129 const Statement_Type Statement::UPDATE;
6130 const Statement_Type Statement::TRUNCATE_TABLE;
6131 const Statement_Type Statement::CREATE_SCHEMA;
6132 const Statement_Type Statement::ALTER_SCHEMA;
6133 const Statement_Type Statement::DROP_SCHEMA;
6134 const Statement_Type Statement::CREATE_TABLE;
6135 const Statement_Type Statement::ALTER_TABLE;
6136 const Statement_Type Statement::DROP_TABLE;
6137 const Statement_Type Statement::ROLLBACK_STATEMENT;
6138 const Statement_Type Statement::SET_VARIABLE;
6139 const Statement_Type Statement::RAW_SQL;
6140 const Statement_Type Statement::Type_MIN;
6141 const Statement_Type Statement::Type_MAX;
6142 const int Statement::Type_ARRAYSIZE;
6145 const int Statement::kTypeFieldNumber;
6146 const int Statement::kStartTimestampFieldNumber;
6147 const int Statement::kEndTimestampFieldNumber;
6148 const int Statement::kSqlFieldNumber;
6149 const int Statement::kInsertHeaderFieldNumber;
6150 const int Statement::kInsertDataFieldNumber;
6151 const int Statement::kUpdateHeaderFieldNumber;
6152 const int Statement::kUpdateDataFieldNumber;
6153 const int Statement::kDeleteHeaderFieldNumber;
6154 const int Statement::kDeleteDataFieldNumber;
6155 const int Statement::kTruncateTableStatementFieldNumber;
6156 const int Statement::kCreateSchemaStatementFieldNumber;
6157 const int Statement::kDropSchemaStatementFieldNumber;
6158 const int Statement::kAlterSchemaStatementFieldNumber;
6159 const int Statement::kCreateTableStatementFieldNumber;
6160 const int Statement::kAlterTableStatementFieldNumber;
6161 const int Statement::kDropTableStatementFieldNumber;
6162 const int Statement::kSetVariableStatementFieldNumber;
6163 const int Statement::kRawSqlSchemaFieldNumber;
6166 Statement::Statement()
6167 : ::google::protobuf::Message() {
6171 void Statement::InitAsDefaultInstance() {
6188 Statement::Statement(
const Statement& from)
6189 : ::google::protobuf::Message() {
6194 void Statement::SharedCtor() {
6197 start_timestamp_ = GOOGLE_ULONGLONG(0);
6198 end_timestamp_ = GOOGLE_ULONGLONG(0);
6199 sql_ =
const_cast< ::std::string*
>(&::google::protobuf::internal::kEmptyString);
6200 insert_header_ = NULL;
6201 insert_data_ = NULL;
6202 update_header_ = NULL;
6203 update_data_ = NULL;
6204 delete_header_ = NULL;
6205 delete_data_ = NULL;
6206 truncate_table_statement_ = NULL;
6207 create_schema_statement_ = NULL;
6208 drop_schema_statement_ = NULL;
6209 alter_schema_statement_ = NULL;
6210 create_table_statement_ = NULL;
6211 alter_table_statement_ = NULL;
6212 drop_table_statement_ = NULL;
6213 set_variable_statement_ = NULL;
6214 raw_sql_schema_ =
const_cast< ::std::string*
>(&::google::protobuf::internal::kEmptyString);
6215 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
6218 Statement::~Statement() {
6222 void Statement::SharedDtor() {
6223 if (sql_ != &::google::protobuf::internal::kEmptyString) {
6226 if (raw_sql_schema_ != &::google::protobuf::internal::kEmptyString) {
6227 delete raw_sql_schema_;
6229 if (
this != default_instance_) {
6230 delete insert_header_;
6231 delete insert_data_;
6232 delete update_header_;
6233 delete update_data_;
6234 delete delete_header_;
6235 delete delete_data_;
6236 delete truncate_table_statement_;
6237 delete create_schema_statement_;
6238 delete drop_schema_statement_;
6239 delete alter_schema_statement_;
6240 delete create_table_statement_;
6241 delete alter_table_statement_;
6242 delete drop_table_statement_;
6243 delete set_variable_statement_;
6247 void Statement::SetCachedSize(
int size)
const {
6248 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
6249 _cached_size_ = size;
6250 GOOGLE_SAFE_CONCURRENT_WRITES_END();
6252 const ::google::protobuf::Descriptor* Statement::descriptor() {
6253 protobuf_AssignDescriptorsOnce();
6254 return Statement_descriptor_;
6257 const Statement& Statement::default_instance() {
6258 if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto();
return *default_instance_;
6261 Statement* Statement::default_instance_ = NULL;
6267 void Statement::Clear() {
6268 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
6270 start_timestamp_ = GOOGLE_ULONGLONG(0);
6271 end_timestamp_ = GOOGLE_ULONGLONG(0);
6273 if (sql_ != &::google::protobuf::internal::kEmptyString) {
6277 if (has_insert_header()) {
6278 if (insert_header_ != NULL) insert_header_->::drizzled::message::InsertHeader::Clear();
6280 if (has_insert_data()) {
6281 if (insert_data_ != NULL) insert_data_->::drizzled::message::InsertData::Clear();
6283 if (has_update_header()) {
6284 if (update_header_ != NULL) update_header_->::drizzled::message::UpdateHeader::Clear();
6286 if (has_update_data()) {
6287 if (update_data_ != NULL) update_data_->::drizzled::message::UpdateData::Clear();
6290 if (_has_bits_[8 / 32] & (0xffu << (8 % 32))) {
6291 if (has_delete_header()) {
6292 if (delete_header_ != NULL) delete_header_->::drizzled::message::DeleteHeader::Clear();
6294 if (has_delete_data()) {
6295 if (delete_data_ != NULL) delete_data_->::drizzled::message::DeleteData::Clear();
6297 if (has_truncate_table_statement()) {
6298 if (truncate_table_statement_ != NULL) truncate_table_statement_->::drizzled::message::TruncateTableStatement::Clear();
6300 if (has_create_schema_statement()) {
6301 if (create_schema_statement_ != NULL) create_schema_statement_->::drizzled::message::CreateSchemaStatement::Clear();
6303 if (has_drop_schema_statement()) {
6304 if (drop_schema_statement_ != NULL) drop_schema_statement_->::drizzled::message::DropSchemaStatement::Clear();
6306 if (has_alter_schema_statement()) {
6307 if (alter_schema_statement_ != NULL) alter_schema_statement_->::drizzled::message::AlterSchemaStatement::Clear();
6309 if (has_create_table_statement()) {
6310 if (create_table_statement_ != NULL) create_table_statement_->::drizzled::message::CreateTableStatement::Clear();
6312 if (has_alter_table_statement()) {
6313 if (alter_table_statement_ != NULL) alter_table_statement_->::drizzled::message::AlterTableStatement::Clear();
6316 if (_has_bits_[16 / 32] & (0xffu << (16 % 32))) {
6317 if (has_drop_table_statement()) {
6318 if (drop_table_statement_ != NULL) drop_table_statement_->::drizzled::message::DropTableStatement::Clear();
6320 if (has_set_variable_statement()) {
6321 if (set_variable_statement_ != NULL) set_variable_statement_->::drizzled::message::SetVariableStatement::Clear();
6323 if (has_raw_sql_schema()) {
6324 if (raw_sql_schema_ != &::google::protobuf::internal::kEmptyString) {
6325 raw_sql_schema_->clear();
6329 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
6330 mutable_unknown_fields()->Clear();
6333 bool Statement::MergePartialFromCodedStream(
6334 ::google::protobuf::io::CodedInputStream* input) {
6335 #define DO_(EXPRESSION) if (!(EXPRESSION)) return false
6336 ::google::protobuf::uint32 tag;
6337 while ((tag = input->ReadTag()) != 0) {
6338 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
6341 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
6342 ::google::protobuf::internal::WireFormatLite::WIRETYPE_VARINT) {
6344 DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
6345 int, ::google::protobuf::internal::WireFormatLite::TYPE_ENUM>(
6347 if (::drizzled::message::Statement_Type_IsValid(value)) {
6348 set_type(static_cast< ::drizzled::message::Statement_Type >(value));
6350 mutable_unknown_fields()->AddVarint(1, value);
6353 goto handle_uninterpreted;
6355 if (input->ExpectTag(16))
goto parse_start_timestamp;
6361 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
6362 ::google::protobuf::internal::WireFormatLite::WIRETYPE_VARINT) {
6363 parse_start_timestamp:
6364 DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
6365 ::google::protobuf::uint64, ::google::protobuf::internal::WireFormatLite::TYPE_UINT64>(
6366 input, &start_timestamp_)));
6367 set_has_start_timestamp();
6369 goto handle_uninterpreted;
6371 if (input->ExpectTag(24))
goto parse_end_timestamp;
6377 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
6378 ::google::protobuf::internal::WireFormatLite::WIRETYPE_VARINT) {
6379 parse_end_timestamp:
6380 DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
6381 ::google::protobuf::uint64, ::google::protobuf::internal::WireFormatLite::TYPE_UINT64>(
6382 input, &end_timestamp_)));
6383 set_has_end_timestamp();
6385 goto handle_uninterpreted;
6387 if (input->ExpectTag(34))
goto parse_sql;
6393 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
6394 ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
6396 DO_(::google::protobuf::internal::WireFormatLite::ReadString(
6397 input, this->mutable_sql()));
6398 ::google::protobuf::internal::WireFormat::VerifyUTF8String(
6399 this->sql().data(), this->sql().length(),
6400 ::google::protobuf::internal::WireFormat::PARSE);
6402 goto handle_uninterpreted;
6404 if (input->ExpectTag(42))
goto parse_insert_header;
6410 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
6411 ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
6412 parse_insert_header:
6413 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
6414 input, mutable_insert_header()));
6416 goto handle_uninterpreted;
6418 if (input->ExpectTag(50))
goto parse_insert_data;
6424 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
6425 ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
6427 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
6428 input, mutable_insert_data()));
6430 goto handle_uninterpreted;
6432 if (input->ExpectTag(58))
goto parse_update_header;
6438 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
6439 ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
6440 parse_update_header:
6441 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
6442 input, mutable_update_header()));
6444 goto handle_uninterpreted;
6446 if (input->ExpectTag(66))
goto parse_update_data;
6452 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
6453 ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
6455 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
6456 input, mutable_update_data()));
6458 goto handle_uninterpreted;
6460 if (input->ExpectTag(74))
goto parse_delete_header;
6466 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
6467 ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
6468 parse_delete_header:
6469 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
6470 input, mutable_delete_header()));
6472 goto handle_uninterpreted;
6474 if (input->ExpectTag(82))
goto parse_delete_data;
6480 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
6481 ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
6483 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
6484 input, mutable_delete_data()));
6486 goto handle_uninterpreted;
6488 if (input->ExpectTag(90))
goto parse_truncate_table_statement;
6494 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
6495 ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
6496 parse_truncate_table_statement:
6497 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
6498 input, mutable_truncate_table_statement()));
6500 goto handle_uninterpreted;
6502 if (input->ExpectTag(98))
goto parse_create_schema_statement;
6508 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
6509 ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
6510 parse_create_schema_statement:
6511 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
6512 input, mutable_create_schema_statement()));
6514 goto handle_uninterpreted;
6516 if (input->ExpectTag(106))
goto parse_drop_schema_statement;
6522 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
6523 ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
6524 parse_drop_schema_statement:
6525 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
6526 input, mutable_drop_schema_statement()));
6528 goto handle_uninterpreted;
6530 if (input->ExpectTag(114))
goto parse_alter_schema_statement;
6536 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
6537 ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
6538 parse_alter_schema_statement:
6539 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
6540 input, mutable_alter_schema_statement()));
6542 goto handle_uninterpreted;
6544 if (input->ExpectTag(122))
goto parse_create_table_statement;
6550 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
6551 ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
6552 parse_create_table_statement:
6553 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
6554 input, mutable_create_table_statement()));
6556 goto handle_uninterpreted;
6558 if (input->ExpectTag(130))
goto parse_alter_table_statement;
6564 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
6565 ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
6566 parse_alter_table_statement:
6567 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
6568 input, mutable_alter_table_statement()));
6570 goto handle_uninterpreted;
6572 if (input->ExpectTag(138))
goto parse_drop_table_statement;
6578 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
6579 ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
6580 parse_drop_table_statement:
6581 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
6582 input, mutable_drop_table_statement()));
6584 goto handle_uninterpreted;
6586 if (input->ExpectTag(146))
goto parse_set_variable_statement;
6592 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
6593 ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
6594 parse_set_variable_statement:
6595 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
6596 input, mutable_set_variable_statement()));
6598 goto handle_uninterpreted;
6600 if (input->ExpectTag(154))
goto parse_raw_sql_schema;
6606 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
6607 ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
6608 parse_raw_sql_schema:
6609 DO_(::google::protobuf::internal::WireFormatLite::ReadString(
6610 input, this->mutable_raw_sql_schema()));
6611 ::google::protobuf::internal::WireFormat::VerifyUTF8String(
6612 this->raw_sql_schema().data(), this->raw_sql_schema().length(),
6613 ::google::protobuf::internal::WireFormat::PARSE);
6615 goto handle_uninterpreted;
6617 if (input->ExpectAtEnd())
return true;
6622 handle_uninterpreted:
6623 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
6624 ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
6627 DO_(::google::protobuf::internal::WireFormat::SkipField(
6628 input, tag, mutable_unknown_fields()));
6637 void Statement::SerializeWithCachedSizes(
6638 ::google::protobuf::io::CodedOutputStream* output)
const {
6641 ::google::protobuf::internal::WireFormatLite::WriteEnum(
6642 1, this->type(), output);
6646 if (has_start_timestamp()) {
6647 ::google::protobuf::internal::WireFormatLite::WriteUInt64(2, this->start_timestamp(), output);
6651 if (has_end_timestamp()) {
6652 ::google::protobuf::internal::WireFormatLite::WriteUInt64(3, this->end_timestamp(), output);
6657 ::google::protobuf::internal::WireFormat::VerifyUTF8String(
6658 this->sql().data(), this->sql().length(),
6659 ::google::protobuf::internal::WireFormat::SERIALIZE);
6660 ::google::protobuf::internal::WireFormatLite::WriteString(
6661 4, this->sql(), output);
6665 if (has_insert_header()) {
6666 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
6667 5, this->insert_header(), output);
6671 if (has_insert_data()) {
6672 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
6673 6, this->insert_data(), output);
6677 if (has_update_header()) {
6678 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
6679 7, this->update_header(), output);
6683 if (has_update_data()) {
6684 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
6685 8, this->update_data(), output);
6689 if (has_delete_header()) {
6690 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
6691 9, this->delete_header(), output);
6695 if (has_delete_data()) {
6696 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
6697 10, this->delete_data(), output);
6701 if (has_truncate_table_statement()) {
6702 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
6703 11, this->truncate_table_statement(), output);
6707 if (has_create_schema_statement()) {
6708 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
6709 12, this->create_schema_statement(), output);
6713 if (has_drop_schema_statement()) {
6714 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
6715 13, this->drop_schema_statement(), output);
6719 if (has_alter_schema_statement()) {
6720 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
6721 14, this->alter_schema_statement(), output);
6725 if (has_create_table_statement()) {
6726 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
6727 15, this->create_table_statement(), output);
6731 if (has_alter_table_statement()) {
6732 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
6733 16, this->alter_table_statement(), output);
6737 if (has_drop_table_statement()) {
6738 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
6739 17, this->drop_table_statement(), output);
6743 if (has_set_variable_statement()) {
6744 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
6745 18, this->set_variable_statement(), output);
6749 if (has_raw_sql_schema()) {
6750 ::google::protobuf::internal::WireFormat::VerifyUTF8String(
6751 this->raw_sql_schema().data(), this->raw_sql_schema().length(),
6752 ::google::protobuf::internal::WireFormat::SERIALIZE);
6753 ::google::protobuf::internal::WireFormatLite::WriteString(
6754 19, this->raw_sql_schema(), output);
6757 if (!unknown_fields().empty()) {
6758 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
6759 unknown_fields(), output);
6763 ::google::protobuf::uint8* Statement::SerializeWithCachedSizesToArray(
6764 ::google::protobuf::uint8* target)
const {
6767 target = ::google::protobuf::internal::WireFormatLite::WriteEnumToArray(
6768 1, this->type(), target);
6772 if (has_start_timestamp()) {
6773 target = ::google::protobuf::internal::WireFormatLite::WriteUInt64ToArray(2, this->start_timestamp(), target);
6777 if (has_end_timestamp()) {
6778 target = ::google::protobuf::internal::WireFormatLite::WriteUInt64ToArray(3, this->end_timestamp(), target);
6783 ::google::protobuf::internal::WireFormat::VerifyUTF8String(
6784 this->sql().data(), this->sql().length(),
6785 ::google::protobuf::internal::WireFormat::SERIALIZE);
6787 ::google::protobuf::internal::WireFormatLite::WriteStringToArray(
6788 4, this->sql(), target);
6792 if (has_insert_header()) {
6793 target = ::google::protobuf::internal::WireFormatLite::
6794 WriteMessageNoVirtualToArray(
6795 5, this->insert_header(), target);
6799 if (has_insert_data()) {
6800 target = ::google::protobuf::internal::WireFormatLite::
6801 WriteMessageNoVirtualToArray(
6802 6, this->insert_data(), target);
6806 if (has_update_header()) {
6807 target = ::google::protobuf::internal::WireFormatLite::
6808 WriteMessageNoVirtualToArray(
6809 7, this->update_header(), target);
6813 if (has_update_data()) {
6814 target = ::google::protobuf::internal::WireFormatLite::
6815 WriteMessageNoVirtualToArray(
6816 8, this->update_data(), target);
6820 if (has_delete_header()) {
6821 target = ::google::protobuf::internal::WireFormatLite::
6822 WriteMessageNoVirtualToArray(
6823 9, this->delete_header(), target);
6827 if (has_delete_data()) {
6828 target = ::google::protobuf::internal::WireFormatLite::
6829 WriteMessageNoVirtualToArray(
6830 10, this->delete_data(), target);
6834 if (has_truncate_table_statement()) {
6835 target = ::google::protobuf::internal::WireFormatLite::
6836 WriteMessageNoVirtualToArray(
6837 11, this->truncate_table_statement(), target);
6841 if (has_create_schema_statement()) {
6842 target = ::google::protobuf::internal::WireFormatLite::
6843 WriteMessageNoVirtualToArray(
6844 12, this->create_schema_statement(), target);
6848 if (has_drop_schema_statement()) {
6849 target = ::google::protobuf::internal::WireFormatLite::
6850 WriteMessageNoVirtualToArray(
6851 13, this->drop_schema_statement(), target);
6855 if (has_alter_schema_statement()) {
6856 target = ::google::protobuf::internal::WireFormatLite::
6857 WriteMessageNoVirtualToArray(
6858 14, this->alter_schema_statement(), target);
6862 if (has_create_table_statement()) {
6863 target = ::google::protobuf::internal::WireFormatLite::
6864 WriteMessageNoVirtualToArray(
6865 15, this->create_table_statement(), target);
6869 if (has_alter_table_statement()) {
6870 target = ::google::protobuf::internal::WireFormatLite::
6871 WriteMessageNoVirtualToArray(
6872 16, this->alter_table_statement(), target);
6876 if (has_drop_table_statement()) {
6877 target = ::google::protobuf::internal::WireFormatLite::
6878 WriteMessageNoVirtualToArray(
6879 17, this->drop_table_statement(), target);
6883 if (has_set_variable_statement()) {
6884 target = ::google::protobuf::internal::WireFormatLite::
6885 WriteMessageNoVirtualToArray(
6886 18, this->set_variable_statement(), target);
6890 if (has_raw_sql_schema()) {
6891 ::google::protobuf::internal::WireFormat::VerifyUTF8String(
6892 this->raw_sql_schema().data(), this->raw_sql_schema().length(),
6893 ::google::protobuf::internal::WireFormat::SERIALIZE);
6895 ::google::protobuf::internal::WireFormatLite::WriteStringToArray(
6896 19, this->raw_sql_schema(), target);
6899 if (!unknown_fields().empty()) {
6900 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
6901 unknown_fields(), target);
6906 int Statement::ByteSize()
const {
6909 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
6913 ::google::protobuf::internal::WireFormatLite::EnumSize(this->type());
6917 if (has_start_timestamp()) {
6919 ::google::protobuf::internal::WireFormatLite::UInt64Size(
6920 this->start_timestamp());
6924 if (has_end_timestamp()) {
6926 ::google::protobuf::internal::WireFormatLite::UInt64Size(
6927 this->end_timestamp());
6933 ::google::protobuf::internal::WireFormatLite::StringSize(
6938 if (has_insert_header()) {
6940 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
6941 this->insert_header());
6945 if (has_insert_data()) {
6947 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
6948 this->insert_data());
6952 if (has_update_header()) {
6954 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
6955 this->update_header());
6959 if (has_update_data()) {
6961 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
6962 this->update_data());
6966 if (_has_bits_[8 / 32] & (0xffu << (8 % 32))) {
6968 if (has_delete_header()) {
6970 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
6971 this->delete_header());
6975 if (has_delete_data()) {
6977 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
6978 this->delete_data());
6982 if (has_truncate_table_statement()) {
6984 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
6985 this->truncate_table_statement());
6989 if (has_create_schema_statement()) {
6991 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
6992 this->create_schema_statement());
6996 if (has_drop_schema_statement()) {
6998 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
6999 this->drop_schema_statement());
7003 if (has_alter_schema_statement()) {
7005 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
7006 this->alter_schema_statement());
7010 if (has_create_table_statement()) {
7012 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
7013 this->create_table_statement());
7017 if (has_alter_table_statement()) {
7019 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
7020 this->alter_table_statement());
7024 if (_has_bits_[16 / 32] & (0xffu << (16 % 32))) {
7026 if (has_drop_table_statement()) {
7028 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
7029 this->drop_table_statement());
7033 if (has_set_variable_statement()) {
7035 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
7036 this->set_variable_statement());
7040 if (has_raw_sql_schema()) {
7042 ::google::protobuf::internal::WireFormatLite::StringSize(
7043 this->raw_sql_schema());
7047 if (!unknown_fields().empty()) {
7049 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
7052 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
7053 _cached_size_ = total_size;
7054 GOOGLE_SAFE_CONCURRENT_WRITES_END();
7058 void Statement::MergeFrom(const ::google::protobuf::Message& from) {
7059 GOOGLE_CHECK_NE(&from,
this);
7061 ::google::protobuf::internal::dynamic_cast_if_available<const Statement*>(
7063 if (source == NULL) {
7064 ::google::protobuf::internal::ReflectionOps::Merge(from,
this);
7070 void Statement::MergeFrom(
const Statement& from) {
7071 GOOGLE_CHECK_NE(&from,
this);
7072 if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
7073 if (from.has_type()) {
7074 set_type(from.type());
7076 if (from.has_start_timestamp()) {
7077 set_start_timestamp(from.start_timestamp());
7079 if (from.has_end_timestamp()) {
7080 set_end_timestamp(from.end_timestamp());
7082 if (from.has_sql()) {
7083 set_sql(from.sql());
7085 if (from.has_insert_header()) {
7086 mutable_insert_header()->::drizzled::message::InsertHeader::MergeFrom(from.insert_header());
7088 if (from.has_insert_data()) {
7089 mutable_insert_data()->::drizzled::message::InsertData::MergeFrom(from.insert_data());
7091 if (from.has_update_header()) {
7092 mutable_update_header()->::drizzled::message::UpdateHeader::MergeFrom(from.update_header());
7094 if (from.has_update_data()) {
7095 mutable_update_data()->::drizzled::message::UpdateData::MergeFrom(from.update_data());
7098 if (from._has_bits_[8 / 32] & (0xffu << (8 % 32))) {
7099 if (from.has_delete_header()) {
7100 mutable_delete_header()->::drizzled::message::DeleteHeader::MergeFrom(from.delete_header());
7102 if (from.has_delete_data()) {
7103 mutable_delete_data()->::drizzled::message::DeleteData::MergeFrom(from.delete_data());
7105 if (from.has_truncate_table_statement()) {
7106 mutable_truncate_table_statement()->::drizzled::message::TruncateTableStatement::MergeFrom(from.truncate_table_statement());
7108 if (from.has_create_schema_statement()) {
7109 mutable_create_schema_statement()->::drizzled::message::CreateSchemaStatement::MergeFrom(from.create_schema_statement());
7111 if (from.has_drop_schema_statement()) {
7112 mutable_drop_schema_statement()->::drizzled::message::DropSchemaStatement::MergeFrom(from.drop_schema_statement());
7114 if (from.has_alter_schema_statement()) {
7115 mutable_alter_schema_statement()->::drizzled::message::AlterSchemaStatement::MergeFrom(from.alter_schema_statement());
7117 if (from.has_create_table_statement()) {
7118 mutable_create_table_statement()->::drizzled::message::CreateTableStatement::MergeFrom(from.create_table_statement());
7120 if (from.has_alter_table_statement()) {
7121 mutable_alter_table_statement()->::drizzled::message::AlterTableStatement::MergeFrom(from.alter_table_statement());
7124 if (from._has_bits_[16 / 32] & (0xffu << (16 % 32))) {
7125 if (from.has_drop_table_statement()) {
7126 mutable_drop_table_statement()->::drizzled::message::DropTableStatement::MergeFrom(from.drop_table_statement());
7128 if (from.has_set_variable_statement()) {
7129 mutable_set_variable_statement()->::drizzled::message::SetVariableStatement::MergeFrom(from.set_variable_statement());
7131 if (from.has_raw_sql_schema()) {
7132 set_raw_sql_schema(from.raw_sql_schema());
7135 mutable_unknown_fields()->MergeFrom(from.unknown_fields());
7138 void Statement::CopyFrom(const ::google::protobuf::Message& from) {
7139 if (&from ==
this)
return;
7144 void Statement::CopyFrom(
const Statement& from) {
7145 if (&from ==
this)
return;
7150 bool Statement::IsInitialized()
const {
7151 if ((_has_bits_[0] & 0x00000007) != 0x00000007)
return false;
7153 if (has_insert_header()) {
7154 if (!this->insert_header().IsInitialized())
return false;
7156 if (has_insert_data()) {
7157 if (!this->insert_data().IsInitialized())
return false;
7159 if (has_update_header()) {
7160 if (!this->update_header().IsInitialized())
return false;
7162 if (has_update_data()) {
7163 if (!this->update_data().IsInitialized())
return false;
7165 if (has_delete_header()) {
7166 if (!this->delete_header().IsInitialized())
return false;
7168 if (has_delete_data()) {
7169 if (!this->delete_data().IsInitialized())
return false;
7171 if (has_truncate_table_statement()) {
7172 if (!this->truncate_table_statement().IsInitialized())
return false;
7174 if (has_create_schema_statement()) {
7175 if (!this->create_schema_statement().IsInitialized())
return false;
7177 if (has_drop_schema_statement()) {
7178 if (!this->drop_schema_statement().IsInitialized())
return false;
7180 if (has_alter_schema_statement()) {
7181 if (!this->alter_schema_statement().IsInitialized())
return false;
7183 if (has_create_table_statement()) {
7184 if (!this->create_table_statement().IsInitialized())
return false;
7186 if (has_alter_table_statement()) {
7187 if (!this->alter_table_statement().IsInitialized())
return false;
7189 if (has_drop_table_statement()) {
7190 if (!this->drop_table_statement().IsInitialized())
return false;
7192 if (has_set_variable_statement()) {
7193 if (!this->set_variable_statement().IsInitialized())
return false;
7198 void Statement::Swap(
Statement* other) {
7199 if (other !=
this) {
7200 std::swap(type_, other->type_);
7201 std::swap(start_timestamp_, other->start_timestamp_);
7202 std::swap(end_timestamp_, other->end_timestamp_);
7203 std::swap(sql_, other->sql_);
7204 std::swap(insert_header_, other->insert_header_);
7205 std::swap(insert_data_, other->insert_data_);
7206 std::swap(update_header_, other->update_header_);
7207 std::swap(update_data_, other->update_data_);
7208 std::swap(delete_header_, other->delete_header_);
7209 std::swap(delete_data_, other->delete_data_);
7210 std::swap(truncate_table_statement_, other->truncate_table_statement_);
7211 std::swap(create_schema_statement_, other->create_schema_statement_);
7212 std::swap(drop_schema_statement_, other->drop_schema_statement_);
7213 std::swap(alter_schema_statement_, other->alter_schema_statement_);
7214 std::swap(create_table_statement_, other->create_table_statement_);
7215 std::swap(alter_table_statement_, other->alter_table_statement_);
7216 std::swap(drop_table_statement_, other->drop_table_statement_);
7217 std::swap(set_variable_statement_, other->set_variable_statement_);
7218 std::swap(raw_sql_schema_, other->raw_sql_schema_);
7219 std::swap(_has_bits_[0], other->_has_bits_[0]);
7220 _unknown_fields_.Swap(&other->_unknown_fields_);
7221 std::swap(_cached_size_, other->_cached_size_);
7225 ::google::protobuf::Metadata Statement::GetMetadata()
const {
7226 protobuf_AssignDescriptorsOnce();
7227 ::google::protobuf::Metadata metadata;
7228 metadata.descriptor = Statement_descriptor_;
7229 metadata.reflection = Statement_reflection_;
7237 const int Transaction::kTransactionContextFieldNumber;
7238 const int Transaction::kStatementFieldNumber;
7239 const int Transaction::kEventFieldNumber;
7240 const int Transaction::kSegmentIdFieldNumber;
7241 const int Transaction::kEndSegmentFieldNumber;
7244 Transaction::Transaction()
7245 : ::google::protobuf::Message() {
7249 void Transaction::InitAsDefaultInstance() {
7254 Transaction::Transaction(
const Transaction& from)
7255 : ::google::protobuf::Message() {
7260 void Transaction::SharedCtor() {
7262 transaction_context_ = NULL;
7265 end_segment_ =
false;
7266 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
7269 Transaction::~Transaction() {
7273 void Transaction::SharedDtor() {
7274 if (
this != default_instance_) {
7275 delete transaction_context_;
7280 void Transaction::SetCachedSize(
int size)
const {
7281 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
7282 _cached_size_ = size;
7283 GOOGLE_SAFE_CONCURRENT_WRITES_END();
7285 const ::google::protobuf::Descriptor* Transaction::descriptor() {
7286 protobuf_AssignDescriptorsOnce();
7287 return Transaction_descriptor_;
7290 const Transaction& Transaction::default_instance() {
7291 if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto();
return *default_instance_;
7294 Transaction* Transaction::default_instance_ = NULL;
7296 Transaction* Transaction::New()
const {
7297 return new Transaction;
7300 void Transaction::Clear() {
7301 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
7302 if (has_transaction_context()) {
7303 if (transaction_context_ != NULL) transaction_context_->::drizzled::message::TransactionContext::Clear();
7306 if (event_ != NULL) event_->::drizzled::message::Event::Clear();
7309 end_segment_ =
false;
7312 ::memset(_has_bits_, 0,
sizeof(_has_bits_));
7313 mutable_unknown_fields()->Clear();
7316 bool Transaction::MergePartialFromCodedStream(
7317 ::google::protobuf::io::CodedInputStream* input) {
7318 #define DO_(EXPRESSION) if (!(EXPRESSION)) return false
7319 ::google::protobuf::uint32 tag;
7320 while ((tag = input->ReadTag()) != 0) {
7321 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
7324 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
7325 ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
7326 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
7327 input, mutable_transaction_context()));
7329 goto handle_uninterpreted;
7331 if (input->ExpectTag(18))
goto parse_statement;
7337 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
7338 ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
7340 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
7341 input, add_statement()));
7343 goto handle_uninterpreted;
7345 if (input->ExpectTag(18))
goto parse_statement;
7346 if (input->ExpectTag(26))
goto parse_event;
7352 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
7353 ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
7355 DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
7356 input, mutable_event()));
7358 goto handle_uninterpreted;
7360 if (input->ExpectTag(32))
goto parse_segment_id;
7366 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
7367 ::google::protobuf::internal::WireFormatLite::WIRETYPE_VARINT) {
7369 DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
7370 ::google::protobuf::uint32, ::google::protobuf::internal::WireFormatLite::TYPE_UINT32>(
7371 input, &segment_id_)));
7372 set_has_segment_id();
7374 goto handle_uninterpreted;
7376 if (input->ExpectTag(40))
goto parse_end_segment;
7382 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
7383 ::google::protobuf::internal::WireFormatLite::WIRETYPE_VARINT) {
7385 DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
7386 bool, ::google::protobuf::internal::WireFormatLite::TYPE_BOOL>(
7387 input, &end_segment_)));
7388 set_has_end_segment();
7390 goto handle_uninterpreted;
7392 if (input->ExpectAtEnd())
return true;
7397 handle_uninterpreted:
7398 if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
7399 ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
7402 DO_(::google::protobuf::internal::WireFormat::SkipField(
7403 input, tag, mutable_unknown_fields()));
7412 void Transaction::SerializeWithCachedSizes(
7413 ::google::protobuf::io::CodedOutputStream* output)
const {
7415 if (has_transaction_context()) {
7416 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
7417 1, this->transaction_context(), output);
7421 for (
int i = 0; i < this->statement_size(); i++) {
7422 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
7423 2, this->statement(i), output);
7428 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
7429 3, this->event(), output);
7433 if (has_segment_id()) {
7434 ::google::protobuf::internal::WireFormatLite::WriteUInt32(4, this->segment_id(), output);
7438 if (has_end_segment()) {
7439 ::google::protobuf::internal::WireFormatLite::WriteBool(5, this->end_segment(), output);
7442 if (!unknown_fields().empty()) {
7443 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
7444 unknown_fields(), output);
7448 ::google::protobuf::uint8* Transaction::SerializeWithCachedSizesToArray(
7449 ::google::protobuf::uint8* target)
const {
7451 if (has_transaction_context()) {
7452 target = ::google::protobuf::internal::WireFormatLite::
7453 WriteMessageNoVirtualToArray(
7454 1, this->transaction_context(), target);
7458 for (
int i = 0; i < this->statement_size(); i++) {
7459 target = ::google::protobuf::internal::WireFormatLite::
7460 WriteMessageNoVirtualToArray(
7461 2, this->statement(i), target);
7466 target = ::google::protobuf::internal::WireFormatLite::
7467 WriteMessageNoVirtualToArray(
7468 3, this->event(), target);
7472 if (has_segment_id()) {
7473 target = ::google::protobuf::internal::WireFormatLite::WriteUInt32ToArray(4, this->segment_id(), target);
7477 if (has_end_segment()) {
7478 target = ::google::protobuf::internal::WireFormatLite::WriteBoolToArray(5, this->end_segment(), target);
7481 if (!unknown_fields().empty()) {
7482 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
7483 unknown_fields(), target);
7488 int Transaction::ByteSize()
const {
7491 if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
7493 if (has_transaction_context()) {
7495 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
7496 this->transaction_context());
7502 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
7507 if (has_segment_id()) {
7509 ::google::protobuf::internal::WireFormatLite::UInt32Size(
7510 this->segment_id());
7514 if (has_end_segment()) {
7515 total_size += 1 + 1;
7520 total_size += 1 * this->statement_size();
7521 for (
int i = 0; i < this->statement_size(); i++) {
7523 ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
7524 this->statement(i));
7527 if (!unknown_fields().empty()) {
7529 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
7532 GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
7533 _cached_size_ = total_size;
7534 GOOGLE_SAFE_CONCURRENT_WRITES_END();
7538 void Transaction::MergeFrom(const ::google::protobuf::Message& from) {
7539 GOOGLE_CHECK_NE(&from,
this);
7540 const Transaction* source =
7541 ::google::protobuf::internal::dynamic_cast_if_available<const Transaction*>(
7543 if (source == NULL) {
7544 ::google::protobuf::internal::ReflectionOps::Merge(from,
this);
7550 void Transaction::MergeFrom(
const Transaction& from) {
7551 GOOGLE_CHECK_NE(&from,
this);
7552 statement_.MergeFrom(from.statement_);
7553 if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
7554 if (from.has_transaction_context()) {
7555 mutable_transaction_context()->::drizzled::message::TransactionContext::MergeFrom(from.transaction_context());
7557 if (from.has_event()) {
7558 mutable_event()->::drizzled::message::Event::MergeFrom(from.event());
7560 if (from.has_segment_id()) {
7561 set_segment_id(from.segment_id());
7563 if (from.has_end_segment()) {
7564 set_end_segment(from.end_segment());
7567 mutable_unknown_fields()->MergeFrom(from.unknown_fields());
7570 void Transaction::CopyFrom(const ::google::protobuf::Message& from) {
7571 if (&from ==
this)
return;
7576 void Transaction::CopyFrom(
const Transaction& from) {
7577 if (&from ==
this)
return;
7582 bool Transaction::IsInitialized()
const {
7583 if ((_has_bits_[0] & 0x00000001) != 0x00000001)
return false;
7585 if (has_transaction_context()) {
7586 if (!this->transaction_context().IsInitialized())
return false;
7588 for (
int i = 0; i < statement_size(); i++) {
7589 if (!this->statement(i).IsInitialized())
return false;
7592 if (!this->event().IsInitialized())
return false;
7597 void Transaction::Swap(Transaction* other) {
7598 if (other !=
this) {
7599 std::swap(transaction_context_, other->transaction_context_);
7600 statement_.Swap(&other->statement_);
7601 std::swap(event_, other->event_);
7602 std::swap(segment_id_, other->segment_id_);
7603 std::swap(end_segment_, other->end_segment_);
7604 std::swap(_has_bits_[0], other->_has_bits_[0]);
7605 _unknown_fields_.Swap(&other->_unknown_fields_);
7606 std::swap(_cached_size_, other->_cached_size_);
7610 ::google::protobuf::Metadata Transaction::GetMetadata()
const {
7611 protobuf_AssignDescriptorsOnce();
7612 ::google::protobuf::Metadata metadata;
7613 metadata.descriptor = Transaction_descriptor_;
7614 metadata.reflection = Transaction_reflection_;