1
// Generated by the protocol buffer compiler. DO NOT EDIT!
3
#define INTERNAL_SUPPRESS_PROTOBUF_FIELD_DEPRECATION
4
#include "transaction.pb.h"
5
#include <google/protobuf/stubs/once.h>
6
#include <google/protobuf/io/coded_stream.h>
7
#include <google/protobuf/wire_format_lite_inl.h>
8
#include <google/protobuf/descriptor.h>
9
#include <google/protobuf/reflection_ops.h>
10
#include <google/protobuf/wire_format.h>
17
const ::google::protobuf::Descriptor* FieldMetadata_descriptor_ = NULL;
18
const ::google::protobuf::internal::GeneratedMessageReflection*
19
FieldMetadata_reflection_ = NULL;
20
const ::google::protobuf::Descriptor* TableMetadata_descriptor_ = NULL;
21
const ::google::protobuf::internal::GeneratedMessageReflection*
22
TableMetadata_reflection_ = NULL;
23
const ::google::protobuf::Descriptor* TransactionContext_descriptor_ = NULL;
24
const ::google::protobuf::internal::GeneratedMessageReflection*
25
TransactionContext_reflection_ = NULL;
26
const ::google::protobuf::Descriptor* InsertRecord_descriptor_ = NULL;
27
const ::google::protobuf::internal::GeneratedMessageReflection*
28
InsertRecord_reflection_ = NULL;
29
const ::google::protobuf::Descriptor* InsertHeader_descriptor_ = NULL;
30
const ::google::protobuf::internal::GeneratedMessageReflection*
31
InsertHeader_reflection_ = NULL;
32
const ::google::protobuf::Descriptor* InsertData_descriptor_ = NULL;
33
const ::google::protobuf::internal::GeneratedMessageReflection*
34
InsertData_reflection_ = NULL;
35
const ::google::protobuf::Descriptor* UpdateRecord_descriptor_ = NULL;
36
const ::google::protobuf::internal::GeneratedMessageReflection*
37
UpdateRecord_reflection_ = NULL;
38
const ::google::protobuf::Descriptor* UpdateHeader_descriptor_ = NULL;
39
const ::google::protobuf::internal::GeneratedMessageReflection*
40
UpdateHeader_reflection_ = NULL;
41
const ::google::protobuf::Descriptor* UpdateData_descriptor_ = NULL;
42
const ::google::protobuf::internal::GeneratedMessageReflection*
43
UpdateData_reflection_ = NULL;
44
const ::google::protobuf::Descriptor* DeleteRecord_descriptor_ = NULL;
45
const ::google::protobuf::internal::GeneratedMessageReflection*
46
DeleteRecord_reflection_ = NULL;
47
const ::google::protobuf::Descriptor* DeleteHeader_descriptor_ = NULL;
48
const ::google::protobuf::internal::GeneratedMessageReflection*
49
DeleteHeader_reflection_ = NULL;
50
const ::google::protobuf::Descriptor* DeleteData_descriptor_ = NULL;
51
const ::google::protobuf::internal::GeneratedMessageReflection*
52
DeleteData_reflection_ = NULL;
53
const ::google::protobuf::Descriptor* TruncateTableStatement_descriptor_ = NULL;
54
const ::google::protobuf::internal::GeneratedMessageReflection*
55
TruncateTableStatement_reflection_ = NULL;
56
const ::google::protobuf::Descriptor* CreateSchemaStatement_descriptor_ = NULL;
57
const ::google::protobuf::internal::GeneratedMessageReflection*
58
CreateSchemaStatement_reflection_ = NULL;
59
const ::google::protobuf::Descriptor* AlterSchemaStatement_descriptor_ = NULL;
60
const ::google::protobuf::internal::GeneratedMessageReflection*
61
AlterSchemaStatement_reflection_ = NULL;
62
const ::google::protobuf::Descriptor* DropSchemaStatement_descriptor_ = NULL;
63
const ::google::protobuf::internal::GeneratedMessageReflection*
64
DropSchemaStatement_reflection_ = NULL;
65
const ::google::protobuf::Descriptor* CreateTableStatement_descriptor_ = NULL;
66
const ::google::protobuf::internal::GeneratedMessageReflection*
67
CreateTableStatement_reflection_ = NULL;
68
const ::google::protobuf::Descriptor* AlterTableStatement_descriptor_ = NULL;
69
const ::google::protobuf::internal::GeneratedMessageReflection*
70
AlterTableStatement_reflection_ = NULL;
71
const ::google::protobuf::Descriptor* DropTableStatement_descriptor_ = NULL;
72
const ::google::protobuf::internal::GeneratedMessageReflection*
73
DropTableStatement_reflection_ = NULL;
74
const ::google::protobuf::Descriptor* SetVariableStatement_descriptor_ = NULL;
75
const ::google::protobuf::internal::GeneratedMessageReflection*
76
SetVariableStatement_reflection_ = NULL;
77
const ::google::protobuf::Descriptor* Statement_descriptor_ = NULL;
78
const ::google::protobuf::internal::GeneratedMessageReflection*
79
Statement_reflection_ = NULL;
80
const ::google::protobuf::EnumDescriptor* Statement_Type_descriptor_ = NULL;
81
const ::google::protobuf::Descriptor* Transaction_descriptor_ = NULL;
82
const ::google::protobuf::internal::GeneratedMessageReflection*
83
Transaction_reflection_ = NULL;
88
void protobuf_AssignDesc_transaction_2eproto() {
89
protobuf_AddDesc_transaction_2eproto();
90
const ::google::protobuf::FileDescriptor* file =
91
::google::protobuf::DescriptorPool::generated_pool()->FindFileByName(
93
GOOGLE_CHECK(file != NULL);
94
FieldMetadata_descriptor_ = file->message_type(0);
95
static const int FieldMetadata_offsets_[2] = {
96
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(FieldMetadata, type_),
97
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(FieldMetadata, name_),
99
FieldMetadata_reflection_ =
100
new ::google::protobuf::internal::GeneratedMessageReflection(
101
FieldMetadata_descriptor_,
102
FieldMetadata::default_instance_,
103
FieldMetadata_offsets_,
104
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(FieldMetadata, _has_bits_[0]),
105
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(FieldMetadata, _unknown_fields_),
107
::google::protobuf::DescriptorPool::generated_pool(),
108
::google::protobuf::MessageFactory::generated_factory(),
109
sizeof(FieldMetadata));
110
TableMetadata_descriptor_ = file->message_type(1);
111
static const int TableMetadata_offsets_[2] = {
112
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(TableMetadata, schema_name_),
113
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(TableMetadata, table_name_),
115
TableMetadata_reflection_ =
116
new ::google::protobuf::internal::GeneratedMessageReflection(
117
TableMetadata_descriptor_,
118
TableMetadata::default_instance_,
119
TableMetadata_offsets_,
120
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(TableMetadata, _has_bits_[0]),
121
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(TableMetadata, _unknown_fields_),
123
::google::protobuf::DescriptorPool::generated_pool(),
124
::google::protobuf::MessageFactory::generated_factory(),
125
sizeof(TableMetadata));
126
TransactionContext_descriptor_ = file->message_type(2);
127
static const int TransactionContext_offsets_[4] = {
128
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(TransactionContext, server_id_),
129
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(TransactionContext, transaction_id_),
130
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(TransactionContext, start_timestamp_),
131
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(TransactionContext, end_timestamp_),
133
TransactionContext_reflection_ =
134
new ::google::protobuf::internal::GeneratedMessageReflection(
135
TransactionContext_descriptor_,
136
TransactionContext::default_instance_,
137
TransactionContext_offsets_,
138
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(TransactionContext, _has_bits_[0]),
139
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(TransactionContext, _unknown_fields_),
141
::google::protobuf::DescriptorPool::generated_pool(),
142
::google::protobuf::MessageFactory::generated_factory(),
143
sizeof(TransactionContext));
144
InsertRecord_descriptor_ = file->message_type(3);
145
static const int InsertRecord_offsets_[1] = {
146
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(InsertRecord, insert_value_),
148
InsertRecord_reflection_ =
149
new ::google::protobuf::internal::GeneratedMessageReflection(
150
InsertRecord_descriptor_,
151
InsertRecord::default_instance_,
152
InsertRecord_offsets_,
153
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(InsertRecord, _has_bits_[0]),
154
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(InsertRecord, _unknown_fields_),
156
::google::protobuf::DescriptorPool::generated_pool(),
157
::google::protobuf::MessageFactory::generated_factory(),
158
sizeof(InsertRecord));
159
InsertHeader_descriptor_ = file->message_type(4);
160
static const int InsertHeader_offsets_[2] = {
161
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(InsertHeader, table_metadata_),
162
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(InsertHeader, field_metadata_),
164
InsertHeader_reflection_ =
165
new ::google::protobuf::internal::GeneratedMessageReflection(
166
InsertHeader_descriptor_,
167
InsertHeader::default_instance_,
168
InsertHeader_offsets_,
169
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(InsertHeader, _has_bits_[0]),
170
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(InsertHeader, _unknown_fields_),
172
::google::protobuf::DescriptorPool::generated_pool(),
173
::google::protobuf::MessageFactory::generated_factory(),
174
sizeof(InsertHeader));
175
InsertData_descriptor_ = file->message_type(5);
176
static const int InsertData_offsets_[3] = {
177
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(InsertData, segment_id_),
178
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(InsertData, end_segment_),
179
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(InsertData, record_),
181
InsertData_reflection_ =
182
new ::google::protobuf::internal::GeneratedMessageReflection(
183
InsertData_descriptor_,
184
InsertData::default_instance_,
186
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(InsertData, _has_bits_[0]),
187
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(InsertData, _unknown_fields_),
189
::google::protobuf::DescriptorPool::generated_pool(),
190
::google::protobuf::MessageFactory::generated_factory(),
192
UpdateRecord_descriptor_ = file->message_type(6);
193
static const int UpdateRecord_offsets_[3] = {
194
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(UpdateRecord, key_value_),
195
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(UpdateRecord, after_value_),
196
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(UpdateRecord, before_value_),
198
UpdateRecord_reflection_ =
199
new ::google::protobuf::internal::GeneratedMessageReflection(
200
UpdateRecord_descriptor_,
201
UpdateRecord::default_instance_,
202
UpdateRecord_offsets_,
203
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(UpdateRecord, _has_bits_[0]),
204
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(UpdateRecord, _unknown_fields_),
206
::google::protobuf::DescriptorPool::generated_pool(),
207
::google::protobuf::MessageFactory::generated_factory(),
208
sizeof(UpdateRecord));
209
UpdateHeader_descriptor_ = file->message_type(7);
210
static const int UpdateHeader_offsets_[3] = {
211
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(UpdateHeader, table_metadata_),
212
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(UpdateHeader, key_field_metadata_),
213
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(UpdateHeader, set_field_metadata_),
215
UpdateHeader_reflection_ =
216
new ::google::protobuf::internal::GeneratedMessageReflection(
217
UpdateHeader_descriptor_,
218
UpdateHeader::default_instance_,
219
UpdateHeader_offsets_,
220
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(UpdateHeader, _has_bits_[0]),
221
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(UpdateHeader, _unknown_fields_),
223
::google::protobuf::DescriptorPool::generated_pool(),
224
::google::protobuf::MessageFactory::generated_factory(),
225
sizeof(UpdateHeader));
226
UpdateData_descriptor_ = file->message_type(8);
227
static const int UpdateData_offsets_[3] = {
228
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(UpdateData, segment_id_),
229
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(UpdateData, end_segment_),
230
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(UpdateData, record_),
232
UpdateData_reflection_ =
233
new ::google::protobuf::internal::GeneratedMessageReflection(
234
UpdateData_descriptor_,
235
UpdateData::default_instance_,
237
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(UpdateData, _has_bits_[0]),
238
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(UpdateData, _unknown_fields_),
240
::google::protobuf::DescriptorPool::generated_pool(),
241
::google::protobuf::MessageFactory::generated_factory(),
243
DeleteRecord_descriptor_ = file->message_type(9);
244
static const int DeleteRecord_offsets_[1] = {
245
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DeleteRecord, key_value_),
247
DeleteRecord_reflection_ =
248
new ::google::protobuf::internal::GeneratedMessageReflection(
249
DeleteRecord_descriptor_,
250
DeleteRecord::default_instance_,
251
DeleteRecord_offsets_,
252
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DeleteRecord, _has_bits_[0]),
253
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DeleteRecord, _unknown_fields_),
255
::google::protobuf::DescriptorPool::generated_pool(),
256
::google::protobuf::MessageFactory::generated_factory(),
257
sizeof(DeleteRecord));
258
DeleteHeader_descriptor_ = file->message_type(10);
259
static const int DeleteHeader_offsets_[2] = {
260
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DeleteHeader, table_metadata_),
261
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DeleteHeader, key_field_metadata_),
263
DeleteHeader_reflection_ =
264
new ::google::protobuf::internal::GeneratedMessageReflection(
265
DeleteHeader_descriptor_,
266
DeleteHeader::default_instance_,
267
DeleteHeader_offsets_,
268
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DeleteHeader, _has_bits_[0]),
269
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DeleteHeader, _unknown_fields_),
271
::google::protobuf::DescriptorPool::generated_pool(),
272
::google::protobuf::MessageFactory::generated_factory(),
273
sizeof(DeleteHeader));
274
DeleteData_descriptor_ = file->message_type(11);
275
static const int DeleteData_offsets_[3] = {
276
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DeleteData, segment_id_),
277
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DeleteData, end_segment_),
278
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DeleteData, record_),
280
DeleteData_reflection_ =
281
new ::google::protobuf::internal::GeneratedMessageReflection(
282
DeleteData_descriptor_,
283
DeleteData::default_instance_,
285
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DeleteData, _has_bits_[0]),
286
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DeleteData, _unknown_fields_),
288
::google::protobuf::DescriptorPool::generated_pool(),
289
::google::protobuf::MessageFactory::generated_factory(),
291
TruncateTableStatement_descriptor_ = file->message_type(12);
292
static const int TruncateTableStatement_offsets_[1] = {
293
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(TruncateTableStatement, table_metadata_),
295
TruncateTableStatement_reflection_ =
296
new ::google::protobuf::internal::GeneratedMessageReflection(
297
TruncateTableStatement_descriptor_,
298
TruncateTableStatement::default_instance_,
299
TruncateTableStatement_offsets_,
300
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(TruncateTableStatement, _has_bits_[0]),
301
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(TruncateTableStatement, _unknown_fields_),
303
::google::protobuf::DescriptorPool::generated_pool(),
304
::google::protobuf::MessageFactory::generated_factory(),
305
sizeof(TruncateTableStatement));
306
CreateSchemaStatement_descriptor_ = file->message_type(13);
307
static const int CreateSchemaStatement_offsets_[1] = {
308
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(CreateSchemaStatement, schema_),
310
CreateSchemaStatement_reflection_ =
311
new ::google::protobuf::internal::GeneratedMessageReflection(
312
CreateSchemaStatement_descriptor_,
313
CreateSchemaStatement::default_instance_,
314
CreateSchemaStatement_offsets_,
315
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(CreateSchemaStatement, _has_bits_[0]),
316
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(CreateSchemaStatement, _unknown_fields_),
318
::google::protobuf::DescriptorPool::generated_pool(),
319
::google::protobuf::MessageFactory::generated_factory(),
320
sizeof(CreateSchemaStatement));
321
AlterSchemaStatement_descriptor_ = file->message_type(14);
322
static const int AlterSchemaStatement_offsets_[2] = {
323
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(AlterSchemaStatement, before_),
324
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(AlterSchemaStatement, after_),
326
AlterSchemaStatement_reflection_ =
327
new ::google::protobuf::internal::GeneratedMessageReflection(
328
AlterSchemaStatement_descriptor_,
329
AlterSchemaStatement::default_instance_,
330
AlterSchemaStatement_offsets_,
331
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(AlterSchemaStatement, _has_bits_[0]),
332
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(AlterSchemaStatement, _unknown_fields_),
334
::google::protobuf::DescriptorPool::generated_pool(),
335
::google::protobuf::MessageFactory::generated_factory(),
336
sizeof(AlterSchemaStatement));
337
DropSchemaStatement_descriptor_ = file->message_type(15);
338
static const int DropSchemaStatement_offsets_[1] = {
339
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DropSchemaStatement, schema_name_),
341
DropSchemaStatement_reflection_ =
342
new ::google::protobuf::internal::GeneratedMessageReflection(
343
DropSchemaStatement_descriptor_,
344
DropSchemaStatement::default_instance_,
345
DropSchemaStatement_offsets_,
346
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DropSchemaStatement, _has_bits_[0]),
347
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DropSchemaStatement, _unknown_fields_),
349
::google::protobuf::DescriptorPool::generated_pool(),
350
::google::protobuf::MessageFactory::generated_factory(),
351
sizeof(DropSchemaStatement));
352
CreateTableStatement_descriptor_ = file->message_type(16);
353
static const int CreateTableStatement_offsets_[1] = {
354
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(CreateTableStatement, table_),
356
CreateTableStatement_reflection_ =
357
new ::google::protobuf::internal::GeneratedMessageReflection(
358
CreateTableStatement_descriptor_,
359
CreateTableStatement::default_instance_,
360
CreateTableStatement_offsets_,
361
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(CreateTableStatement, _has_bits_[0]),
362
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(CreateTableStatement, _unknown_fields_),
364
::google::protobuf::DescriptorPool::generated_pool(),
365
::google::protobuf::MessageFactory::generated_factory(),
366
sizeof(CreateTableStatement));
367
AlterTableStatement_descriptor_ = file->message_type(17);
368
static const int AlterTableStatement_offsets_[2] = {
369
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(AlterTableStatement, before_),
370
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(AlterTableStatement, after_),
372
AlterTableStatement_reflection_ =
373
new ::google::protobuf::internal::GeneratedMessageReflection(
374
AlterTableStatement_descriptor_,
375
AlterTableStatement::default_instance_,
376
AlterTableStatement_offsets_,
377
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(AlterTableStatement, _has_bits_[0]),
378
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(AlterTableStatement, _unknown_fields_),
380
::google::protobuf::DescriptorPool::generated_pool(),
381
::google::protobuf::MessageFactory::generated_factory(),
382
sizeof(AlterTableStatement));
383
DropTableStatement_descriptor_ = file->message_type(18);
384
static const int DropTableStatement_offsets_[2] = {
385
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DropTableStatement, table_metadata_),
386
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DropTableStatement, if_exists_clause_),
388
DropTableStatement_reflection_ =
389
new ::google::protobuf::internal::GeneratedMessageReflection(
390
DropTableStatement_descriptor_,
391
DropTableStatement::default_instance_,
392
DropTableStatement_offsets_,
393
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DropTableStatement, _has_bits_[0]),
394
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(DropTableStatement, _unknown_fields_),
396
::google::protobuf::DescriptorPool::generated_pool(),
397
::google::protobuf::MessageFactory::generated_factory(),
398
sizeof(DropTableStatement));
399
SetVariableStatement_descriptor_ = file->message_type(19);
400
static const int SetVariableStatement_offsets_[2] = {
401
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(SetVariableStatement, variable_metadata_),
402
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(SetVariableStatement, variable_value_),
404
SetVariableStatement_reflection_ =
405
new ::google::protobuf::internal::GeneratedMessageReflection(
406
SetVariableStatement_descriptor_,
407
SetVariableStatement::default_instance_,
408
SetVariableStatement_offsets_,
409
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(SetVariableStatement, _has_bits_[0]),
410
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(SetVariableStatement, _unknown_fields_),
412
::google::protobuf::DescriptorPool::generated_pool(),
413
::google::protobuf::MessageFactory::generated_factory(),
414
sizeof(SetVariableStatement));
415
Statement_descriptor_ = file->message_type(20);
416
static const int Statement_offsets_[18] = {
417
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(Statement, type_),
418
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(Statement, start_timestamp_),
419
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(Statement, end_timestamp_),
420
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(Statement, sql_),
421
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(Statement, insert_header_),
422
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(Statement, insert_data_),
423
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(Statement, update_header_),
424
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(Statement, update_data_),
425
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(Statement, delete_header_),
426
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(Statement, delete_data_),
427
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(Statement, truncate_table_statement_),
428
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(Statement, create_schema_statement_),
429
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(Statement, drop_schema_statement_),
430
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(Statement, alter_schema_statement_),
431
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(Statement, create_table_statement_),
432
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(Statement, alter_table_statement_),
433
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(Statement, drop_table_statement_),
434
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(Statement, set_variable_statement_),
436
Statement_reflection_ =
437
new ::google::protobuf::internal::GeneratedMessageReflection(
438
Statement_descriptor_,
439
Statement::default_instance_,
441
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(Statement, _has_bits_[0]),
442
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(Statement, _unknown_fields_),
444
::google::protobuf::DescriptorPool::generated_pool(),
445
::google::protobuf::MessageFactory::generated_factory(),
447
Statement_Type_descriptor_ = Statement_descriptor_->enum_type(0);
448
Transaction_descriptor_ = file->message_type(21);
449
static const int Transaction_offsets_[2] = {
450
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(Transaction, transaction_context_),
451
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(Transaction, statement_),
453
Transaction_reflection_ =
454
new ::google::protobuf::internal::GeneratedMessageReflection(
455
Transaction_descriptor_,
456
Transaction::default_instance_,
457
Transaction_offsets_,
458
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(Transaction, _has_bits_[0]),
459
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(Transaction, _unknown_fields_),
461
::google::protobuf::DescriptorPool::generated_pool(),
462
::google::protobuf::MessageFactory::generated_factory(),
463
sizeof(Transaction));
468
GOOGLE_PROTOBUF_DECLARE_ONCE(protobuf_AssignDescriptors_once_);
469
inline void protobuf_AssignDescriptorsOnce() {
470
::google::protobuf::GoogleOnceInit(&protobuf_AssignDescriptors_once_,
471
&protobuf_AssignDesc_transaction_2eproto);
474
void protobuf_RegisterTypes(const ::std::string&) {
475
protobuf_AssignDescriptorsOnce();
476
::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
477
FieldMetadata_descriptor_, &FieldMetadata::default_instance());
478
::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
479
TableMetadata_descriptor_, &TableMetadata::default_instance());
480
::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
481
TransactionContext_descriptor_, &TransactionContext::default_instance());
482
::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
483
InsertRecord_descriptor_, &InsertRecord::default_instance());
484
::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
485
InsertHeader_descriptor_, &InsertHeader::default_instance());
486
::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
487
InsertData_descriptor_, &InsertData::default_instance());
488
::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
489
UpdateRecord_descriptor_, &UpdateRecord::default_instance());
490
::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
491
UpdateHeader_descriptor_, &UpdateHeader::default_instance());
492
::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
493
UpdateData_descriptor_, &UpdateData::default_instance());
494
::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
495
DeleteRecord_descriptor_, &DeleteRecord::default_instance());
496
::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
497
DeleteHeader_descriptor_, &DeleteHeader::default_instance());
498
::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
499
DeleteData_descriptor_, &DeleteData::default_instance());
500
::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
501
TruncateTableStatement_descriptor_, &TruncateTableStatement::default_instance());
502
::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
503
CreateSchemaStatement_descriptor_, &CreateSchemaStatement::default_instance());
504
::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
505
AlterSchemaStatement_descriptor_, &AlterSchemaStatement::default_instance());
506
::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
507
DropSchemaStatement_descriptor_, &DropSchemaStatement::default_instance());
508
::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
509
CreateTableStatement_descriptor_, &CreateTableStatement::default_instance());
510
::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
511
AlterTableStatement_descriptor_, &AlterTableStatement::default_instance());
512
::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
513
DropTableStatement_descriptor_, &DropTableStatement::default_instance());
514
::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
515
SetVariableStatement_descriptor_, &SetVariableStatement::default_instance());
516
::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
517
Statement_descriptor_, &Statement::default_instance());
518
::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
519
Transaction_descriptor_, &Transaction::default_instance());
524
void protobuf_ShutdownFile_transaction_2eproto() {
525
delete FieldMetadata::default_instance_;
526
delete FieldMetadata_reflection_;
527
delete TableMetadata::default_instance_;
528
delete TableMetadata_reflection_;
529
delete TransactionContext::default_instance_;
530
delete TransactionContext_reflection_;
531
delete InsertRecord::default_instance_;
532
delete InsertRecord_reflection_;
533
delete InsertHeader::default_instance_;
534
delete InsertHeader_reflection_;
535
delete InsertData::default_instance_;
536
delete InsertData_reflection_;
537
delete UpdateRecord::default_instance_;
538
delete UpdateRecord_reflection_;
539
delete UpdateHeader::default_instance_;
540
delete UpdateHeader_reflection_;
541
delete UpdateData::default_instance_;
542
delete UpdateData_reflection_;
543
delete DeleteRecord::default_instance_;
544
delete DeleteRecord_reflection_;
545
delete DeleteHeader::default_instance_;
546
delete DeleteHeader_reflection_;
547
delete DeleteData::default_instance_;
548
delete DeleteData_reflection_;
549
delete TruncateTableStatement::default_instance_;
550
delete TruncateTableStatement_reflection_;
551
delete CreateSchemaStatement::default_instance_;
552
delete CreateSchemaStatement_reflection_;
553
delete AlterSchemaStatement::default_instance_;
554
delete AlterSchemaStatement_reflection_;
555
delete DropSchemaStatement::default_instance_;
556
delete DropSchemaStatement_reflection_;
557
delete CreateTableStatement::default_instance_;
558
delete CreateTableStatement_reflection_;
559
delete AlterTableStatement::default_instance_;
560
delete AlterTableStatement_reflection_;
561
delete DropTableStatement::default_instance_;
562
delete DropTableStatement_reflection_;
563
delete SetVariableStatement::default_instance_;
564
delete SetVariableStatement_reflection_;
565
delete Statement::default_instance_;
566
delete Statement_reflection_;
567
delete Transaction::default_instance_;
568
delete Transaction_reflection_;
571
void protobuf_AddDesc_transaction_2eproto() {
572
static bool already_here = false;
573
if (already_here) return;
575
GOOGLE_PROTOBUF_VERIFY_VERSION;
577
::drizzled::message::protobuf_AddDesc_table_2eproto();
578
::drizzled::message::protobuf_AddDesc_schema_2eproto();
579
::google::protobuf::DescriptorPool::InternalAddGeneratedFile(
580
"\n\021transaction.proto\022\020drizzled.message\032\013t"
581
"able.proto\032\014schema.proto\"T\n\rFieldMetadat"
582
"a\0225\n\004type\030\001 \002(\0162\'.drizzled.message.Table"
583
".Field.FieldType\022\014\n\004name\030\002 \002(\t\"8\n\rTableM"
584
"etadata\022\023\n\013schema_name\030\001 \002(\t\022\022\n\ntable_na"
585
"me\030\002 \002(\t\"o\n\022TransactionContext\022\021\n\tserver"
586
"_id\030\001 \002(\r\022\026\n\016transaction_id\030\002 \002(\004\022\027\n\017sta"
587
"rt_timestamp\030\003 \002(\004\022\025\n\rend_timestamp\030\004 \002("
588
"\004\"$\n\014InsertRecord\022\024\n\014insert_value\030\001 \003(\014\""
589
"\200\001\n\014InsertHeader\0227\n\016table_metadata\030\001 \002(\013"
590
"2\037.drizzled.message.TableMetadata\0227\n\016fie"
591
"ld_metadata\030\002 \003(\0132\037.drizzled.message.Fie"
592
"ldMetadata\"e\n\nInsertData\022\022\n\nsegment_id\030\001"
593
" \002(\r\022\023\n\013end_segment\030\002 \002(\010\022.\n\006record\030\003 \003("
594
"\0132\036.drizzled.message.InsertRecord\"L\n\014Upd"
595
"ateRecord\022\021\n\tkey_value\030\001 \003(\014\022\023\n\013after_va"
596
"lue\030\002 \003(\014\022\024\n\014before_value\030\003 \003(\014\"\301\001\n\014Upda"
597
"teHeader\0227\n\016table_metadata\030\001 \002(\0132\037.drizz"
598
"led.message.TableMetadata\022;\n\022key_field_m"
599
"etadata\030\002 \003(\0132\037.drizzled.message.FieldMe"
600
"tadata\022;\n\022set_field_metadata\030\003 \003(\0132\037.dri"
601
"zzled.message.FieldMetadata\"e\n\nUpdateDat"
602
"a\022\022\n\nsegment_id\030\001 \002(\r\022\023\n\013end_segment\030\002 \002"
603
"(\010\022.\n\006record\030\003 \003(\0132\036.drizzled.message.Up"
604
"dateRecord\"!\n\014DeleteRecord\022\021\n\tkey_value\030"
605
"\001 \003(\014\"\204\001\n\014DeleteHeader\0227\n\016table_metadata"
606
"\030\001 \002(\0132\037.drizzled.message.TableMetadata\022"
607
";\n\022key_field_metadata\030\002 \003(\0132\037.drizzled.m"
608
"essage.FieldMetadata\"e\n\nDeleteData\022\022\n\nse"
609
"gment_id\030\001 \002(\r\022\023\n\013end_segment\030\002 \002(\010\022.\n\006r"
610
"ecord\030\003 \003(\0132\036.drizzled.message.DeleteRec"
611
"ord\"Q\n\026TruncateTableStatement\0227\n\016table_m"
612
"etadata\030\001 \002(\0132\037.drizzled.message.TableMe"
613
"tadata\"A\n\025CreateSchemaStatement\022(\n\006schem"
614
"a\030\001 \002(\0132\030.drizzled.message.Schema\"i\n\024Alt"
615
"erSchemaStatement\022(\n\006before\030\001 \002(\0132\030.driz"
616
"zled.message.Schema\022\'\n\005after\030\002 \002(\0132\030.dri"
617
"zzled.message.Schema\"*\n\023DropSchemaStatem"
618
"ent\022\023\n\013schema_name\030\001 \002(\t\">\n\024CreateTableS"
619
"tatement\022&\n\005table\030\001 \002(\0132\027.drizzled.messa"
620
"ge.Table\"f\n\023AlterTableStatement\022\'\n\006befor"
621
"e\030\001 \002(\0132\027.drizzled.message.Table\022&\n\005afte"
622
"r\030\002 \002(\0132\027.drizzled.message.Table\"g\n\022Drop"
623
"TableStatement\0227\n\016table_metadata\030\001 \002(\0132\037"
624
".drizzled.message.TableMetadata\022\030\n\020if_ex"
625
"ists_clause\030\002 \001(\010\"j\n\024SetVariableStatemen"
626
"t\022:\n\021variable_metadata\030\001 \002(\0132\037.drizzled."
627
"message.FieldMetadata\022\026\n\016variable_value\030"
628
"\002 \002(\014\"\313\t\n\tStatement\022.\n\004type\030\001 \002(\0162 .driz"
629
"zled.message.Statement.Type\022\027\n\017start_tim"
630
"estamp\030\002 \002(\004\022\025\n\rend_timestamp\030\003 \002(\004\022\013\n\003s"
631
"ql\030\004 \001(\t\0225\n\rinsert_header\030\005 \001(\0132\036.drizzl"
632
"ed.message.InsertHeader\0221\n\013insert_data\030\006"
633
" \001(\0132\034.drizzled.message.InsertData\0225\n\rup"
634
"date_header\030\007 \001(\0132\036.drizzled.message.Upd"
635
"ateHeader\0221\n\013update_data\030\010 \001(\0132\034.drizzle"
636
"d.message.UpdateData\0225\n\rdelete_header\030\t "
637
"\001(\0132\036.drizzled.message.DeleteHeader\0221\n\013d"
638
"elete_data\030\n \001(\0132\034.drizzled.message.Dele"
639
"teData\022J\n\030truncate_table_statement\030\013 \001(\013"
640
"2(.drizzled.message.TruncateTableStateme"
641
"nt\022H\n\027create_schema_statement\030\014 \001(\0132\'.dr"
642
"izzled.message.CreateSchemaStatement\022D\n\025"
643
"drop_schema_statement\030\r \001(\0132%.drizzled.m"
644
"essage.DropSchemaStatement\022F\n\026alter_sche"
645
"ma_statement\030\016 \001(\0132&.drizzled.message.Al"
646
"terSchemaStatement\022F\n\026create_table_state"
647
"ment\030\017 \001(\0132&.drizzled.message.CreateTabl"
648
"eStatement\022D\n\025alter_table_statement\030\020 \001("
649
"\0132%.drizzled.message.AlterTableStatement"
650
"\022B\n\024drop_table_statement\030\021 \001(\0132$.drizzle"
651
"d.message.DropTableStatement\022F\n\026set_vari"
652
"able_statement\030\022 \001(\0132&.drizzled.message."
653
"SetVariableStatement\"\324\001\n\004Type\022\014\n\010ROLLBAC"
654
"K\020\000\022\n\n\006INSERT\020\001\022\n\n\006DELETE\020\002\022\n\n\006UPDATE\020\003\022"
655
"\022\n\016TRUNCATE_TABLE\020\004\022\021\n\rCREATE_SCHEMA\020\005\022\020"
656
"\n\014ALTER_SCHEMA\020\006\022\017\n\013DROP_SCHEMA\020\007\022\020\n\014CRE"
657
"ATE_TABLE\020\010\022\017\n\013ALTER_TABLE\020\t\022\016\n\nDROP_TAB"
658
"LE\020\n\022\020\n\014SET_VARIABLE\020b\022\013\n\007RAW_SQL\020c\"\200\001\n\013"
659
"Transaction\022A\n\023transaction_context\030\001 \002(\013"
660
"2$.drizzled.message.TransactionContext\022."
661
"\n\tstatement\030\002 \003(\0132\033.drizzled.message.Sta"
662
"tementB\002H\001", 3290);
663
::google::protobuf::MessageFactory::InternalRegisterGeneratedFile(
664
"transaction.proto", &protobuf_RegisterTypes);
665
FieldMetadata::default_instance_ = new FieldMetadata();
666
TableMetadata::default_instance_ = new TableMetadata();
667
TransactionContext::default_instance_ = new TransactionContext();
668
InsertRecord::default_instance_ = new InsertRecord();
669
InsertHeader::default_instance_ = new InsertHeader();
670
InsertData::default_instance_ = new InsertData();
671
UpdateRecord::default_instance_ = new UpdateRecord();
672
UpdateHeader::default_instance_ = new UpdateHeader();
673
UpdateData::default_instance_ = new UpdateData();
674
DeleteRecord::default_instance_ = new DeleteRecord();
675
DeleteHeader::default_instance_ = new DeleteHeader();
676
DeleteData::default_instance_ = new DeleteData();
677
TruncateTableStatement::default_instance_ = new TruncateTableStatement();
678
CreateSchemaStatement::default_instance_ = new CreateSchemaStatement();
679
AlterSchemaStatement::default_instance_ = new AlterSchemaStatement();
680
DropSchemaStatement::default_instance_ = new DropSchemaStatement();
681
CreateTableStatement::default_instance_ = new CreateTableStatement();
682
AlterTableStatement::default_instance_ = new AlterTableStatement();
683
DropTableStatement::default_instance_ = new DropTableStatement();
684
SetVariableStatement::default_instance_ = new SetVariableStatement();
685
Statement::default_instance_ = new Statement();
686
Transaction::default_instance_ = new Transaction();
687
FieldMetadata::default_instance_->InitAsDefaultInstance();
688
TableMetadata::default_instance_->InitAsDefaultInstance();
689
TransactionContext::default_instance_->InitAsDefaultInstance();
690
InsertRecord::default_instance_->InitAsDefaultInstance();
691
InsertHeader::default_instance_->InitAsDefaultInstance();
692
InsertData::default_instance_->InitAsDefaultInstance();
693
UpdateRecord::default_instance_->InitAsDefaultInstance();
694
UpdateHeader::default_instance_->InitAsDefaultInstance();
695
UpdateData::default_instance_->InitAsDefaultInstance();
696
DeleteRecord::default_instance_->InitAsDefaultInstance();
697
DeleteHeader::default_instance_->InitAsDefaultInstance();
698
DeleteData::default_instance_->InitAsDefaultInstance();
699
TruncateTableStatement::default_instance_->InitAsDefaultInstance();
700
CreateSchemaStatement::default_instance_->InitAsDefaultInstance();
701
AlterSchemaStatement::default_instance_->InitAsDefaultInstance();
702
DropSchemaStatement::default_instance_->InitAsDefaultInstance();
703
CreateTableStatement::default_instance_->InitAsDefaultInstance();
704
AlterTableStatement::default_instance_->InitAsDefaultInstance();
705
DropTableStatement::default_instance_->InitAsDefaultInstance();
706
SetVariableStatement::default_instance_->InitAsDefaultInstance();
707
Statement::default_instance_->InitAsDefaultInstance();
708
Transaction::default_instance_->InitAsDefaultInstance();
709
::google::protobuf::internal::OnShutdown(&protobuf_ShutdownFile_transaction_2eproto);
712
// Force AddDescriptors() to be called at static initialization time.
713
struct StaticDescriptorInitializer_transaction_2eproto {
714
StaticDescriptorInitializer_transaction_2eproto() {
715
protobuf_AddDesc_transaction_2eproto();
717
} static_descriptor_initializer_transaction_2eproto_;
720
// ===================================================================
722
const ::std::string FieldMetadata::_default_name_;
724
const int FieldMetadata::kTypeFieldNumber;
725
const int FieldMetadata::kNameFieldNumber;
728
FieldMetadata::FieldMetadata() {
732
void FieldMetadata::InitAsDefaultInstance() {
735
FieldMetadata::FieldMetadata(const FieldMetadata& from) {
740
void FieldMetadata::SharedCtor() {
743
name_ = const_cast< ::std::string*>(&_default_name_);
744
::memset(_has_bits_, 0, sizeof(_has_bits_));
747
FieldMetadata::~FieldMetadata() {
751
void FieldMetadata::SharedDtor() {
752
if (name_ != &_default_name_) {
755
if (this != default_instance_) {
759
const ::google::protobuf::Descriptor* FieldMetadata::descriptor() {
760
protobuf_AssignDescriptorsOnce();
761
return FieldMetadata_descriptor_;
764
const FieldMetadata& FieldMetadata::default_instance() {
765
if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto(); return *default_instance_;
768
FieldMetadata* FieldMetadata::default_instance_ = NULL;
770
FieldMetadata* FieldMetadata::New() const {
771
return new FieldMetadata;
774
void FieldMetadata::Clear() {
775
if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
778
if (name_ != &_default_name_) {
783
::memset(_has_bits_, 0, sizeof(_has_bits_));
784
mutable_unknown_fields()->Clear();
787
bool FieldMetadata::MergePartialFromCodedStream(
788
::google::protobuf::io::CodedInputStream* input) {
789
#define DO_(EXPRESSION) if (!(EXPRESSION)) return false
790
::google::protobuf::uint32 tag;
791
while ((tag = input->ReadTag()) != 0) {
792
switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
793
// required .drizzled.message.Table.Field.FieldType type = 1;
795
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
796
::google::protobuf::internal::WireFormatLite::WIRETYPE_VARINT) {
797
goto handle_uninterpreted;
800
DO_(::google::protobuf::internal::WireFormatLite::ReadEnum(input, &value));
801
if (::drizzled::message::Table_Field_FieldType_IsValid(value)) {
802
set_type(static_cast< ::drizzled::message::Table_Field_FieldType >(value));
804
mutable_unknown_fields()->AddVarint(1, value);
806
if (input->ExpectTag(18)) goto parse_name;
810
// required string name = 2;
812
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
813
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
814
goto handle_uninterpreted;
817
DO_(::google::protobuf::internal::WireFormatLite::ReadString(
818
input, this->mutable_name()));
819
::google::protobuf::internal::WireFormat::VerifyUTF8String(
820
this->name().data(), this->name().length(),
821
::google::protobuf::internal::WireFormat::PARSE);
822
if (input->ExpectAtEnd()) return true;
827
handle_uninterpreted:
828
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
829
::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
832
DO_(::google::protobuf::internal::WireFormat::SkipField(
833
input, tag, mutable_unknown_fields()));
842
void FieldMetadata::SerializeWithCachedSizes(
843
::google::protobuf::io::CodedOutputStream* output) const {
844
::google::protobuf::uint8* raw_buffer = output->GetDirectBufferForNBytesAndAdvance(_cached_size_);
845
if (raw_buffer != NULL) {
846
FieldMetadata::SerializeWithCachedSizesToArray(raw_buffer);
850
// required .drizzled.message.Table.Field.FieldType type = 1;
852
::google::protobuf::internal::WireFormatLite::WriteEnum(
853
1, this->type(), output);
856
// required string name = 2;
858
::google::protobuf::internal::WireFormat::VerifyUTF8String(
859
this->name().data(), this->name().length(),
860
::google::protobuf::internal::WireFormat::SERIALIZE);
861
::google::protobuf::internal::WireFormatLite::WriteString(
862
2, this->name(), output);
865
if (!unknown_fields().empty()) {
866
::google::protobuf::internal::WireFormat::SerializeUnknownFields(
867
unknown_fields(), output);
871
::google::protobuf::uint8* FieldMetadata::SerializeWithCachedSizesToArray(
872
::google::protobuf::uint8* target) const {
873
// required .drizzled.message.Table.Field.FieldType type = 1;
875
target = ::google::protobuf::internal::WireFormatLite::WriteEnumToArray(
876
1, this->type(), target);
879
// required string name = 2;
881
::google::protobuf::internal::WireFormat::VerifyUTF8String(
882
this->name().data(), this->name().length(),
883
::google::protobuf::internal::WireFormat::SERIALIZE);
885
::google::protobuf::internal::WireFormatLite::WriteStringToArray(
886
2, this->name(), target);
889
if (!unknown_fields().empty()) {
890
target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
891
unknown_fields(), target);
896
int FieldMetadata::ByteSize() const {
899
if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
900
// required .drizzled.message.Table.Field.FieldType type = 1;
903
::google::protobuf::internal::WireFormatLite::EnumSize(this->type());
906
// required string name = 2;
909
::google::protobuf::internal::WireFormatLite::StringSize(
914
if (!unknown_fields().empty()) {
916
::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
919
_cached_size_ = total_size;
923
void FieldMetadata::MergeFrom(const ::google::protobuf::Message& from) {
924
GOOGLE_CHECK_NE(&from, this);
925
const FieldMetadata* source =
926
::google::protobuf::internal::dynamic_cast_if_available<const FieldMetadata*>(
928
if (source == NULL) {
929
::google::protobuf::internal::ReflectionOps::Merge(from, this);
935
void FieldMetadata::MergeFrom(const FieldMetadata& from) {
936
GOOGLE_CHECK_NE(&from, this);
937
if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
938
if (from._has_bit(0)) {
939
set_type(from.type());
941
if (from._has_bit(1)) {
942
set_name(from.name());
945
mutable_unknown_fields()->MergeFrom(from.unknown_fields());
948
void FieldMetadata::CopyFrom(const ::google::protobuf::Message& from) {
949
if (&from == this) return;
954
void FieldMetadata::CopyFrom(const FieldMetadata& from) {
955
if (&from == this) return;
960
bool FieldMetadata::IsInitialized() const {
961
if ((_has_bits_[0] & 0x00000003) != 0x00000003) return false;
966
void FieldMetadata::Swap(FieldMetadata* other) {
968
std::swap(type_, other->type_);
969
std::swap(name_, other->name_);
970
std::swap(_has_bits_[0], other->_has_bits_[0]);
971
_unknown_fields_.Swap(&other->_unknown_fields_);
972
std::swap(_cached_size_, other->_cached_size_);
976
::google::protobuf::Metadata FieldMetadata::GetMetadata() const {
977
protobuf_AssignDescriptorsOnce();
978
::google::protobuf::Metadata metadata;
979
metadata.descriptor = FieldMetadata_descriptor_;
980
metadata.reflection = FieldMetadata_reflection_;
985
// ===================================================================
987
const ::std::string TableMetadata::_default_schema_name_;
988
const ::std::string TableMetadata::_default_table_name_;
990
const int TableMetadata::kSchemaNameFieldNumber;
991
const int TableMetadata::kTableNameFieldNumber;
994
TableMetadata::TableMetadata() {
998
void TableMetadata::InitAsDefaultInstance() {
1001
TableMetadata::TableMetadata(const TableMetadata& from) {
1006
void TableMetadata::SharedCtor() {
1008
schema_name_ = const_cast< ::std::string*>(&_default_schema_name_);
1009
table_name_ = const_cast< ::std::string*>(&_default_table_name_);
1010
::memset(_has_bits_, 0, sizeof(_has_bits_));
1013
TableMetadata::~TableMetadata() {
1017
void TableMetadata::SharedDtor() {
1018
if (schema_name_ != &_default_schema_name_) {
1019
delete schema_name_;
1021
if (table_name_ != &_default_table_name_) {
1024
if (this != default_instance_) {
1028
const ::google::protobuf::Descriptor* TableMetadata::descriptor() {
1029
protobuf_AssignDescriptorsOnce();
1030
return TableMetadata_descriptor_;
1033
const TableMetadata& TableMetadata::default_instance() {
1034
if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto(); return *default_instance_;
1037
TableMetadata* TableMetadata::default_instance_ = NULL;
1039
TableMetadata* TableMetadata::New() const {
1040
return new TableMetadata;
1043
void TableMetadata::Clear() {
1044
if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
1046
if (schema_name_ != &_default_schema_name_) {
1047
schema_name_->clear();
1051
if (table_name_ != &_default_table_name_) {
1052
table_name_->clear();
1056
::memset(_has_bits_, 0, sizeof(_has_bits_));
1057
mutable_unknown_fields()->Clear();
1060
bool TableMetadata::MergePartialFromCodedStream(
1061
::google::protobuf::io::CodedInputStream* input) {
1062
#define DO_(EXPRESSION) if (!(EXPRESSION)) return false
1063
::google::protobuf::uint32 tag;
1064
while ((tag = input->ReadTag()) != 0) {
1065
switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
1066
// required string schema_name = 1;
1068
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
1069
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
1070
goto handle_uninterpreted;
1072
DO_(::google::protobuf::internal::WireFormatLite::ReadString(
1073
input, this->mutable_schema_name()));
1074
::google::protobuf::internal::WireFormat::VerifyUTF8String(
1075
this->schema_name().data(), this->schema_name().length(),
1076
::google::protobuf::internal::WireFormat::PARSE);
1077
if (input->ExpectTag(18)) goto parse_table_name;
1081
// required string table_name = 2;
1083
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
1084
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
1085
goto handle_uninterpreted;
1088
DO_(::google::protobuf::internal::WireFormatLite::ReadString(
1089
input, this->mutable_table_name()));
1090
::google::protobuf::internal::WireFormat::VerifyUTF8String(
1091
this->table_name().data(), this->table_name().length(),
1092
::google::protobuf::internal::WireFormat::PARSE);
1093
if (input->ExpectAtEnd()) return true;
1098
handle_uninterpreted:
1099
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
1100
::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
1103
DO_(::google::protobuf::internal::WireFormat::SkipField(
1104
input, tag, mutable_unknown_fields()));
1113
void TableMetadata::SerializeWithCachedSizes(
1114
::google::protobuf::io::CodedOutputStream* output) const {
1115
::google::protobuf::uint8* raw_buffer = output->GetDirectBufferForNBytesAndAdvance(_cached_size_);
1116
if (raw_buffer != NULL) {
1117
TableMetadata::SerializeWithCachedSizesToArray(raw_buffer);
1121
// required string schema_name = 1;
1123
::google::protobuf::internal::WireFormat::VerifyUTF8String(
1124
this->schema_name().data(), this->schema_name().length(),
1125
::google::protobuf::internal::WireFormat::SERIALIZE);
1126
::google::protobuf::internal::WireFormatLite::WriteString(
1127
1, this->schema_name(), output);
1130
// required string table_name = 2;
1132
::google::protobuf::internal::WireFormat::VerifyUTF8String(
1133
this->table_name().data(), this->table_name().length(),
1134
::google::protobuf::internal::WireFormat::SERIALIZE);
1135
::google::protobuf::internal::WireFormatLite::WriteString(
1136
2, this->table_name(), output);
1139
if (!unknown_fields().empty()) {
1140
::google::protobuf::internal::WireFormat::SerializeUnknownFields(
1141
unknown_fields(), output);
1145
::google::protobuf::uint8* TableMetadata::SerializeWithCachedSizesToArray(
1146
::google::protobuf::uint8* target) const {
1147
// required string schema_name = 1;
1149
::google::protobuf::internal::WireFormat::VerifyUTF8String(
1150
this->schema_name().data(), this->schema_name().length(),
1151
::google::protobuf::internal::WireFormat::SERIALIZE);
1153
::google::protobuf::internal::WireFormatLite::WriteStringToArray(
1154
1, this->schema_name(), target);
1157
// required string table_name = 2;
1159
::google::protobuf::internal::WireFormat::VerifyUTF8String(
1160
this->table_name().data(), this->table_name().length(),
1161
::google::protobuf::internal::WireFormat::SERIALIZE);
1163
::google::protobuf::internal::WireFormatLite::WriteStringToArray(
1164
2, this->table_name(), target);
1167
if (!unknown_fields().empty()) {
1168
target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
1169
unknown_fields(), target);
1174
int TableMetadata::ByteSize() const {
1177
if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
1178
// required string schema_name = 1;
1179
if (has_schema_name()) {
1181
::google::protobuf::internal::WireFormatLite::StringSize(
1182
this->schema_name());
1185
// required string table_name = 2;
1186
if (has_table_name()) {
1188
::google::protobuf::internal::WireFormatLite::StringSize(
1189
this->table_name());
1193
if (!unknown_fields().empty()) {
1195
::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
1198
_cached_size_ = total_size;
1202
void TableMetadata::MergeFrom(const ::google::protobuf::Message& from) {
1203
GOOGLE_CHECK_NE(&from, this);
1204
const TableMetadata* source =
1205
::google::protobuf::internal::dynamic_cast_if_available<const TableMetadata*>(
1207
if (source == NULL) {
1208
::google::protobuf::internal::ReflectionOps::Merge(from, this);
1214
void TableMetadata::MergeFrom(const TableMetadata& from) {
1215
GOOGLE_CHECK_NE(&from, this);
1216
if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
1217
if (from._has_bit(0)) {
1218
set_schema_name(from.schema_name());
1220
if (from._has_bit(1)) {
1221
set_table_name(from.table_name());
1224
mutable_unknown_fields()->MergeFrom(from.unknown_fields());
1227
void TableMetadata::CopyFrom(const ::google::protobuf::Message& from) {
1228
if (&from == this) return;
1233
void TableMetadata::CopyFrom(const TableMetadata& from) {
1234
if (&from == this) return;
1239
bool TableMetadata::IsInitialized() const {
1240
if ((_has_bits_[0] & 0x00000003) != 0x00000003) return false;
1245
void TableMetadata::Swap(TableMetadata* other) {
1246
if (other != this) {
1247
std::swap(schema_name_, other->schema_name_);
1248
std::swap(table_name_, other->table_name_);
1249
std::swap(_has_bits_[0], other->_has_bits_[0]);
1250
_unknown_fields_.Swap(&other->_unknown_fields_);
1251
std::swap(_cached_size_, other->_cached_size_);
1255
::google::protobuf::Metadata TableMetadata::GetMetadata() const {
1256
protobuf_AssignDescriptorsOnce();
1257
::google::protobuf::Metadata metadata;
1258
metadata.descriptor = TableMetadata_descriptor_;
1259
metadata.reflection = TableMetadata_reflection_;
1264
// ===================================================================
1267
const int TransactionContext::kServerIdFieldNumber;
1268
const int TransactionContext::kTransactionIdFieldNumber;
1269
const int TransactionContext::kStartTimestampFieldNumber;
1270
const int TransactionContext::kEndTimestampFieldNumber;
1273
TransactionContext::TransactionContext() {
1277
void TransactionContext::InitAsDefaultInstance() {
1280
TransactionContext::TransactionContext(const TransactionContext& from) {
1285
void TransactionContext::SharedCtor() {
1288
transaction_id_ = GOOGLE_ULONGLONG(0);
1289
start_timestamp_ = GOOGLE_ULONGLONG(0);
1290
end_timestamp_ = GOOGLE_ULONGLONG(0);
1291
::memset(_has_bits_, 0, sizeof(_has_bits_));
1294
TransactionContext::~TransactionContext() {
1298
void TransactionContext::SharedDtor() {
1299
if (this != default_instance_) {
1303
const ::google::protobuf::Descriptor* TransactionContext::descriptor() {
1304
protobuf_AssignDescriptorsOnce();
1305
return TransactionContext_descriptor_;
1308
const TransactionContext& TransactionContext::default_instance() {
1309
if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto(); return *default_instance_;
1312
TransactionContext* TransactionContext::default_instance_ = NULL;
1314
TransactionContext* TransactionContext::New() const {
1315
return new TransactionContext;
1318
void TransactionContext::Clear() {
1319
if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
1321
transaction_id_ = GOOGLE_ULONGLONG(0);
1322
start_timestamp_ = GOOGLE_ULONGLONG(0);
1323
end_timestamp_ = GOOGLE_ULONGLONG(0);
1325
::memset(_has_bits_, 0, sizeof(_has_bits_));
1326
mutable_unknown_fields()->Clear();
1329
bool TransactionContext::MergePartialFromCodedStream(
1330
::google::protobuf::io::CodedInputStream* input) {
1331
#define DO_(EXPRESSION) if (!(EXPRESSION)) return false
1332
::google::protobuf::uint32 tag;
1333
while ((tag = input->ReadTag()) != 0) {
1334
switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
1335
// required uint32 server_id = 1;
1337
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
1338
::google::protobuf::internal::WireFormatLite::WIRETYPE_VARINT) {
1339
goto handle_uninterpreted;
1341
DO_(::google::protobuf::internal::WireFormatLite::ReadUInt32(
1342
input, &server_id_));
1344
if (input->ExpectTag(16)) goto parse_transaction_id;
1348
// required uint64 transaction_id = 2;
1350
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
1351
::google::protobuf::internal::WireFormatLite::WIRETYPE_VARINT) {
1352
goto handle_uninterpreted;
1354
parse_transaction_id:
1355
DO_(::google::protobuf::internal::WireFormatLite::ReadUInt64(
1356
input, &transaction_id_));
1358
if (input->ExpectTag(24)) goto parse_start_timestamp;
1362
// required uint64 start_timestamp = 3;
1364
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
1365
::google::protobuf::internal::WireFormatLite::WIRETYPE_VARINT) {
1366
goto handle_uninterpreted;
1368
parse_start_timestamp:
1369
DO_(::google::protobuf::internal::WireFormatLite::ReadUInt64(
1370
input, &start_timestamp_));
1372
if (input->ExpectTag(32)) goto parse_end_timestamp;
1376
// required uint64 end_timestamp = 4;
1378
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
1379
::google::protobuf::internal::WireFormatLite::WIRETYPE_VARINT) {
1380
goto handle_uninterpreted;
1382
parse_end_timestamp:
1383
DO_(::google::protobuf::internal::WireFormatLite::ReadUInt64(
1384
input, &end_timestamp_));
1386
if (input->ExpectAtEnd()) return true;
1391
handle_uninterpreted:
1392
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
1393
::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
1396
DO_(::google::protobuf::internal::WireFormat::SkipField(
1397
input, tag, mutable_unknown_fields()));
1406
void TransactionContext::SerializeWithCachedSizes(
1407
::google::protobuf::io::CodedOutputStream* output) const {
1408
::google::protobuf::uint8* raw_buffer = output->GetDirectBufferForNBytesAndAdvance(_cached_size_);
1409
if (raw_buffer != NULL) {
1410
TransactionContext::SerializeWithCachedSizesToArray(raw_buffer);
1414
// required uint32 server_id = 1;
1416
::google::protobuf::internal::WireFormatLite::WriteUInt32(1, this->server_id(), output);
1419
// required uint64 transaction_id = 2;
1421
::google::protobuf::internal::WireFormatLite::WriteUInt64(2, this->transaction_id(), output);
1424
// required uint64 start_timestamp = 3;
1426
::google::protobuf::internal::WireFormatLite::WriteUInt64(3, this->start_timestamp(), output);
1429
// required uint64 end_timestamp = 4;
1431
::google::protobuf::internal::WireFormatLite::WriteUInt64(4, this->end_timestamp(), output);
1434
if (!unknown_fields().empty()) {
1435
::google::protobuf::internal::WireFormat::SerializeUnknownFields(
1436
unknown_fields(), output);
1440
::google::protobuf::uint8* TransactionContext::SerializeWithCachedSizesToArray(
1441
::google::protobuf::uint8* target) const {
1442
// required uint32 server_id = 1;
1444
target = ::google::protobuf::internal::WireFormatLite::WriteUInt32ToArray(1, this->server_id(), target);
1447
// required uint64 transaction_id = 2;
1449
target = ::google::protobuf::internal::WireFormatLite::WriteUInt64ToArray(2, this->transaction_id(), target);
1452
// required uint64 start_timestamp = 3;
1454
target = ::google::protobuf::internal::WireFormatLite::WriteUInt64ToArray(3, this->start_timestamp(), target);
1457
// required uint64 end_timestamp = 4;
1459
target = ::google::protobuf::internal::WireFormatLite::WriteUInt64ToArray(4, this->end_timestamp(), target);
1462
if (!unknown_fields().empty()) {
1463
target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
1464
unknown_fields(), target);
1469
int TransactionContext::ByteSize() const {
1472
if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
1473
// required uint32 server_id = 1;
1474
if (has_server_id()) {
1476
::google::protobuf::internal::WireFormatLite::UInt32Size(
1480
// required uint64 transaction_id = 2;
1481
if (has_transaction_id()) {
1483
::google::protobuf::internal::WireFormatLite::UInt64Size(
1484
this->transaction_id());
1487
// required uint64 start_timestamp = 3;
1488
if (has_start_timestamp()) {
1490
::google::protobuf::internal::WireFormatLite::UInt64Size(
1491
this->start_timestamp());
1494
// required uint64 end_timestamp = 4;
1495
if (has_end_timestamp()) {
1497
::google::protobuf::internal::WireFormatLite::UInt64Size(
1498
this->end_timestamp());
1502
if (!unknown_fields().empty()) {
1504
::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
1507
_cached_size_ = total_size;
1511
void TransactionContext::MergeFrom(const ::google::protobuf::Message& from) {
1512
GOOGLE_CHECK_NE(&from, this);
1513
const TransactionContext* source =
1514
::google::protobuf::internal::dynamic_cast_if_available<const TransactionContext*>(
1516
if (source == NULL) {
1517
::google::protobuf::internal::ReflectionOps::Merge(from, this);
1523
void TransactionContext::MergeFrom(const TransactionContext& from) {
1524
GOOGLE_CHECK_NE(&from, this);
1525
if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
1526
if (from._has_bit(0)) {
1527
set_server_id(from.server_id());
1529
if (from._has_bit(1)) {
1530
set_transaction_id(from.transaction_id());
1532
if (from._has_bit(2)) {
1533
set_start_timestamp(from.start_timestamp());
1535
if (from._has_bit(3)) {
1536
set_end_timestamp(from.end_timestamp());
1539
mutable_unknown_fields()->MergeFrom(from.unknown_fields());
1542
void TransactionContext::CopyFrom(const ::google::protobuf::Message& from) {
1543
if (&from == this) return;
1548
void TransactionContext::CopyFrom(const TransactionContext& from) {
1549
if (&from == this) return;
1554
bool TransactionContext::IsInitialized() const {
1555
if ((_has_bits_[0] & 0x0000000f) != 0x0000000f) return false;
1560
void TransactionContext::Swap(TransactionContext* other) {
1561
if (other != this) {
1562
std::swap(server_id_, other->server_id_);
1563
std::swap(transaction_id_, other->transaction_id_);
1564
std::swap(start_timestamp_, other->start_timestamp_);
1565
std::swap(end_timestamp_, other->end_timestamp_);
1566
std::swap(_has_bits_[0], other->_has_bits_[0]);
1567
_unknown_fields_.Swap(&other->_unknown_fields_);
1568
std::swap(_cached_size_, other->_cached_size_);
1572
::google::protobuf::Metadata TransactionContext::GetMetadata() const {
1573
protobuf_AssignDescriptorsOnce();
1574
::google::protobuf::Metadata metadata;
1575
metadata.descriptor = TransactionContext_descriptor_;
1576
metadata.reflection = TransactionContext_reflection_;
1581
// ===================================================================
1584
const int InsertRecord::kInsertValueFieldNumber;
1587
InsertRecord::InsertRecord() {
1591
void InsertRecord::InitAsDefaultInstance() {
1594
InsertRecord::InsertRecord(const InsertRecord& from) {
1599
void InsertRecord::SharedCtor() {
1601
::memset(_has_bits_, 0, sizeof(_has_bits_));
1604
InsertRecord::~InsertRecord() {
1608
void InsertRecord::SharedDtor() {
1609
if (this != default_instance_) {
1613
const ::google::protobuf::Descriptor* InsertRecord::descriptor() {
1614
protobuf_AssignDescriptorsOnce();
1615
return InsertRecord_descriptor_;
1618
const InsertRecord& InsertRecord::default_instance() {
1619
if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto(); return *default_instance_;
1622
InsertRecord* InsertRecord::default_instance_ = NULL;
1624
InsertRecord* InsertRecord::New() const {
1625
return new InsertRecord;
1628
void InsertRecord::Clear() {
1629
insert_value_.Clear();
1630
::memset(_has_bits_, 0, sizeof(_has_bits_));
1631
mutable_unknown_fields()->Clear();
1634
bool InsertRecord::MergePartialFromCodedStream(
1635
::google::protobuf::io::CodedInputStream* input) {
1636
#define DO_(EXPRESSION) if (!(EXPRESSION)) return false
1637
::google::protobuf::uint32 tag;
1638
while ((tag = input->ReadTag()) != 0) {
1639
switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
1640
// repeated bytes insert_value = 1;
1642
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
1643
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
1644
goto handle_uninterpreted;
1647
DO_(::google::protobuf::internal::WireFormatLite::ReadBytes(
1648
input, this->add_insert_value()));
1649
if (input->ExpectTag(10)) goto parse_insert_value;
1650
if (input->ExpectAtEnd()) return true;
1655
handle_uninterpreted:
1656
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
1657
::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
1660
DO_(::google::protobuf::internal::WireFormat::SkipField(
1661
input, tag, mutable_unknown_fields()));
1670
void InsertRecord::SerializeWithCachedSizes(
1671
::google::protobuf::io::CodedOutputStream* output) const {
1672
::google::protobuf::uint8* raw_buffer = output->GetDirectBufferForNBytesAndAdvance(_cached_size_);
1673
if (raw_buffer != NULL) {
1674
InsertRecord::SerializeWithCachedSizesToArray(raw_buffer);
1678
// repeated bytes insert_value = 1;
1679
for (int i = 0; i < this->insert_value_size(); i++) {
1680
::google::protobuf::internal::WireFormatLite::WriteBytes(
1681
1, this->insert_value(i), output);
1684
if (!unknown_fields().empty()) {
1685
::google::protobuf::internal::WireFormat::SerializeUnknownFields(
1686
unknown_fields(), output);
1690
::google::protobuf::uint8* InsertRecord::SerializeWithCachedSizesToArray(
1691
::google::protobuf::uint8* target) const {
1692
// repeated bytes insert_value = 1;
1693
for (int i = 0; i < this->insert_value_size(); i++) {
1694
target = ::google::protobuf::internal::WireFormatLite::
1695
WriteBytesToArray(1, this->insert_value(i), target);
1698
if (!unknown_fields().empty()) {
1699
target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
1700
unknown_fields(), target);
1705
int InsertRecord::ByteSize() const {
1708
// repeated bytes insert_value = 1;
1709
total_size += 1 * this->insert_value_size();
1710
for (int i = 0; i < this->insert_value_size(); i++) {
1711
total_size += ::google::protobuf::internal::WireFormatLite::BytesSize(
1712
this->insert_value(i));
1715
if (!unknown_fields().empty()) {
1717
::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
1720
_cached_size_ = total_size;
1724
void InsertRecord::MergeFrom(const ::google::protobuf::Message& from) {
1725
GOOGLE_CHECK_NE(&from, this);
1726
const InsertRecord* source =
1727
::google::protobuf::internal::dynamic_cast_if_available<const InsertRecord*>(
1729
if (source == NULL) {
1730
::google::protobuf::internal::ReflectionOps::Merge(from, this);
1736
void InsertRecord::MergeFrom(const InsertRecord& from) {
1737
GOOGLE_CHECK_NE(&from, this);
1738
insert_value_.MergeFrom(from.insert_value_);
1739
mutable_unknown_fields()->MergeFrom(from.unknown_fields());
1742
void InsertRecord::CopyFrom(const ::google::protobuf::Message& from) {
1743
if (&from == this) return;
1748
void InsertRecord::CopyFrom(const InsertRecord& from) {
1749
if (&from == this) return;
1754
bool InsertRecord::IsInitialized() const {
1759
void InsertRecord::Swap(InsertRecord* other) {
1760
if (other != this) {
1761
insert_value_.Swap(&other->insert_value_);
1762
std::swap(_has_bits_[0], other->_has_bits_[0]);
1763
_unknown_fields_.Swap(&other->_unknown_fields_);
1764
std::swap(_cached_size_, other->_cached_size_);
1768
::google::protobuf::Metadata InsertRecord::GetMetadata() const {
1769
protobuf_AssignDescriptorsOnce();
1770
::google::protobuf::Metadata metadata;
1771
metadata.descriptor = InsertRecord_descriptor_;
1772
metadata.reflection = InsertRecord_reflection_;
1777
// ===================================================================
1780
const int InsertHeader::kTableMetadataFieldNumber;
1781
const int InsertHeader::kFieldMetadataFieldNumber;
1784
InsertHeader::InsertHeader() {
1788
void InsertHeader::InitAsDefaultInstance() {
1789
table_metadata_ = const_cast< ::drizzled::message::TableMetadata*>(&::drizzled::message::TableMetadata::default_instance());
1792
InsertHeader::InsertHeader(const InsertHeader& from) {
1797
void InsertHeader::SharedCtor() {
1799
table_metadata_ = NULL;
1800
::memset(_has_bits_, 0, sizeof(_has_bits_));
1803
InsertHeader::~InsertHeader() {
1807
void InsertHeader::SharedDtor() {
1808
if (this != default_instance_) {
1809
delete table_metadata_;
1813
const ::google::protobuf::Descriptor* InsertHeader::descriptor() {
1814
protobuf_AssignDescriptorsOnce();
1815
return InsertHeader_descriptor_;
1818
const InsertHeader& InsertHeader::default_instance() {
1819
if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto(); return *default_instance_;
1822
InsertHeader* InsertHeader::default_instance_ = NULL;
1824
InsertHeader* InsertHeader::New() const {
1825
return new InsertHeader;
1828
void InsertHeader::Clear() {
1829
if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
1831
if (table_metadata_ != NULL) table_metadata_->::drizzled::message::TableMetadata::Clear();
1834
field_metadata_.Clear();
1835
::memset(_has_bits_, 0, sizeof(_has_bits_));
1836
mutable_unknown_fields()->Clear();
1839
bool InsertHeader::MergePartialFromCodedStream(
1840
::google::protobuf::io::CodedInputStream* input) {
1841
#define DO_(EXPRESSION) if (!(EXPRESSION)) return false
1842
::google::protobuf::uint32 tag;
1843
while ((tag = input->ReadTag()) != 0) {
1844
switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
1845
// required .drizzled.message.TableMetadata table_metadata = 1;
1847
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
1848
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
1849
goto handle_uninterpreted;
1851
DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
1852
input, mutable_table_metadata()));
1853
if (input->ExpectTag(18)) goto parse_field_metadata;
1857
// repeated .drizzled.message.FieldMetadata field_metadata = 2;
1859
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
1860
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
1861
goto handle_uninterpreted;
1863
parse_field_metadata:
1864
DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
1865
input, add_field_metadata()));
1866
if (input->ExpectTag(18)) goto parse_field_metadata;
1867
if (input->ExpectAtEnd()) return true;
1872
handle_uninterpreted:
1873
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
1874
::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
1877
DO_(::google::protobuf::internal::WireFormat::SkipField(
1878
input, tag, mutable_unknown_fields()));
1887
void InsertHeader::SerializeWithCachedSizes(
1888
::google::protobuf::io::CodedOutputStream* output) const {
1889
::google::protobuf::uint8* raw_buffer = output->GetDirectBufferForNBytesAndAdvance(_cached_size_);
1890
if (raw_buffer != NULL) {
1891
InsertHeader::SerializeWithCachedSizesToArray(raw_buffer);
1895
// required .drizzled.message.TableMetadata table_metadata = 1;
1897
::google::protobuf::internal::WireFormatLite::WriteMessageNoVirtual(
1898
1, this->table_metadata(), output);
1901
// repeated .drizzled.message.FieldMetadata field_metadata = 2;
1902
for (int i = 0; i < this->field_metadata_size(); i++) {
1903
::google::protobuf::internal::WireFormatLite::WriteMessageNoVirtual(
1904
2, this->field_metadata(i), output);
1907
if (!unknown_fields().empty()) {
1908
::google::protobuf::internal::WireFormat::SerializeUnknownFields(
1909
unknown_fields(), output);
1913
::google::protobuf::uint8* InsertHeader::SerializeWithCachedSizesToArray(
1914
::google::protobuf::uint8* target) const {
1915
// required .drizzled.message.TableMetadata table_metadata = 1;
1917
target = ::google::protobuf::internal::WireFormatLite::
1918
WriteMessageNoVirtualToArray(
1919
1, this->table_metadata(), target);
1922
// repeated .drizzled.message.FieldMetadata field_metadata = 2;
1923
for (int i = 0; i < this->field_metadata_size(); i++) {
1924
target = ::google::protobuf::internal::WireFormatLite::
1925
WriteMessageNoVirtualToArray(
1926
2, this->field_metadata(i), target);
1929
if (!unknown_fields().empty()) {
1930
target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
1931
unknown_fields(), target);
1936
int InsertHeader::ByteSize() const {
1939
if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
1940
// required .drizzled.message.TableMetadata table_metadata = 1;
1941
if (has_table_metadata()) {
1943
::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
1944
this->table_metadata());
1948
// repeated .drizzled.message.FieldMetadata field_metadata = 2;
1949
total_size += 1 * this->field_metadata_size();
1950
for (int i = 0; i < this->field_metadata_size(); i++) {
1952
::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
1953
this->field_metadata(i));
1956
if (!unknown_fields().empty()) {
1958
::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
1961
_cached_size_ = total_size;
1965
void InsertHeader::MergeFrom(const ::google::protobuf::Message& from) {
1966
GOOGLE_CHECK_NE(&from, this);
1967
const InsertHeader* source =
1968
::google::protobuf::internal::dynamic_cast_if_available<const InsertHeader*>(
1970
if (source == NULL) {
1971
::google::protobuf::internal::ReflectionOps::Merge(from, this);
1977
void InsertHeader::MergeFrom(const InsertHeader& from) {
1978
GOOGLE_CHECK_NE(&from, this);
1979
field_metadata_.MergeFrom(from.field_metadata_);
1980
if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
1981
if (from._has_bit(0)) {
1982
mutable_table_metadata()->::drizzled::message::TableMetadata::MergeFrom(from.table_metadata());
1985
mutable_unknown_fields()->MergeFrom(from.unknown_fields());
1988
void InsertHeader::CopyFrom(const ::google::protobuf::Message& from) {
1989
if (&from == this) return;
1994
void InsertHeader::CopyFrom(const InsertHeader& from) {
1995
if (&from == this) return;
2000
bool InsertHeader::IsInitialized() const {
2001
if ((_has_bits_[0] & 0x00000001) != 0x00000001) return false;
2003
if (has_table_metadata()) {
2004
if (!this->table_metadata().IsInitialized()) return false;
2006
for (int i = 0; i < field_metadata_size(); i++) {
2007
if (!this->field_metadata(i).IsInitialized()) return false;
2012
void InsertHeader::Swap(InsertHeader* other) {
2013
if (other != this) {
2014
std::swap(table_metadata_, other->table_metadata_);
2015
field_metadata_.Swap(&other->field_metadata_);
2016
std::swap(_has_bits_[0], other->_has_bits_[0]);
2017
_unknown_fields_.Swap(&other->_unknown_fields_);
2018
std::swap(_cached_size_, other->_cached_size_);
2022
::google::protobuf::Metadata InsertHeader::GetMetadata() const {
2023
protobuf_AssignDescriptorsOnce();
2024
::google::protobuf::Metadata metadata;
2025
metadata.descriptor = InsertHeader_descriptor_;
2026
metadata.reflection = InsertHeader_reflection_;
2031
// ===================================================================
2034
const int InsertData::kSegmentIdFieldNumber;
2035
const int InsertData::kEndSegmentFieldNumber;
2036
const int InsertData::kRecordFieldNumber;
2039
InsertData::InsertData() {
2043
void InsertData::InitAsDefaultInstance() {
2046
InsertData::InsertData(const InsertData& from) {
2051
void InsertData::SharedCtor() {
2054
end_segment_ = false;
2055
::memset(_has_bits_, 0, sizeof(_has_bits_));
2058
InsertData::~InsertData() {
2062
void InsertData::SharedDtor() {
2063
if (this != default_instance_) {
2067
const ::google::protobuf::Descriptor* InsertData::descriptor() {
2068
protobuf_AssignDescriptorsOnce();
2069
return InsertData_descriptor_;
2072
const InsertData& InsertData::default_instance() {
2073
if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto(); return *default_instance_;
2076
InsertData* InsertData::default_instance_ = NULL;
2078
InsertData* InsertData::New() const {
2079
return new InsertData;
2082
void InsertData::Clear() {
2083
if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
2085
end_segment_ = false;
2088
::memset(_has_bits_, 0, sizeof(_has_bits_));
2089
mutable_unknown_fields()->Clear();
2092
bool InsertData::MergePartialFromCodedStream(
2093
::google::protobuf::io::CodedInputStream* input) {
2094
#define DO_(EXPRESSION) if (!(EXPRESSION)) return false
2095
::google::protobuf::uint32 tag;
2096
while ((tag = input->ReadTag()) != 0) {
2097
switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
2098
// required uint32 segment_id = 1;
2100
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
2101
::google::protobuf::internal::WireFormatLite::WIRETYPE_VARINT) {
2102
goto handle_uninterpreted;
2104
DO_(::google::protobuf::internal::WireFormatLite::ReadUInt32(
2105
input, &segment_id_));
2107
if (input->ExpectTag(16)) goto parse_end_segment;
2111
// required bool end_segment = 2;
2113
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
2114
::google::protobuf::internal::WireFormatLite::WIRETYPE_VARINT) {
2115
goto handle_uninterpreted;
2118
DO_(::google::protobuf::internal::WireFormatLite::ReadBool(
2119
input, &end_segment_));
2121
if (input->ExpectTag(26)) goto parse_record;
2125
// repeated .drizzled.message.InsertRecord record = 3;
2127
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
2128
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
2129
goto handle_uninterpreted;
2132
DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
2133
input, add_record()));
2134
if (input->ExpectTag(26)) goto parse_record;
2135
if (input->ExpectAtEnd()) return true;
2140
handle_uninterpreted:
2141
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
2142
::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
2145
DO_(::google::protobuf::internal::WireFormat::SkipField(
2146
input, tag, mutable_unknown_fields()));
2155
void InsertData::SerializeWithCachedSizes(
2156
::google::protobuf::io::CodedOutputStream* output) const {
2157
::google::protobuf::uint8* raw_buffer = output->GetDirectBufferForNBytesAndAdvance(_cached_size_);
2158
if (raw_buffer != NULL) {
2159
InsertData::SerializeWithCachedSizesToArray(raw_buffer);
2163
// required uint32 segment_id = 1;
2165
::google::protobuf::internal::WireFormatLite::WriteUInt32(1, this->segment_id(), output);
2168
// required bool end_segment = 2;
2170
::google::protobuf::internal::WireFormatLite::WriteBool(2, this->end_segment(), output);
2173
// repeated .drizzled.message.InsertRecord record = 3;
2174
for (int i = 0; i < this->record_size(); i++) {
2175
::google::protobuf::internal::WireFormatLite::WriteMessageNoVirtual(
2176
3, this->record(i), output);
2179
if (!unknown_fields().empty()) {
2180
::google::protobuf::internal::WireFormat::SerializeUnknownFields(
2181
unknown_fields(), output);
2185
::google::protobuf::uint8* InsertData::SerializeWithCachedSizesToArray(
2186
::google::protobuf::uint8* target) const {
2187
// required uint32 segment_id = 1;
2189
target = ::google::protobuf::internal::WireFormatLite::WriteUInt32ToArray(1, this->segment_id(), target);
2192
// required bool end_segment = 2;
2194
target = ::google::protobuf::internal::WireFormatLite::WriteBoolToArray(2, this->end_segment(), target);
2197
// repeated .drizzled.message.InsertRecord record = 3;
2198
for (int i = 0; i < this->record_size(); i++) {
2199
target = ::google::protobuf::internal::WireFormatLite::
2200
WriteMessageNoVirtualToArray(
2201
3, this->record(i), target);
2204
if (!unknown_fields().empty()) {
2205
target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
2206
unknown_fields(), target);
2211
int InsertData::ByteSize() const {
2214
if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
2215
// required uint32 segment_id = 1;
2216
if (has_segment_id()) {
2218
::google::protobuf::internal::WireFormatLite::UInt32Size(
2219
this->segment_id());
2222
// required bool end_segment = 2;
2223
if (has_end_segment()) {
2224
total_size += 1 + 1;
2228
// repeated .drizzled.message.InsertRecord record = 3;
2229
total_size += 1 * this->record_size();
2230
for (int i = 0; i < this->record_size(); i++) {
2232
::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
2236
if (!unknown_fields().empty()) {
2238
::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
2241
_cached_size_ = total_size;
2245
void InsertData::MergeFrom(const ::google::protobuf::Message& from) {
2246
GOOGLE_CHECK_NE(&from, this);
2247
const InsertData* source =
2248
::google::protobuf::internal::dynamic_cast_if_available<const InsertData*>(
2250
if (source == NULL) {
2251
::google::protobuf::internal::ReflectionOps::Merge(from, this);
2257
void InsertData::MergeFrom(const InsertData& from) {
2258
GOOGLE_CHECK_NE(&from, this);
2259
record_.MergeFrom(from.record_);
2260
if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
2261
if (from._has_bit(0)) {
2262
set_segment_id(from.segment_id());
2264
if (from._has_bit(1)) {
2265
set_end_segment(from.end_segment());
2268
mutable_unknown_fields()->MergeFrom(from.unknown_fields());
2271
void InsertData::CopyFrom(const ::google::protobuf::Message& from) {
2272
if (&from == this) return;
2277
void InsertData::CopyFrom(const InsertData& from) {
2278
if (&from == this) return;
2283
bool InsertData::IsInitialized() const {
2284
if ((_has_bits_[0] & 0x00000003) != 0x00000003) return false;
2289
void InsertData::Swap(InsertData* other) {
2290
if (other != this) {
2291
std::swap(segment_id_, other->segment_id_);
2292
std::swap(end_segment_, other->end_segment_);
2293
record_.Swap(&other->record_);
2294
std::swap(_has_bits_[0], other->_has_bits_[0]);
2295
_unknown_fields_.Swap(&other->_unknown_fields_);
2296
std::swap(_cached_size_, other->_cached_size_);
2300
::google::protobuf::Metadata InsertData::GetMetadata() const {
2301
protobuf_AssignDescriptorsOnce();
2302
::google::protobuf::Metadata metadata;
2303
metadata.descriptor = InsertData_descriptor_;
2304
metadata.reflection = InsertData_reflection_;
2309
// ===================================================================
2312
const int UpdateRecord::kKeyValueFieldNumber;
2313
const int UpdateRecord::kAfterValueFieldNumber;
2314
const int UpdateRecord::kBeforeValueFieldNumber;
2317
UpdateRecord::UpdateRecord() {
2321
void UpdateRecord::InitAsDefaultInstance() {
2324
UpdateRecord::UpdateRecord(const UpdateRecord& from) {
2329
void UpdateRecord::SharedCtor() {
2331
::memset(_has_bits_, 0, sizeof(_has_bits_));
2334
UpdateRecord::~UpdateRecord() {
2338
void UpdateRecord::SharedDtor() {
2339
if (this != default_instance_) {
2343
const ::google::protobuf::Descriptor* UpdateRecord::descriptor() {
2344
protobuf_AssignDescriptorsOnce();
2345
return UpdateRecord_descriptor_;
2348
const UpdateRecord& UpdateRecord::default_instance() {
2349
if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto(); return *default_instance_;
2352
UpdateRecord* UpdateRecord::default_instance_ = NULL;
2354
UpdateRecord* UpdateRecord::New() const {
2355
return new UpdateRecord;
2358
void UpdateRecord::Clear() {
2360
after_value_.Clear();
2361
before_value_.Clear();
2362
::memset(_has_bits_, 0, sizeof(_has_bits_));
2363
mutable_unknown_fields()->Clear();
2366
bool UpdateRecord::MergePartialFromCodedStream(
2367
::google::protobuf::io::CodedInputStream* input) {
2368
#define DO_(EXPRESSION) if (!(EXPRESSION)) return false
2369
::google::protobuf::uint32 tag;
2370
while ((tag = input->ReadTag()) != 0) {
2371
switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
2372
// repeated bytes key_value = 1;
2374
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
2375
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
2376
goto handle_uninterpreted;
2379
DO_(::google::protobuf::internal::WireFormatLite::ReadBytes(
2380
input, this->add_key_value()));
2381
if (input->ExpectTag(10)) goto parse_key_value;
2382
if (input->ExpectTag(18)) goto parse_after_value;
2386
// repeated bytes after_value = 2;
2388
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
2389
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
2390
goto handle_uninterpreted;
2393
DO_(::google::protobuf::internal::WireFormatLite::ReadBytes(
2394
input, this->add_after_value()));
2395
if (input->ExpectTag(18)) goto parse_after_value;
2396
if (input->ExpectTag(26)) goto parse_before_value;
2400
// repeated bytes before_value = 3;
2402
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
2403
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
2404
goto handle_uninterpreted;
2407
DO_(::google::protobuf::internal::WireFormatLite::ReadBytes(
2408
input, this->add_before_value()));
2409
if (input->ExpectTag(26)) goto parse_before_value;
2410
if (input->ExpectAtEnd()) return true;
2415
handle_uninterpreted:
2416
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
2417
::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
2420
DO_(::google::protobuf::internal::WireFormat::SkipField(
2421
input, tag, mutable_unknown_fields()));
2430
void UpdateRecord::SerializeWithCachedSizes(
2431
::google::protobuf::io::CodedOutputStream* output) const {
2432
::google::protobuf::uint8* raw_buffer = output->GetDirectBufferForNBytesAndAdvance(_cached_size_);
2433
if (raw_buffer != NULL) {
2434
UpdateRecord::SerializeWithCachedSizesToArray(raw_buffer);
2438
// repeated bytes key_value = 1;
2439
for (int i = 0; i < this->key_value_size(); i++) {
2440
::google::protobuf::internal::WireFormatLite::WriteBytes(
2441
1, this->key_value(i), output);
2444
// repeated bytes after_value = 2;
2445
for (int i = 0; i < this->after_value_size(); i++) {
2446
::google::protobuf::internal::WireFormatLite::WriteBytes(
2447
2, this->after_value(i), output);
2450
// repeated bytes before_value = 3;
2451
for (int i = 0; i < this->before_value_size(); i++) {
2452
::google::protobuf::internal::WireFormatLite::WriteBytes(
2453
3, this->before_value(i), output);
2456
if (!unknown_fields().empty()) {
2457
::google::protobuf::internal::WireFormat::SerializeUnknownFields(
2458
unknown_fields(), output);
2462
::google::protobuf::uint8* UpdateRecord::SerializeWithCachedSizesToArray(
2463
::google::protobuf::uint8* target) const {
2464
// repeated bytes key_value = 1;
2465
for (int i = 0; i < this->key_value_size(); i++) {
2466
target = ::google::protobuf::internal::WireFormatLite::
2467
WriteBytesToArray(1, this->key_value(i), target);
2470
// repeated bytes after_value = 2;
2471
for (int i = 0; i < this->after_value_size(); i++) {
2472
target = ::google::protobuf::internal::WireFormatLite::
2473
WriteBytesToArray(2, this->after_value(i), target);
2476
// repeated bytes before_value = 3;
2477
for (int i = 0; i < this->before_value_size(); i++) {
2478
target = ::google::protobuf::internal::WireFormatLite::
2479
WriteBytesToArray(3, this->before_value(i), target);
2482
if (!unknown_fields().empty()) {
2483
target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
2484
unknown_fields(), target);
2489
int UpdateRecord::ByteSize() const {
2492
// repeated bytes key_value = 1;
2493
total_size += 1 * this->key_value_size();
2494
for (int i = 0; i < this->key_value_size(); i++) {
2495
total_size += ::google::protobuf::internal::WireFormatLite::BytesSize(
2496
this->key_value(i));
2499
// repeated bytes after_value = 2;
2500
total_size += 1 * this->after_value_size();
2501
for (int i = 0; i < this->after_value_size(); i++) {
2502
total_size += ::google::protobuf::internal::WireFormatLite::BytesSize(
2503
this->after_value(i));
2506
// repeated bytes before_value = 3;
2507
total_size += 1 * this->before_value_size();
2508
for (int i = 0; i < this->before_value_size(); i++) {
2509
total_size += ::google::protobuf::internal::WireFormatLite::BytesSize(
2510
this->before_value(i));
2513
if (!unknown_fields().empty()) {
2515
::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
2518
_cached_size_ = total_size;
2522
void UpdateRecord::MergeFrom(const ::google::protobuf::Message& from) {
2523
GOOGLE_CHECK_NE(&from, this);
2524
const UpdateRecord* source =
2525
::google::protobuf::internal::dynamic_cast_if_available<const UpdateRecord*>(
2527
if (source == NULL) {
2528
::google::protobuf::internal::ReflectionOps::Merge(from, this);
2534
void UpdateRecord::MergeFrom(const UpdateRecord& from) {
2535
GOOGLE_CHECK_NE(&from, this);
2536
key_value_.MergeFrom(from.key_value_);
2537
after_value_.MergeFrom(from.after_value_);
2538
before_value_.MergeFrom(from.before_value_);
2539
mutable_unknown_fields()->MergeFrom(from.unknown_fields());
2542
void UpdateRecord::CopyFrom(const ::google::protobuf::Message& from) {
2543
if (&from == this) return;
2548
void UpdateRecord::CopyFrom(const UpdateRecord& from) {
2549
if (&from == this) return;
2554
bool UpdateRecord::IsInitialized() const {
2559
void UpdateRecord::Swap(UpdateRecord* other) {
2560
if (other != this) {
2561
key_value_.Swap(&other->key_value_);
2562
after_value_.Swap(&other->after_value_);
2563
before_value_.Swap(&other->before_value_);
2564
std::swap(_has_bits_[0], other->_has_bits_[0]);
2565
_unknown_fields_.Swap(&other->_unknown_fields_);
2566
std::swap(_cached_size_, other->_cached_size_);
2570
::google::protobuf::Metadata UpdateRecord::GetMetadata() const {
2571
protobuf_AssignDescriptorsOnce();
2572
::google::protobuf::Metadata metadata;
2573
metadata.descriptor = UpdateRecord_descriptor_;
2574
metadata.reflection = UpdateRecord_reflection_;
2579
// ===================================================================
2582
const int UpdateHeader::kTableMetadataFieldNumber;
2583
const int UpdateHeader::kKeyFieldMetadataFieldNumber;
2584
const int UpdateHeader::kSetFieldMetadataFieldNumber;
2587
UpdateHeader::UpdateHeader() {
2591
void UpdateHeader::InitAsDefaultInstance() {
2592
table_metadata_ = const_cast< ::drizzled::message::TableMetadata*>(&::drizzled::message::TableMetadata::default_instance());
2595
UpdateHeader::UpdateHeader(const UpdateHeader& from) {
2600
void UpdateHeader::SharedCtor() {
2602
table_metadata_ = NULL;
2603
::memset(_has_bits_, 0, sizeof(_has_bits_));
2606
UpdateHeader::~UpdateHeader() {
2610
void UpdateHeader::SharedDtor() {
2611
if (this != default_instance_) {
2612
delete table_metadata_;
2616
const ::google::protobuf::Descriptor* UpdateHeader::descriptor() {
2617
protobuf_AssignDescriptorsOnce();
2618
return UpdateHeader_descriptor_;
2621
const UpdateHeader& UpdateHeader::default_instance() {
2622
if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto(); return *default_instance_;
2625
UpdateHeader* UpdateHeader::default_instance_ = NULL;
2627
UpdateHeader* UpdateHeader::New() const {
2628
return new UpdateHeader;
2631
void UpdateHeader::Clear() {
2632
if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
2634
if (table_metadata_ != NULL) table_metadata_->::drizzled::message::TableMetadata::Clear();
2637
key_field_metadata_.Clear();
2638
set_field_metadata_.Clear();
2639
::memset(_has_bits_, 0, sizeof(_has_bits_));
2640
mutable_unknown_fields()->Clear();
2643
bool UpdateHeader::MergePartialFromCodedStream(
2644
::google::protobuf::io::CodedInputStream* input) {
2645
#define DO_(EXPRESSION) if (!(EXPRESSION)) return false
2646
::google::protobuf::uint32 tag;
2647
while ((tag = input->ReadTag()) != 0) {
2648
switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
2649
// required .drizzled.message.TableMetadata table_metadata = 1;
2651
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
2652
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
2653
goto handle_uninterpreted;
2655
DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
2656
input, mutable_table_metadata()));
2657
if (input->ExpectTag(18)) goto parse_key_field_metadata;
2661
// repeated .drizzled.message.FieldMetadata key_field_metadata = 2;
2663
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
2664
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
2665
goto handle_uninterpreted;
2667
parse_key_field_metadata:
2668
DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
2669
input, add_key_field_metadata()));
2670
if (input->ExpectTag(18)) goto parse_key_field_metadata;
2671
if (input->ExpectTag(26)) goto parse_set_field_metadata;
2675
// repeated .drizzled.message.FieldMetadata set_field_metadata = 3;
2677
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
2678
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
2679
goto handle_uninterpreted;
2681
parse_set_field_metadata:
2682
DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
2683
input, add_set_field_metadata()));
2684
if (input->ExpectTag(26)) goto parse_set_field_metadata;
2685
if (input->ExpectAtEnd()) return true;
2690
handle_uninterpreted:
2691
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
2692
::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
2695
DO_(::google::protobuf::internal::WireFormat::SkipField(
2696
input, tag, mutable_unknown_fields()));
2705
void UpdateHeader::SerializeWithCachedSizes(
2706
::google::protobuf::io::CodedOutputStream* output) const {
2707
::google::protobuf::uint8* raw_buffer = output->GetDirectBufferForNBytesAndAdvance(_cached_size_);
2708
if (raw_buffer != NULL) {
2709
UpdateHeader::SerializeWithCachedSizesToArray(raw_buffer);
2713
// required .drizzled.message.TableMetadata table_metadata = 1;
2715
::google::protobuf::internal::WireFormatLite::WriteMessageNoVirtual(
2716
1, this->table_metadata(), output);
2719
// repeated .drizzled.message.FieldMetadata key_field_metadata = 2;
2720
for (int i = 0; i < this->key_field_metadata_size(); i++) {
2721
::google::protobuf::internal::WireFormatLite::WriteMessageNoVirtual(
2722
2, this->key_field_metadata(i), output);
2725
// repeated .drizzled.message.FieldMetadata set_field_metadata = 3;
2726
for (int i = 0; i < this->set_field_metadata_size(); i++) {
2727
::google::protobuf::internal::WireFormatLite::WriteMessageNoVirtual(
2728
3, this->set_field_metadata(i), output);
2731
if (!unknown_fields().empty()) {
2732
::google::protobuf::internal::WireFormat::SerializeUnknownFields(
2733
unknown_fields(), output);
2737
::google::protobuf::uint8* UpdateHeader::SerializeWithCachedSizesToArray(
2738
::google::protobuf::uint8* target) const {
2739
// required .drizzled.message.TableMetadata table_metadata = 1;
2741
target = ::google::protobuf::internal::WireFormatLite::
2742
WriteMessageNoVirtualToArray(
2743
1, this->table_metadata(), target);
2746
// repeated .drizzled.message.FieldMetadata key_field_metadata = 2;
2747
for (int i = 0; i < this->key_field_metadata_size(); i++) {
2748
target = ::google::protobuf::internal::WireFormatLite::
2749
WriteMessageNoVirtualToArray(
2750
2, this->key_field_metadata(i), target);
2753
// repeated .drizzled.message.FieldMetadata set_field_metadata = 3;
2754
for (int i = 0; i < this->set_field_metadata_size(); i++) {
2755
target = ::google::protobuf::internal::WireFormatLite::
2756
WriteMessageNoVirtualToArray(
2757
3, this->set_field_metadata(i), target);
2760
if (!unknown_fields().empty()) {
2761
target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
2762
unknown_fields(), target);
2767
int UpdateHeader::ByteSize() const {
2770
if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
2771
// required .drizzled.message.TableMetadata table_metadata = 1;
2772
if (has_table_metadata()) {
2774
::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
2775
this->table_metadata());
2779
// repeated .drizzled.message.FieldMetadata key_field_metadata = 2;
2780
total_size += 1 * this->key_field_metadata_size();
2781
for (int i = 0; i < this->key_field_metadata_size(); i++) {
2783
::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
2784
this->key_field_metadata(i));
2787
// repeated .drizzled.message.FieldMetadata set_field_metadata = 3;
2788
total_size += 1 * this->set_field_metadata_size();
2789
for (int i = 0; i < this->set_field_metadata_size(); i++) {
2791
::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
2792
this->set_field_metadata(i));
2795
if (!unknown_fields().empty()) {
2797
::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
2800
_cached_size_ = total_size;
2804
void UpdateHeader::MergeFrom(const ::google::protobuf::Message& from) {
2805
GOOGLE_CHECK_NE(&from, this);
2806
const UpdateHeader* source =
2807
::google::protobuf::internal::dynamic_cast_if_available<const UpdateHeader*>(
2809
if (source == NULL) {
2810
::google::protobuf::internal::ReflectionOps::Merge(from, this);
2816
void UpdateHeader::MergeFrom(const UpdateHeader& from) {
2817
GOOGLE_CHECK_NE(&from, this);
2818
key_field_metadata_.MergeFrom(from.key_field_metadata_);
2819
set_field_metadata_.MergeFrom(from.set_field_metadata_);
2820
if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
2821
if (from._has_bit(0)) {
2822
mutable_table_metadata()->::drizzled::message::TableMetadata::MergeFrom(from.table_metadata());
2825
mutable_unknown_fields()->MergeFrom(from.unknown_fields());
2828
void UpdateHeader::CopyFrom(const ::google::protobuf::Message& from) {
2829
if (&from == this) return;
2834
void UpdateHeader::CopyFrom(const UpdateHeader& from) {
2835
if (&from == this) return;
2840
bool UpdateHeader::IsInitialized() const {
2841
if ((_has_bits_[0] & 0x00000001) != 0x00000001) return false;
2843
if (has_table_metadata()) {
2844
if (!this->table_metadata().IsInitialized()) return false;
2846
for (int i = 0; i < key_field_metadata_size(); i++) {
2847
if (!this->key_field_metadata(i).IsInitialized()) return false;
2849
for (int i = 0; i < set_field_metadata_size(); i++) {
2850
if (!this->set_field_metadata(i).IsInitialized()) return false;
2855
void UpdateHeader::Swap(UpdateHeader* other) {
2856
if (other != this) {
2857
std::swap(table_metadata_, other->table_metadata_);
2858
key_field_metadata_.Swap(&other->key_field_metadata_);
2859
set_field_metadata_.Swap(&other->set_field_metadata_);
2860
std::swap(_has_bits_[0], other->_has_bits_[0]);
2861
_unknown_fields_.Swap(&other->_unknown_fields_);
2862
std::swap(_cached_size_, other->_cached_size_);
2866
::google::protobuf::Metadata UpdateHeader::GetMetadata() const {
2867
protobuf_AssignDescriptorsOnce();
2868
::google::protobuf::Metadata metadata;
2869
metadata.descriptor = UpdateHeader_descriptor_;
2870
metadata.reflection = UpdateHeader_reflection_;
2875
// ===================================================================
2878
const int UpdateData::kSegmentIdFieldNumber;
2879
const int UpdateData::kEndSegmentFieldNumber;
2880
const int UpdateData::kRecordFieldNumber;
2883
UpdateData::UpdateData() {
2887
void UpdateData::InitAsDefaultInstance() {
2890
UpdateData::UpdateData(const UpdateData& from) {
2895
void UpdateData::SharedCtor() {
2898
end_segment_ = false;
2899
::memset(_has_bits_, 0, sizeof(_has_bits_));
2902
UpdateData::~UpdateData() {
2906
void UpdateData::SharedDtor() {
2907
if (this != default_instance_) {
2911
const ::google::protobuf::Descriptor* UpdateData::descriptor() {
2912
protobuf_AssignDescriptorsOnce();
2913
return UpdateData_descriptor_;
2916
const UpdateData& UpdateData::default_instance() {
2917
if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto(); return *default_instance_;
2920
UpdateData* UpdateData::default_instance_ = NULL;
2922
UpdateData* UpdateData::New() const {
2923
return new UpdateData;
2926
void UpdateData::Clear() {
2927
if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
2929
end_segment_ = false;
2932
::memset(_has_bits_, 0, sizeof(_has_bits_));
2933
mutable_unknown_fields()->Clear();
2936
bool UpdateData::MergePartialFromCodedStream(
2937
::google::protobuf::io::CodedInputStream* input) {
2938
#define DO_(EXPRESSION) if (!(EXPRESSION)) return false
2939
::google::protobuf::uint32 tag;
2940
while ((tag = input->ReadTag()) != 0) {
2941
switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
2942
// required uint32 segment_id = 1;
2944
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
2945
::google::protobuf::internal::WireFormatLite::WIRETYPE_VARINT) {
2946
goto handle_uninterpreted;
2948
DO_(::google::protobuf::internal::WireFormatLite::ReadUInt32(
2949
input, &segment_id_));
2951
if (input->ExpectTag(16)) goto parse_end_segment;
2955
// required bool end_segment = 2;
2957
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
2958
::google::protobuf::internal::WireFormatLite::WIRETYPE_VARINT) {
2959
goto handle_uninterpreted;
2962
DO_(::google::protobuf::internal::WireFormatLite::ReadBool(
2963
input, &end_segment_));
2965
if (input->ExpectTag(26)) goto parse_record;
2969
// repeated .drizzled.message.UpdateRecord record = 3;
2971
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
2972
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
2973
goto handle_uninterpreted;
2976
DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
2977
input, add_record()));
2978
if (input->ExpectTag(26)) goto parse_record;
2979
if (input->ExpectAtEnd()) return true;
2984
handle_uninterpreted:
2985
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
2986
::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
2989
DO_(::google::protobuf::internal::WireFormat::SkipField(
2990
input, tag, mutable_unknown_fields()));
2999
void UpdateData::SerializeWithCachedSizes(
3000
::google::protobuf::io::CodedOutputStream* output) const {
3001
::google::protobuf::uint8* raw_buffer = output->GetDirectBufferForNBytesAndAdvance(_cached_size_);
3002
if (raw_buffer != NULL) {
3003
UpdateData::SerializeWithCachedSizesToArray(raw_buffer);
3007
// required uint32 segment_id = 1;
3009
::google::protobuf::internal::WireFormatLite::WriteUInt32(1, this->segment_id(), output);
3012
// required bool end_segment = 2;
3014
::google::protobuf::internal::WireFormatLite::WriteBool(2, this->end_segment(), output);
3017
// repeated .drizzled.message.UpdateRecord record = 3;
3018
for (int i = 0; i < this->record_size(); i++) {
3019
::google::protobuf::internal::WireFormatLite::WriteMessageNoVirtual(
3020
3, this->record(i), output);
3023
if (!unknown_fields().empty()) {
3024
::google::protobuf::internal::WireFormat::SerializeUnknownFields(
3025
unknown_fields(), output);
3029
::google::protobuf::uint8* UpdateData::SerializeWithCachedSizesToArray(
3030
::google::protobuf::uint8* target) const {
3031
// required uint32 segment_id = 1;
3033
target = ::google::protobuf::internal::WireFormatLite::WriteUInt32ToArray(1, this->segment_id(), target);
3036
// required bool end_segment = 2;
3038
target = ::google::protobuf::internal::WireFormatLite::WriteBoolToArray(2, this->end_segment(), target);
3041
// repeated .drizzled.message.UpdateRecord record = 3;
3042
for (int i = 0; i < this->record_size(); i++) {
3043
target = ::google::protobuf::internal::WireFormatLite::
3044
WriteMessageNoVirtualToArray(
3045
3, this->record(i), target);
3048
if (!unknown_fields().empty()) {
3049
target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
3050
unknown_fields(), target);
3055
int UpdateData::ByteSize() const {
3058
if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
3059
// required uint32 segment_id = 1;
3060
if (has_segment_id()) {
3062
::google::protobuf::internal::WireFormatLite::UInt32Size(
3063
this->segment_id());
3066
// required bool end_segment = 2;
3067
if (has_end_segment()) {
3068
total_size += 1 + 1;
3072
// repeated .drizzled.message.UpdateRecord record = 3;
3073
total_size += 1 * this->record_size();
3074
for (int i = 0; i < this->record_size(); i++) {
3076
::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
3080
if (!unknown_fields().empty()) {
3082
::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
3085
_cached_size_ = total_size;
3089
void UpdateData::MergeFrom(const ::google::protobuf::Message& from) {
3090
GOOGLE_CHECK_NE(&from, this);
3091
const UpdateData* source =
3092
::google::protobuf::internal::dynamic_cast_if_available<const UpdateData*>(
3094
if (source == NULL) {
3095
::google::protobuf::internal::ReflectionOps::Merge(from, this);
3101
void UpdateData::MergeFrom(const UpdateData& from) {
3102
GOOGLE_CHECK_NE(&from, this);
3103
record_.MergeFrom(from.record_);
3104
if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
3105
if (from._has_bit(0)) {
3106
set_segment_id(from.segment_id());
3108
if (from._has_bit(1)) {
3109
set_end_segment(from.end_segment());
3112
mutable_unknown_fields()->MergeFrom(from.unknown_fields());
3115
void UpdateData::CopyFrom(const ::google::protobuf::Message& from) {
3116
if (&from == this) return;
3121
void UpdateData::CopyFrom(const UpdateData& from) {
3122
if (&from == this) return;
3127
bool UpdateData::IsInitialized() const {
3128
if ((_has_bits_[0] & 0x00000003) != 0x00000003) return false;
3133
void UpdateData::Swap(UpdateData* other) {
3134
if (other != this) {
3135
std::swap(segment_id_, other->segment_id_);
3136
std::swap(end_segment_, other->end_segment_);
3137
record_.Swap(&other->record_);
3138
std::swap(_has_bits_[0], other->_has_bits_[0]);
3139
_unknown_fields_.Swap(&other->_unknown_fields_);
3140
std::swap(_cached_size_, other->_cached_size_);
3144
::google::protobuf::Metadata UpdateData::GetMetadata() const {
3145
protobuf_AssignDescriptorsOnce();
3146
::google::protobuf::Metadata metadata;
3147
metadata.descriptor = UpdateData_descriptor_;
3148
metadata.reflection = UpdateData_reflection_;
3153
// ===================================================================
3156
const int DeleteRecord::kKeyValueFieldNumber;
3159
DeleteRecord::DeleteRecord() {
3163
void DeleteRecord::InitAsDefaultInstance() {
3166
DeleteRecord::DeleteRecord(const DeleteRecord& from) {
3171
void DeleteRecord::SharedCtor() {
3173
::memset(_has_bits_, 0, sizeof(_has_bits_));
3176
DeleteRecord::~DeleteRecord() {
3180
void DeleteRecord::SharedDtor() {
3181
if (this != default_instance_) {
3185
const ::google::protobuf::Descriptor* DeleteRecord::descriptor() {
3186
protobuf_AssignDescriptorsOnce();
3187
return DeleteRecord_descriptor_;
3190
const DeleteRecord& DeleteRecord::default_instance() {
3191
if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto(); return *default_instance_;
3194
DeleteRecord* DeleteRecord::default_instance_ = NULL;
3196
DeleteRecord* DeleteRecord::New() const {
3197
return new DeleteRecord;
3200
void DeleteRecord::Clear() {
3202
::memset(_has_bits_, 0, sizeof(_has_bits_));
3203
mutable_unknown_fields()->Clear();
3206
bool DeleteRecord::MergePartialFromCodedStream(
3207
::google::protobuf::io::CodedInputStream* input) {
3208
#define DO_(EXPRESSION) if (!(EXPRESSION)) return false
3209
::google::protobuf::uint32 tag;
3210
while ((tag = input->ReadTag()) != 0) {
3211
switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
3212
// repeated bytes key_value = 1;
3214
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
3215
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
3216
goto handle_uninterpreted;
3219
DO_(::google::protobuf::internal::WireFormatLite::ReadBytes(
3220
input, this->add_key_value()));
3221
if (input->ExpectTag(10)) goto parse_key_value;
3222
if (input->ExpectAtEnd()) return true;
3227
handle_uninterpreted:
3228
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
3229
::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
3232
DO_(::google::protobuf::internal::WireFormat::SkipField(
3233
input, tag, mutable_unknown_fields()));
3242
void DeleteRecord::SerializeWithCachedSizes(
3243
::google::protobuf::io::CodedOutputStream* output) const {
3244
::google::protobuf::uint8* raw_buffer = output->GetDirectBufferForNBytesAndAdvance(_cached_size_);
3245
if (raw_buffer != NULL) {
3246
DeleteRecord::SerializeWithCachedSizesToArray(raw_buffer);
3250
// repeated bytes key_value = 1;
3251
for (int i = 0; i < this->key_value_size(); i++) {
3252
::google::protobuf::internal::WireFormatLite::WriteBytes(
3253
1, this->key_value(i), output);
3256
if (!unknown_fields().empty()) {
3257
::google::protobuf::internal::WireFormat::SerializeUnknownFields(
3258
unknown_fields(), output);
3262
::google::protobuf::uint8* DeleteRecord::SerializeWithCachedSizesToArray(
3263
::google::protobuf::uint8* target) const {
3264
// repeated bytes key_value = 1;
3265
for (int i = 0; i < this->key_value_size(); i++) {
3266
target = ::google::protobuf::internal::WireFormatLite::
3267
WriteBytesToArray(1, this->key_value(i), target);
3270
if (!unknown_fields().empty()) {
3271
target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
3272
unknown_fields(), target);
3277
int DeleteRecord::ByteSize() const {
3280
// repeated bytes key_value = 1;
3281
total_size += 1 * this->key_value_size();
3282
for (int i = 0; i < this->key_value_size(); i++) {
3283
total_size += ::google::protobuf::internal::WireFormatLite::BytesSize(
3284
this->key_value(i));
3287
if (!unknown_fields().empty()) {
3289
::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
3292
_cached_size_ = total_size;
3296
void DeleteRecord::MergeFrom(const ::google::protobuf::Message& from) {
3297
GOOGLE_CHECK_NE(&from, this);
3298
const DeleteRecord* source =
3299
::google::protobuf::internal::dynamic_cast_if_available<const DeleteRecord*>(
3301
if (source == NULL) {
3302
::google::protobuf::internal::ReflectionOps::Merge(from, this);
3308
void DeleteRecord::MergeFrom(const DeleteRecord& from) {
3309
GOOGLE_CHECK_NE(&from, this);
3310
key_value_.MergeFrom(from.key_value_);
3311
mutable_unknown_fields()->MergeFrom(from.unknown_fields());
3314
void DeleteRecord::CopyFrom(const ::google::protobuf::Message& from) {
3315
if (&from == this) return;
3320
void DeleteRecord::CopyFrom(const DeleteRecord& from) {
3321
if (&from == this) return;
3326
bool DeleteRecord::IsInitialized() const {
3331
void DeleteRecord::Swap(DeleteRecord* other) {
3332
if (other != this) {
3333
key_value_.Swap(&other->key_value_);
3334
std::swap(_has_bits_[0], other->_has_bits_[0]);
3335
_unknown_fields_.Swap(&other->_unknown_fields_);
3336
std::swap(_cached_size_, other->_cached_size_);
3340
::google::protobuf::Metadata DeleteRecord::GetMetadata() const {
3341
protobuf_AssignDescriptorsOnce();
3342
::google::protobuf::Metadata metadata;
3343
metadata.descriptor = DeleteRecord_descriptor_;
3344
metadata.reflection = DeleteRecord_reflection_;
3349
// ===================================================================
3352
const int DeleteHeader::kTableMetadataFieldNumber;
3353
const int DeleteHeader::kKeyFieldMetadataFieldNumber;
3356
DeleteHeader::DeleteHeader() {
3360
void DeleteHeader::InitAsDefaultInstance() {
3361
table_metadata_ = const_cast< ::drizzled::message::TableMetadata*>(&::drizzled::message::TableMetadata::default_instance());
3364
DeleteHeader::DeleteHeader(const DeleteHeader& from) {
3369
void DeleteHeader::SharedCtor() {
3371
table_metadata_ = NULL;
3372
::memset(_has_bits_, 0, sizeof(_has_bits_));
3375
DeleteHeader::~DeleteHeader() {
3379
void DeleteHeader::SharedDtor() {
3380
if (this != default_instance_) {
3381
delete table_metadata_;
3385
const ::google::protobuf::Descriptor* DeleteHeader::descriptor() {
3386
protobuf_AssignDescriptorsOnce();
3387
return DeleteHeader_descriptor_;
3390
const DeleteHeader& DeleteHeader::default_instance() {
3391
if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto(); return *default_instance_;
3394
DeleteHeader* DeleteHeader::default_instance_ = NULL;
3396
DeleteHeader* DeleteHeader::New() const {
3397
return new DeleteHeader;
3400
void DeleteHeader::Clear() {
3401
if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
3403
if (table_metadata_ != NULL) table_metadata_->::drizzled::message::TableMetadata::Clear();
3406
key_field_metadata_.Clear();
3407
::memset(_has_bits_, 0, sizeof(_has_bits_));
3408
mutable_unknown_fields()->Clear();
3411
bool DeleteHeader::MergePartialFromCodedStream(
3412
::google::protobuf::io::CodedInputStream* input) {
3413
#define DO_(EXPRESSION) if (!(EXPRESSION)) return false
3414
::google::protobuf::uint32 tag;
3415
while ((tag = input->ReadTag()) != 0) {
3416
switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
3417
// required .drizzled.message.TableMetadata table_metadata = 1;
3419
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
3420
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
3421
goto handle_uninterpreted;
3423
DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
3424
input, mutable_table_metadata()));
3425
if (input->ExpectTag(18)) goto parse_key_field_metadata;
3429
// repeated .drizzled.message.FieldMetadata key_field_metadata = 2;
3431
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
3432
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
3433
goto handle_uninterpreted;
3435
parse_key_field_metadata:
3436
DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
3437
input, add_key_field_metadata()));
3438
if (input->ExpectTag(18)) goto parse_key_field_metadata;
3439
if (input->ExpectAtEnd()) return true;
3444
handle_uninterpreted:
3445
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
3446
::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
3449
DO_(::google::protobuf::internal::WireFormat::SkipField(
3450
input, tag, mutable_unknown_fields()));
3459
void DeleteHeader::SerializeWithCachedSizes(
3460
::google::protobuf::io::CodedOutputStream* output) const {
3461
::google::protobuf::uint8* raw_buffer = output->GetDirectBufferForNBytesAndAdvance(_cached_size_);
3462
if (raw_buffer != NULL) {
3463
DeleteHeader::SerializeWithCachedSizesToArray(raw_buffer);
3467
// required .drizzled.message.TableMetadata table_metadata = 1;
3469
::google::protobuf::internal::WireFormatLite::WriteMessageNoVirtual(
3470
1, this->table_metadata(), output);
3473
// repeated .drizzled.message.FieldMetadata key_field_metadata = 2;
3474
for (int i = 0; i < this->key_field_metadata_size(); i++) {
3475
::google::protobuf::internal::WireFormatLite::WriteMessageNoVirtual(
3476
2, this->key_field_metadata(i), output);
3479
if (!unknown_fields().empty()) {
3480
::google::protobuf::internal::WireFormat::SerializeUnknownFields(
3481
unknown_fields(), output);
3485
::google::protobuf::uint8* DeleteHeader::SerializeWithCachedSizesToArray(
3486
::google::protobuf::uint8* target) const {
3487
// required .drizzled.message.TableMetadata table_metadata = 1;
3489
target = ::google::protobuf::internal::WireFormatLite::
3490
WriteMessageNoVirtualToArray(
3491
1, this->table_metadata(), target);
3494
// repeated .drizzled.message.FieldMetadata key_field_metadata = 2;
3495
for (int i = 0; i < this->key_field_metadata_size(); i++) {
3496
target = ::google::protobuf::internal::WireFormatLite::
3497
WriteMessageNoVirtualToArray(
3498
2, this->key_field_metadata(i), target);
3501
if (!unknown_fields().empty()) {
3502
target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
3503
unknown_fields(), target);
3508
int DeleteHeader::ByteSize() const {
3511
if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
3512
// required .drizzled.message.TableMetadata table_metadata = 1;
3513
if (has_table_metadata()) {
3515
::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
3516
this->table_metadata());
3520
// repeated .drizzled.message.FieldMetadata key_field_metadata = 2;
3521
total_size += 1 * this->key_field_metadata_size();
3522
for (int i = 0; i < this->key_field_metadata_size(); i++) {
3524
::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
3525
this->key_field_metadata(i));
3528
if (!unknown_fields().empty()) {
3530
::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
3533
_cached_size_ = total_size;
3537
void DeleteHeader::MergeFrom(const ::google::protobuf::Message& from) {
3538
GOOGLE_CHECK_NE(&from, this);
3539
const DeleteHeader* source =
3540
::google::protobuf::internal::dynamic_cast_if_available<const DeleteHeader*>(
3542
if (source == NULL) {
3543
::google::protobuf::internal::ReflectionOps::Merge(from, this);
3549
void DeleteHeader::MergeFrom(const DeleteHeader& from) {
3550
GOOGLE_CHECK_NE(&from, this);
3551
key_field_metadata_.MergeFrom(from.key_field_metadata_);
3552
if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
3553
if (from._has_bit(0)) {
3554
mutable_table_metadata()->::drizzled::message::TableMetadata::MergeFrom(from.table_metadata());
3557
mutable_unknown_fields()->MergeFrom(from.unknown_fields());
3560
void DeleteHeader::CopyFrom(const ::google::protobuf::Message& from) {
3561
if (&from == this) return;
3566
void DeleteHeader::CopyFrom(const DeleteHeader& from) {
3567
if (&from == this) return;
3572
bool DeleteHeader::IsInitialized() const {
3573
if ((_has_bits_[0] & 0x00000001) != 0x00000001) return false;
3575
if (has_table_metadata()) {
3576
if (!this->table_metadata().IsInitialized()) return false;
3578
for (int i = 0; i < key_field_metadata_size(); i++) {
3579
if (!this->key_field_metadata(i).IsInitialized()) return false;
3584
void DeleteHeader::Swap(DeleteHeader* other) {
3585
if (other != this) {
3586
std::swap(table_metadata_, other->table_metadata_);
3587
key_field_metadata_.Swap(&other->key_field_metadata_);
3588
std::swap(_has_bits_[0], other->_has_bits_[0]);
3589
_unknown_fields_.Swap(&other->_unknown_fields_);
3590
std::swap(_cached_size_, other->_cached_size_);
3594
::google::protobuf::Metadata DeleteHeader::GetMetadata() const {
3595
protobuf_AssignDescriptorsOnce();
3596
::google::protobuf::Metadata metadata;
3597
metadata.descriptor = DeleteHeader_descriptor_;
3598
metadata.reflection = DeleteHeader_reflection_;
3603
// ===================================================================
3606
const int DeleteData::kSegmentIdFieldNumber;
3607
const int DeleteData::kEndSegmentFieldNumber;
3608
const int DeleteData::kRecordFieldNumber;
3611
DeleteData::DeleteData() {
3615
void DeleteData::InitAsDefaultInstance() {
3618
DeleteData::DeleteData(const DeleteData& from) {
3623
void DeleteData::SharedCtor() {
3626
end_segment_ = false;
3627
::memset(_has_bits_, 0, sizeof(_has_bits_));
3630
DeleteData::~DeleteData() {
3634
void DeleteData::SharedDtor() {
3635
if (this != default_instance_) {
3639
const ::google::protobuf::Descriptor* DeleteData::descriptor() {
3640
protobuf_AssignDescriptorsOnce();
3641
return DeleteData_descriptor_;
3644
const DeleteData& DeleteData::default_instance() {
3645
if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto(); return *default_instance_;
3648
DeleteData* DeleteData::default_instance_ = NULL;
3650
DeleteData* DeleteData::New() const {
3651
return new DeleteData;
3654
void DeleteData::Clear() {
3655
if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
3657
end_segment_ = false;
3660
::memset(_has_bits_, 0, sizeof(_has_bits_));
3661
mutable_unknown_fields()->Clear();
3664
bool DeleteData::MergePartialFromCodedStream(
3665
::google::protobuf::io::CodedInputStream* input) {
3666
#define DO_(EXPRESSION) if (!(EXPRESSION)) return false
3667
::google::protobuf::uint32 tag;
3668
while ((tag = input->ReadTag()) != 0) {
3669
switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
3670
// required uint32 segment_id = 1;
3672
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
3673
::google::protobuf::internal::WireFormatLite::WIRETYPE_VARINT) {
3674
goto handle_uninterpreted;
3676
DO_(::google::protobuf::internal::WireFormatLite::ReadUInt32(
3677
input, &segment_id_));
3679
if (input->ExpectTag(16)) goto parse_end_segment;
3683
// required bool end_segment = 2;
3685
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
3686
::google::protobuf::internal::WireFormatLite::WIRETYPE_VARINT) {
3687
goto handle_uninterpreted;
3690
DO_(::google::protobuf::internal::WireFormatLite::ReadBool(
3691
input, &end_segment_));
3693
if (input->ExpectTag(26)) goto parse_record;
3697
// repeated .drizzled.message.DeleteRecord record = 3;
3699
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
3700
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
3701
goto handle_uninterpreted;
3704
DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
3705
input, add_record()));
3706
if (input->ExpectTag(26)) goto parse_record;
3707
if (input->ExpectAtEnd()) return true;
3712
handle_uninterpreted:
3713
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
3714
::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
3717
DO_(::google::protobuf::internal::WireFormat::SkipField(
3718
input, tag, mutable_unknown_fields()));
3727
void DeleteData::SerializeWithCachedSizes(
3728
::google::protobuf::io::CodedOutputStream* output) const {
3729
::google::protobuf::uint8* raw_buffer = output->GetDirectBufferForNBytesAndAdvance(_cached_size_);
3730
if (raw_buffer != NULL) {
3731
DeleteData::SerializeWithCachedSizesToArray(raw_buffer);
3735
// required uint32 segment_id = 1;
3737
::google::protobuf::internal::WireFormatLite::WriteUInt32(1, this->segment_id(), output);
3740
// required bool end_segment = 2;
3742
::google::protobuf::internal::WireFormatLite::WriteBool(2, this->end_segment(), output);
3745
// repeated .drizzled.message.DeleteRecord record = 3;
3746
for (int i = 0; i < this->record_size(); i++) {
3747
::google::protobuf::internal::WireFormatLite::WriteMessageNoVirtual(
3748
3, this->record(i), output);
3751
if (!unknown_fields().empty()) {
3752
::google::protobuf::internal::WireFormat::SerializeUnknownFields(
3753
unknown_fields(), output);
3757
::google::protobuf::uint8* DeleteData::SerializeWithCachedSizesToArray(
3758
::google::protobuf::uint8* target) const {
3759
// required uint32 segment_id = 1;
3761
target = ::google::protobuf::internal::WireFormatLite::WriteUInt32ToArray(1, this->segment_id(), target);
3764
// required bool end_segment = 2;
3766
target = ::google::protobuf::internal::WireFormatLite::WriteBoolToArray(2, this->end_segment(), target);
3769
// repeated .drizzled.message.DeleteRecord record = 3;
3770
for (int i = 0; i < this->record_size(); i++) {
3771
target = ::google::protobuf::internal::WireFormatLite::
3772
WriteMessageNoVirtualToArray(
3773
3, this->record(i), target);
3776
if (!unknown_fields().empty()) {
3777
target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
3778
unknown_fields(), target);
3783
int DeleteData::ByteSize() const {
3786
if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
3787
// required uint32 segment_id = 1;
3788
if (has_segment_id()) {
3790
::google::protobuf::internal::WireFormatLite::UInt32Size(
3791
this->segment_id());
3794
// required bool end_segment = 2;
3795
if (has_end_segment()) {
3796
total_size += 1 + 1;
3800
// repeated .drizzled.message.DeleteRecord record = 3;
3801
total_size += 1 * this->record_size();
3802
for (int i = 0; i < this->record_size(); i++) {
3804
::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
3808
if (!unknown_fields().empty()) {
3810
::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
3813
_cached_size_ = total_size;
3817
void DeleteData::MergeFrom(const ::google::protobuf::Message& from) {
3818
GOOGLE_CHECK_NE(&from, this);
3819
const DeleteData* source =
3820
::google::protobuf::internal::dynamic_cast_if_available<const DeleteData*>(
3822
if (source == NULL) {
3823
::google::protobuf::internal::ReflectionOps::Merge(from, this);
3829
void DeleteData::MergeFrom(const DeleteData& from) {
3830
GOOGLE_CHECK_NE(&from, this);
3831
record_.MergeFrom(from.record_);
3832
if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
3833
if (from._has_bit(0)) {
3834
set_segment_id(from.segment_id());
3836
if (from._has_bit(1)) {
3837
set_end_segment(from.end_segment());
3840
mutable_unknown_fields()->MergeFrom(from.unknown_fields());
3843
void DeleteData::CopyFrom(const ::google::protobuf::Message& from) {
3844
if (&from == this) return;
3849
void DeleteData::CopyFrom(const DeleteData& from) {
3850
if (&from == this) return;
3855
bool DeleteData::IsInitialized() const {
3856
if ((_has_bits_[0] & 0x00000003) != 0x00000003) return false;
3861
void DeleteData::Swap(DeleteData* other) {
3862
if (other != this) {
3863
std::swap(segment_id_, other->segment_id_);
3864
std::swap(end_segment_, other->end_segment_);
3865
record_.Swap(&other->record_);
3866
std::swap(_has_bits_[0], other->_has_bits_[0]);
3867
_unknown_fields_.Swap(&other->_unknown_fields_);
3868
std::swap(_cached_size_, other->_cached_size_);
3872
::google::protobuf::Metadata DeleteData::GetMetadata() const {
3873
protobuf_AssignDescriptorsOnce();
3874
::google::protobuf::Metadata metadata;
3875
metadata.descriptor = DeleteData_descriptor_;
3876
metadata.reflection = DeleteData_reflection_;
3881
// ===================================================================
3884
const int TruncateTableStatement::kTableMetadataFieldNumber;
3887
TruncateTableStatement::TruncateTableStatement() {
3891
void TruncateTableStatement::InitAsDefaultInstance() {
3892
table_metadata_ = const_cast< ::drizzled::message::TableMetadata*>(&::drizzled::message::TableMetadata::default_instance());
3895
TruncateTableStatement::TruncateTableStatement(const TruncateTableStatement& from) {
3900
void TruncateTableStatement::SharedCtor() {
3902
table_metadata_ = NULL;
3903
::memset(_has_bits_, 0, sizeof(_has_bits_));
3906
TruncateTableStatement::~TruncateTableStatement() {
3910
void TruncateTableStatement::SharedDtor() {
3911
if (this != default_instance_) {
3912
delete table_metadata_;
3916
const ::google::protobuf::Descriptor* TruncateTableStatement::descriptor() {
3917
protobuf_AssignDescriptorsOnce();
3918
return TruncateTableStatement_descriptor_;
3921
const TruncateTableStatement& TruncateTableStatement::default_instance() {
3922
if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto(); return *default_instance_;
3925
TruncateTableStatement* TruncateTableStatement::default_instance_ = NULL;
3927
TruncateTableStatement* TruncateTableStatement::New() const {
3928
return new TruncateTableStatement;
3931
void TruncateTableStatement::Clear() {
3932
if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
3934
if (table_metadata_ != NULL) table_metadata_->::drizzled::message::TableMetadata::Clear();
3937
::memset(_has_bits_, 0, sizeof(_has_bits_));
3938
mutable_unknown_fields()->Clear();
3941
bool TruncateTableStatement::MergePartialFromCodedStream(
3942
::google::protobuf::io::CodedInputStream* input) {
3943
#define DO_(EXPRESSION) if (!(EXPRESSION)) return false
3944
::google::protobuf::uint32 tag;
3945
while ((tag = input->ReadTag()) != 0) {
3946
switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
3947
// required .drizzled.message.TableMetadata table_metadata = 1;
3949
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
3950
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
3951
goto handle_uninterpreted;
3953
DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
3954
input, mutable_table_metadata()));
3955
if (input->ExpectAtEnd()) return true;
3960
handle_uninterpreted:
3961
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
3962
::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
3965
DO_(::google::protobuf::internal::WireFormat::SkipField(
3966
input, tag, mutable_unknown_fields()));
3975
void TruncateTableStatement::SerializeWithCachedSizes(
3976
::google::protobuf::io::CodedOutputStream* output) const {
3977
::google::protobuf::uint8* raw_buffer = output->GetDirectBufferForNBytesAndAdvance(_cached_size_);
3978
if (raw_buffer != NULL) {
3979
TruncateTableStatement::SerializeWithCachedSizesToArray(raw_buffer);
3983
// required .drizzled.message.TableMetadata table_metadata = 1;
3985
::google::protobuf::internal::WireFormatLite::WriteMessageNoVirtual(
3986
1, this->table_metadata(), output);
3989
if (!unknown_fields().empty()) {
3990
::google::protobuf::internal::WireFormat::SerializeUnknownFields(
3991
unknown_fields(), output);
3995
::google::protobuf::uint8* TruncateTableStatement::SerializeWithCachedSizesToArray(
3996
::google::protobuf::uint8* target) const {
3997
// required .drizzled.message.TableMetadata table_metadata = 1;
3999
target = ::google::protobuf::internal::WireFormatLite::
4000
WriteMessageNoVirtualToArray(
4001
1, this->table_metadata(), target);
4004
if (!unknown_fields().empty()) {
4005
target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
4006
unknown_fields(), target);
4011
int TruncateTableStatement::ByteSize() const {
4014
if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
4015
// required .drizzled.message.TableMetadata table_metadata = 1;
4016
if (has_table_metadata()) {
4018
::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
4019
this->table_metadata());
4023
if (!unknown_fields().empty()) {
4025
::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
4028
_cached_size_ = total_size;
4032
void TruncateTableStatement::MergeFrom(const ::google::protobuf::Message& from) {
4033
GOOGLE_CHECK_NE(&from, this);
4034
const TruncateTableStatement* source =
4035
::google::protobuf::internal::dynamic_cast_if_available<const TruncateTableStatement*>(
4037
if (source == NULL) {
4038
::google::protobuf::internal::ReflectionOps::Merge(from, this);
4044
void TruncateTableStatement::MergeFrom(const TruncateTableStatement& from) {
4045
GOOGLE_CHECK_NE(&from, this);
4046
if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
4047
if (from._has_bit(0)) {
4048
mutable_table_metadata()->::drizzled::message::TableMetadata::MergeFrom(from.table_metadata());
4051
mutable_unknown_fields()->MergeFrom(from.unknown_fields());
4054
void TruncateTableStatement::CopyFrom(const ::google::protobuf::Message& from) {
4055
if (&from == this) return;
4060
void TruncateTableStatement::CopyFrom(const TruncateTableStatement& from) {
4061
if (&from == this) return;
4066
bool TruncateTableStatement::IsInitialized() const {
4067
if ((_has_bits_[0] & 0x00000001) != 0x00000001) return false;
4069
if (has_table_metadata()) {
4070
if (!this->table_metadata().IsInitialized()) return false;
4075
void TruncateTableStatement::Swap(TruncateTableStatement* other) {
4076
if (other != this) {
4077
std::swap(table_metadata_, other->table_metadata_);
4078
std::swap(_has_bits_[0], other->_has_bits_[0]);
4079
_unknown_fields_.Swap(&other->_unknown_fields_);
4080
std::swap(_cached_size_, other->_cached_size_);
4084
::google::protobuf::Metadata TruncateTableStatement::GetMetadata() const {
4085
protobuf_AssignDescriptorsOnce();
4086
::google::protobuf::Metadata metadata;
4087
metadata.descriptor = TruncateTableStatement_descriptor_;
4088
metadata.reflection = TruncateTableStatement_reflection_;
4093
// ===================================================================
4096
const int CreateSchemaStatement::kSchemaFieldNumber;
4099
CreateSchemaStatement::CreateSchemaStatement() {
4103
void CreateSchemaStatement::InitAsDefaultInstance() {
4104
schema_ = const_cast< ::drizzled::message::Schema*>(&::drizzled::message::Schema::default_instance());
4107
CreateSchemaStatement::CreateSchemaStatement(const CreateSchemaStatement& from) {
4112
void CreateSchemaStatement::SharedCtor() {
4115
::memset(_has_bits_, 0, sizeof(_has_bits_));
4118
CreateSchemaStatement::~CreateSchemaStatement() {
4122
void CreateSchemaStatement::SharedDtor() {
4123
if (this != default_instance_) {
4128
const ::google::protobuf::Descriptor* CreateSchemaStatement::descriptor() {
4129
protobuf_AssignDescriptorsOnce();
4130
return CreateSchemaStatement_descriptor_;
4133
const CreateSchemaStatement& CreateSchemaStatement::default_instance() {
4134
if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto(); return *default_instance_;
4137
CreateSchemaStatement* CreateSchemaStatement::default_instance_ = NULL;
4139
CreateSchemaStatement* CreateSchemaStatement::New() const {
4140
return new CreateSchemaStatement;
4143
void CreateSchemaStatement::Clear() {
4144
if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
4146
if (schema_ != NULL) schema_->::drizzled::message::Schema::Clear();
4149
::memset(_has_bits_, 0, sizeof(_has_bits_));
4150
mutable_unknown_fields()->Clear();
4153
bool CreateSchemaStatement::MergePartialFromCodedStream(
4154
::google::protobuf::io::CodedInputStream* input) {
4155
#define DO_(EXPRESSION) if (!(EXPRESSION)) return false
4156
::google::protobuf::uint32 tag;
4157
while ((tag = input->ReadTag()) != 0) {
4158
switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
4159
// required .drizzled.message.Schema schema = 1;
4161
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
4162
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
4163
goto handle_uninterpreted;
4165
DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
4166
input, mutable_schema()));
4167
if (input->ExpectAtEnd()) return true;
4172
handle_uninterpreted:
4173
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
4174
::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
4177
DO_(::google::protobuf::internal::WireFormat::SkipField(
4178
input, tag, mutable_unknown_fields()));
4187
void CreateSchemaStatement::SerializeWithCachedSizes(
4188
::google::protobuf::io::CodedOutputStream* output) const {
4189
::google::protobuf::uint8* raw_buffer = output->GetDirectBufferForNBytesAndAdvance(_cached_size_);
4190
if (raw_buffer != NULL) {
4191
CreateSchemaStatement::SerializeWithCachedSizesToArray(raw_buffer);
4195
// required .drizzled.message.Schema schema = 1;
4197
::google::protobuf::internal::WireFormatLite::WriteMessageNoVirtual(
4198
1, this->schema(), output);
4201
if (!unknown_fields().empty()) {
4202
::google::protobuf::internal::WireFormat::SerializeUnknownFields(
4203
unknown_fields(), output);
4207
::google::protobuf::uint8* CreateSchemaStatement::SerializeWithCachedSizesToArray(
4208
::google::protobuf::uint8* target) const {
4209
// required .drizzled.message.Schema schema = 1;
4211
target = ::google::protobuf::internal::WireFormatLite::
4212
WriteMessageNoVirtualToArray(
4213
1, this->schema(), target);
4216
if (!unknown_fields().empty()) {
4217
target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
4218
unknown_fields(), target);
4223
int CreateSchemaStatement::ByteSize() const {
4226
if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
4227
// required .drizzled.message.Schema schema = 1;
4230
::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
4235
if (!unknown_fields().empty()) {
4237
::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
4240
_cached_size_ = total_size;
4244
void CreateSchemaStatement::MergeFrom(const ::google::protobuf::Message& from) {
4245
GOOGLE_CHECK_NE(&from, this);
4246
const CreateSchemaStatement* source =
4247
::google::protobuf::internal::dynamic_cast_if_available<const CreateSchemaStatement*>(
4249
if (source == NULL) {
4250
::google::protobuf::internal::ReflectionOps::Merge(from, this);
4256
void CreateSchemaStatement::MergeFrom(const CreateSchemaStatement& from) {
4257
GOOGLE_CHECK_NE(&from, this);
4258
if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
4259
if (from._has_bit(0)) {
4260
mutable_schema()->::drizzled::message::Schema::MergeFrom(from.schema());
4263
mutable_unknown_fields()->MergeFrom(from.unknown_fields());
4266
void CreateSchemaStatement::CopyFrom(const ::google::protobuf::Message& from) {
4267
if (&from == this) return;
4272
void CreateSchemaStatement::CopyFrom(const CreateSchemaStatement& from) {
4273
if (&from == this) return;
4278
bool CreateSchemaStatement::IsInitialized() const {
4279
if ((_has_bits_[0] & 0x00000001) != 0x00000001) return false;
4282
if (!this->schema().IsInitialized()) return false;
4287
void CreateSchemaStatement::Swap(CreateSchemaStatement* other) {
4288
if (other != this) {
4289
std::swap(schema_, other->schema_);
4290
std::swap(_has_bits_[0], other->_has_bits_[0]);
4291
_unknown_fields_.Swap(&other->_unknown_fields_);
4292
std::swap(_cached_size_, other->_cached_size_);
4296
::google::protobuf::Metadata CreateSchemaStatement::GetMetadata() const {
4297
protobuf_AssignDescriptorsOnce();
4298
::google::protobuf::Metadata metadata;
4299
metadata.descriptor = CreateSchemaStatement_descriptor_;
4300
metadata.reflection = CreateSchemaStatement_reflection_;
4305
// ===================================================================
4308
const int AlterSchemaStatement::kBeforeFieldNumber;
4309
const int AlterSchemaStatement::kAfterFieldNumber;
4312
AlterSchemaStatement::AlterSchemaStatement() {
4316
void AlterSchemaStatement::InitAsDefaultInstance() {
4317
before_ = const_cast< ::drizzled::message::Schema*>(&::drizzled::message::Schema::default_instance());
4318
after_ = const_cast< ::drizzled::message::Schema*>(&::drizzled::message::Schema::default_instance());
4321
AlterSchemaStatement::AlterSchemaStatement(const AlterSchemaStatement& from) {
4326
void AlterSchemaStatement::SharedCtor() {
4330
::memset(_has_bits_, 0, sizeof(_has_bits_));
4333
AlterSchemaStatement::~AlterSchemaStatement() {
4337
void AlterSchemaStatement::SharedDtor() {
4338
if (this != default_instance_) {
4344
const ::google::protobuf::Descriptor* AlterSchemaStatement::descriptor() {
4345
protobuf_AssignDescriptorsOnce();
4346
return AlterSchemaStatement_descriptor_;
4349
const AlterSchemaStatement& AlterSchemaStatement::default_instance() {
4350
if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto(); return *default_instance_;
4353
AlterSchemaStatement* AlterSchemaStatement::default_instance_ = NULL;
4355
AlterSchemaStatement* AlterSchemaStatement::New() const {
4356
return new AlterSchemaStatement;
4359
void AlterSchemaStatement::Clear() {
4360
if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
4362
if (before_ != NULL) before_->::drizzled::message::Schema::Clear();
4365
if (after_ != NULL) after_->::drizzled::message::Schema::Clear();
4368
::memset(_has_bits_, 0, sizeof(_has_bits_));
4369
mutable_unknown_fields()->Clear();
4372
bool AlterSchemaStatement::MergePartialFromCodedStream(
4373
::google::protobuf::io::CodedInputStream* input) {
4374
#define DO_(EXPRESSION) if (!(EXPRESSION)) return false
4375
::google::protobuf::uint32 tag;
4376
while ((tag = input->ReadTag()) != 0) {
4377
switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
4378
// required .drizzled.message.Schema before = 1;
4380
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
4381
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
4382
goto handle_uninterpreted;
4384
DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
4385
input, mutable_before()));
4386
if (input->ExpectTag(18)) goto parse_after;
4390
// required .drizzled.message.Schema after = 2;
4392
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
4393
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
4394
goto handle_uninterpreted;
4397
DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
4398
input, mutable_after()));
4399
if (input->ExpectAtEnd()) return true;
4404
handle_uninterpreted:
4405
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
4406
::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
4409
DO_(::google::protobuf::internal::WireFormat::SkipField(
4410
input, tag, mutable_unknown_fields()));
4419
void AlterSchemaStatement::SerializeWithCachedSizes(
4420
::google::protobuf::io::CodedOutputStream* output) const {
4421
::google::protobuf::uint8* raw_buffer = output->GetDirectBufferForNBytesAndAdvance(_cached_size_);
4422
if (raw_buffer != NULL) {
4423
AlterSchemaStatement::SerializeWithCachedSizesToArray(raw_buffer);
4427
// required .drizzled.message.Schema before = 1;
4429
::google::protobuf::internal::WireFormatLite::WriteMessageNoVirtual(
4430
1, this->before(), output);
4433
// required .drizzled.message.Schema after = 2;
4435
::google::protobuf::internal::WireFormatLite::WriteMessageNoVirtual(
4436
2, this->after(), output);
4439
if (!unknown_fields().empty()) {
4440
::google::protobuf::internal::WireFormat::SerializeUnknownFields(
4441
unknown_fields(), output);
4445
::google::protobuf::uint8* AlterSchemaStatement::SerializeWithCachedSizesToArray(
4446
::google::protobuf::uint8* target) const {
4447
// required .drizzled.message.Schema before = 1;
4449
target = ::google::protobuf::internal::WireFormatLite::
4450
WriteMessageNoVirtualToArray(
4451
1, this->before(), target);
4454
// required .drizzled.message.Schema after = 2;
4456
target = ::google::protobuf::internal::WireFormatLite::
4457
WriteMessageNoVirtualToArray(
4458
2, this->after(), target);
4461
if (!unknown_fields().empty()) {
4462
target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
4463
unknown_fields(), target);
4468
int AlterSchemaStatement::ByteSize() const {
4471
if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
4472
// required .drizzled.message.Schema before = 1;
4475
::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
4479
// required .drizzled.message.Schema after = 2;
4482
::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
4487
if (!unknown_fields().empty()) {
4489
::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
4492
_cached_size_ = total_size;
4496
void AlterSchemaStatement::MergeFrom(const ::google::protobuf::Message& from) {
4497
GOOGLE_CHECK_NE(&from, this);
4498
const AlterSchemaStatement* source =
4499
::google::protobuf::internal::dynamic_cast_if_available<const AlterSchemaStatement*>(
4501
if (source == NULL) {
4502
::google::protobuf::internal::ReflectionOps::Merge(from, this);
4508
void AlterSchemaStatement::MergeFrom(const AlterSchemaStatement& from) {
4509
GOOGLE_CHECK_NE(&from, this);
4510
if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
4511
if (from._has_bit(0)) {
4512
mutable_before()->::drizzled::message::Schema::MergeFrom(from.before());
4514
if (from._has_bit(1)) {
4515
mutable_after()->::drizzled::message::Schema::MergeFrom(from.after());
4518
mutable_unknown_fields()->MergeFrom(from.unknown_fields());
4521
void AlterSchemaStatement::CopyFrom(const ::google::protobuf::Message& from) {
4522
if (&from == this) return;
4527
void AlterSchemaStatement::CopyFrom(const AlterSchemaStatement& from) {
4528
if (&from == this) return;
4533
bool AlterSchemaStatement::IsInitialized() const {
4534
if ((_has_bits_[0] & 0x00000003) != 0x00000003) return false;
4537
if (!this->before().IsInitialized()) return false;
4540
if (!this->after().IsInitialized()) return false;
4545
void AlterSchemaStatement::Swap(AlterSchemaStatement* other) {
4546
if (other != this) {
4547
std::swap(before_, other->before_);
4548
std::swap(after_, other->after_);
4549
std::swap(_has_bits_[0], other->_has_bits_[0]);
4550
_unknown_fields_.Swap(&other->_unknown_fields_);
4551
std::swap(_cached_size_, other->_cached_size_);
4555
::google::protobuf::Metadata AlterSchemaStatement::GetMetadata() const {
4556
protobuf_AssignDescriptorsOnce();
4557
::google::protobuf::Metadata metadata;
4558
metadata.descriptor = AlterSchemaStatement_descriptor_;
4559
metadata.reflection = AlterSchemaStatement_reflection_;
4564
// ===================================================================
4566
const ::std::string DropSchemaStatement::_default_schema_name_;
4568
const int DropSchemaStatement::kSchemaNameFieldNumber;
4571
DropSchemaStatement::DropSchemaStatement() {
4575
void DropSchemaStatement::InitAsDefaultInstance() {
4578
DropSchemaStatement::DropSchemaStatement(const DropSchemaStatement& from) {
4583
void DropSchemaStatement::SharedCtor() {
4585
schema_name_ = const_cast< ::std::string*>(&_default_schema_name_);
4586
::memset(_has_bits_, 0, sizeof(_has_bits_));
4589
DropSchemaStatement::~DropSchemaStatement() {
4593
void DropSchemaStatement::SharedDtor() {
4594
if (schema_name_ != &_default_schema_name_) {
4595
delete schema_name_;
4597
if (this != default_instance_) {
4601
const ::google::protobuf::Descriptor* DropSchemaStatement::descriptor() {
4602
protobuf_AssignDescriptorsOnce();
4603
return DropSchemaStatement_descriptor_;
4606
const DropSchemaStatement& DropSchemaStatement::default_instance() {
4607
if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto(); return *default_instance_;
4610
DropSchemaStatement* DropSchemaStatement::default_instance_ = NULL;
4612
DropSchemaStatement* DropSchemaStatement::New() const {
4613
return new DropSchemaStatement;
4616
void DropSchemaStatement::Clear() {
4617
if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
4619
if (schema_name_ != &_default_schema_name_) {
4620
schema_name_->clear();
4624
::memset(_has_bits_, 0, sizeof(_has_bits_));
4625
mutable_unknown_fields()->Clear();
4628
bool DropSchemaStatement::MergePartialFromCodedStream(
4629
::google::protobuf::io::CodedInputStream* input) {
4630
#define DO_(EXPRESSION) if (!(EXPRESSION)) return false
4631
::google::protobuf::uint32 tag;
4632
while ((tag = input->ReadTag()) != 0) {
4633
switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
4634
// required string schema_name = 1;
4636
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
4637
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
4638
goto handle_uninterpreted;
4640
DO_(::google::protobuf::internal::WireFormatLite::ReadString(
4641
input, this->mutable_schema_name()));
4642
::google::protobuf::internal::WireFormat::VerifyUTF8String(
4643
this->schema_name().data(), this->schema_name().length(),
4644
::google::protobuf::internal::WireFormat::PARSE);
4645
if (input->ExpectAtEnd()) return true;
4650
handle_uninterpreted:
4651
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
4652
::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
4655
DO_(::google::protobuf::internal::WireFormat::SkipField(
4656
input, tag, mutable_unknown_fields()));
4665
void DropSchemaStatement::SerializeWithCachedSizes(
4666
::google::protobuf::io::CodedOutputStream* output) const {
4667
::google::protobuf::uint8* raw_buffer = output->GetDirectBufferForNBytesAndAdvance(_cached_size_);
4668
if (raw_buffer != NULL) {
4669
DropSchemaStatement::SerializeWithCachedSizesToArray(raw_buffer);
4673
// required string schema_name = 1;
4675
::google::protobuf::internal::WireFormat::VerifyUTF8String(
4676
this->schema_name().data(), this->schema_name().length(),
4677
::google::protobuf::internal::WireFormat::SERIALIZE);
4678
::google::protobuf::internal::WireFormatLite::WriteString(
4679
1, this->schema_name(), output);
4682
if (!unknown_fields().empty()) {
4683
::google::protobuf::internal::WireFormat::SerializeUnknownFields(
4684
unknown_fields(), output);
4688
::google::protobuf::uint8* DropSchemaStatement::SerializeWithCachedSizesToArray(
4689
::google::protobuf::uint8* target) const {
4690
// required string schema_name = 1;
4692
::google::protobuf::internal::WireFormat::VerifyUTF8String(
4693
this->schema_name().data(), this->schema_name().length(),
4694
::google::protobuf::internal::WireFormat::SERIALIZE);
4696
::google::protobuf::internal::WireFormatLite::WriteStringToArray(
4697
1, this->schema_name(), target);
4700
if (!unknown_fields().empty()) {
4701
target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
4702
unknown_fields(), target);
4707
int DropSchemaStatement::ByteSize() const {
4710
if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
4711
// required string schema_name = 1;
4712
if (has_schema_name()) {
4714
::google::protobuf::internal::WireFormatLite::StringSize(
4715
this->schema_name());
4719
if (!unknown_fields().empty()) {
4721
::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
4724
_cached_size_ = total_size;
4728
void DropSchemaStatement::MergeFrom(const ::google::protobuf::Message& from) {
4729
GOOGLE_CHECK_NE(&from, this);
4730
const DropSchemaStatement* source =
4731
::google::protobuf::internal::dynamic_cast_if_available<const DropSchemaStatement*>(
4733
if (source == NULL) {
4734
::google::protobuf::internal::ReflectionOps::Merge(from, this);
4740
void DropSchemaStatement::MergeFrom(const DropSchemaStatement& from) {
4741
GOOGLE_CHECK_NE(&from, this);
4742
if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
4743
if (from._has_bit(0)) {
4744
set_schema_name(from.schema_name());
4747
mutable_unknown_fields()->MergeFrom(from.unknown_fields());
4750
void DropSchemaStatement::CopyFrom(const ::google::protobuf::Message& from) {
4751
if (&from == this) return;
4756
void DropSchemaStatement::CopyFrom(const DropSchemaStatement& from) {
4757
if (&from == this) return;
4762
bool DropSchemaStatement::IsInitialized() const {
4763
if ((_has_bits_[0] & 0x00000001) != 0x00000001) return false;
4768
void DropSchemaStatement::Swap(DropSchemaStatement* other) {
4769
if (other != this) {
4770
std::swap(schema_name_, other->schema_name_);
4771
std::swap(_has_bits_[0], other->_has_bits_[0]);
4772
_unknown_fields_.Swap(&other->_unknown_fields_);
4773
std::swap(_cached_size_, other->_cached_size_);
4777
::google::protobuf::Metadata DropSchemaStatement::GetMetadata() const {
4778
protobuf_AssignDescriptorsOnce();
4779
::google::protobuf::Metadata metadata;
4780
metadata.descriptor = DropSchemaStatement_descriptor_;
4781
metadata.reflection = DropSchemaStatement_reflection_;
4786
// ===================================================================
4789
const int CreateTableStatement::kTableFieldNumber;
4792
CreateTableStatement::CreateTableStatement() {
4796
void CreateTableStatement::InitAsDefaultInstance() {
4797
table_ = const_cast< ::drizzled::message::Table*>(&::drizzled::message::Table::default_instance());
4800
CreateTableStatement::CreateTableStatement(const CreateTableStatement& from) {
4805
void CreateTableStatement::SharedCtor() {
4808
::memset(_has_bits_, 0, sizeof(_has_bits_));
4811
CreateTableStatement::~CreateTableStatement() {
4815
void CreateTableStatement::SharedDtor() {
4816
if (this != default_instance_) {
4821
const ::google::protobuf::Descriptor* CreateTableStatement::descriptor() {
4822
protobuf_AssignDescriptorsOnce();
4823
return CreateTableStatement_descriptor_;
4826
const CreateTableStatement& CreateTableStatement::default_instance() {
4827
if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto(); return *default_instance_;
4830
CreateTableStatement* CreateTableStatement::default_instance_ = NULL;
4832
CreateTableStatement* CreateTableStatement::New() const {
4833
return new CreateTableStatement;
4836
void CreateTableStatement::Clear() {
4837
if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
4839
if (table_ != NULL) table_->::drizzled::message::Table::Clear();
4842
::memset(_has_bits_, 0, sizeof(_has_bits_));
4843
mutable_unknown_fields()->Clear();
4846
bool CreateTableStatement::MergePartialFromCodedStream(
4847
::google::protobuf::io::CodedInputStream* input) {
4848
#define DO_(EXPRESSION) if (!(EXPRESSION)) return false
4849
::google::protobuf::uint32 tag;
4850
while ((tag = input->ReadTag()) != 0) {
4851
switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
4852
// required .drizzled.message.Table table = 1;
4854
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
4855
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
4856
goto handle_uninterpreted;
4858
DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
4859
input, mutable_table()));
4860
if (input->ExpectAtEnd()) return true;
4865
handle_uninterpreted:
4866
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
4867
::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
4870
DO_(::google::protobuf::internal::WireFormat::SkipField(
4871
input, tag, mutable_unknown_fields()));
4880
void CreateTableStatement::SerializeWithCachedSizes(
4881
::google::protobuf::io::CodedOutputStream* output) const {
4882
::google::protobuf::uint8* raw_buffer = output->GetDirectBufferForNBytesAndAdvance(_cached_size_);
4883
if (raw_buffer != NULL) {
4884
CreateTableStatement::SerializeWithCachedSizesToArray(raw_buffer);
4888
// required .drizzled.message.Table table = 1;
4890
::google::protobuf::internal::WireFormatLite::WriteMessageNoVirtual(
4891
1, this->table(), output);
4894
if (!unknown_fields().empty()) {
4895
::google::protobuf::internal::WireFormat::SerializeUnknownFields(
4896
unknown_fields(), output);
4900
::google::protobuf::uint8* CreateTableStatement::SerializeWithCachedSizesToArray(
4901
::google::protobuf::uint8* target) const {
4902
// required .drizzled.message.Table table = 1;
4904
target = ::google::protobuf::internal::WireFormatLite::
4905
WriteMessageNoVirtualToArray(
4906
1, this->table(), target);
4909
if (!unknown_fields().empty()) {
4910
target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
4911
unknown_fields(), target);
4916
int CreateTableStatement::ByteSize() const {
4919
if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
4920
// required .drizzled.message.Table table = 1;
4923
::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
4928
if (!unknown_fields().empty()) {
4930
::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
4933
_cached_size_ = total_size;
4937
void CreateTableStatement::MergeFrom(const ::google::protobuf::Message& from) {
4938
GOOGLE_CHECK_NE(&from, this);
4939
const CreateTableStatement* source =
4940
::google::protobuf::internal::dynamic_cast_if_available<const CreateTableStatement*>(
4942
if (source == NULL) {
4943
::google::protobuf::internal::ReflectionOps::Merge(from, this);
4949
void CreateTableStatement::MergeFrom(const CreateTableStatement& from) {
4950
GOOGLE_CHECK_NE(&from, this);
4951
if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
4952
if (from._has_bit(0)) {
4953
mutable_table()->::drizzled::message::Table::MergeFrom(from.table());
4956
mutable_unknown_fields()->MergeFrom(from.unknown_fields());
4959
void CreateTableStatement::CopyFrom(const ::google::protobuf::Message& from) {
4960
if (&from == this) return;
4965
void CreateTableStatement::CopyFrom(const CreateTableStatement& from) {
4966
if (&from == this) return;
4971
bool CreateTableStatement::IsInitialized() const {
4972
if ((_has_bits_[0] & 0x00000001) != 0x00000001) return false;
4975
if (!this->table().IsInitialized()) return false;
4980
void CreateTableStatement::Swap(CreateTableStatement* other) {
4981
if (other != this) {
4982
std::swap(table_, other->table_);
4983
std::swap(_has_bits_[0], other->_has_bits_[0]);
4984
_unknown_fields_.Swap(&other->_unknown_fields_);
4985
std::swap(_cached_size_, other->_cached_size_);
4989
::google::protobuf::Metadata CreateTableStatement::GetMetadata() const {
4990
protobuf_AssignDescriptorsOnce();
4991
::google::protobuf::Metadata metadata;
4992
metadata.descriptor = CreateTableStatement_descriptor_;
4993
metadata.reflection = CreateTableStatement_reflection_;
4998
// ===================================================================
5001
const int AlterTableStatement::kBeforeFieldNumber;
5002
const int AlterTableStatement::kAfterFieldNumber;
5005
AlterTableStatement::AlterTableStatement() {
5009
void AlterTableStatement::InitAsDefaultInstance() {
5010
before_ = const_cast< ::drizzled::message::Table*>(&::drizzled::message::Table::default_instance());
5011
after_ = const_cast< ::drizzled::message::Table*>(&::drizzled::message::Table::default_instance());
5014
AlterTableStatement::AlterTableStatement(const AlterTableStatement& from) {
5019
void AlterTableStatement::SharedCtor() {
5023
::memset(_has_bits_, 0, sizeof(_has_bits_));
5026
AlterTableStatement::~AlterTableStatement() {
5030
void AlterTableStatement::SharedDtor() {
5031
if (this != default_instance_) {
5037
const ::google::protobuf::Descriptor* AlterTableStatement::descriptor() {
5038
protobuf_AssignDescriptorsOnce();
5039
return AlterTableStatement_descriptor_;
5042
const AlterTableStatement& AlterTableStatement::default_instance() {
5043
if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto(); return *default_instance_;
5046
AlterTableStatement* AlterTableStatement::default_instance_ = NULL;
5048
AlterTableStatement* AlterTableStatement::New() const {
5049
return new AlterTableStatement;
5052
void AlterTableStatement::Clear() {
5053
if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
5055
if (before_ != NULL) before_->::drizzled::message::Table::Clear();
5058
if (after_ != NULL) after_->::drizzled::message::Table::Clear();
5061
::memset(_has_bits_, 0, sizeof(_has_bits_));
5062
mutable_unknown_fields()->Clear();
5065
bool AlterTableStatement::MergePartialFromCodedStream(
5066
::google::protobuf::io::CodedInputStream* input) {
5067
#define DO_(EXPRESSION) if (!(EXPRESSION)) return false
5068
::google::protobuf::uint32 tag;
5069
while ((tag = input->ReadTag()) != 0) {
5070
switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
5071
// required .drizzled.message.Table before = 1;
5073
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
5074
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
5075
goto handle_uninterpreted;
5077
DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
5078
input, mutable_before()));
5079
if (input->ExpectTag(18)) goto parse_after;
5083
// required .drizzled.message.Table after = 2;
5085
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
5086
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
5087
goto handle_uninterpreted;
5090
DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
5091
input, mutable_after()));
5092
if (input->ExpectAtEnd()) return true;
5097
handle_uninterpreted:
5098
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
5099
::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
5102
DO_(::google::protobuf::internal::WireFormat::SkipField(
5103
input, tag, mutable_unknown_fields()));
5112
void AlterTableStatement::SerializeWithCachedSizes(
5113
::google::protobuf::io::CodedOutputStream* output) const {
5114
::google::protobuf::uint8* raw_buffer = output->GetDirectBufferForNBytesAndAdvance(_cached_size_);
5115
if (raw_buffer != NULL) {
5116
AlterTableStatement::SerializeWithCachedSizesToArray(raw_buffer);
5120
// required .drizzled.message.Table before = 1;
5122
::google::protobuf::internal::WireFormatLite::WriteMessageNoVirtual(
5123
1, this->before(), output);
5126
// required .drizzled.message.Table after = 2;
5128
::google::protobuf::internal::WireFormatLite::WriteMessageNoVirtual(
5129
2, this->after(), output);
5132
if (!unknown_fields().empty()) {
5133
::google::protobuf::internal::WireFormat::SerializeUnknownFields(
5134
unknown_fields(), output);
5138
::google::protobuf::uint8* AlterTableStatement::SerializeWithCachedSizesToArray(
5139
::google::protobuf::uint8* target) const {
5140
// required .drizzled.message.Table before = 1;
5142
target = ::google::protobuf::internal::WireFormatLite::
5143
WriteMessageNoVirtualToArray(
5144
1, this->before(), target);
5147
// required .drizzled.message.Table after = 2;
5149
target = ::google::protobuf::internal::WireFormatLite::
5150
WriteMessageNoVirtualToArray(
5151
2, this->after(), target);
5154
if (!unknown_fields().empty()) {
5155
target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
5156
unknown_fields(), target);
5161
int AlterTableStatement::ByteSize() const {
5164
if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
5165
// required .drizzled.message.Table before = 1;
5168
::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
5172
// required .drizzled.message.Table after = 2;
5175
::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
5180
if (!unknown_fields().empty()) {
5182
::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
5185
_cached_size_ = total_size;
5189
void AlterTableStatement::MergeFrom(const ::google::protobuf::Message& from) {
5190
GOOGLE_CHECK_NE(&from, this);
5191
const AlterTableStatement* source =
5192
::google::protobuf::internal::dynamic_cast_if_available<const AlterTableStatement*>(
5194
if (source == NULL) {
5195
::google::protobuf::internal::ReflectionOps::Merge(from, this);
5201
void AlterTableStatement::MergeFrom(const AlterTableStatement& from) {
5202
GOOGLE_CHECK_NE(&from, this);
5203
if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
5204
if (from._has_bit(0)) {
5205
mutable_before()->::drizzled::message::Table::MergeFrom(from.before());
5207
if (from._has_bit(1)) {
5208
mutable_after()->::drizzled::message::Table::MergeFrom(from.after());
5211
mutable_unknown_fields()->MergeFrom(from.unknown_fields());
5214
void AlterTableStatement::CopyFrom(const ::google::protobuf::Message& from) {
5215
if (&from == this) return;
5220
void AlterTableStatement::CopyFrom(const AlterTableStatement& from) {
5221
if (&from == this) return;
5226
bool AlterTableStatement::IsInitialized() const {
5227
if ((_has_bits_[0] & 0x00000003) != 0x00000003) return false;
5230
if (!this->before().IsInitialized()) return false;
5233
if (!this->after().IsInitialized()) return false;
5238
void AlterTableStatement::Swap(AlterTableStatement* other) {
5239
if (other != this) {
5240
std::swap(before_, other->before_);
5241
std::swap(after_, other->after_);
5242
std::swap(_has_bits_[0], other->_has_bits_[0]);
5243
_unknown_fields_.Swap(&other->_unknown_fields_);
5244
std::swap(_cached_size_, other->_cached_size_);
5248
::google::protobuf::Metadata AlterTableStatement::GetMetadata() const {
5249
protobuf_AssignDescriptorsOnce();
5250
::google::protobuf::Metadata metadata;
5251
metadata.descriptor = AlterTableStatement_descriptor_;
5252
metadata.reflection = AlterTableStatement_reflection_;
5257
// ===================================================================
5260
const int DropTableStatement::kTableMetadataFieldNumber;
5261
const int DropTableStatement::kIfExistsClauseFieldNumber;
5264
DropTableStatement::DropTableStatement() {
5268
void DropTableStatement::InitAsDefaultInstance() {
5269
table_metadata_ = const_cast< ::drizzled::message::TableMetadata*>(&::drizzled::message::TableMetadata::default_instance());
5272
DropTableStatement::DropTableStatement(const DropTableStatement& from) {
5277
void DropTableStatement::SharedCtor() {
5279
table_metadata_ = NULL;
5280
if_exists_clause_ = false;
5281
::memset(_has_bits_, 0, sizeof(_has_bits_));
5284
DropTableStatement::~DropTableStatement() {
5288
void DropTableStatement::SharedDtor() {
5289
if (this != default_instance_) {
5290
delete table_metadata_;
5294
const ::google::protobuf::Descriptor* DropTableStatement::descriptor() {
5295
protobuf_AssignDescriptorsOnce();
5296
return DropTableStatement_descriptor_;
5299
const DropTableStatement& DropTableStatement::default_instance() {
5300
if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto(); return *default_instance_;
5303
DropTableStatement* DropTableStatement::default_instance_ = NULL;
5305
DropTableStatement* DropTableStatement::New() const {
5306
return new DropTableStatement;
5309
void DropTableStatement::Clear() {
5310
if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
5312
if (table_metadata_ != NULL) table_metadata_->::drizzled::message::TableMetadata::Clear();
5314
if_exists_clause_ = false;
5316
::memset(_has_bits_, 0, sizeof(_has_bits_));
5317
mutable_unknown_fields()->Clear();
5320
bool DropTableStatement::MergePartialFromCodedStream(
5321
::google::protobuf::io::CodedInputStream* input) {
5322
#define DO_(EXPRESSION) if (!(EXPRESSION)) return false
5323
::google::protobuf::uint32 tag;
5324
while ((tag = input->ReadTag()) != 0) {
5325
switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
5326
// required .drizzled.message.TableMetadata table_metadata = 1;
5328
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
5329
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
5330
goto handle_uninterpreted;
5332
DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
5333
input, mutable_table_metadata()));
5334
if (input->ExpectTag(16)) goto parse_if_exists_clause;
5338
// optional bool if_exists_clause = 2;
5340
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
5341
::google::protobuf::internal::WireFormatLite::WIRETYPE_VARINT) {
5342
goto handle_uninterpreted;
5344
parse_if_exists_clause:
5345
DO_(::google::protobuf::internal::WireFormatLite::ReadBool(
5346
input, &if_exists_clause_));
5348
if (input->ExpectAtEnd()) return true;
5353
handle_uninterpreted:
5354
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
5355
::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
5358
DO_(::google::protobuf::internal::WireFormat::SkipField(
5359
input, tag, mutable_unknown_fields()));
5368
void DropTableStatement::SerializeWithCachedSizes(
5369
::google::protobuf::io::CodedOutputStream* output) const {
5370
::google::protobuf::uint8* raw_buffer = output->GetDirectBufferForNBytesAndAdvance(_cached_size_);
5371
if (raw_buffer != NULL) {
5372
DropTableStatement::SerializeWithCachedSizesToArray(raw_buffer);
5376
// required .drizzled.message.TableMetadata table_metadata = 1;
5378
::google::protobuf::internal::WireFormatLite::WriteMessageNoVirtual(
5379
1, this->table_metadata(), output);
5382
// optional bool if_exists_clause = 2;
5384
::google::protobuf::internal::WireFormatLite::WriteBool(2, this->if_exists_clause(), output);
5387
if (!unknown_fields().empty()) {
5388
::google::protobuf::internal::WireFormat::SerializeUnknownFields(
5389
unknown_fields(), output);
5393
::google::protobuf::uint8* DropTableStatement::SerializeWithCachedSizesToArray(
5394
::google::protobuf::uint8* target) const {
5395
// required .drizzled.message.TableMetadata table_metadata = 1;
5397
target = ::google::protobuf::internal::WireFormatLite::
5398
WriteMessageNoVirtualToArray(
5399
1, this->table_metadata(), target);
5402
// optional bool if_exists_clause = 2;
5404
target = ::google::protobuf::internal::WireFormatLite::WriteBoolToArray(2, this->if_exists_clause(), target);
5407
if (!unknown_fields().empty()) {
5408
target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
5409
unknown_fields(), target);
5414
int DropTableStatement::ByteSize() const {
5417
if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
5418
// required .drizzled.message.TableMetadata table_metadata = 1;
5419
if (has_table_metadata()) {
5421
::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
5422
this->table_metadata());
5425
// optional bool if_exists_clause = 2;
5426
if (has_if_exists_clause()) {
5427
total_size += 1 + 1;
5431
if (!unknown_fields().empty()) {
5433
::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
5436
_cached_size_ = total_size;
5440
void DropTableStatement::MergeFrom(const ::google::protobuf::Message& from) {
5441
GOOGLE_CHECK_NE(&from, this);
5442
const DropTableStatement* source =
5443
::google::protobuf::internal::dynamic_cast_if_available<const DropTableStatement*>(
5445
if (source == NULL) {
5446
::google::protobuf::internal::ReflectionOps::Merge(from, this);
5452
void DropTableStatement::MergeFrom(const DropTableStatement& from) {
5453
GOOGLE_CHECK_NE(&from, this);
5454
if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
5455
if (from._has_bit(0)) {
5456
mutable_table_metadata()->::drizzled::message::TableMetadata::MergeFrom(from.table_metadata());
5458
if (from._has_bit(1)) {
5459
set_if_exists_clause(from.if_exists_clause());
5462
mutable_unknown_fields()->MergeFrom(from.unknown_fields());
5465
void DropTableStatement::CopyFrom(const ::google::protobuf::Message& from) {
5466
if (&from == this) return;
5471
void DropTableStatement::CopyFrom(const DropTableStatement& from) {
5472
if (&from == this) return;
5477
bool DropTableStatement::IsInitialized() const {
5478
if ((_has_bits_[0] & 0x00000001) != 0x00000001) return false;
5480
if (has_table_metadata()) {
5481
if (!this->table_metadata().IsInitialized()) return false;
5486
void DropTableStatement::Swap(DropTableStatement* other) {
5487
if (other != this) {
5488
std::swap(table_metadata_, other->table_metadata_);
5489
std::swap(if_exists_clause_, other->if_exists_clause_);
5490
std::swap(_has_bits_[0], other->_has_bits_[0]);
5491
_unknown_fields_.Swap(&other->_unknown_fields_);
5492
std::swap(_cached_size_, other->_cached_size_);
5496
::google::protobuf::Metadata DropTableStatement::GetMetadata() const {
5497
protobuf_AssignDescriptorsOnce();
5498
::google::protobuf::Metadata metadata;
5499
metadata.descriptor = DropTableStatement_descriptor_;
5500
metadata.reflection = DropTableStatement_reflection_;
5505
// ===================================================================
5507
const ::std::string SetVariableStatement::_default_variable_value_;
5509
const int SetVariableStatement::kVariableMetadataFieldNumber;
5510
const int SetVariableStatement::kVariableValueFieldNumber;
5513
SetVariableStatement::SetVariableStatement() {
5517
void SetVariableStatement::InitAsDefaultInstance() {
5518
variable_metadata_ = const_cast< ::drizzled::message::FieldMetadata*>(&::drizzled::message::FieldMetadata::default_instance());
5521
SetVariableStatement::SetVariableStatement(const SetVariableStatement& from) {
5526
void SetVariableStatement::SharedCtor() {
5528
variable_metadata_ = NULL;
5529
variable_value_ = const_cast< ::std::string*>(&_default_variable_value_);
5530
::memset(_has_bits_, 0, sizeof(_has_bits_));
5533
SetVariableStatement::~SetVariableStatement() {
5537
void SetVariableStatement::SharedDtor() {
5538
if (variable_value_ != &_default_variable_value_) {
5539
delete variable_value_;
5541
if (this != default_instance_) {
5542
delete variable_metadata_;
5546
const ::google::protobuf::Descriptor* SetVariableStatement::descriptor() {
5547
protobuf_AssignDescriptorsOnce();
5548
return SetVariableStatement_descriptor_;
5551
const SetVariableStatement& SetVariableStatement::default_instance() {
5552
if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto(); return *default_instance_;
5555
SetVariableStatement* SetVariableStatement::default_instance_ = NULL;
5557
SetVariableStatement* SetVariableStatement::New() const {
5558
return new SetVariableStatement;
5561
void SetVariableStatement::Clear() {
5562
if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
5564
if (variable_metadata_ != NULL) variable_metadata_->::drizzled::message::FieldMetadata::Clear();
5567
if (variable_value_ != &_default_variable_value_) {
5568
variable_value_->clear();
5572
::memset(_has_bits_, 0, sizeof(_has_bits_));
5573
mutable_unknown_fields()->Clear();
5576
bool SetVariableStatement::MergePartialFromCodedStream(
5577
::google::protobuf::io::CodedInputStream* input) {
5578
#define DO_(EXPRESSION) if (!(EXPRESSION)) return false
5579
::google::protobuf::uint32 tag;
5580
while ((tag = input->ReadTag()) != 0) {
5581
switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
5582
// required .drizzled.message.FieldMetadata variable_metadata = 1;
5584
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
5585
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
5586
goto handle_uninterpreted;
5588
DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
5589
input, mutable_variable_metadata()));
5590
if (input->ExpectTag(18)) goto parse_variable_value;
5594
// required bytes variable_value = 2;
5596
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
5597
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
5598
goto handle_uninterpreted;
5600
parse_variable_value:
5601
DO_(::google::protobuf::internal::WireFormatLite::ReadBytes(
5602
input, this->mutable_variable_value()));
5603
if (input->ExpectAtEnd()) return true;
5608
handle_uninterpreted:
5609
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
5610
::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
5613
DO_(::google::protobuf::internal::WireFormat::SkipField(
5614
input, tag, mutable_unknown_fields()));
5623
void SetVariableStatement::SerializeWithCachedSizes(
5624
::google::protobuf::io::CodedOutputStream* output) const {
5625
::google::protobuf::uint8* raw_buffer = output->GetDirectBufferForNBytesAndAdvance(_cached_size_);
5626
if (raw_buffer != NULL) {
5627
SetVariableStatement::SerializeWithCachedSizesToArray(raw_buffer);
5631
// required .drizzled.message.FieldMetadata variable_metadata = 1;
5633
::google::protobuf::internal::WireFormatLite::WriteMessageNoVirtual(
5634
1, this->variable_metadata(), output);
5637
// required bytes variable_value = 2;
5639
::google::protobuf::internal::WireFormatLite::WriteBytes(
5640
2, this->variable_value(), output);
5643
if (!unknown_fields().empty()) {
5644
::google::protobuf::internal::WireFormat::SerializeUnknownFields(
5645
unknown_fields(), output);
5649
::google::protobuf::uint8* SetVariableStatement::SerializeWithCachedSizesToArray(
5650
::google::protobuf::uint8* target) const {
5651
// required .drizzled.message.FieldMetadata variable_metadata = 1;
5653
target = ::google::protobuf::internal::WireFormatLite::
5654
WriteMessageNoVirtualToArray(
5655
1, this->variable_metadata(), target);
5658
// required bytes variable_value = 2;
5661
::google::protobuf::internal::WireFormatLite::WriteBytesToArray(
5662
2, this->variable_value(), target);
5665
if (!unknown_fields().empty()) {
5666
target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
5667
unknown_fields(), target);
5672
int SetVariableStatement::ByteSize() const {
5675
if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
5676
// required .drizzled.message.FieldMetadata variable_metadata = 1;
5677
if (has_variable_metadata()) {
5679
::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
5680
this->variable_metadata());
5683
// required bytes variable_value = 2;
5684
if (has_variable_value()) {
5686
::google::protobuf::internal::WireFormatLite::BytesSize(
5687
this->variable_value());
5691
if (!unknown_fields().empty()) {
5693
::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
5696
_cached_size_ = total_size;
5700
void SetVariableStatement::MergeFrom(const ::google::protobuf::Message& from) {
5701
GOOGLE_CHECK_NE(&from, this);
5702
const SetVariableStatement* source =
5703
::google::protobuf::internal::dynamic_cast_if_available<const SetVariableStatement*>(
5705
if (source == NULL) {
5706
::google::protobuf::internal::ReflectionOps::Merge(from, this);
5712
void SetVariableStatement::MergeFrom(const SetVariableStatement& from) {
5713
GOOGLE_CHECK_NE(&from, this);
5714
if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
5715
if (from._has_bit(0)) {
5716
mutable_variable_metadata()->::drizzled::message::FieldMetadata::MergeFrom(from.variable_metadata());
5718
if (from._has_bit(1)) {
5719
set_variable_value(from.variable_value());
5722
mutable_unknown_fields()->MergeFrom(from.unknown_fields());
5725
void SetVariableStatement::CopyFrom(const ::google::protobuf::Message& from) {
5726
if (&from == this) return;
5731
void SetVariableStatement::CopyFrom(const SetVariableStatement& from) {
5732
if (&from == this) return;
5737
bool SetVariableStatement::IsInitialized() const {
5738
if ((_has_bits_[0] & 0x00000003) != 0x00000003) return false;
5740
if (has_variable_metadata()) {
5741
if (!this->variable_metadata().IsInitialized()) return false;
5746
void SetVariableStatement::Swap(SetVariableStatement* other) {
5747
if (other != this) {
5748
std::swap(variable_metadata_, other->variable_metadata_);
5749
std::swap(variable_value_, other->variable_value_);
5750
std::swap(_has_bits_[0], other->_has_bits_[0]);
5751
_unknown_fields_.Swap(&other->_unknown_fields_);
5752
std::swap(_cached_size_, other->_cached_size_);
5756
::google::protobuf::Metadata SetVariableStatement::GetMetadata() const {
5757
protobuf_AssignDescriptorsOnce();
5758
::google::protobuf::Metadata metadata;
5759
metadata.descriptor = SetVariableStatement_descriptor_;
5760
metadata.reflection = SetVariableStatement_reflection_;
5765
// ===================================================================
5767
const ::google::protobuf::EnumDescriptor* Statement_Type_descriptor() {
5768
protobuf_AssignDescriptorsOnce();
5769
return Statement_Type_descriptor_;
5771
bool Statement_Type_IsValid(int value) {
5793
const Statement_Type Statement::ROLLBACK;
5794
const Statement_Type Statement::INSERT;
5795
const Statement_Type Statement::DELETE;
5796
const Statement_Type Statement::UPDATE;
5797
const Statement_Type Statement::TRUNCATE_TABLE;
5798
const Statement_Type Statement::CREATE_SCHEMA;
5799
const Statement_Type Statement::ALTER_SCHEMA;
5800
const Statement_Type Statement::DROP_SCHEMA;
5801
const Statement_Type Statement::CREATE_TABLE;
5802
const Statement_Type Statement::ALTER_TABLE;
5803
const Statement_Type Statement::DROP_TABLE;
5804
const Statement_Type Statement::SET_VARIABLE;
5805
const Statement_Type Statement::RAW_SQL;
5806
const Statement_Type Statement::Type_MIN;
5807
const Statement_Type Statement::Type_MAX;
5809
const ::std::string Statement::_default_sql_;
5811
const int Statement::kTypeFieldNumber;
5812
const int Statement::kStartTimestampFieldNumber;
5813
const int Statement::kEndTimestampFieldNumber;
5814
const int Statement::kSqlFieldNumber;
5815
const int Statement::kInsertHeaderFieldNumber;
5816
const int Statement::kInsertDataFieldNumber;
5817
const int Statement::kUpdateHeaderFieldNumber;
5818
const int Statement::kUpdateDataFieldNumber;
5819
const int Statement::kDeleteHeaderFieldNumber;
5820
const int Statement::kDeleteDataFieldNumber;
5821
const int Statement::kTruncateTableStatementFieldNumber;
5822
const int Statement::kCreateSchemaStatementFieldNumber;
5823
const int Statement::kDropSchemaStatementFieldNumber;
5824
const int Statement::kAlterSchemaStatementFieldNumber;
5825
const int Statement::kCreateTableStatementFieldNumber;
5826
const int Statement::kAlterTableStatementFieldNumber;
5827
const int Statement::kDropTableStatementFieldNumber;
5828
const int Statement::kSetVariableStatementFieldNumber;
5831
Statement::Statement() {
5835
void Statement::InitAsDefaultInstance() {
5836
insert_header_ = const_cast< ::drizzled::message::InsertHeader*>(&::drizzled::message::InsertHeader::default_instance());
5837
insert_data_ = const_cast< ::drizzled::message::InsertData*>(&::drizzled::message::InsertData::default_instance());
5838
update_header_ = const_cast< ::drizzled::message::UpdateHeader*>(&::drizzled::message::UpdateHeader::default_instance());
5839
update_data_ = const_cast< ::drizzled::message::UpdateData*>(&::drizzled::message::UpdateData::default_instance());
5840
delete_header_ = const_cast< ::drizzled::message::DeleteHeader*>(&::drizzled::message::DeleteHeader::default_instance());
5841
delete_data_ = const_cast< ::drizzled::message::DeleteData*>(&::drizzled::message::DeleteData::default_instance());
5842
truncate_table_statement_ = const_cast< ::drizzled::message::TruncateTableStatement*>(&::drizzled::message::TruncateTableStatement::default_instance());
5843
create_schema_statement_ = const_cast< ::drizzled::message::CreateSchemaStatement*>(&::drizzled::message::CreateSchemaStatement::default_instance());
5844
drop_schema_statement_ = const_cast< ::drizzled::message::DropSchemaStatement*>(&::drizzled::message::DropSchemaStatement::default_instance());
5845
alter_schema_statement_ = const_cast< ::drizzled::message::AlterSchemaStatement*>(&::drizzled::message::AlterSchemaStatement::default_instance());
5846
create_table_statement_ = const_cast< ::drizzled::message::CreateTableStatement*>(&::drizzled::message::CreateTableStatement::default_instance());
5847
alter_table_statement_ = const_cast< ::drizzled::message::AlterTableStatement*>(&::drizzled::message::AlterTableStatement::default_instance());
5848
drop_table_statement_ = const_cast< ::drizzled::message::DropTableStatement*>(&::drizzled::message::DropTableStatement::default_instance());
5849
set_variable_statement_ = const_cast< ::drizzled::message::SetVariableStatement*>(&::drizzled::message::SetVariableStatement::default_instance());
5852
Statement::Statement(const Statement& from) {
5857
void Statement::SharedCtor() {
5860
start_timestamp_ = GOOGLE_ULONGLONG(0);
5861
end_timestamp_ = GOOGLE_ULONGLONG(0);
5862
sql_ = const_cast< ::std::string*>(&_default_sql_);
5863
insert_header_ = NULL;
5864
insert_data_ = NULL;
5865
update_header_ = NULL;
5866
update_data_ = NULL;
5867
delete_header_ = NULL;
5868
delete_data_ = NULL;
5869
truncate_table_statement_ = NULL;
5870
create_schema_statement_ = NULL;
5871
drop_schema_statement_ = NULL;
5872
alter_schema_statement_ = NULL;
5873
create_table_statement_ = NULL;
5874
alter_table_statement_ = NULL;
5875
drop_table_statement_ = NULL;
5876
set_variable_statement_ = NULL;
5877
::memset(_has_bits_, 0, sizeof(_has_bits_));
5880
Statement::~Statement() {
5884
void Statement::SharedDtor() {
5885
if (sql_ != &_default_sql_) {
5888
if (this != default_instance_) {
5889
delete insert_header_;
5890
delete insert_data_;
5891
delete update_header_;
5892
delete update_data_;
5893
delete delete_header_;
5894
delete delete_data_;
5895
delete truncate_table_statement_;
5896
delete create_schema_statement_;
5897
delete drop_schema_statement_;
5898
delete alter_schema_statement_;
5899
delete create_table_statement_;
5900
delete alter_table_statement_;
5901
delete drop_table_statement_;
5902
delete set_variable_statement_;
5906
const ::google::protobuf::Descriptor* Statement::descriptor() {
5907
protobuf_AssignDescriptorsOnce();
5908
return Statement_descriptor_;
5911
const Statement& Statement::default_instance() {
5912
if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto(); return *default_instance_;
5915
Statement* Statement::default_instance_ = NULL;
5917
Statement* Statement::New() const {
5918
return new Statement;
5921
void Statement::Clear() {
5922
if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
5924
start_timestamp_ = GOOGLE_ULONGLONG(0);
5925
end_timestamp_ = GOOGLE_ULONGLONG(0);
5927
if (sql_ != &_default_sql_) {
5932
if (insert_header_ != NULL) insert_header_->::drizzled::message::InsertHeader::Clear();
5935
if (insert_data_ != NULL) insert_data_->::drizzled::message::InsertData::Clear();
5938
if (update_header_ != NULL) update_header_->::drizzled::message::UpdateHeader::Clear();
5941
if (update_data_ != NULL) update_data_->::drizzled::message::UpdateData::Clear();
5944
if (_has_bits_[8 / 32] & (0xffu << (8 % 32))) {
5946
if (delete_header_ != NULL) delete_header_->::drizzled::message::DeleteHeader::Clear();
5949
if (delete_data_ != NULL) delete_data_->::drizzled::message::DeleteData::Clear();
5952
if (truncate_table_statement_ != NULL) truncate_table_statement_->::drizzled::message::TruncateTableStatement::Clear();
5955
if (create_schema_statement_ != NULL) create_schema_statement_->::drizzled::message::CreateSchemaStatement::Clear();
5958
if (drop_schema_statement_ != NULL) drop_schema_statement_->::drizzled::message::DropSchemaStatement::Clear();
5961
if (alter_schema_statement_ != NULL) alter_schema_statement_->::drizzled::message::AlterSchemaStatement::Clear();
5964
if (create_table_statement_ != NULL) create_table_statement_->::drizzled::message::CreateTableStatement::Clear();
5967
if (alter_table_statement_ != NULL) alter_table_statement_->::drizzled::message::AlterTableStatement::Clear();
5970
if (_has_bits_[16 / 32] & (0xffu << (16 % 32))) {
5972
if (drop_table_statement_ != NULL) drop_table_statement_->::drizzled::message::DropTableStatement::Clear();
5975
if (set_variable_statement_ != NULL) set_variable_statement_->::drizzled::message::SetVariableStatement::Clear();
5978
::memset(_has_bits_, 0, sizeof(_has_bits_));
5979
mutable_unknown_fields()->Clear();
5982
bool Statement::MergePartialFromCodedStream(
5983
::google::protobuf::io::CodedInputStream* input) {
5984
#define DO_(EXPRESSION) if (!(EXPRESSION)) return false
5985
::google::protobuf::uint32 tag;
5986
while ((tag = input->ReadTag()) != 0) {
5987
switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
5988
// required .drizzled.message.Statement.Type type = 1;
5990
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
5991
::google::protobuf::internal::WireFormatLite::WIRETYPE_VARINT) {
5992
goto handle_uninterpreted;
5995
DO_(::google::protobuf::internal::WireFormatLite::ReadEnum(input, &value));
5996
if (::drizzled::message::Statement_Type_IsValid(value)) {
5997
set_type(static_cast< ::drizzled::message::Statement_Type >(value));
5999
mutable_unknown_fields()->AddVarint(1, value);
6001
if (input->ExpectTag(16)) goto parse_start_timestamp;
6005
// required uint64 start_timestamp = 2;
6007
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
6008
::google::protobuf::internal::WireFormatLite::WIRETYPE_VARINT) {
6009
goto handle_uninterpreted;
6011
parse_start_timestamp:
6012
DO_(::google::protobuf::internal::WireFormatLite::ReadUInt64(
6013
input, &start_timestamp_));
6015
if (input->ExpectTag(24)) goto parse_end_timestamp;
6019
// required uint64 end_timestamp = 3;
6021
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
6022
::google::protobuf::internal::WireFormatLite::WIRETYPE_VARINT) {
6023
goto handle_uninterpreted;
6025
parse_end_timestamp:
6026
DO_(::google::protobuf::internal::WireFormatLite::ReadUInt64(
6027
input, &end_timestamp_));
6029
if (input->ExpectTag(34)) goto parse_sql;
6033
// optional string sql = 4;
6035
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
6036
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
6037
goto handle_uninterpreted;
6040
DO_(::google::protobuf::internal::WireFormatLite::ReadString(
6041
input, this->mutable_sql()));
6042
::google::protobuf::internal::WireFormat::VerifyUTF8String(
6043
this->sql().data(), this->sql().length(),
6044
::google::protobuf::internal::WireFormat::PARSE);
6045
if (input->ExpectTag(42)) goto parse_insert_header;
6049
// optional .drizzled.message.InsertHeader insert_header = 5;
6051
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
6052
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
6053
goto handle_uninterpreted;
6055
parse_insert_header:
6056
DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
6057
input, mutable_insert_header()));
6058
if (input->ExpectTag(50)) goto parse_insert_data;
6062
// optional .drizzled.message.InsertData insert_data = 6;
6064
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
6065
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
6066
goto handle_uninterpreted;
6069
DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
6070
input, mutable_insert_data()));
6071
if (input->ExpectTag(58)) goto parse_update_header;
6075
// optional .drizzled.message.UpdateHeader update_header = 7;
6077
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
6078
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
6079
goto handle_uninterpreted;
6081
parse_update_header:
6082
DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
6083
input, mutable_update_header()));
6084
if (input->ExpectTag(66)) goto parse_update_data;
6088
// optional .drizzled.message.UpdateData update_data = 8;
6090
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
6091
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
6092
goto handle_uninterpreted;
6095
DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
6096
input, mutable_update_data()));
6097
if (input->ExpectTag(74)) goto parse_delete_header;
6101
// optional .drizzled.message.DeleteHeader delete_header = 9;
6103
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
6104
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
6105
goto handle_uninterpreted;
6107
parse_delete_header:
6108
DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
6109
input, mutable_delete_header()));
6110
if (input->ExpectTag(82)) goto parse_delete_data;
6114
// optional .drizzled.message.DeleteData delete_data = 10;
6116
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
6117
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
6118
goto handle_uninterpreted;
6121
DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
6122
input, mutable_delete_data()));
6123
if (input->ExpectTag(90)) goto parse_truncate_table_statement;
6127
// optional .drizzled.message.TruncateTableStatement truncate_table_statement = 11;
6129
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
6130
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
6131
goto handle_uninterpreted;
6133
parse_truncate_table_statement:
6134
DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
6135
input, mutable_truncate_table_statement()));
6136
if (input->ExpectTag(98)) goto parse_create_schema_statement;
6140
// optional .drizzled.message.CreateSchemaStatement create_schema_statement = 12;
6142
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
6143
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
6144
goto handle_uninterpreted;
6146
parse_create_schema_statement:
6147
DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
6148
input, mutable_create_schema_statement()));
6149
if (input->ExpectTag(106)) goto parse_drop_schema_statement;
6153
// optional .drizzled.message.DropSchemaStatement drop_schema_statement = 13;
6155
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
6156
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
6157
goto handle_uninterpreted;
6159
parse_drop_schema_statement:
6160
DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
6161
input, mutable_drop_schema_statement()));
6162
if (input->ExpectTag(114)) goto parse_alter_schema_statement;
6166
// optional .drizzled.message.AlterSchemaStatement alter_schema_statement = 14;
6168
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
6169
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
6170
goto handle_uninterpreted;
6172
parse_alter_schema_statement:
6173
DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
6174
input, mutable_alter_schema_statement()));
6175
if (input->ExpectTag(122)) goto parse_create_table_statement;
6179
// optional .drizzled.message.CreateTableStatement create_table_statement = 15;
6181
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
6182
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
6183
goto handle_uninterpreted;
6185
parse_create_table_statement:
6186
DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
6187
input, mutable_create_table_statement()));
6188
if (input->ExpectTag(130)) goto parse_alter_table_statement;
6192
// optional .drizzled.message.AlterTableStatement alter_table_statement = 16;
6194
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
6195
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
6196
goto handle_uninterpreted;
6198
parse_alter_table_statement:
6199
DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
6200
input, mutable_alter_table_statement()));
6201
if (input->ExpectTag(138)) goto parse_drop_table_statement;
6205
// optional .drizzled.message.DropTableStatement drop_table_statement = 17;
6207
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
6208
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
6209
goto handle_uninterpreted;
6211
parse_drop_table_statement:
6212
DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
6213
input, mutable_drop_table_statement()));
6214
if (input->ExpectTag(146)) goto parse_set_variable_statement;
6218
// optional .drizzled.message.SetVariableStatement set_variable_statement = 18;
6220
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
6221
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
6222
goto handle_uninterpreted;
6224
parse_set_variable_statement:
6225
DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
6226
input, mutable_set_variable_statement()));
6227
if (input->ExpectAtEnd()) return true;
6232
handle_uninterpreted:
6233
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
6234
::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
6237
DO_(::google::protobuf::internal::WireFormat::SkipField(
6238
input, tag, mutable_unknown_fields()));
6247
void Statement::SerializeWithCachedSizes(
6248
::google::protobuf::io::CodedOutputStream* output) const {
6249
::google::protobuf::uint8* raw_buffer = output->GetDirectBufferForNBytesAndAdvance(_cached_size_);
6250
if (raw_buffer != NULL) {
6251
Statement::SerializeWithCachedSizesToArray(raw_buffer);
6255
// required .drizzled.message.Statement.Type type = 1;
6257
::google::protobuf::internal::WireFormatLite::WriteEnum(
6258
1, this->type(), output);
6261
// required uint64 start_timestamp = 2;
6263
::google::protobuf::internal::WireFormatLite::WriteUInt64(2, this->start_timestamp(), output);
6266
// required uint64 end_timestamp = 3;
6268
::google::protobuf::internal::WireFormatLite::WriteUInt64(3, this->end_timestamp(), output);
6271
// optional string sql = 4;
6273
::google::protobuf::internal::WireFormat::VerifyUTF8String(
6274
this->sql().data(), this->sql().length(),
6275
::google::protobuf::internal::WireFormat::SERIALIZE);
6276
::google::protobuf::internal::WireFormatLite::WriteString(
6277
4, this->sql(), output);
6280
// optional .drizzled.message.InsertHeader insert_header = 5;
6282
::google::protobuf::internal::WireFormatLite::WriteMessageNoVirtual(
6283
5, this->insert_header(), output);
6286
// optional .drizzled.message.InsertData insert_data = 6;
6288
::google::protobuf::internal::WireFormatLite::WriteMessageNoVirtual(
6289
6, this->insert_data(), output);
6292
// optional .drizzled.message.UpdateHeader update_header = 7;
6294
::google::protobuf::internal::WireFormatLite::WriteMessageNoVirtual(
6295
7, this->update_header(), output);
6298
// optional .drizzled.message.UpdateData update_data = 8;
6300
::google::protobuf::internal::WireFormatLite::WriteMessageNoVirtual(
6301
8, this->update_data(), output);
6304
// optional .drizzled.message.DeleteHeader delete_header = 9;
6306
::google::protobuf::internal::WireFormatLite::WriteMessageNoVirtual(
6307
9, this->delete_header(), output);
6310
// optional .drizzled.message.DeleteData delete_data = 10;
6312
::google::protobuf::internal::WireFormatLite::WriteMessageNoVirtual(
6313
10, this->delete_data(), output);
6316
// optional .drizzled.message.TruncateTableStatement truncate_table_statement = 11;
6318
::google::protobuf::internal::WireFormatLite::WriteMessageNoVirtual(
6319
11, this->truncate_table_statement(), output);
6322
// optional .drizzled.message.CreateSchemaStatement create_schema_statement = 12;
6324
::google::protobuf::internal::WireFormatLite::WriteMessageNoVirtual(
6325
12, this->create_schema_statement(), output);
6328
// optional .drizzled.message.DropSchemaStatement drop_schema_statement = 13;
6330
::google::protobuf::internal::WireFormatLite::WriteMessageNoVirtual(
6331
13, this->drop_schema_statement(), output);
6334
// optional .drizzled.message.AlterSchemaStatement alter_schema_statement = 14;
6336
::google::protobuf::internal::WireFormatLite::WriteMessageNoVirtual(
6337
14, this->alter_schema_statement(), output);
6340
// optional .drizzled.message.CreateTableStatement create_table_statement = 15;
6342
::google::protobuf::internal::WireFormatLite::WriteMessageNoVirtual(
6343
15, this->create_table_statement(), output);
6346
// optional .drizzled.message.AlterTableStatement alter_table_statement = 16;
6348
::google::protobuf::internal::WireFormatLite::WriteMessageNoVirtual(
6349
16, this->alter_table_statement(), output);
6352
// optional .drizzled.message.DropTableStatement drop_table_statement = 17;
6354
::google::protobuf::internal::WireFormatLite::WriteMessageNoVirtual(
6355
17, this->drop_table_statement(), output);
6358
// optional .drizzled.message.SetVariableStatement set_variable_statement = 18;
6360
::google::protobuf::internal::WireFormatLite::WriteMessageNoVirtual(
6361
18, this->set_variable_statement(), output);
6364
if (!unknown_fields().empty()) {
6365
::google::protobuf::internal::WireFormat::SerializeUnknownFields(
6366
unknown_fields(), output);
6370
::google::protobuf::uint8* Statement::SerializeWithCachedSizesToArray(
6371
::google::protobuf::uint8* target) const {
6372
// required .drizzled.message.Statement.Type type = 1;
6374
target = ::google::protobuf::internal::WireFormatLite::WriteEnumToArray(
6375
1, this->type(), target);
6378
// required uint64 start_timestamp = 2;
6380
target = ::google::protobuf::internal::WireFormatLite::WriteUInt64ToArray(2, this->start_timestamp(), target);
6383
// required uint64 end_timestamp = 3;
6385
target = ::google::protobuf::internal::WireFormatLite::WriteUInt64ToArray(3, this->end_timestamp(), target);
6388
// optional string sql = 4;
6390
::google::protobuf::internal::WireFormat::VerifyUTF8String(
6391
this->sql().data(), this->sql().length(),
6392
::google::protobuf::internal::WireFormat::SERIALIZE);
6394
::google::protobuf::internal::WireFormatLite::WriteStringToArray(
6395
4, this->sql(), target);
6398
// optional .drizzled.message.InsertHeader insert_header = 5;
6400
target = ::google::protobuf::internal::WireFormatLite::
6401
WriteMessageNoVirtualToArray(
6402
5, this->insert_header(), target);
6405
// optional .drizzled.message.InsertData insert_data = 6;
6407
target = ::google::protobuf::internal::WireFormatLite::
6408
WriteMessageNoVirtualToArray(
6409
6, this->insert_data(), target);
6412
// optional .drizzled.message.UpdateHeader update_header = 7;
6414
target = ::google::protobuf::internal::WireFormatLite::
6415
WriteMessageNoVirtualToArray(
6416
7, this->update_header(), target);
6419
// optional .drizzled.message.UpdateData update_data = 8;
6421
target = ::google::protobuf::internal::WireFormatLite::
6422
WriteMessageNoVirtualToArray(
6423
8, this->update_data(), target);
6426
// optional .drizzled.message.DeleteHeader delete_header = 9;
6428
target = ::google::protobuf::internal::WireFormatLite::
6429
WriteMessageNoVirtualToArray(
6430
9, this->delete_header(), target);
6433
// optional .drizzled.message.DeleteData delete_data = 10;
6435
target = ::google::protobuf::internal::WireFormatLite::
6436
WriteMessageNoVirtualToArray(
6437
10, this->delete_data(), target);
6440
// optional .drizzled.message.TruncateTableStatement truncate_table_statement = 11;
6442
target = ::google::protobuf::internal::WireFormatLite::
6443
WriteMessageNoVirtualToArray(
6444
11, this->truncate_table_statement(), target);
6447
// optional .drizzled.message.CreateSchemaStatement create_schema_statement = 12;
6449
target = ::google::protobuf::internal::WireFormatLite::
6450
WriteMessageNoVirtualToArray(
6451
12, this->create_schema_statement(), target);
6454
// optional .drizzled.message.DropSchemaStatement drop_schema_statement = 13;
6456
target = ::google::protobuf::internal::WireFormatLite::
6457
WriteMessageNoVirtualToArray(
6458
13, this->drop_schema_statement(), target);
6461
// optional .drizzled.message.AlterSchemaStatement alter_schema_statement = 14;
6463
target = ::google::protobuf::internal::WireFormatLite::
6464
WriteMessageNoVirtualToArray(
6465
14, this->alter_schema_statement(), target);
6468
// optional .drizzled.message.CreateTableStatement create_table_statement = 15;
6470
target = ::google::protobuf::internal::WireFormatLite::
6471
WriteMessageNoVirtualToArray(
6472
15, this->create_table_statement(), target);
6475
// optional .drizzled.message.AlterTableStatement alter_table_statement = 16;
6477
target = ::google::protobuf::internal::WireFormatLite::
6478
WriteMessageNoVirtualToArray(
6479
16, this->alter_table_statement(), target);
6482
// optional .drizzled.message.DropTableStatement drop_table_statement = 17;
6484
target = ::google::protobuf::internal::WireFormatLite::
6485
WriteMessageNoVirtualToArray(
6486
17, this->drop_table_statement(), target);
6489
// optional .drizzled.message.SetVariableStatement set_variable_statement = 18;
6491
target = ::google::protobuf::internal::WireFormatLite::
6492
WriteMessageNoVirtualToArray(
6493
18, this->set_variable_statement(), target);
6496
if (!unknown_fields().empty()) {
6497
target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
6498
unknown_fields(), target);
6503
int Statement::ByteSize() const {
6506
if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
6507
// required .drizzled.message.Statement.Type type = 1;
6510
::google::protobuf::internal::WireFormatLite::EnumSize(this->type());
6513
// required uint64 start_timestamp = 2;
6514
if (has_start_timestamp()) {
6516
::google::protobuf::internal::WireFormatLite::UInt64Size(
6517
this->start_timestamp());
6520
// required uint64 end_timestamp = 3;
6521
if (has_end_timestamp()) {
6523
::google::protobuf::internal::WireFormatLite::UInt64Size(
6524
this->end_timestamp());
6527
// optional string sql = 4;
6530
::google::protobuf::internal::WireFormatLite::StringSize(
6534
// optional .drizzled.message.InsertHeader insert_header = 5;
6535
if (has_insert_header()) {
6537
::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
6538
this->insert_header());
6541
// optional .drizzled.message.InsertData insert_data = 6;
6542
if (has_insert_data()) {
6544
::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
6545
this->insert_data());
6548
// optional .drizzled.message.UpdateHeader update_header = 7;
6549
if (has_update_header()) {
6551
::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
6552
this->update_header());
6555
// optional .drizzled.message.UpdateData update_data = 8;
6556
if (has_update_data()) {
6558
::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
6559
this->update_data());
6563
if (_has_bits_[8 / 32] & (0xffu << (8 % 32))) {
6564
// optional .drizzled.message.DeleteHeader delete_header = 9;
6565
if (has_delete_header()) {
6567
::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
6568
this->delete_header());
6571
// optional .drizzled.message.DeleteData delete_data = 10;
6572
if (has_delete_data()) {
6574
::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
6575
this->delete_data());
6578
// optional .drizzled.message.TruncateTableStatement truncate_table_statement = 11;
6579
if (has_truncate_table_statement()) {
6581
::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
6582
this->truncate_table_statement());
6585
// optional .drizzled.message.CreateSchemaStatement create_schema_statement = 12;
6586
if (has_create_schema_statement()) {
6588
::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
6589
this->create_schema_statement());
6592
// optional .drizzled.message.DropSchemaStatement drop_schema_statement = 13;
6593
if (has_drop_schema_statement()) {
6595
::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
6596
this->drop_schema_statement());
6599
// optional .drizzled.message.AlterSchemaStatement alter_schema_statement = 14;
6600
if (has_alter_schema_statement()) {
6602
::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
6603
this->alter_schema_statement());
6606
// optional .drizzled.message.CreateTableStatement create_table_statement = 15;
6607
if (has_create_table_statement()) {
6609
::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
6610
this->create_table_statement());
6613
// optional .drizzled.message.AlterTableStatement alter_table_statement = 16;
6614
if (has_alter_table_statement()) {
6616
::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
6617
this->alter_table_statement());
6621
if (_has_bits_[16 / 32] & (0xffu << (16 % 32))) {
6622
// optional .drizzled.message.DropTableStatement drop_table_statement = 17;
6623
if (has_drop_table_statement()) {
6625
::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
6626
this->drop_table_statement());
6629
// optional .drizzled.message.SetVariableStatement set_variable_statement = 18;
6630
if (has_set_variable_statement()) {
6632
::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
6633
this->set_variable_statement());
6637
if (!unknown_fields().empty()) {
6639
::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
6642
_cached_size_ = total_size;
6646
void Statement::MergeFrom(const ::google::protobuf::Message& from) {
6647
GOOGLE_CHECK_NE(&from, this);
6648
const Statement* source =
6649
::google::protobuf::internal::dynamic_cast_if_available<const Statement*>(
6651
if (source == NULL) {
6652
::google::protobuf::internal::ReflectionOps::Merge(from, this);
6658
void Statement::MergeFrom(const Statement& from) {
6659
GOOGLE_CHECK_NE(&from, this);
6660
if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
6661
if (from._has_bit(0)) {
6662
set_type(from.type());
6664
if (from._has_bit(1)) {
6665
set_start_timestamp(from.start_timestamp());
6667
if (from._has_bit(2)) {
6668
set_end_timestamp(from.end_timestamp());
6670
if (from._has_bit(3)) {
6671
set_sql(from.sql());
6673
if (from._has_bit(4)) {
6674
mutable_insert_header()->::drizzled::message::InsertHeader::MergeFrom(from.insert_header());
6676
if (from._has_bit(5)) {
6677
mutable_insert_data()->::drizzled::message::InsertData::MergeFrom(from.insert_data());
6679
if (from._has_bit(6)) {
6680
mutable_update_header()->::drizzled::message::UpdateHeader::MergeFrom(from.update_header());
6682
if (from._has_bit(7)) {
6683
mutable_update_data()->::drizzled::message::UpdateData::MergeFrom(from.update_data());
6686
if (from._has_bits_[8 / 32] & (0xffu << (8 % 32))) {
6687
if (from._has_bit(8)) {
6688
mutable_delete_header()->::drizzled::message::DeleteHeader::MergeFrom(from.delete_header());
6690
if (from._has_bit(9)) {
6691
mutable_delete_data()->::drizzled::message::DeleteData::MergeFrom(from.delete_data());
6693
if (from._has_bit(10)) {
6694
mutable_truncate_table_statement()->::drizzled::message::TruncateTableStatement::MergeFrom(from.truncate_table_statement());
6696
if (from._has_bit(11)) {
6697
mutable_create_schema_statement()->::drizzled::message::CreateSchemaStatement::MergeFrom(from.create_schema_statement());
6699
if (from._has_bit(12)) {
6700
mutable_drop_schema_statement()->::drizzled::message::DropSchemaStatement::MergeFrom(from.drop_schema_statement());
6702
if (from._has_bit(13)) {
6703
mutable_alter_schema_statement()->::drizzled::message::AlterSchemaStatement::MergeFrom(from.alter_schema_statement());
6705
if (from._has_bit(14)) {
6706
mutable_create_table_statement()->::drizzled::message::CreateTableStatement::MergeFrom(from.create_table_statement());
6708
if (from._has_bit(15)) {
6709
mutable_alter_table_statement()->::drizzled::message::AlterTableStatement::MergeFrom(from.alter_table_statement());
6712
if (from._has_bits_[16 / 32] & (0xffu << (16 % 32))) {
6713
if (from._has_bit(16)) {
6714
mutable_drop_table_statement()->::drizzled::message::DropTableStatement::MergeFrom(from.drop_table_statement());
6716
if (from._has_bit(17)) {
6717
mutable_set_variable_statement()->::drizzled::message::SetVariableStatement::MergeFrom(from.set_variable_statement());
6720
mutable_unknown_fields()->MergeFrom(from.unknown_fields());
6723
void Statement::CopyFrom(const ::google::protobuf::Message& from) {
6724
if (&from == this) return;
6729
void Statement::CopyFrom(const Statement& from) {
6730
if (&from == this) return;
6735
bool Statement::IsInitialized() const {
6736
if ((_has_bits_[0] & 0x00000007) != 0x00000007) return false;
6738
if (has_insert_header()) {
6739
if (!this->insert_header().IsInitialized()) return false;
6741
if (has_insert_data()) {
6742
if (!this->insert_data().IsInitialized()) return false;
6744
if (has_update_header()) {
6745
if (!this->update_header().IsInitialized()) return false;
6747
if (has_update_data()) {
6748
if (!this->update_data().IsInitialized()) return false;
6750
if (has_delete_header()) {
6751
if (!this->delete_header().IsInitialized()) return false;
6753
if (has_delete_data()) {
6754
if (!this->delete_data().IsInitialized()) return false;
6756
if (has_truncate_table_statement()) {
6757
if (!this->truncate_table_statement().IsInitialized()) return false;
6759
if (has_create_schema_statement()) {
6760
if (!this->create_schema_statement().IsInitialized()) return false;
6762
if (has_drop_schema_statement()) {
6763
if (!this->drop_schema_statement().IsInitialized()) return false;
6765
if (has_alter_schema_statement()) {
6766
if (!this->alter_schema_statement().IsInitialized()) return false;
6768
if (has_create_table_statement()) {
6769
if (!this->create_table_statement().IsInitialized()) return false;
6771
if (has_alter_table_statement()) {
6772
if (!this->alter_table_statement().IsInitialized()) return false;
6774
if (has_drop_table_statement()) {
6775
if (!this->drop_table_statement().IsInitialized()) return false;
6777
if (has_set_variable_statement()) {
6778
if (!this->set_variable_statement().IsInitialized()) return false;
6783
void Statement::Swap(Statement* other) {
6784
if (other != this) {
6785
std::swap(type_, other->type_);
6786
std::swap(start_timestamp_, other->start_timestamp_);
6787
std::swap(end_timestamp_, other->end_timestamp_);
6788
std::swap(sql_, other->sql_);
6789
std::swap(insert_header_, other->insert_header_);
6790
std::swap(insert_data_, other->insert_data_);
6791
std::swap(update_header_, other->update_header_);
6792
std::swap(update_data_, other->update_data_);
6793
std::swap(delete_header_, other->delete_header_);
6794
std::swap(delete_data_, other->delete_data_);
6795
std::swap(truncate_table_statement_, other->truncate_table_statement_);
6796
std::swap(create_schema_statement_, other->create_schema_statement_);
6797
std::swap(drop_schema_statement_, other->drop_schema_statement_);
6798
std::swap(alter_schema_statement_, other->alter_schema_statement_);
6799
std::swap(create_table_statement_, other->create_table_statement_);
6800
std::swap(alter_table_statement_, other->alter_table_statement_);
6801
std::swap(drop_table_statement_, other->drop_table_statement_);
6802
std::swap(set_variable_statement_, other->set_variable_statement_);
6803
std::swap(_has_bits_[0], other->_has_bits_[0]);
6804
_unknown_fields_.Swap(&other->_unknown_fields_);
6805
std::swap(_cached_size_, other->_cached_size_);
6809
::google::protobuf::Metadata Statement::GetMetadata() const {
6810
protobuf_AssignDescriptorsOnce();
6811
::google::protobuf::Metadata metadata;
6812
metadata.descriptor = Statement_descriptor_;
6813
metadata.reflection = Statement_reflection_;
6818
// ===================================================================
6821
const int Transaction::kTransactionContextFieldNumber;
6822
const int Transaction::kStatementFieldNumber;
6825
Transaction::Transaction() {
6829
void Transaction::InitAsDefaultInstance() {
6830
transaction_context_ = const_cast< ::drizzled::message::TransactionContext*>(&::drizzled::message::TransactionContext::default_instance());
6833
Transaction::Transaction(const Transaction& from) {
6838
void Transaction::SharedCtor() {
6840
transaction_context_ = NULL;
6841
::memset(_has_bits_, 0, sizeof(_has_bits_));
6844
Transaction::~Transaction() {
6848
void Transaction::SharedDtor() {
6849
if (this != default_instance_) {
6850
delete transaction_context_;
6854
const ::google::protobuf::Descriptor* Transaction::descriptor() {
6855
protobuf_AssignDescriptorsOnce();
6856
return Transaction_descriptor_;
6859
const Transaction& Transaction::default_instance() {
6860
if (default_instance_ == NULL) protobuf_AddDesc_transaction_2eproto(); return *default_instance_;
6863
Transaction* Transaction::default_instance_ = NULL;
6865
Transaction* Transaction::New() const {
6866
return new Transaction;
6869
void Transaction::Clear() {
6870
if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
6872
if (transaction_context_ != NULL) transaction_context_->::drizzled::message::TransactionContext::Clear();
6876
::memset(_has_bits_, 0, sizeof(_has_bits_));
6877
mutable_unknown_fields()->Clear();
6880
bool Transaction::MergePartialFromCodedStream(
6881
::google::protobuf::io::CodedInputStream* input) {
6882
#define DO_(EXPRESSION) if (!(EXPRESSION)) return false
6883
::google::protobuf::uint32 tag;
6884
while ((tag = input->ReadTag()) != 0) {
6885
switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
6886
// required .drizzled.message.TransactionContext transaction_context = 1;
6888
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
6889
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
6890
goto handle_uninterpreted;
6892
DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
6893
input, mutable_transaction_context()));
6894
if (input->ExpectTag(18)) goto parse_statement;
6898
// repeated .drizzled.message.Statement statement = 2;
6900
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
6901
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
6902
goto handle_uninterpreted;
6905
DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
6906
input, add_statement()));
6907
if (input->ExpectTag(18)) goto parse_statement;
6908
if (input->ExpectAtEnd()) return true;
6913
handle_uninterpreted:
6914
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
6915
::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
6918
DO_(::google::protobuf::internal::WireFormat::SkipField(
6919
input, tag, mutable_unknown_fields()));
6928
void Transaction::SerializeWithCachedSizes(
6929
::google::protobuf::io::CodedOutputStream* output) const {
6930
::google::protobuf::uint8* raw_buffer = output->GetDirectBufferForNBytesAndAdvance(_cached_size_);
6931
if (raw_buffer != NULL) {
6932
Transaction::SerializeWithCachedSizesToArray(raw_buffer);
6936
// required .drizzled.message.TransactionContext transaction_context = 1;
6938
::google::protobuf::internal::WireFormatLite::WriteMessageNoVirtual(
6939
1, this->transaction_context(), output);
6942
// repeated .drizzled.message.Statement statement = 2;
6943
for (int i = 0; i < this->statement_size(); i++) {
6944
::google::protobuf::internal::WireFormatLite::WriteMessageNoVirtual(
6945
2, this->statement(i), output);
6948
if (!unknown_fields().empty()) {
6949
::google::protobuf::internal::WireFormat::SerializeUnknownFields(
6950
unknown_fields(), output);
6954
::google::protobuf::uint8* Transaction::SerializeWithCachedSizesToArray(
6955
::google::protobuf::uint8* target) const {
6956
// required .drizzled.message.TransactionContext transaction_context = 1;
6958
target = ::google::protobuf::internal::WireFormatLite::
6959
WriteMessageNoVirtualToArray(
6960
1, this->transaction_context(), target);
6963
// repeated .drizzled.message.Statement statement = 2;
6964
for (int i = 0; i < this->statement_size(); i++) {
6965
target = ::google::protobuf::internal::WireFormatLite::
6966
WriteMessageNoVirtualToArray(
6967
2, this->statement(i), target);
6970
if (!unknown_fields().empty()) {
6971
target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
6972
unknown_fields(), target);
6977
int Transaction::ByteSize() const {
6980
if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
6981
// required .drizzled.message.TransactionContext transaction_context = 1;
6982
if (has_transaction_context()) {
6984
::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
6985
this->transaction_context());
6989
// repeated .drizzled.message.Statement statement = 2;
6990
total_size += 1 * this->statement_size();
6991
for (int i = 0; i < this->statement_size(); i++) {
6993
::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
6994
this->statement(i));
6997
if (!unknown_fields().empty()) {
6999
::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
7002
_cached_size_ = total_size;
7006
void Transaction::MergeFrom(const ::google::protobuf::Message& from) {
7007
GOOGLE_CHECK_NE(&from, this);
7008
const Transaction* source =
7009
::google::protobuf::internal::dynamic_cast_if_available<const Transaction*>(
7011
if (source == NULL) {
7012
::google::protobuf::internal::ReflectionOps::Merge(from, this);
7018
void Transaction::MergeFrom(const Transaction& from) {
7019
GOOGLE_CHECK_NE(&from, this);
7020
statement_.MergeFrom(from.statement_);
7021
if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
7022
if (from._has_bit(0)) {
7023
mutable_transaction_context()->::drizzled::message::TransactionContext::MergeFrom(from.transaction_context());
7026
mutable_unknown_fields()->MergeFrom(from.unknown_fields());
7029
void Transaction::CopyFrom(const ::google::protobuf::Message& from) {
7030
if (&from == this) return;
7035
void Transaction::CopyFrom(const Transaction& from) {
7036
if (&from == this) return;
7041
bool Transaction::IsInitialized() const {
7042
if ((_has_bits_[0] & 0x00000001) != 0x00000001) return false;
7044
if (has_transaction_context()) {
7045
if (!this->transaction_context().IsInitialized()) return false;
7047
for (int i = 0; i < statement_size(); i++) {
7048
if (!this->statement(i).IsInitialized()) return false;
7053
void Transaction::Swap(Transaction* other) {
7054
if (other != this) {
7055
std::swap(transaction_context_, other->transaction_context_);
7056
statement_.Swap(&other->statement_);
7057
std::swap(_has_bits_[0], other->_has_bits_[0]);
7058
_unknown_fields_.Swap(&other->_unknown_fields_);
7059
std::swap(_cached_size_, other->_cached_size_);
7063
::google::protobuf::Metadata Transaction::GetMetadata() const {
7064
protobuf_AssignDescriptorsOnce();
7065
::google::protobuf::Metadata metadata;
7066
metadata.descriptor = Transaction_descriptor_;
7067
metadata.reflection = Transaction_reflection_;
7072
} // namespace message
7073
} // namespace drizzled