1
// Generated by the protocol buffer compiler. DO NOT EDIT!
3
#define INTERNAL_SUPPRESS_PROTOBUF_FIELD_DEPRECATION
4
#include "resultset.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* SelectRecord_descriptor_ = NULL;
18
const ::google::protobuf::internal::GeneratedMessageReflection*
19
SelectRecord_reflection_ = NULL;
20
const ::google::protobuf::Descriptor* SelectHeader_descriptor_ = NULL;
21
const ::google::protobuf::internal::GeneratedMessageReflection*
22
SelectHeader_reflection_ = NULL;
23
const ::google::protobuf::Descriptor* SelectData_descriptor_ = NULL;
24
const ::google::protobuf::internal::GeneratedMessageReflection*
25
SelectData_reflection_ = NULL;
26
const ::google::protobuf::Descriptor* Resultset_descriptor_ = NULL;
27
const ::google::protobuf::internal::GeneratedMessageReflection*
28
Resultset_reflection_ = NULL;
33
void protobuf_AssignDesc_resultset_2eproto() {
34
protobuf_AddDesc_resultset_2eproto();
35
const ::google::protobuf::FileDescriptor* file =
36
::google::protobuf::DescriptorPool::generated_pool()->FindFileByName(
38
GOOGLE_CHECK(file != NULL);
39
SelectRecord_descriptor_ = file->message_type(0);
40
static const int SelectRecord_offsets_[1] = {
41
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(SelectRecord, record_value_),
43
SelectRecord_reflection_ =
44
new ::google::protobuf::internal::GeneratedMessageReflection(
45
SelectRecord_descriptor_,
46
SelectRecord::default_instance_,
47
SelectRecord_offsets_,
48
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(SelectRecord, _has_bits_[0]),
49
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(SelectRecord, _unknown_fields_),
51
::google::protobuf::DescriptorPool::generated_pool(),
52
::google::protobuf::MessageFactory::generated_factory(),
53
sizeof(SelectRecord));
54
SelectHeader_descriptor_ = file->message_type(1);
55
static const int SelectHeader_offsets_[2] = {
56
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(SelectHeader, table_metadata_),
57
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(SelectHeader, field_metadata_),
59
SelectHeader_reflection_ =
60
new ::google::protobuf::internal::GeneratedMessageReflection(
61
SelectHeader_descriptor_,
62
SelectHeader::default_instance_,
63
SelectHeader_offsets_,
64
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(SelectHeader, _has_bits_[0]),
65
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(SelectHeader, _unknown_fields_),
67
::google::protobuf::DescriptorPool::generated_pool(),
68
::google::protobuf::MessageFactory::generated_factory(),
69
sizeof(SelectHeader));
70
SelectData_descriptor_ = file->message_type(2);
71
static const int SelectData_offsets_[3] = {
72
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(SelectData, segment_id_),
73
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(SelectData, end_segment_),
74
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(SelectData, record_),
76
SelectData_reflection_ =
77
new ::google::protobuf::internal::GeneratedMessageReflection(
78
SelectData_descriptor_,
79
SelectData::default_instance_,
81
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(SelectData, _has_bits_[0]),
82
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(SelectData, _unknown_fields_),
84
::google::protobuf::DescriptorPool::generated_pool(),
85
::google::protobuf::MessageFactory::generated_factory(),
87
Resultset_descriptor_ = file->message_type(3);
88
static const int Resultset_offsets_[5] = {
89
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(Resultset, key_),
90
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(Resultset, schema_),
91
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(Resultset, sql_),
92
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(Resultset, select_header_),
93
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(Resultset, select_data_),
95
Resultset_reflection_ =
96
new ::google::protobuf::internal::GeneratedMessageReflection(
97
Resultset_descriptor_,
98
Resultset::default_instance_,
100
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(Resultset, _has_bits_[0]),
101
GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(Resultset, _unknown_fields_),
103
::google::protobuf::DescriptorPool::generated_pool(),
104
::google::protobuf::MessageFactory::generated_factory(),
110
GOOGLE_PROTOBUF_DECLARE_ONCE(protobuf_AssignDescriptors_once_);
111
inline void protobuf_AssignDescriptorsOnce() {
112
::google::protobuf::GoogleOnceInit(&protobuf_AssignDescriptors_once_,
113
&protobuf_AssignDesc_resultset_2eproto);
116
void protobuf_RegisterTypes(const ::std::string&) {
117
protobuf_AssignDescriptorsOnce();
118
::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
119
SelectRecord_descriptor_, &SelectRecord::default_instance());
120
::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
121
SelectHeader_descriptor_, &SelectHeader::default_instance());
122
::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
123
SelectData_descriptor_, &SelectData::default_instance());
124
::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
125
Resultset_descriptor_, &Resultset::default_instance());
130
void protobuf_ShutdownFile_resultset_2eproto() {
131
delete SelectRecord::default_instance_;
132
delete SelectRecord_reflection_;
133
delete SelectHeader::default_instance_;
134
delete SelectHeader_reflection_;
135
delete SelectData::default_instance_;
136
delete SelectData_reflection_;
137
delete Resultset::default_instance_;
138
delete Resultset_reflection_;
141
void protobuf_AddDesc_resultset_2eproto() {
142
static bool already_here = false;
143
if (already_here) return;
145
GOOGLE_PROTOBUF_VERIFY_VERSION;
147
::drizzled::message::protobuf_AddDesc_table_2eproto();
148
::drizzled::message::protobuf_AddDesc_schema_2eproto();
149
::drizzled::message::protobuf_AddDesc_transaction_2eproto();
150
::google::protobuf::DescriptorPool::InternalAddGeneratedFile(
151
"\n\017resultset.proto\022\020drizzled.message\032\013tab"
152
"le.proto\032\014schema.proto\032\021transaction.prot"
153
"o\"$\n\014SelectRecord\022\024\n\014record_value\030\001 \003(\014\""
154
"\200\001\n\014SelectHeader\0227\n\016table_metadata\030\001 \003(\013"
155
"2\037.drizzled.message.TableMetadata\0227\n\016fie"
156
"ld_metadata\030\002 \003(\0132\037.drizzled.message.Fie"
157
"ldMetadata\"e\n\nSelectData\022\022\n\nsegment_id\030\001"
158
" \002(\r\022\023\n\013end_segment\030\002 \002(\010\022.\n\006record\030\003 \003("
159
"\0132\036.drizzled.message.SelectRecord\"\237\001\n\tRe"
160
"sultset\022\013\n\003key\030\001 \002(\t\022\016\n\006schema\030\002 \002(\t\022\013\n\003"
161
"sql\030\003 \001(\t\0225\n\rselect_header\030\004 \001(\0132\036.drizz"
162
"led.message.SelectHeader\0221\n\013select_data\030"
163
"\005 \001(\0132\034.drizzled.message.SelectDataB\002H\001", 519);
164
::google::protobuf::MessageFactory::InternalRegisterGeneratedFile(
165
"resultset.proto", &protobuf_RegisterTypes);
166
SelectRecord::default_instance_ = new SelectRecord();
167
SelectHeader::default_instance_ = new SelectHeader();
168
SelectData::default_instance_ = new SelectData();
169
Resultset::default_instance_ = new Resultset();
170
SelectRecord::default_instance_->InitAsDefaultInstance();
171
SelectHeader::default_instance_->InitAsDefaultInstance();
172
SelectData::default_instance_->InitAsDefaultInstance();
173
Resultset::default_instance_->InitAsDefaultInstance();
174
::google::protobuf::internal::OnShutdown(&protobuf_ShutdownFile_resultset_2eproto);
177
// Force AddDescriptors() to be called at static initialization time.
178
struct StaticDescriptorInitializer_resultset_2eproto {
179
StaticDescriptorInitializer_resultset_2eproto() {
180
protobuf_AddDesc_resultset_2eproto();
182
} static_descriptor_initializer_resultset_2eproto_;
185
// ===================================================================
188
const int SelectRecord::kRecordValueFieldNumber;
191
SelectRecord::SelectRecord() {
195
void SelectRecord::InitAsDefaultInstance() {
198
SelectRecord::SelectRecord(const SelectRecord& from) {
203
void SelectRecord::SharedCtor() {
205
::memset(_has_bits_, 0, sizeof(_has_bits_));
208
SelectRecord::~SelectRecord() {
212
void SelectRecord::SharedDtor() {
213
if (this != default_instance_) {
217
const ::google::protobuf::Descriptor* SelectRecord::descriptor() {
218
protobuf_AssignDescriptorsOnce();
219
return SelectRecord_descriptor_;
222
const SelectRecord& SelectRecord::default_instance() {
223
if (default_instance_ == NULL) protobuf_AddDesc_resultset_2eproto(); return *default_instance_;
226
SelectRecord* SelectRecord::default_instance_ = NULL;
228
SelectRecord* SelectRecord::New() const {
229
return new SelectRecord;
232
void SelectRecord::Clear() {
233
record_value_.Clear();
234
::memset(_has_bits_, 0, sizeof(_has_bits_));
235
mutable_unknown_fields()->Clear();
238
bool SelectRecord::MergePartialFromCodedStream(
239
::google::protobuf::io::CodedInputStream* input) {
240
#define DO_(EXPRESSION) if (!(EXPRESSION)) return false
241
::google::protobuf::uint32 tag;
242
while ((tag = input->ReadTag()) != 0) {
243
switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
244
// repeated bytes record_value = 1;
246
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
247
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
248
goto handle_uninterpreted;
251
DO_(::google::protobuf::internal::WireFormatLite::ReadBytes(
252
input, this->add_record_value()));
253
if (input->ExpectTag(10)) goto parse_record_value;
254
if (input->ExpectAtEnd()) return true;
259
handle_uninterpreted:
260
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
261
::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
264
DO_(::google::protobuf::internal::WireFormat::SkipField(
265
input, tag, mutable_unknown_fields()));
274
void SelectRecord::SerializeWithCachedSizes(
275
::google::protobuf::io::CodedOutputStream* output) const {
276
::google::protobuf::uint8* raw_buffer = output->GetDirectBufferForNBytesAndAdvance(_cached_size_);
277
if (raw_buffer != NULL) {
278
SelectRecord::SerializeWithCachedSizesToArray(raw_buffer);
282
// repeated bytes record_value = 1;
283
for (int i = 0; i < this->record_value_size(); i++) {
284
::google::protobuf::internal::WireFormatLite::WriteBytes(
285
1, this->record_value(i), output);
288
if (!unknown_fields().empty()) {
289
::google::protobuf::internal::WireFormat::SerializeUnknownFields(
290
unknown_fields(), output);
294
::google::protobuf::uint8* SelectRecord::SerializeWithCachedSizesToArray(
295
::google::protobuf::uint8* target) const {
296
// repeated bytes record_value = 1;
297
for (int i = 0; i < this->record_value_size(); i++) {
298
target = ::google::protobuf::internal::WireFormatLite::
299
WriteBytesToArray(1, this->record_value(i), target);
302
if (!unknown_fields().empty()) {
303
target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
304
unknown_fields(), target);
309
int SelectRecord::ByteSize() const {
312
// repeated bytes record_value = 1;
313
total_size += 1 * this->record_value_size();
314
for (int i = 0; i < this->record_value_size(); i++) {
315
total_size += ::google::protobuf::internal::WireFormatLite::BytesSize(
316
this->record_value(i));
319
if (!unknown_fields().empty()) {
321
::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
324
_cached_size_ = total_size;
328
void SelectRecord::MergeFrom(const ::google::protobuf::Message& from) {
329
GOOGLE_CHECK_NE(&from, this);
330
const SelectRecord* source =
331
::google::protobuf::internal::dynamic_cast_if_available<const SelectRecord*>(
333
if (source == NULL) {
334
::google::protobuf::internal::ReflectionOps::Merge(from, this);
340
void SelectRecord::MergeFrom(const SelectRecord& from) {
341
GOOGLE_CHECK_NE(&from, this);
342
record_value_.MergeFrom(from.record_value_);
343
mutable_unknown_fields()->MergeFrom(from.unknown_fields());
346
void SelectRecord::CopyFrom(const ::google::protobuf::Message& from) {
347
if (&from == this) return;
352
void SelectRecord::CopyFrom(const SelectRecord& from) {
353
if (&from == this) return;
358
bool SelectRecord::IsInitialized() const {
363
void SelectRecord::Swap(SelectRecord* other) {
365
record_value_.Swap(&other->record_value_);
366
std::swap(_has_bits_[0], other->_has_bits_[0]);
367
_unknown_fields_.Swap(&other->_unknown_fields_);
368
std::swap(_cached_size_, other->_cached_size_);
372
::google::protobuf::Metadata SelectRecord::GetMetadata() const {
373
protobuf_AssignDescriptorsOnce();
374
::google::protobuf::Metadata metadata;
375
metadata.descriptor = SelectRecord_descriptor_;
376
metadata.reflection = SelectRecord_reflection_;
381
// ===================================================================
384
const int SelectHeader::kTableMetadataFieldNumber;
385
const int SelectHeader::kFieldMetadataFieldNumber;
388
SelectHeader::SelectHeader() {
392
void SelectHeader::InitAsDefaultInstance() {
395
SelectHeader::SelectHeader(const SelectHeader& from) {
400
void SelectHeader::SharedCtor() {
402
::memset(_has_bits_, 0, sizeof(_has_bits_));
405
SelectHeader::~SelectHeader() {
409
void SelectHeader::SharedDtor() {
410
if (this != default_instance_) {
414
const ::google::protobuf::Descriptor* SelectHeader::descriptor() {
415
protobuf_AssignDescriptorsOnce();
416
return SelectHeader_descriptor_;
419
const SelectHeader& SelectHeader::default_instance() {
420
if (default_instance_ == NULL) protobuf_AddDesc_resultset_2eproto(); return *default_instance_;
423
SelectHeader* SelectHeader::default_instance_ = NULL;
425
SelectHeader* SelectHeader::New() const {
426
return new SelectHeader;
429
void SelectHeader::Clear() {
430
table_metadata_.Clear();
431
field_metadata_.Clear();
432
::memset(_has_bits_, 0, sizeof(_has_bits_));
433
mutable_unknown_fields()->Clear();
436
bool SelectHeader::MergePartialFromCodedStream(
437
::google::protobuf::io::CodedInputStream* input) {
438
#define DO_(EXPRESSION) if (!(EXPRESSION)) return false
439
::google::protobuf::uint32 tag;
440
while ((tag = input->ReadTag()) != 0) {
441
switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
442
// repeated .drizzled.message.TableMetadata table_metadata = 1;
444
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
445
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
446
goto handle_uninterpreted;
448
parse_table_metadata:
449
DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
450
input, add_table_metadata()));
451
if (input->ExpectTag(10)) goto parse_table_metadata;
452
if (input->ExpectTag(18)) goto parse_field_metadata;
456
// repeated .drizzled.message.FieldMetadata field_metadata = 2;
458
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
459
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
460
goto handle_uninterpreted;
462
parse_field_metadata:
463
DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
464
input, add_field_metadata()));
465
if (input->ExpectTag(18)) goto parse_field_metadata;
466
if (input->ExpectAtEnd()) return true;
471
handle_uninterpreted:
472
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
473
::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
476
DO_(::google::protobuf::internal::WireFormat::SkipField(
477
input, tag, mutable_unknown_fields()));
486
void SelectHeader::SerializeWithCachedSizes(
487
::google::protobuf::io::CodedOutputStream* output) const {
488
::google::protobuf::uint8* raw_buffer = output->GetDirectBufferForNBytesAndAdvance(_cached_size_);
489
if (raw_buffer != NULL) {
490
SelectHeader::SerializeWithCachedSizesToArray(raw_buffer);
494
// repeated .drizzled.message.TableMetadata table_metadata = 1;
495
for (int i = 0; i < this->table_metadata_size(); i++) {
496
::google::protobuf::internal::WireFormatLite::WriteMessageNoVirtual(
497
1, this->table_metadata(i), output);
500
// repeated .drizzled.message.FieldMetadata field_metadata = 2;
501
for (int i = 0; i < this->field_metadata_size(); i++) {
502
::google::protobuf::internal::WireFormatLite::WriteMessageNoVirtual(
503
2, this->field_metadata(i), output);
506
if (!unknown_fields().empty()) {
507
::google::protobuf::internal::WireFormat::SerializeUnknownFields(
508
unknown_fields(), output);
512
::google::protobuf::uint8* SelectHeader::SerializeWithCachedSizesToArray(
513
::google::protobuf::uint8* target) const {
514
// repeated .drizzled.message.TableMetadata table_metadata = 1;
515
for (int i = 0; i < this->table_metadata_size(); i++) {
516
target = ::google::protobuf::internal::WireFormatLite::
517
WriteMessageNoVirtualToArray(
518
1, this->table_metadata(i), target);
521
// repeated .drizzled.message.FieldMetadata field_metadata = 2;
522
for (int i = 0; i < this->field_metadata_size(); i++) {
523
target = ::google::protobuf::internal::WireFormatLite::
524
WriteMessageNoVirtualToArray(
525
2, this->field_metadata(i), target);
528
if (!unknown_fields().empty()) {
529
target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
530
unknown_fields(), target);
535
int SelectHeader::ByteSize() const {
538
// repeated .drizzled.message.TableMetadata table_metadata = 1;
539
total_size += 1 * this->table_metadata_size();
540
for (int i = 0; i < this->table_metadata_size(); i++) {
542
::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
543
this->table_metadata(i));
546
// repeated .drizzled.message.FieldMetadata field_metadata = 2;
547
total_size += 1 * this->field_metadata_size();
548
for (int i = 0; i < this->field_metadata_size(); i++) {
550
::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
551
this->field_metadata(i));
554
if (!unknown_fields().empty()) {
556
::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
559
_cached_size_ = total_size;
563
void SelectHeader::MergeFrom(const ::google::protobuf::Message& from) {
564
GOOGLE_CHECK_NE(&from, this);
565
const SelectHeader* source =
566
::google::protobuf::internal::dynamic_cast_if_available<const SelectHeader*>(
568
if (source == NULL) {
569
::google::protobuf::internal::ReflectionOps::Merge(from, this);
575
void SelectHeader::MergeFrom(const SelectHeader& from) {
576
GOOGLE_CHECK_NE(&from, this);
577
table_metadata_.MergeFrom(from.table_metadata_);
578
field_metadata_.MergeFrom(from.field_metadata_);
579
mutable_unknown_fields()->MergeFrom(from.unknown_fields());
582
void SelectHeader::CopyFrom(const ::google::protobuf::Message& from) {
583
if (&from == this) return;
588
void SelectHeader::CopyFrom(const SelectHeader& from) {
589
if (&from == this) return;
594
bool SelectHeader::IsInitialized() const {
596
for (int i = 0; i < table_metadata_size(); i++) {
597
if (!this->table_metadata(i).IsInitialized()) return false;
599
for (int i = 0; i < field_metadata_size(); i++) {
600
if (!this->field_metadata(i).IsInitialized()) return false;
605
void SelectHeader::Swap(SelectHeader* other) {
607
table_metadata_.Swap(&other->table_metadata_);
608
field_metadata_.Swap(&other->field_metadata_);
609
std::swap(_has_bits_[0], other->_has_bits_[0]);
610
_unknown_fields_.Swap(&other->_unknown_fields_);
611
std::swap(_cached_size_, other->_cached_size_);
615
::google::protobuf::Metadata SelectHeader::GetMetadata() const {
616
protobuf_AssignDescriptorsOnce();
617
::google::protobuf::Metadata metadata;
618
metadata.descriptor = SelectHeader_descriptor_;
619
metadata.reflection = SelectHeader_reflection_;
624
// ===================================================================
627
const int SelectData::kSegmentIdFieldNumber;
628
const int SelectData::kEndSegmentFieldNumber;
629
const int SelectData::kRecordFieldNumber;
632
SelectData::SelectData() {
636
void SelectData::InitAsDefaultInstance() {
639
SelectData::SelectData(const SelectData& from) {
644
void SelectData::SharedCtor() {
647
end_segment_ = false;
648
::memset(_has_bits_, 0, sizeof(_has_bits_));
651
SelectData::~SelectData() {
655
void SelectData::SharedDtor() {
656
if (this != default_instance_) {
660
const ::google::protobuf::Descriptor* SelectData::descriptor() {
661
protobuf_AssignDescriptorsOnce();
662
return SelectData_descriptor_;
665
const SelectData& SelectData::default_instance() {
666
if (default_instance_ == NULL) protobuf_AddDesc_resultset_2eproto(); return *default_instance_;
669
SelectData* SelectData::default_instance_ = NULL;
671
SelectData* SelectData::New() const {
672
return new SelectData;
675
void SelectData::Clear() {
676
if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
678
end_segment_ = false;
681
::memset(_has_bits_, 0, sizeof(_has_bits_));
682
mutable_unknown_fields()->Clear();
685
bool SelectData::MergePartialFromCodedStream(
686
::google::protobuf::io::CodedInputStream* input) {
687
#define DO_(EXPRESSION) if (!(EXPRESSION)) return false
688
::google::protobuf::uint32 tag;
689
while ((tag = input->ReadTag()) != 0) {
690
switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
691
// required uint32 segment_id = 1;
693
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
694
::google::protobuf::internal::WireFormatLite::WIRETYPE_VARINT) {
695
goto handle_uninterpreted;
697
DO_(::google::protobuf::internal::WireFormatLite::ReadUInt32(
698
input, &segment_id_));
700
if (input->ExpectTag(16)) goto parse_end_segment;
704
// required bool end_segment = 2;
706
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
707
::google::protobuf::internal::WireFormatLite::WIRETYPE_VARINT) {
708
goto handle_uninterpreted;
711
DO_(::google::protobuf::internal::WireFormatLite::ReadBool(
712
input, &end_segment_));
714
if (input->ExpectTag(26)) goto parse_record;
718
// repeated .drizzled.message.SelectRecord record = 3;
720
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
721
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
722
goto handle_uninterpreted;
725
DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
726
input, add_record()));
727
if (input->ExpectTag(26)) goto parse_record;
728
if (input->ExpectAtEnd()) return true;
733
handle_uninterpreted:
734
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
735
::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
738
DO_(::google::protobuf::internal::WireFormat::SkipField(
739
input, tag, mutable_unknown_fields()));
748
void SelectData::SerializeWithCachedSizes(
749
::google::protobuf::io::CodedOutputStream* output) const {
750
::google::protobuf::uint8* raw_buffer = output->GetDirectBufferForNBytesAndAdvance(_cached_size_);
751
if (raw_buffer != NULL) {
752
SelectData::SerializeWithCachedSizesToArray(raw_buffer);
756
// required uint32 segment_id = 1;
758
::google::protobuf::internal::WireFormatLite::WriteUInt32(1, this->segment_id(), output);
761
// required bool end_segment = 2;
763
::google::protobuf::internal::WireFormatLite::WriteBool(2, this->end_segment(), output);
766
// repeated .drizzled.message.SelectRecord record = 3;
767
for (int i = 0; i < this->record_size(); i++) {
768
::google::protobuf::internal::WireFormatLite::WriteMessageNoVirtual(
769
3, this->record(i), output);
772
if (!unknown_fields().empty()) {
773
::google::protobuf::internal::WireFormat::SerializeUnknownFields(
774
unknown_fields(), output);
778
::google::protobuf::uint8* SelectData::SerializeWithCachedSizesToArray(
779
::google::protobuf::uint8* target) const {
780
// required uint32 segment_id = 1;
782
target = ::google::protobuf::internal::WireFormatLite::WriteUInt32ToArray(1, this->segment_id(), target);
785
// required bool end_segment = 2;
787
target = ::google::protobuf::internal::WireFormatLite::WriteBoolToArray(2, this->end_segment(), target);
790
// repeated .drizzled.message.SelectRecord record = 3;
791
for (int i = 0; i < this->record_size(); i++) {
792
target = ::google::protobuf::internal::WireFormatLite::
793
WriteMessageNoVirtualToArray(
794
3, this->record(i), target);
797
if (!unknown_fields().empty()) {
798
target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
799
unknown_fields(), target);
804
int SelectData::ByteSize() const {
807
if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
808
// required uint32 segment_id = 1;
809
if (has_segment_id()) {
811
::google::protobuf::internal::WireFormatLite::UInt32Size(
815
// required bool end_segment = 2;
816
if (has_end_segment()) {
821
// repeated .drizzled.message.SelectRecord record = 3;
822
total_size += 1 * this->record_size();
823
for (int i = 0; i < this->record_size(); i++) {
825
::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
829
if (!unknown_fields().empty()) {
831
::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
834
_cached_size_ = total_size;
838
void SelectData::MergeFrom(const ::google::protobuf::Message& from) {
839
GOOGLE_CHECK_NE(&from, this);
840
const SelectData* source =
841
::google::protobuf::internal::dynamic_cast_if_available<const SelectData*>(
843
if (source == NULL) {
844
::google::protobuf::internal::ReflectionOps::Merge(from, this);
850
void SelectData::MergeFrom(const SelectData& from) {
851
GOOGLE_CHECK_NE(&from, this);
852
record_.MergeFrom(from.record_);
853
if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
854
if (from._has_bit(0)) {
855
set_segment_id(from.segment_id());
857
if (from._has_bit(1)) {
858
set_end_segment(from.end_segment());
861
mutable_unknown_fields()->MergeFrom(from.unknown_fields());
864
void SelectData::CopyFrom(const ::google::protobuf::Message& from) {
865
if (&from == this) return;
870
void SelectData::CopyFrom(const SelectData& from) {
871
if (&from == this) return;
876
bool SelectData::IsInitialized() const {
877
if ((_has_bits_[0] & 0x00000003) != 0x00000003) return false;
882
void SelectData::Swap(SelectData* other) {
884
std::swap(segment_id_, other->segment_id_);
885
std::swap(end_segment_, other->end_segment_);
886
record_.Swap(&other->record_);
887
std::swap(_has_bits_[0], other->_has_bits_[0]);
888
_unknown_fields_.Swap(&other->_unknown_fields_);
889
std::swap(_cached_size_, other->_cached_size_);
893
::google::protobuf::Metadata SelectData::GetMetadata() const {
894
protobuf_AssignDescriptorsOnce();
895
::google::protobuf::Metadata metadata;
896
metadata.descriptor = SelectData_descriptor_;
897
metadata.reflection = SelectData_reflection_;
902
// ===================================================================
904
const ::std::string Resultset::_default_key_;
905
const ::std::string Resultset::_default_schema_;
906
const ::std::string Resultset::_default_sql_;
908
const int Resultset::kKeyFieldNumber;
909
const int Resultset::kSchemaFieldNumber;
910
const int Resultset::kSqlFieldNumber;
911
const int Resultset::kSelectHeaderFieldNumber;
912
const int Resultset::kSelectDataFieldNumber;
915
Resultset::Resultset() {
919
void Resultset::InitAsDefaultInstance() {
920
select_header_ = const_cast< ::drizzled::message::SelectHeader*>(&::drizzled::message::SelectHeader::default_instance());
921
select_data_ = const_cast< ::drizzled::message::SelectData*>(&::drizzled::message::SelectData::default_instance());
924
Resultset::Resultset(const Resultset& from) {
929
void Resultset::SharedCtor() {
931
key_ = const_cast< ::std::string*>(&_default_key_);
932
schema_ = const_cast< ::std::string*>(&_default_schema_);
933
sql_ = const_cast< ::std::string*>(&_default_sql_);
934
select_header_ = NULL;
936
::memset(_has_bits_, 0, sizeof(_has_bits_));
939
Resultset::~Resultset() {
943
void Resultset::SharedDtor() {
944
if (key_ != &_default_key_) {
947
if (schema_ != &_default_schema_) {
950
if (sql_ != &_default_sql_) {
953
if (this != default_instance_) {
954
delete select_header_;
959
const ::google::protobuf::Descriptor* Resultset::descriptor() {
960
protobuf_AssignDescriptorsOnce();
961
return Resultset_descriptor_;
964
const Resultset& Resultset::default_instance() {
965
if (default_instance_ == NULL) protobuf_AddDesc_resultset_2eproto(); return *default_instance_;
968
Resultset* Resultset::default_instance_ = NULL;
970
Resultset* Resultset::New() const {
971
return new Resultset;
974
void Resultset::Clear() {
975
if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
977
if (key_ != &_default_key_) {
982
if (schema_ != &_default_schema_) {
987
if (sql_ != &_default_sql_) {
992
if (select_header_ != NULL) select_header_->::drizzled::message::SelectHeader::Clear();
995
if (select_data_ != NULL) select_data_->::drizzled::message::SelectData::Clear();
998
::memset(_has_bits_, 0, sizeof(_has_bits_));
999
mutable_unknown_fields()->Clear();
1002
bool Resultset::MergePartialFromCodedStream(
1003
::google::protobuf::io::CodedInputStream* input) {
1004
#define DO_(EXPRESSION) if (!(EXPRESSION)) return false
1005
::google::protobuf::uint32 tag;
1006
while ((tag = input->ReadTag()) != 0) {
1007
switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
1008
// required string key = 1;
1010
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
1011
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
1012
goto handle_uninterpreted;
1014
DO_(::google::protobuf::internal::WireFormatLite::ReadString(
1015
input, this->mutable_key()));
1016
::google::protobuf::internal::WireFormat::VerifyUTF8String(
1017
this->key().data(), this->key().length(),
1018
::google::protobuf::internal::WireFormat::PARSE);
1019
if (input->ExpectTag(18)) goto parse_schema;
1023
// required string schema = 2;
1025
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
1026
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
1027
goto handle_uninterpreted;
1030
DO_(::google::protobuf::internal::WireFormatLite::ReadString(
1031
input, this->mutable_schema()));
1032
::google::protobuf::internal::WireFormat::VerifyUTF8String(
1033
this->schema().data(), this->schema().length(),
1034
::google::protobuf::internal::WireFormat::PARSE);
1035
if (input->ExpectTag(26)) goto parse_sql;
1039
// optional string sql = 3;
1041
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
1042
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
1043
goto handle_uninterpreted;
1046
DO_(::google::protobuf::internal::WireFormatLite::ReadString(
1047
input, this->mutable_sql()));
1048
::google::protobuf::internal::WireFormat::VerifyUTF8String(
1049
this->sql().data(), this->sql().length(),
1050
::google::protobuf::internal::WireFormat::PARSE);
1051
if (input->ExpectTag(34)) goto parse_select_header;
1055
// optional .drizzled.message.SelectHeader select_header = 4;
1057
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
1058
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
1059
goto handle_uninterpreted;
1061
parse_select_header:
1062
DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
1063
input, mutable_select_header()));
1064
if (input->ExpectTag(42)) goto parse_select_data;
1068
// optional .drizzled.message.SelectData select_data = 5;
1070
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) !=
1071
::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
1072
goto handle_uninterpreted;
1075
DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
1076
input, mutable_select_data()));
1077
if (input->ExpectAtEnd()) return true;
1082
handle_uninterpreted:
1083
if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
1084
::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
1087
DO_(::google::protobuf::internal::WireFormat::SkipField(
1088
input, tag, mutable_unknown_fields()));
1097
void Resultset::SerializeWithCachedSizes(
1098
::google::protobuf::io::CodedOutputStream* output) const {
1099
::google::protobuf::uint8* raw_buffer = output->GetDirectBufferForNBytesAndAdvance(_cached_size_);
1100
if (raw_buffer != NULL) {
1101
Resultset::SerializeWithCachedSizesToArray(raw_buffer);
1105
// required string key = 1;
1107
::google::protobuf::internal::WireFormat::VerifyUTF8String(
1108
this->key().data(), this->key().length(),
1109
::google::protobuf::internal::WireFormat::SERIALIZE);
1110
::google::protobuf::internal::WireFormatLite::WriteString(
1111
1, this->key(), output);
1114
// required string schema = 2;
1116
::google::protobuf::internal::WireFormat::VerifyUTF8String(
1117
this->schema().data(), this->schema().length(),
1118
::google::protobuf::internal::WireFormat::SERIALIZE);
1119
::google::protobuf::internal::WireFormatLite::WriteString(
1120
2, this->schema(), output);
1123
// optional string sql = 3;
1125
::google::protobuf::internal::WireFormat::VerifyUTF8String(
1126
this->sql().data(), this->sql().length(),
1127
::google::protobuf::internal::WireFormat::SERIALIZE);
1128
::google::protobuf::internal::WireFormatLite::WriteString(
1129
3, this->sql(), output);
1132
// optional .drizzled.message.SelectHeader select_header = 4;
1134
::google::protobuf::internal::WireFormatLite::WriteMessageNoVirtual(
1135
4, this->select_header(), output);
1138
// optional .drizzled.message.SelectData select_data = 5;
1140
::google::protobuf::internal::WireFormatLite::WriteMessageNoVirtual(
1141
5, this->select_data(), output);
1144
if (!unknown_fields().empty()) {
1145
::google::protobuf::internal::WireFormat::SerializeUnknownFields(
1146
unknown_fields(), output);
1150
::google::protobuf::uint8* Resultset::SerializeWithCachedSizesToArray(
1151
::google::protobuf::uint8* target) const {
1152
// required string key = 1;
1154
::google::protobuf::internal::WireFormat::VerifyUTF8String(
1155
this->key().data(), this->key().length(),
1156
::google::protobuf::internal::WireFormat::SERIALIZE);
1158
::google::protobuf::internal::WireFormatLite::WriteStringToArray(
1159
1, this->key(), target);
1162
// required string schema = 2;
1164
::google::protobuf::internal::WireFormat::VerifyUTF8String(
1165
this->schema().data(), this->schema().length(),
1166
::google::protobuf::internal::WireFormat::SERIALIZE);
1168
::google::protobuf::internal::WireFormatLite::WriteStringToArray(
1169
2, this->schema(), target);
1172
// optional string sql = 3;
1174
::google::protobuf::internal::WireFormat::VerifyUTF8String(
1175
this->sql().data(), this->sql().length(),
1176
::google::protobuf::internal::WireFormat::SERIALIZE);
1178
::google::protobuf::internal::WireFormatLite::WriteStringToArray(
1179
3, this->sql(), target);
1182
// optional .drizzled.message.SelectHeader select_header = 4;
1184
target = ::google::protobuf::internal::WireFormatLite::
1185
WriteMessageNoVirtualToArray(
1186
4, this->select_header(), target);
1189
// optional .drizzled.message.SelectData select_data = 5;
1191
target = ::google::protobuf::internal::WireFormatLite::
1192
WriteMessageNoVirtualToArray(
1193
5, this->select_data(), target);
1196
if (!unknown_fields().empty()) {
1197
target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
1198
unknown_fields(), target);
1203
int Resultset::ByteSize() const {
1206
if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
1207
// required string key = 1;
1210
::google::protobuf::internal::WireFormatLite::StringSize(
1214
// required string schema = 2;
1217
::google::protobuf::internal::WireFormatLite::StringSize(
1221
// optional string sql = 3;
1224
::google::protobuf::internal::WireFormatLite::StringSize(
1228
// optional .drizzled.message.SelectHeader select_header = 4;
1229
if (has_select_header()) {
1231
::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
1232
this->select_header());
1235
// optional .drizzled.message.SelectData select_data = 5;
1236
if (has_select_data()) {
1238
::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
1239
this->select_data());
1243
if (!unknown_fields().empty()) {
1245
::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
1248
_cached_size_ = total_size;
1252
void Resultset::MergeFrom(const ::google::protobuf::Message& from) {
1253
GOOGLE_CHECK_NE(&from, this);
1254
const Resultset* source =
1255
::google::protobuf::internal::dynamic_cast_if_available<const Resultset*>(
1257
if (source == NULL) {
1258
::google::protobuf::internal::ReflectionOps::Merge(from, this);
1264
void Resultset::MergeFrom(const Resultset& from) {
1265
GOOGLE_CHECK_NE(&from, this);
1266
if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
1267
if (from._has_bit(0)) {
1268
set_key(from.key());
1270
if (from._has_bit(1)) {
1271
set_schema(from.schema());
1273
if (from._has_bit(2)) {
1274
set_sql(from.sql());
1276
if (from._has_bit(3)) {
1277
mutable_select_header()->::drizzled::message::SelectHeader::MergeFrom(from.select_header());
1279
if (from._has_bit(4)) {
1280
mutable_select_data()->::drizzled::message::SelectData::MergeFrom(from.select_data());
1283
mutable_unknown_fields()->MergeFrom(from.unknown_fields());
1286
void Resultset::CopyFrom(const ::google::protobuf::Message& from) {
1287
if (&from == this) return;
1292
void Resultset::CopyFrom(const Resultset& from) {
1293
if (&from == this) return;
1298
bool Resultset::IsInitialized() const {
1299
if ((_has_bits_[0] & 0x00000003) != 0x00000003) return false;
1301
if (has_select_header()) {
1302
if (!this->select_header().IsInitialized()) return false;
1304
if (has_select_data()) {
1305
if (!this->select_data().IsInitialized()) return false;
1310
void Resultset::Swap(Resultset* other) {
1311
if (other != this) {
1312
std::swap(key_, other->key_);
1313
std::swap(schema_, other->schema_);
1314
std::swap(sql_, other->sql_);
1315
std::swap(select_header_, other->select_header_);
1316
std::swap(select_data_, other->select_data_);
1317
std::swap(_has_bits_[0], other->_has_bits_[0]);
1318
_unknown_fields_.Swap(&other->_unknown_fields_);
1319
std::swap(_cached_size_, other->_cached_size_);
1323
::google::protobuf::Metadata Resultset::GetMetadata() const {
1324
protobuf_AssignDescriptorsOnce();
1325
::google::protobuf::Metadata metadata;
1326
metadata.descriptor = Resultset_descriptor_;
1327
metadata.reflection = Resultset_reflection_;
1332
} // namespace message
1333
} // namespace drizzled