SQL: CREATE VIEW with view_list from versioned table [fixes #151]

This commit is contained in:
kevg 2017-03-13 14:29:21 +03:00 committed by Aleksey Midenkov
parent 4782b74023
commit a37cf5258b
3 changed files with 22 additions and 4 deletions

View file

@ -110,6 +110,8 @@ x
1
select * from vvvt1 for system_time all;
x
create or replace table t1 (x int) with system versioning;
create or replace view vt1(c) as select x from t1;
drop view vvvt1;
drop view vvt1;
drop view vt1;

View file

@ -70,6 +70,9 @@ select * from vt1 for system_time all;
select * from vvt1 for system_time all;
select * from vvvt1 for system_time all;
create or replace table t1 (x int) with system versioning;
create or replace view vt1(c) as select x from t1;
drop view vvvt1;
drop view vvt1;
drop view vt1;

View file

@ -463,12 +463,25 @@ bool mysql_create_view(THD *thd, TABLE_LIST *views,
TABLE_SHARE *s= tl->table->s;
if (s->versioned)
{
const char *start= s->vers_start_field()->field_name;
const char *end = s->vers_end_field()->field_name;
select_lex->item_list.push_back(new (thd->mem_root) Item_field(
thd, &select_lex->context, NULL, NULL,
s->vers_start_field()->field_name));
thd, &select_lex->context, NULL, NULL, start));
select_lex->item_list.push_back(new (thd->mem_root) Item_field(
thd, &select_lex->context, NULL, NULL,
s->vers_end_field()->field_name));
thd, &select_lex->context, NULL, NULL, end));
if (lex->view_list.elements)
{
if (LEX_STRING *s= thd->make_lex_string(start, strlen(start)))
lex->view_list.push_back(s);
else
goto err;
if (LEX_STRING *s= thd->make_lex_string(end, strlen(end)))
lex->view_list.push_back(s);
else
goto err;
}
}
}
}