Skip to content

Commit 5e90874

Browse files
committed
Fix error in vops_check_clusters
1 parent 312accd commit 5e90874

File tree

2 files changed

+26
-4
lines changed

2 files changed

+26
-4
lines changed

Diff for: projections.sql

+22
Original file line numberDiff line numberDiff line change
@@ -72,3 +72,25 @@ group by
7272
order by
7373
l_returnflag,
7474
l_linestatus;
75+
76+
select
77+
l_returnflag,
78+
l_linestatus,
79+
avg(l_quantity) as sum_qty,
80+
avg(l_extendedprice) as sum_base_price,
81+
avg(l_extendedprice*(1-l_discount)) as sum_disc_price,
82+
avg(l_extendedprice*(1-l_discount)*(1+l_tax)) as sum_charge,
83+
avg(l_quantity) as avg_qty,
84+
avg(l_extendedprice) as avg_price,
85+
avg(l_discount) as avg_disc,
86+
count(*) as count_order
87+
from
88+
lineitem
89+
where
90+
l_shipdate <= '1998-12-01'
91+
group by
92+
l_returnflag,
93+
l_linestatus
94+
order by
95+
l_returnflag,
96+
l_linestatus;

Diff for: vops.c

+4-4
Original file line numberDiff line numberDiff line change
@@ -3742,7 +3742,7 @@ vops_update_vars_clusters(vops_pullvar_context *ctx)
37423742
}
37433743

37443744
/*
3745-
* Check that all variables used together are both either scalar, eithe vector.
3745+
* Check that all variables used together are both either scalar, either vector.
37463746
*/
37473747
static bool
37483748
vops_check_clusters(vops_vars_cluster* clusters, Bitmapset* vectorCols, Bitmapset* scalarCols)
@@ -4146,11 +4146,11 @@ vops_substitute_tables_with_projections(char const* queryString, Query *query)
41464146
/* Update vector/scalar bitmap sets for this query for this projection */
41474147
for (j = 0; j < nVectorColumns; j++)
41484148
{
4149-
vectorCols = bms_add_member(vectorCols, DatumGetInt32(vectorAttnos[j])*n_rels + relno - 1);
4149+
vectorCols = bms_add_member(vectorCols, DatumGetInt32(vectorAttnos[j])*n_rels + relno);
41504150
}
41514151
for (j = 0; j < nScalarColumns; j++)
41524152
{
4153-
scalarCols = bms_add_member(scalarCols, DatumGetInt32(scalarAttnos[j])*n_rels + relno - 1);
4153+
scalarCols = bms_add_member(scalarCols, DatumGetInt32(scalarAttnos[j])*n_rels + relno);
41544154
}
41554155
if (keyName != NULL && select->whereClause)
41564156
{
@@ -4194,7 +4194,7 @@ vops_substitute_tables_with_projections(char const* queryString, Query *query)
41944194
/* Add all used attributes to set of scalar columns */
41954195
while ((bit = bms_next_member(all, bit)) >= 0)
41964196
{
4197-
scalarCols = bms_add_member(scalarCols, bit*n_rels + relno - 1);
4197+
scalarCols = bms_add_member(scalarCols, bit*n_rels + relno);
41984198
}
41994199
MemoryContextSwitchTo(spi_memctx);
42004200
}

0 commit comments

Comments
 (0)