Commit 0822f1ea authored by yiwenshao's avatar yiwenshao

able to use ashe

parent 9ac5841e
...@@ -40,20 +40,6 @@ void parseResType(const ResType &rd) { ...@@ -40,20 +40,6 @@ void parseResType(const ResType &rd) {
} }
} }
/*
static void sp_next_second(const help_select & hs,ResType inRes){
ps->safeCreateEmbeddedTHD();
const ResType &resin = inRes;
try{
//AbstractQueryExecutor::ResultType::RESULTS
ps->getSchemaCache().updateStaleness(ps->getEConn(),false);
const auto &res = decryptResults(resin,hs.rmeta);
parseResType(res);
}catch(...){
std::cout<<"second next error"<<std::endl;
}
}*/
static void sp_next_first(const help_select &hs){ static void sp_next_first(const help_select &hs){
ps->safeCreateEmbeddedTHD(); ps->safeCreateEmbeddedTHD();
try{ try{
...@@ -112,6 +98,10 @@ static void my_gather_select(Analysis &a, LEX *const lex){ ...@@ -112,6 +98,10 @@ static void my_gather_select(Analysis &a, LEX *const lex){
//===========================================Rewrite============================================= //===========================================Rewrite=============================================
/*Rewrite an Item_field using the selected OLK.(get the anno field name)
The OLK comes from the chooseOne function
*/
static static
Item * Item *
my_do_rewrite_type(const Item_field &i, const OLK &constr, my_do_rewrite_type(const Item_field &i, const OLK &constr,
...@@ -237,8 +227,11 @@ help_select my_rewrite_select(Analysis &a, LEX *lex){ ...@@ -237,8 +227,11 @@ help_select my_rewrite_select(Analysis &a, LEX *lex){
//this is actually table list instead of join list. //this is actually table list instead of join list.
new_lex->select_lex.top_join_list = new_lex->select_lex.top_join_list =
rewrite_table_list(lex->select_lex.top_join_list, a); rewrite_table_list(lex->select_lex.top_join_list, a);
SELECT_LEX *const select_lex_res = my_rewrite_select_lex(new_lex->select_lex, a); SELECT_LEX *const select_lex_res = my_rewrite_select_lex(new_lex->select_lex, a);
set_select_lex(new_lex,select_lex_res); set_select_lex(new_lex,select_lex_res);
help_select hs; help_select hs;
hs.query = lexToQuery(*new_lex); hs.query = lexToQuery(*new_lex);
hs.rmeta = a.rmeta; hs.rmeta = a.rmeta;
......
...@@ -97,6 +97,7 @@ EncSet::chooseOne() const { ...@@ -97,6 +97,7 @@ EncSet::chooseOne() const {
oDET, oDET,
oOPE, oOPE,
oAGG, oAGG,
oASHE,
oSWP, oSWP,
oPLAIN, oPLAIN,
}; };
......
...@@ -16,6 +16,7 @@ public: ...@@ -16,6 +16,7 @@ public:
std::pair<ResultType, AbstractAnything *> std::pair<ResultType, AbstractAnything *>
nextImpl(const ResType &res, const NextParams &nparams); nextImpl(const ResType &res, const NextParams &nparams);
std::string getQuery(){return query;} std::string getQuery(){return query;}
const ReturnMeta & getReturnMeta(){return rmeta;}
private: private:
const std::string query; const std::string query;
const ReturnMeta rmeta; const ReturnMeta rmeta;
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment