*retrieved_attrs=lappend_int(*retrieved_attrs,

SelfItemPointerAttributeNumber);

}

if (bms_is_member(ObjectIdAttributeNumber-FirstLowInvalidHeapAttributeNumber,

attrs_used))

{

*retrieved_attrs=lappend_int(*retrieved_attrs,

ObjectIdAttributeNumber);

}

if (first&& !is_returning)

appendStringInfoString(buf,"NULL");

ADD_REL_QUALIFIER(buf,varno);

appendStringInfoString(buf,"ctid");

}

elseif (varattno==ObjectIdAttributeNumber)

{

if (qualify_col)

ADD_REL_QUALIFIER(buf,varno);

appendStringInfoString(buf,"oid");

}

elseif (varattno<0)

{

set vops.auto_substitute_projections=on;

explain (costs off) select avg((open+close)/2),max(high-low) from stock group by symbol;

QUERY PLAN

--------------------------

QUERY PLAN

--------------------------------

HashAggregate

Group Key: symbol

-> Seq Scan on vstock

-> Seq Scan on vstock stock

(3 rows)

select avg((open+close)/2),max(high-low) from stock group by symbol;

10.9200000762939 | 1

(1 row)

create table wiki_data(

cat_id bigint,

page_id bigint,

requests int,

size bigint,

dyear int,

dmonth int,

dday int,

dhour int

);

create table wiki_cat

( cat_id bigint primary key,

category varchar(20))

;

insert into wiki_data values

(101,1001,123,456),

(101,1002,789,123),

(101,1003,456,789),

(102,2001,123,456),

(102,2002,789,123),

(103,3001,456,789);

insert into wiki_cat values

(101, 'cat 101'),

(102, 'cat 102'),

(103, 'cat 103');

select create_projection('wiki_data_prj', 'wiki_data', array['page_id','requests','size'],array['cat_id']);

create_projection

-------------------

(1 row)

select wiki_data_prj_refresh();

wiki_data_prj_refresh

-----------------------

6

(1 row)

SELECT

category,

sum( requests ),

sum( size )

FROM

wiki_data

INNER JOIN wiki_cat

ON wiki_data.cat_id = wiki_cat.cat_id

GROUP BY

category

ORDER BY 3 DESC limit 5;

category | sum | sum

----------+------+------

cat 101 | 1368 | 1368

cat 103 | 456 | 789

cat 102 | 912 | 579

(3 rows)

set vops.auto_substitute_projections=on;

SELECT

category,

sum( requests ),

sum( size )

FROM

wiki_data

INNER JOIN wiki_cat

ON wiki_data.cat_id = wiki_cat.cat_id

GROUP BY

category

ORDER BY 3 DESC limit 5;

category | sum | sum

----------+------+------

cat 101 | 1368 | 1368

cat 103 | 456 | 789

cat 102 | 912 | 579

(3 rows)

explain (costs off) SELECT

category,

sum( requests ),

sum( size )

FROM

wiki_data

INNER JOIN wiki_cat

ON wiki_data.cat_id = wiki_cat.cat_id

GROUP BY

category

ORDER BY 3 DESC limit 5;

QUERY PLAN

---------------------------------------------------------------------

Limit

-> Sort

Sort Key: (sum(wiki_data.size)) DESC

-> HashAggregate

Group Key: wiki_cat.category

-> Hash Join

Hash Cond: (wiki_cat.cat_id = wiki_data.cat_id)

-> Seq Scan on wiki_cat

-> Hash

-> Seq Scan on wiki_data_prj wiki_data

(10 rows)

selectavg((open+close)/2),max(high-low)from stockgroup by symbol;

setvops.auto_substitute_projections=off;

selectavg((open+close)/2),max(high-low)from stockgroup by symbol;

createtablewiki_data(

cat_idbigint,

page_idbigint,

requestsint,

sizebigint,

dyearint,

dmonthint,

ddayint,

dhourint

);

( cat_idbigintprimary key,

categoryvarchar(20))

;

insert into wiki_datavalues

(101,1001,123,456),

(101,1002,789,123),

(101,1003,456,789),

(102,2001,123,456),

(102,2002,789,123),

(103,3001,456,789);

insert into wiki_catvalues

(101,'cat 101'),

(102,'cat 102'),

(103,'cat 103');

select create_projection('wiki_data_prj','wiki_data', array['page_id','requests','size'],array['cat_id']);

select wiki_data_prj_refresh();

category,

sum( requests ),

sum( size )

wiki_data

INNER JOIN wiki_cat

ONwiki_data.cat_id=wiki_cat.cat_id

category

ORDER BY3DESClimit5;

setvops.auto_substitute_projections=on;

category,

sum( requests ),

sum( size )

wiki_data

INNER JOIN wiki_cat

ONwiki_data.cat_id=wiki_cat.cat_id

category

ORDER BY3DESClimit5;

explain (costs off)SELECT

category,

sum( requests ),

sum( size )

wiki_data

INNER JOIN wiki_cat

ONwiki_data.cat_id=wiki_cat.cat_id

category

ORDER BY3DESClimit5;

UserTableUpdateOpenIndexes()

{

List*recheckIndexes=NIL;

#ifPG_VERSION_NUM>=120000

HeapTupletuple=ExecFetchSlotHeapTuple(slot, true,NULL);

HeapTupletuple=slot->tts_tuple;

if (HeapTupleIsHeapOnly(slot->tts_tuple))

if (HeapTupleIsHeapOnly(tuple))

return;

if (estate->es_result_relation_info->ri_NumIndices>0)

{

recheckIndexes=ExecInsertIndexTuples(slot,

&slot->tts_tuple->t_self,

&tuple->t_self,

estate, false,NULL,NIL);

if (recheckIndexes!=NIL)

{

ResultRelInfo*resultRelInfo;

rel=heap_open(oid,NoLock);

rel=heap_open(oid,RowExclusiveLock);

PushActiveSnapshot(GetTransactionSnapshot());

estate->es_num_result_relations=1;

estate->es_result_relation_info=resultRelInfo;

ExecOpenIndices(estate->es_result_relation_info, false);

#ifPG_VERSION_NUM>=110000

#ifPG_VERSION_NUM>=120000

slot=ExecInitExtraTupleSlot(estate,RelationGetDescr(rel),&TTSOpsHeapTuple);

#elifPG_VERSION_NUM>=110000

slot=ExecInitExtraTupleSlot(estate,RelationGetDescr(rel));

slot=ExecInitExtraTupleSlot(estate);

staticvoidinsert_tuple(Datum*values,bool*nulls)

{

HeapTupletup=heap_form_tuple(RelationGetDescr(rel),values,nulls);

#ifPG_VERSION_NUM>=120000

ExecStoreHeapTuple(tup,slot, true);

simple_heap_insert(rel,ExecFetchSlotHeapTuple(slot, true,NULL));

ExecStoreTuple(tup,slot,InvalidBuffer, true);

simple_heap_insert(rel,slot->tts_tuple);

UserTableUpdateOpenIndexes();

}

user_ctx->nulls= (bool*)palloc(sizeof(bool)*n_attrs);

user_ctx->types= (vops_type*)palloc(sizeof(vops_type)*n_attrs);

user_ctx->tiles= (vops_tile_hdr**)palloc(sizeof(vops_tile_hdr*)*n_attrs);

#ifPG_VERSION_NUM>=120000

user_ctx->desc=CreateTemplateTupleDesc(n_attrs);

user_ctx->desc=CreateTemplateTupleDesc(n_attrs, false);

func_ctx->user_fctx=user_ctx;

user_ctx->n_attrs=n_attrs;

user_ctx->tile_pos=0;

ctx->scope=scope;

node= (Node*)from->fromlist;

}

elseif (IsA(node,Query))

{

returnquery_tree_walker((Query*)node,vops_pullvars_walker,ctx,0);

}

(void)expression_tree_walker(node,vops_pullvars_walker,ctx);

ctx->scope=scope;

return false;

returnnode;

}

vops_get_join_rangevar(Node*node,int*relno)

{

if (IsA(node,JoinExpr))

{

RangeVar*rv;

JoinExpr*join= (JoinExpr*)node;

rv=vops_get_join_rangevar(join->larg,relno);

if (rv!=NULL)

returnrv;

rv=vops_get_join_rangevar(join->rarg,relno);

if (rv!=NULL)

returnrv;

}

{

Assert(IsA(node,RangeVar));

if (--*relno==0)

return (RangeVar*)node;

}

returnNULL;

}

vops_get_rangevar(List*from,intrelno)

{

ListCell*cell;

foreach (cell,from)

{

Node*node= (Node*)lfirst(cell);

RangeVar*rv=vops_get_join_rangevar(node,&relno);

if (rv!=NULL)

returnrv;

}

Assert(false);

}

pullvar_ctx.consts= (Const**)palloc0((strlen(queryString)+1)*sizeof(Const*));

pullvar_ctx.scope=SCOPE_DEFAULT;

pullvar_ctx.refs=palloc0(n_rels*sizeof(vops_table_refs));

query_tree_walker(query,vops_pullvars_walker,&pullvar_ctx,0);

query_tree_walker(query,vops_pullvars_walker,&pullvar_ctx,QTW_IGNORE_CTE_SUBQUERIES|QTW_IGNORE_RANGE_TABLE);

SPI_connect();

}

elog(DEBUG1,"Use projection %s instead of table %d",projectionName,rte->relid);

rv=list_nth_node(RangeVar,select->fromClause,fromno-1);

rv=vops_get_rangevar(select->fromClause,fromno);

Assert(rv!=NULL);

if (rv->alias==NULL)

rv->alias=makeAlias(rv->relname,NULL);

rv->relname=pstrdup(projectionName);

params==NULL)/* do not support prepared statements yet */

{

char*explain=pstrdup(queryString);

char*select=strstr(explain,"select");

size_tprefix= (select!=NULL) ? (select-explain) :7;

char*select;

size_tprefix;

select=strstr(explain,"select");

if (select==NULL) {

select=strstr(explain,"SELECT");

}

prefix= (select!=NULL) ? (select-explain) :7;

memset(explain,' ',prefix);/* clear "explain" prefix: we need to preseve node locations */

vops_substitute_tables_with_projections(explain,query);

}

MemoryContextSwitchTo(oldcontext);

tup=heap_form_tuple(fsstate->tupdesc,fsstate->dst_values,fsstate->dst_nulls);

ExecStoreTuple(tup,slot,InvalidBuffer, false);

#ifPG_VERSION_NUM>=120000

ExecStoreHeapTuple(tup,slot, false);

ExecStoreTuple(tup,slot,InvalidBuffer, false);

returnslot;

}

NextTuple:;