6 #ifndef __EXECUTE_SQL_H__
7 #define __EXECUTE_SQL_H__
9 #include "../GenericRecord.hpp"
33 data(std::vector<std::vector<uint8_t> >()),
34 options(std::map<std::string, std::string>())
220 ExecuteSqlRequest(
const std::string& statement_,
const int64_t offset_,
const int64_t limit_,
const std::string& requestSchemaStr_,
const std::vector<std::vector<uint8_t> >& data_,
const std::map<std::string, std::string>& options_):
421 ExecuteSqlRequest(
const std::string& statement_,
const int64_t offset_,
const int64_t limit_,
const std::string& encoding_,
const std::string& requestSchemaStr_,
const std::vector<std::vector<uint8_t> >& data_,
const std::map<std::string, std::string>& options_):
437 std::vector<std::vector<uint8_t> >
data;
444 template<>
struct codec_traits<gpudb::ExecuteSqlRequest>
449 ::avro::encode(e, v.
offset);
450 ::avro::encode(e, v.
limit);
453 ::avro::encode(e, v.
data);
459 if (::avro::ResolvingDecoder *rd = dynamic_cast< ::avro::ResolvingDecoder*>(&d))
461 const std::vector<size_t> fo = rd->fieldOrder();
463 for (std::vector<size_t>::const_iterator it = fo.begin(); it != fo.end(); ++it)
472 ::avro::decode(d, v.
offset);
476 ::avro::decode(d, v.
limit);
488 ::avro::decode(d, v.
data);
503 ::avro::decode(d, v.
offset);
504 ::avro::decode(d, v.
limit);
507 ::avro::decode(d, v.
data);
538 info(std::map<std::string, std::string>())
549 std::map<std::string, std::string>
info;
555 template<>
struct codec_traits<gpudb::RawExecuteSqlResponse>
566 ::avro::encode(e, v.
info);
571 if (::avro::ResolvingDecoder *rd = dynamic_cast< ::avro::ResolvingDecoder*>(&d))
573 const std::vector<size_t> fo = rd->fieldOrder();
575 for (std::vector<size_t>::const_iterator it = fo.begin(); it != fo.end(); ++it)
608 ::avro::decode(d, v.
info);
625 ::avro::decode(d, v.
info);
654 info(std::map<std::string, std::string>()),
661 std::vector<gpudb::GenericRecord>
data;
665 std::map<std::string, std::string>
info;
gpudb_type_ptr_t dataTypePtr
ExecuteSqlRequest()
Constructs an ExecuteSqlRequest object with default parameter values.
ExecuteSqlRequest(const std::string &statement_, const int64_t offset_, const int64_t limit_, const std::string &requestSchemaStr_, const std::vector< std::vector< uint8_t > > &data_, const std::map< std::string, std::string > &options_)
Constructs an ExecuteSqlRequest object with the specified parameters.
boost::shared_ptr< Type > gpudb_type_ptr_t
std::map< std::string, std::string > options
std::vector< gpudb::GenericRecord > data
std::string requestSchemaStr
int64_t totalNumberOfRecords
ExecuteSqlResponse()
Constructs an ExecuteSqlResponse object with default parameter values.
std::string jsonEncodedResponse
std::vector< std::vector< uint8_t > > data
A set of output parameters for const.
int64_t totalNumberOfRecords
A set of output parameters for const.
std::string responseSchemaStr
A set of input parameters for const.
std::map< std::string, std::string > info
ExecuteSqlRequest(const std::string &statement_, const int64_t offset_, const int64_t limit_, const std::string &encoding_, const std::string &requestSchemaStr_, const std::vector< std::vector< uint8_t > > &data_, const std::map< std::string, std::string > &options_)
Constructs an ExecuteSqlRequest object with the specified parameters.
std::map< std::string, std::string > info
RawExecuteSqlResponse()
Constructs a RawExecuteSqlResponse object with default parameter values.
std::string responseSchemaStr
std::vector< uint8_t > binaryEncodedResponse