Changeset: b5fb4f3fdc2d for MonetDB
URL: https://dev.monetdb.org/hg/MonetDB?cmd=changeset;node=b5fb4f3fdc2d
Added Files:
sql/test/miscellaneous/Tests/update_delete_aliases.sql
sql/test/miscellaneous/Tests/update_delete_aliases.stable.err
sql/test/miscellaneous/Tests/update_delete_aliases.stable.out
Modified Files:
clients/mapiclient/mhelp.c
sql/server/rel_updates.c
sql/server/sql_parser.y
sql/test/miscellaneous/Tests/All
Branch: merge-statements
Log Message:
Added optional aliases for update and delete statements
Exemplifying queries:
update t1 as a1 set col1=n where a1.col2=m;
delete from t1 as a1 where a1.col1=n;
diffs (truncated from 327 to 300 lines):
diff --git a/clients/mapiclient/mhelp.c b/clients/mapiclient/mhelp.c
--- a/clients/mapiclient/mhelp.c
+++ b/clients/mapiclient/mhelp.c
@@ -275,7 +275,7 @@ SQLhelp sqlhelp[] = {
NULL},
{"DELETE",
"",
- "[ WITH with_list ] DELETE FROM qname [ WHERE search_condition ]",
+ "[ WITH with_list ] DELETE FROM qname [ [AS] ident ] [ WHERE
search_condition ]",
"with_list,search_condition",
NULL},
{"DROP AGGREGATE",
@@ -478,7 +478,7 @@ SQLhelp sqlhelp[] = {
NULL},
{"UPDATE",
"",
- "[ WITH with_list ] UPDATE qname SET assignment_list [ WHERE
search_condition ]",
+ "[ WITH with_list ] UPDATE qname [ [AS] ident ] SET assignment_list [
WHERE search_condition ]",
"with_list,assignment_list,search_condition",
NULL},
{"WHILE",
diff --git a/sql/server/rel_updates.c b/sql/server/rel_updates.c
--- a/sql/server/rel_updates.c
+++ b/sql/server/rel_updates.c
@@ -886,7 +886,7 @@ update_check_column(mvc *sql, sql_table
}
static sql_rel *
-update_table(mvc *sql, dlist *qname, dlist *assignmentlist, symbol *opt_from,
symbol *opt_where)
+update_table(mvc *sql, dlist *qname, str alias, dlist *assignmentlist, symbol
*opt_from, symbol *opt_where)
{
char *sname = qname_schema(qname);
char *tname = qname_table(qname);
@@ -931,6 +931,10 @@ update_table(mvc *sql, dlist *qname, dli
pcols = mt->part.pexp->cols;
}
res = bt;
+ if(alias) {
+ for(node *nn = res->exps->h ; nn ; nn = nn->next)
+ exp_setname(sql->sa, (sql_exp*) nn->data,
alias, NULL); //the last parameter is optional, hence NULL
+ }
#if 0
dlist *selection = dlist_create(sql->sa);
dlist *from_list = dlist_create(sql->sa);
@@ -983,9 +987,16 @@ update_table(mvc *sql, dlist *qname, dli
for (n = fl->h; n && res; n = n->next) {
fnd = table_ref(sql, NULL, n->data.sym, 0);
- if (fnd)
+ if (fnd) {
+ if(alias) {
+ for(node *nn = fnd->exps->h ;
nn ; nn = nn->next) {
+ sql_exp* ee =
(sql_exp*) nn->data;
+ if(ee->rname &&
!strcmp(ee->rname, alias))
+ return
sql_error(sql, 02, SQLSTATE(42000) "UPDATE: multiple references into table
'%s'", alias);
+ }
+ }
res = rel_crossproduct(sql->sa, res,
fnd, op_join);
- else
+ } else
res = fnd;
}
if (!res)
@@ -1196,7 +1207,7 @@ rel_truncate(sql_allocator *sa, sql_rel
}
static sql_rel *
-delete_table(mvc *sql, dlist *qname, symbol *opt_where)
+delete_table(mvc *sql, dlist *qname, str alias, symbol *opt_where)
{
char *sname = qname_schema(qname);
char *tname = qname_table(qname);
@@ -1236,6 +1247,10 @@ delete_table(mvc *sql, dlist *qname, sym
sql->errstr[0] = 0;
sql->session->status = status;
r = rel_basetable(sql, t, t->base.name );
+ if(alias) {
+ for(node *nn = r->exps->h ; nn ; nn =
nn->next)
+ exp_setname(sql->sa, (sql_exp*)
nn->data, alias, NULL); //the last parameter is optional, hence NULL
+ }
r = rel_logical_exp(sql, r, opt_where,
sql_where);
}
if (!r) {
@@ -1937,7 +1952,8 @@ rel_updates(mvc *sql, symbol *s)
{
dlist *l = s->data.lval;
- ret = update_table(sql, l->h->data.lval, l->h->next->data.lval,
l->h->next->next->data.sym, l->h->next->next->next->data.sym);
+ ret = update_table(sql, l->h->data.lval, l->h->next->data.sval,
l->h->next->next->data.lval,
+
l->h->next->next->next->data.sym, l->h->next->next->next->next->data.sym);
sql->type = Q_UPDATE;
}
break;
@@ -1945,7 +1961,7 @@ rel_updates(mvc *sql, symbol *s)
{
dlist *l = s->data.lval;
- ret = delete_table(sql, l->h->data.lval, l->h->next->data.sym);
+ ret = delete_table(sql, l->h->data.lval, l->h->next->data.sval,
l->h->next->next->data.sym);
sql->type = Q_UPDATE;
}
break;
diff --git a/sql/server/sql_parser.y b/sql/server/sql_parser.y
--- a/sql/server/sql_parser.y
+++ b/sql/server/sql_parser.y
@@ -3028,11 +3028,12 @@ string_commalist_contents:
;
delete_stmt:
- sqlDELETE FROM qname opt_where_clause
+ sqlDELETE FROM qname opt_alias_name opt_where_clause
{ dlist *l = L();
append_list(l, $3);
- append_symbol(l, $4);
+ append_string(l, $4);
+ append_symbol(l, $5);
$$ = _symbol_create_list( SQL_DELETE, l ); }
;
@@ -3058,13 +3059,14 @@ truncate_stmt:
;
update_stmt:
- UPDATE qname SET assignment_commalist opt_from_clause opt_where_clause
+ UPDATE qname opt_alias_name SET assignment_commalist opt_from_clause
opt_where_clause
{ dlist *l = L();
append_list(l, $2);
- append_list(l, $4);
- append_symbol(l, $5);
+ append_string(l, $3);
+ append_list(l, $5);
append_symbol(l, $6);
+ append_symbol(l, $7);
$$ = _symbol_create_list( SQL_UPDATE, l ); }
;
diff --git a/sql/test/miscellaneous/Tests/All b/sql/test/miscellaneous/Tests/All
--- a/sql/test/miscellaneous/Tests/All
+++ b/sql/test/miscellaneous/Tests/All
@@ -1,3 +1,4 @@
declared_tables
#now
trace_test
+update_delete_aliases
diff --git a/sql/test/miscellaneous/Tests/update_delete_aliases.sql
b/sql/test/miscellaneous/Tests/update_delete_aliases.sql
new file mode 100644
--- /dev/null
+++ b/sql/test/miscellaneous/Tests/update_delete_aliases.sql
@@ -0,0 +1,17 @@
+create table updateme (a int, b int);
+create table other (a int, b int);
+insert into updateme values (1,1), (2,2), (3,3);
+
+update updateme as other set a=3 where b=2;
+update updateme as other set a=2 where other.b=3;
+update updateme as other set a=3 where updateme.b=2; --error
+update updateme as other set a=4 from other where other.a=1; --error
+select a, b from updateme;
+
+delete from updateme as other where other.a=3;
+delete from updateme where other.b=2; --error
+delete from updateme as other where updateme.b=2; --error
+select a, b from updateme;
+
+drop table updateme;
+drop table other;
diff --git a/sql/test/miscellaneous/Tests/update_delete_aliases.stable.err
b/sql/test/miscellaneous/Tests/update_delete_aliases.stable.err
new file mode 100644
--- /dev/null
+++ b/sql/test/miscellaneous/Tests/update_delete_aliases.stable.err
@@ -0,0 +1,51 @@
+stderr of test 'update_delete_aliases` in directory 'sql/test/miscellaneous`
itself:
+
+
+# 15:27:52 >
+# 15:27:52 > "mserver5" "--debug=10" "--set" "gdk_nr_threads=0" "--set"
"mapi_open=true" "--set" "mapi_port=37046" "--set"
"mapi_usock=/var/tmp/mtest-19826/.s.monetdb.37046" "--set" "monet_prompt="
"--forcemito"
"--dbpath=/home/ferreira/repositories/MonetDB-default/BUILD/var/MonetDB/mTests_sql_test_miscellaneous"
"--set" "embedded_c=true"
+# 15:27:52 >
+
+# builtin opt gdk_dbpath =
/home/ferreira/repositories/MonetDB-default/BUILD/var/monetdb5/dbfarm/demo
+# builtin opt gdk_debug = 0
+# builtin opt gdk_vmtrim = no
+# builtin opt monet_prompt = >
+# builtin opt monet_daemon = no
+# builtin opt mapi_port = 50000
+# builtin opt mapi_open = false
+# builtin opt mapi_autosense = false
+# builtin opt sql_optimizer = default_pipe
+# builtin opt sql_debug = 0
+# cmdline opt gdk_nr_threads = 0
+# cmdline opt mapi_open = true
+# cmdline opt mapi_port = 37046
+# cmdline opt mapi_usock = /var/tmp/mtest-19826/.s.monetdb.37046
+# cmdline opt monet_prompt =
+# cmdline opt gdk_dbpath =
/home/ferreira/repositories/MonetDB-default/BUILD/var/MonetDB/mTests_sql_test_miscellaneous
+# cmdline opt embedded_c = true
+# cmdline opt gdk_debug = 553648138
+
+# 15:27:53 >
+# 15:27:53 > "mclient" "-lsql" "-ftest" "-tnone" "-Eutf-8" "-i" "-e"
"--host=/var/tmp/mtest-19826" "--port=37046"
+# 15:27:53 >
+
+MAPI = (monetdb) /var/tmp/mtest-19826/.s.monetdb.37046
+QUERY = update updateme as other set a=3 where updateme.b=2; --error
+ERROR = !SELECT: no such column 'updateme.b'
+CODE = 42S22
+MAPI = (monetdb) /var/tmp/mtest-19826/.s.monetdb.37046
+QUERY = update updateme as other set a=4 from other where other.a=1; --error
+ERROR = !UPDATE: multiple references into table 'other'
+CODE = 42000
+MAPI = (monetdb) /var/tmp/mtest-19826/.s.monetdb.37046
+QUERY = delete from updateme where other.b=2; --error
+ERROR = !SELECT: no such column 'other.b'
+CODE = 42S22
+MAPI = (monetdb) /var/tmp/mtest-19826/.s.monetdb.37046
+QUERY = delete from updateme as other where updateme.b=2; --error
+ERROR = !SELECT: no such column 'updateme.b'
+CODE = 42S22
+
+# 15:27:53 >
+# 15:27:53 > "Done."
+# 15:27:53 >
+
diff --git a/sql/test/miscellaneous/Tests/update_delete_aliases.stable.out
b/sql/test/miscellaneous/Tests/update_delete_aliases.stable.out
new file mode 100644
--- /dev/null
+++ b/sql/test/miscellaneous/Tests/update_delete_aliases.stable.out
@@ -0,0 +1,98 @@
+stdout of test 'update_delete_aliases` in directory 'sql/test/miscellaneous`
itself:
+
+
+# 15:34:26 >
+# 15:34:26 > "mserver5" "--debug=10" "--set" "gdk_nr_threads=0" "--set"
"mapi_open=true" "--set" "mapi_port=38079" "--set"
"mapi_usock=/var/tmp/mtest-23035/.s.monetdb.38079" "--set" "monet_prompt="
"--forcemito"
"--dbpath=/home/ferreira/repositories/MonetDB-default/BUILD/var/MonetDB/mTests_sql_test_miscellaneous"
"--set" "embedded_c=true"
+# 15:34:26 >
+
+# MonetDB 5 server v11.32.0# MonetDB5 server v11.32.0 (hg id: 0d6a22537b43+)
+# This is an unreleased version
+# Serving database 'mTests_sql_test_miscellaneous', using 8 threads
+# Compiled for x86_64-pc-linux-gnu/64bit with 128bit integers
+# Found 15.492 GiB available main-memory.
+# Copyright (c) 1993 - July 2008 CWI.
+# Copyright (c) August 2008 - 2018 MonetDB B.V., all rights reserved
+# Visit https://www.monetdb.org/ for further information
+# Listening for connection requests on mapi:monetdb://wired-142.cwi.nl:38079/
+# Listening for UNIX domain connection requests on
mapi:monetdb:///var/tmp/mtest-23035/.s.monetdb.38079
+# MonetDB/GIS module loaded
+# SQL catalog created, loading sql scripts once
+# loading sql script: 09_like.sql
+# loading sql script: 10_math.sql
+# loading sql script: 11_times.sql
+# loading sql script: 12_url.sql
+# loading sql script: 13_date.sql
+# loading sql script: 14_inet.sql
+# loading sql script: 15_querylog.sql
+# loading sql script: 16_tracelog.sql
+# loading sql script: 17_temporal.sql
+# loading sql script: 18_index.sql
+# loading sql script: 20_vacuum.sql
+# loading sql script: 21_dependency_views.sql
+# loading sql script: 22_clients.sql
+# loading sql script: 23_skyserver.sql
+# loading sql script: 25_debug.sql
+# loading sql script: 26_sysmon.sql
+# loading sql script: 27_rejects.sql
+# loading sql script: 39_analytics.sql
+# loading sql script: 39_analytics_hge.sql
+# loading sql script: 40_geom.sql
+# loading sql script: 40_json.sql
+# loading sql script: 40_json_hge.sql
+# loading sql script: 41_md5sum.sql
+# loading sql script: 45_uuid.sql
+# loading sql script: 46_profiler.sql
+# loading sql script: 51_sys_schema_extension.sql
+# loading sql script: 60_wlcr.sql
+# loading sql script: 72_fits.sql
+# loading sql script: 74_netcdf.sql
+# loading sql script: 75_lidar.sql
+# loading sql script: 75_shp.sql
+# loading sql script: 75_storagemodel.sql
+# loading sql script: 80_statistics.sql
+# loading sql script: 80_udf.sql
+# loading sql script: 80_udf_hge.sql
+# loading sql script: 85_bam.sql
+# loading sql script: 90_generator.sql
+# loading sql script: 90_generator_hge.sql
+# loading sql script: 99_system.sql
+# MonetDB/SQL module loaded
+
+Ready.
+
+# 15:34:26 >
+# 15:34:26 > "mclient" "-lsql" "-ftest" "-tnone" "-Eutf-8" "-i" "-e"
"--host=/var/tmp/mtest-23035" "--port=38079"
+# 15:34:26 >
+
+#create table updateme (a int, b int);
+#create table other (a int, b int);
+#insert into updateme values (1,1), (2,2), (3,3);
+[ 3 ]
+#update updateme as other set a=3 where b=2;
_______________________________________________
checkin-list mailing list
[email protected]
https://www.monetdb.org/mailman/listinfo/checkin-list
