database/openGauss-server
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

!2500 修复table sample场景下，随机数取值没有考虑到多个sample执行的情况

Browse Source 
Merge pull request !2500 from pengjiong/fix_date
This commit is contained in:
opengauss-bot
2022-11-30 09:00:15 +00:00
committed by Gitee
parent 8685b8f7c6 8865e5fc82
commit 3dd27248f5
7 changed files with 458 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
src/common/port/erand48.cpp
View File

@ -69,17 +69,19 @@ double pg_erand48(unsigned short xseed[3])
return ldexp((double)xseed[0], -48) + ldexp((double)xseed[1], -32) + ldexp((double)xseed[2], -16);
}
long pg_lrand48(void)
long pg_lrand48(unsigned short rand48_seed[3])
{
_dorand48(_rand48_seed);
return ((long)_rand48_seed[2] << 15) + ((long)_rand48_seed[1] >> 1);
unsigned short *rand_seed = rand48_seed == NULL ? _rand48_seed : rand48_seed;
_dorand48(rand_seed);
return ((long)rand_seed[2] << 15) + ((long)rand_seed[1] >> 1);
}
void pg_srand48(long seed)
void pg_srand48(long seed, unsigned short rand48_seed[3])
{
_rand48_seed[0] = RAND48_SEED_0;
_rand48_seed[1] = (unsigned short)seed;
_rand48_seed[2] = (unsigned short)((unsigned long)seed >> 16);
unsigned short *rand_seed = rand48_seed == NULL ? _rand48_seed : rand48_seed;
rand_seed[0] = RAND48_SEED_0;
rand_seed[1] = (unsigned short)seed;
rand_seed[2] = (unsigned short)((unsigned long)seed >> 16);
_rand48_mult[0] = RAND48_MULT_0;
_rand48_mult[1] = RAND48_MULT_1;
_rand48_mult[2] = RAND48_MULT_2;
@ -97,3 +99,10 @@ unsigned short* pg_get_srand48()
{
return _rand48_seed;
}
void pg_srand48_default(unsigned short rand48_seed[3])
{
rand48_seed[0] = RAND48_SEED_0;
rand48_seed[1] = RAND48_SEED_1;
rand48_seed[2] = RAND48_SEED_2;
}

20
src/gausskernel/runtime/executor/nodeSamplescan.cpp
View File

@ -45,8 +45,6 @@
#include "nodes/execnodes.h"
#include "access/ustore/knl_uscan.h"
static double sample_random_fract(void);
/*
* Description: Initialize relation descriptor for sample table scan.
*
@ -220,7 +218,9 @@ void BaseTableSample::getSeed()
}
if (seed > 0) {
gs_srandom(seed);
pg_srand48(seed, rand48Seed);
} else {
pg_srand48_default(rand48Seed);
}
}
@ -273,7 +273,7 @@ void BaseTableSample::system_nextsampleblock()
/* We should start from currentBlock + 1. */
for (blockindex = currentBlock + 1; blockindex < totalBlockNum; blockindex++) {
if (sample_random_fract() < percent[SYSTEM_SAMPLE]) {
if ((((double)pg_lrand48(rand48Seed) + 1) / ((double)MAX_RANDOM_VALUE + 2)) < percent[SYSTEM_SAMPLE]) {
break;
}
}
@ -343,7 +343,7 @@ void BaseTableSample::bernoulli_nextsampletuple()
* block.
*/
for (; tupoffset <= curBlockMaxoffset; tupoffset++) {
if (sample_random_fract() < percent[BERNOULLI_SAMPLE]) {
if ((((double)pg_lrand48(rand48Seed) + 1) / ((double)MAX_RANDOM_VALUE + 2)) < percent[BERNOULLI_SAMPLE]) {
break;
}
}
@ -429,6 +429,11 @@ void BaseTableSample::resetSampleScan()
currentBlock = InvalidBlockNumber;
curBlockMaxoffset = InvalidOffsetNumber;
finished = false;
if (seed > 0) {
pg_srand48(seed, rand48Seed);
} else {
pg_srand48_default(rand48Seed);
}
}
/*
@ -1185,8 +1190,3 @@ void ColumnTableSample::scanVecSample(VectorBatch* pOutBatch)
}
}
}
static double sample_random_fract(void)
{
return ((double)gs_random() + 1) / ((double)MAX_RANDOM_VALUE + 2);
}

1
src/include/executor/node/nodeSamplescan.h
View File

@ -64,6 +64,7 @@ public:
/* how many tuples in current page. */
OffsetNumber curBlockMaxoffset;
bool finished;
unsigned short rand48Seed[3];
void (BaseTableSample::*nextSampleBlock_function)();
void (BaseTableSample::*nextSampleTuple_function)();

5
src/include/port.h
View File

@ -304,8 +304,9 @@ extern off_t ftello(FILE* stream);
#endif
extern double pg_erand48(unsigned short xseed[3]);
extern long pg_lrand48(void);
extern void pg_srand48(long seed);
extern long pg_lrand48(unsigned short rand48_seed[3] = NULL);
extern void pg_srand48(long seed, unsigned short rand48_seed[3] = NULL);
extern void pg_srand48_default(unsigned short rand48_seed[3]);
extern long free_list_lrand48(void);
extern void free_list_srand48(long seed);
extern void pg_reset_srand48(unsigned short xseed[3]);

328
src/test/regress/expected/tablesample_3.out Executable file
View File

@ -0,0 +1,328 @@
create schema tablesample_schema4;
set current_schema = tablesample_schema4;
create table test_tablesample(id int, name text, salary numeric);
create table test_tablesample2(id int, name text, salary numeric);
insert into test_tablesample select generate_series(1, 3000), 'row'|| generate_series(1,3000), generate_series(1, 3000);
insert into test_tablesample2 select * from test_tablesample;
analyze test_tablesample;
analyze test_tablesample2;
-- union same query, should return only 1 row
select count(*) from ((select * from test_tablesample tablesample BERNOULLI(5) REPEATABLE (200) limit 1) union (select * from test_tablesample tablesample BERNOULLI(5) REPEATABLE (200) limit 1));
count
-------
1
(1 row)
select count(*) from ((select * from test_tablesample tablesample SYSTEM(20) REPEATABLE (200) limit 1) union (select * from test_tablesample tablesample SYSTEM(20) REPEATABLE (200) limit 1));
count
-------
1
(1 row)
explain (costs off) select * from test_tablesample tablesample BERNOULLI(50) REPEATABLE (200) left join test_tablesample2 tablesample BERNOULLI(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
QUERY PLAN
---------------------------------------------------------------------------------
Hash Anti Join
Hash Cond: (test_tablesample.id = test_tablesample2.id)
-> Sample Scan on test_tablesample
Sampling: bernoulli (50::real) REPEATABLE (200::double precision)
-> Hash
-> Sample Scan on test_tablesample2
Sampling: bernoulli (50::real) REPEATABLE (200::double precision)
(7 rows)
select * from test_tablesample tablesample BERNOULLI(50) REPEATABLE (200) left join test_tablesample2 tablesample BERNOULLI(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
id | name | salary | id | name | salary
----+------+--------+----+------+--------
(0 rows)
set enable_hashjoin to off;
explain (costs off) select * from test_tablesample tablesample BERNOULLI(50) REPEATABLE (200) left join test_tablesample2 tablesample BERNOULLI(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
QUERY PLAN
---------------------------------------------------------------------------------
Merge Anti Join
Merge Cond: (test_tablesample.id = test_tablesample2.id)
-> Sort
Sort Key: test_tablesample.id
-> Sample Scan on test_tablesample
Sampling: bernoulli (50::real) REPEATABLE (200::double precision)
-> Sort
Sort Key: test_tablesample2.id
-> Sample Scan on test_tablesample2
Sampling: bernoulli (50::real) REPEATABLE (200::double precision)
(10 rows)
select * from test_tablesample tablesample BERNOULLI(50) REPEATABLE (200) left join test_tablesample2 tablesample BERNOULLI(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
id | name | salary | id | name | salary
----+------+--------+----+------+--------
(0 rows)
set enable_mergejoin to off;
explain (costs off) select * from test_tablesample tablesample BERNOULLI(50) REPEATABLE (200) left join test_tablesample2 tablesample BERNOULLI(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
QUERY PLAN
---------------------------------------------------------------------------------
Nested Loop Anti Join
Join Filter: (test_tablesample.id = test_tablesample2.id)
-> Sample Scan on test_tablesample
Sampling: bernoulli (50::real) REPEATABLE (200::double precision)
-> Materialize
-> Sample Scan on test_tablesample2
Sampling: bernoulli (50::real) REPEATABLE (200::double precision)
(7 rows)
select * from test_tablesample tablesample BERNOULLI(50) REPEATABLE (200) left join test_tablesample2 tablesample BERNOULLI(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
id | name | salary | id | name | salary
----+------+--------+----+------+--------
(0 rows)
set enable_material to off;
explain (costs off) select * from test_tablesample tablesample BERNOULLI(50) REPEATABLE (200) left join test_tablesample2 tablesample BERNOULLI(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
QUERY PLAN
---------------------------------------------------------------------------
Nested Loop Anti Join
Join Filter: (test_tablesample.id = test_tablesample2.id)
-> Sample Scan on test_tablesample
Sampling: bernoulli (50::real) REPEATABLE (200::double precision)
-> Sample Scan on test_tablesample2
Sampling: bernoulli (50::real) REPEATABLE (200::double precision)
(6 rows)
select * from test_tablesample tablesample BERNOULLI(50) REPEATABLE (200) left join test_tablesample2 tablesample BERNOULLI(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
id | name | salary | id | name | salary
----+------+--------+----+------+--------
(0 rows)
explain (costs off) select * from test_tablesample tablesample SYSTEM(50) REPEATABLE (200) left join test_tablesample2 tablesample SYSTEM(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
QUERY PLAN
------------------------------------------------------------------------
Nested Loop Anti Join
Join Filter: (test_tablesample.id = test_tablesample2.id)
-> Sample Scan on test_tablesample
Sampling: system (50::real) REPEATABLE (200::double precision)
-> Sample Scan on test_tablesample2
Sampling: system (50::real) REPEATABLE (200::double precision)
(6 rows)
select * from test_tablesample tablesample SYSTEM(50) REPEATABLE (200) left join test_tablesample2 tablesample SYSTEM(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
id | name | salary | id | name | salary
----+------+--------+----+------+--------
(0 rows)
drop table test_tablesample;
drop table test_tablesample2;
create table test_tablesample(id int, name text, salary numeric) with (orientation=column);
create table test_tablesample2(id int, name text, salary numeric) with (orientation=column);
insert into test_tablesample values(generate_series(1, 50), 'row'|| generate_series(1,50), generate_series(1, 50));
insert into test_tablesample2 values(generate_series(1, 50), 'row'|| generate_series(1,50), generate_series(1, 50));
analyze test_tablesample;
analyze test_tablesample2;
-- union same query, should return only 1 row
select count(*) from ((select * from test_tablesample tablesample BERNOULLI(10) REPEATABLE (200) limit 1) union (select * from test_tablesample tablesample BERNOULLI(10) REPEATABLE (200) limit 1));
count
-------
1
(1 row)
select count(*) from ((select * from test_tablesample tablesample SYSTEM(30) REPEATABLE (200) limit 1) union (select * from test_tablesample tablesample SYSTEM(30) REPEATABLE (200) limit 1));
count
-------
1
(1 row)
explain (costs off) select * from test_tablesample tablesample BERNOULLI(50) REPEATABLE (200) left join test_tablesample2 tablesample BERNOULLI(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
QUERY PLAN
---------------------------------------------------------------------------------
Row Adapter
-> Vector Nest Loop Anti Join
Join Filter: (test_tablesample.id = test_tablesample2.id)
-> VecSample Scan on test_tablesample
Sampling: bernoulli (50::real) REPEATABLE (200::double precision)
-> VecSample Scan on test_tablesample2
Sampling: bernoulli (50::real) REPEATABLE (200::double precision)
(7 rows)
select * from test_tablesample tablesample BERNOULLI(50) REPEATABLE (200) left join test_tablesample2 tablesample BERNOULLI(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
id | name | salary | id | name | salary
----+------+--------+----+------+--------
(0 rows)
set enable_hashjoin to off;
explain (costs off) select * from test_tablesample tablesample BERNOULLI(50) REPEATABLE (200) left join test_tablesample2 tablesample BERNOULLI(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
QUERY PLAN
---------------------------------------------------------------------------------
Row Adapter
-> Vector Nest Loop Anti Join
Join Filter: (test_tablesample.id = test_tablesample2.id)
-> VecSample Scan on test_tablesample
Sampling: bernoulli (50::real) REPEATABLE (200::double precision)
-> VecSample Scan on test_tablesample2
Sampling: bernoulli (50::real) REPEATABLE (200::double precision)
(7 rows)
select * from test_tablesample tablesample BERNOULLI(50) REPEATABLE (200) left join test_tablesample2 tablesample BERNOULLI(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
id | name | salary | id | name | salary
----+------+--------+----+------+--------
(0 rows)
set enable_mergejoin to off;
explain (costs off) select * from test_tablesample tablesample BERNOULLI(50) REPEATABLE (200) left join test_tablesample2 tablesample BERNOULLI(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
QUERY PLAN
---------------------------------------------------------------------------------
Row Adapter
-> Vector Nest Loop Anti Join
Join Filter: (test_tablesample.id = test_tablesample2.id)
-> VecSample Scan on test_tablesample
Sampling: bernoulli (50::real) REPEATABLE (200::double precision)
-> VecSample Scan on test_tablesample2
Sampling: bernoulli (50::real) REPEATABLE (200::double precision)
(7 rows)
select * from test_tablesample tablesample BERNOULLI(50) REPEATABLE (200) left join test_tablesample2 tablesample BERNOULLI(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
id | name | salary | id | name | salary
----+------+--------+----+------+--------
(0 rows)
set enable_material to off;
explain (costs off) select * from test_tablesample tablesample BERNOULLI(50) REPEATABLE (200) left join test_tablesample2 tablesample BERNOULLI(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
QUERY PLAN
---------------------------------------------------------------------------------
Row Adapter
-> Vector Nest Loop Anti Join
Join Filter: (test_tablesample.id = test_tablesample2.id)
-> VecSample Scan on test_tablesample
Sampling: bernoulli (50::real) REPEATABLE (200::double precision)
-> VecSample Scan on test_tablesample2
Sampling: bernoulli (50::real) REPEATABLE (200::double precision)
(7 rows)
select * from test_tablesample tablesample BERNOULLI(50) REPEATABLE (200) left join test_tablesample2 tablesample BERNOULLI(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
id | name | salary | id | name | salary
----+------+--------+----+------+--------
(0 rows)
explain (costs off) select * from test_tablesample tablesample SYSTEM(50) REPEATABLE (200) left join test_tablesample2 tablesample SYSTEM(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
QUERY PLAN
------------------------------------------------------------------------------
Row Adapter
-> Vector Nest Loop Anti Join
Join Filter: (test_tablesample.id = test_tablesample2.id)
-> VecSample Scan on test_tablesample
Sampling: system (50::real) REPEATABLE (200::double precision)
-> VecSample Scan on test_tablesample2
Sampling: system (50::real) REPEATABLE (200::double precision)
(7 rows)
select * from test_tablesample tablesample SYSTEM(50) REPEATABLE (200) left join test_tablesample2 tablesample SYSTEM(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
id | name | salary | id | name | salary
----+------+--------+----+------+--------
(0 rows)
drop table test_tablesample;
drop table test_tablesample2;
create table test_tablesample(id int, name text, salary numeric) with (storage_type=ustore);
create table test_tablesample2(id int, name text, salary numeric) with (storage_type=ustore);
insert into test_tablesample select generate_series(1, 500), 'row'|| generate_series(1,500), generate_series(1, 500);
insert into test_tablesample2 select * from test_tablesample;
analyze test_tablesample;
analyze test_tablesample2;
-- union same query, should return only 1 row
select count(*) from ((select * from test_tablesample tablesample BERNOULLI(10) REPEATABLE (200) limit 1) union (select * from test_tablesample tablesample BERNOULLI(10) REPEATABLE (200) limit 1));
count
-------
1
(1 row)
select count(*) from ((select * from test_tablesample tablesample SYSTEM(70) REPEATABLE (200) limit 1) union (select * from test_tablesample tablesample SYSTEM(70) REPEATABLE (200) limit 1));
count
-------
1
(1 row)
explain (costs off) select * from test_tablesample tablesample BERNOULLI(50) REPEATABLE (200) left join test_tablesample2 tablesample BERNOULLI(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
QUERY PLAN
---------------------------------------------------------------------------
Nested Loop Anti Join
Join Filter: (test_tablesample.id = test_tablesample2.id)
-> Sample Scan on test_tablesample
Sampling: bernoulli (50::real) REPEATABLE (200::double precision)
-> Sample Scan on test_tablesample2
Sampling: bernoulli (50::real) REPEATABLE (200::double precision)
(6 rows)
select * from test_tablesample tablesample BERNOULLI(50) REPEATABLE (200) left join test_tablesample2 tablesample BERNOULLI(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
id | name | salary | id | name | salary
----+------+--------+----+------+--------
(0 rows)
set enable_hashjoin to off;
explain (costs off) select * from test_tablesample tablesample BERNOULLI(50) REPEATABLE (200) left join test_tablesample2 tablesample BERNOULLI(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
QUERY PLAN
---------------------------------------------------------------------------
Nested Loop Anti Join
Join Filter: (test_tablesample.id = test_tablesample2.id)
-> Sample Scan on test_tablesample
Sampling: bernoulli (50::real) REPEATABLE (200::double precision)
-> Sample Scan on test_tablesample2
Sampling: bernoulli (50::real) REPEATABLE (200::double precision)
(6 rows)
select * from test_tablesample tablesample BERNOULLI(50) REPEATABLE (200) left join test_tablesample2 tablesample BERNOULLI(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
id | name | salary | id | name | salary
----+------+--------+----+------+--------
(0 rows)
set enable_mergejoin to off;
explain (costs off) select * from test_tablesample tablesample BERNOULLI(50) REPEATABLE (200) left join test_tablesample2 tablesample BERNOULLI(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
QUERY PLAN
---------------------------------------------------------------------------
Nested Loop Anti Join
Join Filter: (test_tablesample.id = test_tablesample2.id)
-> Sample Scan on test_tablesample
Sampling: bernoulli (50::real) REPEATABLE (200::double precision)
-> Sample Scan on test_tablesample2
Sampling: bernoulli (50::real) REPEATABLE (200::double precision)
(6 rows)
select * from test_tablesample tablesample BERNOULLI(50) REPEATABLE (200) left join test_tablesample2 tablesample BERNOULLI(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
id | name | salary | id | name | salary
----+------+--------+----+------+--------
(0 rows)
set enable_material to off;
explain (costs off) select * from test_tablesample tablesample BERNOULLI(50) REPEATABLE (200) left join test_tablesample2 tablesample BERNOULLI(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
QUERY PLAN
---------------------------------------------------------------------------
Nested Loop Anti Join
Join Filter: (test_tablesample.id = test_tablesample2.id)
-> Sample Scan on test_tablesample
Sampling: bernoulli (50::real) REPEATABLE (200::double precision)
-> Sample Scan on test_tablesample2
Sampling: bernoulli (50::real) REPEATABLE (200::double precision)
(6 rows)
select * from test_tablesample tablesample BERNOULLI(50) REPEATABLE (200) left join test_tablesample2 tablesample BERNOULLI(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
id | name | salary | id | name | salary
----+------+--------+----+------+--------
(0 rows)
explain (costs off) select * from test_tablesample tablesample SYSTEM(50) REPEATABLE (200) left join test_tablesample2 tablesample SYSTEM(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
QUERY PLAN
------------------------------------------------------------------------
Nested Loop Anti Join
Join Filter: (test_tablesample.id = test_tablesample2.id)
-> Sample Scan on test_tablesample
Sampling: system (50::real) REPEATABLE (200::double precision)
-> Sample Scan on test_tablesample2
Sampling: system (50::real) REPEATABLE (200::double precision)
(6 rows)
select * from test_tablesample tablesample SYSTEM(50) REPEATABLE (200) left join test_tablesample2 tablesample SYSTEM(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
id | name | salary | id | name | salary
----+------+--------+----+------+--------
(0 rows)
reset search_path;
drop schema tablesample_schema4 cascade;
NOTICE: drop cascades to 2 other objects
DETAIL: drop cascades to table tablesample_schema4.test_tablesample
drop cascades to table tablesample_schema4.test_tablesample2

2
src/test/regress/parallel_schedule0
View File

@ -662,7 +662,7 @@ test: bypass_preparedexecute_support
test: sqlbypass_partition
test: sqlbypass_partition_prepare
test: string_digit_to_numeric
test: string_digit_to_numeric tablesample_3
# Another group of parallel tests
# ----------
#test: collate tablesample tablesample_1 tablesample_2 matview

99
src/test/regress/sql/tablesample_3.sql Executable file
View File

@ -0,0 +1,99 @@
create schema tablesample_schema4;
set current_schema = tablesample_schema4;
create table test_tablesample(id int, name text, salary numeric);
create table test_tablesample2(id int, name text, salary numeric);
insert into test_tablesample select generate_series(1, 3000), 'row'|| generate_series(1,3000), generate_series(1, 3000);
insert into test_tablesample2 select * from test_tablesample;
analyze test_tablesample;
analyze test_tablesample2;
-- union same query, should return only 1 row
select count(*) from ((select * from test_tablesample tablesample BERNOULLI(5) REPEATABLE (200) limit 1) union (select * from test_tablesample tablesample BERNOULLI(5) REPEATABLE (200) limit 1));
select count(*) from ((select * from test_tablesample tablesample SYSTEM(20) REPEATABLE (200) limit 1) union (select * from test_tablesample tablesample SYSTEM(20) REPEATABLE (200) limit 1));
explain (costs off) select * from test_tablesample tablesample BERNOULLI(50) REPEATABLE (200) left join test_tablesample2 tablesample BERNOULLI(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
select * from test_tablesample tablesample BERNOULLI(50) REPEATABLE (200) left join test_tablesample2 tablesample BERNOULLI(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
set enable_hashjoin to off;
explain (costs off) select * from test_tablesample tablesample BERNOULLI(50) REPEATABLE (200) left join test_tablesample2 tablesample BERNOULLI(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
select * from test_tablesample tablesample BERNOULLI(50) REPEATABLE (200) left join test_tablesample2 tablesample BERNOULLI(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
set enable_mergejoin to off;
explain (costs off) select * from test_tablesample tablesample BERNOULLI(50) REPEATABLE (200) left join test_tablesample2 tablesample BERNOULLI(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
select * from test_tablesample tablesample BERNOULLI(50) REPEATABLE (200) left join test_tablesample2 tablesample BERNOULLI(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
set enable_material to off;
explain (costs off) select * from test_tablesample tablesample BERNOULLI(50) REPEATABLE (200) left join test_tablesample2 tablesample BERNOULLI(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
select * from test_tablesample tablesample BERNOULLI(50) REPEATABLE (200) left join test_tablesample2 tablesample BERNOULLI(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
explain (costs off) select * from test_tablesample tablesample SYSTEM(50) REPEATABLE (200) left join test_tablesample2 tablesample SYSTEM(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
select * from test_tablesample tablesample SYSTEM(50) REPEATABLE (200) left join test_tablesample2 tablesample SYSTEM(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
drop table test_tablesample;
drop table test_tablesample2;
create table test_tablesample(id int, name text, salary numeric) with (orientation=column);
create table test_tablesample2(id int, name text, salary numeric) with (orientation=column);
insert into test_tablesample values(generate_series(1, 50), 'row'|| generate_series(1,50), generate_series(1, 50));
insert into test_tablesample2 values(generate_series(1, 50), 'row'|| generate_series(1,50), generate_series(1, 50));
analyze test_tablesample;
analyze test_tablesample2;
-- union same query, should return only 1 row
select count(*) from ((select * from test_tablesample tablesample BERNOULLI(10) REPEATABLE (200) limit 1) union (select * from test_tablesample tablesample BERNOULLI(10) REPEATABLE (200) limit 1));
select count(*) from ((select * from test_tablesample tablesample SYSTEM(30) REPEATABLE (200) limit 1) union (select * from test_tablesample tablesample SYSTEM(30) REPEATABLE (200) limit 1));
explain (costs off) select * from test_tablesample tablesample BERNOULLI(50) REPEATABLE (200) left join test_tablesample2 tablesample BERNOULLI(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
select * from test_tablesample tablesample BERNOULLI(50) REPEATABLE (200) left join test_tablesample2 tablesample BERNOULLI(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
set enable_hashjoin to off;
explain (costs off) select * from test_tablesample tablesample BERNOULLI(50) REPEATABLE (200) left join test_tablesample2 tablesample BERNOULLI(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
select * from test_tablesample tablesample BERNOULLI(50) REPEATABLE (200) left join test_tablesample2 tablesample BERNOULLI(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
set enable_mergejoin to off;
explain (costs off) select * from test_tablesample tablesample BERNOULLI(50) REPEATABLE (200) left join test_tablesample2 tablesample BERNOULLI(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
select * from test_tablesample tablesample BERNOULLI(50) REPEATABLE (200) left join test_tablesample2 tablesample BERNOULLI(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
set enable_material to off;
explain (costs off) select * from test_tablesample tablesample BERNOULLI(50) REPEATABLE (200) left join test_tablesample2 tablesample BERNOULLI(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
select * from test_tablesample tablesample BERNOULLI(50) REPEATABLE (200) left join test_tablesample2 tablesample BERNOULLI(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
explain (costs off) select * from test_tablesample tablesample SYSTEM(50) REPEATABLE (200) left join test_tablesample2 tablesample SYSTEM(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
select * from test_tablesample tablesample SYSTEM(50) REPEATABLE (200) left join test_tablesample2 tablesample SYSTEM(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
drop table test_tablesample;
drop table test_tablesample2;
create table test_tablesample(id int, name text, salary numeric) with (storage_type=ustore);
create table test_tablesample2(id int, name text, salary numeric) with (storage_type=ustore);
insert into test_tablesample select generate_series(1, 500), 'row'|| generate_series(1,500), generate_series(1, 500);
insert into test_tablesample2 select * from test_tablesample;
analyze test_tablesample;
analyze test_tablesample2;
-- union same query, should return only 1 row
select count(*) from ((select * from test_tablesample tablesample BERNOULLI(10) REPEATABLE (200) limit 1) union (select * from test_tablesample tablesample BERNOULLI(10) REPEATABLE (200) limit 1));
select count(*) from ((select * from test_tablesample tablesample SYSTEM(70) REPEATABLE (200) limit 1) union (select * from test_tablesample tablesample SYSTEM(70) REPEATABLE (200) limit 1));
explain (costs off) select * from test_tablesample tablesample BERNOULLI(50) REPEATABLE (200) left join test_tablesample2 tablesample BERNOULLI(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
select * from test_tablesample tablesample BERNOULLI(50) REPEATABLE (200) left join test_tablesample2 tablesample BERNOULLI(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
set enable_hashjoin to off;
explain (costs off) select * from test_tablesample tablesample BERNOULLI(50) REPEATABLE (200) left join test_tablesample2 tablesample BERNOULLI(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
select * from test_tablesample tablesample BERNOULLI(50) REPEATABLE (200) left join test_tablesample2 tablesample BERNOULLI(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
set enable_mergejoin to off;
explain (costs off) select * from test_tablesample tablesample BERNOULLI(50) REPEATABLE (200) left join test_tablesample2 tablesample BERNOULLI(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
select * from test_tablesample tablesample BERNOULLI(50) REPEATABLE (200) left join test_tablesample2 tablesample BERNOULLI(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
set enable_material to off;
explain (costs off) select * from test_tablesample tablesample BERNOULLI(50) REPEATABLE (200) left join test_tablesample2 tablesample BERNOULLI(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
select * from test_tablesample tablesample BERNOULLI(50) REPEATABLE (200) left join test_tablesample2 tablesample BERNOULLI(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
explain (costs off) select * from test_tablesample tablesample SYSTEM(50) REPEATABLE (200) left join test_tablesample2 tablesample SYSTEM(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
select * from test_tablesample tablesample SYSTEM(50) REPEATABLE (200) left join test_tablesample2 tablesample SYSTEM(50) REPEATABLE (200) on test_tablesample.id=test_tablesample2.id where test_tablesample2.id is NULL;
reset search_path;
drop schema tablesample_schema4 cascade;