mirror of
https://github.com/MariaDB/server.git
synced 2025-01-31 02:51:44 +01:00
531acda484
Make sure that SELECT_LEX_UNIT::derived, behaves as documented (points to the "TABLE_LIST representing this union in the embedding select"). For recursive CTE this was not necessarily the case, it could've pointed to the TABLE_LIST inside the CTE, not in the embedding select. To fix: * don't update unit->derived in mysql_derived_prepare(), pass derived as an argument to st_select_lex_unit::prepare() * prefer to set unit->derived in TABLE_LIST::init_derived() to the TABLE_LIST in the embedding select, not to the recursive reference. Fail if there are many TABLE_LISTs in the embedding select with conflicting FOR SYSTEM_TIME clauses. cleanup: * remove redundant THD* argument from st_select_lex_unit::prepare()
226 lines
5.4 KiB
Text
226 lines
5.4 KiB
Text
-- source include/have_innodb.inc
|
|
set time_zone="+00:00";
|
|
set default_storage_engine=innodb;
|
|
create or replace table dept (
|
|
dept_id int(10) primary key,
|
|
name varchar(100)
|
|
) with system versioning;
|
|
|
|
create or replace table emp (
|
|
emp_id int(10) primary key,
|
|
dept_id int(10) not null,
|
|
name varchar(100) not null,
|
|
mgr int(10),
|
|
salary int(10) not null,
|
|
constraint `dept-emp-fk`
|
|
foreign key (dept_id) references dept (dept_id)
|
|
on delete cascade
|
|
on update restrict,
|
|
constraint `mgr-fk`
|
|
foreign key (mgr) references emp (emp_id)
|
|
on delete restrict
|
|
on update restrict
|
|
) with system versioning;
|
|
|
|
insert into dept (dept_id, name) values (10, "accounting");
|
|
|
|
insert into emp (emp_id, name, salary, dept_id, mgr) values
|
|
(1, "bill", 1000, 10, null),
|
|
(20, "john", 500, 10, 1),
|
|
(30, "jane", 750, 10,1 );
|
|
|
|
select row_start into @ts_1 from emp where name="jane";
|
|
|
|
update emp set mgr=30 where name ="john";
|
|
|
|
explain extended
|
|
with ancestors as (
|
|
select e.emp_id, e.name, e.mgr, e.salary from emp as e where name = 'bill'
|
|
union
|
|
select e.emp_id, e.name, e.mgr, e.salary from emp as e
|
|
) select * from ancestors for system_time as of @ts_1;
|
|
|
|
select row_start into @ts_2 from emp where name="john";
|
|
|
|
let $q=
|
|
/* All report to 'Bill' */
|
|
with recursive
|
|
ancestors
|
|
as
|
|
(
|
|
select e.emp_id, e.name, e.mgr, e.salary
|
|
from emp for system_time as of timestamp @ts_1 as e
|
|
where name = 'bill'
|
|
union
|
|
select e.emp_id, e.name, e.mgr, e.salary
|
|
from emp for system_time as of timestamp @ts_1 as e,
|
|
ancestors as a
|
|
where e.mgr = a.emp_id
|
|
)
|
|
select * from ancestors;
|
|
|
|
eval explain extended $q;
|
|
eval $q;
|
|
|
|
let $q=with recursive
|
|
ancestors
|
|
as
|
|
(
|
|
select e.emp_id, e.name, e.mgr, e.salary
|
|
from emp as e
|
|
where name = 'bill'
|
|
union
|
|
select e.emp_id, e.name, e.mgr, e.salary
|
|
from emp as e,
|
|
ancestors as a
|
|
where e.mgr = a.emp_id
|
|
)
|
|
select * from ancestors for system_time as of timestamp @ts_1;
|
|
|
|
eval explain extended $q;
|
|
eval $q;
|
|
|
|
let $q=with recursive
|
|
ancestors
|
|
as
|
|
(
|
|
select e.emp_id, e.name, e.mgr, e.salary
|
|
from emp as e
|
|
where name = 'bill'
|
|
union
|
|
select e.emp_id, e.name, e.mgr, e.salary
|
|
from emp as e,
|
|
ancestors as a
|
|
where e.mgr = a.emp_id
|
|
)
|
|
select name from emp where emp_id in (select emp_id from ancestors for system_time as of timestamp @ts_1);
|
|
|
|
eval explain extended $q;
|
|
eval $q;
|
|
|
|
with recursive
|
|
ancestors
|
|
as
|
|
(
|
|
select e.emp_id, e.name, e.mgr, e.salary
|
|
from emp as e
|
|
where name = 'bill'
|
|
union
|
|
select e.emp_id, e.name, e.mgr, e.salary
|
|
from emp as e,
|
|
ancestors as a
|
|
where e.mgr = a.emp_id
|
|
)
|
|
select * from ancestors for system_time as of @ts_2,
|
|
ancestors for system_time as of @ts_2 a2;
|
|
|
|
--error ER_CONFLICTING_FOR_SYSTEM_TIME
|
|
with recursive
|
|
ancestors
|
|
as
|
|
(
|
|
select e.emp_id, e.name, e.mgr, e.salary
|
|
from emp as e
|
|
where name = 'bill'
|
|
union
|
|
select e.emp_id, e.name, e.mgr, e.salary
|
|
from emp as e,
|
|
ancestors as a
|
|
where e.mgr = a.emp_id
|
|
)
|
|
select * from ancestors for system_time as of @ts_2,
|
|
ancestors for system_time as of now() a2;
|
|
|
|
--error ER_CONFLICTING_FOR_SYSTEM_TIME
|
|
with recursive
|
|
ancestors
|
|
as
|
|
(
|
|
select e.emp_id, e.name, e.mgr, e.salary
|
|
from emp as e
|
|
where name = 'bill'
|
|
union
|
|
select e.emp_id, e.name, e.mgr, e.salary
|
|
from emp as e,
|
|
ancestors as a
|
|
where e.mgr = a.emp_id
|
|
)
|
|
select * from ancestors,
|
|
ancestors for system_time as of @ts_2 a2;
|
|
|
|
--error ER_CONFLICTING_FOR_SYSTEM_TIME
|
|
with recursive
|
|
ancestors
|
|
as
|
|
(
|
|
select e.emp_id, e.name, e.mgr, e.salary
|
|
from emp as e
|
|
where name = 'bill'
|
|
union
|
|
select e.emp_id, e.name, e.mgr, e.salary
|
|
from emp as e,
|
|
ancestors as a
|
|
where e.mgr = a.emp_id
|
|
)
|
|
select * from ancestors for system_time as of @ts_2,
|
|
ancestors a2;
|
|
|
|
--error ER_CONFLICTING_FOR_SYSTEM_TIME
|
|
with recursive
|
|
ancestors
|
|
as
|
|
(
|
|
select e.emp_id, e.name, e.mgr, e.salary
|
|
from emp as e
|
|
where name = 'bill'
|
|
union
|
|
select e.emp_id, e.name, e.mgr, e.salary
|
|
from emp as e,
|
|
ancestors as a
|
|
where e.mgr = a.emp_id
|
|
)
|
|
select * from ancestors for system_time as of @ts_2
|
|
where emp_id in (select * from ancestors);
|
|
|
|
--echo # SYSTEM_TIME to internal recursive instance is prohibited
|
|
--error ER_VERS_NOT_VERSIONED
|
|
with recursive cte as
|
|
(
|
|
select * from emp
|
|
union all
|
|
select * from cte for system_time as of @ts_1
|
|
)
|
|
select * from cte;
|
|
|
|
create or replace table emp ( emp_id int, name varchar(127), mgr int) with system versioning;
|
|
create or replace table addr ( emp_id int, address varchar(100)) with system versioning;
|
|
insert emp values (1, 'bill', 0), (2, 'bill', 1), (3, 'kate', 1);
|
|
insert addr values (1, 'Moscow'), (2, 'New York'), (3, 'London');
|
|
set @ts=now(6);
|
|
delete from emp;
|
|
delete from addr;
|
|
|
|
with recursive
|
|
ancestors
|
|
as
|
|
(
|
|
select e.emp_id, e.name, e.mgr
|
|
from emp for system_time as of timestamp @ts as e
|
|
where name = 'bill'
|
|
union
|
|
select ee.emp_id, ee.name, ee.mgr
|
|
from emp for system_time as of timestamp @ts as ee, ancestors as a
|
|
where ee.mgr = a.emp_id
|
|
)
|
|
select * from ancestors;
|
|
|
|
insert emp values (4, 'john', 1);
|
|
insert addr values (4, 'Paris');
|
|
with ancestors as (select * from emp natural join addr) select * from ancestors;
|
|
with ancestors as (select * from emp natural join addr) select * from ancestors for system_time all;
|
|
with ancestors as (select * from (select * from emp natural join addr) for system_time all as t) select * from ancestors;
|
|
select * from (select * from emp natural join addr) for system_time all as t;
|
|
|
|
drop table emp;
|
|
drop table dept;
|
|
drop table addr;
|